主分类 + 子分类 DAO改造

yujian

2019-03-27 cdcbed9af813b2a02cdc01eefa24db8bec6b51a9

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

@@ -16,16 +16,11 @@
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.LostOrderService;

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

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

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

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

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

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

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

@@ -44,18 +39,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;

@@ -105,9 +88,10 @@
      }

      return orderList;

   }

	


   /**

    * 获取第三方普通订单

    * 
    * @param startTime

    * @param span

    * @return

@@ -129,13 +113,14 @@


   /**

    * 获取某个区间段的订单

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

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

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

      if (span % 1200 != 0)

         count++;

@@ -153,17 +138,17 @@
      }

      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;

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

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

      if (span % 1200 != 0)

         count++;

@@ -200,36 +185,38 @@
   }



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

		
      // 老版本处理方式

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

@@ -348,11 +335,11 @@
   }



   // 每15分钟爬取一次

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

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

   public void doJob1() {

//      if (!Constant.IS_TASK)

//         return;

      long currentTime = System.currentTimeMillis();

      if (!Constant.IS_TASK)

         return;

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

@@ -371,8 +358,9 @@
   public void doJob6() {

      if (!Constant.IS_TASK)

         return;

      long endTime=System.currentTimeMillis();

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

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

      ;

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

   }



   // 返利