wangli/workflow-engine
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

update - 修改推送消息时,模板 ID 选择错误的问题

Browse Source
This commit is contained in:
wangli 2023-11-30 17:52:23 +08:00
parent 88884bb9bd
commit d2eb34298f
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/notice/RocketMqMessagePushEventListener.java
View File

@ -117,7 +117,7 @@ public class RocketMqMessagePushEventListener implements BpmnMessagePushEventLis
if (Objects.isNull(event.getNoticeConfig()) || !StringUtils.hasLength(event.getNoticeConfig().getPendingMessageId()) || Objects.isNull(event.getAssigner())) { if (Objects.isNull(event.getNoticeConfig()) || !StringUtils.hasLength(event.getNoticeConfig().getPendingMessageId()) || Objects.isNull(event.getAssigner())) {
return; return;
} }
MessagePushDTO dto = build(event.getNoticeConfig().getNoticeMessageId(), PROCESS_PUSH_PENDING, event, MessagePushDTO dto = build(event.getNoticeConfig().getPendingMessageId(), PROCESS_PUSH_PENDING, event,
collectionVariable(event)); collectionVariable(event));
log.info("MessagePushEventListener#onPending MQ.Data: {}", JSON.toJSONString(dto)); log.info("MessagePushEventListener#onPending MQ.Data: {}", JSON.toJSONString(dto));
sendMessageQueue(dto, PROCESS_PUSH_PENDING); sendMessageQueue(dto, PROCESS_PUSH_PENDING);
@ -128,7 +128,7 @@ public class RocketMqMessagePushEventListener implements BpmnMessagePushEventLis
if (Objects.isNull(event.getNoticeConfig()) || !StringUtils.hasLength(event.getNoticeConfig().getSmsId()) || Objects.isNull(event.getAssigner())) { if (Objects.isNull(event.getNoticeConfig()) || !StringUtils.hasLength(event.getNoticeConfig().getSmsId()) || Objects.isNull(event.getAssigner())) {
return; return;
} }
MessagePushDTO dto = build(event.getNoticeConfig().getNoticeMessageId(), PROCESS_PUSH_SMS, event, MessagePushDTO dto = build(event.getNoticeConfig().getSmsId(), PROCESS_PUSH_SMS, event,
collectionVariable(event)); collectionVariable(event));
log.info("MessagePushEventListener#onSms MQ.Data: {}", JSON.toJSONString(dto)); log.info("MessagePushEventListener#onSms MQ.Data: {}", JSON.toJSONString(dto));
sendMessageQueue(dto, PROCESS_PUSH_SMS); sendMessageQueue(dto, PROCESS_PUSH_SMS);