Quartz定时任务

typescript复制代码 @Component
 public class QuartzUtil {
 
     private static final SchedulerFactory SCHEDULER_FACTORY = new StdSchedulerFactory();
 
     @Autowired
     private QuartzService quartzService;
 
     /**
      * 添加一个定时任务
      *
      * @param name      任务名。每个任务唯一，不能重复。方便起见，触发器名也设为这个
      * @param group     任务分组。方便起见，触发器分组也设为这个
      * @param jobClass  任务的类类型  eg:TemplateJob.class
      * @param startTime 任务开始时间。传null就是立即开始
      * @param endTime   任务结束时间。如果是一次性任务或永久执行的任务就传null
      * @param cron      时间设置表达式。传null就是一次性任务
      */
     public boolean addJob(String name, String group, Class<? extends Job> jobClass,
                        LocalDateTime startTime, LocalDateTime endTime, String cron, JobDataMap jobDataMap) {
         try {
             // 第一步: 定义一个JobDetail
             JobDetail jobDetail = JobBuilder.newJob(jobClass).
                     withIdentity(name, group).setJobData(jobDataMap).build();
             // 第二步: 设置触发器
             TriggerBuilder<Trigger> triggerBuilder = newTrigger();
             triggerBuilder.withIdentity(name, group);
             triggerBuilder.startAt(toStartDate(startTime));
             triggerBuilder.endAt(toEndDate(endTime)); //设为null则表示不会停止
             if (StrUtil.isNotEmpty(cron)) {
                 triggerBuilder.withSchedule(CronScheduleBuilder.cronSchedule(cron));
             }
             Trigger trigger = triggerBuilder.build();
             //第三步：调度器设置
             Scheduler scheduler = SCHEDULER_FACTORY.getScheduler();
             scheduler.scheduleJob(jobDetail, trigger);
             if (!scheduler.isShutdown()) {
                 scheduler.start();
             }
         } catch (Exception e) {
             e.printStackTrace();
             return false;
         }
         return true;
     }
 
     private static Date toEndDate(LocalDateTime endDateTime) {
         // 结束时间可以为null，所以endDateTime为null，直接返回null即可
         return endDateTime != null ?
                 DateUtil.date(endDateTime) : null;
     }
 
     private static Date toStartDate(LocalDateTime startDateTime) {
         // startDateTime为空时返回当前时间，表示立即开始
         return startDateTime != null ?
                 DateUtil.date(startDateTime) : new Date();
     }
 
 }

typescript复制代码public boolean cancelJob(String jobName, String groupName) {
    try {
        Scheduler scheduler = SCHEDULER_FACTORY.getScheduler();
        TriggerKey triggerKey = TriggerKey.triggerKey(jobName, groupName);
        scheduler.pauseTrigger(triggerKey); // 停止触发器
        scheduler.unscheduleJob(triggerKey);    // 移除触发器
        scheduler.deleteJob(JobKey.jobKey(jobName, groupName)); // 删除任务
    } catch (Exception e) {
        e.printStackTrace();
        return false;
    }
    //将数据库中的任务状态设为 取消
    return true;
}

typescript复制代码@Component
public class SpringContextJobUtil implements ApplicationContextAware {

    private static ApplicationContext context;

    @Override
    @SuppressWarnings("static-access")
    public void setApplicationContext(ApplicationContext context)
            throws BeansException {
        this.context = context;
    }

    public static Object getBean(String beanName) {
        return context.getBean(beanName);
    }

}

typescript复制代码@Component
public class QuartzUtil {

    public boolean addJob(String name, String group, Class<? extends Job> jobClass,
                       LocalDateTime startTime, LocalDateTime endTime, String cron, JobDataMap jobDataMap) {
       	//…………
        //存储到数据库中
        QuartzEntity entity = new QuartzEntity();
        entity.setJobName(name);
        entity.setGroupName(group);
        entity.setStartTime(startTime != null ? startTime : LocalDateTime.now());
        entity.setEndTime(endTime);
        entity.setJobClass(jobClass.getName());
        entity.setCron(cron);
        entity.setJobDataMapJson(JSONUtil.toJsonStr(jobDataMap));
        entity.setStatus("0");
        quartzService.save(entity);
        return true;
    }

    public boolean modifyJobTime(String name, String group, LocalDateTime newStartTime,
                             LocalDateTime newEndTime, String cron) {
        //…………
        // 修改数据库中的记录
        QuartzEntity entity = new QuartzEntity();
        entity.setJobName(name);
        entity.setGroupName(group);
        if (newStartTime != null) {
            entity.setStartTime(newStartTime);
        }
        if (newEndTime != null) {
            entity.setEndTime(newEndTime);
        }
        if (StrUtil.isNotEmpty(cron)) {
            entity.setCron(cron);
        }
        return quartzService.modifyJob(entity);
    }

    public boolean cancelJob(String jobName, String groupName) {
        //…………
        //将数据库中的任务状态设为 取消
        return quartzService.modifyTaskStatus(jobName, "2");
    }

}

typescript复制代码@Service("orderService")
public class OrderServiceImpl implements OrderService {

    @Autowired
    private QuartzUtil quartzUtil;

    @Override
    public String bookTicket(String userId, String ticketId) {
        //TODO 查询余票下订单等一些列操作
        Order order = new Order();
        //…………
        //创建一个定时任务
        LocalDateTime noticeTime = order.getDepartureTime().minusHours(2); //通知时间为发车前两小时
        quartzUtil.addJob(String.valueOf(order.getId()), QuartzGroupEnum.DEPARTURE_NOTICE.getValue(),
                DepartureNoticeJob.class, noticeTime, null, null, null);
        return "";
    }

    @Override
    public String rebook(Order order) {
        //TODO 修改订单等一系列操作
        //修改定时任务
        LocalDateTime noticeTime = order.getDepartureTime().minusHours(2); //通知时间为发车前两小时
        quartzUtil.modifyJob(String.valueOf(order.getId()), QuartzGroupEnum.DEPARTURE_NOTICE.getValue(),
                noticeTime, null, null);
        return "";
    }

    @Override
    public String cancelOrder(Order order) {
        //TODO 取消订单等一系列操作
        //取消定时任务
        quartzUtil.cancelJob(String.valueOf(order.getId()), QuartzGroupEnum.DEPARTURE_NOTICE.getValue());
        return "";
    }
}