package com.itstyle.quartz.config;
|
|
import org.quartz.CronScheduleBuilder;
|
import org.quartz.JobBuilder;
|
import org.quartz.JobDetail;
|
import org.quartz.Scheduler;
|
import org.quartz.Trigger;
|
import org.quartz.TriggerBuilder;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.boot.ApplicationArguments;
|
import org.springframework.boot.ApplicationRunner;
|
import org.springframework.stereotype.Component;
|
|
import com.itstyle.quartz.entity.QuartzEntity;
|
import com.itstyle.quartz.service.IJobService;
|
/**
|
* 初始化一个测试Demo任务
|
* 创建者 科帮网
|
* 创建时间 2018年4月3日
|
*/
|
@Component
|
public class TaskRunner implements ApplicationRunner{
|
|
private final static Logger LOGGER = LoggerFactory.getLogger(TaskRunner.class);
|
|
@Autowired
|
private IJobService jobService;
|
@Autowired
|
private Scheduler scheduler;
|
|
@Override
|
public void run(ApplicationArguments var) throws Exception{
|
/**
|
* 系统启动的时候会初始化一个任务
|
*/
|
// Long count = jobService.listQuartzEntity(null);
|
// if(count==0){
|
// LOGGER.info("初始化测试任务");
|
// QuartzEntity quartz = new QuartzEntity();
|
// quartz.setJobName("test01");
|
// quartz.setJobGroup("test");
|
// quartz.setDescription("测试任务");
|
// quartz.setJobClassName("com.itstyle.quartz.job.ChickenJob");
|
// quartz.setCronExpression("*/5 * * * * ?");
|
// quartz.setJobMethodName("test1");
|
// Class cls = Class.forName(quartz.getJobClassName()) ;
|
// cls.newInstance();
|
// //构建job信息
|
// JobDetail job = JobBuilder.newJob(cls).withIdentity(quartz.getJobName(),
|
// quartz.getJobGroup())
|
// .withDescription(quartz.getDescription()).build();
|
// job.getJobDataMap().put("jobMethodName", "test1");
|
// // 触发时间点
|
// CronScheduleBuilder cronScheduleBuilder = CronScheduleBuilder.cronSchedule(quartz.getCronExpression());
|
// Trigger trigger = TriggerBuilder.newTrigger().withIdentity("trigger"+quartz.getJobName(), quartz.getJobGroup())
|
// .startNow().withSchedule(cronScheduleBuilder).build();
|
// //交由Scheduler安排触发
|
// scheduler.scheduleJob(job, trigger);
|
// }
|
}
|
|
}
|
