From cd3157a751d5fa519b410ace661c94e4b6217a53 Mon Sep 17 00:00:00 2001
From: bunny <1319900154@qq.com>
Date: Fri, 26 Jul 2024 13:12:26 +0800
Subject: [PATCH] =?UTF-8?q?:rocket:=20feat(=E6=96=B0=E5=A2=9E):=20?=
 =?UTF-8?q?=E6=9A=82=E5=81=9C=E4=BB=BB=E5=8A=A1?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../cn/bunny/dto/quartz/QuartzAddDto.java     | 19 ++++++++++++++++++
 .../cn/bunny/dto/quartz/QuartzPauseDto.java   | 15 ++++++++++++++
 .../quartz/BlobTriggersController.java        | 20 -------------------
 .../quartz/CalendarsController.java           | 18 -----------------
 .../quartz/CronTriggersController.java        | 18 -----------------
 .../quartz/FiredTriggersController.java       | 18 -----------------
 .../controller/quartz/JobController.java      | 17 ++++++++++------
 .../controller/quartz/LocksController.java    | 18 -----------------
 .../quartz/PausedTriggerGrpsController.java   | 18 -----------------
 .../quartz/SchedulerStateController.java      | 18 -----------------
 .../quartz/SimpleTriggersController.java      | 18 -----------------
 .../quartz/SimpropTriggersController.java     | 18 -----------------
 .../controller/quartz/TriggersController.java | 18 -----------------
 .../service/service/quartz/JobService.java    | 12 +++++++++--
 .../service/quartz/impl/JobServiceImpl.java   | 17 ++++++++++++++--
 15 files changed, 70 insertions(+), 192 deletions(-)
 create mode 100644 dao/src/main/java/cn/bunny/dto/quartz/QuartzAddDto.java
 create mode 100644 dao/src/main/java/cn/bunny/dto/quartz/QuartzPauseDto.java
 delete mode 100644 service/src/main/java/cn/bunny/service/controller/quartz/BlobTriggersController.java
 delete mode 100644 service/src/main/java/cn/bunny/service/controller/quartz/CalendarsController.java
 delete mode 100644 service/src/main/java/cn/bunny/service/controller/quartz/CronTriggersController.java
 delete mode 100644 service/src/main/java/cn/bunny/service/controller/quartz/FiredTriggersController.java
 delete mode 100644 service/src/main/java/cn/bunny/service/controller/quartz/LocksController.java
 delete mode 100644 service/src/main/java/cn/bunny/service/controller/quartz/PausedTriggerGrpsController.java
 delete mode 100644 service/src/main/java/cn/bunny/service/controller/quartz/SchedulerStateController.java
 delete mode 100644 service/src/main/java/cn/bunny/service/controller/quartz/SimpleTriggersController.java
 delete mode 100644 service/src/main/java/cn/bunny/service/controller/quartz/SimpropTriggersController.java
 delete mode 100644 service/src/main/java/cn/bunny/service/controller/quartz/TriggersController.java

