springboot jpa quartz动态定时任务

package com.huang.boot.task; import com.alibaba.fastjson.JSON; import com.huang.boot.entity.ScheduleJob; import org.quartz.*; /** * 定时任务工具类 * */ public class ScheduleUtils { private final static String JOB_NAME = "TASK_"; /** * 获取触发器key */ public static TriggerKey getTriggerKey(Integer jobId) { return TriggerKey.triggerKey(JOB_NAME + jobId); } /** * 获取jobKey */ public static JobKey getJobKey(Integer jobId) { return JobKey.jobKey(JOB_NAME + jobId); } /** * 获取表达式触发器 * @throws Exception */ public static CronTrigger getCronTrigger(Scheduler scheduler, Integer jobId) throws Exception { try { return (CronTrigger) scheduler.getTrigger(getTriggerKey(jobId)); } catch (SchedulerException e) { throw new Exception("获取定时任务CronTrigger出现异常", e); } } /** * 创建定时任务 * @throws Exception */ public static void createScheduleJob(Scheduler scheduler, ScheduleJob scheduleJob) throws Exception { try { //构建job信息 JobDetail jobDetail = JobBuilder.newJob(ScheduleHandler.class).withIdentity(getJobKey(scheduleJob.getJobId())).build(); //表达式调度构建器 CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule(scheduleJob.getCronExpression()) .withMisfireHandlingInstructionDoNothing(); //按新的cronExpression表达式构建一个新的trigger CronTrigger trigger = TriggerBuilder.newTrigger().withIdentity(getTriggerKey(scheduleJob.getJobId())).withSchedule(scheduleBuilder).build(); //放入参数，运行时的方法可以获取 jobDetail.getJobDataMap().put(scheduleJob.JOB_PARAM_KEY, JSON.toJSONString(scheduleJob)); scheduler.scheduleJob(jobDetail, trigger); //暂停任务 /* if(scheduleJob.getStatus() == ScheduleStatus.PAUSE.getValue()){ pauseJob(scheduler, scheduleJob.getJobId()); }*/ } catch (SchedulerException e) { throw new Exception("创建定时任务失败", e); } } /** * 更新定时任务 * @throws Exception */ public static void updateScheduleJob(Scheduler scheduler, ScheduleJob scheduleJob) throws Exception { try { TriggerKey triggerKey = getTriggerKey(scheduleJob.getJobId()); //表达式调度构建器 CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule(scheduleJob.getCronExpression()) .withMisfireHandlingInstructionDoNothing(); CronTrigger trigger = getCronTrigger(scheduler, scheduleJob.getJobId()); //按新的cronExpression表达式重新构建trigger trigger = trigger.getTriggerBuilder().withIdentity(triggerKey).withSchedule(scheduleBuilder).build(); //参数 trigger.getJobDataMap().put(ScheduleJob.JOB_PARAM_KEY, JSON.toJSONString(scheduleJob)); scheduler.rescheduleJob(triggerKey, trigger); //暂停任务 /* if(scheduleJob.getStatus() == ScheduleStatus.PAUSE.getValue()){ pauseJob(scheduler, scheduleJob.getJobId()); }*/ } catch (SchedulerException e) { throw new Exception("更新定时任务失败", e); } } /** * 立即执行任务 * @throws Exception */ public static void run(Scheduler scheduler, ScheduleJob scheduleJob) throws Exception { try { //参数 JobDataMap dataMap = new JobDataMap(); dataMap.put(ScheduleJob.JOB_PARAM_KEY, JSON.toJSONString(scheduleJob)); scheduler.triggerJob(getJobKey(scheduleJob.getJobId()), dataMap); } catch (SchedulerException e) { throw new Exception("立即执行定时任务失败", e); } } /** * 暂停任务 * @throws Exception */ public static void pauseJob(Scheduler scheduler, Integer jobId) throws Exception { try { scheduler.pauseJob(getJobKey(jobId)); } catch (SchedulerException e) { throw new Exception("暂停定时任务失败", e); } } /** * 恢复任务 * @throws Exception */ public static void resumeJob(Scheduler scheduler, Integer jobId) throws Exception { try { scheduler.resumeJob(getJobKey(jobId)); } catch (SchedulerException e) { throw new Exception("暂停定时任务失败", e); } } /** * 删除定时任务 * @throws Exception */ public static void deleteScheduleJob(Scheduler scheduler, Integer jobId) throws Exception { try { scheduler.deleteJob(getJobKey(jobId)); } catch (SchedulerException e) { throw new Exception("删除定时任务失败", e); } } }