From ae7ea421eab22da8fb5e6cec3e8d8652a1e1dd5a Mon Sep 17 00:00:00 2001 From: wangli <274027703@qq.com> Date: Wed, 5 Jun 2024 21:21:25 +0800 Subject: [PATCH] =?UTF-8?q?update(REQ-2324)=20-=20=E4=BF=AE=E5=A4=8D=20tri?= =?UTF-8?q?gger=20=E6=96=B9=E6=B3=95=E5=BC=82=E6=AD=A5=E5=AF=BC=E8=87=B4?= =?UTF-8?q?=E7=9A=84=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../core/service/impl/BpmnProcessActivityServiceImpl.java | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) diff --git a/workflow-engine-core/src/main/java/cn/axzo/workflow/core/service/impl/BpmnProcessActivityServiceImpl.java b/workflow-engine-core/src/main/java/cn/axzo/workflow/core/service/impl/BpmnProcessActivityServiceImpl.java index 3a456d5ba..36bee1a63 100644 --- a/workflow-engine-core/src/main/java/cn/axzo/workflow/core/service/impl/BpmnProcessActivityServiceImpl.java +++ b/workflow-engine-core/src/main/java/cn/axzo/workflow/core/service/impl/BpmnProcessActivityServiceImpl.java @@ -9,6 +9,7 @@ import cn.axzo.workflow.core.service.BpmnProcessActivityService; import cn.axzo.workflow.core.service.ExtAxHiTaskInstService; import cn.hutool.json.JSONUtil; import lombok.extern.slf4j.Slf4j; +import org.flowable.common.engine.impl.interceptor.Command; import org.flowable.common.engine.impl.interceptor.CommandExecutor; import org.flowable.engine.RuntimeService; import org.flowable.engine.runtime.Execution; @@ -43,6 +44,7 @@ public class BpmnProcessActivityServiceImpl implements BpmnProcessActivityServic private static final String JOB_TRIGGER_ASYNC_NAME = "asyncTrigger"; private static final String JOB_ASSIGNEE_ASYNC_NAME = "asyncSetAssignee"; + @Override public void executeAsyncJob(JobEntity job) { if (job == null) { log.error("job is null"); @@ -74,7 +76,11 @@ public class BpmnProcessActivityServiceImpl implements BpmnProcessActivityServic @Override public void triggerAsync(String executionId) { - validateAndStartAsyncJob(executionId, executionId, JOB_TRIGGER_ASYNC_NAME); + processEngineConfiguration.getCommandExecutor().execute((Command) commandContext -> { + validateAndStartAsyncJob(executionId, executionId, JOB_TRIGGER_ASYNC_NAME); + return null; + }); + } @Override