feat(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/constant/ChangeFieldWatchConstants.java

@@ -11,7 +11,7 @@ public class ChangeFieldWatchConstants {
             Collections.unmodifiableSet(new HashSet<>(Arrays.asList(
                     "equDefine", "equCode", "useInnerCode", "factoryNum",
                     "province", "city", "county", "street", "factoryUseSiteStreet", "address", "useOrgCode", "carNumber", "useRegistrationCode",
-                    "receiveCompanyCode", "orgBranchName"
+                    "receiveCompanyCode", "orgBranchName", "orgName"
             )));
 
     /**

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

@@ -187,20 +187,36 @@ public class ChangeEquipImpactCertListener {
                         .add(new BigDecimal(afterValue).subtract(new BigDecimal(beforeValue))).toPlainString());
                 break;
             case "orgBranchName":
-                this.updateUseRegistrationManagement(manage, meta.getChangeId());
+                this.updateUseRegistrationManagementByEquId(manage, meta.getChangeId());
+                break;
+            case "orgName":
+                this.updateUseRegistrationManagementByProjectContraptionId(manage, meta.getChangeId());
+                break;
             default:
                 log.warn("未处理的USE_CERT字段：[{}]", columnKey);
                 break;
         }
     }
 
-    private void updateUseRegistrationManagement(JgUseRegistrationManage manage, Object changeId) {
-        LambdaQueryWrapper<IdxBizJgSupervisionInfo> lambda = new QueryWrapper<IdxBizJgSupervisionInfo>().lambda().select(IdxBizJgSupervisionInfo::getOrgBranchCode, IdxBizJgSupervisionInfo::getOrgBranchName).eq(IdxBizJgSupervisionInfo::getRecord, changeId);
+    private void updateUseRegistrationManagementByEquId(JgUseRegistrationManage manage, Object record) {
+        LambdaQueryWrapper<IdxBizJgSupervisionInfo> lambda = new QueryWrapper<IdxBizJgSupervisionInfo>().lambda().select(IdxBizJgSupervisionInfo::getOrgBranchCode, IdxBizJgSupervisionInfo::getOrgBranchName).eq(IdxBizJgSupervisionInfo::getRecord, record);
         IdxBizJgSupervisionInfo supervisionInfo = supervisionInfoMapper.selectOne(lambda);
+        if (supervisionInfo == null) {
+            return;
+        }
         manage.setSuperviseOrgCode(supervisionInfo.getOrgBranchCode());
         manage.setSuperviseOrgName(supervisionInfo.getOrgBranchName());
     }
 
+    private void updateUseRegistrationManagementByProjectContraptionId(JgUseRegistrationManage manage, Object projectId) {
+        IdxBizJgProjectContraption projectContraption = jgProjectContraptionService.lambdaQuery().select(IdxBizJgProjectContraption::getOrgCode, IdxBizJgProjectContraption::getOrgName).eq(IdxBizJgProjectContraption::getSequenceNbr, projectId).one();
+        if (projectContraption == null) {
+            return;
+        }
+        manage.setSuperviseOrgCode(projectContraption.getOrgCode());
+        manage.setSuperviseOrgName(projectContraption.getOrgName());
+    }
+
     private void updateEquUseAddressByChangeId(JgUseRegistrationManage manage, Object changeId) {
         LambdaQueryWrapper<IdxBizJgUseInfo> lambda = new QueryWrapper<IdxBizJgUseInfo>().lambda();
         lambda.eq(IdxBizJgUseInfo::getRecord, String.valueOf(changeId));