From 75b8c1572d647000dbf929adf17ae3f40097ac87 Mon Sep 17 00:00:00 2001
From: yinzuomei <576302893@qq.com>
Date: Wed, 22 Mar 2023 15:09:45 +0800
Subject: [PATCH] =?UTF-8?q?/epmetuser/dataSyncRecordDisability/detail/?=
 =?UTF-8?q?=E8=B0=83=E6=95=B4=EF=BC=8C=E5=88=A0=E9=99=A4=E5=B1=85=E6=B0=91?=
 =?UTF-8?q?=E5=A2=9E=E5=8A=A0=E9=80=BB=E8=BE=91?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../com/epmet/dao/DataSyncRecordDeathDao.java |  2 +
 .../dao/DataSyncRecordDisabilityDao.java      |  7 ++++
 .../service/DataSyncRecordDeathService.java   |  6 +++
 .../DataSyncRecordDisabilityService.java      |  6 +++
 .../impl/DataSyncRecordDeathServiceImpl.java  | 10 ++++-
 .../DataSyncRecordDisabilityServiceImpl.java  | 39 ++++++++++++-------
 .../service/impl/IcResiUserServiceImpl.java   |  8 +++-
 .../mapper/DataSyncRecordDeathDao.xml         |  6 +++
 .../mapper/DataSyncRecordDisabilityDao.xml    |  6 +++
 9 files changed, 74 insertions(+), 16 deletions(-)

diff --git a/epmet-user/epmet-user-server/src/main/java/com/epmet/dao/DataSyncRecordDeathDao.java b/epmet-user/epmet-user-server/src/main/java/com/epmet/dao/DataSyncRecordDeathDao.java
index 4633fa4ea5..6d915dd477 100644
--- a/epmet-user/epmet-user-server/src/main/java/com/epmet/dao/DataSyncRecordDeathDao.java
+++ b/epmet-user/epmet-user-server/src/main/java/com/epmet/dao/DataSyncRecordDeathDao.java
@@ -29,4 +29,6 @@ public interface DataSyncRecordDeathDao extends BaseDao<DataSyncRecordDeathEntit
                                             @Param("idCard") String idCard,
                                             @Param("name") String name,
                                             @Param("agencyId") String agencyId);
+
+    int deleteByIcResiUserId(String icResiUserId);
 }
\ No newline at end of file
diff --git a/epmet-user/epmet-user-server/src/main/java/com/epmet/dao/DataSyncRecordDisabilityDao.java b/epmet-user/epmet-user-server/src/main/java/com/epmet/dao/DataSyncRecordDisabilityDao.java
index d17f7e13cd..ce926dd4ac 100644
--- a/epmet-user/epmet-user-server/src/main/java/com/epmet/dao/DataSyncRecordDisabilityDao.java
+++ b/epmet-user/epmet-user-server/src/main/java/com/epmet/dao/DataSyncRecordDisabilityDao.java
@@ -36,4 +36,11 @@ public interface DataSyncRecordDisabilityDao extends BaseDao<DataSyncRecordDisab
      * @date 2022/10/14 13:44
      */
     void batchUpdateDisability(List<DataSyncRecordDisabilityEntity> entities);
+
+    /**
+     * 删除居民信息时，同时删除data_sync_record_disability
+     * @param icResiUserId
+     * @return
+     */
+    int deleteByIcResiUserId(String icResiUserId);
 }
diff --git a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/DataSyncRecordDeathService.java b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/DataSyncRecordDeathService.java
index de5e8ef59f..0ac72679db 100644
--- a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/DataSyncRecordDeathService.java
+++ b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/DataSyncRecordDeathService.java
@@ -67,4 +67,10 @@ public interface DataSyncRecordDeathService extends BaseService<DataSyncRecordDe
      * @param ids 要操作的记录id
      */
     void batchUpdate(String userId, String customerId, List<String> ids);
+
+    /**
+     * 删除居民信息时，同时删除data_sync_record_death
+     * @param icResiUserId
+     */
+    void deleteByIcResiUserId(String icResiUserId);
 }
diff --git a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/DataSyncRecordDisabilityService.java b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/DataSyncRecordDisabilityService.java
index b49becbc7f..4f627b589b 100644
--- a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/DataSyncRecordDisabilityService.java
+++ b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/DataSyncRecordDisabilityService.java
@@ -107,4 +107,10 @@ public interface DataSyncRecordDisabilityService extends BaseService<DataSyncRec
      * @date 2022/10/13 16:18
      */
     void batchUpdate(String[] ids, TokenDto tokenDto);
