From aa400d6a8db98bb2d30aeb01e2ec2162b48ee07a Mon Sep 17 00:00:00 2001
From: xuyang <748613696@qq.com>
Date: Tue, 28 Mar 2023 14:37:13 +0800
Subject: [PATCH] =?UTF-8?q?bug=E8=B0=83=E6=95=B4?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../harmonic/service/mysql/Impl/line/IntegrityServiceImpl.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/line/IntegrityServiceImpl.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/line/IntegrityServiceImpl.java
index 0f853e060..ea24eb277 100644
--- a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/line/IntegrityServiceImpl.java
+++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/line/IntegrityServiceImpl.java
@@ -105,7 +105,7 @@ public class IntegrityServiceImpl extends MppServiceImpl<RStatIntegrityDMapper,
     }
 
     private int getDataCount(String lineId,String date){
-        QueryResult sqlResult = influxDbUtils.query("SELECT * FROM data_v WHERE time >= '" + date + " 00:00:00' and time <= '" + date + " 23:59:59' and line_id = '" + lineId + "' and phasic_type = 'T' tz('Asia/Shanghai')");
+        QueryResult sqlResult = influxDbUtils.query("SELECT * FROM data_v WHERE time >= '" + date + " 00:00:00' and time <= '" + date + " 23:59:59' and line_id = '" + lineId + "' and phasic_type = 'T' and value_type = 'MAX' tz('Asia/Shanghai')");
         InfluxDBResultMapper resultMapper = new InfluxDBResultMapper();
         List<DataVPO> list = resultMapper.toPOJO(sqlResult, DataVPO.class);
         if (CollectionUtils.isEmpty(list)){