From 1043097a11b9af6818d0a853c67be8a8932eba2d Mon Sep 17 00:00:00 2001
From: xy <748613696@qq.com>
Date: Wed, 17 Dec 2025 11:17:24 +0800
Subject: [PATCH] =?UTF-8?q?=E7=AE=97=E6=B3=95=E8=B0=83=E6=95=B4?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../line/DataCleanServiceImpl.java            | 39 ++++++++++---------
 1 file changed, 20 insertions(+), 19 deletions(-)

diff --git a/algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/serviceimpl/line/DataCleanServiceImpl.java b/algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/serviceimpl/line/DataCleanServiceImpl.java
index 5c8ad11..1ec4027 100644
--- a/algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/serviceimpl/line/DataCleanServiceImpl.java
+++ b/algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/serviceimpl/line/DataCleanServiceImpl.java
@@ -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));