From d811b2e0de3e6bd8cf6848ea374d877fab2f5e41 Mon Sep 17 00:00:00 2001 From: bunny <1319900154@qq.com> Date: Fri, 26 Jul 2024 13:15:33 +0800 Subject: [PATCH] =?UTF-8?q?:rocket:=20feat(=E6=96=B0=E5=A2=9E):=20?= =?UTF-8?q?=E6=81=A2=E5=A4=8D=E4=BB=BB=E5=8A=A1?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- ...PauseDto.java => QuartzPauseOrResumeDto.java} | 2 +- .../service/controller/quartz/JobController.java | 11 +++++++++-- .../bunny/service/service/quartz/JobService.java | 11 +++++++++-- .../service/quartz/impl/JobServiceImpl.java | 16 ++++++++++++++-- 4 files changed, 33 insertions(+), 7 deletions(-) rename dao/src/main/java/cn/bunny/dto/quartz/{QuartzPauseDto.java => QuartzPauseOrResumeDto.java} (88%) diff --git a/dao/src/main/java/cn/bunny/dto/quartz/QuartzPauseDto.java b/dao/src/main/java/cn/bunny/dto/quartz/QuartzPauseOrResumeDto.java similarity index 88% rename from dao/src/main/java/cn/bunny/dto/quartz/QuartzPauseDto.java rename to dao/src/main/java/cn/bunny/dto/quartz/QuartzPauseOrResumeDto.java index df02447..bb0a6d9 100644 --- a/dao/src/main/java/cn/bunny/dto/quartz/QuartzPauseDto.java +++ b/dao/src/main/java/cn/bunny/dto/quartz/QuartzPauseOrResumeDto.java @@ -9,7 +9,7 @@ import lombok.NoArgsConstructor; @AllArgsConstructor @NoArgsConstructor @Builder -public class QuartzPauseDto { +public class QuartzPauseOrResumeDto { private String jobName;// 任务名称 private String jobGroup;// 任务分组 } 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 cb71774..dc6d6a3 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,7 +1,7 @@ package cn.bunny.service.controller.quartz; import cn.bunny.dto.quartz.QuartzAddDto; -import cn.bunny.dto.quartz.QuartzPauseDto; +import cn.bunny.dto.quartz.QuartzPauseOrResumeDto; import cn.bunny.pojo.result.Result; import cn.bunny.service.service.quartz.JobService; import io.swagger.v3.oas.annotations.Operation; @@ -26,8 +26,15 @@ public class JobController { @Operation(summary = "暂停任务", description = "暂停任务") @PutMapping("/pause") - public Result pause(@RequestBody QuartzPauseDto dto) { + public Result pause(@RequestBody QuartzPauseOrResumeDto dto) { jobService.pause(dto); return Result.success(); } + + @Operation(summary = "恢复任务", description = "恢复任务") + @PutMapping("/resume") + public Result resume(@RequestBody QuartzPauseOrResumeDto dto) { + jobService.resume(dto); + return Result.success(); + } } \ No newline at end of file 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 d2de3ad..47f9013 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,7 +1,7 @@ package cn.bunny.service.service.quartz; import cn.bunny.dto.quartz.QuartzAddDto; -import cn.bunny.dto.quartz.QuartzPauseDto; +import cn.bunny.dto.quartz.QuartzPauseOrResumeDto; import cn.bunny.entity.system.quartz.JobDetails; import com.baomidou.mybatisplus.extension.service.IService; @@ -19,5 +19,12 @@ public interface JobService extends IService { * * @param dto 暂停任务 */ - void pause(QuartzPauseDto dto); + void pause(QuartzPauseOrResumeDto dto); + + /** + * * 恢复任务 + * + * @param dto 恢复任务 + */ + void resume(QuartzPauseOrResumeDto 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 b9cde1e..d101b52 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,7 +1,7 @@ package cn.bunny.service.service.quartz.impl; import cn.bunny.dto.quartz.QuartzAddDto; -import cn.bunny.dto.quartz.QuartzPauseDto; +import cn.bunny.dto.quartz.QuartzPauseOrResumeDto; import cn.bunny.entity.system.quartz.JobDetails; import cn.bunny.service.mapper.quartz.JobDetailsMapper; import cn.bunny.service.service.quartz.JobService; @@ -62,8 +62,20 @@ public class JobServiceImpl extends ServiceImpl im */ @SneakyThrows @Override - public void pause(QuartzPauseDto dto) { + public void pause(QuartzPauseOrResumeDto dto) { JobKey key = new JobKey(dto.getJobName(), dto.getJobGroup()); scheduler.pauseJob(key); } + + /** + * * 恢复任务 + * + * @param dto 恢复任务 + */ + @SneakyThrows + @Override + public void resume(QuartzPauseOrResumeDto dto) { + JobKey key = new JobKey(dto.getJobName(), dto.getJobGroup()); + scheduler.resumeJob(key); + } }