From abfe636ee5c8ad51af20505bb4e4054c2b603cb7 Mon Sep 17 00:00:00 2001
From: yaowanxin <3588231647@qq.com>
Date: 星期五, 01 八月 2025 12:28:44 +0800
Subject: [PATCH] 增添标识类，方法名
---
cnas-device/src/main/java/com/ruoyi/device/controller/WeightController.java | 30 ++++++++++--------------------
1 files changed, 10 insertions(+), 20 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..8c3dfd0 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
@@ -24,7 +24,7 @@
List<Double> weightList = weightRequest.getWeights();
// 鍦ㄨ繖閲屾坊鍔犳暟鎹鐞嗛�昏緫锛屼緥濡傛墦鍗般�佸瓨鍌ㄥ埌鏁版嵁搴撶瓑
System.out.println("鎺ユ敹鍒扮殑鏁版嵁: " + weightList);
- processThreeTimesValueDataStream(weightList, WeightRequestDto.DENSITY);
+ processValueDataStream(weightList, WeightRequestDto.DENSITY);
// 澶勭悊鎴愬姛杩斿洖 200 鐘舵�佺爜鍜屾秷鎭�
return ResponseEntity.ok("鏁版嵁澶勭悊鎴愬姛");
@@ -34,25 +34,15 @@
}
}
- 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);
- }
+ private void processValueDataStream(List<Double> weightList, String dataStream) {
+ // 澶勭悊 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