package com.yeshi.fanli.job.order.vipshop;
|
|
import java.util.ArrayList;
|
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.vipshop.VipShopOrderQueryModel;
|
import com.yeshi.fanli.dto.vipshop.VipShopQueryOrderResultDTO;
|
import com.yeshi.fanli.entity.vipshop.VipShopOrder;
|
import com.yeshi.fanli.exception.vipshop.VipShopOrderException;
|
import com.yeshi.fanli.log.LogHelper;
|
import com.yeshi.fanli.service.inter.order.vipshop.VipShopOrderService;
|
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.VipShopOrderCMQManager;
|
import com.yeshi.fanli.util.vipshop.VipShopApiUtil;
|
|
//从淘宝爬去订单更新
|
@Component
|
public class UpdateVipShopOrderJob {
|
|
@Resource
|
private VipShopOrderService vipShopOrderService;
|
|
@Resource
|
private RedisManager redisManager;
|
|
/**
|
* 保存订单
|
*
|
* @param VipShopOrderList
|
*/
|
public void saveVipShopOrders(List<VipShopOrder> vipShopOrderList) {
|
for (VipShopOrder order : vipShopOrderList) {
|
try {
|
vipShopOrderService.addOrder(order);
|
/**
|
* 做频率限制
|
*/
|
String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.VIPShopOrder, order.getOrderSn() + "");
|
String result = redisManager.getCommonString(key);
|
// 判断
|
// if (StringUtil.isNullOrEmpty(result)) {
|
VipShopOrderCMQManager.getInstance().addVipShopOrder(order.getOrderSn() + "");
|
redisManager.cacheCommonString(key, "1", 60 * 60 * 2);// 2小时内不再更新
|
LogHelper.test("唯品会订单消息发送成功");
|
// }else{
|
// LogHelper.test("唯品会订单频率限制");
|
// }
|
} catch (VipShopOrderException e) {
|
e.printStackTrace();
|
LogHelper.errorDetailInfo(e);
|
}
|
}
|
}
|
|
/**
|
* 快速订单更新（爬取本小时内的单,每分钟一次）
|
*/
|
@XxlJob("updateVipShopOrderHandler")
|
public ReturnT<String> updateVipShopSoonOrder(String param) throws Exception {
|
LogHelper.test("updateVipShopOrderHandler:"+param);
|
long endTime = System.currentTimeMillis();
|
if ("1hour".equalsIgnoreCase(param)) {// 更新1小时内的订单
|
updateByOrderTime(endTime - 1000 * 60 * 60 * 1L, endTime);
|
updateByUpdateTime(endTime - 1000 * 60 * 60 * 1L, endTime);
|
} else if ("1day".equalsIgnoreCase(param)) {// 更新最近1天更新的数据
|
updateByOrderTime(endTime - 1000 * 60 * 60 * 24L, endTime);
|
updateByUpdateTime(endTime - 1000 * 60 * 60 * 24L, endTime);
|
}
|
/*
|
* else if ("3day".equalsIgnoreCase(param)) {// 更新最近3天更新的数据
|
* updateByOrderTime(endTime - 1000 * 60 * 60 * 24 * 3L, endTime);
|
* updateByUpdateTime(endTime - 1000 * 60 * 60 * 24 * 3L, endTime); }
|
*/
|
return ReturnT.SUCCESS;
|
}
|
|
/**
|
* 按下单时间更新
|
* @Title: updateByOrderTime
|
* @Description:
|
* @param startTime
|
* @param endTime
|
* void 返回类型
|
* @throws
|
*/
|
|
public void updateByOrderTime(long startTime, long endTime) {
|
List<VipShopOrder> vipShopOrderList = new ArrayList<>();
|
int page = 1;
|
VipShopQueryOrderResultDTO result = VipShopApiUtil
|
.getOrderList(VipShopOrderQueryModel.createOrderTime(startTime, endTime, null, page));
|
|
while (result != null && result.getOrderList().size() > 0) {
|
page++;
|
vipShopOrderList.addAll(result.getOrderList());
|
result = VipShopApiUtil
|
.getOrderList(VipShopOrderQueryModel.createOrderTime(startTime, endTime, null, page));
|
}
|
|
saveVipShopOrders(vipShopOrderList);
|
}
|
|
/**
|
* 按更新时间更新
|
* @Title: updateByOrderTime
|
* @Description:
|
* @param startTime
|
* @param endTime
|
* void 返回类型
|
* @throws
|
*/
|
|
public void updateByUpdateTime(long startTime, long endTime) {
|
List<VipShopOrder> vipShopOrderList = new ArrayList<>();
|
int page = 1;
|
VipShopQueryOrderResultDTO result = VipShopApiUtil
|
.getOrderList(VipShopOrderQueryModel.createUpdateTime(startTime, endTime, null, page));
|
|
while (result != null && result.getOrderList().size() > 0) {
|
page++;
|
vipShopOrderList.addAll(result.getOrderList());
|
result = VipShopApiUtil
|
.getOrderList(VipShopOrderQueryModel.createUpdateTime(startTime, endTime, null, page));
|
}
|
saveVipShopOrders(vipShopOrderList);
|
}
|
|
}
|
