feat(大编辑)：管道增减功能开发

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/biz/changeRegistrationTransfer/ChangeRegistrationTransferDataChangeHandler.java

@@ -51,6 +51,17 @@ public class ChangeRegistrationTransferDataChangeHandler extends DefaultBizDataC
         return changeRegistrationTransferEditUpdateService.getEqsByApplyNo(applyNo);
     }
 
+    /**
+     * 管道专用
+     * @param applyNo 单据号
+     * 判断数据是实时落库，还是先存到json
+     * @return 是否需要临时存储
+     */
+    @Override
+    public Boolean requiresTemporarySave(String applyNo) {
+        return false;
+    }
+
 
     @Override
     public Boolean bizIsFinished(String applyNo) {

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/biz/changeRegistrationUnit/ChangeRegistrationUnitDataChangeHandler.java

@@ -41,6 +41,17 @@ public class ChangeRegistrationUnitDataChangeHandler extends DefaultBizDataChang
         return Collections.emptyList();
     }
 
+    /**
+     * 管道专用
+     * @param applyNo 单据号
+     * 判断数据是实时落库，还是先存到json
+     * @return 是否需要临时存储
+     */
+    @Override
+    public Boolean requiresTemporarySave(String applyNo) {
+        return false;
+    }
+
     @Override
     public Boolean beforeCheck(String bizId, String applyNo, ModelType model, Map<String, Object> changeData) {
         return Boolean.TRUE;

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/biz/changeVehicleRegistrationUnit/ChangeVehicleRegistrationUnitDataChangeHandler.java

@@ -51,6 +51,17 @@ public class ChangeVehicleRegistrationUnitDataChangeHandler extends DefaultBizDa
         return changeVehicleRegistrationUnitEditUpdateService.getEqsByApplyNo(applyNo);
     }
 
+    /**
+     * 管道专用
+     * @param applyNo 单据号
+     * 判断数据是实时落库，还是先存到json
+     * @return 是否需要临时存储
+     */
+    @Override
+    public Boolean requiresTemporarySave(String applyNo) {
+        return false;
+    }
+
 
     @Override
     public Boolean bizIsFinished(String applyNo) {

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/biz/enableDisable/EnableDisableDataChangeHandler.java

@@ -51,6 +51,16 @@ public class EnableDisableDataChangeHandler extends DefaultBizDataChangeHandler<
         return enableDisableEditUpdateService.getEqsByApplyNo(applyNo);
     }
 
+    /**
+     * 管道专用
+     * @param applyNo 单据号
+     * 判断数据是实时落库，还是先存到json
+     * @return 是否需要临时存储
+     */
+    @Override
+    public Boolean requiresTemporarySave(String applyNo) {
+        return false;
+    }
 
     @Override
     public Boolean bizIsFinished(String applyNo) {

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/biz/equipTransfer/EquipTransferDataChangeHandler.java

@@ -46,6 +46,17 @@ public class EquipTransferDataChangeHandler extends DefaultBizDataChangeHandler<
         return Boolean.TRUE;
     }
 
+    /**
+     * 管道专用
+     * @param applyNo 单据号
+     * 判断数据是实时落库，还是先存到json
+     * @return 是否需要临时存储
+     */
+    @Override
+    public Boolean requiresTemporarySave(String applyNo) {
+        return false;
+    }
+
     @Override
     public Set<String> getEqs(String applyNo) {
         return equipTransferEditUpdateService.getEqsByApplyNo(applyNo);

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/biz/installNotice/InstallNoticeDataChangeHandler.java

@@ -43,6 +43,17 @@ public class InstallNoticeDataChangeHandler extends DefaultBizDataChangeHandler<
         return true;
     }
 
+    /**
+     * 管道专用
+     * @param applyNo 单据号
+     * 判断数据是实时落库，还是先存到json
+     * @return 是否需要临时存储
+     */
+    @Override
+    public Boolean requiresTemporarySave(String applyNo) {
+        return false;
+    }
+
     @Override
     public Set<String> getEqs(String applyNo) {
         return installNoticeEditUpdateService.getEqsByApplyNo(applyNo);

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/biz/maintainNotice/MaintainNoticeDataChangeHandler.java

@@ -46,6 +46,17 @@ public class MaintainNoticeDataChangeHandler extends DefaultBizDataChangeHandler
         return Boolean.TRUE;
     }
 
+    /**
+     * 管道专用
+     * @param applyNo 单据号
+     * 判断数据是实时落库，还是先存到json
+     * @return 是否需要临时存储
+     */
+    @Override
+    public Boolean requiresTemporarySave(String applyNo) {
+        return false;
+    }
+
     @Override
     public Set<String> getEqs(String applyNo) {
         return maintainNoticeEditUpdateService.getEqsByApplyNo(applyNo);

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/biz/maintenanceContract/MaintenanceContractDataChangeHandler.java

@@ -41,6 +41,17 @@ public class MaintenanceContractDataChangeHandler extends DefaultBizDataChangeHa
         return Collections.emptyList();
     }
 
