admin
2020-05-06 24a8d17e007545f7426c48352109aa1a9c6587ee
fanli/src/main/java/com/yeshi/fanli/job/order/jd/UpdateJDOrderJob.java
@@ -6,7 +6,6 @@
import javax.annotation.Resource;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import com.xxl.job.core.biz.model.ReturnT;
@@ -16,7 +15,6 @@
import com.yeshi.fanli.exception.jd.JDOrderException;
import com.yeshi.fanli.log.LogHelper;
import com.yeshi.fanli.service.inter.order.jd.JDOrderService;
import com.yeshi.fanli.util.Constant;
import com.yeshi.fanli.util.RedisKeyEnum;
import com.yeshi.fanli.util.RedisManager;
import com.yeshi.fanli.util.StringUtil;
@@ -72,19 +70,24 @@
   /**
    * 快速订单更新(爬取本小时内的单,每分钟一次)
    */
   @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();
      LogHelper.job("开始爬取京东订单");
      long now = System.currentTimeMillis();
      JDOrderResult result = JDApiUtil.getOrderList(1, 200, new Date(now), JDApiUtil.ORDER_TYPE_CREATETIME);
      if (result != null && result.getOrderList() != null)
         saveJDOrders(result.getOrderList());
      // 查询上个小时的
      result = JDApiUtil.getOrderList(1, 200, new Date(now - 1000 * 60 * 60L), JDApiUtil.ORDER_TYPE_CREATETIME);
      if (result != null && result.getOrderList() != null)
         saveJDOrders(result.getOrderList());
         JDOrderResult result = JDApiUtil.getOrderList(1, 200, new Date(now), JDApiUtil.ORDER_TYPE_CREATETIME);
         if (result != null && result.getOrderList() != null)
            saveJDOrders(result.getOrderList());
         // 查询上个小时的
         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 +95,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 +158,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));