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);
+                        }
                     }
                 }
             }