Quartz定时任务

<!--添加Quartz的支持 -->
    <dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-quartz</artifactId>
    </dependency>

import org.quartz.CronScheduleBuilder;
import org.quartz.JobBuilder;
import org.quartz.JobDetail;
import org.quartz.Trigger;
import org.quartz.TriggerBuilder;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import com.jt.quartz.OrderQuartz;
@Configuration
public class OrderQuartzConfig {
  
  //定义任务详情
  @Bean
  public JobDetail orderjobDetail() {
    //指定job的名称和持久化保存任务
    return JobBuilder
        .newJob(OrderQuartz.class)
        .withIdentity("orderQuartz")
        .storeDurably()
        .build();
  }
  //定义触发器
  @Bean
  public Trigger orderTrigger() {
    /*SimpleScheduleBuilder builder = SimpleScheduleBuilder.simpleSchedule()
        .withIntervalInMinutes(1) //定义时间周期
        .repeatForever();*/
    CronScheduleBuilder scheduleBuilder 
      = CronScheduleBuilder.cronSchedule("0 0/1 * * * ?");
    return TriggerBuilder
        .newTrigger()
        .forJob(orderjobDetail())
        .withIdentity("orderQuartz")
        .withSchedule(scheduleBuilder).build();
  }
}

import java.util.Calendar;
import java.util.Date;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.quartz.QuartzJobBean;
import org.springframework.stereotype.Component;
import org.springframework.transaction.annotation.Transactional;
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
import com.jt.mapper.OrderMapper;
import com.jt.pojo.Order;
//准备订单定时任务
@Component  //orderQuartz
public class OrderQuartz extends QuartzJobBean{
  @Autowired
  private OrderMapper orderMapper;
 
  
  /**
   * 将超时30分钟的订单状态码由1改为6
   * 条件:  //now - created >  30分钟 
   *     created < now-30分钟
   *     and status = 1
   */
  @Override
  @Transactional
  protected void executeInternal(JobExecutionContext context) throws JobExecutionException {
    //获取当前时间的日历对象
    Calendar calendar = Calendar.getInstance();
    //毫秒/秒/分钟/小时/天/月/年/星期
    calendar.add(Calendar.MINUTE, -30);
    //获取超时时间
    Date timeOut = calendar.getTime();
    Order order = new Order();
    order.setStatus(6).setUpdated(new Date());
    UpdateWrapper<Order> updateWrapper = new UpdateWrapper<>();
    updateWrapper.lt("created",timeOut);
    updateWrapper.eq("status", 1);
    orderMapper.update(order, updateWrapper);
    System.out.println("定时任务执行完成!!!!");
  }
}