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:
wr
2025-12-19 09:39:51 +08:00
parent f09409c553
commit e126a3f800
1 changed files with 4 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/serviceimpl/line/FlowAsyncServiceImpl.java
View File

@@ -319,14 +319,10 @@ public class FlowAsyncServiceImpl implements FlowAsyncService {
PqDataVerifyCount verifyCount = new PqDataVerifyCount();
verifyCount.setLineId(item.getLineId());
verifyCount.setTime(LocalDate.parse(dataDate, DateTimeFormatter.ofPattern(DatePattern.NORM_DATE_PATTERN)));
verifyCount.setTotalAll(data1.size());
verifyCount.setFlickerAll(data9.size());
verifyCount.setTotal(allTimeSet.size() * item.getTimeInterval());
verifyCount.setTotalAll(1440);
List<DataVDto> dataV = data1.stream()
.filter(item1 -> allTimeSet.contains(item1.getMinTime().substring(11, 19)))
.collect(Collectors.toList());
if (CollUtil.isNotEmpty(dataV)) {
verifyCount.setTotal(dataV.size());
if (CollUtil.isNotEmpty(data1)) {
// dataV.forEach(item1-> item1.setAbnormalFlag(1));
// dataVFeignClient.addInfluxDbList(dataV);
}
@@ -379,11 +375,7 @@ public class FlowAsyncServiceImpl implements FlowAsyncService {
// dataFluc.forEach(item1-> item1.setAbnormalFlag(1));
// dataFlucFeignClient.addInfluxDbList(dataFluc);
// }
List<DataFlickerDto> dataFlicker = data9.stream()
.filter(item1 -> allTimeSet.contains(item1.getMinTime().substring(11, 19)))
.collect(Collectors.toList());
if (CollUtil.isNotEmpty(dataFlicker)) {
verifyCount.setFlicker(dataFlicker.size());
if (CollUtil.isNotEmpty(data9)) {
// dataFlicker.forEach(item1-> item1.setAbnormalFlag(1));
// dataFlickerFeignClient.addInfluxDbList(dataFlicker);
}