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 c920bf67b1..d17f7e13cd 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 @@ -21,5 +21,19 @@ public interface DataSyncRecordDisabilityDao extends BaseDao list(DataSyncRecordDisabilityFormDTO formDTO); + /** + * Desc: 更新 icResiUser + * @param entities + * @author zxc + * @date 2022/10/14 13:43 + */ void batchUpdateResiDisability(List entities); + + /** + * Desc: 批量更新残疾表 + * @param entities + * @author zxc + * @date 2022/10/14 13:44 + */ + void batchUpdateDisability(List entities); } diff --git a/epmet-user/epmet-user-server/src/main/java/com/epmet/entity/DataSyncRecordDisabilityEntity.java b/epmet-user/epmet-user-server/src/main/java/com/epmet/entity/DataSyncRecordDisabilityEntity.java index b09103c8d7..5d2987cdb3 100644 --- a/epmet-user/epmet-user-server/src/main/java/com/epmet/entity/DataSyncRecordDisabilityEntity.java +++ b/epmet-user/epmet-user-server/src/main/java/com/epmet/entity/DataSyncRecordDisabilityEntity.java @@ -135,4 +135,10 @@ public class DataSyncRecordDisabilityEntity extends BaseEpmetEntity { */ private String dealResult; + /** + * 更新状态 + */ + @TableField(exist = false) + private Boolean updateStatus = false; + } 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 1fc23c1341..4fed49f5de 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 @@ -228,6 +228,7 @@ public class DataSyncRecordDisabilityServiceImpl extends BaseServiceImpl StringUtils.isBlank(e.getCjzk()) || StringUtils.isBlank(e.getCjlb())).forEach(e -> e.setUpdateStatus(true)); // 变更记录 List collect = entities.stream().map(m -> { CategoryStatusAndIdDTO dto = new CategoryStatusAndIdDTO(); @@ -255,6 +256,8 @@ public class DataSyncRecordDisabilityServiceImpl extends BaseServiceImpl { IcResiUserEntity entity = icResiUserDao.selectById(i.getIcResiUserId()); @@ -211,7 +210,7 @@ public class IcUserChangeRecordServiceImpl extends BaseServiceImpl UPDATED_TIME = NOW() - WHERE 1=1 - - id = #{item.icResiUserId} - + WHERE 1=1 + + id = #{item.icResiUserId} + + + + + UPDATE data_sync_record_disability + + + + + + when id = #{item.id} then 2 + + + when id = #{item.id} then 1 + + + + + + + + + when id = #{item.id} then '处理失败' + + + when id = #{item.id} then '处理成功' + + + + + UPDATED_TIME = NOW() + + WHERE 1=1 + + id = #{item.id} +