用户注册信息

yujian

2020-01-18 f4a0f2acc63d7785eab108419a4e16f5f688cb95

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

@@ -12,11 +12,11 @@
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.pdd.PDDOrderService;

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.StringUtil;

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

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

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



//从淘宝爬去订单更新

@@ -35,21 +35,26 @@
    * @param jdOrderList

    */

   public void savePDDOrders(List<PDDOrder> orderList) {

      for (PDDOrder order : orderList)

      for (PDDOrder order : orderList) {

         if (order.getOrderStatus() == 2) {

            System.out.println(order);

         }



         try {

            pddOrderService.addOrder(order);

            /**

             * 做频率限制

             */

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

            String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.PDDOrder, 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();

         }

      }

   }



   /**