代码调整
This commit is contained in:
@@ -1,22 +0,0 @@
|
|||||||
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);
|
|
||||||
|
|
||||||
}
|
|
||||||
@@ -2,11 +2,9 @@ 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;
|
||||||
@@ -29,7 +27,6 @@ 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;
|
||||||
@@ -566,240 +563,211 @@ 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);
|
||||||
// System.out.println("dataV==:" + dataV);
|
if (!CollectionUtils.isEmpty(dataV)) {
|
||||||
// List<RStatDataVD> list = test(lineIndex,startTime,endTime);
|
for (DataVPO item : dataV) {
|
||||||
// System.out.println("list==:" + list);
|
RStatDataVDPO po1 = new RStatDataVDPO();
|
||||||
|
BeanUtils.copyProperties(item,po1);
|
||||||
// if (!CollectionUtils.isEmpty(dataV)) {
|
po1.setTime(time);
|
||||||
// for (DataVPO item : dataV) {
|
po1.setQualityFlag(Integer.parseInt(item.getQualityFlag()));
|
||||||
// RStatDataVDPO po1 = new RStatDataVDPO();
|
dataVPOList.add(po1);
|
||||||
// BeanUtils.copyProperties(item,po1);
|
}
|
||||||
// po1.setTime(time);
|
}
|
||||||
// po1.setQualityFlag(Integer.parseInt(item.getQualityFlag()));
|
/*生成dayI表*/
|
||||||
// dataVPOList.add(po1);
|
List<DataIPO> dataI = getDataI(lineIndex, startTime, endTime);
|
||||||
// }
|
if (!CollectionUtils.isEmpty(dataI)) {
|
||||||
// }
|
for (DataIPO item : dataI) {
|
||||||
// /*生成dayI表*/
|
RStatDataIDPO po1 = new RStatDataIDPO();
|
||||||
// List<DataIPO> dataI = getDataI(lineIndex, startTime, endTime);
|
BeanUtils.copyProperties(item,po1);
|
||||||
// if (!CollectionUtils.isEmpty(dataI)) {
|
po1.setTime(time);
|
||||||
// for (DataIPO item : dataI) {
|
po1.setQualityFlag(Integer.parseInt(item.getQualityFlag()));
|
||||||
// RStatDataIDPO po1 = new RStatDataIDPO();
|
dataIPOList.add(po1);
|
||||||
// BeanUtils.copyProperties(item,po1);
|
}
|
||||||
// po1.setTime(time);
|
}
|
||||||
// po1.setQualityFlag(Integer.parseInt(item.getQualityFlag()));
|
/*生成dayFlicker表*/
|
||||||
// dataIPOList.add(po1);
|
List<DataFlickerPO> dataFlickerPO = getDataFlicker(lineIndex, startTime, endTime);
|
||||||
// }
|
if (!CollectionUtils.isEmpty(dataFlickerPO)) {
|
||||||
// }
|
for (DataFlickerPO item : dataFlickerPO) {
|
||||||
// /*生成dayFlicker表*/
|
RStatDataFlickerDPO po1 = new RStatDataFlickerDPO();
|
||||||
// List<DataFlickerPO> dataFlickerPO = getDataFlicker(lineIndex, startTime, endTime);
|
BeanUtils.copyProperties(item,po1);
|
||||||
// if (!CollectionUtils.isEmpty(dataFlickerPO)) {
|
po1.setTime(time);
|
||||||
// for (DataFlickerPO item : dataFlickerPO) {
|
po1.setQualityFlag(Integer.parseInt(item.getQualityFlag()));
|
||||||
// RStatDataFlickerDPO po1 = new RStatDataFlickerDPO();
|
dataFlickerPOList.add(po1);
|
||||||
// BeanUtils.copyProperties(item,po1);
|
}
|
||||||
// po1.setTime(time);
|
}
|
||||||
// po1.setQualityFlag(Integer.parseInt(item.getQualityFlag()));
|
/*生成dayFluc表*/
|
||||||
// dataFlickerPOList.add(po1);
|
List<DataFlucPO> dataFlucPO = getDataFluc(lineIndex, startTime, endTime);
|
||||||
// }
|
if (!CollectionUtils.isEmpty(dataFlucPO)) {
|
||||||
// }
|
for (DataFlucPO item : dataFlucPO) {
|
||||||
// /*生成dayFluc表*/
|
RStatDataFlucDPO po1 = new RStatDataFlucDPO();
|
||||||
// List<DataFlucPO> dataFlucPO = getDataFluc(lineIndex, startTime, endTime);
|
BeanUtils.copyProperties(item,po1);
|
||||||
// if (!CollectionUtils.isEmpty(dataFlucPO)) {
|
po1.setTime(time);
|
||||||
// for (DataFlucPO item : dataFlucPO) {
|
po1.setQualityFlag(Integer.parseInt(item.getQualityFlag()));
|
||||||
// RStatDataFlucDPO po1 = new RStatDataFlucDPO();
|
dataFlucPOList.add(po1);
|
||||||
// BeanUtils.copyProperties(item,po1);
|
}
|
||||||
// po1.setTime(time);
|
}
|
||||||
// po1.setQualityFlag(Integer.parseInt(item.getQualityFlag()));
|
/*生成dayHarmphasicI表*/
|
||||||
// dataFlucPOList.add(po1);
|
List<DataHarmPhasicIPO> dataHarmphasicIPO = getDataHarmphasicI(lineIndex, startTime, endTime);
|
||||||
// }
|
if (!CollectionUtils.isEmpty(dataHarmphasicIPO)) {
|
||||||
// }
|
for (DataHarmPhasicIPO item : dataHarmphasicIPO) {
|
||||||
// /*生成dayHarmphasicI表*/
|
RStatDataHarmphasicIDPO po1 = new RStatDataHarmphasicIDPO();
|
||||||
// List<DataHarmPhasicIPO> dataHarmphasicIPO = getDataHarmphasicI(lineIndex, startTime, endTime);
|
BeanUtils.copyProperties(item,po1);
|
||||||
// if (!CollectionUtils.isEmpty(dataHarmphasicIPO)) {
|
po1.setTime(time);
|
||||||
// for (DataHarmPhasicIPO item : dataHarmphasicIPO) {
|
po1.setQualityFlag(Integer.parseInt(item.getQualityFlag()));
|
||||||
// RStatDataHarmphasicIDPO po1 = new RStatDataHarmphasicIDPO();
|
dataHarmPhasicIPOList.add(po1);
|
||||||
// BeanUtils.copyProperties(item,po1);
|
}
|
||||||
// po1.setTime(time);
|
}
|
||||||
// po1.setQualityFlag(Integer.parseInt(item.getQualityFlag()));
|
/*生成dayHarmphasicV表*/
|
||||||
// dataHarmPhasicIPOList.add(po1);
|
List<DataHarmPhasicVPO> dataHarmphasicVPO = getDataHarmphasicV(lineIndex, startTime, endTime);
|
||||||
// }
|
if (!CollectionUtils.isEmpty(dataHarmphasicVPO)) {
|
||||||
// }
|
for (DataHarmPhasicVPO item : dataHarmphasicVPO) {
|
||||||
// /*生成dayHarmphasicV表*/
|
RStatDataHarmphasicVDPO po1 = new RStatDataHarmphasicVDPO();
|
||||||
// List<DataHarmPhasicVPO> dataHarmphasicVPO = getDataHarmphasicV(lineIndex, startTime, endTime);
|
BeanUtils.copyProperties(item,po1);
|
||||||
// if (!CollectionUtils.isEmpty(dataHarmphasicVPO)) {
|
po1.setTime(time);
|
||||||
// for (DataHarmPhasicVPO item : dataHarmphasicVPO) {
|
po1.setQualityFlag(Integer.parseInt(item.getQualityFlag()));
|
||||||
// RStatDataHarmphasicVDPO po1 = new RStatDataHarmphasicVDPO();
|
dataHarmPhasicVPOList.add(po1);
|
||||||
// BeanUtils.copyProperties(item,po1);
|
}
|
||||||
// po1.setTime(time);
|
}
|
||||||
// po1.setQualityFlag(Integer.parseInt(item.getQualityFlag()));
|
/*生成dayHarmPowerP表*/
|
||||||
// dataHarmPhasicVPOList.add(po1);
|
List<DataHarmPowerPPO> dataHarmPowerPPO = getDataHarmPowerP(lineIndex, startTime, endTime);
|
||||||
// }
|
if (!CollectionUtils.isEmpty(dataHarmPowerPPO)) {
|
||||||
// }
|
for (DataHarmPowerPPO item : dataHarmPowerPPO) {
|
||||||
// /*生成dayHarmPowerP表*/
|
RStatDataHarmpowerPDPO po1 = new RStatDataHarmpowerPDPO();
|
||||||
// List<DataHarmPowerPPO> dataHarmPowerPPO = getDataHarmPowerP(lineIndex, startTime, endTime);
|
BeanUtils.copyProperties(item,po1);
|
||||||
// if (!CollectionUtils.isEmpty(dataHarmPowerPPO)) {
|
po1.setTime(time);
|
||||||
// for (DataHarmPowerPPO item : dataHarmPowerPPO) {
|
po1.setQualityFlag(Integer.parseInt(item.getQualityFlag()));
|
||||||
// RStatDataHarmpowerPDPO po1 = new RStatDataHarmpowerPDPO();
|
dataHarmPowerPPOList.add(po1);
|
||||||
// BeanUtils.copyProperties(item,po1);
|
}
|
||||||
// po1.setTime(time);
|
}
|
||||||
// po1.setQualityFlag(Integer.parseInt(item.getQualityFlag()));
|
/*生成dayHarmPowerQ表*/
|
||||||
// dataHarmPowerPPOList.add(po1);
|
List<DataHarmPowerQPO> dataHarmPowerQPO = getDataHarmPowerQ(lineIndex, startTime, endTime);
|
||||||
// }
|
if (!CollectionUtils.isEmpty(dataHarmPowerQPO)) {
|
||||||
// }
|
for (DataHarmPowerQPO item : dataHarmPowerQPO) {
|
||||||
// /*生成dayHarmPowerQ表*/
|
RStatDataHarmpowerQDPO po1 = new RStatDataHarmpowerQDPO();
|
||||||
// List<DataHarmPowerQPO> dataHarmPowerQPO = getDataHarmPowerQ(lineIndex, startTime, endTime);
|
BeanUtils.copyProperties(item,po1);
|
||||||
// if (!CollectionUtils.isEmpty(dataHarmPowerQPO)) {
|
po1.setTime(time);
|
||||||
// for (DataHarmPowerQPO item : dataHarmPowerQPO) {
|
po1.setQualityFlag(Integer.parseInt(item.getQualityFlag()));
|
||||||
// RStatDataHarmpowerQDPO po1 = new RStatDataHarmpowerQDPO();
|
dataHarmPowerQPOList.add(po1);
|
||||||
// BeanUtils.copyProperties(item,po1);
|
}
|
||||||
// po1.setTime(time);
|
}
|
||||||
// po1.setQualityFlag(Integer.parseInt(item.getQualityFlag()));
|
/*生成dayHarmPowerS表*/
|
||||||
// dataHarmPowerQPOList.add(po1);
|
List<DataHarmPowerSPO> dataHarmPowers = getDataHarmPowerS(lineIndex, startTime, endTime);
|
||||||
// }
|
if (!CollectionUtils.isEmpty(dataHarmPowers)) {
|
||||||
// }
|
for (DataHarmPowerSPO item : dataHarmPowers) {
|
||||||
// /*生成dayHarmPowerS表*/
|
RStatDataHarmpowerSDPO po1 = new RStatDataHarmpowerSDPO();
|
||||||
// List<DataHarmPowerSPO> dataHarmPowers = getDataHarmPowerS(lineIndex, startTime, endTime);
|
BeanUtils.copyProperties(item,po1);
|
||||||
// if (!CollectionUtils.isEmpty(dataHarmPowers)) {
|
po1.setTime(time);
|
||||||
// for (DataHarmPowerSPO item : dataHarmPowers) {
|
po1.setQualityFlag(Integer.parseInt(item.getQualityFlag()));
|
||||||
// RStatDataHarmpowerSDPO po1 = new RStatDataHarmpowerSDPO();
|
dataHarmPowerSPOList.add(po1);
|
||||||
// BeanUtils.copyProperties(item,po1);
|
}
|
||||||
// po1.setTime(time);
|
}
|
||||||
// po1.setQualityFlag(Integer.parseInt(item.getQualityFlag()));
|
/*生成dayHarmRateI*/
|
||||||
// dataHarmPowerSPOList.add(po1);
|
List<DataHarmRateIPO> dataHarmRateI = getDataHarmRateI(lineIndex, startTime, endTime);
|
||||||
// }
|
if (!CollectionUtils.isEmpty(dataHarmRateI)) {
|
||||||
// }
|
for (DataHarmRateIPO item : dataHarmRateI) {
|
||||||
// /*生成dayHarmRateI*/
|
RStatDataHarmrateIDPO po1 = new RStatDataHarmrateIDPO();
|
||||||
// List<DataHarmRateIPO> dataHarmRateI = getDataHarmRateI(lineIndex, startTime, endTime);
|
BeanUtils.copyProperties(item,po1);
|
||||||
// if (!CollectionUtils.isEmpty(dataHarmRateI)) {
|
po1.setTime(time);
|
||||||
// for (DataHarmRateIPO item : dataHarmRateI) {
|
po1.setQualityFlag(Integer.parseInt(item.getQualityFlag()));
|
||||||
// RStatDataHarmrateIDPO po1 = new RStatDataHarmrateIDPO();
|
dataHarmRateIPOList.add(po1);
|
||||||
// BeanUtils.copyProperties(item,po1);
|
}
|
||||||
// po1.setTime(time);
|
}
|
||||||
// po1.setQualityFlag(Integer.parseInt(item.getQualityFlag()));
|
/*生成dayHarmRateV*/
|
||||||
// dataHarmRateIPOList.add(po1);
|
List<DataHarmRateVPO> dataHarmRateVPO = getDataHarmRateV(lineIndex, startTime, endTime);
|
||||||
// }
|
if (!CollectionUtils.isEmpty(dataHarmRateVPO)) {
|
||||||
// }
|
for (DataHarmRateVPO item : dataHarmRateVPO) {
|
||||||
// /*生成dayHarmRateV*/
|
RStatDataHarmrateVDPO po1 = new RStatDataHarmrateVDPO();
|
||||||
// List<DataHarmRateVPO> dataHarmRateVPO = getDataHarmRateV(lineIndex, startTime, endTime);
|
BeanUtils.copyProperties(item,po1);
|
||||||
// if (!CollectionUtils.isEmpty(dataHarmRateVPO)) {
|
po1.setTime(time);
|
||||||
// for (DataHarmRateVPO item : dataHarmRateVPO) {
|
po1.setQualityFlag(Integer.parseInt(item.getQualityFlag()));
|
||||||
// RStatDataHarmrateVDPO po1 = new RStatDataHarmrateVDPO();
|
dataHarmRateVPOList.add(po1);
|
||||||
// BeanUtils.copyProperties(item,po1);
|
}
|
||||||
// po1.setTime(time);
|
}
|
||||||
// po1.setQualityFlag(Integer.parseInt(item.getQualityFlag()));
|
/*生成dayInHarmI*/
|
||||||
// dataHarmRateVPOList.add(po1);
|
List<DataInHarmIPO> dataInHarmIPO = getDataInHarmI(lineIndex, startTime, endTime);
|
||||||
// }
|
if (!CollectionUtils.isEmpty(dataInHarmIPO)) {
|
||||||
// }
|
for (DataInHarmIPO item : dataInHarmIPO) {
|
||||||
// /*生成dayInHarmI*/
|
RStatDataInharmIDPO po1 = new RStatDataInharmIDPO();
|
||||||
// List<DataInHarmIPO> dataInHarmIPO = getDataInHarmI(lineIndex, startTime, endTime);
|
BeanUtils.copyProperties(item,po1);
|
||||||
// if (!CollectionUtils.isEmpty(dataInHarmIPO)) {
|
po1.setTime(time);
|
||||||
// for (DataInHarmIPO item : dataInHarmIPO) {
|
po1.setQualityFlag(Integer.parseInt(item.getQualityFlag()));
|
||||||
// RStatDataInharmIDPO po1 = new RStatDataInharmIDPO();
|
dataInHarmIPOList.add(po1);
|
||||||
// BeanUtils.copyProperties(item,po1);
|
}
|
||||||
// po1.setTime(time);
|
}
|
||||||
// po1.setQualityFlag(Integer.parseInt(item.getQualityFlag()));
|
/*生成dayInHarmV*/
|
||||||
// dataInHarmIPOList.add(po1);
|
List<DataInHarmVPO> dataInHarmVPO = getDataInHarmV(lineIndex, startTime, endTime);
|
||||||
// }
|
if (!CollectionUtils.isEmpty(dataInHarmVPO)) {
|
||||||
// }
|
for (DataInHarmVPO item : dataInHarmVPO) {
|
||||||
// /*生成dayInHarmV*/
|
RStatDataInharmVDPO po1 = new RStatDataInharmVDPO();
|
||||||
// List<DataInHarmVPO> dataInHarmVPO = getDataInHarmV(lineIndex, startTime, endTime);
|
BeanUtils.copyProperties(item,po1);
|
||||||
// if (!CollectionUtils.isEmpty(dataInHarmVPO)) {
|
po1.setTime(time);
|
||||||
// for (DataInHarmVPO item : dataInHarmVPO) {
|
po1.setQualityFlag(Integer.parseInt(item.getQualityFlag()));
|
||||||
// RStatDataInharmVDPO po1 = new RStatDataInharmVDPO();
|
dataInHarmVPOList.add(po1);
|
||||||
// BeanUtils.copyProperties(item,po1);
|
}
|
||||||
// po1.setTime(time);
|
}
|
||||||
// po1.setQualityFlag(Integer.parseInt(item.getQualityFlag()));
|
/*生成dayPlt*/
|
||||||
// dataInHarmVPOList.add(po1);
|
List<DataPltPO> dataPlt = getDataPlt(lineIndex, startTime, endTime);
|
||||||
// }
|
if (!CollectionUtils.isEmpty(dataPlt)) {
|
||||||
// }
|
for (DataPltPO item : dataPlt) {
|
||||||
// /*生成dayPlt*/
|
RStatDataPltDPO po1 = new RStatDataPltDPO();
|
||||||
// List<DataPltPO> dataPlt = getDataPlt(lineIndex, startTime, endTime);
|
BeanUtils.copyProperties(item,po1);
|
||||||
// if (!CollectionUtils.isEmpty(dataPlt)) {
|
po1.setTime(time);
|
||||||
// for (DataPltPO item : dataPlt) {
|
po1.setQualityFlag(Integer.parseInt(item.getQualityFlag()));
|
||||||
// RStatDataPltDPO po1 = new RStatDataPltDPO();
|
dataPltPOList.add(po1);
|
||||||
// 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
|
||||||
@@ -3869,10 +3837,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);
|
||||||
PropertyDescriptor[] pds = src.getPropertyDescriptors ( );
|
java.beans.PropertyDescriptor[] pds = src.getPropertyDescriptors ( );
|
||||||
|
|
||||||
Set<String> emptyNames = new HashSet<String> ( );
|
Set<String> emptyNames = new HashSet<String> ( );
|
||||||
for (PropertyDescriptor pd : pds) {
|
for (java.beans.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 ( ));
|
||||||
|
|||||||
Reference in New Issue
Block a user