blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
admin
2019-07-30 573c491b4a1ba60e12a5678a01c1546c0077c1ee 
 fanli/src/main/java/com/yeshi/fanli/job/UpdateOrderJob.java


@@ -1,28 +1,33 @@


package com.yeshi.fanli.job;







import java.math.BigDecimal;



import java.util.ArrayList;



import java.util.Calendar;



import java.util.Date;



import java.util.HashMap;



import java.util.HashSet;



import java.util.Iterator;



import java.util.List;



import java.util.Map;



import java.util.Set;







import javax.annotation.Resource;







import org.springframework.scheduling.annotation.Scheduled;



import org.springframework.stereotype.Component;







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



import com.yeshi.fanli.dto.taobao.WeiQuanOrderResult;



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



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



import com.yeshi.fanli.entity.order.CommonOrder;



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



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



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



import com.yeshi.fanli.exception.TaoBaoOrderException;



import com.yeshi.fanli.log.LogHelper;



import com.yeshi.fanli.service.inter.common.DataMonitorService;



import com.yeshi.fanli.service.inter.hongbao.HongBaoService;



import com.yeshi.fanli.service.inter.hongbao.ThreeSaleGiftService;



import com.yeshi.fanli.service.inter.order.CommonOrderService;



import com.yeshi.fanli.service.inter.order.LostOrderService;



import com.yeshi.fanli.service.inter.order.OrderItemServcie;



import com.yeshi.fanli.service.inter.order.OrderProcessService;



import com.yeshi.fanli.service.inter.order.PidOrderService;



import com.yeshi.fanli.service.inter.order.OrderService;



import com.yeshi.fanli.service.inter.taobao.TaoBaoOrderService;



import com.yeshi.fanli.service.inter.taobao.TaoBaoUnionConfigService;



import com.yeshi.fanli.service.inter.taobao.TaoBaoWeiQuanOrderService;



@@ -30,9 +35,10 @@


import com.yeshi.fanli.util.Constant;



import com.yeshi.fanli.util.RedisManager;



import com.yeshi.fanli.util.StringUtil;



import com.yeshi.fanli.util.TaoBaoConstant;



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



@@ -41,18 +47,6 @@


   public UpdateOrderJob() {



      System.out.println("初始化:UpdateOrderJob");



   }







   @Resource



   private OrderItemServcie orderItemServcie;







   @Resource



   private ThreeSaleGiftService threeSaleGiftService;







   @Resource



   private HongBaoService hongBaoService;







   @Resource



   private PidOrderService pidOrderService;







   @Resource



   private OrderProcessService orderProcessService;



