Merge branch 'div' of ssh://193.112.35.168:29418/fanli-server into div

yujian

2019-08-27 d8359ddb48dab5cc797a9d552e11fde571f4920c

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

@@ -89,11 +89,13 @@
      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);

            TaoKeOrderApiUtil.TK_STATUS_ALL, 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);

               TaoKeOrderApiUtil.TK_STATUS_ALL, TaoBaoConstant.TAOBAO_AUTH_APPKEY,

               TaoBaoConstant.TAOBAO_AUTH_APPSECRET);

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

            orderList.addAll(tempOrderList);

      }

@@ -111,11 +113,13 @@
      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);

            TaoKeOrderApiUtil.TK_STATUS_ALL, 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);

               TaoKeOrderApiUtil.TK_STATUS_ALL, TaoBaoConstant.TAOBAO_AUTH_APPKEY,

               TaoBaoConstant.TAOBAO_AUTH_APPSECRET);

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

            orderList.addAll(tempOrderList);

      }

@@ -302,7 +306,6 @@
         taoBaoOrderService.addTaoBaoOrderList(orderList);

      } catch (Exception e) {

         LogHelper.errorDetailInfo(e);



      }



      try {

@@ -363,7 +366,6 @@
      if (!Constant.IS_TASK)

         return;

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

      ;

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

   }



@@ -372,8 +374,14 @@
   public void doJob2() {

      if (!Constant.IS_TASK)

         return;

      doTaoBaoWeiQuan();

      LogHelper.error("处理返利到账前置");

      try {



         doTaoBaoWeiQuanOrder(2);

      } catch (Exception e) {

         LogHelper.errorDetailInfo(e);

      }

      LogHelper.error("开始处理返利");

      orderProcessService.fanli();

   }



@@ -385,34 +393,57 @@
      orderProcessService.fanliInvaiteAndShare();

   }



   // 维权订单处理-处理最近60天的

   // 30分钟一次

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

   public void doTaoBaoWeiQuan() {

      if (!Constant.IS_TASK)

         return;

      // 新版维权订单处理

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

   private void doTaoBaoWeiQuanOrder(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);

                     "yyyy-MM-dd")), 1, 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, 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, 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, 1, true);

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

               "yyyy-MM-dd")), 3, 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")), 3, 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);

               "yyyy-MM-dd")), 3, 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);

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

         orderList.addAll(result.orderList);



         for (TaoBaoWeiQuanOrder order : orderList)

@@ -420,6 +451,16 @@
         // 处理维权订单

         orderProcessService.weiQuanOrder(orderList);

      }



   }



   // 维权订单处理-处理最近60天的

   // 30分钟一次

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

   public void doTaoBaoWeiQuan() {

      if (!Constant.IS_TASK)

         return;

      doTaoBaoWeiQuanOrder(5);

   }



   // 每6个小时执行一次

@@ -474,7 +515,7 @@
   }



   /**

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

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

    */

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

   public void doSettleOrdersToday() {

@@ -482,8 +523,8 @@
         return;

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

      Calendar ca = Calendar.getInstance();

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

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

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

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

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

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

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