getBoss方法只查询有效上级信息

yujian

2019-09-02 9eeda0d3049b71877c373c04d65533939b5582ef

 fanli/src/main/java/com/yeshi/fanli/job/order/taobao/UpdateTBRelationAndSpecialOrderJob.java

@@ -44,10 +44,30 @@
    *            结束页码（每页100条数据）

    */

   public void updateRelationAndSpecialOrder(long startTime, long endTime) {

      List<TaoBaoOrder> list = TaoKeOrderApiUtil.getSpecialOrder(startTime, endTime);

      List<TaoBaoOrder> list1 = TaoKeOrderApiUtil.getThirdSpecialOrder(startTime, endTime);

      List<TaoBaoOrder> list2 = TaoKeOrderApiUtil.getRelationOrder(startTime, endTime);

      List<TaoBaoOrder> list3 = TaoKeOrderApiUtil.getThirdRelationOrder(startTime, endTime);

      List<TaoBaoOrder> list = TaoKeOrderApiUtil.getSpecialOrder(startTime, endTime,TaoKeOrderApiUtil.TK_STATUS_ALL);

      List<TaoBaoOrder> list1 = TaoKeOrderApiUtil.getThirdSpecialOrder(startTime, endTime,TaoKeOrderApiUtil.TK_STATUS_ALL);

      List<TaoBaoOrder> list2 = TaoKeOrderApiUtil.getRelationOrder(startTime, endTime,TaoKeOrderApiUtil.TK_STATUS_ALL);

      List<TaoBaoOrder> list3 = TaoKeOrderApiUtil.getThirdRelationOrder(startTime, endTime,TaoKeOrderApiUtil.TK_STATUS_ALL);

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

         list.addAll(list1);

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

         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);

   }

	
   public void updateRelationAndSpecialSettleOrder(long startTime, long endTime) {

      List<TaoBaoOrder> list = TaoKeOrderApiUtil.getSpecialOrder(startTime, endTime,TaoKeOrderApiUtil.TK_STATUS_SETTLEMENT);

      List<TaoBaoOrder> list1 = TaoKeOrderApiUtil.getThirdSpecialOrder(startTime, endTime,TaoKeOrderApiUtil.TK_STATUS_SETTLEMENT);

      List<TaoBaoOrder> list2 = TaoKeOrderApiUtil.getRelationOrder(startTime, endTime,TaoKeOrderApiUtil.TK_STATUS_SETTLEMENT);

      List<TaoBaoOrder> list3 = TaoKeOrderApiUtil.getThirdRelationOrder(startTime, endTime,TaoKeOrderApiUtil.TK_STATUS_SETTLEMENT);

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

         list.addAll(list1);

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

@@ -118,6 +138,7 @@
      LogHelper.orderInfo("爬单:30s爬取一次单");

      long endTime = System.currentTimeMillis();

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

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

   }



   // 每5分钟更新（近1天数据）

@@ -127,6 +148,7 @@
         return;

      long endTime = System.currentTimeMillis();

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

      updateRelationAndSpecialSettleOrder(endTime - 1000 * 60 * 60 * 24L, endTime);

   }



   // 每个小时更新