diff --git a/pqs-influx/src/main/java/com/njcn/influx/service/impl/CommonServiceImpl.java b/pqs-influx/src/main/java/com/njcn/influx/service/impl/CommonServiceImpl.java
index 2f3f7402c..820c13222 100644
--- a/pqs-influx/src/main/java/com/njcn/influx/service/impl/CommonServiceImpl.java
+++ b/pqs-influx/src/main/java/com/njcn/influx/service/impl/CommonServiceImpl.java
@@ -11,6 +11,7 @@ import org.springframework.stereotype.Service;
 
 import java.util.HashMap;
 import java.util.List;
+import java.util.Objects;
 
 /**
  * Description:
@@ -28,13 +29,22 @@ public class CommonServiceImpl implements CommonService {
     @Override
     public StatisticalDataDTO getLineRtData(String lineId, String tableName, String columnName, String phasic, String dataType) {
         InfluxQueryWrapper influxQueryWrapper = new InfluxQueryWrapper(tableName,StatisticalDataDTO.class);
-        influxQueryWrapper.select(StatisticalDataDTO::getLineId)
-                          .select(StatisticalDataDTO::getPhaseType)
-                          .select(StatisticalDataDTO::getValueType)
-                          .last(columnName)
-                          .eq(InfluxDBTableConstant.LINE_ID,lineId)
-                          .eq(InfluxDBTableConstant.PHASIC_TYPE,phasic)
-                          .eq(InfluxDBTableConstant.VALUE_TYPE,dataType);
+        if (Objects.equals(dataType,"M")){
+            influxQueryWrapper.select(StatisticalDataDTO::getLineId)
+                    .select(StatisticalDataDTO::getPhaseType)
+                    .select(StatisticalDataDTO::getValueType)
+                    .last(columnName)
+                    .eq(InfluxDBTableConstant.LINE_ID,lineId)
+                    .eq(InfluxDBTableConstant.PHASIC_TYPE,phasic);
+        } else {
+            influxQueryWrapper.select(StatisticalDataDTO::getLineId)
+                    .select(StatisticalDataDTO::getPhaseType)
+                    .select(StatisticalDataDTO::getValueType)
+                    .last(columnName)
+                    .eq(InfluxDBTableConstant.LINE_ID,lineId)
+                    .eq(InfluxDBTableConstant.PHASIC_TYPE,phasic)
+                    .eq(InfluxDBTableConstant.VALUE_TYPE,dataType);
+        }
         return commonMapper.getLineRtData(influxQueryWrapper);
     }