推广红包-不在收回

yujian

2019-07-23 c76ad0e79b95c0bceed8a0234211f2c7f0168b14

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

@@ -1,5 +1,6 @@
package com.yeshi.fanli.job;



import java.math.BigDecimal;

import java.util.ArrayList;

import java.util.Calendar;

import java.util.Date;

@@ -323,7 +324,7 @@


               }



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

               CMQManager.getInstance().addTaoBaoOrderMsg(key);



               try {

                  // 6小时内不再处理

@@ -471,7 +472,7 @@
   }



   /**

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

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

    */

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

   public void doLocalTaoBaoOrder() {

@@ -496,4 +497,62 @@
      }

   }



   /**

    * 更新最近的本地单(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);

      }

   }



}