From 3d59a3d05899bfe864aec97dfb588ff95107778b Mon Sep 17 00:00:00 2001
From: xy <748613696@qq.com>
Date: Thu, 9 Apr 2026 11:22:07 +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/IDataLimitRateAsyncImpl.java      | 10 +++++-----
 1 file changed, 5 insertions(+), 5 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 e87a209..73d0126 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
@@ -647,14 +647,14 @@ public class IDataLimitRateAsyncImpl implements IDataLimitRateAsync {
         if (!CollectionUtils.isEmpty(dataVPOUnbalanceList)) {
             for (DataVDto item : dataVPOUnbalanceList) {
                 if (ObjectUtil.isNotNull(item.getVUnbalance())) {
-                    if (InfluxDBTableConstant.AVG.equalsIgnoreCase(item.getValueType()) || InfluxDBTableConstant.CP95.equalsIgnoreCase(item.getValueType()) ) {
-                        if (item.getVUnbalance() > 2.0) {
-                            addAbnormalData(sx, item.getPhasicType(), "CP95", item.getMinTime(), item.getVUnbalance(), 2.0f);
-                        }
-                    } else {
+                    if (InfluxDBTableConstant.MAX.equalsIgnoreCase(item.getValueType())) {
                         if (item.getVUnbalance() > 4.0) {
                             addAbnormalData(sx, item.getPhasicType(), item.getValueType(), item.getMinTime(), item.getVUnbalance(), 4.0f);
                         }
+                    } else {
+                        if (item.getVUnbalance() > 2.0) {
+                            addAbnormalData(sx, item.getPhasicType(), "CP95", item.getMinTime(), item.getVUnbalance(), 2.0f);
+                        }
                     }
                 }
             }