89 lines
3.2 KiB
Java
89 lines
3.2 KiB
Java
package com.njcn.influx.service.impl;
|
|
|
|
import com.njcn.influx.imapper.DataVMapper;
|
|
import com.njcn.influx.pojo.po.DataV;
|
|
import com.njcn.influx.query.InfluxQueryWrapper;
|
|
import com.njcn.influx.service.IDataVService;
|
|
import org.springframework.stereotype.Service;
|
|
|
|
import javax.annotation.Resource;
|
|
import java.util.ArrayList;
|
|
import java.util.List;
|
|
|
|
/**
|
|
* 类的介绍：
|
|
*
|
|
* @author xuyang
|
|
* @version 1.0.0
|
|
* @createTime 2023/5/5 14:38
|
|
*/
|
|
@Service
|
|
public class DataVServiceImpl implements IDataVService {
|
|
|
|
@Resource
|
|
private DataVMapper dataVMapper;
|
|
|
|
@Override
|
|
public List<DataV> getDataV(String lineIndex, String startTime, String endTime) {
|
|
//最小值
|
|
List<DataV> result1 ;
|
|
InfluxQueryWrapper influxQueryWrapper = new InfluxQueryWrapper(DataV.class);
|
|
influxQueryWrapper.minSamePrefixAndSuffix("v_","", this.harmonicTimesList(1,50,1));
|
|
influxQueryWrapper.eq(DataV::getLineId, lineIndex)
|
|
.eq(DataV::getValueType, "MIN")
|
|
.min(DataV::getFreq)
|
|
.min(DataV::getFreqDev)
|
|
.min(DataV::getRms)
|
|
.min(DataV::getRmsLvr)
|
|
.min(DataV::getVNeg)
|
|
.min(DataV::getVPos)
|
|
.min(DataV::getVThd)
|
|
.min(DataV::getVUnbalance)
|
|
.min(DataV::getVZero)
|
|
.min(DataV::getVlDev)
|
|
.min(DataV::getVuDev)
|
|
.groupBy(DataV::getLineId,DataV::getPhaseType,DataV::getQualityFlag,DataV::getValueType)
|
|
.between(DataV::getTime, startTime, endTime);
|
|
result1 = dataVMapper.getStatisticsByWraper(influxQueryWrapper);
|
|
System.out.println("result1==:" + result1);
|
|
return result1;
|
|
}
|
|
|
|
@Override
|
|
public List<DataV> getHarmonicDataV(String lineIndex, String startTime, String endTime) {
|
|
List<DataV> result1 ;
|
|
InfluxQueryWrapper influxQueryWrapper = new InfluxQueryWrapper(DataV.class);
|
|
influxQueryWrapper.eq(DataV::getLineId, lineIndex)
|
|
.eq(DataV::getValueType, "CP95")
|
|
.ne(DataV::getPhaseType, "T")
|
|
.between(DataV::getTime, startTime, endTime);;
|
|
result1 = dataVMapper.getStatisticsByWraper(influxQueryWrapper);
|
|
return result1;
|
|
}
|
|
|
|
@Override
|
|
public List<DataV> getNewDataV(String lineIndex, String startTime, String endTime) {
|
|
InfluxQueryWrapper influxQueryWrapper = new InfluxQueryWrapper(DataV.class);
|
|
influxQueryWrapper.eq(DataV::getLineId, lineIndex)
|
|
.between(DataV::getTime, startTime, endTime);;
|
|
return dataVMapper.getStatisticsByWraper(influxQueryWrapper);
|
|
}
|
|
|
|
|
|
/***
|
|
* 自定义需要查询的谐波次数
|
|
* @author xuyang
|
|
* @param start 起始次数@Min(value = 1) @Max(value = 100)
|
|
* @param end 结束次数 @Min(value = 1) @Max(value = 100)
|
|
* @param interval 间隔
|
|
* @return List<Object>
|
|
*/
|
|
public List<Object> harmonicTimesList(Integer start, Integer end, Integer interval) {
|
|
List<Object> timesList = new ArrayList<>();
|
|
for (int i = start; i <= end;i = i+interval) {
|
|
timesList.add(i);
|
|
}
|
|
return timesList;
|
|
}
|
|
}
|