From 859d6321b1b1c606de09e9b6a6286aaeace638fe Mon Sep 17 00:00:00 2001
From: yangys <y_ys79@sina.com>
Date: 星期三, 16 十月 2024 21:03:52 +0800
Subject: [PATCH] 接收采集数据，增加了使用配置数据点限制，配置了的数据点才会保存。未配置则丢弃
---
collect/src/main/java/com/qianwen/mdc/collect/service/PackedDataService.java | 5 ++++-
1 files changed, 4 insertions(+), 1 deletions(-)
diff --git a/collect/src/main/java/com/qianwen/mdc/collect/service/PackedDataService.java b/collect/src/main/java/com/qianwen/mdc/collect/service/PackedDataService.java
index 99392cd..2e5d115 100644
--- a/collect/src/main/java/com/qianwen/mdc/collect/service/PackedDataService.java
+++ b/collect/src/main/java/com/qianwen/mdc/collect/service/PackedDataService.java
@@ -47,6 +47,8 @@
private WorkstationCache workstationCache;
@Autowired
private TimeSliceCache timeSliceCache;
+ @Autowired
+ private WorkstationDatapointsService dpService;
static {
PROCESS_PARAM_MAP.put(1, "STATE");
@@ -91,12 +93,13 @@
String[] keys = map.keySet().toArray(new String[0]);
for (int j = 0; j < keys.length; j++) {
//TODO: 杩欓噷锛屽師绯荤粺杩涜浜嗚繃婊ゃ�俉orkstationCollectDataServiceImpl.handlerWorkstationCollectData閲�
+
PackedTelemetryData pkData = new PackedTelemetryData();
pkData.setWorkstationId(tdata.getWorkstationId());
pkData.setValue(map.get(keys[j]));
pkData.setTime(item.getTime());
- pkData.setName(keys[j]);//鍙傛暟鍚嶇О
+ pkData.setName(keys[j]);//鏁版嵁鐐瑰悕绉�
fillByCalendar(pkData);
--
Gitblit v1.9.3