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

@@ -3,6 +3,7 @@ package com.yeejoin.amos.boot.module.jg.biz.edit.event.listener;
 import cn.hutool.core.bean.BeanUtil;
 import cn.hutool.core.date.DateUtil;
 import com.alibaba.fastjson.JSONObject;
+import com.yeejoin.amos.boot.module.jg.api.dto.BizRelationDataDto;
 import com.yeejoin.amos.boot.module.jg.api.dto.ESDataChangeLogDto;
 import com.yeejoin.amos.boot.module.jg.api.dto.FieldChangeMeta;
 import com.yeejoin.amos.boot.module.jg.api.dto.JgResumeInfoDto;
@@ -102,36 +103,37 @@ public class ChangeLogInsertListener {
     @Async
     protected void insertCertLog(JgBizChangeLog changeLog, BaseBizDataChangeEvent event) {
         try {
-            String bizId = event.getBizRelationData().getBizId();
+            BizRelationDataDto data = event.getBizRelationData();
+            String bizId = data.getBizId();
             String businessTypeName = BusinessTypeEnum.findNameByEnumName(changeLog.getBizType()).orElse("设备编辑");
-            String approvalUnit = event.getBizRelationData().getUnitName();
-            String approvalUnitCode = event.getBizRelationData().getUnitCode();
-            String recUserName = event.getBizRelationData().getRecUserName();
+            String approvalUnit = data.getUnitName();
+            String approvalUnitCode = data.getUnitCode();
+            String recUserName = data.getRecUserName();
             String recUserId = event.getRequestContext().getExcutedUserId();
             String changeLogId = String.valueOf(changeLog.getSequenceNbr());
-            Date now = new Date();
-            event.getData().stream()
+            String equId = (data.getProjectContraptionIds() == null || data.getProjectContraptionIds().isEmpty())
+                    ? event.getData().stream()
                     .map(FieldChangeMeta::getChangeId)
                     .filter(Objects::nonNull)
-                    .distinct()
-                    .forEach(equId -> {
-                        JgResumeInfoDto dto = new JgResumeInfoDto();
-                        dto.setApplyNo(bizId);
-                        dto.setBusinessType(businessTypeName);
-                        dto.setBusinessId(bizId);
-                        dto.setEquId(equId);
-                        dto.setResumeType("1");
-                        dto.setChangeContent("设备编辑");
-                        dto.setChangeLogId(changeLogId);
-                        dto.setApprovalUnit(approvalUnit);
-                        dto.setApprovalUnitCode(approvalUnitCode);
-                        dto.setRecDate(now);
-                        dto.setRecUserName(recUserName);
-                        dto.setRecUserId(recUserId);
-                        dto.setStatus("正常");
-                        dto.setRoutePath(routePath);
-                        jgResumeInfoService.createWithModel(dto);
-                    });
+                    .findFirst()
+                    .orElse(null)
+                    : data.getProjectContraptionIds().iterator().next();
+            JgResumeInfoDto dto = new JgResumeInfoDto();
+            dto.setApplyNo(bizId);
+            dto.setBusinessType(businessTypeName);
+            dto.setBusinessId(bizId);
+            dto.setEquId(equId);
+            dto.setResumeType("1");
+            dto.setChangeContent("设备编辑");
+            dto.setChangeLogId(changeLogId);
+            dto.setApprovalUnit(approvalUnit);
+            dto.setApprovalUnitCode(approvalUnitCode);
+            dto.setRecDate(new Date());
+            dto.setRecUserName(recUserName);
+            dto.setRecUserId(recUserId);
+            dto.setStatus("正常");
+            dto.setRoutePath(routePath);
+            jgResumeInfoService.createWithModel(dto);
         } catch (Exception e) {
             log.error("插入设备履历日志异常，bizType: {}, 错误: {}", changeLog.getBizType(), e.getMessage(), e);
         }