From 7ef593e1e3c35aaeecf9318f0b3941230d3ed002 Mon Sep 17 00:00:00 2001 From: yangys <y_ys79@sina.com> Date: 星期三, 09 十月 2024 11:22:54 +0800 Subject: [PATCH] 增加在数据点计算规则后数据点名称加_n的适配 --- collect/src/main/java/com/qianwen/mdc/collect/service/CollectDataService.java | 5 ----- 1 files changed, 0 insertions(+), 5 deletions(-) diff --git a/collect/src/main/java/com/qianwen/mdc/collect/service/CollectDataService.java b/collect/src/main/java/com/qianwen/mdc/collect/service/CollectDataService.java index f219f26..6e86e38 100644 --- a/collect/src/main/java/com/qianwen/mdc/collect/service/CollectDataService.java +++ b/collect/src/main/java/com/qianwen/mdc/collect/service/CollectDataService.java @@ -4,7 +4,6 @@ import java.util.HashMap; import java.util.List; import java.util.Map; -import java.util.Random; import java.util.stream.Collectors; import org.apache.iotdb.isession.pool.SessionDataSetWrapper; @@ -26,9 +25,6 @@ import com.qianwen.mdc.collect.domain.TelemetryData; import com.qianwen.mdc.collect.domain.TelemetryDataItem; import com.qianwen.mdc.collect.mqtt.MqttMessageSender; -import com.qianwen.mdc.collect.utils.redis.RedisUtil; - -import cn.hutool.json.JSONUtil; /** * 閲囬泦鏁版嵁澶勭悊鍏ュ簱 @@ -129,7 +125,6 @@ int rowIndex = 0; Map<String, List<TypedTelemetryData>> processParamsMap = parseTelemetryToTypedMapList(dt); - String[] nameArr = processParamsMap.keySet().toArray(new String[0]); String name; -- Gitblit v1.9.3