From ba1f5a2e001ab227d0c7816b20bc61250e4bdf0c Mon Sep 17 00:00:00 2001
From: xy <748613696@qq.com>
Date: Tue, 3 Feb 2026 16:37:36 +0800
Subject: [PATCH] =?UTF-8?q?=E9=95=BF=E6=97=B6=E9=97=B4=E9=97=AA=E5=8F=98?=
 =?UTF-8?q?=E6=96=B0=E5=A2=9E=E6=9C=80=E5=A4=A7=E5=80=BC=E9=99=90=E5=80=BC?=
 =?UTF-8?q?=E5=88=A4=E6=96=AD?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../algorithm/serviceimpl/line/IDataLimitRateAsyncImpl.java    | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

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 672d553..4b023c7 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
@@ -186,10 +186,11 @@ public class IDataLimitRateAsyncImpl implements IDataLimitRateAsync {
                 .collect(Collectors.groupingBy(DataVDto::getLineId));
 
         /**
-         * 功能描述:获取influxDB -> data_plt -> 长时间闪变 -> 注(取最大值原始算法去掉了，现没有根据最大值比较)
+         * 功能描述:获取influxDB -> data_plt -> 长时间闪变
          */
         Map<String, List<DataPltDto>> dataPlt = dataPltAllTime.stream()
                 .filter(x -> phase.contains(x.getPhasicType()))
+                .filter(x -> InfluxDBTableConstant.MAX.equalsIgnoreCase(x.getValueType()))
                 .collect(Collectors.groupingBy(DataPltDto::getLineId));
 
         for (String item : list) {