Merge remote-tracking branch 'origin/master'

admin

2019-07-30 573c491b4a1ba60e12a5678a01c1546c0077c1ee

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

@@ -1,24 +1,30 @@
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.dto.taobao.WeiQuanOrderResult;

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

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

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

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.log.LogHelper;

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

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.OrderProcessService;

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

@@ -29,6 +35,7 @@
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.TaoBaoOrderUtil;

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

@@ -40,10 +47,6 @@
   public UpdateOrderJob() {

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

   }





   @Resource

   private ThreeSaleGiftService threeSaleGiftService;



   @Resource

   private OrderProcessService orderProcessService;

@@ -72,6 +75,9 @@
   @Resource

   private OrderService orderService;



   @Resource

   private CommonOrderService commonOrderService;



   /**

    * 新版获取普通订单

    * 

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

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

               TaoBaoConstant.TAOBAO_AUTH_APPKEY, TaoBaoConstant.TAOBAO_AUTH_APPSECRET);

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

            orderList.addAll(tempOrderList);

      }

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

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

               TaoBaoConstant.TAOBAO_AUTH_APPKEY, TaoBaoConstant.TAOBAO_AUTH_APPSECRET);

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

            orderList.addAll(tempOrderList);

      }

@@ -268,7 +274,7 @@
      return orderList;

   }



   private void addOrder(List<TaoBaoOrder> orderList) {

   public void addOrder(List<TaoBaoOrder> orderList) {



      if (orderList != null)

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

@@ -295,11 +301,8 @@
      try {

         taoBaoOrderService.addTaoBaoOrderList(orderList);

      } catch (Exception e) {

         try {

            LogHelper.errorDetailInfo(e);

         } catch (Exception e1) {

            e1.printStackTrace();

         }

         LogHelper.errorDetailInfo(e);



      }



      try {

@@ -320,7 +323,7 @@


               }



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

               CMQManager.getInstance().addTaoBaoOrderMsg(key);



               try {

                  // 6小时内不再处理

@@ -331,11 +334,7 @@
            }

         }

      } catch (Exception e) {

         try {

            LogHelper.errorDetailInfo(e);

         } catch (Exception e1) {

            e1.printStackTrace();

         }

         LogHelper.errorDetailInfo(e);

      }

   }



@@ -373,8 +372,7 @@
   public void doJob2() {

      if (!Constant.IS_TASK)

         return;

      doTaoBaoWeiQuan();



      doTaoBaoWeiQuan(10);

      orderProcessService.fanli();

   }



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

      }

   }



}