+    /**
+     * 管道专用
+     * @param applyNo 单据号
+     * 判断数据是实时落库，还是先存到json
+     * @return 是否需要临时存储
+     */
+    @Override
+    public Boolean requiresTemporarySave(String applyNo) {
+        return false;
+    }
+
     @Override
     public Boolean beforeCheck(String bizId, String applyNo, ModelType model, Map<String, Object> changeData) {
         return Boolean.TRUE;

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/biz/reformNotice/ReformNoticeDataChangeHandler.java

@@ -55,6 +55,17 @@ public class ReformNoticeDataChangeHandler extends DefaultBizDataChangeHandler<B
         return jgReformNotice.getNoticeStatus().equals(String.valueOf(FlowStatusEnum.TO_BE_FINISHED.getCode()));
     }
 
+    /**
+     * 管道专用
+     * @param applyNo 单据号
+     * 判断数据是实时落库，还是先存到json
+     * @return 是否需要临时存储
+     */
+    @Override
+    public Boolean requiresTemporarySave(String applyNo) {
+        return false;
+    }
+
     @Override
     public Set<String> getProjectContraptionIds(String applyNo) {
         JgReformNotice jgReformNotice = reformNoticeEditUpdateService.getJgReformNoticeService().getOne(new LambdaQueryWrapper<JgReformNotice>().eq(JgReformNotice::getApplyNo, applyNo).select(BaseEntity::getSequenceNbr, JgReformNotice::getProjectContraptionId));

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/biz/scrapCancel/ScrapCancelDataChangeHandler.java

@@ -46,6 +46,17 @@ public class ScrapCancelDataChangeHandler extends DefaultBizDataChangeHandler<Ba
         return Boolean.TRUE;
     }
 
+    /**
+     * 管道专用
+     * @param applyNo 单据号
+     * 判断数据是实时落库，还是先存到json
+     * @return 是否需要临时存储
+     */
+    @Override
+    public Boolean requiresTemporarySave(String applyNo) {
+        return false;
+    }
+
     @Override
     public Set<String> getEqs(String applyNo) {
         return scrapCancelEditUpdateService.getEqsByApplyNo(applyNo);

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/biz/transferNotice/TransferNoticeDataChangeHandler.java

@@ -51,6 +51,16 @@ public class TransferNoticeDataChangeHandler extends DefaultBizDataChangeHandler
         return transferNoticeEditUpdateService.getEqsByApplyNo(applyNo);
     }
 
+    /**
+     * 管道专用
+     * @param applyNo 单据号
+     * 判断数据是实时落库，还是先存到json
+     * @return 是否需要临时存储
+     */
+    @Override
+    public Boolean requiresTemporarySave(String applyNo) {
+        return false;
+    }
 
     @Override
     public Boolean bizIsFinished(String applyNo) {

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/biz/vehicleInformation/VehicleInformationDataChangeHandler.java

@@ -51,6 +51,16 @@ public class VehicleInformationDataChangeHandler extends DefaultBizDataChangeHan
         return vehicleInformationEditUpdateService.getEqsByApplyNo(applyNo);
     }
 
+    /**
+     * 管道专用
+     * @param applyNo 单据号
+     * 判断数据是实时落库，还是先存到json
+     * @return 是否需要临时存储
+     */
+    @Override
+    public Boolean requiresTemporarySave(String applyNo) {
+        return false;
+    }
 
     @Override
     public Boolean bizIsFinished(String applyNo) {

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

@@ -3174,7 +3174,7 @@ public class JgUseRegistrationServiceImpl extends BaseService<JgUseRegistrationD
                             );
                             // 2.原装置、新装置重新计算管道长度
                             this.updateTotalPieLineLength(jgUseRegistration.getOriginProjectContraptionIds(), jgUseRegistration.getProjectContraptionId());
-                        } else {        // 为进行过编辑逻辑，走原来逻辑
+                        } else {        // 未进行过编辑逻辑，走原来逻辑
                             eqList.stream()
                                     .filter(v -> jgUseRegistration.getOriginProjectContraptionIds().contains(v.getOriginProjectContraptionId()))
                                     .forEach(v -> esEquipmentCategory.findById(v.getEquId()).ifPresent(equInfoEs -> {
@@ -3294,7 +3294,10 @@ public class JgUseRegistrationServiceImpl extends BaseService<JgUseRegistrationD
 
     private void updateTotalPieLineLength(String originProjectContraptionIds, String projectContraptionId) {
         String[] oPids = originProjectContraptionIds != null ? originProjectContraptionIds.split(",") : null;
-        Set<String> pIds =  new HashSet<>(Arrays.asList(oPids));
+        Set<String> pIds = null;
+        if (oPids != null) {
+            pIds = new HashSet<>(Arrays.asList(oPids));
+        }
         pIds.add(projectContraptionId);
         pIds.parallelStream().forEach(pid->{
             List<String> records = idxBizJgUseInfoService.list(new LambdaQueryWrapper<IdxBizJgUseInfo>().in(IdxBizJgUseInfo::getProjectContraptionId, pid)).stream().map(IdxBizJgUseInfo::getRecord).collect(toList());