拼多多推广链接

yujian

2019-08-01 695c32b9958ab902b697dcdb88f71683b9c2c3d6

 fanli/src/main/java/com/yeshi/fanli/job/order/jd/UpdateJDOrderJob.java

@@ -13,6 +13,7 @@
import com.yeshi.fanli.entity.jd.JDOrder;

import com.yeshi.fanli.exception.jd.JDOrderException;

import com.yeshi.fanli.service.inter.jd.JDOrderService;

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;

@@ -42,8 +43,7 @@
             */

            String key = "jd-order-" + order.getOrderId();

            String result = redisManager.getCommonString(key);

            if (!StringUtil.isNullOrEmpty(result))

               continue;



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

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

         } catch (JDOrderException e) {

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

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

   public void updateSoonOrder() {

      if (!Constant.IS_TASK)

         return;



      JDOrderResult result = JDApiUtil.getOrderList(1, 200, new Date(), JDApiUtil.ORDER_TYPE_CREATETIME);

      if (result != null && result.getOrderList() != null)

         saveJDOrders(result.getOrderList());

@@ -66,14 +69,19 @@
    */

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

   public void updateUpdateOrder() {

      if (!Constant.IS_TASK)

         return;

      List<JDOrder> jdOrderList = new ArrayList<>();

      int pageSize = 200;

      int page = 1;

      JDOrderResult result = JDApiUtil.getOrderList(page++, pageSize, new Date(), JDApiUtil.ORDER_TYPE_UPDATETIME);

      jdOrderList.addAll(result.getOrderList());

      while (result.isHasMore()) {

         result = JDApiUtil.getOrderList(page++, pageSize, new Date(), JDApiUtil.ORDER_TYPE_UPDATETIME);

      if (result != null) {

         jdOrderList.addAll(result.getOrderList());

         while (result != null && result.isHasMore()) {

            result = JDApiUtil.getOrderList(page++, pageSize, new Date(), JDApiUtil.ORDER_TYPE_UPDATETIME);

            if (result != null)

               jdOrderList.addAll(result.getOrderList());

         }

      }

      saveJDOrders(jdOrderList);

   }