From d0df66049bf8ff7fb06d763aec3969288a802e47 Mon Sep 17 00:00:00 2001
From: yaowanxin <3588231647@qq.com>
Date: 星期五, 01 八月 2025 11:38:55 +0800
Subject: [PATCH] 改变redis数据存储
---
cnas-device/src/main/java/com/ruoyi/device/controller/WeightController.java | 26 ++++++++------------------
1 files changed, 8 insertions(+), 18 deletions(-)
diff --git a/cnas-device/src/main/java/com/ruoyi/device/controller/WeightController.java b/cnas-device/src/main/java/com/ruoyi/device/controller/WeightController.java
index 2838296..9e6676f 100644
--- a/cnas-device/src/main/java/com/ruoyi/device/controller/WeightController.java
+++ b/cnas-device/src/main/java/com/ruoyi/device/controller/WeightController.java
@@ -35,24 +35,14 @@
}
private void processThreeTimesValueDataStream(List<Double> weightList, String dataStream) {
- // 浠� Redis 鑾峰彇宸插瓨鍌ㄧ殑鍊�
- Object valueFromRedis = RedisUtil.get(dataStream);
- JSONArray valueArray = new JSONArray();
-
-
- if (valueFromRedis != null) {
- if (valueFromRedis instanceof String) {
- try {
- valueArray = JSONArray.parseArray((String) valueFromRedis);
- } catch (Exception e) {
- // 濡傛灉瑙ｆ瀽澶辫触锛岃鏄� Redis 涓殑鍊煎彲鑳戒笉鏄悎娉曠殑 JSON 鏁扮粍锛屽垱寤虹┖鏁扮粍
- valueArray = new JSONArray();
- }
- } else if (valueFromRedis instanceof Double) {
- valueArray.add(valueFromRedis);
- }
+ // 澶勭悊 weightList 涓� null 鐨勬儏鍐�
+ if (weightList == null) {
+ // 鑻� weightList 涓� null锛屽彲閫夋嫨鍒犻櫎 Redis 涓殑瀵瑰簲閿垨瀛樺叆绌烘暟缁勶紝杩欓噷閫夋嫨瀛樺叆绌烘暟缁�
+ RedisUtil.set(dataStream, "[]");
+ return;
}
- valueArray.addAll(weightList);
- RedisUtil.set(dataStream, valueArray.toJSONString());
+ // 灏� weightList 杞崲涓� JSON 瀛楃涓插苟瀛樺叆 Redis
+ String jsonStr = JSONArray.toJSONString(weightList);
+ RedisUtil.set(dataStream, jsonStr);
}
}
--
Gitblit v1.9.3