Merge remote-tracking branch 'origin/develop_tzs_register' into develop_tzs_register

amos-boot-system-tzs/amos-boot-module-jg/amos-boot-module-jg-biz/src/main/java/com/yeejoin/amos/boot/module/jg/biz/edit/process/equip/CommonEquipDataProcessService.java

@@ -1028,10 +1028,10 @@ public class CommonEquipDataProcessService {
             equipChangeDataUpdateServiceImpl.updateFactoryEsData(record, equipFactoryChangeDataDto);
         }
         // 设计信息
-        if (changeDataDto instanceof IdxBizJgDesignInfo) {
-            IdxBizJgDesignInfo equipDesignChangeDataDto = (IdxBizJgDesignInfo) changeDataDto;
-            equipChangeDataUpdateServiceImpl.checkDesignChangeData(record, equipDesignChangeDataDto);
-        }
+//        if (changeDataDto instanceof IdxBizJgDesignInfo) {
+//            IdxBizJgDesignInfo equipDesignChangeDataDto = (IdxBizJgDesignInfo) changeDataDto;
+//            equipChangeDataUpdateServiceImpl.checkDesignChangeData(record, equipDesignChangeDataDto);
+//        }
         // 使用信息
         if (changeDataDto instanceof IdxBizJgUseInfo) {
             IdxBizJgUseInfo equipUseInfoChangeDataDto = (IdxBizJgUseInfo) changeDataDto;
@@ -1039,8 +1039,13 @@ public class CommonEquipDataProcessService {
         }
         // 检验信息
         if (changeDataDto instanceof IdxBizJgInspectionDetectionInfo) {
-            IdxBizJgInspectionDetectionInfo equipUseInfoChangeDataDto = (IdxBizJgInspectionDetectionInfo) changeDataDto;
-            equipChangeDataUpdateServiceImpl.updateInspectInfoEs(record, equipUseInfoChangeDataDto);
+            IdxBizJgInspectionDetectionInfo equipInspectionInfoChangeDataDto = (IdxBizJgInspectionDetectionInfo) changeDataDto;
+            equipChangeDataUpdateServiceImpl.updateInspectInfoEs(record, equipInspectionInfoChangeDataDto);
+        }
+        // 监督管理信息
+        if (changeDataDto instanceof IdxBizJgSupervisionInfo) {
+            IdxBizJgSupervisionInfo equipSupervisionInfoChangeDataDto = (IdxBizJgSupervisionInfo) changeDataDto;
+            equipChangeDataUpdateServiceImpl.updateSupervisionInfoEs(record, equipSupervisionInfoChangeDataDto);
         }
     }
 

amos-boot-system-tzs/amos-boot-module-jg/amos-boot-module-jg-biz/src/main/java/com/yeejoin/amos/boot/module/jg/biz/edit/process/equip/EquipChangeDataUpdateServiceImpl.java

@@ -371,6 +371,19 @@ public class EquipChangeDataUpdateServiceImpl {
         }
     }
 
+    public void updateSupervisionInfoEs(String record, IdxBizJgSupervisionInfo equipSupervisionInfoChangeDataDto) {
+        // es 数据更新
+        Optional<ESEquipmentCategoryDto> optional = esEquipmentCategory.findById(record);
+        if (optional.isPresent()) {
+            ESEquipmentCategoryDto esEquipmentCategoryDto = optional.get();
+            if(equipSupervisionInfoChangeDataDto.getOrgBranchCode() != null) {
+                esEquipmentCategoryDto.setORG_BRANCH_CODE(equipSupervisionInfoChangeDataDto.getOrgBranchCode());
+                esEquipmentCategoryDto.setORG_BRANCH_NAME(equipSupervisionInfoChangeDataDto.getOrgBranchName());
+                esEquipmentCategory.save(esEquipmentCategoryDto);
+            }
+        }
+    }
+
     public void updateOtherInfoChangeData(String record, EquipOtherInfoChangeDataDto otherInfoChangeDataDto) {
         LambdaUpdateWrapper<IdxBizJgOtherInfo> updateWrapper = new LambdaUpdateWrapper<>();
         updateWrapper.eq(IdxBizJgOtherInfo::getRecord, record);

amos-boot-system-tzs/amos-boot-module-jg/amos-boot-module-jg-biz/src/main/java/com/yeejoin/amos/boot/module/jg/biz/edit/process/equip/SingleEquipChangeProcess.java

@@ -130,6 +130,7 @@ public class SingleEquipChangeProcess implements IEquipChangeDataProcessStrategy
         commonEquipDataProcessService.updateEsDataOfEquip(record, designInfoNew);
         commonEquipDataProcessService.updateEsDataOfEquip(record, otherInfoNew);
         commonEquipDataProcessService.updateEsDataOfEquip(record, factoryInfoNew);
+        commonEquipDataProcessService.updateEsDataOfEquip(record, idxBizJgSupervisionInfoNew);
 
         // 如果是气瓶则按照证更新其他同证下的气瓶字段
         this.updateOtherEquipInSameCert(useInfoNew, registerInfoNew, registerInfoOld, allChangeColumns);