Middleware/cn-data-platform
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

算法调整

Browse Source
This commit is contained in:
xy
2025-12-17 11:17:24 +08:00
parent 713db187c5
commit 1043097a11
1 changed files with 20 additions and 19 deletions
Download Patch File Download Diff File Expand all files Collapse all files

39
algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/serviceimpl/line/DataCleanServiceImpl.java
View File

@@ -367,25 +367,26 @@ public class DataCleanServiceImpl implements IDataCleanService {
}
}
if (CollUtil.isNotEmpty(data2)) {
logger.info("{}数据清洗dataI集合大小为>>>>>>>>>>>>{}", lineParam.getStartTime(), MemorySizeUtil.getObjectSize(data2));
List<PqDataVerify> result = new ArrayList<>();
List<PqReasonableRangeDto> list = map.get(DataCleanEnum.DataI.getCode());
Map<String, PqReasonableRangeDto> pqReasonableRangeDtoMap = list.stream().collect(Collectors.toMap(PqReasonableRangeDto::getIndexCode, Function.identity()));
data2.forEach(data -> {
List<PqDataVerify> pqDataVerifies = judgeDataI(pqReasonableRangeDtoMap, item, data);
result.addAll(pqDataVerifies);
});
if (CollUtil.isNotEmpty(result)) {
Map<String, Object> dtoMap = handleDataI(result, bak, item.getTimeInterval());
Set<String> timeSet = new HashSet<>(result.stream().map(dt -> dt.getTime().format(DateTimeFormatter.ofPattern(DatePattern.NORM_TIME_PATTERN))).collect(Collectors.toSet()));
dtoMap.put("errorTimes", timeSet.size() * item.getTimeInterval());
allTimeSet.addAll(timeSet);
if (CollUtil.isNotEmpty(dtoMap)) {
resultData.add(dtoMap);
}
}
}
//电流有效值先不判断异常
// if (CollUtil.isNotEmpty(data2)) {
// logger.info("{}数据清洗dataI集合大小为>>>>>>>>>>>>{}", lineParam.getStartTime(), MemorySizeUtil.getObjectSize(data2));
// List<PqDataVerify> result = new ArrayList<>();
// List<PqReasonableRangeDto> list = map.get(DataCleanEnum.DataI.getCode());
// Map<String, PqReasonableRangeDto> pqReasonableRangeDtoMap = list.stream().collect(Collectors.toMap(PqReasonableRangeDto::getIndexCode, Function.identity()));
// data2.forEach(data -> {
// List<PqDataVerify> pqDataVerifies = judgeDataI(pqReasonableRangeDtoMap, item, data);
// result.addAll(pqDataVerifies);
// });
// if (CollUtil.isNotEmpty(result)) {
// Map<String, Object> dtoMap = handleDataI(result, bak, item.getTimeInterval());
// Set<String> timeSet = new HashSet<>(result.stream().map(dt -> dt.getTime().format(DateTimeFormatter.ofPattern(DatePattern.NORM_TIME_PATTERN))).collect(Collectors.toSet()));
// dtoMap.put("errorTimes", timeSet.size() * item.getTimeInterval());
// allTimeSet.addAll(timeSet);
// if (CollUtil.isNotEmpty(dtoMap)) {
// resultData.add(dtoMap);
// }
// }
// }
if (CollUtil.isNotEmpty(data3)) {
logger.info("{}数据清洗dataPlt集合大小为>>>>>>>>>>>>{}", lineParam.getStartTime(), MemorySizeUtil.getObjectSize(data3));