refeat(监管业务)：增加施工单位信息到使用信息表

amos-boot-system-tzs/amos-boot-module-jg/amos-boot-module-jg-biz/src/main/java/com/yeejoin/amos/boot/module/jg/biz/service/impl/JgChangeRegistrationReformServiceImpl.java

@@ -628,6 +628,7 @@ public class JgChangeRegistrationReformServiceImpl extends BaseService<JgChangeR
                 updateTechparamsByEquIdAndCurrentDoucumentId(jgChangeRegistrationReformEq.getEquId(), jgChangeRegistrationReform.getSequenceNbr().toString(), null, jgChangeRegistrationReform.getApplyNo());
                 // 生成流水信息
                 saveRecord(jgChangeRegistrationReformEq.getEquId(), jgChangeRegistrationReform, taskV2Model);
+                this.clearUscWInfo(jgChangeRegistrationReform);
             }  else {                                                                                         // 压力管道逻辑
                 // 1.批量更新技术参数
                 // 1.1 技术参数更新
@@ -681,6 +682,26 @@ public class JgChangeRegistrationReformServiceImpl extends BaseService<JgChangeR
         });
     }
 
+    private void clearUscWInfo(JgChangeRegistrationReform reform) {
+        List<JgChangeRegistrationReformEq> reformEqs = jgChangeRegistrationReformEqMapper.selectList(new LambdaQueryWrapper<JgChangeRegistrationReformEq>().eq(JgChangeRegistrationReformEq::getEquipTransferId, reform.getSequenceNbr()));
+        reformEqs.forEach(reformEq -> {
+            // 数据库表清空
+            LambdaUpdateWrapper<IdxBizJgUseInfo> updateWrapper = new LambdaUpdateWrapper<>();
+            updateWrapper.eq(IdxBizJgUseInfo::getRecord, reformEq.getEquId());
+            updateWrapper.set(IdxBizJgUseInfo::getUSC_UNIT_CREDIT_CODE, null);
+            updateWrapper.set(IdxBizJgUseInfo::getUSC_UNIT_NAME, null);
+            idxBizJgUseInfoService.update(updateWrapper);
+            // es清空
+            Optional<ESEquipmentCategoryDto> optional = esEquipmentCategory.findById(reformEq.getEquId());
+            if (optional.isPresent()) {
+                ESEquipmentCategoryDto esEquipmentCategoryDto = optional.get();
+                esEquipmentCategoryDto.setUSC_UNIT_NAME(null);
+                esEquipmentCategoryDto.setUSC_UNIT_CREDIT_CODE(null);
+                esEquipmentCategory.save(esEquipmentCategoryDto);
+            }
+        });
+    }
+
     private void saveCertFlowBatch(JgChangeRegistrationReform jgChangeRegistrationReform, List<IdxBizJgTechParamsPipeline> paramsPipelines, TaskV2Model taskV2Model) {
         // 1.更新使用登记证信息
         JgUseRegistrationManage jgUseRegistrationManage = jgUseRegistrationManageService.lambdaQuery()

amos-boot-system-tzs/amos-boot-module-jg/amos-boot-module-jg-biz/src/main/java/com/yeejoin/amos/boot/module/jg/biz/service/impl/JgUseRegistrationServiceImpl.java

@@ -1793,6 +1793,8 @@ public class JgUseRegistrationServiceImpl extends BaseService<JgUseRegistrationD
         String usePlace = useInfo.getProvinceName() + "/" + useInfo.getCityName() + "/" + useInfo.getCountyName() + "/" + useInfo.getStreetName();
         useInfo.setIsIntoManagement(Boolean.TRUE);
         useInfo.setUseDate(Objects.toString(mapData.get("useDate"), ""));
+        useInfo.setUSC_UNIT_CREDIT_CODE("");
+        useInfo.setUSC_UNIT_NAME("");
         useInfoMapper.updateById(useInfo);
         // 更新es
         updateEsData(usePlace, mapData, otherInfo, useInfo, jgUseRegistration, jsonObject);