From 8502fb2a1648d1453f96b4288d68c16dfcf5bae5 Mon Sep 17 00:00:00 2001
From: baoshiwei <baoshiwei@shlanbao.cn>
Date: 星期一, 12 五月 2025 16:19:49 +0800
Subject: [PATCH] feat(data): 新增mqtt电表数据解析和写入,新增opcua电表和温湿度计数据解析和写入

---
 src/main/java/com/zhitan/redis/RedisCache.java |   35 +++++++++++++++++++++--------------
 1 files changed, 21 insertions(+), 14 deletions(-)

diff --git a/src/main/java/com/zhitan/redis/RedisCache.java b/src/main/java/com/zhitan/redis/RedisCache.java
index d008cb7..567d67f 100644
--- a/src/main/java/com/zhitan/redis/RedisCache.java
+++ b/src/main/java/com/zhitan/redis/RedisCache.java
@@ -80,22 +80,29 @@
     }
 
     /**
-     * 缂撳瓨List鏁版嵁
-     *
-     * @param key      缂撳瓨鐨勯敭鍊�
-     * @param dataList 寰呯紦瀛樼殑List鏁版嵁
-     * @return 缂撳瓨鐨勫璞�
-     */
-    public <T> ListOperations<String, T> setCacheList(String key, List<T> dataList) {
-        ListOperations listOperation = redisTemplate.opsForList();
-        if (null != dataList) {
-            int size = dataList.size();
-            for (int i = 0; i < size; i++) {
-                listOperation.leftPush(key, dataList.get(i));
-            }
+ * 缂撳瓨List鏁版嵁锛屽苟璁剧疆杩囨湡鏃堕棿
+ *
+ * @param key      缂撳瓨鐨勯敭鍊�
+ * @param dataList 寰呯紦瀛樼殑List鏁版嵁
+ * @param timeout  杩囨湡鏃堕棿
+ * @param timeUnit 鏃堕棿鍗曚綅
+ * @return 缂撳瓨鐨勫璞�
+ */
+public <T> ListOperations<String, T> setCacheList(String key, List<T> dataList, Integer timeout, TimeUnit timeUnit) {
+    ListOperations listOperation = redisTemplate.opsForList();
+    if (null != dataList) {
+        int size = dataList.size();
+        for (int i = 0; i < size; i++) {
+            listOperation.leftPush(key, dataList.get(i));
         }
-        return listOperation;
     }
+    // 璁剧疆杩囨湡鏃堕棿
+    if (timeout > 0) {
+        redisTemplate.expire(key, timeout, timeUnit);
+    }
+    return listOperation;
+}
+
 
     /**
      * 鑾峰緱缂撳瓨鐨刲ist瀵硅薄

--
Gitblit v1.9.3