动态v2兼容

yujian

2019-07-31 f4548a3ee46afe45da4ee2a42dc169c575deee9f

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

@@ -1,8 +1,5 @@
package com.yeshi.fanli.job;



import java.util.Calendar;

import java.util.Collections;

import java.util.Comparator;

import java.util.Iterator;

import java.util.List;

import java.util.Map;

@@ -57,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);

   }



@@ -64,11 +67,7 @@
      try {

         taoBaoOrderService.addTaoBaoOrderList(orderList);

      } catch (Exception e) {

         try {

            LogHelper.errorDetailInfo(e);

         } catch (Exception e1) {

            e1.printStackTrace();

         }

         LogHelper.errorDetailInfo(e);

      }



      try {

@@ -89,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分钟内不再处理

@@ -100,11 +105,7 @@
            }

         }

      } catch (Exception e) {

         try {

            LogHelper.errorDetailInfo(e);

         } catch (Exception e1) {

            e1.printStackTrace();

         }

         LogHelper.errorDetailInfo(e);

      }

   }



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

         return;

      // 爬取近20分钟的数据

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

      long endTime = System.currentTimeMillis();

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

   }

@@ -132,13 +134,13 @@
   public void doJob3() {

      if (!Constant.IS_TASK)

         return;

//      Calendar calendar = Calendar.getInstance();

//      int h = calendar.get(Calendar.HOUR_OF_DAY);

//      // 每个小时更新100页数据

//      int fromPage = h * 100;

//      if (fromPage <= 0)

//         fromPage = 11;

//      int toPage = h * 100 + 100;

      // Calendar calendar = Calendar.getInstance();

      // int h = calendar.get(Calendar.HOUR_OF_DAY);

      // // 每个小时更新100页数据

      // int fromPage = h * 100;

      // if (fromPage <= 0)

      // fromPage = 11;

      // int toPage = h * 100 + 100;

   }



}