用户注册信息

yujian

2020-01-18 f4a0f2acc63d7785eab108419a4e16f5f688cb95

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

@@ -12,10 +12,10 @@
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;

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

            // continue;

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

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

         } catch (PDDOrderException e) {

            e.printStackTrace();

         }

      }

   }



   /**

@@ -57,8 +62,8 @@
    */

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

   public void updateSoonOrder() {

//      if (!Constant.IS_TASK)

//         return;

      if (!Constant.IS_TASK)

         return;

      Date now = null;

      now = PinDuoDuoApiUtil.getSystemTime();

      if (now == null)

@@ -75,8 +80,8 @@
    */

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

   public void updateUpdateOrder() {

//      if (!Constant.IS_TASK)

//         return;

      if (!Constant.IS_TASK)

         return;

      long endTime = System.currentTimeMillis() - 1000 * 60 * 60L;

      long startTime = System.currentTimeMillis() - 1000 * 60 * 60 * 24L;

      int page = 1;