|
@@ -18,6 +18,7 @@
|
|
|
package net.yyc.quartz.config;
|
|
package net.yyc.quartz.config;
|
|
|
|
|
|
|
|
import net.yyc.quartz.constants.QuartzEnum;
|
|
import net.yyc.quartz.constants.QuartzEnum;
|
|
|
|
|
+import net.yyc.quartz.entity.SysJob;
|
|
|
import net.yyc.quartz.service.SysJobService;
|
|
import net.yyc.quartz.service.SysJobService;
|
|
|
import net.yyc.quartz.util.TaskUtil;
|
|
import net.yyc.quartz.util.TaskUtil;
|
|
|
import lombok.AllArgsConstructor;
|
|
import lombok.AllArgsConstructor;
|
|
@@ -26,6 +27,8 @@ import org.quartz.Scheduler;
|
|
|
import org.springframework.context.annotation.Bean;
|
|
import org.springframework.context.annotation.Bean;
|
|
|
import org.springframework.context.annotation.Configuration;
|
|
import org.springframework.context.annotation.Configuration;
|
|
|
|
|
|
|
|
|
|
+import java.util.List;
|
|
|
|
|
+
|
|
|
/**
|
|
/**
|
|
|
* @author 郑健楠
|
|
* @author 郑健楠
|
|
|
* <p>
|
|
* <p>
|
|
@@ -44,20 +47,27 @@ public class QuartzInitJob {
|
|
|
|
|
|
|
|
@Bean
|
|
@Bean
|
|
|
public void customize() {
|
|
public void customize() {
|
|
|
- sysJobService.list().forEach(sysjob -> {
|
|
|
|
|
|
|
+ List<SysJob> jobList = sysJobService.list();
|
|
|
|
|
+ log.info("========== 开始加载定时任务,共 {} 条 ==========", jobList.size());
|
|
|
|
|
+ jobList.forEach(sysjob -> {
|
|
|
if (QuartzEnum.JOB_STATUS_RELEASE.getType().equals(sysjob.getJobStatus())) {
|
|
if (QuartzEnum.JOB_STATUS_RELEASE.getType().equals(sysjob.getJobStatus())) {
|
|
|
|
|
+ log.info("[移除] jobId: {}, jobName: {}, jobGroup: {}, 状态: 已发布", sysjob.getJobId(), sysjob.getJobName(), sysjob.getJobGroup());
|
|
|
taskUtil.removeJob(sysjob, scheduler);
|
|
taskUtil.removeJob(sysjob, scheduler);
|
|
|
}
|
|
}
|
|
|
else if (QuartzEnum.JOB_STATUS_RUNNING.getType().equals(sysjob.getJobStatus())) {
|
|
else if (QuartzEnum.JOB_STATUS_RUNNING.getType().equals(sysjob.getJobStatus())) {
|
|
|
|
|
+ log.info("[调度] jobId: {}, jobName: {}, jobGroup: {}, 状态: 运行中", sysjob.getJobId(), sysjob.getJobName(), sysjob.getJobGroup());
|
|
|
taskUtil.resumeJob(sysjob, scheduler);
|
|
taskUtil.resumeJob(sysjob, scheduler);
|
|
|
}
|
|
}
|
|
|
else if (QuartzEnum.JOB_STATUS_NOT_RUNNING.getType().equals(sysjob.getJobStatus())) {
|
|
else if (QuartzEnum.JOB_STATUS_NOT_RUNNING.getType().equals(sysjob.getJobStatus())) {
|
|
|
|
|
+ log.info("[暂停] jobId: {}, jobName: {}, jobGroup: {}, 状态: 暂停", sysjob.getJobId(), sysjob.getJobName(), sysjob.getJobGroup());
|
|
|
taskUtil.pauseJob(sysjob, scheduler);
|
|
taskUtil.pauseJob(sysjob, scheduler);
|
|
|
}
|
|
}
|
|
|
else {
|
|
else {
|
|
|
|
|
+ log.info("[移除] jobId: {}, jobName: {}, jobGroup: {}, 状态: {}", sysjob.getJobId(), sysjob.getJobName(), sysjob.getJobGroup(), sysjob.getJobStatus());
|
|
|
taskUtil.removeJob(sysjob, scheduler);
|
|
taskUtil.removeJob(sysjob, scheduler);
|
|
|
}
|
|
}
|
|
|
});
|
|
});
|
|
|
|
|
+ log.info("========== 定时任务加载完成 ==========");
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
}
|
|
}
|