淘宝转链接口更新

admin

2025-02-25 30d8e227e8d823b6c38c3b9c90ac2df03b63befe

 fanli/src/main/java/com/yeshi/fanli/job/order/suning/UpdateSuningOrderJob.java

@@ -1,102 +1,113 @@
package com.yeshi.fanli.job.order.suning;



import java.util.ArrayList;

import java.util.Date;

import java.util.List;



import javax.annotation.Resource;



import org.springframework.stereotype.Component;



import com.xxl.job.core.biz.model.ReturnT;

import com.xxl.job.core.handler.annotation.XxlJob;

import com.yeshi.fanli.dto.suning.SuningOrderQueryResultDTO;

import com.yeshi.fanli.entity.suning.SuningOrderInfo;

import com.yeshi.fanli.exception.suning.SuningOrderException;

import com.yeshi.fanli.service.inter.order.suning.SuningOrderService;

import com.yeshi.fanli.util.RedisKeyEnum;

import com.yeshi.fanli.util.RedisManager;

import com.yeshi.fanli.util.StringUtil;

import com.yeshi.fanli.util.mq.cmq.order.SuningOrderCMQManager;

import com.yeshi.fanli.util.suning.SuningApiUtil;



//从淘宝爬去订单更新

@Component

public class UpdateSuningOrderJob {



   @Resource

   private SuningOrderService suningOrderService;



   @Resource

   private RedisManager redisManager;



   /**

    * 保存订单

    * 
    * @param SuningOrderList

    */

   public void saveSuningOrders(List<SuningOrderInfo> suningOrderList) {

      for (SuningOrderInfo order : suningOrderList) {

         try {

            suningOrderService.addOrder(order);

            /**

             * 做频率限制

             */

            String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.SuningOrder, order.getOrderCode() + "");

            String result = redisManager.getCommonString(key);

            // 判断

            if (StringUtil.isNullOrEmpty(result)) {

               SuningOrderCMQManager.getInstance().addSuningOrder(order.getOrderCode() + "");

               redisManager.cacheCommonString(key, "1", 60 * 60 * 2);// 2小时内不再更新

            }

         } catch (SuningOrderException e) {

            e.printStackTrace();

         }

      }

   }



   /**

    * 快速订单更新（爬取本小时内的单,每分钟一次）

    */

   @XxlJob("updateSuningOrderHandler")

   public ReturnT<String> updateSuningSoonOrder(String param) throws Exception {

      long endTime = System.currentTimeMillis();

      if ("1hour".equalsIgnoreCase(param)) {// 更新1小时内的订单

         updateByOrderTime(endTime - 1000 * 60 * 60 * 1L, endTime,2);

         updateByOrderTime(endTime - 1000 * 60 * 60 * 1L, endTime,3);

         updateByOrderTime(endTime - 1000 * 60 * 60 * 1L, endTime,4);

         updateByOrderTime(endTime - 1000 * 60 * 60 * 1L, endTime,5);

      } else if ("1day".equalsIgnoreCase(param)) {// 更新最近1天更新的数据

         updateByOrderTime(endTime - 1000 * 60 * 60 * 24L, endTime,2);

         updateByOrderTime(endTime - 1000 * 60 * 60 * 24L, endTime,3);

         updateByOrderTime(endTime - 1000 * 60 * 60 * 24L, endTime,4);

         updateByOrderTime(endTime - 1000 * 60 * 60 * 24L, endTime,5);

      }

      return ReturnT.SUCCESS;

   }



   /**

    * 按下单时间更新

    * @Title: updateByOrderTime

    * @Description: 
    * @param startTime

    * @param endTime 
    * void 返回类型

    * @throws

    */



   public void updateByOrderTime(long startTime, long endTime,int status) {

      List<SuningOrderInfo> suningOrderList = new ArrayList<>();

      int page = 1;



      SuningOrderQueryResultDTO result = SuningApiUtil.getOrderList(new Date(startTime), new Date(endTime), page, status);



      while (result != null && result.getOrderList().size() > 0) {

         page++;

         suningOrderList.addAll(result.getOrderList());

         result = SuningApiUtil.getOrderList(new Date(startTime), new Date(endTime), page, status);

      }



      saveSuningOrders(suningOrderList);

   }

}

package com.yeshi.fanli.job.order.suning;

