From 7ad8f5f80cb3d91e37d2cd4b76ecc0ac7c7869cb Mon Sep 17 00:00:00 2001
From: xy <748613696@qq.com>
Date: Tue, 16 Jun 2026 16:20:32 +0800
Subject: [PATCH] =?UTF-8?q?=E5=BE=AE=E8=B0=83?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../listener/RedisKeyExpirationListener.java  | 67 -------------------
 1 file changed, 67 deletions(-)
 delete mode 100644 iot-analysis/analysis-stat/stat-boot/src/main/java/com/njcn/stat/listener/RedisKeyExpirationListener.java

diff --git a/iot-analysis/analysis-stat/stat-boot/src/main/java/com/njcn/stat/listener/RedisKeyExpirationListener.java b/iot-analysis/analysis-stat/stat-boot/src/main/java/com/njcn/stat/listener/RedisKeyExpirationListener.java
deleted file mode 100644
index 6ae17be..0000000
--- a/iot-analysis/analysis-stat/stat-boot/src/main/java/com/njcn/stat/listener/RedisKeyExpirationListener.java
+++ /dev/null
@@ -1,67 +0,0 @@
-//package com.njcn.stat.listener;
-//
-//import cn.hutool.core.collection.CollectionUtil;
-//import com.njcn.common.pojo.exception.BusinessException;
-//import com.njcn.redis.pojo.enums.AppRedisKey;
-//import com.njcn.redis.utils.RedisUtil;
-//import com.njcn.stat.enums.StatResponseEnum;
-//import com.njcn.system.api.EpdFeignClient;
-//import com.njcn.system.pojo.dto.EpdDTO;
-//import lombok.extern.slf4j.Slf4j;
-//import org.apache.commons.lang3.StringUtils;
-//import org.springframework.core.annotation.Order;
-//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 javax.annotation.Resource;
-//import java.util.HashMap;
-//import java.util.List;
-//import java.util.Map;
-//
-///**
-// * @author hongawen
-// * @version 1.0.0
-// * @date 2022年04月02日 14:31
-// */
-//@Slf4j
-//@Component
-//public class RedisKeyExpirationListener extends KeyExpirationEventMessageListener {
-//
-//    @Resource
-//    private EpdFeignClient epdFeignClient;
-//
-//    @Resource
-//    private RedisUtil redisUtil;
-//
-//    public RedisKeyExpirationListener(RedisMessageListenerContainer listenerContainer) {
-//        super(listenerContainer);
-//    }
-//
-//
-//    /**
-//     * 针对redis数据失效事件，进行数据处理
-//     * 注意message.toString()可以获取失效的key
-//     */
-//    @Override
-//    @Order(0)
-//    public void onMessage(Message message, byte[] pattern) {
-//        if (StringUtils.isBlank(message.toString())) {
-//            return;
-//        }
-//        //判断失效的key
-//        String expiredKey = message.toString();
-//        if(expiredKey.equals(AppRedisKey.ELE_EPD_PQD)){
-//            Map<String,String> map = new HashMap<>();
-//            List<EpdDTO> list = epdFeignClient.findAll().getData();
-//            if (CollectionUtil.isEmpty(list)){
-//                throw new BusinessException(StatResponseEnum.DICT_NULL);
-//            }
-//            list.forEach(item->{
-//                map.put(item.getDictName(),item.getTableName());
-//            });
-//            redisUtil.saveByKeyWithExpire(AppRedisKey.ELE_EPD_PQD,map,3600L);
-//        }
-//    }
-//}