xiaoguangbin/AnalysisSystemForRadionuclide
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

台站运行管理模块查询台站监测数据信息返回内容过滤后的内容返回，不再返回全部缓存信息

Browse Source
This commit is contained in:
qiaoqinzheng 2024-02-19 17:01:21 +08:00
parent cbcbb93209
commit df379a6b17
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
jeecg-module-station-operation/src/main/java/org/jeecg/modules/service/impl/StationOperationServiceImpl.java
View File

@ -424,8 +424,10 @@ public class StationOperationServiceImpl extends ServiceImpl<StationOperationMap
for (Map<String, DetectorData> detectorDataMap:detectorValue) { for (Map<String, DetectorData> detectorDataMap:detectorValue) {
for (String key :detectorDataMap.keySet()) { for (String key :detectorDataMap.keySet()) {
DetectorData detectorData = detectorDataMap.get(key); DetectorData detectorData = detectorDataMap.get(key);
List<DataInfoVo> dataList = detectorData.getDataList();
//通过流过滤出数据的开始时间戳在用户统计的开始时间戳之后的数据 //通过流过滤出数据的开始时间戳在用户统计的开始时间戳之后的数据
detectorData.getDataList().stream().filter(item -> item.getBeginTime() >= startMill).collect(Collectors.toList()); dataList = dataList.stream().filter(item -> item.getBeginTime() >= startMill).collect(Collectors.toList());
detectorData.setDataList(dataList);
} }
} }
} }
@ -461,8 +463,10 @@ public class StationOperationServiceImpl extends ServiceImpl<StationOperationMap
for (Map<String, DetectorData> detectorDataMap:detectorValue) { for (Map<String, DetectorData> detectorDataMap:detectorValue) {
for (String key :detectorDataMap.keySet()) { for (String key :detectorDataMap.keySet()) {
DetectorData detectorData = detectorDataMap.get(key); DetectorData detectorData = detectorDataMap.get(key);
List<DataInfoVo> dataList = detectorData.getDataList();
//通过流过滤出数据的开始时间戳在用户统计的开始时间戳之后的数据 //通过流过滤出数据的开始时间戳在用户统计的开始时间戳之后的数据
detectorData.getDataList().stream().filter(item -> item.getBeginTime() >= startMill).collect(Collectors.toList()); dataList = dataList.stream().filter(item -> item.getBeginTime() >= startMill).collect(Collectors.toList());
detectorData.setDataList(dataList);
} }
} }
} }