From d2eb34298f2124072552432aa6170968fa887136 Mon Sep 17 00:00:00 2001 From: wangli <274027703@qq.com> Date: Thu, 30 Nov 2023 17:52:23 +0800 Subject: [PATCH] =?UTF-8?q?update=20-=20=E4=BF=AE=E6=94=B9=E6=8E=A8?= =?UTF-8?q?=E9=80=81=E6=B6=88=E6=81=AF=E6=97=B6,=E6=A8=A1=E6=9D=BF=20ID=20?= =?UTF-8?q?=E9=80=89=E6=8B=A9=E9=94=99=E8=AF=AF=E7=9A=84=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../listener/notice/RocketMqMessagePushEventListener.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/notice/RocketMqMessagePushEventListener.java b/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/notice/RocketMqMessagePushEventListener.java index 8622dddd0..79bae021c 100644 --- a/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/notice/RocketMqMessagePushEventListener.java +++ b/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/notice/RocketMqMessagePushEventListener.java @@ -117,7 +117,7 @@ public class RocketMqMessagePushEventListener implements BpmnMessagePushEventLis if (Objects.isNull(event.getNoticeConfig()) || !StringUtils.hasLength(event.getNoticeConfig().getPendingMessageId()) || Objects.isNull(event.getAssigner())) { return; } - MessagePushDTO dto = build(event.getNoticeConfig().getNoticeMessageId(), PROCESS_PUSH_PENDING, event, + MessagePushDTO dto = build(event.getNoticeConfig().getPendingMessageId(), PROCESS_PUSH_PENDING, event, collectionVariable(event)); log.info("MessagePushEventListener#onPending MQ.Data: {}", JSON.toJSONString(dto)); 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())) { return; } - MessagePushDTO dto = build(event.getNoticeConfig().getNoticeMessageId(), PROCESS_PUSH_SMS, event, + MessagePushDTO dto = build(event.getNoticeConfig().getSmsId(), PROCESS_PUSH_SMS, event, collectionVariable(event)); log.info("MessagePushEventListener#onSms MQ.Data: {}", JSON.toJSONString(dto)); sendMessageQueue(dto, PROCESS_PUSH_SMS);