From ac3e0ca9e03d8f92eaec7296e9ed9c6c6428ec63 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E6=9D=8E=E9=BE=99?= Date: Wed, 26 Feb 2025 16:11:52 +0800 Subject: [PATCH] =?UTF-8?q?feat:(feature/REQ-3581)=20=E5=A2=9E=E5=8A=A0mq?= =?UTF-8?q?=E7=9A=84=E6=B6=88=E8=B4=B9=E6=97=A5=E5=BF=97=EF=BC=8C=E6=96=B9?= =?UTF-8?q?=E4=BE=BF=E6=8E=92=E6=9F=A5=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../workflow/process/CompleteVisaChangeStampHandler.java | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/visa/visa-server/src/main/java/cn/axzo/nanopart/visa/server/mq/listener/workflow/process/CompleteVisaChangeStampHandler.java b/visa/visa-server/src/main/java/cn/axzo/nanopart/visa/server/mq/listener/workflow/process/CompleteVisaChangeStampHandler.java index 849058d2..8e14397c 100644 --- a/visa/visa-server/src/main/java/cn/axzo/nanopart/visa/server/mq/listener/workflow/process/CompleteVisaChangeStampHandler.java +++ b/visa/visa-server/src/main/java/cn/axzo/nanopart/visa/server/mq/listener/workflow/process/CompleteVisaChangeStampHandler.java @@ -46,6 +46,7 @@ public class CompleteVisaChangeStampHandler implements ProcessInstanceEventHandl @Override public void onCompleted(ProcessInstanceDTO dto) { Long visaId = Long.valueOf(dto.getBusinessKey()); + log.info("CompleteVisaChangeStampHandler visaId, {}", visaId); Long operatorId = Optional.ofNullable(dto.getLastOperationAssigner()) .map(e -> Long.valueOf(e.getPersonId())) .orElse(null); @@ -56,20 +57,23 @@ public class CompleteVisaChangeStampHandler implements ProcessInstanceEventHandl .build(); List allRecordRelations = changeRecordRelationService.findByCondition(visaRelationDto); + log.info("CompleteVisaChangeStampHandler allRecordRelations, {}", JSON.toJSONString(allRecordRelations)); + List changeRecordRelations = allRecordRelations.stream() .filter(e -> Objects.equals(JSON.parseObject(e.getContent()).getString("approvalId"), dto.getProcessInstanceId())) .collect(Collectors.toList()); if (CollectionUtils.isEmpty(changeRecordRelations)) { - log.warn("用印审核完成数据异常，未找到对应的用印申请记录，visaId,{}; processInstanceId,{}", visaId, dto.getProcessInstanceId()); + log.warn("CompleteVisaChangeStampHandler 用印审核完成数据异常，未找到对应的用印申请记录，visaId,{}; processInstanceId,{}", visaId, dto.getProcessInstanceId()); return; } if (changeRecordRelations.size() > 1) { - log.warn("用印审核完成数据异常，找到多条对应的用印申请记录，visaId,{}; processInstanceId,{}", visaId, dto.getProcessInstanceId()); + log.warn("CompleteVisaChangeStampHandler 用印审核完成数据异常，找到多条对应的用印申请记录，visaId,{}; processInstanceId,{}", visaId, dto.getProcessInstanceId()); } ChangeRecordRelation changeRecordRelation = changeRecordRelations.stream() .findFirst() .get(); + log.info("CompleteVisaChangeStampHandler changeRecordRelation, {}", JSON.toJSONString(changeRecordRelation)); ChangeRecordRelation update = new ChangeRecordRelation(); update.setId(changeRecordRelation.getId());