Middleware/cn-data-platform
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

1.污染值算法微调

Browse Source
This commit is contained in:
wr
2025-07-31 16:57:29 +08:00
parent 6559aff5d8
commit 660b4d49c0
1 changed files with 7 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/influxdb/InfluxdbDataIImpl.java
View File

@@ -206,14 +206,14 @@ public class InfluxdbDataIImpl extends MppServiceImpl<RStatDataIRelationMapper,
@Override
public List<DataIDto> getGroupByTimeDataI(LineCountEvaluateParam lineParam) {
InfluxQueryWrapper harmRateVQueryWrapper = new InfluxQueryWrapper(DataHarmrateV.class);
harmRateVQueryWrapper.maxSamePrefixAndSuffix(InfluxDbSqlConstant.I, "", HarmonicTimesUtil.harmonicTimesList(2, 50, 1));
harmRateVQueryWrapper.regular(DataV::getLineId, lineParam.getLineId())
.eq(DataHarmrateV::getValueType, InfluxDbSqlConstant.CP95)
.ne(DataHarmrateV::getPhasicType, InfluxDBTableConstant.PHASE_TYPE_T)
InfluxQueryWrapper influxQueryWrapper = new InfluxQueryWrapper(DataI.class);
influxQueryWrapper.maxSamePrefixAndSuffix(InfluxDbSqlConstant.I, "", HarmonicTimesUtil.harmonicTimesList(2, 50, 1));
influxQueryWrapper.regular(DataI::getLineId, lineParam.getLineId())
.eq(DataI::getValueType, InfluxDbSqlConstant.CP95)
.ne(DataI::getPhasicType, InfluxDBTableConstant.PHASE_TYPE_T)
.groupBy("time(" + lineParam.getValueType().get(0) + "m)")
.between(DataHarmrateV::getTime, lineParam.getStartTime(), lineParam.getEndTime());
List<DataI> list = dataIMapper.selectByQueryWrapper(harmRateVQueryWrapper);
.between(DataI::getTime, lineParam.getStartTime(), lineParam.getEndTime());
List<DataI> list = dataIMapper.selectByQueryWrapper(influxQueryWrapper);
List<DataIDto> result = new ArrayList<>();
list.forEach(item -> {
DataIDto dto = new DataIDto();