+
+    /**
+     * 删除居民信息时，同时删除data_sync_record_disability
+     * @param icResiUserId
+     */
+    void deleteByIcResiUserId(String icResiUserId);
 }
diff --git a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/DataSyncRecordDeathServiceImpl.java b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/DataSyncRecordDeathServiceImpl.java
index e83e251478..75403760af 100644
--- a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/DataSyncRecordDeathServiceImpl.java
+++ b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/DataSyncRecordDeathServiceImpl.java
@@ -155,5 +155,13 @@ public class DataSyncRecordDeathServiceImpl extends BaseServiceImpl<DataSyncReco
         }
     }
 
-
+    /**
+     * 删除居民信息时，同时删除data_sync_record_death
+     *
+     * @param icResiUserId
+     */
+    @Override
+    public void deleteByIcResiUserId(String icResiUserId) {
+        baseDao.deleteByIcResiUserId(icResiUserId);
+    }
 }
diff --git a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/DataSyncRecordDisabilityServiceImpl.java b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/DataSyncRecordDisabilityServiceImpl.java
index a11f6bbab5..66d02e9d6e 100644
--- a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/DataSyncRecordDisabilityServiceImpl.java
+++ b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/DataSyncRecordDisabilityServiceImpl.java
@@ -45,6 +45,7 @@ import org.apache.commons.collections4.CollectionUtils;
 import org.apache.commons.collections4.MapUtils;
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.scheduling.annotation.Async;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
@@ -107,20 +108,22 @@ public class DataSyncRecordDisabilityServiceImpl extends BaseServiceImpl<DataSyn
         if (null != result.getGender()){
             result.setGenderCn(result.getGender() == NumConstant.ONE ? "男" : "女");
         }
-        if(StringUtils.isBlank(entity.getIcResiUserId())){
-            throw new EpmetException(EpmetErrorCode.EPMET_COMMON_OPERATION_FAIL.getCode(), "icResiUserId为空,idCard:" + entity.getIdCard(),
-                    String.format("居民信息中不存在此居民【身份证号：%s】", entity.getIdCard()));
-        }
-        IcResiUserDTO icResiUserDTO = icResiUserService.get(entity.getIcResiUserId());
-        ResiInfoDTO resiInfoDTO = ConvertUtils.sourceToTarget(icResiUserDTO, ResiInfoDTO.class);
-        if (StringUtils.isNotBlank(resiInfoDTO.getGender())) {
-            resiInfoDTO.setGenderCn(resiInfoDTO.getGender().equals(NumConstant.ONE_STR) ? "男" : "女");
-        } else {
-            resiInfoDTO.setGenderCn(GenderEnum.UN_KNOWN.getName());
+        if (StringUtils.isNotBlank(entity.getIcResiUserId())) {
+            IcResiUserDTO icResiUserDTO = icResiUserService.get(entity.getIcResiUserId());
+            if (null != icResiUserDTO) {
+                ResiInfoDTO resiInfoDTO = ConvertUtils.sourceToTarget(icResiUserDTO, ResiInfoDTO.class);
+                if (StringUtils.isNotBlank(resiInfoDTO.getGender())) {
+                    resiInfoDTO.setGenderCn(resiInfoDTO.getGender().equals(NumConstant.ONE_STR) ? "男" : "女");
+                } else {
+                    resiInfoDTO.setGenderCn(GenderEnum.UN_KNOWN.getName());
+                }
+                resiInfoDTO.setCjzkCn(getCj(resiInfoDTO.getCjzk()));
+                resiInfoDTO.setCjlbCn(getCjlb(resiInfoDTO.getCjlb(), entity.getCustomerId()));
+                result.setResiInfo(resiInfoDTO);
+            } else {
+                log.warn(String.format("ic_resi_user is null icResiUserId:%s", entity.getIcResiUserId()));
+            }
         }
-        resiInfoDTO.setCjzkCn(getCj(resiInfoDTO.getCjzk()));
-        resiInfoDTO.setCjlbCn(getCjlb(resiInfoDTO.getCjlb(),entity.getCustomerId()));
-        result.setResiInfo(resiInfoDTO);
         return result;
     }
 
@@ -323,4 +326,14 @@ public class DataSyncRecordDisabilityServiceImpl extends BaseServiceImpl<DataSyn
         baseDao.batchUpdateDisability(entities);
     }
 
