wangqifan 3 лет назад
Родитель
Сommit
bac0c87785
1 измененных файлов с 3 добавлено и 1 удалено
  1. 3 1
      src/main/java/com/izouma/nineth/service/OrderCancelService.java

+ 3 - 1
src/main/java/com/izouma/nineth/service/OrderCancelService.java

@@ -13,6 +13,7 @@ import org.springframework.stereotype.Service;
 
 import java.time.LocalDateTime;
 import java.util.List;
+import java.util.concurrent.TimeUnit;
 
 @Service
 @Slf4j
@@ -22,7 +23,8 @@ public class OrderCancelService {
     private final OrderRepo         orderRepo;
     private final OrderService      orderService;
 
-    @Scheduled(fixedRate = 30000)
+    @Scheduled(fixedRate = 30000, initialDelay = 10000)
+    @RedisLock(value = "order_batch_cancel", expire = 3, unit = TimeUnit.MINUTES)
     public void batchCancel() {
         List<Order> orders = orderRepo.findByStatusAndCreatedAtBeforeAndDelFalse(OrderStatus.NOT_PAID,
                 LocalDateTime.now().minusSeconds(210));