From b901213a1bb11af00a6bf14b5a15f34766a71c19 Mon Sep 17 00:00:00 2001 From: xiaoyong931011 <15274802129@163.com> Date: Sat, 25 Sep 2021 19:00:09 +0800 Subject: [PATCH] Merge branch 'master' of http://120.27.238.55:7000/r/xc-mall --- src/main/java/cc/mrbird/febs/common/listener/RedisKeyExpirationListener.java | 44 ++++++++++++++++++++++---------------------- 1 files changed, 22 insertions(+), 22 deletions(-) diff --git a/src/main/java/cc/mrbird/febs/common/listener/RedisKeyExpirationListener.java b/src/main/java/cc/mrbird/febs/common/listener/RedisKeyExpirationListener.java index 737c005..612cfb2 100644 --- a/src/main/java/cc/mrbird/febs/common/listener/RedisKeyExpirationListener.java +++ b/src/main/java/cc/mrbird/febs/common/listener/RedisKeyExpirationListener.java @@ -32,27 +32,27 @@ @Override public void onMessage(Message message, byte[] pattern) { - String expireKey = message.toString(); - if (expireKey.startsWith(AppContants.REDIS_ORDER_OVERTIME_PREFIX)) { - List<String> split = StrUtil.split(expireKey, '_'); - if (split.size() < 4) { - log.error("自动取消订单失效:{}", expireKey); - return; - } - Long memberId = Long.valueOf(split.get(2)); - Long orderId = Long.valueOf(split.get(3)); - - MallOrderInfo orderInfo = mallOrderInfoMapper.selectOrderByMemberIdAndId(memberId, orderId); - if (orderInfo == null) { - log.error("自动取消订单参数错误:{}", expireKey); - return; - } - if (orderInfo.getStatus() == OrderStatusEnum.WAIT_PAY.getValue()) { - log.info("自动取消订单:{},{}", memberId, orderId); - orderInfo.setStatus(OrderStatusEnum.CANCEL.getValue()); - orderInfo.setCancelType(MallOrderInfo.CANCEL_OVERTIME_NO_PAY); - mallOrderInfoMapper.updateById(orderInfo); - } - } +// String expireKey = message.toString(); +// if (expireKey.startsWith(AppContants.REDIS_ORDER_OVERTIME_PREFIX)) { +// List<String> split = StrUtil.split(expireKey, '_'); +// if (split.size() < 4) { +// log.error("自动取消订单失效:{}", expireKey); +// return; +// } +// Long memberId = Long.valueOf(split.get(2)); +// Long orderId = Long.valueOf(split.get(3)); +// +// MallOrderInfo orderInfo = mallOrderInfoMapper.selectOrderByMemberIdAndId(memberId, orderId); +// if (orderInfo == null) { +// log.error("自动取消订单参数错误:{}", expireKey); +// return; +// } +// if (orderInfo.getStatus() == OrderStatusEnum.WAIT_PAY.getValue()) { +// log.info("自动取消订单:{},{}", memberId, orderId); +// orderInfo.setStatus(OrderStatusEnum.CANCEL.getValue()); +// orderInfo.setCancelType(MallOrderInfo.CANCEL_OVERTIME_NO_PAY); +// mallOrderInfoMapper.updateById(orderInfo); +// } +// } } } -- Gitblit v1.9.1