金币明细bug

yujian

2019-09-03 d1dccd08a249b830a95eeeb04af25f87d5c056be

 fanli/src/main/java/com/yeshi/fanli/job/order/jd/UpdateJDOrderJob.java

@@ -15,6 +15,7 @@
import com.yeshi.fanli.service.inter.jd.JDOrderService;

import com.yeshi.fanli.util.Constant;

import com.yeshi.fanli.util.RedisManager;

import com.yeshi.fanli.util.TimeUtil;

import com.yeshi.fanli.util.cmq.JDOrderCMQManager;

import com.yeshi.fanli.util.jd.JDApiUtil;



@@ -93,4 +94,61 @@
      saveJDOrders(jdOrderList);

   }



   /**

    * 更新一个小时的订单

    * 
    * @param date

    */

   private List<JDOrder> getHourOrder(Date date) {

      List<JDOrder> jdOrderList = new ArrayList<>();

      int pageSize = 200;

      int page = 1;

      JDOrderResult result = JDApiUtil.getOrderList(page++, pageSize, date, JDApiUtil.ORDER_TYPE_UPDATETIME);

      if (result != null) {

         jdOrderList.addAll(result.getOrderList());

         while (result != null && result.isHasMore()) {

            result = JDApiUtil.getOrderList(page++, pageSize,date, JDApiUtil.ORDER_TYPE_UPDATETIME);

            if (result != null)

               jdOrderList.addAll(result.getOrderList());

         }

      }

      return jdOrderList;

   }



   /**

    * 更新一天的数据

    * 
    * @param date

    */

   public void updateDayOrder(Date date) {

      Date now = new Date();

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

      Date startTime = new Date(

            TimeUtil.convertToTimeTemp(TimeUtil.getGernalTime(date.getTime(), "yyyy-MM-dd"), "yyyy-MM-dd"));

      // 一个小时为一个步长

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

         Date da = new Date(startTime.getTime() + 1000 * 60 * 60L * i);

         if (da.getTime() > now.getTime())

            return;

         List<JDOrder> tempOrderList = getHourOrder(da);

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

            orderList.addAll(tempOrderList);

      }

      saveJDOrders(orderList);

   }



	
   /**

    * 更新最近3天的订单（每天早上凌晨0点过10分，早上8点过10分）

    */

   @Scheduled(cron = "0 10 0,8 * * ? ")

   public void updateLatest3DayOrder() {

      if (!Constant.IS_TASK)

         return;

      Date now = new Date();

      for (int i = 1; i < 4; i++) {

         updateDayOrder(new Date(now.getTime() - 1000 * 60 * 60 * 24L * i));

      }

   }



}