| | |
| | | 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;
|
| | |
| | | String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.VIPShopOrder, order.getOrderSn() + "");
|
| | | String result = redisManager.getCommonString(key);
|
| | | // 判断
|
| | | if (StringUtil.isNullOrEmpty(result)) {
|
| | | // 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);
|