Middleware/pqs-influx
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

DataHarmPowerPService中新增查询方法getNewHarmonicPowerP

Browse Source
This commit is contained in:
guofeihu
2024-09-03 09:44:01 +08:00
parent d99292fad1
commit d298f2b9fd
2 changed files with 13 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/main/java/com/njcn/influx/service/DataHarmPowerPService.java
View File

@@ -12,4 +12,6 @@ import java.util.List;
*/ */
public interface DataHarmPowerPService { public interface DataHarmPowerPService {
List<DataHarmPowerP> getHarmonicPowerP(String lineIndex, String startTime, String endTime); List<DataHarmPowerP> getHarmonicPowerP(String lineIndex, String startTime, String endTime);
List<DataHarmPowerP> getNewHarmonicPowerP(String lineIndex, String startTime, String endTime, String phaseType, String valueType);
} }

11
src/main/java/com/njcn/influx/service/impl/DataHarmPowerPServiceImpl.java
View File

@@ -29,4 +29,15 @@ public class DataHarmPowerPServiceImpl implements DataHarmPowerPService {
result1 = dataHarmPowerPMapper.getStatisticsByWraper(influxQueryWrapper); result1 = dataHarmPowerPMapper.getStatisticsByWraper(influxQueryWrapper);
return result1; return result1;
} }
@Override
public List<DataHarmPowerP> getNewHarmonicPowerP(String lineIndex, String startTime, String endTime, String phaseType, String valueType) {
InfluxQueryWrapper influxQueryWrapper = new InfluxQueryWrapper(DataHarmPowerP.class);
influxQueryWrapper.between(DataHarmPowerP::getTime, startTime, endTime);
if(lineIndex != null) influxQueryWrapper.eq(DataHarmPowerP::getLineId, lineIndex);
if(phaseType != null) influxQueryWrapper.eq(DataHarmPowerP::getPhaseType, phaseType);
if(valueType != null) influxQueryWrapper.eq(DataHarmPowerP::getValueType, valueType);
List<DataHarmPowerP> result1 = dataHarmPowerPMapper.getStatisticsByWraper(influxQueryWrapper);
return result1;
}
} }