From 74a12dcd282e754964c5dce3899f87c52442108b Mon Sep 17 00:00:00 2001 From: wangli <274027703@qq.com> Date: Tue, 2 Dec 2025 18:51:53 +0800 Subject: [PATCH] =?UTF-8?q?feat(REQ-5965)=20-=20=E5=A2=9E=E5=8A=A0?= =?UTF-8?q?=E5=8F=91=E9=80=81=E5=BE=85=E5=8A=9E=E5=89=8D=E7=9A=84=E5=8F=98?= =?UTF-8?q?=E9=87=8F=E6=97=A5=E5=BF=97?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../listener/notice/RocketMqMessagePushEventListener.java | 5 +++-- 1 file changed, 3 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 6d6f2efb5..4c9638cc0 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 @@ -363,12 +363,13 @@ public class RocketMqMessagePushEventListener extends AbstractBpmnEventListener< private Map collectionVariable(MessagePushEvent event) { Map variables = new HashMap<>(); - BpmnProcessInstanceVO processInstance = getContext().getInstanceVO(() -> getBpmnProcessInstanceVO(event)); Map originVariables = processInstance.getVariables().entrySet().stream() .filter(e -> Objects.nonNull(e.getKey()) && Objects.nonNull(e.getValue())) .collect(Collectors.toMap(Map.Entry::getKey, Map.Entry::getValue)); - + originVariables.forEach((k, v) -> { + log.info("流程实例变量 key: {}, value: {}", k, JSONUtil.toJsonStr(v)); + }); BpmnTaskDelegateAssigner initiator = BpmnTaskDelegateAssigner.toObjectCompatible(originVariables.get(INTERNAL_INITIATOR)); if (Objects.isNull(initiator)) { initiator = new BpmnTaskDelegateAssigner();