package com.zjt.shop.config;import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.listener.RedisMessageListenerContainer;
import org.springframework.data.redis.serializer.GenericJackson2JsonRedisSerializer;
import org.springframework.data.redis.serializer.StringRedisSerializer;/*** 作者：zhuLin* 日期：2020-08-21 11:48* 备注：redis监听配置*/@Configuration
public class RedisListenerConfig {@Autowiredprivate RedisTemplate redisTemplate;/*** 处理乱码* @return*/@Beanpublic RedisTemplate redisTemplateInit() {// key序列化redisTemplate.setKeySerializer(new StringRedisSerializer());//val实例化redisTemplate.setValueSerializer(new GenericJackson2JsonRedisSerializer());return redisTemplate;}@BeanRedisMessageListenerContainer container(RedisConnectionFactory connectionFactory) {RedisMessageListenerContainer container = new RedisMessageListenerContainer();container.setConnectionFactory(connectionFactory);return container;}}

package com.zjt.shop.common.util;import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
import com.zjt.shop.modules.order.service.OrderInfoService;
import com.zjt.shop.modules.product.entity.OrderInfoEntity;
import com.zjt.shop.modules.product.mapper.OrderInfoMapper;
import lombok.extern.slf4j.Slf4j;
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;/*** 作者：zhuLin* 日期：2020-08-21 11:51* 备注：redis数据失效事件*/
@Slf4j
@Component
public class RedisKeyExpirationListener extends KeyExpirationEventMessageListener {public RedisKeyExpirationListener(RedisMessageListenerContainer listenerContainer) {super(listenerContainer);}@Autowiredprivate OrderInfoMapper orderInfoMapper;/*** 针对redis数据失效事件，进行数据处理* @param message* @param pattern*/@Overridepublic void onMessage(Message message, byte[] pattern) {try {String key = message.toString();//从失效key中筛选代表订单失效的keyif (key != null && key.startsWith("order_")) {//截取订单号，查询订单，如果是未支付状态则为-取消订单String orderNo = key.substring(6);QueryWrapper<OrderInfoEntity> queryWrapper = new QueryWrapper<>();queryWrapper.eq("order_no",orderNo);OrderInfoEntity orderInfo = orderInfoMapper.selectOne(queryWrapper);if (orderInfo != null) {if (orderInfo.getOrderState() == 0) {   //待支付orderInfo.setOrderState(4);         //已取消orderInfoMapper.updateById(orderInfo);log.info("订单号为【" + orderNo + "】超时未支付-自动修改为已取消状态");}}}} catch (Exception e) {e.printStackTrace();log.error("【修改支付订单过期状态异常】：" + e.getMessage());}}
}