From 39cb2329f5b215fb5788c2f43530f766ddf5be7a Mon Sep 17 00:00:00 2001 From: HAHA Date: Thu, 23 Jun 2022 15:48:11 +0800 Subject: [PATCH 1/5] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E6=8A=9B=E5=87=BA?= =?UTF-8?q?=E5=BC=82=E5=B8=B8=E4=BF=A1=E6=81=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../service/impl/IcResiUserServiceImpl.java | 26 ++++++------------- 1 file changed, 8 insertions(+), 18 deletions(-) diff --git a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/IcResiUserServiceImpl.java b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/IcResiUserServiceImpl.java index 3a01487589..9172544598 100644 --- a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/IcResiUserServiceImpl.java +++ b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/IcResiUserServiceImpl.java @@ -2611,32 +2611,24 @@ public class IcResiUserServiceImpl extends BaseServiceImpl result = guardarDatosFeignClient.getResidentDetailByIdCard(dto); ResidentByIdCardResultDTO residentDetailByIdCard = result.getData(); - if (org.springframework.util.StringUtils.isEmpty(residentDetailByIdCard)) { - throw new RenException("获取不到人的信息"); - } - // 根据房屋id获取房屋信息 - if (StringUtils.isBlank(form.getHomeId())) { - throw new RenException("房屋id不能为空"); + if(!result.success() || residentDetailByIdCard == null){ + throw new EpmetException(EpmetErrorCode.EPMET_COMMON_OPERATION_FAIL.getCode(), "获取居民信息失败", "获取居民信息失败"); } HouseInfoCache houseInfo = CustomerIcHouseRedis.getHouseInfo(form.getCustomerId(), form.getHomeId()); - if (org.springframework.util.StringUtils.isEmpty(houseInfo)) { - throw new RenException("获取不到房屋信息"); + if(houseInfo == null){ + throw new EpmetException(EpmetErrorCode.EPMET_COMMON_OPERATION_FAIL.getCode(), "获取房屋信息失败", "获取房屋信息失败"); } // 将人的信息放入ic_resi_user对象中 IcResiUserEntity entity = new IcResiUserEntity(); entity.setCustomerId(form.getCustomerId()); // 进行日期转换 if(residentDetailByIdCard.getBirthday() == null){ - throw new RenException("出生日期为空"); + throw new EpmetException(EpmetErrorCode.EPMET_COMMON_OPERATION_FAIL.getCode(), "获取出生日期失败", "获取出生日期失败"); } - Date d = new Date(); SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd"); String birthday = sdf.format(residentDetailByIdCard.getBirthday()); @@ -2649,7 +2641,7 @@ public class IcResiUserServiceImpl extends BaseServiceImpl Date: Thu, 23 Jun 2022 17:40:16 +0800 Subject: [PATCH 2/5] =?UTF-8?q?=E6=96=B0=E5=A2=9E=E8=BF=94=E5=9B=9E?= =?UTF-8?q?=E5=AD=97=E6=AE=B5?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../epmet/opendata/dto/result/CaResidentResultDTO.java | 10 ++++++++++ .../src/main/resources/mapper/CaResidentDao.xml | 5 ++++- .../com/epmet/service/impl/IcResiUserServiceImpl.java | 5 +++-- 3 files changed, 17 insertions(+), 3 deletions(-) diff --git a/epmet-module/open-data-worker/open-data-worker-client/src/main/java/com/epmet/opendata/dto/result/CaResidentResultDTO.java b/epmet-module/open-data-worker/open-data-worker-client/src/main/java/com/epmet/opendata/dto/result/CaResidentResultDTO.java index a94247a9ba..2e32889995 100644 --- a/epmet-module/open-data-worker/open-data-worker-client/src/main/java/com/epmet/opendata/dto/result/CaResidentResultDTO.java +++ b/epmet-module/open-data-worker/open-data-worker-client/src/main/java/com/epmet/opendata/dto/result/CaResidentResultDTO.java @@ -16,6 +16,16 @@ public class CaResidentResultDTO implements Serializable { private String streetName; + /** + * 房屋id + */ + private String homeId; + + /** + * ic_resi_user表id + */ + private String icResiUserId; + /** * 人口ID */ diff --git a/epmet-module/open-data-worker/open-data-worker-server/src/main/resources/mapper/CaResidentDao.xml b/epmet-module/open-data-worker/open-data-worker-server/src/main/resources/mapper/CaResidentDao.xml index c541483cf0..a0243f0dc8 100644 --- a/epmet-module/open-data-worker/open-data-worker-server/src/main/resources/mapper/CaResidentDao.xml +++ b/epmet-module/open-data-worker/open-data-worker-server/src/main/resources/mapper/CaResidentDao.xml @@ -103,10 +103,13 @@ ca.plat_code, vs.grid_name, vs.community_name as comName, - vs.street_name + vs.street_name, + cau.home_id, + cau.ic_resi_user_id FROM ca_resident as ca left join view_grid_comm_street_ca as vs on ca.grid_id = vs.grid_id + left join ca_resident_user as cau on cau.id_card = ca.id_card and del_flag = '0' ca.delete_flag = 'normal' diff --git a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/IcResiUserServiceImpl.java b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/IcResiUserServiceImpl.java index 9172544598..2c7823ea61 100644 --- a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/IcResiUserServiceImpl.java +++ b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/IcResiUserServiceImpl.java @@ -2655,8 +2655,9 @@ public class IcResiUserServiceImpl extends BaseServiceImpl resultDTOResult = getGovOrgOpenFeignClient.getHouseAgencyInfo(houseInfo.getHomeId()); - entity.setGridId(resultDTOResult.getData().getGridId()); - entity.setPids(resultDTOResult.getData().getPids()); + HouseAgencyInfoResultDTO data = resultDTOResult.getData(); + entity.setGridId(data.getGridId()); + entity.setPids(data.getPids() + ":" + data.getAgencyId()); } else { throw new EpmetException(EpmetErrorCode.EPMET_COMMON_OPERATION_FAIL.getCode(), "房屋信息不完整", "房屋信息不完整"); } From b84fd9d351c157e0a7645bdd6da3ad41454f1cfe Mon Sep 17 00:00:00 2001 From: HAHA Date: Fri, 24 Jun 2022 10:23:57 +0800 Subject: [PATCH 3/5] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E7=B4=A2=E5=BC=95?= =?UTF-8?q?=E7=9A=84flyway=E8=84=9A=E6=9C=AC?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../db/migration/V0.0.10__add_indexes_of_ca_resident_user.sql | 2 ++ 1 file changed, 2 insertions(+) create mode 100644 epmet-module/open-data-worker/open-data-worker-server/src/main/resources/db/migration/V0.0.10__add_indexes_of_ca_resident_user.sql diff --git a/epmet-module/open-data-worker/open-data-worker-server/src/main/resources/db/migration/V0.0.10__add_indexes_of_ca_resident_user.sql b/epmet-module/open-data-worker/open-data-worker-server/src/main/resources/db/migration/V0.0.10__add_indexes_of_ca_resident_user.sql new file mode 100644 index 0000000000..21be295744 --- /dev/null +++ b/epmet-module/open-data-worker/open-data-worker-server/src/main/resources/db/migration/V0.0.10__add_indexes_of_ca_resident_user.sql @@ -0,0 +1,2 @@ +ALTER TABLE `ca_resident_user` ADD INDEX ID_CARD (`id_card` ) +ALTER TABLE `ca_resident_user` ADD INDEX DEL_FLAG (`DEL_FLAG` ) From d83e9f0bbb48aa75abb0e473f854b5ee68b8c7c2 Mon Sep 17 00:00:00 2001 From: HAHA Date: Fri, 24 Jun 2022 10:34:15 +0800 Subject: [PATCH 4/5] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E7=B4=A2=E5=BC=95?= =?UTF-8?q?=E7=9A=84flyway=E8=84=9A=E6=9C=AC?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../db/migration/V0.0.10__add_indexes_of_ca_resident_user.sql | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/epmet-module/open-data-worker/open-data-worker-server/src/main/resources/db/migration/V0.0.10__add_indexes_of_ca_resident_user.sql b/epmet-module/open-data-worker/open-data-worker-server/src/main/resources/db/migration/V0.0.10__add_indexes_of_ca_resident_user.sql index 21be295744..93ea003731 100644 --- a/epmet-module/open-data-worker/open-data-worker-server/src/main/resources/db/migration/V0.0.10__add_indexes_of_ca_resident_user.sql +++ b/epmet-module/open-data-worker/open-data-worker-server/src/main/resources/db/migration/V0.0.10__add_indexes_of_ca_resident_user.sql @@ -1,2 +1,2 @@ -ALTER TABLE `ca_resident_user` ADD INDEX ID_CARD (`id_card` ) +ALTER TABLE `ca_resident_user` ADD INDEX ID_CARD (`id_card` ); ALTER TABLE `ca_resident_user` ADD INDEX DEL_FLAG (`DEL_FLAG` ) From 3c36ee6010437b4e26bd7e45063260ba38781534 Mon Sep 17 00:00:00 2001 From: YUJT Date: Fri, 24 Jun 2022 12:12:30 +0800 Subject: [PATCH 5/5] =?UTF-8?q?=E6=B7=BB=E5=8A=A0flyway=E8=84=9A=E6=9C=AC?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../db/migration/V0.0.11__update_ca_view.sql | 35 +++++++++++++++++++ 1 file changed, 35 insertions(+) create mode 100644 epmet-module/open-data-worker/open-data-worker-server/src/main/resources/db/migration/V0.0.11__update_ca_view.sql diff --git a/epmet-module/open-data-worker/open-data-worker-server/src/main/resources/db/migration/V0.0.11__update_ca_view.sql b/epmet-module/open-data-worker/open-data-worker-server/src/main/resources/db/migration/V0.0.11__update_ca_view.sql new file mode 100644 index 0000000000..c145aeb367 --- /dev/null +++ b/epmet-module/open-data-worker/open-data-worker-server/src/main/resources/db/migration/V0.0.11__update_ca_view.sql @@ -0,0 +1,35 @@ +DROP INDEX DEL_FLAG ON `ca_resident_user` + +DROP VIEW IF EXISTS `view_grid_comm_street_ca`; +CREATE ALGORITHM = UNDEFINED SQL SECURITY DEFINER VIEW `view_grid_comm_street_ca` AS SELECT +`g4`.`grid_id` AS `grid_id`, +`g4`.`grid_name` AS `grid_name`, +`g3`.`grid_id` AS `community_id`, +`g3`.`grid_name` AS `community_name`, +`g2`.`grid_id` AS `street_id`, +`g2`.`grid_name` AS `street_name`, +concat( `g2`.`grid_id`, ':', `g3`.`grid_id`, ':', `g4`.`grid_id` ) AS `grid_id_path`, +`bbo`.`business_org_id` AS `business_org_id` +FROM + ((( + `ca_bm_grid` `g4` + JOIN `ca_bm_grid` `g3` ON ((( + `g3`.`grid_id` = `g4`.`parent_id` + ) + AND ( `g3`.`grid_level` = 'level3' ) + AND ( `g3`.`delete_flag` = 'normal' )))) + JOIN `ca_bm_grid` `g2` ON ((( + `g2`.`grid_id` = `g3`.`parent_id` + ) + AND ( `g2`.`grid_level` = 'level2' ) + AND ( `g2`.`delete_flag` = 'normal' )))) + LEFT JOIN `business_bind_org` `bbo` ON ((( + concat( `g4`.`grid_id` ) = `bbo`.`third_org_id` + ) + AND ( `bbo`.`business_code` = 'ca' ) + AND ( `bbo`.`DEL_FLAG` = '0' )))) +WHERE + (( + `g4`.`grid_level` = 'level4' + ) + AND ( `g4`.`delete_flag` = 'normal' )) \ No newline at end of file