增加新订单处理队列

admin

2019-07-22 b4b421ba6b85b586f9b8171c876f716bab9840d0

 fanli/src/main/java/com/yeshi/fanli/job/UpdateRelationAndSpecialOrderJob.java

@@ -16,6 +16,7 @@
import com.yeshi.fanli.util.Constant;

import com.yeshi.fanli.util.RedisManager;

import com.yeshi.fanli.util.StringUtil;

import com.yeshi.fanli.util.TimeUtil;

import com.yeshi.fanli.util.taobao.TaoBaoOrderUtil;

import com.yeshi.fanli.util.taobao.TaoKeOrderApiUtil;



@@ -53,6 +54,12 @@
         list.addAll(list2);

      if (list3 != null && list3.size() > 0)

         list.addAll(list3);

      // 爬取到的订单号

      if (list != null)

         for (TaoBaoOrder order : list) {

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

         }



      addRelationAndSpecialOrder(list);

   }



@@ -81,7 +88,13 @@


               }



               CMQManager.getInstance().addTaoBaoOrderMsg(key, orders);

               LogHelper.orderInfo("添加到队列:" + key);

               if (orders != null && orders.size() > 0 && System.currentTimeMillis()

                     - TimeUtil.convertToTimeTemp(orders.get(0).getCreateTime(), "yyyy-MM-dd HH:mm:ss") < 1000

                           * 60 * 10L)// 10分钟内产生的单作为新订单处理

                  CMQManager.getInstance().addTaoBaoNewOrderMsg(key);

               else

                  CMQManager.getInstance().addTaoBaoOrderMsg(key);



               try {

                  // 20分钟内不再处理

@@ -102,6 +115,7 @@
      if (!Constant.IS_TASK)

         return;

      // 爬取近20分钟的数据

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

      long endTime = System.currentTimeMillis();

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

   }