+    /**
+     * 删除居民信息时，同时删除data_sync_record_disability
+     *
+     * @param icResiUserId
+     */
+    @Async
+    @Override
+    public void deleteByIcResiUserId(String icResiUserId) {
+        baseDao.deleteByIcResiUserId(icResiUserId);
+    }
 }
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 50d5025c4e..c1bdb55132 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
@@ -58,7 +58,6 @@ import com.epmet.dao.*;
 import com.epmet.dto.*;
 import com.epmet.dto.form.*;
 import com.epmet.dto.form.demand.UserDemandNameQueryFormDTO;
-import com.epmet.dto.form.stats.UserHouseStatsQueryFormDTO;
 import com.epmet.dto.result.*;
 import com.epmet.dto.result.demand.IcResiDemandDictDTO;
 import com.epmet.dto.result.demand.OptionDTO;
@@ -74,7 +73,6 @@ import com.epmet.opendata.dto.result.ResidentByIdCardResultDTO;
 import com.epmet.opendata.feign.GuardarDatosFeignClient;
 import com.epmet.resi.partymember.feign.ResiPartyMemberOpenFeignClient;
 import com.epmet.service.*;
-import com.epmet.stats.UserHouseStatsResultDTO;
 import com.github.pagehelper.Page;
 import com.github.pagehelper.PageHelper;
 import com.github.pagehelper.PageInfo;
@@ -93,6 +91,7 @@ import org.springframework.transaction.annotation.Transactional;
 
 import javax.annotation.Resource;
 import javax.servlet.http.HttpServletResponse;
+import javax.swing.*;
 import java.io.IOException;
 import java.io.PrintWriter;
 import java.math.BigDecimal;
@@ -211,6 +210,11 @@ public class IcResiUserServiceImpl extends BaseServiceImpl<IcResiUserDao, IcResi
         icUserTransferRecordService.deleteByIcResiUserId(formDTO.getIcResiUserId(),formDTO.getCurrentStaffId());
         icUserChangeRecordService.deleteByIcResiUserId(formDTO.getIcResiUserId(),formDTO.getCurrentStaffId());
         icUserChangeDetailedService.deleteByIcResiUserId(formDTO.getIcResiUserId(),formDTO.getCurrentStaffId());
+        //如果是烟台客户，删除居民时，同时删除死亡数据data_sync_record_death、残疾记录data_sync_record_disability
+        if(CustomerIdConstant.YT_CUSTOMER_ID.equals(formDTO.getCustomerId())){
+            SpringContextUtils.getBean(DataSyncRecordDisabilityService.class).deleteByIcResiUserId(formDTO.getIcResiUserId());
+            SpringContextUtils.getBean(DataSyncRecordDeathService.class).deleteByIcResiUserId(formDTO.getIcResiUserId());
+        }
     }
 
     /**
diff --git a/epmet-user/epmet-user-server/src/main/resources/mapper/DataSyncRecordDeathDao.xml b/epmet-user/epmet-user-server/src/main/resources/mapper/DataSyncRecordDeathDao.xml
index 67e8f18649..ad5e414ba3 100644
--- a/epmet-user/epmet-user-server/src/main/resources/mapper/DataSyncRecordDeathDao.xml
+++ b/epmet-user/epmet-user-server/src/main/resources/mapper/DataSyncRecordDeathDao.xml
@@ -60,4 +60,10 @@
         ORDER BY
             d.CREATED_TIME DESC
     </select>
+
+    <delete id="deleteByIcResiUserId" parameterType="java.lang.String">
+
+        delete from data_sync_record_death
+        where IC_RESI_USER_ID = #{icResiUserId}
+    </delete>
 </mapper>
diff --git a/epmet-user/epmet-user-server/src/main/resources/mapper/DataSyncRecordDisabilityDao.xml b/epmet-user/epmet-user-server/src/main/resources/mapper/DataSyncRecordDisabilityDao.xml
index 1d16260551..e16d903832 100644
--- a/epmet-user/epmet-user-server/src/main/resources/mapper/DataSyncRecordDisabilityDao.xml
+++ b/epmet-user/epmet-user-server/src/main/resources/mapper/DataSyncRecordDisabilityDao.xml
@@ -215,4 +215,10 @@
 <!--        sex = values(sex),-->
 <!--        class = values(class)-->
 <!--    </insert>-->
+
+
+    <delete id="deleteByIcResiUserId" parameterType="java.lang.String">
+        delete from data_sync_record_disability
+        where IC_RESI_USER_ID = #{icResiUserId}
+    </delete>
 </mapper>