From 4f8c34d21b120a9ccdf33b1e09920b527a720fc8 Mon Sep 17 00:00:00 2001
From: xy <748613696@qq.com>
Date: Wed, 28 Jan 2026 08:40: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

---
 .../line/IDataLimitRateAsyncImpl.java         | 28 +++++++++----------
 1 file changed, 14 insertions(+), 14 deletions(-)

diff --git a/algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/serviceimpl/line/IDataLimitRateAsyncImpl.java b/algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/serviceimpl/line/IDataLimitRateAsyncImpl.java
index eea1486..672d553 100644
--- a/algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/serviceimpl/line/IDataLimitRateAsyncImpl.java
+++ b/algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/serviceimpl/line/IDataLimitRateAsyncImpl.java
@@ -123,7 +123,7 @@ public class IDataLimitRateAsyncImpl implements IDataLimitRateAsync {
          */
         Map<String, List<DataHarmDto>> harmRateV = dataVHarmList.stream()
                 .filter(x -> phase.contains(x.getPhasicType()))
-                .filter(x -> InfluxDBTableConstant.CP95.equals(x.getValueType()))
+                .filter(x -> InfluxDBTableConstant.CP95.equalsIgnoreCase(x.getValueType()))
                 .collect(Collectors.groupingBy(DataHarmDto::getLineId));
 
         /**
@@ -131,7 +131,7 @@ public class IDataLimitRateAsyncImpl implements IDataLimitRateAsync {
          */
         Map<String, List<DataIDto>> dataI = dataIList.stream()
                 .filter(x -> phase.contains(x.getPhasicType()))
-                .filter(x -> InfluxDBTableConstant.CP95.equals(x.getValueType()))
+                .filter(x -> InfluxDBTableConstant.CP95.equalsIgnoreCase(x.getValueType()))
                 .collect(Collectors.groupingBy(DataIDto::getLineId));
 
 
@@ -140,7 +140,7 @@ public class IDataLimitRateAsyncImpl implements IDataLimitRateAsync {
          */
         Map<String, List<DataHarmDto>> inHarmV = dataVInHarmList.stream()
                 .filter(x -> phase.contains(x.getPhasicType()))
-                .filter(x -> InfluxDBTableConstant.CP95.equals(x.getValueType()))
+                .filter(x -> InfluxDBTableConstant.CP95.equalsIgnoreCase(x.getValueType()))
                 .collect(Collectors.groupingBy(DataHarmDto::getLineId));
 
         /**
@@ -148,41 +148,41 @@ public class IDataLimitRateAsyncImpl implements IDataLimitRateAsync {
          */
         Map<String, List<DataVDto>> dataVThd = dataVAllTime.stream()
                 .filter(x -> phase.contains(x.getPhasicType()))
-                .filter(x -> InfluxDBTableConstant.CP95.equals(x.getValueType()))
+                .filter(x -> InfluxDBTableConstant.CP95.equalsIgnoreCase(x.getValueType()))
                 .collect(Collectors.groupingBy(DataVDto::getLineId));
 
         /**
          * 功能描述:获取influxDB -> data_v -> 负序电压不平衡度 -> 最大值 && 日95%概率值
          */
         Map<String, List<DataVDto>> dataVUnbalance = dataVAllTime.stream()
-                .filter(x -> InfluxDBTableConstant.PHASE_TYPE_T.equals(x.getPhasicType()))
-                .filter(x -> InfluxDBTableConstant.CP95.equals(x.getValueType()) ||
-                        InfluxDBTableConstant.MAX.equals(x.getValueType()))
+                .filter(x -> InfluxDBTableConstant.PHASE_TYPE_T.equalsIgnoreCase(x.getPhasicType()))
+                .filter(x -> InfluxDBTableConstant.CP95.equalsIgnoreCase(x.getValueType()) ||
+                        InfluxDBTableConstant.MAX.equalsIgnoreCase(x.getValueType()))
                 .collect(Collectors.groupingBy(DataVDto::getLineId));
 
         /**
          * 功能描述:获取influxDB -> data_i -> 负序电流 -> 最大值 && 日95%概率值
          */
         Map<String, List<DataIDto>> dataINeg = dataIList.stream()
-                .filter(x -> InfluxDBTableConstant.PHASE_TYPE_T.equals(x.getPhasicType()))
-                .filter(x -> InfluxDBTableConstant.CP95.equals(x.getValueType()) ||
-                        InfluxDBTableConstant.MAX.equals(x.getValueType()))
+                .filter(x -> InfluxDBTableConstant.PHASE_TYPE_T.equalsIgnoreCase(x.getPhasicType()))
+                .filter(x -> InfluxDBTableConstant.CP95.equalsIgnoreCase(x.getValueType()) ||
+                        InfluxDBTableConstant.MAX.equalsIgnoreCase(x.getValueType()))
                 .collect(Collectors.groupingBy(DataIDto::getLineId));
 
         /**
          * 功能描述:获取influxDB -> data_v -> 频率偏差 -> 最大值 && 最小值
          */
         Map<String, List<DataVDto>> dataVFreq = dataVAllTime.stream()
-                .filter(x -> InfluxDBTableConstant.PHASE_TYPE_T.equals(x.getPhasicType()))
-                .filter(x -> InfluxDBTableConstant.MIN.equals(x.getValueType()) ||
-                        InfluxDBTableConstant.MAX.equals(x.getValueType()))
+                .filter(x -> InfluxDBTableConstant.PHASE_TYPE_T.equalsIgnoreCase(x.getPhasicType()))
+                .filter(x -> InfluxDBTableConstant.MIN.equalsIgnoreCase(x.getValueType()) ||
+                        InfluxDBTableConstant.MAX.equalsIgnoreCase(x.getValueType()))
                 .collect(Collectors.groupingBy(DataVDto::getLineId));
         /**
          * 功能描述:获取influxDB -> data_v -> 电压偏差 -> 最大值
          */
         Map<String, List<DataVDto>> dataVDev = dataVAllTime.stream()
                 .filter(x -> phase.contains(x.getPhasicType()))
-                .filter(x -> InfluxDBTableConstant.MAX.equals(x.getValueType()))
+                .filter(x -> InfluxDBTableConstant.MAX.equalsIgnoreCase(x.getValueType()))
                 .collect(Collectors.groupingBy(DataVDto::getLineId));
 
         /**