package com.config.redis;
import org.apache.commons.lang.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.connection.Message;
import org.springframework.data.redis.listener.KeyExpirationEventMessageListener;
import org.springframework.data.redis.listener.RedisMessageListenerContainer;
import org.springframework.stereotype.Component;
import java.math.BigDecimal;
import java.util.List;
/**
* 监听所有的过期事件
*/
@Component
public class RedisKeyExpirationListener extends KeyExpirationEventMessageListener {
@Autowired
BusinessPurchaseOrderService purchaseOrderService;
@Autowired
private CustomCategoryTypeService categoryTypeService;
public RedisKeyExpirationListener(RedisMessageListenerContainer listenerContainer) {
super(listenerContainer);
}
/**
* 1、获取redis缓存内超过30分钟的订单编号
* 2、根据订单编号查询订单表，判断此订单是否支付
* 3、未支付根据订单编号关闭此订单
* @param message
* @param pattern
*/
@Override
public void onMessage(Message message, byte[] pattern) {
//1、获取失效Redis的key值
String expiredKey = message.toString();
//2、判断是订单编码则调用关闭订单方法
if (expiredKey.length()>10&&expiredKey.substring(0,10).equals(CommonConstant.AUTO_CLOSE_ORDER_PREFIX)){
closeOrder(expiredKey.substring(10));
}
}
/**
* 1、根据订单编号到订单表查询此订单是否支付
* 2、关闭订单
**/
private void closeOrder(String orderCode){
//1、根据订单编号到订单表查询此订单是否支付
Integer count = purchaseOrderService.orderCountByOrder(orderCode);
PurchaseOrder purchaseOrder = purchaseOrderService.orderByOrder(orderCode);
//未支付
if (purchaseOrder != null){
//2、关闭订单逻辑
//xxxxxxxx
}
}
}
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 举报，一经查实，本站将立刻删除。
文章由极客之音整理，本文链接：https://www.bmabk.com/index.php/post/192819.html
