admin
2020-05-06 24a8d17e007545f7426c48352109aa1a9c6587ee
fanli/src/main/java/com/yeshi/fanli/job/order/pdd/UpdatePDDOrderJob.java
@@ -6,17 +6,17 @@
import javax.annotation.Resource;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import com.xxl.job.core.biz.model.ReturnT;
import com.xxl.job.core.handler.annotation.XxlJob;
import com.yeshi.fanli.dto.pdd.PDDOrderResult;
import com.yeshi.fanli.entity.pdd.PDDOrder;
import com.yeshi.fanli.exception.pdd.PDDOrderException;
import com.yeshi.fanli.service.inter.order.pdd.PDDOrderService;
import com.yeshi.fanli.util.Constant;
import com.yeshi.fanli.util.RedisKeyEnum;
import com.yeshi.fanli.util.RedisManager;
import com.yeshi.fanli.util.cmq.PDDOrderCMQManager;
import com.yeshi.fanli.util.cmq.order.PDDOrderCMQManager;
import com.yeshi.fanli.util.pinduoduo.PinDuoDuoApiUtil;
//从淘宝爬去订单更新
@@ -45,7 +45,7 @@
            /**
             * 做频率限制
             */
            String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.PDDOrder, order.getOrderSn() + "" );
            String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.PDDOrder, order.getOrderSn() + "");
            String result = redisManager.getCommonString(key);
            // if (!StringUtil.isNullOrEmpty(result))
            // continue;
@@ -58,12 +58,23 @@
   }
   /**
    * 拼多多订单爬取
    */
   @XxlJob("updatePDDOrderHandler")
   public ReturnT<String> updatePDDOrder(String param) throws Exception {
      if ("1".equalsIgnoreCase(param)) {// 更新本小时内的单
         updateSoonOrder();
      } else if ("1day".equalsIgnoreCase(param)) {// 爬取最近1天的订单(30分钟一次)
         updateUpdateOrder();
      }
      return ReturnT.SUCCESS;
   }
   /**
    * 快速订单更新(爬取本小时内的单,每分钟一次)
    */
   @Scheduled(cron = "0 0/1 * * * ? ")
   // @Scheduled(cron = "0 0/1 * * * ? ")
   public void updateSoonOrder() {
      if (!Constant.IS_TASK)
         return;
      Date now = null;
      now = PinDuoDuoApiUtil.getSystemTime();
      if (now == null)
@@ -78,10 +89,8 @@
   /**
    * 爬取最近1天的订单(30分钟一次)
    */
   @Scheduled(cron = "0 0/30 * * * ? ")
   // @Scheduled(cron = "0 0/30 * * * ? ")
   public void updateUpdateOrder() {
      if (!Constant.IS_TASK)
         return;
      long endTime = System.currentTimeMillis() - 1000 * 60 * 60L;
      long startTime = System.currentTimeMillis() - 1000 * 60 * 60 * 24L;
      int page = 1;