From e126a3f800575ca5410ce72d671d54267ce9dcb1 Mon Sep 17 00:00:00 2001 From: wr <1754607820@qq.com> Date: Fri, 19 Dec 2025 09:39:51 +0800 Subject: [PATCH] =?UTF-8?q?=E5=BE=AE=E8=B0=83?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../serviceimpl/line/FlowAsyncServiceImpl.java | 16 ++++------------ 1 file changed, 4 insertions(+), 12 deletions(-) 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); }