admin
2020-04-20 aa43ebe703d3b28520a8b1e4b852b8beb957c5ca
fanli/src/main/java/com/yeshi/fanli/job/order/jd/UpdateJDOrderJob.java
@@ -72,9 +72,9 @@
   /**
    * 快速订单更新(爬取本小时内的单,每分钟一次)
    */
   @XxlJob("updateJDSoonOrderHandler")
   public ReturnT<String> startPreDividents(String param) throws Exception {
   @XxlJob("updateJDOrderHandler")
   public ReturnT<String> updateJDSoonOrder(String param) throws Exception {
      if ("1".equalsIgnoreCase(param)) {//更新本小时内的单
      LogHelper.job("开始爬取京东订单");
      long now = System.currentTimeMillis();
@@ -85,6 +85,11 @@
      result = JDApiUtil.getOrderList(1, 200, new Date(now - 1000 * 60 * 60L), JDApiUtil.ORDER_TYPE_CREATETIME);
      if (result != null && result.getOrderList() != null)
         saveJDOrders(result.getOrderList());
      } else if ("1hour".equalsIgnoreCase(param)) {// 更新1小时内的订单
         updateUpdateOrder();
      } else if ("3day".equalsIgnoreCase(param)) {// 更新最近3天更新的数据
         updateLatest3DayOrder();
      }
      return ReturnT.SUCCESS;
   }
@@ -92,10 +97,8 @@
   /**
    * 爬取最近一小时内的状态更新了的单(10分钟一次)
    */
   @Scheduled(cron = "0 0/10 * * * ? ")
   public void updateUpdateOrder() {
      if (!Constant.IS_TASK)
         return;
      List<JDOrder> jdOrderList = new ArrayList<>();
      int pageSize = 200;
      int page = 1;
@@ -157,10 +160,7 @@
   /**
    * 更新最近3天的订单(每天早上凌晨0点过10分,早上8点过10分)
    */
   @Scheduled(cron = "0 10 0,8 * * ? ")
   public void updateLatest3DayOrder() {
      if (!Constant.IS_TASK)
         return;
      Date now = new Date();
      for (int i = 1; i < 4; i++) {
         updateDayOrder(new Date(now.getTime() - 1000 * 60 * 60 * 24L * i));