From a492609b360b3f9f58280728d553a6b7cec89985 Mon Sep 17 00:00:00 2001 From: chendaofei <857448963@qq.com> Date: Tue, 13 Aug 2024 11:18:41 +0800 Subject: [PATCH] =?UTF-8?q?1.=E5=8E=BB=E9=99=A4influxdb=E7=94=9F=E6=88=90?= =?UTF-8?q?=E6=AF=8F=E6=97=A5=E6=97=A5=E8=A1=A8=E6=95=B0=E6=8D=AE=E4=BB=A3?= =?UTF-8?q?=E7=A0=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../mysql/Impl/line/DayDataServiceImpl.java | 88 +++++++++---------- 1 file changed, 44 insertions(+), 44 deletions(-) diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/line/DayDataServiceImpl.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/line/DayDataServiceImpl.java index 077ffd7bf..3c681ab87 100644 --- a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/line/DayDataServiceImpl.java +++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/line/DayDataServiceImpl.java @@ -635,7 +635,7 @@ public class DayDataServiceImpl implements DayDataService { List dataPltPOList = new ArrayList<>(); List dataFlickerPOList = new ArrayList<>(); //day表 - List dayVList = new ArrayList<>(); + /* List dayVList = new ArrayList<>(); List dayIList = new ArrayList<>(); List dayFlickerList = new ArrayList<>(); List dayFlucList = new ArrayList<>(); @@ -648,7 +648,7 @@ public class DayDataServiceImpl implements DayDataService { List dayHarmRateIList = new ArrayList<>(); List dayInHarmIList = new ArrayList<>(); List dayInHarmVList = new ArrayList<>(); - List dayPltList = new ArrayList<>(); + List dayPltList = new ArrayList<>();*/ List 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); } }