@@ -78,30 +72,162 @@


   @Resource



   private LostOrderService lostOrderService;







   private void updateOrder(long startTime, long endTime) {



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



   @Resource



   private OrderService orderService;







   @Resource



   private CommonOrderService commonOrderService;







   /**



    * 新版获取普通订单



    * 


    * @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,



            TaoBaoConstant.TAOBAO_AUTH_APPKEY, TaoBaoConstant.TAOBAO_AUTH_APPSECRET);



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



         page++;



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



               TaoBaoConstant.TAOBAO_AUTH_APPKEY, TaoBaoConstant.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,



            TaoBaoConstant.TAOBAO_AUTH_APPKEY, TaoBaoConstant.TAOBAO_AUTH_APPSECRET);



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



         page++;



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



               TaoBaoConstant.TAOBAO_AUTH_APPKEY, TaoBaoConstant.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<>();



      try {



         orderList = TaoBaoOrderUtil.getOrderList(startTime, endTime, configList.get(0));



      } catch (TaoBaoOrderException e2) {



         try {



            LogHelper.errorDetailInfo(e2);



         } catch (Exception e) {



            e.printStackTrace();



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



      }



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



      try {



         thirdOrderList = TaoBaoOrderUtil.getThirdServiceOrderList(startTime, endTime, configList.get(0));



      } catch (TaoBaoOrderException e2) {



         try {



            LogHelper.errorDetailInfo(e2);



         } catch (Exception e) {



            e.printStackTrace();



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



      }



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



         orderList.addAll(thirdOrderList);



      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 {



      // orderList = TaoBaoOrderUtil.getOrderList(startTime, endTime,



      // configList.get(0));



      // } catch (TaoBaoOrderException e2) {



      // try {



      // LogHelper.errorDetailInfo(e2);



      // } catch (Exception e) {



      // e.printStackTrace();



      // }



      // }



      // List<TaoBaoOrder> thirdOrderList = new ArrayList<>();



      // try {



      // thirdOrderList = TaoBaoOrderUtil.getThirdServiceOrderList(startTime,



      // endTime, configList.get(0));



      // } catch (TaoBaoOrderException e2) {



      // try {



      // LogHelper.errorDetailInfo(e2);



      // } catch (Exception e) {



      // e.printStackTrace();



      // }



      // }



      // if (thirdOrderList != null && thirdOrderList.size() > 0)



      // orderList.addAll(thirdOrderList);



      // 新版本处理方式



      List<TaoBaoOrder> orderList = getCommonOrder(startTime, endTime);



      List<TaoBaoOrder> tempOrderList2 = getThirdCommonOrder(startTime, endTime);



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



         orderList.addAll(tempOrderList2);







      LogHelper.orderInfo("正在执行订单爬取结束，共有订单:" + orderList.size());



      addOrder(orderList);



@@ -110,18 +236,73 @@


      } catch (InterruptedException e) {



         e.printStackTrace();



      }







   }







   private void addOrder(List<TaoBaoOrder> orderList) {



   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;



   }







   public void addOrder(List<TaoBaoOrder> orderList) {







      if (orderList != null)



         for (int i = 0; i < orderList.size(); i++) {



            // 移除会员运营ID与渠道专属订单



            if (orderList.get(i).getAdPositionName().contains("会员运营")



                  || orderList.get(i).getAdPositionName().contains("渠道专属")) {



               if (orderList.get(i).getAdPositionName().contains("会员运营")) {// 处理订单申诉



                  Order order = orderService.findOrderByOrderIdAndType(orderList.get(i).getOrderId(),



                        Order.ORDER_TYPE_TAOBAO);



                  if (order != null && order.getBeizhu().contains("补单")) {// 不排除补单的情况







                  } else {



                     orderList.remove(i);



                     i--;



                     break;



                  }



               } else {



                  orderList.remove(i);



                  i--;



               }



            }



         }







      try {



         taoBaoOrderService.addTaoBaoOrderList(orderList);



      } catch (Exception e) {



         try {



            LogHelper.errorDetailInfo(e);



         } catch (Exception e1) {



            e1.printStackTrace();



         }



         LogHelper.errorDetailInfo(e);







      }







      try {



@@ -142,7 +323,7 @@






               }







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



               CMQManager.getInstance().addTaoBaoOrderMsg(key);







               try {



                  // 6小时内不再处理



@@ -153,11 +334,7 @@


            }



         }



      } catch (Exception e) {



         try {



            LogHelper.errorDetailInfo(e);



         } catch (Exception e1) {



            e1.printStackTrace();



         }



         LogHelper.errorDetailInfo(e);



      }



   }







@@ -166,7 +343,7 @@


   public void doJob1() {



      if (!Constant.IS_TASK)



         return;



      long currentTime = System.currentTimeMillis();



      long currentTime = System.currentTimeMillis() - 1000 * 60;



      String h = TimeUtil.getGernalTime(currentTime, "HH");



      String m = TimeUtil.getGernalTime(currentTime, "mm");



      int mm = Integer.parseInt(h) * 60 + Integer.parseInt(m);



@@ -181,43 +358,13 @@


   }







   // 淘宝推广订单 每隔3分13秒执行一次



   @Scheduled(cron = "13 0/3 0 24,25 * ? ")



   @Scheduled(cron = "13 0/3 * * * ? ")



   public void doJob6() {



      if (!Constant.IS_TASK)



         return;



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



      LogHelper.orderInfo("正在执行订单爬取...");



      // 爬取1分钟以前的



      long endTime = System.currentTimeMillis() - 1000 * 60 * 1L;



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



      try {



         orderList = TaoBaoOrderUtil.getOrderList(endTime - 1000 * 60 * 60 * 24 * 2L, endTime, configList.get(0));



         TaoBao110Util.rightTaoBaoOrderWarning();



      } catch (TaoBaoOrderException e) {



         try {



            LogHelper.errorDetailInfo(e);



            TaoBao110Util.reportTaoBaoOrderWarning(e.getCode(), e.getMessage());



         } catch (Exception e2) {



            e2.printStackTrace();



         }



      }



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



      try {



         thirdOrderList = TaoBaoOrderUtil.getThirdServiceOrderList(endTime - 1000 * 60 * 60 * 24 * 2L, endTime,



               configList.get(0));



      } catch (TaoBaoOrderException e) {



         try {



            LogHelper.errorDetailInfo(e);



         } catch (Exception e2) {



            e2.printStackTrace();



         }



      }



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



         orderList.addAll(thirdOrderList);



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



         dataMonitorService.parseTaoBaoOrderSuccess();



      LogHelper.orderInfo("正在执行订单爬取结束，共有订单:" + orderList.size());



      addOrder(orderList);



      long endTime = System.currentTimeMillis() - 1000 * 60;



      ;



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



   }







   // 返利



@@ -225,8 +372,7 @@


   public void doJob2() {



      if (!Constant.IS_TASK)



         return;



      doTaoBaoWeiQuan();







      doTaoBaoWeiQuan(10);



      orderProcessService.fanli();



   }







@@ -244,28 +390,193 @@


   public void doTaoBaoWeiQuan() {



      if (!Constant.IS_TASK)



         return;



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



      List<TaoBaoWeiQuanOrder> orderList = TaoBaoOrderUtil.getWeiQuanOrders(



            System.currentTimeMillis() - 1000 * 60 * 60 * 24 * 60L, System.currentTimeMillis(), configList.get(0));



      if (orderList != null)



         for (TaoBaoWeiQuanOrder order : orderList)



            taoBaoWeiQuanOrderService.addWeiQuanOrder(order);// 添加维权订单到数据库



      // 处理维权订单



      orderProcessService.weiQuanOrder(orderList);



      // 新版维权订单处理



      doTaoBaoWeiQuan(60);



   }







   // 处理分享商品所产生的订单(后续版本废除)



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



   // public void doPidOrder() {



   // if (!Constant.IS_TASK)



   // return;



   // pidOrderService.doPidOrder();



   // }



   private void doTaoBaoWeiQuan(int day) {



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



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



         WeiQuanOrderResult result = TaoKeOrderApiUtil



               .getTaoBaoSpecialWeiQuanOrderList(new Date(TimeUtil.convertToTimeTemp(



                     TimeUtil.getGernalTime(System.currentTimeMillis() - 1000 * 60 * 60 * 24L * i, "yyyy-MM-dd"),



                     "yyyy-MM-dd")), 1, false);



         orderList.addAll(result.orderList);







         result = TaoKeOrderApiUtil.getTaoBaoSpecialWeiQuanOrderList(new Date(TimeUtil.convertToTimeTemp(



               TimeUtil.getGernalTime(System.currentTimeMillis() - 1000 * 60 * 60 * 24L * i, "yyyy-MM-dd"),



               "yyyy-MM-dd")), 1, true);



         orderList.addAll(result.orderList);







         result = TaoKeOrderApiUtil.getTaoBaoRelationWeiQuanOrderList(new Date(TimeUtil.convertToTimeTemp(



               TimeUtil.getGernalTime(System.currentTimeMillis() - 1000 * 60 * 60 * 24L * i, "yyyy-MM-dd"),



               "yyyy-MM-dd")), 1, false);



         orderList.addAll(result.orderList);







         result = TaoKeOrderApiUtil.getTaoBaoRelationWeiQuanOrderList(new Date(TimeUtil.convertToTimeTemp(



               TimeUtil.getGernalTime(System.currentTimeMillis() - 1000 * 60 * 60 * 24L * i, "yyyy-MM-dd"),



               "yyyy-MM-dd")), 1, true);



         orderList.addAll(result.orderList);







         for (TaoBaoWeiQuanOrder order : orderList)



            taoBaoWeiQuanOrderService.addWeiQuanOrder(order);// 添加维权订单到数据库



         // 处理维权订单



         orderProcessService.weiQuanOrder(orderList);



      }







   }







   // 每6个小时执行一次



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



   public void doLostOrder() {



      if (!Constant.IS_TASK)



         return;



      lostOrderService.processFail();



   }







   // 每2分钟执行一次



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



   public void addLostOrder() {



      if (!Constant.IS_TASK)



         return;



      LogHelper.test("处理丢失订单");



      List<LostOrder> list = lostOrderService.listByStateAndResultCode(LostOrder.STATE_PASS,



            LostOrder.RESULT_CODE_VERFING, 1, 50);



      if (list != null)



         for (LostOrder lo : list) {



            List<TaoBaoOrder> taoBaoOrderList = taoBaoOrderService.getTaoBaoOrderByOrderId(lo.getOrderId());



            // 清除频率限制



            if (taoBaoOrderList != null && taoBaoOrderList.size() > 0) {



               String key = "addorderqueue-" + lo.getOrderId();



               redisManager.removeCommonString(key);



               addOrder(taoBaoOrderList);



               LogHelper.test("自动处理淘宝订单:" + lo.getOrderId());



            }



         }



   }







   /**



    * 处理淘宝结算订单,30fen执行一次



    */



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



   public void doSettleOrders() {



      if (!Constant.IS_TASK)



         return;



      // 处理3-15天前的订单，每天跑一次



      Calendar ca = Calendar.getInstance();



      int hour = ca.get(Calendar.HOUR_OF_DAY);







      long startTime = TimeUtil.convertToTimeTemp(



            TimeUtil.getGernalTime(ca.getTimeInMillis() - 1000 * 60 * 60 * 24 * 3L, "yyyy-MM-dd"), "yyyy-MM-dd")



            - hour * (1000 * 60 * 60 * 12L);



      long endTime = startTime + 1000 * 60 * 60 * 12L;



      List<TaoBaoOrder> orderList = TaoKeOrderApiUtil.getTaoBaoSettleOrders(startTime, endTime, false);



      List<TaoBaoOrder> tempOrderList = TaoKeOrderApiUtil.getTaoBaoSettleOrders(startTime, endTime, true);



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



         orderList.addAll(tempOrderList);



      addOrder(orderList);



   }







   /**



    * 13分钟更新最近13分钟的结算数据



    */



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



   public void doSettleOrdersToday() {



      if (!Constant.IS_TASK)



         return;



      // 处理3-15天前的订单，每天跑一次



      Calendar ca = Calendar.getInstance();



      long startTime = ca.getTimeInMillis() - 1000 * 60 * 5L - 1000 * 60 * 13L;



      long endTime = startTime + 1000 * 60 * 13L;



      List<TaoBaoOrder> orderList = TaoKeOrderApiUtil.getTaoBaoSettleOrders(startTime, endTime, false);



      List<TaoBaoOrder> tempOrderList = TaoKeOrderApiUtil.getTaoBaoSettleOrders(startTime, endTime, true);



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



         orderList.addAll(tempOrderList);



      addOrder(orderList);



   }







   /**



    * 更新本地订单（凌晨25分更新）



    */



   @Scheduled(cron = "25 0 0 * * ? ")



   public void doLocalTaoBaoOrder() {



      if (!Constant.IS_TASK)



         return;



      // 处理3-15天前的订单，每天跑一次



      Long startTime = System.currentTimeMillis() - 1000 * 60 * 60 * 24 * 60L;



      Long endTime = startTime + 1000 * 60 * 60 * 24 * 48L;



      List<CommonOrder> commonOrderList = commonOrderService.listBySourceTypeAndStateAndThirdCrateTime(



            Constant.SOURCE_TYPE_TAOBAO, CommonOrder.STATE_FK, startTime, endTime, 1, 500);



      Set<String> orderIds = new HashSet<>();



      for (CommonOrder co : commonOrderList) {



         orderIds.add(co.getOrderNo());



      }







      for (Iterator<String> its = orderIds.iterator(); its.hasNext();) {



         String orderId = its.next();



         List<TaoBaoOrder> orderList = taoBaoOrderService.getTaoBaoOrderByOrderId(orderId);



         Map<String, List<TaoBaoOrder>> orders = new HashMap<>();



         orders.put(orderId, orderList);



         orderProcessService.processOrder(orders);



      }



   }







   /**



    * 更新最近的本地单(30分钟更新一次)



    */







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



   public void doLatestLocalTaoBaoOrder() {



      if (!Constant.IS_TASK)



         return;



      Long endTime = System.currentTimeMillis() - 1000 * 60 * 10L;



      Long startTime = endTime - 1000 * 60 * 60 * 12L;



      updateLocalTaoBaoOrder(startTime, endTime, 1, 2000);







   }







   public void updateLocalTaoBaoOrder(Long startTime, Long endTime, int page, int count) {



      List<TaoBaoOrder> list = taoBaoOrderService.listBySettlementTime(startTime, endTime, page, count);



      Set<String> orderIds = new HashSet<>();



      for (TaoBaoOrder co : list) {



         orderIds.add(co.getOrderId());



      }







      for (Iterator<String> its = orderIds.iterator(); its.hasNext();) {



         String orderId = its.next();



         // 查询是否有处于订单付款状态的单



         List<CommonOrder> commonOrderList = commonOrderService



               .listBySourceTypeAndOrderId(Constant.SOURCE_TYPE_TAOBAO, orderId);



         boolean update = false;



         if (commonOrderList != null)



            for (CommonOrder co : commonOrderList) {



               if (co.getState() == CommonOrder.STATE_FK && co.getPayment().compareTo(new BigDecimal(0)) > 0) {



                  update = true;



                  break;



               }



            }







         if (update) {



            List<TaoBaoOrder> orderList = taoBaoOrderService.getTaoBaoOrderByOrderId(orderId);



            Map<String, List<TaoBaoOrder>> orders = new HashMap<>();



            orders.put(orderId, orderList);



            orderProcessService.processOrder(orders);



         }



      }



   }







   @Scheduled(cron = "30 13 3 * * ? ")



   public void doLatest5DayLocalTaoBaoOrder() {



      if (!Constant.IS_TASK)



         return;



      Long endTime = System.currentTimeMillis() - 1000 * 60 * 60 * 12L;



      Long startTime = endTime - 1000 * 60 * 60 * 24 * 5L;



      long count = taoBaoOrderService.countBySettlementTime(startTime, endTime);



      int pageSize = 100;



      long page = count % pageSize == 0 ? count / pageSize : count / pageSize + 1;



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



         updateLocalTaoBaoOrder(startTime, endTime, i + 1, pageSize);



      }



   }







}