[苍穹外卖]-09Spring Task定时任务

news2024/11/24 9:20:50

Spring Task

spring Task是spring框架提供的任务调度工具,可以按照约定的时间自动执行某个代码逻辑

只要是需要定时处理的场景都可以使用Spring Task定时任务框架

cron表达式就是一个字符串,可以定义任务触发的时间

构成规则: 分为6或7个域, 由空格隔开,每个域代表一个含义
每个域的含义分别为: 秒, 分钟, 小时, 日, 月, 周, 年(可选)
年这个域是可选的, 所以域有可能是6个也可能是7个

特殊符号: * 表示通配/所有, ? 号表示忽略/不指定, /表示间隔
cron表达式在线生成器: 在线Cron表达式生成器

入门案例

导入maven坐标, spring-context中自带

通过@EnableScheduling 注解开启任务调度

@SpringBootApplication
@EnableScheduling //开启任务调度
public class SkyApplication {
    public static void main(String[] args) {
        SpringApplication.run(SkyApplication.class, args);
        log.info("server started");
    }
}

自定义定时任务类

@Component
@Slf4j
public class MyTask {
    /**
     * 定时任务,每隔5秒执行一次
     */
    @Scheduled(cron = "0/5 * * * * ?")
    public void executeTask() {
        log.info("定时任务开始执行:{}", new Date());
    }
}

定时任务类需要交给IOC容器管理
执行效果: 每隔5秒打印一次内容

订单状态定时处理

用户下单后可能存在的问题:

订单超时处理: 下单后未支付, 订单一直处于"待支付"状态, 如果不处理, 系统中就会存在大量的完不成的订单

用户收到货之后, 商家不点击完成按钮, 订单一直处于"派送中"状态, 如果不处理, 系统中就会存在大量无效订单

支付超时自动取消: 通过定时任务, 每分钟检查一次, 如果支付超时订单(下单15分为限), 自动修改订单状态为"已取消"
订单自动完成: 通过定时任务, 每天凌晨1点检查一次, 如果有"派送中"的订单, 则自动把订单状态改为"已完成"

业务实现

在启动类中添加 @EnableScheduling注解开启任务调度, 新建定时任务类, 编写定时任务方法

@Component
@Slf4j
public class OrderTask {

    @Autowired
    private OrderMapper orderMapper;

    /**
     * 处理订单超时的方法
     */
    @Scheduled(cron = "0 * * * * ?") // 每分钟触发一次
    public void processTimeoutOrder() {
        log.info("定时处理超时订单: {}", LocalDateTime.now());
        // 计算超时时间
        LocalDateTime time = LocalDateTime.now().plusMinutes(-15);
        // 根据状态和时间查询是否存在超时的订单
        List<Orders> ordersList = orderMapper.getByStatusAndOrderTimeLT(Orders.PENDING_PAYMENT, time);
        // 修改订单信息
        if (ordersList != null && ordersList.size() > 0) {
            for (Orders orders : ordersList) {
                orders.setStatus(Orders.CANCELLED);
                orders.setCancelReason("订单超时,自动取消");
                orders.setCancelTime(LocalDateTime.now());
                orderMapper.update(orders);
            }
        }
    }

    /**
     * 处理一直处于派送中的订单
     */
    @Scheduled(cron = "0 0 1 * * ?") // 每天凌晨1点出发一次
    public void processDeliveryOrder() {
        log.info("定时处理处于派送中的订单:{}", LocalDateTime.now());
        // 计算时间条件
        LocalDateTime time = LocalDateTime.now().plusMinutes(-60);
        // 根据状态和时间查询是否存在一直派送的订单
        List<Orders> ordersList = orderMapper.getByStatusAndOrderTimeLT(Orders.DELIVERY_IN_PROGRESS, time);
        // 修改订单信息
        if (ordersList != null && ordersList.size() > 0) {
            for (Orders orders : ordersList) {
                orders.setStatus(Orders.COMPLETED);
                orderMapper.update(orders);
            }
        }
    }

}

@Mapper
public interface OrderMapper {
   /**
     * 根据订单状态和超时时间查询订单
     * @param status
     * @param orderTime
     * @return
     */
    @Select("select * from orders where status = #{status} and order_time < #{orderTime}")
    List<Orders> getByStatusAndOrderTimeLT(Integer status, LocalDateTime orderTime);

}