Merge branch 'div' of ssh://193.112.35.168:29418/fanli-server into div

yujian

2019-08-27 d8359ddb48dab5cc797a9d552e11fde571f4920c

 fanli/src/main/java/com/yeshi/fanli/job/order/pdd/UpdatePDDOrderJob.java

@@ -13,9 +13,9 @@
import com.yeshi.fanli.entity.pdd.PDDOrder;

import com.yeshi.fanli.exception.pdd.PDDOrderException;

import com.yeshi.fanli.service.inter.pdd.PDDOrderService;

import com.yeshi.fanli.util.Constant;

import com.yeshi.fanli.util.RedisManager;

import com.yeshi.fanli.util.StringUtil;

import com.yeshi.fanli.util.cmq.JDOrderCMQManager;

import com.yeshi.fanli.util.cmq.PDDOrderCMQManager;

import com.yeshi.fanli.util.pinduoduo.PinDuoDuoApiUtil;



//从淘宝爬去订单更新

@@ -42,9 +42,9 @@
             */

            String key = "pdd-order-" + order.getOrderSn();

            String result = redisManager.getCommonString(key);

            if (!StringUtil.isNullOrEmpty(result))

               continue;

            JDOrderCMQManager.getInstance().addJDOrder(order.getOrderSn() + "");

            // if (!StringUtil.isNullOrEmpty(result))

            // continue;

            PDDOrderCMQManager.getInstance().addPDDOrder(order.getOrderSn() + "");

            redisManager.cacheCommonString(key, "1", 60 * 60 * 2);// 2小时内不再更新

         } catch (PDDOrderException e) {

            e.printStackTrace();

@@ -56,6 +56,8 @@
    */

   @Scheduled(cron = "0 0/1 * * * ? ")

   public void updateSoonOrder() {

      if (!Constant.IS_TASK)

         return;

      Date now = null;

      now = PinDuoDuoApiUtil.getSystemTime();

      if (now == null)

@@ -72,6 +74,8 @@
    */

   @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;