diff --git a/jeecg-module-station-operation/src/main/java/org/jeecg/modules/service/impl/StationOperationServiceImpl.java b/jeecg-module-station-operation/src/main/java/org/jeecg/modules/service/impl/StationOperationServiceImpl.java index 4a5cc75e..6bfb88fc 100644 --- a/jeecg-module-station-operation/src/main/java/org/jeecg/modules/service/impl/StationOperationServiceImpl.java +++ b/jeecg-module-station-operation/src/main/java/org/jeecg/modules/service/impl/StationOperationServiceImpl.java @@ -424,8 +424,10 @@ public class StationOperationServiceImpl extends ServiceImpl<StationOperationMap for (Map<String, DetectorData> detectorDataMap:detectorValue) { for (String key :detectorDataMap.keySet()) { 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 (String key :detectorDataMap.keySet()) { 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); } } }