定时任务

src/main/java/com/izouma/tcg/service/delay/OrderDelayService.java

@@ -24,7 +24,7 @@ public class OrderDelayService {
     private final Log logger = LogFactory.getLog(this.getClass());
 
     @Autowired
-    private OrderInfoService orderFormService;
+    private OrderInfoService orderInfoService;
 
     private Thread takeOrder;
 
@@ -45,11 +45,11 @@ public class OrderDelayService {
     }
 
     private class TakeOrder implements Runnable {
-        private OrderInfoService orderFormService;
+        private OrderInfoService orderInfoService;
 
         public TakeOrder(OrderInfoService orderFormService) {
             super();
-            this.orderFormService = orderFormService;
+            this.orderInfoService = orderFormService;
         }
 
         @Override
@@ -60,7 +60,7 @@ public class OrderDelayService {
                     // take():获取队列，在必要时阻塞等待，直到该队列上有一个具有过期延迟的元素可用。
                     DelayOrder delayedOrder = delayOrders.take();
                     // 处理待支付且支付超时订单
-                    orderFormService.cancel(delayedOrder.getOrderInfoId());
+                    orderInfoService.cancel(delayedOrder.getOrderInfoId());
                     delayOrders.remove(delayedOrder);
                 } catch (Exception e) {
                     logger.error("The thread is Interrupted!");
@@ -72,7 +72,7 @@ public class OrderDelayService {
     // @PostConstruct：当整个bean被初始化完成后执行
     @PostConstruct
     public void init() {
-        takeOrder = new Thread(new TakeOrder(orderFormService));
+        takeOrder = new Thread(new TakeOrder(orderInfoService));
         takeOrder.start();
     }
 

src/main/java/com/izouma/tcg/service/orderInfo/OrderInfoService.java

@@ -36,13 +36,21 @@ import java.util.stream.Collectors;
 @Service
 @AllArgsConstructor
 public class OrderInfoService {
+    @Autowired
+    private OrderInfoRepo         orderInfoRepo;
+    @Autowired
+    private CardBoxRepo           cardBoxRepo;
+    @Autowired
+    private CardCaseRepo          cardCaseRepo;
+    @Autowired
+    private Cache<String, Object> caffeineCache;
+    @Autowired
+    private TransactionRecordRepo transactionRecordRepo;
+    @Autowired
+    private OrderDelayService     orderDelayService;
 
-    private final OrderInfoRepo         orderInfoRepo;
-    private final CardBoxRepo           cardBoxRepo;
-    private final CardCaseRepo          cardCaseRepo;
-    private final Cache<String, Object> caffeineCache;
-    private final TransactionRecordRepo transactionRecordRepo;
-    private final OrderDelayService     orderDelayService;
+    public OrderInfoService() {
+    }
 
     public Page<OrderInfo> all(PageQuery pageQuery) {
         return orderInfoRepo