diff --git a/src/main/java/com/sczx/order/task/OrderOverdueTask.java b/src/main/java/com/sczx/order/task/OrderOverdueTask.java index ee071b1..9e234dd 100644 --- a/src/main/java/com/sczx/order/task/OrderOverdueTask.java +++ b/src/main/java/com/sczx/order/task/OrderOverdueTask.java @@ -31,7 +31,7 @@ public class OrderOverdueTask { * lockAtMostFor:锁最多持有时间,防止节点宕机导致锁无法释放 * lockAtLeastFor:锁最少持有时间,防止任务执行过快导致频繁执行 */ - @Scheduled(cron = "0 */30 * * * ?") + @Scheduled(cron = "0 */1 * * * ?") @SchedulerLock(name = "checkOverdueOrders", lockAtMostFor = "9m", lockAtLeastFor = "1m") public void checkOverdueOrders() { log.info("开始执行逾期订单检查任务"); @@ -52,6 +52,7 @@ public class OrderOverdueTask { LambdaQueryWrapper queryWrapper = new LambdaQueryWrapper<>(); queryWrapper.in(OrderMainPO::getOrderStatus, Collections.singletonList(OrderStatusEnum.RENT_ING.getCode())) + .isNotNull(OrderMainPO::getEndRentTime) .lt(OrderMainPO::getEndRentTime, LocalDateTime.now()); List overdueOrders = orderMainRepo.list(queryWrapper);