import java.io.IOException;
import java.util.Properties;import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.config.PropertiesFactoryBean;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.core.io.ClassPathResource;
import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.scheduling.quartz.SchedulerFactoryBean;@Configuration
@EnableScheduling
public class QuartzSchedule {@Autowiredprivate MyJobFactory myJobFactory;@Beanpublic SchedulerFactoryBean schedulerFactoryBean() throws IOException {SchedulerFactoryBean factory = new SchedulerFactoryBean();factory.setOverwriteExistingJobs(true);// 延时启动factory.setStartupDelay(20);// 加载quartz数据源配置
        factory.setQuartzProperties(quartzProperties());// 自定义Job Factory，用于Spring注入
        factory.setJobFactory(myJobFactory);return factory;}/*** 加载quartz数据源配置* * @return* @throws IOException*/@Beanpublic Properties quartzProperties() throws IOException {PropertiesFactoryBean propertiesFactoryBean = new PropertiesFactoryBean();propertiesFactoryBean.setLocation(new ClassPathResource("/quartz.properties"));propertiesFactoryBean.afterPropertiesSet();return propertiesFactoryBean.getObject();}}

@Component
public class MyJobFactory extends AdaptableJobFactory {@Autowiredprivate AutowireCapableBeanFactory capableBeanFactory;@Overrideprotected Object createJobInstance(TriggerFiredBundle bundle) throws Exception {// 调用父类的方法Object jobInstance = super.createJobInstance(bundle);// 进行注入
        capableBeanFactory.autowireBean(jobInstance);return jobInstance;}
}

public class MyJob implements Job, Serializable {private static final long serialVersionUID = 1L;private Logger logger = LoggerFactory.getLogger(this.getClass());@Autowiredprivate SomeService someService;@Overridepublic void execute(JobExecutionContext context) throws JobExecutionException {someService.doSomething();}
}

JobDetail jobDetail = JobBuilder.newJob(((Job) Class.forName(job.getClazz()).newInstance()).getClass()).withIdentity(job.getJobName(), job.getJobGroup()).build();jobDetail.getJobDataMap().put("extdata", job.getExtData());// 表达式调度构建器CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule(job.getCronExpression()).withMisfireHandlingInstructionDoNothing();// 构建一个triggerTriggerBuilder<CronTrigger> triggerBuilder = TriggerBuilder.newTrigger().withIdentity(triggerKey).withSchedule(scheduleBuilder);if (job.getStartTime() != null) {triggerBuilder.startAt(job.getStartTime());}if (job.getEndTime() != null) {triggerBuilder.endAt(job.getEndTime());}CronTrigger trigger = triggerBuilder.build();scheduler.scheduleJob(jobDetail, trigger);// 注入到管理类