对接快递100&聚水潭API（对接快递公司是啥意思）

 1 import lombok.AllArgsConstructor;
 2 import lombok.extern.slf4j.Slf4j;
 3 import org.springframework.scheduling.annotation.Scheduled;
 4 import org.springframework.stereotype.Component;
 5 
 6 import java.util.List;
 7 
 8 /**
 9  *  定时任务
10  */
11 @Component
12 @AllArgsConstructor
13 @Slf4j
14 public class OrderScheduledTask {
15 
16     private OmsOrderService omsOrderService;
17     private OmsOrderRepository omsOrderRepository;
18 
19 
20     /**
21      * 平台同步到本地定时任务 
22      * 需要在启动类中加入: @EnableScheduling 启动定时任务
23      */
24     @Scheduled(fixedDelay = 10*60*1000) // 距离上次执行完10分钟后执行
25     public void omsOrderUploadScheduledTask() {
26         try {
27             log.info("平台同步到本地定时任务开始：{}", DateUtil.getCurDateTime());
28             //生产消息： 取数据：已同步
29             List<OmsOrder> orderList = omsOrderRepository.findBySynStatusAndPayStatus("1", "1");
30             // 处理数据：每次同步20 条数据
31             if (!orderList.isEmpty() && orderList.size() > 0) {
32                 if (orderList.size() >= 20) {
33                 // 消费消息 + 保存消息：
34                     omsOrderService.updateDataToPool(orderList.subList(0, 20));
35                     // 递归调用 omsOrderSearchScheduledTask
36                     omsOrderSearchScheduledTask();
37                 } else {
38                     omsOrderService.updateDataToPool(orderList);
39                 }
40             }else {
41                 log.info("没有符合条件的订单,无需从平台同步数据");
42             }
43         } catch (Exception e) {
44             log.info("平台同步到本地定时任务exception: {}", e.getMessage());
45         }
46         log.info("平台同步到本地定时任务结束：{}", DateUtil.getCurDateTime());
47     }
48 
49 }