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

influxDB测试代码

Browse Source
This commit is contained in:
xuyang
2023-04-27 16:34:40 +08:00
parent 1f2d333924
commit 1c0173a15b
4 changed files with 258 additions and 200 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
pqs-prepare/prepare-api/src/main/java/com/njcn/prepare/harmonic/pojo/influxdb/po/DataVPO.java
View File

@@ -1,5 +1,7 @@
package com.njcn.prepare.harmonic.pojo.influxdb.po; package com.njcn.prepare.harmonic.pojo.influxdb.po;
import com.fasterxml.jackson.databind.annotation.JsonSerialize;
import com.njcn.common.utils.serializer.InstantDateSerializer;
import lombok.Data; import lombok.Data;
import org.influxdb.annotation.Column; import org.influxdb.annotation.Column;
import org.influxdb.annotation.Measurement; import org.influxdb.annotation.Measurement;
@@ -11,6 +13,7 @@ import java.time.Instant;
public class DataVPO { public class DataVPO {
@Column(name = "time") @Column(name = "time")
@JsonSerialize(using = InstantDateSerializer.class)
private Instant time; private Instant time;
@Column(name = "freq") @Column(name = "freq")

1
pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/controller/line/DistortionRateController.java
View File

@@ -44,6 +44,7 @@ public class DistortionRateController extends BaseController {
@PostMapping("/distortionRate") @PostMapping("/distortionRate")
@ApiOperation("谐波畸变率排名_mysql") @ApiOperation("谐波畸变率排名_mysql")
@ApiImplicitParam(name = "lineParam", value = "参数", required = true) @ApiImplicitParam(name = "lineParam", value = "参数", required = true)
@Deprecated
public HttpResult<String> distortionRate(@RequestBody @Validated LineParam lineParam){ public HttpResult<String> distortionRate(@RequestBody @Validated LineParam lineParam){
String methodDescribe = getMethodDescribe("distortionRate"); String methodDescribe = getMethodDescribe("distortionRate");
distortionRateService.distortionRate(lineParam); distortionRateService.distortionRate(lineParam);

22
pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/InfluxTestMapper.java Normal file
View File

@@ -0,0 +1,22 @@
package com.njcn.prepare.harmonic.mapper;
import com.njcn.harmonic.pojo.po.RStatDataVD;
import com.njcn.influx.base.InfluxDbBaseMapper;
import com.njcn.influx.query.InfluxQueryWrapper;
import com.njcn.prepare.harmonic.pojo.influxdb.po.DataVPO;
import java.util.List;
/**
* <p>
* Mapper 接口
* </p>
*
* @author lxp
* @since 2023-03-16
*/
public interface InfluxTestMapper extends InfluxDbBaseMapper<DataVPO> {
List<RStatDataVD> selectData(InfluxQueryWrapper influxQueryWrapper);
}

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

@@ -2,9 +2,11 @@ package com.njcn.prepare.harmonic.service.mysql.Impl.line;
import com.njcn.harmonic.pojo.po.*; import com.njcn.harmonic.pojo.po.*;
import com.njcn.harmonic.pojo.po.day.*; import com.njcn.harmonic.pojo.po.day.*;
import com.njcn.influx.query.InfluxQueryWrapper;
import com.njcn.influxdb.param.InfluxDBPublicParam; import com.njcn.influxdb.param.InfluxDBPublicParam;
import com.njcn.influxdb.utils.InfluxDbUtils; import com.njcn.influxdb.utils.InfluxDbUtils;
import com.njcn.prepare.harmonic.constant.InfluxdbPOConverter; import com.njcn.prepare.harmonic.constant.InfluxdbPOConverter;
import com.njcn.prepare.harmonic.mapper.InfluxTestMapper;
import com.njcn.prepare.harmonic.pojo.influxdb.po.*; import com.njcn.prepare.harmonic.pojo.influxdb.po.*;
import com.njcn.prepare.harmonic.pojo.mysql.po.line.RMpFlickerReportDPO; import com.njcn.prepare.harmonic.pojo.mysql.po.line.RMpFlickerReportDPO;
import com.njcn.prepare.harmonic.pojo.mysql.po.line.RMpHarmonicPReportDPO; import com.njcn.prepare.harmonic.pojo.mysql.po.line.RMpHarmonicPReportDPO;
@@ -27,6 +29,7 @@ import org.springframework.stereotype.Component;
import org.springframework.transaction.annotation.Transactional; import org.springframework.transaction.annotation.Transactional;
import org.springframework.util.CollectionUtils; import org.springframework.util.CollectionUtils;
import java.beans.PropertyDescriptor;
import java.text.ParseException; import java.text.ParseException;
import java.text.SimpleDateFormat; import java.text.SimpleDateFormat;
import java.time.Instant; import java.time.Instant;
@@ -563,211 +566,240 @@ public class DayDataServiceImpl implements DayDataService {
List<RStatDataInharmVDPO> dataInHarmVPOList = new ArrayList<> (); List<RStatDataInharmVDPO> dataInHarmVPOList = new ArrayList<> ();
List<RStatDataPltDPO> dataPltPOList = new ArrayList<> (); List<RStatDataPltDPO> dataPltPOList = new ArrayList<> ();
List<DataVPO> dataV = getDataV("f3e221c3a75c140b348b1fdb619541f3", "2023-04-26 00:00:00", "2023-04-26 23:59:59");
System.out.println("dataV==:" + dataV);
List<RStatDataVD> list = test("f3e221c3a75c140b348b1fdb619541f3", "2023-04-26 00:00:00", "2023-04-26 23:59:59");
System.out.println("list==:" + list);
for (String lineIndex : indexLists) { for (String lineIndex : indexLists) {
/*生成dayV表*/ // /*生成dayV表*/
List<DataVPO> dataV = getDataV(lineIndex, startTime, endTime); // List<DataVPO> dataV = getDataV(lineIndex, startTime, endTime);
if (!CollectionUtils.isEmpty(dataV)) { // System.out.println("dataV==:" + dataV);
for (DataVPO item : dataV) { // List<RStatDataVD> list = test(lineIndex,startTime,endTime);
RStatDataVDPO po1 = new RStatDataVDPO(); // System.out.println("list==:" + list);
BeanUtils.copyProperties(item,po1);
po1.setTime(time); // if (!CollectionUtils.isEmpty(dataV)) {
po1.setQualityFlag(Integer.parseInt(item.getQualityFlag())); // for (DataVPO item : dataV) {
dataVPOList.add(po1); // RStatDataVDPO po1 = new RStatDataVDPO();
} // BeanUtils.copyProperties(item,po1);
} // po1.setTime(time);
/*生成dayI表*/ // po1.setQualityFlag(Integer.parseInt(item.getQualityFlag()));
List<DataIPO> dataI = getDataI(lineIndex, startTime, endTime); // dataVPOList.add(po1);
if (!CollectionUtils.isEmpty(dataI)) { // }
for (DataIPO item : dataI) { // }
RStatDataIDPO po1 = new RStatDataIDPO(); // /*生成dayI表*/
BeanUtils.copyProperties(item,po1); // List<DataIPO> dataI = getDataI(lineIndex, startTime, endTime);
po1.setTime(time); // if (!CollectionUtils.isEmpty(dataI)) {
po1.setQualityFlag(Integer.parseInt(item.getQualityFlag())); // for (DataIPO item : dataI) {
dataIPOList.add(po1); // RStatDataIDPO po1 = new RStatDataIDPO();
} // BeanUtils.copyProperties(item,po1);
} // po1.setTime(time);
/*生成dayFlicker表*/ // po1.setQualityFlag(Integer.parseInt(item.getQualityFlag()));
List<DataFlickerPO> dataFlickerPO = getDataFlicker(lineIndex, startTime, endTime); // dataIPOList.add(po1);
if (!CollectionUtils.isEmpty(dataFlickerPO)) { // }
for (DataFlickerPO item : dataFlickerPO) { // }
RStatDataFlickerDPO po1 = new RStatDataFlickerDPO(); // /*生成dayFlicker表*/
BeanUtils.copyProperties(item,po1); // List<DataFlickerPO> dataFlickerPO = getDataFlicker(lineIndex, startTime, endTime);
po1.setTime(time); // if (!CollectionUtils.isEmpty(dataFlickerPO)) {
po1.setQualityFlag(Integer.parseInt(item.getQualityFlag())); // for (DataFlickerPO item : dataFlickerPO) {
dataFlickerPOList.add(po1); // RStatDataFlickerDPO po1 = new RStatDataFlickerDPO();
} // BeanUtils.copyProperties(item,po1);
} // po1.setTime(time);
/*生成dayFluc表*/ // po1.setQualityFlag(Integer.parseInt(item.getQualityFlag()));
List<DataFlucPO> dataFlucPO = getDataFluc(lineIndex, startTime, endTime); // dataFlickerPOList.add(po1);
if (!CollectionUtils.isEmpty(dataFlucPO)) { // }
for (DataFlucPO item : dataFlucPO) { // }
RStatDataFlucDPO po1 = new RStatDataFlucDPO(); // /*生成dayFluc表*/
BeanUtils.copyProperties(item,po1); // List<DataFlucPO> dataFlucPO = getDataFluc(lineIndex, startTime, endTime);
po1.setTime(time); // if (!CollectionUtils.isEmpty(dataFlucPO)) {
po1.setQualityFlag(Integer.parseInt(item.getQualityFlag())); // for (DataFlucPO item : dataFlucPO) {
dataFlucPOList.add(po1); // RStatDataFlucDPO po1 = new RStatDataFlucDPO();
} // BeanUtils.copyProperties(item,po1);
} // po1.setTime(time);
/*生成dayHarmphasicI表*/ // po1.setQualityFlag(Integer.parseInt(item.getQualityFlag()));
List<DataHarmPhasicIPO> dataHarmphasicIPO = getDataHarmphasicI(lineIndex, startTime, endTime); // dataFlucPOList.add(po1);
if (!CollectionUtils.isEmpty(dataHarmphasicIPO)) { // }
for (DataHarmPhasicIPO item : dataHarmphasicIPO) { // }
RStatDataHarmphasicIDPO po1 = new RStatDataHarmphasicIDPO(); // /*生成dayHarmphasicI表*/
BeanUtils.copyProperties(item,po1); // List<DataHarmPhasicIPO> dataHarmphasicIPO = getDataHarmphasicI(lineIndex, startTime, endTime);
po1.setTime(time); // if (!CollectionUtils.isEmpty(dataHarmphasicIPO)) {
po1.setQualityFlag(Integer.parseInt(item.getQualityFlag())); // for (DataHarmPhasicIPO item : dataHarmphasicIPO) {
dataHarmPhasicIPOList.add(po1); // RStatDataHarmphasicIDPO po1 = new RStatDataHarmphasicIDPO();
} // BeanUtils.copyProperties(item,po1);
} // po1.setTime(time);
/*生成dayHarmphasicV表*/ // po1.setQualityFlag(Integer.parseInt(item.getQualityFlag()));
List<DataHarmPhasicVPO> dataHarmphasicVPO = getDataHarmphasicV(lineIndex, startTime, endTime); // dataHarmPhasicIPOList.add(po1);
if (!CollectionUtils.isEmpty(dataHarmphasicVPO)) { // }
for (DataHarmPhasicVPO item : dataHarmphasicVPO) { // }
RStatDataHarmphasicVDPO po1 = new RStatDataHarmphasicVDPO(); // /*生成dayHarmphasicV表*/
BeanUtils.copyProperties(item,po1); // List<DataHarmPhasicVPO> dataHarmphasicVPO = getDataHarmphasicV(lineIndex, startTime, endTime);
po1.setTime(time); // if (!CollectionUtils.isEmpty(dataHarmphasicVPO)) {
po1.setQualityFlag(Integer.parseInt(item.getQualityFlag())); // for (DataHarmPhasicVPO item : dataHarmphasicVPO) {
dataHarmPhasicVPOList.add(po1); // RStatDataHarmphasicVDPO po1 = new RStatDataHarmphasicVDPO();
} // BeanUtils.copyProperties(item,po1);
} // po1.setTime(time);
/*生成dayHarmPowerP表*/ // po1.setQualityFlag(Integer.parseInt(item.getQualityFlag()));
List<DataHarmPowerPPO> dataHarmPowerPPO = getDataHarmPowerP(lineIndex, startTime, endTime); // dataHarmPhasicVPOList.add(po1);
if (!CollectionUtils.isEmpty(dataHarmPowerPPO)) { // }
for (DataHarmPowerPPO item : dataHarmPowerPPO) { // }
RStatDataHarmpowerPDPO po1 = new RStatDataHarmpowerPDPO(); // /*生成dayHarmPowerP表*/
BeanUtils.copyProperties(item,po1); // List<DataHarmPowerPPO> dataHarmPowerPPO = getDataHarmPowerP(lineIndex, startTime, endTime);
po1.setTime(time); // if (!CollectionUtils.isEmpty(dataHarmPowerPPO)) {
po1.setQualityFlag(Integer.parseInt(item.getQualityFlag())); // for (DataHarmPowerPPO item : dataHarmPowerPPO) {
dataHarmPowerPPOList.add(po1); // RStatDataHarmpowerPDPO po1 = new RStatDataHarmpowerPDPO();
} // BeanUtils.copyProperties(item,po1);
} // po1.setTime(time);
/*生成dayHarmPowerQ表*/ // po1.setQualityFlag(Integer.parseInt(item.getQualityFlag()));
List<DataHarmPowerQPO> dataHarmPowerQPO = getDataHarmPowerQ(lineIndex, startTime, endTime); // dataHarmPowerPPOList.add(po1);
if (!CollectionUtils.isEmpty(dataHarmPowerQPO)) { // }
for (DataHarmPowerQPO item : dataHarmPowerQPO) { // }
RStatDataHarmpowerQDPO po1 = new RStatDataHarmpowerQDPO(); // /*生成dayHarmPowerQ表*/
BeanUtils.copyProperties(item,po1); // List<DataHarmPowerQPO> dataHarmPowerQPO = getDataHarmPowerQ(lineIndex, startTime, endTime);
po1.setTime(time); // if (!CollectionUtils.isEmpty(dataHarmPowerQPO)) {
po1.setQualityFlag(Integer.parseInt(item.getQualityFlag())); // for (DataHarmPowerQPO item : dataHarmPowerQPO) {
dataHarmPowerQPOList.add(po1); // RStatDataHarmpowerQDPO po1 = new RStatDataHarmpowerQDPO();
} // BeanUtils.copyProperties(item,po1);
} // po1.setTime(time);
/*生成dayHarmPowerS表*/ // po1.setQualityFlag(Integer.parseInt(item.getQualityFlag()));
List<DataHarmPowerSPO> dataHarmPowers = getDataHarmPowerS(lineIndex, startTime, endTime); // dataHarmPowerQPOList.add(po1);
if (!CollectionUtils.isEmpty(dataHarmPowers)) { // }
for (DataHarmPowerSPO item : dataHarmPowers) { // }
RStatDataHarmpowerSDPO po1 = new RStatDataHarmpowerSDPO(); // /*生成dayHarmPowerS表*/
BeanUtils.copyProperties(item,po1); // List<DataHarmPowerSPO> dataHarmPowers = getDataHarmPowerS(lineIndex, startTime, endTime);
po1.setTime(time); // if (!CollectionUtils.isEmpty(dataHarmPowers)) {
po1.setQualityFlag(Integer.parseInt(item.getQualityFlag())); // for (DataHarmPowerSPO item : dataHarmPowers) {
dataHarmPowerSPOList.add(po1); // RStatDataHarmpowerSDPO po1 = new RStatDataHarmpowerSDPO();
} // BeanUtils.copyProperties(item,po1);
} // po1.setTime(time);
/*生成dayHarmRateI*/ // po1.setQualityFlag(Integer.parseInt(item.getQualityFlag()));
List<DataHarmRateIPO> dataHarmRateI = getDataHarmRateI(lineIndex, startTime, endTime); // dataHarmPowerSPOList.add(po1);
if (!CollectionUtils.isEmpty(dataHarmRateI)) { // }
for (DataHarmRateIPO item : dataHarmRateI) { // }
RStatDataHarmrateIDPO po1 = new RStatDataHarmrateIDPO(); // /*生成dayHarmRateI*/
BeanUtils.copyProperties(item,po1); // List<DataHarmRateIPO> dataHarmRateI = getDataHarmRateI(lineIndex, startTime, endTime);
po1.setTime(time); // if (!CollectionUtils.isEmpty(dataHarmRateI)) {
po1.setQualityFlag(Integer.parseInt(item.getQualityFlag())); // for (DataHarmRateIPO item : dataHarmRateI) {
dataHarmRateIPOList.add(po1); // RStatDataHarmrateIDPO po1 = new RStatDataHarmrateIDPO();
} // BeanUtils.copyProperties(item,po1);
} // po1.setTime(time);
/*生成dayHarmRateV*/ // po1.setQualityFlag(Integer.parseInt(item.getQualityFlag()));
List<DataHarmRateVPO> dataHarmRateVPO = getDataHarmRateV(lineIndex, startTime, endTime); // dataHarmRateIPOList.add(po1);
if (!CollectionUtils.isEmpty(dataHarmRateVPO)) { // }
for (DataHarmRateVPO item : dataHarmRateVPO) { // }
RStatDataHarmrateVDPO po1 = new RStatDataHarmrateVDPO(); // /*生成dayHarmRateV*/
BeanUtils.copyProperties(item,po1); // List<DataHarmRateVPO> dataHarmRateVPO = getDataHarmRateV(lineIndex, startTime, endTime);
po1.setTime(time); // if (!CollectionUtils.isEmpty(dataHarmRateVPO)) {
po1.setQualityFlag(Integer.parseInt(item.getQualityFlag())); // for (DataHarmRateVPO item : dataHarmRateVPO) {
dataHarmRateVPOList.add(po1); // RStatDataHarmrateVDPO po1 = new RStatDataHarmrateVDPO();
} // BeanUtils.copyProperties(item,po1);
} // po1.setTime(time);
/*生成dayInHarmI*/ // po1.setQualityFlag(Integer.parseInt(item.getQualityFlag()));
List<DataInHarmIPO> dataInHarmIPO = getDataInHarmI(lineIndex, startTime, endTime); // dataHarmRateVPOList.add(po1);
if (!CollectionUtils.isEmpty(dataInHarmIPO)) { // }
for (DataInHarmIPO item : dataInHarmIPO) { // }
RStatDataInharmIDPO po1 = new RStatDataInharmIDPO(); // /*生成dayInHarmI*/
BeanUtils.copyProperties(item,po1); // List<DataInHarmIPO> dataInHarmIPO = getDataInHarmI(lineIndex, startTime, endTime);
po1.setTime(time); // if (!CollectionUtils.isEmpty(dataInHarmIPO)) {
po1.setQualityFlag(Integer.parseInt(item.getQualityFlag())); // for (DataInHarmIPO item : dataInHarmIPO) {
dataInHarmIPOList.add(po1); // RStatDataInharmIDPO po1 = new RStatDataInharmIDPO();
} // BeanUtils.copyProperties(item,po1);
} // po1.setTime(time);
/*生成dayInHarmV*/ // po1.setQualityFlag(Integer.parseInt(item.getQualityFlag()));
List<DataInHarmVPO> dataInHarmVPO = getDataInHarmV(lineIndex, startTime, endTime); // dataInHarmIPOList.add(po1);
if (!CollectionUtils.isEmpty(dataInHarmVPO)) { // }
for (DataInHarmVPO item : dataInHarmVPO) { // }
RStatDataInharmVDPO po1 = new RStatDataInharmVDPO(); // /*生成dayInHarmV*/
BeanUtils.copyProperties(item,po1); // List<DataInHarmVPO> dataInHarmVPO = getDataInHarmV(lineIndex, startTime, endTime);
po1.setTime(time); // if (!CollectionUtils.isEmpty(dataInHarmVPO)) {
po1.setQualityFlag(Integer.parseInt(item.getQualityFlag())); // for (DataInHarmVPO item : dataInHarmVPO) {
dataInHarmVPOList.add(po1); // RStatDataInharmVDPO po1 = new RStatDataInharmVDPO();
} // BeanUtils.copyProperties(item,po1);
} // po1.setTime(time);
/*生成dayPlt*/ // po1.setQualityFlag(Integer.parseInt(item.getQualityFlag()));
List<DataPltPO> dataPlt = getDataPlt(lineIndex, startTime, endTime); // dataInHarmVPOList.add(po1);
if (!CollectionUtils.isEmpty(dataPlt)) { // }
for (DataPltPO item : dataPlt) { // }
RStatDataPltDPO po1 = new RStatDataPltDPO(); // /*生成dayPlt*/
BeanUtils.copyProperties(item,po1); // List<DataPltPO> dataPlt = getDataPlt(lineIndex, startTime, endTime);
po1.setTime(time); // if (!CollectionUtils.isEmpty(dataPlt)) {
po1.setQualityFlag(Integer.parseInt(item.getQualityFlag())); // for (DataPltPO item : dataPlt) {
dataPltPOList.add(po1); // RStatDataPltDPO po1 = new RStatDataPltDPO();
} // BeanUtils.copyProperties(item,po1);
} // po1.setTime(time);
// po1.setQualityFlag(Integer.parseInt(item.getQualityFlag()));
// dataPltPOList.add(po1);
// }
// }
} }
if (!CollectionUtils.isEmpty(dataVPOList)){ // if (!CollectionUtils.isEmpty(dataVPOList)){
statDataVDService.insert(dataVPOList); // statDataVDService.insert(dataVPOList);
} // }
if (!CollectionUtils.isEmpty(dataIPOList)){ // if (!CollectionUtils.isEmpty(dataIPOList)){
statDataIDService.insert(dataIPOList); // statDataIDService.insert(dataIPOList);
} // }
if (!CollectionUtils.isEmpty(dataFlickerPOList)){ // if (!CollectionUtils.isEmpty(dataFlickerPOList)){
statDataFlickerDService.insert(dataFlickerPOList); // statDataFlickerDService.insert(dataFlickerPOList);
} // }
if (!CollectionUtils.isEmpty(dataFlucPOList)){ // if (!CollectionUtils.isEmpty(dataFlucPOList)){
statDataFlucDService.insert(dataFlucPOList); // statDataFlucDService.insert(dataFlucPOList);
} // }
if (!CollectionUtils.isEmpty(dataHarmPhasicIPOList)){ // if (!CollectionUtils.isEmpty(dataHarmPhasicIPOList)){
statDataHarmphasicIDService.insert(dataHarmPhasicIPOList); // statDataHarmphasicIDService.insert(dataHarmPhasicIPOList);
} // }
if (!CollectionUtils.isEmpty(dataHarmPhasicVPOList)){ // if (!CollectionUtils.isEmpty(dataHarmPhasicVPOList)){
statDataHarmphasicVDService.insert(dataHarmPhasicVPOList); // statDataHarmphasicVDService.insert(dataHarmPhasicVPOList);
} // }
if (!CollectionUtils.isEmpty(dataHarmPowerPPOList)){ // if (!CollectionUtils.isEmpty(dataHarmPowerPPOList)){
statDataHarmpowerPDService.insert(dataHarmPowerPPOList); // statDataHarmpowerPDService.insert(dataHarmPowerPPOList);
} // }
if (!CollectionUtils.isEmpty(dataHarmPowerQPOList)){ // if (!CollectionUtils.isEmpty(dataHarmPowerQPOList)){
statDataHarmpowerQDService.insert(dataHarmPowerQPOList); // statDataHarmpowerQDService.insert(dataHarmPowerQPOList);
} // }
if (!CollectionUtils.isEmpty(dataHarmPowerSPOList)){ // if (!CollectionUtils.isEmpty(dataHarmPowerSPOList)){
statDataHarmpowerSDService.insert(dataHarmPowerSPOList); // statDataHarmpowerSDService.insert(dataHarmPowerSPOList);
} // }
if (!CollectionUtils.isEmpty(dataHarmRateIPOList)){ // if (!CollectionUtils.isEmpty(dataHarmRateIPOList)){
statDataHarmRateIDService.insert(dataHarmRateIPOList); // statDataHarmRateIDService.insert(dataHarmRateIPOList);
} // }
if (!CollectionUtils.isEmpty(dataHarmRateVPOList)){ // if (!CollectionUtils.isEmpty(dataHarmRateVPOList)){
statDataHarmRateVDService.insert(dataHarmRateVPOList); // statDataHarmRateVDService.insert(dataHarmRateVPOList);
} // }
if (!CollectionUtils.isEmpty(dataInHarmIPOList)){ // if (!CollectionUtils.isEmpty(dataInHarmIPOList)){
statDataInharmIDService.insert(dataInHarmIPOList); // statDataInharmIDService.insert(dataInHarmIPOList);
} // }
if (!CollectionUtils.isEmpty(dataInHarmVPOList)){ // if (!CollectionUtils.isEmpty(dataInHarmVPOList)){
statDataInharmVDService.insert(dataInHarmVPOList); // statDataInharmVDService.insert(dataInHarmVPOList);
} // }
if (!CollectionUtils.isEmpty(dataPltPOList)){ // if (!CollectionUtils.isEmpty(dataPltPOList)){
statDataPltDService.insert(dataPltPOList); // statDataPltDService.insert(dataPltPOList);
} // }
log.info(LocalDateTime.now()+"data表转day结束=====》"); log.info(LocalDateTime.now()+"data表转day结束=====》");
} }
private final InfluxTestMapper mapper;
public List<RStatDataVD> test(String lineId,String startTime, String endTime) {
InfluxQueryWrapper influxQueryWrapper = new InfluxQueryWrapper(DataVPO.class, RStatDataVD.class);
influxQueryWrapper.max(DataVPO::getFreq);
influxQueryWrapper.eq(DataVPO::getLineId,lineId);
influxQueryWrapper.between(DataVPO::getTime,startTime,endTime);
List<RStatDataVD> list = mapper.selectData(influxQueryWrapper);
return list;
}
/** /**
* 功能描述:获取dataV数据 * 功能描述:获取dataV数据
* @author xy * @author xy
@@ -3837,10 +3869,10 @@ public class DayDataServiceImpl implements DayDataService {
*/ */
public String[] getNullPropertyNames (Object source) { public String[] getNullPropertyNames (Object source) {
final BeanWrapper src = new BeanWrapperImpl (source); final BeanWrapper src = new BeanWrapperImpl (source);
java.beans.PropertyDescriptor[] pds = src.getPropertyDescriptors ( ); PropertyDescriptor[] pds = src.getPropertyDescriptors ( );
Set<String> emptyNames = new HashSet<String> ( ); Set<String> emptyNames = new HashSet<String> ( );
for (java.beans.PropertyDescriptor pd : pds) { for (PropertyDescriptor pd : pds) {
Object srcValue = src.getPropertyValue (pd.getName ( )); Object srcValue = src.getPropertyValue (pd.getName ( ));
if (srcValue == null){ if (srcValue == null){
emptyNames.add (pd.getName ( )); emptyNames.add (pd.getName ( ));