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

河北超高压算法测试

Browse Source
This commit is contained in:
xuyang
2024-01-18 17:23:16 +08:00
parent 5b0f6a73ed
commit e33c78a040
1 changed files with 5 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -151,6 +151,7 @@ public class DayDataServiceImpl implements DayDataService {
for (List<String> pendingId : pendingIds) {
//获取dataV数据
List<DataV> vList = getDataV(pendingId,beginDay,endDay);
log.info("mysql入库数据：" + vList);
list1.addAll(vList);
//获取dataI数据
//List<DataI> iList = getDataI(pendingId,beginDay,endDay);
@@ -464,6 +465,7 @@ public class DayDataServiceImpl implements DayDataService {
.groupBy(DataV::getLineId,DataV::getPhasicType,DataV::getQualityFlag,DataV::getValueType)
.between(DataV::getTime, startTime, endTime);
List<DataV> result1 = dataVMapper.getStatisticsByWraper(influxQueryWrapper);
log.info("最小值数据：" + result1);
result.addAll(result1);
//最大值
InfluxQueryWrapper influxQueryWrapper2 = new InfluxQueryWrapper(DataV.class);
@@ -484,6 +486,7 @@ public class DayDataServiceImpl implements DayDataService {
.groupBy(DataV::getLineId,DataV::getPhasicType,DataV::getQualityFlag,DataV::getValueType)
.between(DataV::getTime, startTime, endTime);
List<DataV> result2 = dataVMapper.getStatisticsByWraper(influxQueryWrapper2);
log.info("最大值数据：" + result2);
result.addAll(result2);
//平均值
InfluxQueryWrapper influxQueryWrapper3 = new InfluxQueryWrapper(DataV.class);
@@ -504,6 +507,7 @@ public class DayDataServiceImpl implements DayDataService {
.groupBy(DataV::getLineId,DataV::getPhasicType,DataV::getQualityFlag,DataV::getValueType)
.between(DataV::getTime, startTime, endTime);
List<DataV> result3 = dataVMapper.getStatisticsByWraper(influxQueryWrapper3);
log.info("平均值数据：" + result3);
result.addAll(result3);
//CP95(取平均值的CP95值)
InfluxQueryWrapper influxQueryWrapper4 = new InfluxQueryWrapper(DataV.class);
@@ -524,6 +528,7 @@ public class DayDataServiceImpl implements DayDataService {
.groupBy(DataV::getLineId,DataV::getPhasicType,DataV::getQualityFlag,DataV::getValueType)
.between(DataV::getTime, startTime, endTime);
List<DataV> result4 = dataVMapper.getStatisticsByWraper(influxQueryWrapper4);
log.info("CP95值数据：" + result4);
result4.forEach(item->{
item.setValueType(InfluxDbSqlConstant.CP95);
});