接收采集数据，增加了使用配置数据点限制，配置了的数据点才会保存。未配置则丢弃

yangys

2024-10-16 859d6321b1b1c606de09e9b6a6286aaeace638fe

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
package com.qianwen.mdc.collect.domain;
 
import java.util.ArrayList;
import java.util.Collections;
import java.util.List;
import java.util.Map;
 
/**
 * 采集的数据
 */
public class TelemetryData {
    private long workstationId;
    /**
     * iotdb的appId
     */
    private String appId;
    private List<TelemetryDataItem> dataItems = new ArrayList<>();
 
    public void addItem(TelemetryDataItem item) {
        dataItems.add(item);
    }
    public void addItem(long ts,List<Map<String,String>> datas) {
        TelemetryDataItem item = new TelemetryDataItem();
        item.setTime(ts);
        item.setDataPoints(datas);
        dataItems.add(item);
    }
    
    public long getWorkstationId() {
        return workstationId;
    }
    public void setWorkstationId(long workstationId) {
        this.workstationId = workstationId;
    }
    
    public List<TelemetryDataItem> getDataItems() {
        return dataItems;
    }
    public void setDataItems(List<TelemetryDataItem> dataItems) {
        this.dataItems = dataItems;
    }
    
    public String getAppId() {
        return appId;
    }
    public void setAppId(String appId) {
        this.appId = appId;
    }
    @Override
    public String toString() {
        return "TelemetryData [workstationId=" + workstationId + ", appId=" + appId + ", dataItems=" + dataItems + "]";
    }
    
    
}