/epmetuser/dataSyncRecordDisability/detail/调整，删除居民增加逻辑

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);
 }

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);
 }

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);
 }

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);
 }

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);
+    }
 }

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);
+    }
 }

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());
+        }
     }
 
     /**

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>

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>