Microservice/pqs
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 1 Wiki Activity

bug调整

Browse Source
This commit is contained in:
xuyang
2023-03-28 14:37:13 +08:00
parent 4f5c0a4a94
commit aa400d6a8d
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/line/IntegrityServiceImpl.java
View File

@@ -105,7 +105,7 @@ public class IntegrityServiceImpl extends MppServiceImpl<RStatIntegrityDMapper,
} }
private int getDataCount(String lineId,String date){ 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(); InfluxDBResultMapper resultMapper = new InfluxDBResultMapper();
List<DataVPO> list = resultMapper.toPOJO(sqlResult, DataVPO.class); List<DataVPO> list = resultMapper.toPOJO(sqlResult, DataVPO.class);
if (CollectionUtils.isEmpty(list)){ if (CollectionUtils.isEmpty(list)){