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