diff --git a/dao/src/main/java/cn/bunny/dto/quartz/QuartzAddDto.java b/dao/src/main/java/cn/bunny/dto/quartz/QuartzAddDto.java
new file mode 100644
index 0000000..6f36b9a
--- /dev/null
+++ b/dao/src/main/java/cn/bunny/dto/quartz/QuartzAddDto.java
@@ -0,0 +1,19 @@
+package cn.bunny.dto.quartz;
+
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
+@Builder
+public class QuartzAddDto {
+    private String jobName;// 任务名称
+    private String jobGroup;// 任务分组
+    private String cronExpression;// 执行时间
+    private String description;// 任务描述
+    private String jobMethodName;// 执行方法
+    private String jobClassName;// 执行类
+}
diff --git a/dao/src/main/java/cn/bunny/dto/quartz/QuartzPauseDto.java b/dao/src/main/java/cn/bunny/dto/quartz/QuartzPauseDto.java
new file mode 100644
index 0000000..df02447
--- /dev/null
+++ b/dao/src/main/java/cn/bunny/dto/quartz/QuartzPauseDto.java
@@ -0,0 +1,15 @@
+package cn.bunny.dto.quartz;
+
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
+@Builder
+public class QuartzPauseDto {
+    private String jobName;// 任务名称
+    private String jobGroup;// 任务分组
+}
diff --git a/service/src/main/java/cn/bunny/service/controller/quartz/BlobTriggersController.java b/service/src/main/java/cn/bunny/service/controller/quartz/BlobTriggersController.java
deleted file mode 100644
index adaa9b9..0000000
--- a/service/src/main/java/cn/bunny/service/controller/quartz/BlobTriggersController.java
+++ /dev/null
@@ -1,20 +0,0 @@
-package cn.bunny.service.controller.quartz;
-
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RestController;
-
-/**
- * <p>
- *  前端控制器
- * </p>
- *
- * @author Bunny
- * @since 2024-07-25
- */
-@RestController
-@RequestMapping("/blobTriggers")
-public class BlobTriggersController {
-// qrtz_job_details
-// qrtz_triggers
-// qrtz_cron_triggers
-}
diff --git a/service/src/main/java/cn/bunny/service/controller/quartz/CalendarsController.java b/service/src/main/java/cn/bunny/service/controller/quartz/CalendarsController.java
deleted file mode 100644
index 8d497ad..0000000
--- a/service/src/main/java/cn/bunny/service/controller/quartz/CalendarsController.java
+++ /dev/null
@@ -1,18 +0,0 @@
-package cn.bunny.service.controller.quartz;
-
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RestController;
-
-/**
- * <p>
- *  前端控制器
- * </p>
- *
- * @author Bunny
- * @since 2024-07-25
- */
-@RestController
-@RequestMapping("/calendars")
-public class CalendarsController {
-
-}
diff --git a/service/src/main/java/cn/bunny/service/controller/quartz/CronTriggersController.java b/service/src/main/java/cn/bunny/service/controller/quartz/CronTriggersController.java
deleted file mode 100644
index b364890..0000000
--- a/service/src/main/java/cn/bunny/service/controller/quartz/CronTriggersController.java
+++ /dev/null
@@ -1,18 +0,0 @@
-package cn.bunny.service.controller.quartz;
-
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RestController;
-
-/**
- * <p>
- *  前端控制器
- * </p>
- *
- * @author Bunny
- * @since 2024-07-25
- */
-@RestController
-@RequestMapping("/cronTriggers")
-public class CronTriggersController {
-
-}
diff --git a/service/src/main/java/cn/bunny/service/controller/quartz/FiredTriggersController.java b/service/src/main/java/cn/bunny/service/controller/quartz/FiredTriggersController.java
deleted file mode 100644
index 9004114..0000000
--- a/service/src/main/java/cn/bunny/service/controller/quartz/FiredTriggersController.java
+++ /dev/null
@@ -1,18 +0,0 @@
-package cn.bunny.service.controller.quartz;
-
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RestController;
-
-/**
- * <p>
- *  前端控制器
- * </p>
- *
- * @author Bunny
- * @since 2024-07-25
- */
-@RestController
-@RequestMapping("/firedTriggers")
-public class FiredTriggersController {
-
-}
diff --git a/service/src/main/java/cn/bunny/service/controller/quartz/JobController.java b/service/src/main/java/cn/bunny/service/controller/quartz/JobController.java
index a02aecd..cb71774 100644
--- a/service/src/main/java/cn/bunny/service/controller/quartz/JobController.java
+++ b/service/src/main/java/cn/bunny/service/controller/quartz/JobController.java
@@ -1,15 +1,13 @@
 package cn.bunny.service.controller.quartz;
 
-import cn.bunny.dto.quartz.QuartzDto;
+import cn.bunny.dto.quartz.QuartzAddDto;
+import cn.bunny.dto.quartz.QuartzPauseDto;
 import cn.bunny.pojo.result.Result;
 import cn.bunny.service.service.quartz.JobService;
 import io.swagger.v3.oas.annotations.Operation;
 import io.swagger.v3.oas.annotations.tags.Tag;
 import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.web.bind.annotation.PostMapping;
