Merge remote-tracking branch 'origin/div' into div

admin

2020-04-13 dd5b15229cb15459fa7c31ccea77dac28cbfafbd

 fanli/src/main/java/com/yeshi/fanli/job/order/taobao/UpdateTBRelationAndSpecialOrderJob.java

@@ -15,6 +15,7 @@
import com.yeshi.fanli.service.inter.order.tb.TaoBaoOrderService;

import com.yeshi.fanli.util.CMQManager;

import com.yeshi.fanli.util.Constant;

import com.yeshi.fanli.util.RedisKeyEnum;

import com.yeshi.fanli.util.RedisManager;

import com.yeshi.fanli.util.StringUtil;

import com.yeshi.fanli.util.TimeUtil;

@@ -53,7 +54,7 @@
      // 爬取到的订单号

      if (list != null)

         for (TaoBaoOrder order : list) {

            LogHelper.orderInfo("爬取到的订单号:" + order.getOrderId());

            LogHelper.orderInfo("会员/渠道爬取到的订单号:" + order.getOrderId());

         }



      addRelationAndSpecialOrder(list);

@@ -73,7 +74,7 @@
      // 爬取到的订单号

      if (list != null)

         for (TaoBaoOrder order : list) {

            LogHelper.orderInfo("爬取到的订单号:" + order.getOrderId());

            LogHelper.orderInfo("会员/渠道爬取到的订单号:" + order.getOrderId());

         }



      addRelationAndSpecialOrder(list);

@@ -87,7 +88,7 @@
      // 爬取到的订单号

      if (list != null)

         for (TaoBaoOrder order : list) {

            LogHelper.orderInfo("爬取到的订单号:" + order.getOrderId());

            LogHelper.orderInfo("会员/渠道爬取到的订单号:" + order.getOrderId());

         }

      addRelationAndSpecialOrder(list);

   }

@@ -106,8 +107,7 @@
            while (its.hasNext()) {

               String key = its.next();

               List<TaoBaoOrder> orders = map.get(key);

               String redisKey = "addorderqueue-" + TaoBaoOrderUtil.getOrderDataHashCode(orders);

               ;

               String redisKey = RedisKeyEnum.getRedisKey(RedisKeyEnum.addOrderQueue, TaoBaoOrderUtil.getOrderDataHashCode(orders));

               // redis做频率限制

               try {

                  if (!StringUtil.isNullOrEmpty(redisManager.getCommonString(redisKey))) {

@@ -145,7 +145,7 @@
      if (!Constant.IS_TASK)

         return;

      // 爬取近20分钟的数据

      LogHelper.orderInfo("爬单:30s爬取一次单");

      LogHelper.job("爬单:30s爬取一次单");

      Date systemDate = TaoKeApiUtil.getTaoBaoSystemTime();

      long endTime = systemDate != null ? systemDate.getTime() : System.currentTimeMillis();

      updateRelationAndSpecialOrder(endTime - 1000 * 60 * 20L, endTime);

@@ -158,7 +158,7 @@
   public void doJob2() {

      if (!Constant.IS_TASK)

         return;

      LogHelper.orderInfo("爬单:5min爬取一次单");

      LogHelper.job("爬单:5min爬取一次单");

      Date systemDate = TaoKeApiUtil.getTaoBaoSystemTime();

      long endTime = systemDate != null ? systemDate.getTime() : System.currentTimeMillis();

      updateRelationAndSpecialOrder(endTime - 1000 * 60 * 60 * 24L, endTime);