From de012b69fb209a0464215c881677dbe7e255453e Mon Sep 17 00:00:00 2001 From: wangli <274027703@qq.com> Date: Fri, 5 Sep 2025 11:25:22 +0800 Subject: [PATCH] =?UTF-8?q?fix=20-=20=E8=B0=83=E6=95=B4=20xxljob?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- pom.xml | 6 ++++ workflow-engine-server/pom.xml | 4 +++ .../server/xxljob/NodeAlterJobHandler.java | 30 +++++++++++++++++++ 3 files changed, 40 insertions(+) create mode 100644 workflow-engine-server/src/main/java/cn/axzo/workflow/server/xxljob/NodeAlterJobHandler.java diff --git a/pom.xml b/pom.xml index b9cc62063..fe575363e 100644 --- a/pom.xml +++ b/pom.xml @@ -32,6 +32,7 @@ 2.0.0 2.5.0 0.0.1-SNAPSHOT + 2.0.1-SNAPSHOT @@ -179,6 +180,11 @@ doc-api ${axzo-dependencies.version} + + cn.axzo.infra + adapter + ${adapter.version} + diff --git a/workflow-engine-server/pom.xml b/workflow-engine-server/pom.xml index 10cae3ff8..dc7817d5c 100644 --- a/workflow-engine-server/pom.xml +++ b/workflow-engine-server/pom.xml @@ -154,6 +154,10 @@ cn.axzo.nanopart doc-api + + cn.axzo.infra + adapter + diff --git a/workflow-engine-server/src/main/java/cn/axzo/workflow/server/xxljob/NodeAlterJobHandler.java b/workflow-engine-server/src/main/java/cn/axzo/workflow/server/xxljob/NodeAlterJobHandler.java new file mode 100644 index 000000000..836e09668 --- /dev/null +++ b/workflow-engine-server/src/main/java/cn/axzo/workflow/server/xxljob/NodeAlterJobHandler.java @@ -0,0 +1,30 @@ +package cn.axzo.workflow.server.xxljob; + +import cn.axzo.infra.xxl220to250.IJobHandler; +import com.xxl.job.core.biz.model.ReturnT; +import com.xxl.job.core.context.XxlJobHelper; +import com.xxl.job.core.handler.annotation.XxlJob; +import lombok.RequiredArgsConstructor; +import lombok.extern.slf4j.Slf4j; +import org.springframework.stereotype.Component; + +/** + * TODO + * + * @author wangli + * @since 2025-09-05 11:19 + */ +@Component +@RequiredArgsConstructor +@Slf4j +public class NodeAlterJobHandler extends IJobHandler { + @XxlJob("nodeAlterJobHandler") + @Override + public ReturnT execute(String param) throws Exception { +// log.info(); + XxlJobHelper.log("request param: {}", param); + + + return null; + } +}