-import org.springframework.web.bind.annotation.RequestBody;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.bind.annotation.*;
 
 @Tag(name = "Quartz定时任务")
 @RestController
@@ -21,8 +19,15 @@ public class JobController {
 
     @Operation(summary = "添加任务", description = "添加任务")
     @PostMapping("/add")
-    public Result<String> addJob(@RequestBody QuartzDto dto) {
+    public Result<String> addJob(@RequestBody QuartzAddDto dto) {
         jobService.addJob(dto);
         return Result.success();
     }
+
+    @Operation(summary = "暂停任务", description = "暂停任务")
+    @PutMapping("/pause")
+    public Result<String> pause(@RequestBody QuartzPauseDto dto) {
+        jobService.pause(dto);
+        return Result.success();
+    }
 }
\ No newline at end of file
diff --git a/service/src/main/java/cn/bunny/service/controller/quartz/LocksController.java b/service/src/main/java/cn/bunny/service/controller/quartz/LocksController.java
deleted file mode 100644
index 512fef6..0000000
--- a/service/src/main/java/cn/bunny/service/controller/quartz/LocksController.java
+++ /dev/null
@@ -1,18 +0,0 @@
-package cn.bunny.service.controller.quartz;
-
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RestController;
-
-/**
- * <p>
- *  前端控制器
- * </p>
- *
- * @author Bunny
- * @since 2024-07-25
- */
-@RestController
-@RequestMapping("/locks")
-public class LocksController {
-
-}
diff --git a/service/src/main/java/cn/bunny/service/controller/quartz/PausedTriggerGrpsController.java b/service/src/main/java/cn/bunny/service/controller/quartz/PausedTriggerGrpsController.java
deleted file mode 100644
index 721f232..0000000
--- a/service/src/main/java/cn/bunny/service/controller/quartz/PausedTriggerGrpsController.java
+++ /dev/null
@@ -1,18 +0,0 @@
-package cn.bunny.service.controller.quartz;
-
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RestController;
-
-/**
- * <p>
- *  前端控制器
- * </p>
- *
- * @author Bunny
- * @since 2024-07-25
- */
-@RestController
-@RequestMapping("/pausedTriggerGrps")
-public class PausedTriggerGrpsController {
-
-}
diff --git a/service/src/main/java/cn/bunny/service/controller/quartz/SchedulerStateController.java b/service/src/main/java/cn/bunny/service/controller/quartz/SchedulerStateController.java
deleted file mode 100644
index d4a81b9..0000000
--- a/service/src/main/java/cn/bunny/service/controller/quartz/SchedulerStateController.java
+++ /dev/null
@@ -1,18 +0,0 @@
-package cn.bunny.service.controller.quartz;
-
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RestController;
-
-/**
- * <p>
- *  前端控制器
- * </p>
- *
- * @author Bunny
- * @since 2024-07-25
- */
-@RestController
-@RequestMapping("/schedulerState")
-public class SchedulerStateController {
-
-}
diff --git a/service/src/main/java/cn/bunny/service/controller/quartz/SimpleTriggersController.java b/service/src/main/java/cn/bunny/service/controller/quartz/SimpleTriggersController.java
deleted file mode 100644
index 0569735..0000000
--- a/service/src/main/java/cn/bunny/service/controller/quartz/SimpleTriggersController.java
+++ /dev/null
@@ -1,18 +0,0 @@
-package cn.bunny.service.controller.quartz;
-
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RestController;
-
-/**
- * <p>
- *  前端控制器
- * </p>
- *
- * @author Bunny
- * @since 2024-07-25
- */
-@RestController
-@RequestMapping("/simpleTriggers")
-public class SimpleTriggersController {
-
-}
diff --git a/service/src/main/java/cn/bunny/service/controller/quartz/SimpropTriggersController.java b/service/src/main/java/cn/bunny/service/controller/quartz/SimpropTriggersController.java
deleted file mode 100644
index 81f63ae..0000000
--- a/service/src/main/java/cn/bunny/service/controller/quartz/SimpropTriggersController.java
+++ /dev/null
@@ -1,18 +0,0 @@
-package cn.bunny.service.controller.quartz;
-
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RestController;
-
-/**
- * <p>
- *  前端控制器
- * </p>
- *
- * @author Bunny
- * @since 2024-07-25
- */
-@RestController
-@RequestMapping("/simpropTriggers")
-public class SimpropTriggersController {
-
-}
diff --git a/service/src/main/java/cn/bunny/service/controller/quartz/TriggersController.java b/service/src/main/java/cn/bunny/service/controller/quartz/TriggersController.java
deleted file mode 100644
index b1e3de0..0000000
--- a/service/src/main/java/cn/bunny/service/controller/quartz/TriggersController.java
+++ /dev/null
@@ -1,18 +0,0 @@
-package cn.bunny.service.controller.quartz;
-
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RestController;
-
-/**
- * <p>
- *  前端控制器
- * </p>
- *
- * @author Bunny
- * @since 2024-07-25
- */
-@RestController
-@RequestMapping("/triggers")
-public class TriggersController {
-
-}
diff --git a/service/src/main/java/cn/bunny/service/service/quartz/JobService.java b/service/src/main/java/cn/bunny/service/service/quartz/JobService.java
index cd3883d..d2de3ad 100644
--- a/service/src/main/java/cn/bunny/service/service/quartz/JobService.java
+++ b/service/src/main/java/cn/bunny/service/service/quartz/JobService.java
@@ -1,6 +1,7 @@
 package cn.bunny.service.service.quartz;
 
-import cn.bunny.dto.quartz.QuartzDto;
+import cn.bunny.dto.quartz.QuartzAddDto;
+import cn.bunny.dto.quartz.QuartzPauseDto;
 import cn.bunny.entity.system.quartz.JobDetails;
 import com.baomidou.mybatisplus.extension.service.IService;
 
@@ -11,5 +12,12 @@ public interface JobService extends IService<JobDetails> {
      *
      * @param dto 添加任务
      */
-    void addJob(QuartzDto dto);
+    void addJob(QuartzAddDto dto);
+
+    /**
+     * * 暂停任务
+     *
+     * @param dto 暂停任务
+     */
+    void pause(QuartzPauseDto dto);
 }
diff --git a/service/src/main/java/cn/bunny/service/service/quartz/impl/JobServiceImpl.java b/service/src/main/java/cn/bunny/service/service/quartz/impl/JobServiceImpl.java
index ce32d7a..b9cde1e 100644
--- a/service/src/main/java/cn/bunny/service/service/quartz/impl/JobServiceImpl.java
+++ b/service/src/main/java/cn/bunny/service/service/quartz/impl/JobServiceImpl.java
@@ -1,6 +1,7 @@
 package cn.bunny.service.service.quartz.impl;
 
-import cn.bunny.dto.quartz.QuartzDto;
+import cn.bunny.dto.quartz.QuartzAddDto;
+import cn.bunny.dto.quartz.QuartzPauseDto;
 import cn.bunny.entity.system.quartz.JobDetails;
 import cn.bunny.service.mapper.quartz.JobDetailsMapper;
 import cn.bunny.service.service.quartz.JobService;
@@ -28,7 +29,7 @@ public class JobServiceImpl extends ServiceImpl<JobDetailsMapper, JobDetails> im
      */
     @SneakyThrows
     @Override
-    public void addJob(QuartzDto dto) {
+    public void addJob(QuartzAddDto dto) {
         String jobGroup = dto.getJobGroup();
         String jobName = dto.getJobName();
         String cronExpression = dto.getCronExpression();
@@ -53,4 +54,16 @@ public class JobServiceImpl extends ServiceImpl<JobDetailsMapper, JobDetails> im
                 .startNow().withSchedule(cronScheduleBuilder).build();
         scheduler.scheduleJob(jobDetail, trigger);
     }
+
+    /**
+     * * 暂停任务
+     *
+     * @param dto 暂停任务
+     */
+    @SneakyThrows
+    @Override
+    public void pause(QuartzPauseDto dto) {
+        JobKey key = new JobKey(dto.getJobName(), dto.getJobGroup());
+        scheduler.pauseJob(key);
+    }
 }