From 0bbdbca1491a6d042c85e5345c539a180b419cc0 Mon Sep 17 00:00:00 2001
From: 钟日健 <5689795+arsn@user.noreply.gitee.com>
Date: Thu, 17 Mar 2022 14:15:16 +0800
Subject: [PATCH] 新增立即启动任务和暂停任务接口

---
 deploy/deploy.yml                                                                |    2 +-
 src/main/java/org/springblade/modules/quartz/controller/ScheduledController.java |   32 ++++++++++++++++++++++++++++++++
 2 files changed, 33 insertions(+), 1 deletions(-)

diff --git a/deploy/deploy.yml b/deploy/deploy.yml
index b13d639..06eff9b 100644
--- a/deploy/deploy.yml
+++ b/deploy/deploy.yml
@@ -25,7 +25,7 @@
       imagePullSecrets:
         - name: aliyun  #提前在项目下配置访问阿里云的账号密码
       containers:
-        - image: registry.cn-hangzhou.aliyuncs.com/arsn/zhbaw:SNAPSHOT-6
+        - image: registry.cn-hangzhou.aliyuncs.com/arsn/zhbaw:SNAPSHOT-7
 #        - image: $REGISTRY/$DOCKERHUB_NAMESPACE/zhba:SNAPSHOT-$BUILD_NUMBER
           imagePullPolicy: Always
           name: zhbaw
diff --git a/src/main/java/org/springblade/modules/quartz/controller/ScheduledController.java b/src/main/java/org/springblade/modules/quartz/controller/ScheduledController.java
index 8f139c6..6f8df60 100644
--- a/src/main/java/org/springblade/modules/quartz/controller/ScheduledController.java
+++ b/src/main/java/org/springblade/modules/quartz/controller/ScheduledController.java
@@ -129,4 +129,36 @@
 		}
 		return R.status(status);
 	}
+
+	/**
+	 * 启动定时任务
+	 * @param scheduledJob
+	 * @return
+	 */
+	@PostMapping("/runQuartz")
+	public R runQuartz(@RequestBody ScheduledJob scheduledJob){
+		scheduledJob.setUpdateTime(new Date());
+		boolean status = scheduledJobService.updateById(scheduledJob);
+		if (status){
+			//立即启动任务
+			scheduleManager.run(scheduledJob);
+		}
+		return R.status(status);
+	}
+
+	/**
+	 * 定时任务恢复
+	 * @param scheduledJob
+	 * @return
+	 */
+	@PostMapping("/stopQuartz")
+	public R stopQuartz(@RequestBody ScheduledJob scheduledJob){
+		scheduledJob.setUpdateTime(new Date());
+		boolean status = scheduledJobService.updateById(scheduledJob);
+		if (status){
+			//暂停定时任务
+			scheduleManager.pauseJob(scheduledJob);
+		}
+		return R.status(status);
+	}
 }

--
Gitblit v1.9.3