长时间闪变新增最大值限值判断

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) {