diff --git a/jero-boot/jero-boot-module-system/src/main/java/com/jero/modules/quartz/controller/QuartzJobController.java b/jero-boot/jero-boot-module-system/src/main/java/com/jero/modules/quartz/controller/QuartzJobController.java index 03ea71ca..83f4380c 100644 --- a/jero-boot/jero-boot-module-system/src/main/java/com/jero/modules/quartz/controller/QuartzJobController.java +++ b/jero-boot/jero-boot-module-system/src/main/java/com/jero/modules/quartz/controller/QuartzJobController.java @@ -89,10 +89,6 @@ public class QuartzJobController { //@RequiresRoles("admin") @RequestMapping(value = "/add", method = RequestMethod.POST) public Result add(@RequestBody QuartzJob quartzJob) { - List list = quartzJobService.findByJobClassName(quartzJob.getJobClassName()); - if (list != null && list.size() > 0) { - return Result.error("该定时任务类名已存在"); - } quartzJobService.saveAndScheduleJob(quartzJob); return Result.OK("创建定时任务成功"); } @@ -155,39 +151,38 @@ public class QuartzJobController { /** * 暂停定时任务 * - * @param jobClassName + * @param id * @return */ //@RequiresRoles("admin") @GetMapping(value = "/pause") @ApiOperation(value = "暂停定时任务") - public Result pauseJob(@RequestParam(name = "jobClassName", required = true) String jobClassName) { - QuartzJob job = null; - job = quartzJobService.getOne(new LambdaQueryWrapper().eq(QuartzJob::getJobClassName, jobClassName)); + public Result pauseJob(@RequestParam(name = "id") String id) { + QuartzJob job = quartzJobService.getById(id); if (job == null) { return Result.error("定时任务不存在!"); } quartzJobService.pause(job); - return Result.OK("暂停定时任务成功"); + return Result.ok("暂停定时任务成功"); } /** * 启动定时任务 - * - * @param jobClassName + * + * @param id * @return */ //@RequiresRoles("admin") @GetMapping(value = "/resume") @ApiOperation(value = "恢复定时任务") - public Result resumeJob(@RequestParam(name = "jobClassName", required = true) String jobClassName) { - QuartzJob job = quartzJobService.getOne(new LambdaQueryWrapper().eq(QuartzJob::getJobClassName, jobClassName)); + public Result resumeJob(@RequestParam(name = "id") String id) { + QuartzJob job = quartzJobService.getById(id); if (job == null) { return Result.error("定时任务不存在!"); } quartzJobService.resumeJob(job); //scheduler.resumeJob(JobKey.jobKey(job.getJobClassName().trim())); - return Result.OK("恢复定时任务成功"); + return Result.ok("恢复定时任务成功"); } /** diff --git a/jero-boot/jero-boot-module-system/src/main/java/com/jero/modules/quartz/job/SampleParamJob.java b/jero-boot/jero-boot-module-system/src/main/java/com/jero/modules/quartz/job/SampleParamJob.java index 0d2b289d..e6120624 100644 --- a/jero-boot/jero-boot-module-system/src/main/java/com/jero/modules/quartz/job/SampleParamJob.java +++ b/jero-boot/jero-boot-module-system/src/main/java/com/jero/modules/quartz/job/SampleParamJob.java @@ -26,7 +26,7 @@ public class SampleParamJob implements Job { @Override public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException { - - log.info(String.format("welcome %s! jero-boot 带参数定时任务 SampleParamJob ! 时间:" + DateUtils.now(), this.parameter)); + log.info(" Job Execution key:"+jobExecutionContext.getJobDetail().getKey()); + log.info( String.format("welcome %s! Jeecg-Boot 带参数定时任务 SampleParamJob ! 时间:" + DateUtils.now(), this.parameter)); } } diff --git a/jero-boot/jero-boot-module-system/src/main/java/com/jero/modules/quartz/service/impl/QuartzJobServiceImpl.java b/jero-boot/jero-boot-module-system/src/main/java/com/jero/modules/quartz/service/impl/QuartzJobServiceImpl.java index d039b6df..fc56862b 100644 --- a/jero-boot/jero-boot-module-system/src/main/java/com/jero/modules/quartz/service/impl/QuartzJobServiceImpl.java +++ b/jero-boot/jero-boot-module-system/src/main/java/com/jero/modules/quartz/service/impl/QuartzJobServiceImpl.java @@ -41,18 +41,18 @@ public class QuartzJobServiceImpl extends ServiceImpl