回填

epmet-user/epmet-user-server/src/main/java/com/epmet/dao/DataSyncRecordDisabilityDao.java

@@ -21,5 +21,19 @@ public interface DataSyncRecordDisabilityDao extends BaseDao<DataSyncRecordDisab
 
     List<DataSyncRecordDisabilityDTO> list(DataSyncRecordDisabilityFormDTO formDTO);
 
+    /**
+     * Desc: 更新 icResiUser
+     * @param entities
+     * @author zxc
+     * @date 2022/10/14 13:43
+     */
     void batchUpdateResiDisability(List<DataSyncRecordDisabilityEntity> entities);
+
+    /**
+     * Desc: 批量更新残疾表
+     * @param entities
+     * @author zxc
+     * @date 2022/10/14 13:44
+     */
+    void batchUpdateDisability(List<DataSyncRecordDisabilityEntity> entities);
 }

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

epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/DataSyncRecordDisabilityServiceImpl.java

@@ -228,6 +228,7 @@ public class DataSyncRecordDisabilityServiceImpl extends BaseServiceImpl<DataSyn
                 }
             });
         });
+        entities.stream().filter(e -> StringUtils.isBlank(e.getCjzk()) || StringUtils.isBlank(e.getCjlb())).forEach(e -> e.setUpdateStatus(true));
         // 变更记录
         List<CategoryStatusAndIdDTO> collect = entities.stream().map(m -> {
             CategoryStatusAndIdDTO dto = new CategoryStatusAndIdDTO();
@@ -255,6 +256,8 @@ public class DataSyncRecordDisabilityServiceImpl extends BaseServiceImpl<DataSyn
         icUserChangeRecordService.addRecordByResidentCategory(addRecordByResidentCategoryFormDTO);
         // 更新 ic_resi_user
         baseDao.batchUpdateResiDisability(entities);
+        // 回填 主表
+        baseDao.batchUpdateDisability(entities);
     }
 
 }

epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/IcUserChangeRecordServiceImpl.java

@@ -192,7 +192,6 @@ public class IcUserChangeRecordServiceImpl extends BaseServiceImpl<IcUserChangeR
      * @date 2022/10/14 09:04
      */
     @Override
-    @Transactional(rollbackFor = Exception.class)
     public void addRecordByResidentCategory(AddRecordByResidentCategoryFormDTO formDTO) {
         formDTO.getIcResiUserIds().forEach(i -> {
             IcResiUserEntity entity = icResiUserDao.selectById(i.getIcResiUserId());
@@ -211,7 +210,7 @@ public class IcUserChangeRecordServiceImpl extends BaseServiceImpl<IcUserChangeR
                 icUserChangeRecordEntity.setBeforeChangeName(categoryMap.get(formDTO.getColumnName()).equals(NumConstant.ONE_STR) ? formDTO.getLabel().concat(":是") : formDTO.getLabel().concat(":否"));
                 icUserChangeRecordEntity.setAfterChangeName(i.getCategoryStatus().equals(NumConstant.ONE_STR) ? formDTO.getLabel().concat(":是") : formDTO.getLabel().concat(":否"));
                 icUserChangeRecordEntity.setChangeTime(new Date());
-                icUserChangeRecordEntity.setRemark(formDTO.getColumnName().concat("数据更新"));
+                icUserChangeRecordEntity.setRemark(formDTO.getLabel().concat("数据更新"));
                 baseDao.insert(icUserChangeRecordEntity);
 
                 IcUserChangeDetailedEntity icUserChangeDetailedEntity = new IcUserChangeDetailedEntity();

epmet-user/epmet-user-server/src/main/resources/mapper/DataSyncRecordDisabilityDao.xml

@@ -83,11 +83,46 @@
                 </foreach>
             </trim>
             UPDATED_TIME = NOW()
-            WHERE 1=1
-            <foreach collection="list" item="item" open="AND( " separator=" OR " index="index" close=")">
-                id = #{item.icResiUserId}
-            </foreach>
         </trim>
+        WHERE 1=1
+        <foreach collection="list" item="item" open="AND( " separator=" OR " index="index" close=")">
+            id = #{item.icResiUserId}
+        </foreach>
+    </update>
+
+    <update id="batchUpdateDisability">
+        UPDATE data_sync_record_disability
+        <trim prefix="set" suffixOverrides=",">
+            <trim prefix="DEAL_STATUS =(case" suffix="end),">
+                <foreach collection="list" item="item">
+                    <choose>
+                        <when test='item.updateStatus == true '>
+                            when id = #{item.id} then 2
+                        </when>
+                        <otherwise>
+                            when id = #{item.id} then 1
+                        </otherwise>
+                    </choose>
+                </foreach>
+            </trim>
+            <trim prefix="DEAL_RESULT =(case" suffix="end),">
+                <foreach collection="list" item="item">
+                    <choose>
+                        <when test='item.updateStatus == true '>
+                            when id = #{item.id} then '处理失败'
+                        </when>
+                        <otherwise>
+                            when id = #{item.id} then '处理成功'
+                        </otherwise>
+                    </choose>
+                </foreach>
+            </trim>
+            UPDATED_TIME = NOW()
+        </trim>
+        WHERE 1=1
+        <foreach collection="list" item="item" open="AND( " separator=" OR " index="index" close=")">
+            id = #{item.id}
+        </foreach>
     </update>
 
     <select id="list" resultType="com.epmet.dto.DataSyncRecordDisabilityDTO">