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

1.去除influxdb生成每日日表数据代码

Browse Source
This commit is contained in:
chendaofei
2024-08-13 11:18:41 +08:00
parent 1f18c71eb7
commit a492609b36
1 changed files with 44 additions and 44 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -635,7 +635,7 @@ public class DayDataServiceImpl implements DayDataService {
List<RStatDataPltDPO> dataPltPOList = new ArrayList<>();
List<RStatDataFlickerDPO> dataFlickerPOList = new ArrayList<>();
//day表
List<DayV> dayVList = new ArrayList<>();
/* List<DayV> dayVList = new ArrayList<>();
List<DayI> dayIList = new ArrayList<>();
List<DayFlicker> dayFlickerList = new ArrayList<>();
List<DayFluc> dayFlucList = new ArrayList<>();
@@ -648,7 +648,7 @@ public class DayDataServiceImpl implements DayDataService {
List<DayHarmRateI> dayHarmRateIList = new ArrayList<>();
List<DayInHarmI> dayInHarmIList = new ArrayList<>();
List<DayInHarmV> dayInHarmVList = new ArrayList<>();
List<DayPlt> dayPltList = new ArrayList<>();
List<DayPlt> dayPltList = new ArrayList<>();*/
List<String> lineIds = calculatedParam.getIdList();
//河北数据量较大，以尺寸20分片
@@ -713,13 +713,13 @@ public class DayDataServiceImpl implements DayDataService {
po1.setTime(LocalDate.parse(calculatedParam.getDataDate(), DatePattern.NORM_DATE_FORMATTER));
po1.setQualityFlag(Integer.parseInt(item.getQualityFlag()));
dataVPOList.add(po1);
DayV dayV = new DayV();
/* DayV dayV = new DayV();
BeanUtils.copyProperties(item, dayV);
dayV.setTime(DateUtil.parse(calculatedParam.getDataDate(), DatePattern.NORM_DATE_FORMATTER).toInstant());
dayVList.add(dayV);
dayVList.add(dayV);*/
}
statDataVDService.insert(dataVPOList);
dayVMapper.insertBatch(dayVList);
// dayVMapper.insertBatch(dayVList);
}
//dataI数据入库
if (!CollectionUtils.isEmpty(list2)) {
@@ -729,13 +729,13 @@ public class DayDataServiceImpl implements DayDataService {
po1.setTime(LocalDate.parse(calculatedParam.getDataDate(), DatePattern.NORM_DATE_FORMATTER));
po1.setQualityFlag(Integer.parseInt(item.getQualityFlag()));
dataIPOList.add(po1);
DayI dayI = new DayI();
/* DayI dayI = new DayI();
BeanUtils.copyProperties(item, dayI);
dayI.setTime(DateUtil.parse(calculatedParam.getDataDate(), DatePattern.NORM_DATE_FORMATTER).toInstant());
dayIList.add(dayI);
dayIList.add(dayI);*/
}
statDataIDService.insert(dataIPOList);
dayIMapper.insertBatch(dayIList);
//dayIMapper.insertBatch(dayIList);
}
//dataFlicker数据入库
if (!CollectionUtils.isEmpty(list3)) {
@@ -746,13 +746,13 @@ public class DayDataServiceImpl implements DayDataService {
po1.setQualityFlag(Integer.parseInt(item.getQualityFlag()));
dataFlickerPOList.add(po1);
DayFlicker dayFlicker = new DayFlicker();
/* DayFlicker dayFlicker = new DayFlicker();
BeanUtils.copyProperties(item, dayFlicker);
dayFlicker.setTime(DateUtil.parse(calculatedParam.getDataDate(), DatePattern.NORM_DATE_FORMATTER).toInstant());
dayFlickerList.add(dayFlicker);
dayFlickerList.add(dayFlicker);*/
}
statDataFlickerDService.insert(dataFlickerPOList);
dayFlickerMapper.insertBatch(dayFlickerList);
//dayFlickerMapper.insertBatch(dayFlickerList);
}
//dataFluc数据入库
if (!CollectionUtils.isEmpty(list4)) {
@@ -763,13 +763,13 @@ public class DayDataServiceImpl implements DayDataService {
po1.setQualityFlag(Integer.parseInt(item.getQualityFlag()));
dataFlucPOList.add(po1);
DayFluc dayFluc = new DayFluc();
/* DayFluc dayFluc = new DayFluc();
BeanUtils.copyProperties(item, dayFluc);
dayFluc.setTime(DateUtil.parse(calculatedParam.getDataDate(), DatePattern.NORM_DATE_FORMATTER).toInstant());
dayFlucList.add(dayFluc);
dayFlucList.add(dayFluc);*/
}
statDataFlucDService.insert(dataFlucPOList);
dayFlucMapper.insertBatch(dayFlucList);
//dayFlucMapper.insertBatch(dayFlucList);
}
//data_harmphasic_i数据入库
if (!CollectionUtils.isEmpty(list5)) {
@@ -780,13 +780,13 @@ public class DayDataServiceImpl implements DayDataService {
po1.setQualityFlag(Integer.parseInt(item.getQualityFlag()));
dataHarmPhasicIPOList.add(po1);
DayHarmPhasicI dayHarmPhasicI = new DayHarmPhasicI();
/* DayHarmPhasicI dayHarmPhasicI = new DayHarmPhasicI();
BeanUtils.copyProperties(item, dayHarmPhasicI);
dayHarmPhasicI.setTime(DateUtil.parse(calculatedParam.getDataDate(), DatePattern.NORM_DATE_FORMATTER).toInstant());
dayHarmPhasicIList.add(dayHarmPhasicI);
dayHarmPhasicIList.add(dayHarmPhasicI);*/
}
statDataHarmphasicIDService.insert(dataHarmPhasicIPOList);
dayHarmPhasicIMapper.insertBatch(dayHarmPhasicIList);
//dayHarmPhasicIMapper.insertBatch(dayHarmPhasicIList);
}
//data_harmphasic_v数据入库
if (!CollectionUtils.isEmpty(list6)) {
@@ -797,13 +797,13 @@ public class DayDataServiceImpl implements DayDataService {
po1.setQualityFlag(Integer.parseInt(item.getQualityFlag()));
dataHarmPhasicVPOList.add(po1);
DayHarmPhasicV dayHarmPhasicV = new DayHarmPhasicV();
/* DayHarmPhasicV dayHarmPhasicV = new DayHarmPhasicV();
BeanUtils.copyProperties(item, dayHarmPhasicV);
dayHarmPhasicV.setTime(DateUtil.parse(calculatedParam.getDataDate(), DatePattern.NORM_DATE_FORMATTER).toInstant());
dayHarmPhasicVList.add(dayHarmPhasicV);
dayHarmPhasicVList.add(dayHarmPhasicV);*/
}
statDataHarmphasicVDService.insert(dataHarmPhasicVPOList);
dayHarmPhasicVMapper.insertBatch(dayHarmPhasicVList);
//dayHarmPhasicVMapper.insertBatch(dayHarmPhasicVList);
}
//data_harmpower_p数据入库
if (!CollectionUtils.isEmpty(list7)) {
@@ -814,13 +814,13 @@ public class DayDataServiceImpl implements DayDataService {
po1.setQualityFlag(Integer.parseInt(item.getQualityFlag()));
dataHarmPowerPPOList.add(po1);
DayHarmPowerP dayHarmPowerP = new DayHarmPowerP();
/* DayHarmPowerP dayHarmPowerP = new DayHarmPowerP();
BeanUtils.copyProperties(item, dayHarmPowerP);
dayHarmPowerP.setTime(DateUtil.parse(calculatedParam.getDataDate(), DatePattern.NORM_DATE_FORMATTER).toInstant());
dayHarmPowerPList.add(dayHarmPowerP);
dayHarmPowerPList.add(dayHarmPowerP);*/
}
statDataHarmpowerPDService.insert(dataHarmPowerPPOList);
dayHarmPowerPMapper.insertBatch(dayHarmPowerPList);
//dayHarmPowerPMapper.insertBatch(dayHarmPowerPList);
}
//data_harmpower_q数据入库
if (!CollectionUtils.isEmpty(list8)) {
@@ -831,13 +831,13 @@ public class DayDataServiceImpl implements DayDataService {
po1.setQualityFlag(Integer.parseInt(item.getQualityFlag()));
dataHarmPowerQPOList.add(po1);
DayHarmPowerQ dayHarmPowerQ = new DayHarmPowerQ();
/* DayHarmPowerQ dayHarmPowerQ = new DayHarmPowerQ();
BeanUtils.copyProperties(item, dayHarmPowerQ);
dayHarmPowerQ.setTime(DateUtil.parse(calculatedParam.getDataDate(), DatePattern.NORM_DATE_FORMATTER).toInstant());
dayHarmPowerQList.add(dayHarmPowerQ);
dayHarmPowerQList.add(dayHarmPowerQ);*/
}
statDataHarmpowerQDService.insert(dataHarmPowerQPOList);
dayHarmPowerQMapper.insertBatch(dayHarmPowerQList);
//dayHarmPowerQMapper.insertBatch(dayHarmPowerQList);
}
//data_harmpower_s数据入库
if (!CollectionUtils.isEmpty(list9)) {
@@ -848,13 +848,13 @@ public class DayDataServiceImpl implements DayDataService {
po1.setQualityFlag(Integer.parseInt(item.getQualityFlag()));
dataHarmPowerSPOList.add(po1);
DayHarmPowerS dayHarmPowerS = new DayHarmPowerS();
/* DayHarmPowerS dayHarmPowerS = new DayHarmPowerS();
BeanUtils.copyProperties(item, dayHarmPowerS);
dayHarmPowerS.setTime(DateUtil.parse(calculatedParam.getDataDate(), DatePattern.NORM_DATE_FORMATTER).toInstant());
dayHarmPowerSList.add(dayHarmPowerS);
dayHarmPowerSList.add(dayHarmPowerS);*/
}
statDataHarmpowerSDService.insert(dataHarmPowerSPOList);
dayHarmPowerSMapper.insertBatch(dayHarmPowerSList);
//dayHarmPowerSMapper.insertBatch(dayHarmPowerSList);
}
//data_harmrate_i数据入库
if (!CollectionUtils.isEmpty(list10)) {
@@ -865,13 +865,13 @@ public class DayDataServiceImpl implements DayDataService {
po1.setQualityFlag(Integer.parseInt(item.getQualityFlag()));
dataHarmRateIPOList.add(po1);
DayHarmRateI dayHarmRateI = new DayHarmRateI();
/* DayHarmRateI dayHarmRateI = new DayHarmRateI();
BeanUtils.copyProperties(item, dayHarmRateI);
dayHarmRateI.setTime(DateUtil.parse(calculatedParam.getDataDate(), DatePattern.NORM_DATE_FORMATTER).toInstant());
dayHarmRateIList.add(dayHarmRateI);
dayHarmRateIList.add(dayHarmRateI);*/
}
statDataHarmRateIDService.insert(dataHarmRateIPOList);
dayHarmRateIMapper.insertBatch(dayHarmRateIList);
//dayHarmRateIMapper.insertBatch(dayHarmRateIList);
}
//data_harmrate_v数据入库
if (!CollectionUtils.isEmpty(list11)) {
@@ -882,13 +882,13 @@ public class DayDataServiceImpl implements DayDataService {
po1.setQualityFlag(Integer.parseInt(item.getQualityFlag()));
dataHarmRateVPOList.add(po1);
DayHarmRateV dayHarmRateV = new DayHarmRateV();
/* DayHarmRateV dayHarmRateV = new DayHarmRateV();
BeanUtils.copyProperties(item, dayHarmRateV);
dayHarmRateV.setTime(DateUtil.parse(calculatedParam.getDataDate(), DatePattern.NORM_DATE_FORMATTER).toInstant());
dayHarmRateVList.add(dayHarmRateV);
dayHarmRateVList.add(dayHarmRateV);*/
}
statDataHarmRateVDService.insert(dataHarmRateVPOList);
dayHarmRateVMapper.insertBatch(dayHarmRateVList);
//dayHarmRateVMapper.insertBatch(dayHarmRateVList);
}
//data_inharm_i数据入库
if (!CollectionUtils.isEmpty(list12)) {
@@ -899,13 +899,13 @@ public class DayDataServiceImpl implements DayDataService {
po1.setQualityFlag(Integer.parseInt(item.getQualityFlag()));
dataInHarmIPOList.add(po1);
DayInHarmI dayInHarmI = new DayInHarmI();
/* DayInHarmI dayInHarmI = new DayInHarmI();
BeanUtils.copyProperties(item, dayInHarmI);
dayInHarmI.setTime(DateUtil.parse(calculatedParam.getDataDate(), DatePattern.NORM_DATE_FORMATTER).toInstant());
dayInHarmIList.add(dayInHarmI);
dayInHarmIList.add(dayInHarmI);*/
}
statDataInharmIDService.insert(dataInHarmIPOList);
dayInHarmIMapper.insertBatch(dayInHarmIList);
//dayInHarmIMapper.insertBatch(dayInHarmIList);
}
//data_inharm_v数据入库
if (!CollectionUtils.isEmpty(list13)) {
@@ -916,13 +916,13 @@ public class DayDataServiceImpl implements DayDataService {
po1.setQualityFlag(Integer.parseInt(item.getQualityFlag()));
dataInHarmVPOList.add(po1);
DayInHarmV dayInHarmV = new DayInHarmV();
/* DayInHarmV dayInHarmV = new DayInHarmV();
BeanUtils.copyProperties(item, dayInHarmV);
dayInHarmV.setTime(DateUtil.parse(calculatedParam.getDataDate(), DatePattern.NORM_DATE_FORMATTER).toInstant());
dayInHarmVList.add(dayInHarmV);
dayInHarmVList.add(dayInHarmV);*/
}
statDataInharmVDService.insert(dataInHarmVPOList);
dayInHarmVMapper.insertBatch(dayInHarmVList);
//dayInHarmVMapper.insertBatch(dayInHarmVList);
}
//data_plt数据入库
if (!CollectionUtils.isEmpty(list16)) {
@@ -933,13 +933,13 @@ public class DayDataServiceImpl implements DayDataService {
po1.setQualityFlag(Integer.parseInt(item.getQualityFlag()));
dataPltPOList.add(po1);
DayPlt dayPlt = new DayPlt();
/* DayPlt dayPlt = new DayPlt();
BeanUtils.copyProperties(item, dayPlt);
dayPlt.setTime(DateUtil.parse(calculatedParam.getDataDate(), DatePattern.NORM_DATE_FORMATTER).toInstant());
dayPltList.add(dayPlt);
dayPltList.add(dayPlt);*/
}
statDataPltDService.insert(dataPltPOList);
dayPltMapper.insertBatch(dayPltList);
//dayPltMapper.insertBatch(dayPltList);
}
}