From 250110ff9127123eb5308f0e4b5bef70b5ffecea Mon Sep 17 00:00:00 2001 From: wangli <274027703@qq.com> Date: Tue, 23 Apr 2024 16:29:35 +0800 Subject: [PATCH] =?UTF-8?q?update=20-=20=E5=9C=A8=E5=8F=91=E9=80=81?= =?UTF-8?q?=E5=BE=85=E5=8A=9E=E6=97=B6,=E9=80=8F=E4=BC=A0=E7=94=A8?= =?UTF-8?q?=E4=BA=8E=E6=9F=A5=E8=AF=A2=E8=83=BD=E7=94=A8=E6=8C=89=E9=92=AE?= =?UTF-8?q?=E7=9A=84=E5=89=8D=E7=BD=AE=E6=95=B0=E6=8D=AE?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../listener/notice/RocketMqMessagePushEventListener.java | 6 +++--- 1 file changed, 3 insertions(+), 3 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 f91779c87..d320e290e 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 @@ -153,20 +153,20 @@ public class RocketMqMessagePushEventListener extends AbstractBpmnEventListener< PROCESS_PUSH_PENDING, event, collectionVariable(event)); List buttons = new ArrayList<>(); - // TODO 发送待办时, 计算当前人能操作的按钮有哪些? + // 发送待办时, 计算当前人能操作的按钮有哪些? if (StringUtils.hasText(event.getProcessDefinitionId())) { BpmnTaskDelegateAssigner bpmnTaskDelegateAssigner = event.getAssigners().get(0); Process process = getContext().getProcess(() -> ProcessDefinitionUtil.getBpmnModel(event.getProcessDefinitionId()).getMainProcess()); BpmnMetaParserHelper.getButtonConfig(process, event.getCurrentTaskDefinitionKey()) .ifPresent(buttonConf -> { BpmnProcessInstanceVO instance = getContext().getInstanceVO(() -> getBpmnProcessInstanceVO(event)); - if (bpmnTaskDelegateAssigner.comparePersonIdToOther(instance.getStartUserId())) { + if (bpmnTaskDelegateAssigner.comparePersonIdToOther(instance.getInitiator())) { buttons.addAll(buttonConf.getInitiator()); } buttons.addAll(buttonConf.getCurrent()); }); } - + dto.setButtons(buttons); sendMessageQueue(dto, PROCESS_PUSH_PENDING); } if (log.isDebugEnabled()) {