diff --git a/algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/serviceimpl/line/FlowAsyncServiceImpl.java b/algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/serviceimpl/line/FlowAsyncServiceImpl.java index bcca522..afe4b2c 100644 --- a/algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/serviceimpl/line/FlowAsyncServiceImpl.java +++ b/algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/serviceimpl/line/FlowAsyncServiceImpl.java @@ -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 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 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); }