fix(jg):有证历史登记报错问题处理

amos-boot-system-tzs/amos-boot-module-jg/amos-boot-module-jg-biz/src/main/java/com/yeejoin/amos/boot/module/jg/biz/edit/event/listener/ChangeEquipImpactCertListener.java

@@ -15,8 +15,10 @@ import com.yeejoin.amos.boot.module.jg.biz.service.impl.JgInstallationNoticeEqSe
 import com.yeejoin.amos.boot.module.jg.biz.service.impl.JgInstallationNoticeServiceImpl;
 import com.yeejoin.amos.boot.module.jg.biz.service.impl.JgUseRegistrationManageServiceImpl;
 import com.yeejoin.amos.boot.module.ymt.api.entity.IdxBizJgProjectContraption;
+import com.yeejoin.amos.boot.module.ymt.api.entity.IdxBizJgRegisterInfo;
 import com.yeejoin.amos.boot.module.ymt.api.entity.IdxBizJgUseInfo;
 import com.yeejoin.amos.boot.module.ymt.api.enums.FlowStatusEnum;
+import com.yeejoin.amos.boot.module.ymt.api.mapper.IdxBizJgRegisterInfoMapper;
 import com.yeejoin.amos.boot.module.ymt.api.mapper.IdxBizJgUseInfoMapper;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
@@ -52,6 +54,7 @@ public class ChangeEquipImpactCertListener {
     private final IdxBizJgProjectContraptionServiceImplService jgProjectContraptionService;
     private final JgInstallationNoticeEqServiceImpl jgInstallationNoticeEqService;
     private final IdxBizJgUseInfoMapper useInfoMapper;
+    private final IdxBizJgRegisterInfoMapper registerInfoMapper;
 
     /**
      * 事件监听：只把事件放入队列
@@ -296,6 +299,25 @@ public class ChangeEquipImpactCertListener {
 
     private void handleNewEquipEdit(BaseBizDataChangeEvent event) {
         log.info("处理 handleNewEquipEdit 类型逻辑");
+        if (event.getBizRelationData().getBizIsFinished()){
+            String useOrgCode = "";
+            for (FieldChangeMeta meta : event.getData()) {
+                String columnKey = meta.getColumnKey();
+                if (columnKey.equals("useOrgCode")){
+                    useOrgCode = meta.getColumnOldValue();
+                }else{
+                    LambdaQueryWrapper<IdxBizJgRegisterInfo> queryRegisterWrapper = new QueryWrapper<IdxBizJgRegisterInfo>().lambda();
+                    queryRegisterWrapper.eq(IdxBizJgRegisterInfo::getRecord, event.getBizRelationData().getBizId());
+                    IdxBizJgRegisterInfo registerInfo = registerInfoMapper.selectOne(queryRegisterWrapper);
+                    useOrgCode = registerInfo.getUseOrgCode();
+                }
+            }
+            JgUseRegistrationManage jgUseRegistrationManage = jgUseRegistrationManageService.lambdaQuery()
+                    .eq(JgUseRegistrationManage::getUseRegistrationCode, useOrgCode)
+                    .eq(JgUseRegistrationManage::getIsDelete, 0)
+                    .one();
+            this.handleFieldChange(event.getData(), jgUseRegistrationManage);
+        }
     }
 
     private void handleNewProjectEdit(List<FieldChangeMeta> fieldChangeMetaList, String projectContraptionId) {

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/JgInstallationNoticeServiceImpl.java

@@ -413,7 +413,7 @@ public class JgInstallationNoticeServiceImpl extends BaseService<JgInstallationN
                 installationInfo.put("equDefineName", projectContraption.getEquDefineName());
                 equipListMaps = projectContraptionService.getBaseMapper().selectEquipList(projectContraptionId);
                 equipListMaps.forEach(item ->
-                        item.put("deviceLevel", Optional.ofNullable(dataDictionaryMapper.getByCode(String.valueOf(item.get("deviceLevel")),"8300"))
+                        item.put("deviceLevel", Optional.ofNullable(dataDictionaryMapper.getByCode(String.valueOf(item.get("deviceLevel")), projectContraption.getEquCategory()))
                                 .map(DataDictionary::getName)
                                 .orElse("")));
             } else {
@@ -2024,7 +2024,7 @@ public class JgInstallationNoticeServiceImpl extends BaseService<JgInstallationN
         List<Map<String, Object>> deviceList = projectContraptionService.getBaseMapper().selectEquipList(projectContraptionSeq);
         deviceList.forEach(device -> {
             String deviceLevel = String.valueOf(device.get("deviceLevel"));
-            device.put("deviceLevel", dataDictionaryMapper.getByCode(deviceLevel,"8300").getName());
+            device.put("deviceLevel", dataDictionaryMapper.getByCode(deviceLevel, projectContraption.getEquCategory()).getName());
             device.put("sequenceNbr", projectContraptionSeq);
             device.put("equListName", projectContraption.getEquListName());
         });

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

@@ -1951,7 +1951,8 @@ public class JgUseRegistrationServiceImpl extends BaseService<JgUseRegistrationD
             // 更新es的下次检验日期
             param.put("NEXT_INSPECT_DATE", this.castDate2TimeStr(dataMap.getString("nextInspectDate")));
             param.put("USE_INNER_CODE", useInfo.getUseInnerCode());
-            if (!Arrays.asList("temp", "tempEdit").contains(dataMap.get("historySubmitType"))) {
+            String historySubmitType = String.valueOf(dataMap.get("historySubmitType"));
+            if (!"temp".equals(historySubmitType) && !"tempEdit".equals(historySubmitType)) {
                 param.put("IS_INTO_MANAGEMENT", true);
             }
             param.put("USE_PLACE_CODE", jsonObject.get("province") + "#" + jsonObject.get("city") + "#" + jsonObject.get("county") + "#" + jsonObject.get("factoryUseSiteStreet"));
@@ -1963,6 +1964,7 @@ public class JgUseRegistrationServiceImpl extends BaseService<JgUseRegistrationD
             param.put("EQU_CODE", dataMap.get("equCode"));
             param.put("USE_ORG_CODE", jgUseRegistration.getUseRegistrationCode());
             param.put("CYLINDER_CATEGORY", dataMap.get("cylinderCategory"));
+            param.put("FACTORY_NUM", MapUtil.getStr(dataMap, "factoryNum"));
             objMap.put((String) dataMap.get("equipId"), param);
             tzsServiceFeignClient.commonUpdateEsDataByIds(objMap);
         }