From 04b6ba9d4aca333aae1560971923d6ab211908db Mon Sep 17 00:00:00 2001
From: srzou <srzou@outlook.com>
Date: Sat, 19 Oct 2024 21:12:02 +0800
Subject: [PATCH] =?UTF-8?q?=E6=96=B0=E5=A2=9E=20query=E3=80=81trigger?=
 =?UTF-8?q?=E3=80=81updateStatus=20=E7=9B=B8=E5=85=B3demo?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../snailjob/handler/TestQueryJobHandler.java | 19 ++++++++++
 .../handler/TestTriggerJobHandler.java        | 28 +++++++++++++++
 .../handler/TestUpdateJobStatusHandler.java   | 35 +++++++++++++++++++
 3 files changed, 82 insertions(+)
 create mode 100644 src/main/java/com/example/snailjob/handler/TestQueryJobHandler.java
 create mode 100644 src/main/java/com/example/snailjob/handler/TestTriggerJobHandler.java
 create mode 100644 src/main/java/com/example/snailjob/handler/TestUpdateJobStatusHandler.java

diff --git a/src/main/java/com/example/snailjob/handler/TestQueryJobHandler.java b/src/main/java/com/example/snailjob/handler/TestQueryJobHandler.java
new file mode 100644
index 0000000..d78fa55
--- /dev/null
+++ b/src/main/java/com/example/snailjob/handler/TestQueryJobHandler.java
@@ -0,0 +1,19 @@
+package com.example.snailjob.handler;
+
+import com.aizuda.snailjob.client.job.core.dto.JobResponseVO;
+import com.aizuda.snailjob.client.job.core.openapi.SnailJobOpenApi;
+import org.springframework.stereotype.Component;
+
+@Component
+public class TestQueryJobHandler {
+
+    /**
+     * 查看任务详情
+     *
+     * @param jobId
+     * @return 任务详情
+     */
+    public JobResponseVO queryJob(Long jobId){
+        return SnailJobOpenApi.getJobDetail(jobId).execute();
+    }
+}
diff --git a/src/main/java/com/example/snailjob/handler/TestTriggerJobHandler.java b/src/main/java/com/example/snailjob/handler/TestTriggerJobHandler.java
new file mode 100644
index 0000000..1d22f47
--- /dev/null
+++ b/src/main/java/com/example/snailjob/handler/TestTriggerJobHandler.java
@@ -0,0 +1,28 @@
+package com.example.snailjob.handler;
+
+import com.aizuda.snailjob.client.job.core.openapi.SnailJobOpenApi;
+import org.springframework.stereotype.Component;
+
+@Component
+public class TestTriggerJobHandler {
+
+    /**
+     * 手动调度任务
+     *
+     * @param jobId 任务ID
+     * @return
+     */
+    public Boolean triggerJob(Long jobId){
+        return SnailJobOpenApi.triggerJob(jobId).execute();
+    }
+
+    /**
+     * 手动调度工作流任务
+     *
+     * @param workFlowId 工作流任务ID
+     * @return
+     */
+    public Boolean triggerWorkFlow(Long workFlowId){
+        return SnailJobOpenApi.triggerWorkFlow(workFlowId).execute();
+    }
+}
diff --git a/src/main/java/com/example/snailjob/handler/TestUpdateJobStatusHandler.java b/src/main/java/com/example/snailjob/handler/TestUpdateJobStatusHandler.java
new file mode 100644
index 0000000..2483061
--- /dev/null
+++ b/src/main/java/com/example/snailjob/handler/TestUpdateJobStatusHandler.java
@@ -0,0 +1,35 @@
+package com.example.snailjob.handler;
+
+import com.aizuda.snailjob.client.job.core.openapi.SnailJobOpenApi;
+import com.aizuda.snailjob.common.core.enums.StatusEnum;
+import org.springframework.stereotype.Component;
+
+@Component
+public class TestUpdateJobStatusHandler {
+
+    /**
+     * 更新定时任务状态
+     *
+     * @param jobId 定时任务ID
+     * @return
+     */
+    public Boolean updateJobStatus(Long jobId){
+        return SnailJobOpenApi
+                .updateJobStatus(jobId)
+                .setStatus(StatusEnum.NO)
+                .execute();
+    }
+
+    /**
+     * 更新工作流任务状态
+     *
+     * @param workFlowId 工作流ID
+     * @return
+     */
+    public Boolean updateWorkFlowStatus(Long workFlowId){
+        return SnailJobOpenApi
+                .updateWorkFlowStatus(workFlowId)
+                .setStatus(StatusEnum.YES)
+                .execute();
+    }
+}