wangli/nanopart
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat(REQ-3581) - 添加调用消息的通知日志打印

Browse Source
This commit is contained in:
wangli 2025-03-20 11:43:17 +08:00
parent 6913a23b25
commit c5e23cc7cd
1 changed files with 16 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
visa/visa-server/src/main/java/cn/axzo/nanopart/visa/server/mq/listener/workflow/process/ProcessInstanceOfVisaAllEventHandler.java
View File

@ -125,9 +125,16 @@ public class ProcessInstanceOfVisaAllEventHandler extends BasicLogSupport implem
private void sendCompleteNotice(ProcessInstanceDTO dto) {
Map<String, Object> variables = dto.getVariables();
BpmnTaskDelegateAssigner initiator = dto.getInitiator();
MessageSendReqV3 completeNotice = new MessageSendReqV3();
completeNotice.setSender(PersonV3DTO.builder().build());
completeNotice.setReceivers(Lists.newArrayList(PersonV3DTO.builder().build()));
completeNotice.setReceivers(Lists.newArrayList(PersonV3DTO.builder()
.id(Long.valueOf(initiator.getPersonId()))
.name(initiator.getAssignerName())
.imReceiveModel(new PersonV3DTO.ReceiveModel(
StringUtils.hasText(initiator.getOuId()) && !Objects.equals("null", initiator.getOuId()) ? Long.valueOf(initiator.getOuId()) : null,
StringUtils.hasText(initiator.getTenantId()) && !Objects.equals("null", initiator.getTenantId()) ? Long.valueOf(initiator.getTenantId()) : null))
.build()));
completeNotice.setBizEventMappingCode(refreshableConfiguration.getProcessInstanceCompleteMsgEventCode());
completeNotice.setBizCode(dto.getBusinessKey());
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
@ -196,9 +203,16 @@ public class ProcessInstanceOfVisaAllEventHandler extends BasicLogSupport implem
private void sendRejectNotice(ProcessInstanceDTO dto) {
Map<String, Object> variables = dto.getVariables();
BpmnTaskDelegateAssigner initiator = dto.getInitiator();
MessageSendReqV3 rejectNotice = new MessageSendReqV3();
rejectNotice.setSender(PersonV3DTO.builder().build());
rejectNotice.setReceivers(Lists.newArrayList(PersonV3DTO.builder().build()));
rejectNotice.setReceivers(Lists.newArrayList(PersonV3DTO.builder()
.id(Long.valueOf(initiator.getPersonId()))
.name(initiator.getAssignerName())
.imReceiveModel(new PersonV3DTO.ReceiveModel(
StringUtils.hasText(initiator.getOuId()) && !Objects.equals("null", initiator.getOuId()) ? Long.valueOf(initiator.getOuId()) : null,
StringUtils.hasText(initiator.getTenantId()) && !Objects.equals("null", initiator.getTenantId()) ? Long.valueOf(initiator.getTenantId()) : null))
.build()));
rejectNotice.setBizEventMappingCode(refreshableConfiguration.getProcessInstanceRejectMsgEventCode());
rejectNotice.setBizCode(dto.getBusinessKey());
rejectNotice.setBizExtParams(new JSONObject(Maps.of(