From 06a84d0bcd24f58599ae03321ff1e964417b9281 Mon Sep 17 00:00:00 2001 From: yangqicheng Date: Mon, 20 May 2024 19:53:01 +0800 Subject: [PATCH] =?UTF-8?q?update=20-=20REQ-2364-=E8=B0=83=E6=95=B4?= =?UTF-8?q?=E7=B1=BB=E5=90=8D?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- ...cJobRetryHandler.java => DeadLetterJobRetryHandler.java} | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) rename workflow-engine-server/src/main/java/cn/axzo/workflow/server/xxljob/{AsyncJobRetryHandler.java => DeadLetterJobRetryHandler.java} (94%) diff --git a/workflow-engine-server/src/main/java/cn/axzo/workflow/server/xxljob/AsyncJobRetryHandler.java b/workflow-engine-server/src/main/java/cn/axzo/workflow/server/xxljob/DeadLetterJobRetryHandler.java similarity index 94% rename from workflow-engine-server/src/main/java/cn/axzo/workflow/server/xxljob/AsyncJobRetryHandler.java rename to workflow-engine-server/src/main/java/cn/axzo/workflow/server/xxljob/DeadLetterJobRetryHandler.java index a028063fe..ebae7878f 100644 --- a/workflow-engine-server/src/main/java/cn/axzo/workflow/server/xxljob/AsyncJobRetryHandler.java +++ b/workflow-engine-server/src/main/java/cn/axzo/workflow/server/xxljob/DeadLetterJobRetryHandler.java @@ -26,7 +26,7 @@ import static com.xxl.job.core.biz.model.ReturnT.FAIL_CODE; @Component @RequiredArgsConstructor @Slf4j -public class AsyncJobRetryHandler extends IJobHandler { +public class DeadLetterJobRetryHandler extends IJobHandler { @Resource private BpmnProcessVariableService variableService; @@ -35,7 +35,7 @@ public class AsyncJobRetryHandler extends IJobHandler { private BpmnProcessJobService jobService; @Override - @XxlJob("asyncJobRetry") + @XxlJob("deadLetterJobRetry") public ReturnT execute(String param) { if (StringUtils.isBlank(param)) { return new ReturnT<>(FAIL_CODE, "参数不能为空"); @@ -50,7 +50,7 @@ public class AsyncJobRetryHandler extends IJobHandler { } //设置变量 if (bean.getVariables() != null && !bean.getVariables().isEmpty()) { - variableService.updateVariables(bean.getProcessInstanceId(), bean.variables); + variableService.updateVariables(bean.getProcessInstanceId(), bean.getVariables()); } //进行重试 jobService.executeDeadLetterJobActionByProcInstId(bean.getProcessInstanceId());