import com.xxl.job.core.biz.model.ReturnT;
import com.xxl.job.core.handler.annotation.XxlJob;
import com.yeshi.fanli.dto.mq.order.body.CommonOrderMQMsg;
import com.yeshi.fanli.dto.suning.SuningOrderQueryResultDTO;
import com.yeshi.fanli.entity.suning.SuningOrderInfo;
import com.yeshi.fanli.exception.suning.SuningOrderException;
import com.yeshi.fanli.service.inter.order.suning.SuningOrderService;
import com.yeshi.fanli.util.Constant;
import com.yeshi.fanli.util.RedisKeyEnum;
import com.yeshi.fanli.util.RedisManager;
import com.yeshi.fanli.util.StringUtil;
import com.yeshi.fanli.util.mq.cmq.order.OrdersCMQManager;
import com.yeshi.fanli.util.suning.SuningApiUtil;
import org.springframework.stereotype.Component;

import javax.annotation.Resource;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;

//从淘宝爬去订单更新
@Component
public class UpdateSuningOrderJob {

   @Resource
   private SuningOrderService suningOrderService;

   @Resource
   private RedisManager redisManager;

   @Resource
   private OrdersCMQManager ordersCMQManager;



   /**
    * 保存订单
    * 
    * @param SuningOrderList
    */
   public void saveSuningOrders(List<SuningOrderInfo> suningOrderList) {

      //5分钟不更新就报警
      try {
         redisManager.cacheCommonString(RedisKeyEnum.monitor.getKey() + Constant.SOURCE_TYPE_SUNING, "1", 60 * 5);
      } catch (Exception e) {
      }
      for (SuningOrderInfo order : suningOrderList) {
         try {
            suningOrderService.addOrder(order);
            /**
             * 做频率限制
             */
            String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.SuningOrder, order.getOrderCode() + "");
            String result = redisManager.getCommonString(key);
            // 判断
            if (StringUtil.isNullOrEmpty(result)) {
               ordersCMQManager.addOrder(new CommonOrderMQMsg(order.getOrderCode() + "",Constant.SOURCE_TYPE_SUNING));
               redisManager.cacheCommonString(key, "1", 60 * 60 * 2);// 2小时内不再更新
            }
         } catch (SuningOrderException e) {
            e.printStackTrace();
         }
      }
   }

   /**
    * 快速订单更新（爬取本小时内的单,每分钟一次）
    */
   @XxlJob("updateSuningOrderHandler")
   public ReturnT<String> updateSuningSoonOrder(String param) throws Exception {
      long endTime = System.currentTimeMillis();
      if ("1hour".equalsIgnoreCase(param)) {// 更新1小时内的订单
         updateByOrderTime(endTime - 1000 * 60 * 60 * 1L, endTime,2);
         updateByOrderTime(endTime - 1000 * 60 * 60 * 1L, endTime,3);
         updateByOrderTime(endTime - 1000 * 60 * 60 * 1L, endTime,4);
         updateByOrderTime(endTime - 1000 * 60 * 60 * 1L, endTime,5);
      } else if ("1day".equalsIgnoreCase(param)) {// 更新最近1天更新的数据
         updateByOrderTime(endTime - 1000 * 60 * 60 * 24L, endTime,2);
         updateByOrderTime(endTime - 1000 * 60 * 60 * 24L, endTime,3);
         updateByOrderTime(endTime - 1000 * 60 * 60 * 24L, endTime,4);
         updateByOrderTime(endTime - 1000 * 60 * 60 * 24L, endTime,5);
      }
      return ReturnT.SUCCESS;
   }

   /**
    * 按下单时间更新
    * @Title: updateByOrderTime
    * @Description: 
    * @param startTime
    * @param endTime 
    * void 返回类型
    * @throws
    */

   public void updateByOrderTime(long startTime, long endTime,int status) {
      List<SuningOrderInfo> suningOrderList = new ArrayList<>();
      int page = 1;

      SuningOrderQueryResultDTO result = SuningApiUtil.getOrderList(new Date(startTime), new Date(endTime), page, status);

      while (result != null && result.getOrderList().size() > 0) {
         page++;
         suningOrderList.addAll(result.getOrderList());
         result = SuningApiUtil.getOrderList(new Date(startTime), new Date(endTime), page, status);
      }

      saveSuningOrders(suningOrderList);
   }
}