Merge remote-tracking branch 'origin/master'

admin

2019-03-08 f5ad4a8171b20ab75eaac90c9717fe7fd801d6cd

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

@@ -1,6 +1,7 @@
package com.yeshi.fanli.job;



import java.util.ArrayList;

import java.util.Date;

import java.util.Iterator;

import java.util.List;

import java.util.Map;

@@ -10,7 +11,7 @@
import org.springframework.scheduling.annotation.Scheduled;

import org.springframework.stereotype.Component;



import com.yeshi.fanli.entity.bus.user.LostOrder;

import com.taobao.api.TaobaoObject;

import com.yeshi.fanli.entity.bus.user.Order;

import com.yeshi.fanli.entity.taobao.PidUser;

import com.yeshi.fanli.entity.taobao.TaoBaoOrder;

@@ -36,6 +37,7 @@
import com.yeshi.fanli.util.TimeUtil;

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

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

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



//从淘宝爬去订单更新

@Component

@@ -84,7 +86,122 @@
   @Resource

   private OrderService orderService;



   private void updateOrder(long startTime, long endTime) {

   /**

    * 新版获取普通订单

    * 
    * @param startTime

    * @param span

    * @return

    */

   private static List<TaoBaoOrder> getCommonOrder(long startTime, int span) {

      int page = 1;

      String startTimeStr = TimeUtil.getGernalTime(startTime, "yyyy-MM-dd HH:mm:ss");

      List<TaoBaoOrder> orderList = TaoKeOrderApiUtil.getTaoBaoAllOrder(startTimeStr, span, page,

            Constant.TAOBAO_AUTH_APPKEY, Constant.TAOBAO_AUTH_APPSECRET);

      while (orderList.size() == 100 * page) {

         page++;

         List<TaoBaoOrder> tempOrderList = TaoKeOrderApiUtil.getTaoBaoAllOrder(startTimeStr, span, page,

               Constant.TAOBAO_AUTH_APPKEY, Constant.TAOBAO_AUTH_APPSECRET);

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

            orderList.addAll(tempOrderList);

      }

      return orderList;

   }

	
   /**

    * 获取第三方普通订单

    * @param startTime

    * @param span

    * @return

    */

   private static List<TaoBaoOrder> getThirdCommonOrder(long startTime, int span) {

      int page = 1;

      String startTimeStr = TimeUtil.getGernalTime(startTime, "yyyy-MM-dd HH:mm:ss");

      List<TaoBaoOrder> orderList = TaoKeOrderApiUtil.getTaoBaoThirdAllOrder(startTimeStr, span, page,

            Constant.TAOBAO_AUTH_APPKEY, Constant.TAOBAO_AUTH_APPSECRET);

      while (orderList.size() == 100 * page) {

         page++;

         List<TaoBaoOrder> tempOrderList = TaoKeOrderApiUtil.getTaoBaoThirdAllOrder(startTimeStr, span, page,

               Constant.TAOBAO_AUTH_APPKEY, Constant.TAOBAO_AUTH_APPSECRET);

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

            orderList.addAll(tempOrderList);

      }

      return orderList;

   }



   /**

    * 获取某个区间段的订单

    * @param startTime

    * @param endTime

    * @return

    */

   public static List<TaoBaoOrder> getCommonOrder(long startTime, long endTime) {

      List<TaoBaoOrder> orderList = new ArrayList<>();

      long span =(endTime - startTime)%1000==0? (endTime - startTime)/1000:(endTime - startTime)/1000+1;

      int count = (int) (span / 1200);

      if (span % 1200 != 0)

         count++;

      for (int i = 0; i < count; i++) {

         long startT = startTime + i * 1200 * 1000L;

         int s = 1200;

         if (endTime < startT + 1200 * 1000L) {

            s = (int) ((endTime - startT) / 1000) + 1;

            if (s < 60)

               s = 60;

         }

         List<TaoBaoOrder> tempOrderList = getCommonOrder(startT, s);

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

            orderList.addAll(tempOrderList);

      }

      return orderList;

   }

	
	
   /**

    * 爬取三方订单

    * @param startTime

    * @param endTime

    * @return

    */

   public static List<TaoBaoOrder> getThirdCommonOrder(long startTime, long endTime) {

      List<TaoBaoOrder> orderList = new ArrayList<>();

      long span =(endTime - startTime)%1000==0? (endTime - startTime)/1000:(endTime - startTime)/1000+1;

      int count = (int) (span / 1200);

      if (span % 1200 != 0)

         count++;

      for (int i = 0; i < count; i++) {

         long startT = startTime + i * 1200 * 1000L;

         int s = 1200;

         if (endTime < startT + 1200 * 1000L) {

            s = (int) ((endTime - startT) / 1000) + 1;

            if (s < 60)

               s = 60;

         }

         List<TaoBaoOrder> tempOrderList = getThirdCommonOrder(startT, s);

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

            orderList.addAll(tempOrderList);

      }

      return orderList;

   }



   /**

    * 按天获取普通订单（新版）

    * 
    * @param date

    * @return

    */

   public List<TaoBaoOrder> getCommonOrderByDay(Date date) {

      List<TaoBaoOrder> orderList = new ArrayList<>();

      // 将一天分成12段

      for (int i = 0; i < 72; i++) {

         List<TaoBaoOrder> tempOrderList = getCommonOrder(date.getTime() + 1000 * 60 * 20L * i, 1200);

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

            orderList.addAll(tempOrderList);

      }

      return orderList;

   }



   public void updateOrder(long startTime, long endTime) {

      List<TaoBaoUnionConfig> configList = taoBaoUnionConfigService.getConfigByTypeCache(PidUser.TYPE_FANLI_ANDROID);

      List<TaoBaoOrder> orderList = new ArrayList<>();

      try {

@@ -116,7 +233,42 @@
      } catch (InterruptedException e) {

         e.printStackTrace();

      }

   }



   public static List<TaoBaoOrder> mixTaoBaoOrder(List<TaoBaoOrder> commonOrderList, List<TaoBaoOrder> sorderList) {

      Map<String, List<TaoBaoOrder>> commonMap = TaoBaoOrderUtil.classifyTaoBaoOrderByOrderId(commonOrderList);

      Map<String, List<TaoBaoOrder>> sMap = TaoBaoOrderUtil.classifyTaoBaoOrderByOrderId(sorderList);

      // 获取订单交集

      Iterator<String> its = commonMap.keySet().iterator();

      List<String> commonOrderIdList = new ArrayList<>();

      List<String> sOrderIdList = new ArrayList<>();

      while (its.hasNext()) {

         String orderId = its.next();

         commonOrderIdList.add(orderId);

      }

      its = sMap.keySet().iterator();

      while (its.hasNext()) {

         String orderId = its.next();

         sOrderIdList.add(orderId);

      }



      // 求交集

      commonOrderIdList.retainAll(sOrderIdList);



      List<TaoBaoOrder> orderList = new ArrayList<>();



      for (String orderId : commonOrderIdList) {

         List<TaoBaoOrder> list = commonMap.get(orderId);

         String specialId = sMap.get(orderId).get(0).getSpecialId();

         String relationId = sMap.get(orderId).get(0).getRelationId();

         for (TaoBaoOrder to : list) {

            to.setSpecialId(specialId);

            to.setRelationId(relationId);

            orderList.add(to);

         }

      }



      return orderList;

   }



   private void addRelationAndSpecialOrder(List<TaoBaoOrder> orderList) {