From 3c9aaa160879c2fae563f6083f0842cd69b3348f Mon Sep 17 00:00:00 2001 From: xuyang <748613696@qq.com> Date: Fri, 19 Jan 2024 08:45:53 +0800 Subject: [PATCH] =?UTF-8?q?=E6=B2=B3=E5=8C=97=E8=B6=85=E9=AB=98=E5=8E=8B?= =?UTF-8?q?=E7=AE=97=E6=B3=95=E8=B0=83=E6=95=B4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../prepare/executor/MeasurementExecutor.java | 99 ++++ .../mysql/Impl/line/DayDataServiceImpl.java | 501 ++++++++++++++++++ .../service/mysql/line/DayDataService.java | 112 ++++ 3 files changed, 712 insertions(+) diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/executor/MeasurementExecutor.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/executor/MeasurementExecutor.java index ac5419a1d..712af1749 100644 --- a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/executor/MeasurementExecutor.java +++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/executor/MeasurementExecutor.java @@ -213,6 +213,105 @@ public class MeasurementExecutor extends BaseExecutor { dayDataService.dataToDayHandler(bindCmp.getRequestData()); } + @LiteflowMethod(value = LiteFlowMethodEnum.IS_ACCESS, nodeId = "dataV", nodeType = NodeTypeEnum.COMMON) + public boolean dataToDayAccess1(NodeComponent bindCmp) { + return isAccess(bindCmp); + } + @LiteflowMethod(value = LiteFlowMethodEnum.PROCESS, nodeId = "dataV", nodeType = NodeTypeEnum.COMMON) + public void dataToDayProcess1(NodeComponent bindCmp) { + dayDataService.dataVHardler(bindCmp.getRequestData()); + } + + @LiteflowMethod(value = LiteFlowMethodEnum.IS_ACCESS, nodeId = "dataI", nodeType = NodeTypeEnum.COMMON) + public boolean dataToDayAccess2(NodeComponent bindCmp) { + return isAccess(bindCmp); + } + @LiteflowMethod(value = LiteFlowMethodEnum.PROCESS, nodeId = "dataI", nodeType = NodeTypeEnum.COMMON) + public void dataToDayProcess2(NodeComponent bindCmp) {dayDataService.dataIHardler(bindCmp.getRequestData());} + + @LiteflowMethod(value = LiteFlowMethodEnum.IS_ACCESS, nodeId = "dataFlicker", nodeType = NodeTypeEnum.COMMON) + public boolean dataToDayAccess3(NodeComponent bindCmp) { + return isAccess(bindCmp); + } + @LiteflowMethod(value = LiteFlowMethodEnum.PROCESS, nodeId = "dataFlicker", nodeType = NodeTypeEnum.COMMON) + public void dataToDayProcess3(NodeComponent bindCmp) {dayDataService.dataFlickerHardler(bindCmp.getRequestData());} + + @LiteflowMethod(value = LiteFlowMethodEnum.IS_ACCESS, nodeId = "dataFluc", nodeType = NodeTypeEnum.COMMON) + public boolean dataToDayAccess4(NodeComponent bindCmp) { + return isAccess(bindCmp); + } + @LiteflowMethod(value = LiteFlowMethodEnum.PROCESS, nodeId = "dataFluc", nodeType = NodeTypeEnum.COMMON) + public void dataToDayProcess4(NodeComponent bindCmp) {dayDataService.dataFlucHardler(bindCmp.getRequestData());} + + @LiteflowMethod(value = LiteFlowMethodEnum.IS_ACCESS, nodeId = "dataHarmPhasicI", nodeType = NodeTypeEnum.COMMON) + public boolean dataToDayAccess5(NodeComponent bindCmp) { + return isAccess(bindCmp); + } + @LiteflowMethod(value = LiteFlowMethodEnum.PROCESS, nodeId = "dataHarmPhasicI", nodeType = NodeTypeEnum.COMMON) + public void dataToDayProcess5(NodeComponent bindCmp) {dayDataService.dataHarmPhasicIHardler(bindCmp.getRequestData());} + + @LiteflowMethod(value = LiteFlowMethodEnum.IS_ACCESS, nodeId = "dataHarmPhasicV", nodeType = NodeTypeEnum.COMMON) + public boolean dataToDayAccess6(NodeComponent bindCmp) { + return isAccess(bindCmp); + } + @LiteflowMethod(value = LiteFlowMethodEnum.PROCESS, nodeId = "dataHarmPhasicV", nodeType = NodeTypeEnum.COMMON) + public void dataToDayProcess6(NodeComponent bindCmp) {dayDataService.dataHarmPhasicVHardler(bindCmp.getRequestData());} + + @LiteflowMethod(value = LiteFlowMethodEnum.IS_ACCESS, nodeId = "dataHarmPowerP", nodeType = NodeTypeEnum.COMMON) + public boolean dataToDayAccess7(NodeComponent bindCmp) {return isAccess(bindCmp);} + + @LiteflowMethod(value = LiteFlowMethodEnum.PROCESS, nodeId = "dataHarmPowerP", nodeType = NodeTypeEnum.COMMON) + public void dataToDayProcess7(NodeComponent bindCmp) {dayDataService.dataHarmPowerPHardler(bindCmp.getRequestData());} + + @LiteflowMethod(value = LiteFlowMethodEnum.IS_ACCESS, nodeId = "dataHarmPowerQ", nodeType = NodeTypeEnum.COMMON) + public boolean dataToDayAccess8(NodeComponent bindCmp) { + return isAccess(bindCmp); + } + @LiteflowMethod(value = LiteFlowMethodEnum.PROCESS, nodeId = "dataHarmPowerQ", nodeType = NodeTypeEnum.COMMON) + public void dataToDayProcess8(NodeComponent bindCmp) {dayDataService.dataHarmPowerQHardler(bindCmp.getRequestData());} + + @LiteflowMethod(value = LiteFlowMethodEnum.IS_ACCESS, nodeId = "dataHarmPowerS", nodeType = NodeTypeEnum.COMMON) + public boolean dataToDayAccess9(NodeComponent bindCmp) { + return isAccess(bindCmp); + } + @LiteflowMethod(value = LiteFlowMethodEnum.PROCESS, nodeId = "dataHarmPowerS", nodeType = NodeTypeEnum.COMMON) + public void dataToDayProcess9(NodeComponent bindCmp) {dayDataService.dataHarmPowerSHardler(bindCmp.getRequestData());} + + @LiteflowMethod(value = LiteFlowMethodEnum.IS_ACCESS, nodeId = "dataHarmRateI", nodeType = NodeTypeEnum.COMMON) + public boolean dataToDayAccess10(NodeComponent bindCmp) { + return isAccess(bindCmp); + } + @LiteflowMethod(value = LiteFlowMethodEnum.PROCESS, nodeId = "dataHarmRateI", nodeType = NodeTypeEnum.COMMON) + public void dataToDayProcess10(NodeComponent bindCmp) {dayDataService.dataHarmRateIHardler(bindCmp.getRequestData());} + + @LiteflowMethod(value = LiteFlowMethodEnum.IS_ACCESS, nodeId = "dataHarmRateV", nodeType = NodeTypeEnum.COMMON) + public boolean dataToDayAccess11(NodeComponent bindCmp) { + return isAccess(bindCmp); + } + @LiteflowMethod(value = LiteFlowMethodEnum.PROCESS, nodeId = "dataHarmRateV", nodeType = NodeTypeEnum.COMMON) + public void dataToDayProcess11(NodeComponent bindCmp) {dayDataService.dataHarmRateVHardler(bindCmp.getRequestData());} + + @LiteflowMethod(value = LiteFlowMethodEnum.IS_ACCESS, nodeId = "dataInHarmI", nodeType = NodeTypeEnum.COMMON) + public boolean dataToDayAccess12(NodeComponent bindCmp) { + return isAccess(bindCmp); + } + @LiteflowMethod(value = LiteFlowMethodEnum.PROCESS, nodeId = "dataInHarmI", nodeType = NodeTypeEnum.COMMON) + public void dataToDayProcess12(NodeComponent bindCmp) {dayDataService.dataInHarmIHardler(bindCmp.getRequestData());} + + @LiteflowMethod(value = LiteFlowMethodEnum.IS_ACCESS, nodeId = "dataInHarmV", nodeType = NodeTypeEnum.COMMON) + public boolean dataToDayAccess13(NodeComponent bindCmp) { + return isAccess(bindCmp); + } + @LiteflowMethod(value = LiteFlowMethodEnum.PROCESS, nodeId = "dataInHarmV", nodeType = NodeTypeEnum.COMMON) + public void dataToDayProcess13(NodeComponent bindCmp) {dayDataService.dataInHarmVHardler(bindCmp.getRequestData());} + + @LiteflowMethod(value = LiteFlowMethodEnum.IS_ACCESS, nodeId = "dataPlt", nodeType = NodeTypeEnum.COMMON) + public boolean dataToDayAccess14(NodeComponent bindCmp) { + return isAccess(bindCmp); + } + @LiteflowMethod(value = LiteFlowMethodEnum.PROCESS, nodeId = "dataPlt", nodeType = NodeTypeEnum.COMMON) + public void dataToDayProcess14(NodeComponent bindCmp) {dayDataService.dataPltHardler(bindCmp.getRequestData());} + /** * 算法名: 暂无-----监测点数据完整性_日表(r_stat_integrity_d) * 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 64ca34fef..519a2dd42 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 @@ -91,6 +91,507 @@ public class DayDataServiceImpl implements DayDataService { private final DataInHarmRateVMapper dataInHarmRateVMapper; private final DataPltMapper dataPltMapper; + @Override + public void dataVHardler(CalculatedParam calculatedParam) { + log.info(LocalDateTime.now() + "dataV表转r_stat_data_v_d开始=====》"); + List list1 = new ArrayList<>(); + List dataVPOList = new ArrayList<>(); + List dayVList = new ArrayList<>(); + List lineIds = calculatedParam.getIdList(); + //河北数据量较大，单个监测点执行 + List> pendingIds = ListUtils.partition(lineIds,5); + String beginDay =LocalDateTimeUtil.format(LocalDateTimeUtil.beginOfDay(LocalDateTimeUtil.parse(calculatedParam.getDataDate(), DatePattern.NORM_DATE_PATTERN)),DatePattern.NORM_DATETIME_PATTERN); + String endDay = LocalDateTimeUtil.format(LocalDateTimeUtil.endOfDay(LocalDateTimeUtil.parse(calculatedParam.getDataDate(), DatePattern.NORM_DATE_PATTERN)),DatePattern.NORM_DATETIME_PATTERN); + for (List pendingId : pendingIds) { + //获取dataV数据 + List vList = getDataV(pendingId,beginDay,endDay); + list1.addAll(vList); + } + //dataV数据入库 + if (!CollectionUtils.isEmpty(list1)) { + for (DataV item : list1) { + RStatDataVDPO po1 = new RStatDataVDPO(); + BeanUtils.copyProperties(item, po1); + po1.setTime(LocalDate.parse(calculatedParam.getDataDate(), DatePattern.NORM_DATE_FORMATTER)); + po1.setQualityFlag(Integer.parseInt(item.getQualityFlag())); + dataVPOList.add(po1); + DayV dayV = new DayV(); + BeanUtils.copyProperties(item, dayV); + dayV.setTime(DateUtil.parse(calculatedParam.getDataDate(), DatePattern.NORM_DATE_FORMATTER).toInstant()); + dayVList.add(dayV); + } + statDataVDService.insert(dataVPOList); + dayVMapper.insertBatch(dayVList); + } + } + + @Override + public void dataIHardler(CalculatedParam calculatedParam) { + log.info(LocalDateTime.now() + "dataI表转r_stat_data_i_d开始=====》"); + List list2 = new ArrayList<>(); + List dataIPOList = new ArrayList<>(); + List dayIList = new ArrayList<>(); + + List lineIds = calculatedParam.getIdList(); + //河北数据量较大，单个监测点执行 + List> pendingIds = ListUtils.partition(lineIds,5); + String beginDay =LocalDateTimeUtil.format(LocalDateTimeUtil.beginOfDay(LocalDateTimeUtil.parse(calculatedParam.getDataDate(), DatePattern.NORM_DATE_PATTERN)),DatePattern.NORM_DATETIME_PATTERN); + String endDay = LocalDateTimeUtil.format(LocalDateTimeUtil.endOfDay(LocalDateTimeUtil.parse(calculatedParam.getDataDate(), DatePattern.NORM_DATE_PATTERN)),DatePattern.NORM_DATETIME_PATTERN); + for (List pendingId : pendingIds) { + //获取dataI数据 + List iList = getDataI(pendingId,beginDay,endDay); + list2.addAll(iList); + } + //dataI数据入库 + if (!CollectionUtils.isEmpty(list2)) { + for (DataI item : list2) { + RStatDataIDPO po1 = new RStatDataIDPO(); + BeanUtils.copyProperties(item, po1); + po1.setTime(LocalDate.parse(calculatedParam.getDataDate(), DatePattern.NORM_DATE_FORMATTER)); + po1.setQualityFlag(Integer.parseInt(item.getQualityFlag())); + dataIPOList.add(po1); + DayI dayI = new DayI(); + BeanUtils.copyProperties(item, dayI); + dayI.setTime(DateUtil.parse(calculatedParam.getDataDate(), DatePattern.NORM_DATE_FORMATTER).toInstant()); + dayIList.add(dayI); + } + statDataIDService.insert(dataIPOList); + dayIMapper.insertBatch(dayIList); + } + } + + @Override + public void dataFlickerHardler(CalculatedParam calculatedParam) { + log.info(LocalDateTime.now() + "dataFlicker表转r_stat_data_flicker_d开始=====》"); + List list3 = new ArrayList<>(); + List dataFlickerPOList = new ArrayList<>(); + List dayFlickerList = new ArrayList<>(); + + List lineIds = calculatedParam.getIdList(); + //河北数据量较大，单个监测点执行 + List> pendingIds = ListUtils.partition(lineIds,5); + String beginDay =LocalDateTimeUtil.format(LocalDateTimeUtil.beginOfDay(LocalDateTimeUtil.parse(calculatedParam.getDataDate(), DatePattern.NORM_DATE_PATTERN)),DatePattern.NORM_DATETIME_PATTERN); + String endDay = LocalDateTimeUtil.format(LocalDateTimeUtil.endOfDay(LocalDateTimeUtil.parse(calculatedParam.getDataDate(), DatePattern.NORM_DATE_PATTERN)),DatePattern.NORM_DATETIME_PATTERN); + for (List pendingId : pendingIds) { + //获取dataFlicker数据 + List dataFlickerList = getDataFlicker(pendingId,beginDay,endDay); + list3.addAll(dataFlickerList); + } + //dataFlicker数据入库 + if (!CollectionUtils.isEmpty(list3)) { + for (DataFlicker item : list3) { + RStatDataFlickerDPO po1 = new RStatDataFlickerDPO(); + BeanUtils.copyProperties(item, po1); + po1.setTime(LocalDate.parse(calculatedParam.getDataDate(), DatePattern.NORM_DATE_FORMATTER)); + po1.setQualityFlag(Integer.parseInt(item.getQualityFlag())); + dataFlickerPOList.add(po1); + + DayFlicker dayFlicker = new DayFlicker(); + BeanUtils.copyProperties(item, dayFlicker); + dayFlicker.setTime(DateUtil.parse(calculatedParam.getDataDate(), DatePattern.NORM_DATE_FORMATTER).toInstant()); + dayFlickerList.add(dayFlicker); + } + statDataFlickerDService.insert(dataFlickerPOList); + dayFlickerMapper.insertBatch(dayFlickerList); + } + } + + @Override + public void dataFlucHardler(CalculatedParam calculatedParam) { + log.info(LocalDateTime.now() + "dataFluc表转r_stat_data_fluc_d开始=====》"); + List list4 = new ArrayList<>(); + List dataFlucPOList = new ArrayList<>(); + List dayFlucList = new ArrayList<>(); + List lineIds = calculatedParam.getIdList(); + //河北数据量较大，单个监测点执行 + List> pendingIds = ListUtils.partition(lineIds,5); + String beginDay =LocalDateTimeUtil.format(LocalDateTimeUtil.beginOfDay(LocalDateTimeUtil.parse(calculatedParam.getDataDate(), DatePattern.NORM_DATE_PATTERN)),DatePattern.NORM_DATETIME_PATTERN); + String endDay = LocalDateTimeUtil.format(LocalDateTimeUtil.endOfDay(LocalDateTimeUtil.parse(calculatedParam.getDataDate(), DatePattern.NORM_DATE_PATTERN)),DatePattern.NORM_DATETIME_PATTERN); + for (List pendingId : pendingIds) { + //获取dataFluc数据 + List dataFlucList = getDataFluc(pendingId,beginDay,endDay); + list4.addAll(dataFlucList); + } + //dataFluc数据入库 + if (!CollectionUtils.isEmpty(list4)) { + for (DataFluc item : list4) { + RStatDataFlucDPO po1 = new RStatDataFlucDPO(); + BeanUtils.copyProperties(item, po1); + po1.setTime(LocalDate.parse(calculatedParam.getDataDate(), DatePattern.NORM_DATE_FORMATTER)); + po1.setQualityFlag(Integer.parseInt(item.getQualityFlag())); + dataFlucPOList.add(po1); + + DayFluc dayFluc = new DayFluc(); + BeanUtils.copyProperties(item, dayFluc); + dayFluc.setTime(DateUtil.parse(calculatedParam.getDataDate(), DatePattern.NORM_DATE_FORMATTER).toInstant()); + dayFlucList.add(dayFluc); + } + statDataFlucDService.insert(dataFlucPOList); + dayFlucMapper.insertBatch(dayFlucList); + } + } + + @Override + public void dataHarmPhasicIHardler(CalculatedParam calculatedParam) { + log.info(LocalDateTime.now() + "data_harmphasic_i表转r_stat_data_harmphasic_i_d开始=====》"); + List list5 = new ArrayList<>(); + List dataHarmPhasicIPOList = new ArrayList<>(); + List dayHarmPhasicIList = new ArrayList<>(); + + List lineIds = calculatedParam.getIdList(); + //河北数据量较大，单个监测点执行 + List> pendingIds = ListUtils.partition(lineIds,5); + String beginDay =LocalDateTimeUtil.format(LocalDateTimeUtil.beginOfDay(LocalDateTimeUtil.parse(calculatedParam.getDataDate(), DatePattern.NORM_DATE_PATTERN)),DatePattern.NORM_DATETIME_PATTERN); + String endDay = LocalDateTimeUtil.format(LocalDateTimeUtil.endOfDay(LocalDateTimeUtil.parse(calculatedParam.getDataDate(), DatePattern.NORM_DATE_PATTERN)),DatePattern.NORM_DATETIME_PATTERN); + for (List pendingId : pendingIds) { + //获取DataHarmPhasicI数据 + List dataHarmPhasicIList = getDataHarmphasicI(pendingId,beginDay,endDay); + list5.addAll(dataHarmPhasicIList); + } + //data_harmphasic_i数据入库 + if (!CollectionUtils.isEmpty(list5)) { + for (DataHarmPhasicI item : list5) { + RStatDataHarmphasicIDPO po1 = new RStatDataHarmphasicIDPO(); + BeanUtils.copyProperties(item, po1); + po1.setTime(LocalDate.parse(calculatedParam.getDataDate(), DatePattern.NORM_DATE_FORMATTER)); + po1.setQualityFlag(Integer.parseInt(item.getQualityFlag())); + dataHarmPhasicIPOList.add(po1); + + DayHarmPhasicI dayHarmPhasicI = new DayHarmPhasicI(); + BeanUtils.copyProperties(item, dayHarmPhasicI); + dayHarmPhasicI.setTime(DateUtil.parse(calculatedParam.getDataDate(), DatePattern.NORM_DATE_FORMATTER).toInstant()); + dayHarmPhasicIList.add(dayHarmPhasicI); + } + statDataHarmphasicIDService.insert(dataHarmPhasicIPOList); + dayHarmPhasicIMapper.insertBatch(dayHarmPhasicIList); + } + } + + + @Override + public void dataHarmPhasicVHardler(CalculatedParam calculatedParam) { + log.info(LocalDateTime.now() + "data_harmphasic_v表转r_stat_data_harmphasic_v_d开始=====》"); + List list6 = new ArrayList<>(); + List dataHarmPhasicVPOList = new ArrayList<>(); + List dayHarmPhasicVList = new ArrayList<>(); + + List lineIds = calculatedParam.getIdList(); + //河北数据量较大，单个监测点执行 + List> pendingIds = ListUtils.partition(lineIds,5); + String beginDay =LocalDateTimeUtil.format(LocalDateTimeUtil.beginOfDay(LocalDateTimeUtil.parse(calculatedParam.getDataDate(), DatePattern.NORM_DATE_PATTERN)),DatePattern.NORM_DATETIME_PATTERN); + String endDay = LocalDateTimeUtil.format(LocalDateTimeUtil.endOfDay(LocalDateTimeUtil.parse(calculatedParam.getDataDate(), DatePattern.NORM_DATE_PATTERN)),DatePattern.NORM_DATETIME_PATTERN); + for (List pendingId : pendingIds) { + //获取DataHarmPhasicV数据 + List dataHarmPhasicVList = getDataHarmphasicV(pendingId,beginDay,endDay); + list6.addAll(dataHarmPhasicVList); + } + //data_harmphasic_v数据入库 + if (!CollectionUtils.isEmpty(list6)) { + for (DataHarmPhasicV item : list6) { + RStatDataHarmphasicVDPO po1 = new RStatDataHarmphasicVDPO(); + BeanUtils.copyProperties(item, po1); + po1.setTime(LocalDate.parse(calculatedParam.getDataDate(), DatePattern.NORM_DATE_FORMATTER)); + po1.setQualityFlag(Integer.parseInt(item.getQualityFlag())); + dataHarmPhasicVPOList.add(po1); + + DayHarmPhasicV dayHarmPhasicV = new DayHarmPhasicV(); + BeanUtils.copyProperties(item, dayHarmPhasicV); + dayHarmPhasicV.setTime(DateUtil.parse(calculatedParam.getDataDate(), DatePattern.NORM_DATE_FORMATTER).toInstant()); + dayHarmPhasicVList.add(dayHarmPhasicV); + } + statDataHarmphasicVDService.insert(dataHarmPhasicVPOList); + dayHarmPhasicVMapper.insertBatch(dayHarmPhasicVList); + } + } + + @Override + public void dataHarmPowerPHardler(CalculatedParam calculatedParam) { + log.info(LocalDateTime.now() + "data_harmpower_p转r_stat_data_harmpower_p_d开始=====》"); + List list7 = new ArrayList<>(); + List dataHarmPowerPPOList = new ArrayList<>(); + List dayHarmPowerPList = new ArrayList<>(); + List lineIds = calculatedParam.getIdList(); + //河北数据量较大，单个监测点执行 + List> pendingIds = ListUtils.partition(lineIds,5); + String beginDay =LocalDateTimeUtil.format(LocalDateTimeUtil.beginOfDay(LocalDateTimeUtil.parse(calculatedParam.getDataDate(), DatePattern.NORM_DATE_PATTERN)),DatePattern.NORM_DATETIME_PATTERN); + String endDay = LocalDateTimeUtil.format(LocalDateTimeUtil.endOfDay(LocalDateTimeUtil.parse(calculatedParam.getDataDate(), DatePattern.NORM_DATE_PATTERN)),DatePattern.NORM_DATETIME_PATTERN); + for (List pendingId : pendingIds) { + //获取data_harmpower_p数据 + List dataHarmPowerPList = getDataHarmPowerP(pendingId,beginDay,endDay); + list7.addAll(dataHarmPowerPList); + } + //data_harmpower_p数据入库 + if (!CollectionUtils.isEmpty(list7)) { + for (DataHarmPowerP item : list7) { + RStatDataHarmpowerPDPO po1 = new RStatDataHarmpowerPDPO(); + BeanUtils.copyProperties(item, po1); + po1.setTime(LocalDate.parse(calculatedParam.getDataDate(), DatePattern.NORM_DATE_FORMATTER)); + po1.setQualityFlag(Integer.parseInt(item.getQualityFlag())); + dataHarmPowerPPOList.add(po1); + + DayHarmPowerP dayHarmPowerP = new DayHarmPowerP(); + BeanUtils.copyProperties(item, dayHarmPowerP); + dayHarmPowerP.setTime(DateUtil.parse(calculatedParam.getDataDate(), DatePattern.NORM_DATE_FORMATTER).toInstant()); + dayHarmPowerPList.add(dayHarmPowerP); + } + statDataHarmpowerPDService.insert(dataHarmPowerPPOList); + dayHarmPowerPMapper.insertBatch(dayHarmPowerPList); + } + } + + @Override + public void dataHarmPowerQHardler(CalculatedParam calculatedParam) { + log.info(LocalDateTime.now() + "data_harmpower_q转r_stat_data_harmpower_q_d开始=====》"); + List list8 = new ArrayList<>(); + List dataHarmPowerQPOList = new ArrayList<>(); + List dayHarmPowerQList = new ArrayList<>(); + + List lineIds = calculatedParam.getIdList(); + //河北数据量较大，单个监测点执行 + List> pendingIds = ListUtils.partition(lineIds,5); + String beginDay =LocalDateTimeUtil.format(LocalDateTimeUtil.beginOfDay(LocalDateTimeUtil.parse(calculatedParam.getDataDate(), DatePattern.NORM_DATE_PATTERN)),DatePattern.NORM_DATETIME_PATTERN); + String endDay = LocalDateTimeUtil.format(LocalDateTimeUtil.endOfDay(LocalDateTimeUtil.parse(calculatedParam.getDataDate(), DatePattern.NORM_DATE_PATTERN)),DatePattern.NORM_DATETIME_PATTERN); + for (List pendingId : pendingIds) { + //获取data_harmpower_q数据 + List dataHarmPowerQList = getDataHarmPowerQ(pendingId,beginDay,endDay); + list8.addAll(dataHarmPowerQList); + } + //data_harmpower_q数据入库 + if (!CollectionUtils.isEmpty(list8)) { + for (DataHarmPowerQ item : list8) { + RStatDataHarmpowerQDPO po1 = new RStatDataHarmpowerQDPO(); + BeanUtils.copyProperties(item, po1); + po1.setTime(LocalDate.parse(calculatedParam.getDataDate(), DatePattern.NORM_DATE_FORMATTER)); + po1.setQualityFlag(Integer.parseInt(item.getQualityFlag())); + dataHarmPowerQPOList.add(po1); + + DayHarmPowerQ dayHarmPowerQ = new DayHarmPowerQ(); + BeanUtils.copyProperties(item, dayHarmPowerQ); + dayHarmPowerQ.setTime(DateUtil.parse(calculatedParam.getDataDate(), DatePattern.NORM_DATE_FORMATTER).toInstant()); + dayHarmPowerQList.add(dayHarmPowerQ); + } + statDataHarmpowerQDService.insert(dataHarmPowerQPOList); + dayHarmPowerQMapper.insertBatch(dayHarmPowerQList); + } + } + + @Override + public void dataHarmPowerSHardler(CalculatedParam calculatedParam) { + log.info(LocalDateTime.now() + "data_harmpower_s转r_stat_data_harmpower_s_d开始=====》"); + List list9 = new ArrayList<>(); + List dataHarmPowerSPOList = new ArrayList<>(); + List dayHarmPowerSList = new ArrayList<>(); + + List lineIds = calculatedParam.getIdList(); + //河北数据量较大，单个监测点执行 + List> pendingIds = ListUtils.partition(lineIds,5); + String beginDay =LocalDateTimeUtil.format(LocalDateTimeUtil.beginOfDay(LocalDateTimeUtil.parse(calculatedParam.getDataDate(), DatePattern.NORM_DATE_PATTERN)),DatePattern.NORM_DATETIME_PATTERN); + String endDay = LocalDateTimeUtil.format(LocalDateTimeUtil.endOfDay(LocalDateTimeUtil.parse(calculatedParam.getDataDate(), DatePattern.NORM_DATE_PATTERN)),DatePattern.NORM_DATETIME_PATTERN); + for (List pendingId : pendingIds) { + //获取data_harmpower_s数据 + List dataHarmPowerSList = getDataHarmPowerS(pendingId,beginDay,endDay); + list9.addAll(dataHarmPowerSList); + } + //data_harmpower_s数据入库 + if (!CollectionUtils.isEmpty(list9)) { + for (DataHarmPowerS item : list9) { + RStatDataHarmpowerSDPO po1 = new RStatDataHarmpowerSDPO(); + BeanUtils.copyProperties(item, po1); + po1.setTime(LocalDate.parse(calculatedParam.getDataDate(), DatePattern.NORM_DATE_FORMATTER)); + po1.setQualityFlag(Integer.parseInt(item.getQualityFlag())); + dataHarmPowerSPOList.add(po1); + + DayHarmPowerS dayHarmPowerS = new DayHarmPowerS(); + BeanUtils.copyProperties(item, dayHarmPowerS); + dayHarmPowerS.setTime(DateUtil.parse(calculatedParam.getDataDate(), DatePattern.NORM_DATE_FORMATTER).toInstant()); + dayHarmPowerSList.add(dayHarmPowerS); + } + statDataHarmpowerSDService.insert(dataHarmPowerSPOList); + dayHarmPowerSMapper.insertBatch(dayHarmPowerSList); + } + } + + @Override + public void dataHarmRateIHardler(CalculatedParam calculatedParam) { + log.info(LocalDateTime.now() + "data_harmrate_i转r_stat_data_harmrate_i_d开始=====》"); + List list10 = new ArrayList<>(); + List dataHarmRateIPOList = new ArrayList<>(); + List dayHarmRateIList = new ArrayList<>(); + + List lineIds = calculatedParam.getIdList(); + //河北数据量较大，单个监测点执行 + List> pendingIds = ListUtils.partition(lineIds,5); + String beginDay =LocalDateTimeUtil.format(LocalDateTimeUtil.beginOfDay(LocalDateTimeUtil.parse(calculatedParam.getDataDate(), DatePattern.NORM_DATE_PATTERN)),DatePattern.NORM_DATETIME_PATTERN); + String endDay = LocalDateTimeUtil.format(LocalDateTimeUtil.endOfDay(LocalDateTimeUtil.parse(calculatedParam.getDataDate(), DatePattern.NORM_DATE_PATTERN)),DatePattern.NORM_DATETIME_PATTERN); + for (List pendingId : pendingIds) { + //获取data_harmrate_i数据 + List dataHarmRateIList = getDataHarmRateI(pendingId,beginDay,endDay); + list10.addAll(dataHarmRateIList); + } + //data_harmrate_i数据入库 + if (!CollectionUtils.isEmpty(list10)) { + for (DataHarmRateI item : list10) { + RStatDataHarmrateIDPO po1 = new RStatDataHarmrateIDPO(); + BeanUtils.copyProperties(item, po1); + po1.setTime(LocalDate.parse(calculatedParam.getDataDate(), DatePattern.NORM_DATE_FORMATTER)); + po1.setQualityFlag(Integer.parseInt(item.getQualityFlag())); + dataHarmRateIPOList.add(po1); + + DayHarmRateI dayHarmRateI = new DayHarmRateI(); + BeanUtils.copyProperties(item, dayHarmRateI); + dayHarmRateI.setTime(DateUtil.parse(calculatedParam.getDataDate(), DatePattern.NORM_DATE_FORMATTER).toInstant()); + dayHarmRateIList.add(dayHarmRateI); + } + statDataHarmRateIDService.insert(dataHarmRateIPOList); + dayHarmRateIMapper.insertBatch(dayHarmRateIList); + } + } + + @Override + public void dataHarmRateVHardler(CalculatedParam calculatedParam) { + log.info(LocalDateTime.now() + "data_harmrate_v转r_stat_data_harmrate_v_d开始=====》"); + List list11 = new ArrayList<>(); + List dataHarmRateVPOList = new ArrayList<>(); + List dayHarmRateVList = new ArrayList<>(); + + List lineIds = calculatedParam.getIdList(); + //河北数据量较大，单个监测点执行 + List> pendingIds = ListUtils.partition(lineIds,5); + String beginDay =LocalDateTimeUtil.format(LocalDateTimeUtil.beginOfDay(LocalDateTimeUtil.parse(calculatedParam.getDataDate(), DatePattern.NORM_DATE_PATTERN)),DatePattern.NORM_DATETIME_PATTERN); + String endDay = LocalDateTimeUtil.format(LocalDateTimeUtil.endOfDay(LocalDateTimeUtil.parse(calculatedParam.getDataDate(), DatePattern.NORM_DATE_PATTERN)),DatePattern.NORM_DATETIME_PATTERN); + for (List pendingId : pendingIds) { + //获取data_harmrate_v数据 + List dataHarmRateVList = getDataHarmRateV(pendingId,beginDay,endDay); + list11.addAll(dataHarmRateVList); + } + //data_harmrate_v数据入库 + if (!CollectionUtils.isEmpty(list11)) { + for (DataHarmRateV item : list11) { + RStatDataHarmrateVDPO po1 = new RStatDataHarmrateVDPO(); + BeanUtils.copyProperties(item, po1); + po1.setTime(LocalDate.parse(calculatedParam.getDataDate(), DatePattern.NORM_DATE_FORMATTER)); + po1.setQualityFlag(Integer.parseInt(item.getQualityFlag())); + dataHarmRateVPOList.add(po1); + + DayHarmRateV dayHarmRateV = new DayHarmRateV(); + BeanUtils.copyProperties(item, dayHarmRateV); + dayHarmRateV.setTime(DateUtil.parse(calculatedParam.getDataDate(), DatePattern.NORM_DATE_FORMATTER).toInstant()); + dayHarmRateVList.add(dayHarmRateV); + } + statDataHarmRateVDService.insert(dataHarmRateVPOList); + dayHarmRateVMapper.insertBatch(dayHarmRateVList); + } + } + + @Override + public void dataInHarmIHardler(CalculatedParam calculatedParam) { + log.info(LocalDateTime.now() + "data_inharm_i转r_stat_data_inharm_i_d开始=====》"); + List list12 = new ArrayList<>(); + List dataInHarmIPOList = new ArrayList<>(); + List dayInHarmIList = new ArrayList<>(); + + List lineIds = calculatedParam.getIdList(); + //河北数据量较大，单个监测点执行 + List> pendingIds = ListUtils.partition(lineIds,5); + String beginDay =LocalDateTimeUtil.format(LocalDateTimeUtil.beginOfDay(LocalDateTimeUtil.parse(calculatedParam.getDataDate(), DatePattern.NORM_DATE_PATTERN)),DatePattern.NORM_DATETIME_PATTERN); + String endDay = LocalDateTimeUtil.format(LocalDateTimeUtil.endOfDay(LocalDateTimeUtil.parse(calculatedParam.getDataDate(), DatePattern.NORM_DATE_PATTERN)),DatePattern.NORM_DATETIME_PATTERN); + for (List pendingId : pendingIds) { + //获取data_inharm_i数据 + List dataInHarmIList = getDataInHarmI(pendingId,beginDay,endDay); + list12.addAll(dataInHarmIList); + } + //data_inharm_i数据入库 + if (!CollectionUtils.isEmpty(list12)) { + for (DataInHarmI item : list12) { + RStatDataInharmIDPO po1 = new RStatDataInharmIDPO(); + BeanUtils.copyProperties(item, po1); + po1.setTime(LocalDate.parse(calculatedParam.getDataDate(), DatePattern.NORM_DATE_FORMATTER)); + po1.setQualityFlag(Integer.parseInt(item.getQualityFlag())); + dataInHarmIPOList.add(po1); + + DayInHarmI dayInHarmI = new DayInHarmI(); + BeanUtils.copyProperties(item, dayInHarmI); + dayInHarmI.setTime(DateUtil.parse(calculatedParam.getDataDate(), DatePattern.NORM_DATE_FORMATTER).toInstant()); + dayInHarmIList.add(dayInHarmI); + } + statDataInharmIDService.insert(dataInHarmIPOList); + dayInHarmIMapper.insertBatch(dayInHarmIList); + } + } + + @Override + public void dataInHarmVHardler(CalculatedParam calculatedParam) { + log.info(LocalDateTime.now() + "data_inharm_v转r_stat_data_inharm_v_d开始=====》"); + List list13 = new ArrayList<>(); + List dataInHarmVPOList = new ArrayList<>(); + List dayInHarmVList = new ArrayList<>(); + + List lineIds = calculatedParam.getIdList(); + //河北数据量较大，单个监测点执行 + List> pendingIds = ListUtils.partition(lineIds,5); + String beginDay =LocalDateTimeUtil.format(LocalDateTimeUtil.beginOfDay(LocalDateTimeUtil.parse(calculatedParam.getDataDate(), DatePattern.NORM_DATE_PATTERN)),DatePattern.NORM_DATETIME_PATTERN); + String endDay = LocalDateTimeUtil.format(LocalDateTimeUtil.endOfDay(LocalDateTimeUtil.parse(calculatedParam.getDataDate(), DatePattern.NORM_DATE_PATTERN)),DatePattern.NORM_DATETIME_PATTERN); + for (List pendingId : pendingIds) { + //获取data_inharm_v数据 + List dataInHarmVList = getDataInHarmV(pendingId,beginDay,endDay); + list13.addAll(dataInHarmVList); + } + //data_inharm_v数据入库 + if (!CollectionUtils.isEmpty(list13)) { + for (DataInHarmV item : list13) { + RStatDataInharmVDPO po1 = new RStatDataInharmVDPO(); + BeanUtils.copyProperties(item, po1); + po1.setTime(LocalDate.parse(calculatedParam.getDataDate(), DatePattern.NORM_DATE_FORMATTER)); + po1.setQualityFlag(Integer.parseInt(item.getQualityFlag())); + dataInHarmVPOList.add(po1); + + DayInHarmV dayInHarmV = new DayInHarmV(); + BeanUtils.copyProperties(item, dayInHarmV); + dayInHarmV.setTime(DateUtil.parse(calculatedParam.getDataDate(), DatePattern.NORM_DATE_FORMATTER).toInstant()); + dayInHarmVList.add(dayInHarmV); + } + statDataInharmVDService.insert(dataInHarmVPOList); + dayInHarmVMapper.insertBatch(dayInHarmVList); + } + } + + @Override + public void dataPltHardler(CalculatedParam calculatedParam) { + log.info(LocalDateTime.now() + "data_plt转r_stat_data_plt_d开始=====》"); + List list16 = new ArrayList<>(); + List dataPltPOList = new ArrayList<>(); + List dayPltList = new ArrayList<>(); + + List lineIds = calculatedParam.getIdList(); + //河北数据量较大，单个监测点执行 + List> pendingIds = ListUtils.partition(lineIds,5); + String beginDay =LocalDateTimeUtil.format(LocalDateTimeUtil.beginOfDay(LocalDateTimeUtil.parse(calculatedParam.getDataDate(), DatePattern.NORM_DATE_PATTERN)),DatePattern.NORM_DATETIME_PATTERN); + String endDay = LocalDateTimeUtil.format(LocalDateTimeUtil.endOfDay(LocalDateTimeUtil.parse(calculatedParam.getDataDate(), DatePattern.NORM_DATE_PATTERN)),DatePattern.NORM_DATETIME_PATTERN); + for (List pendingId : pendingIds) { + //获取data_plt数据 + List dataPltList = getDataPlt(pendingId,beginDay,endDay); + list16.addAll(dataPltList); + } + //data_plt数据入库 + if (!CollectionUtils.isEmpty(list16)) { + for (DataPlt item : list16) { + RStatDataPltDPO po1 = new RStatDataPltDPO(); + BeanUtils.copyProperties(item, po1); + po1.setTime(LocalDate.parse(calculatedParam.getDataDate(), DatePattern.NORM_DATE_FORMATTER)); + po1.setQualityFlag(Integer.parseInt(item.getQualityFlag())); + dataPltPOList.add(po1); + + DayPlt dayPlt = new DayPlt(); + BeanUtils.copyProperties(item, dayPlt); + dayPlt.setTime(DateUtil.parse(calculatedParam.getDataDate(), DatePattern.NORM_DATE_FORMATTER).toInstant()); + dayPltList.add(dayPlt); + } + statDataPltDService.insert(dataPltPOList); + dayPltMapper.insertBatch(dayPltList); + } + } + + @Override @Transactional(rollbackFor = {Exception.class}) public void dataToDayHandler(CalculatedParam calculatedParam) { diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/line/DayDataService.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/line/DayDataService.java index 15d150ab5..8b77da39b 100644 --- a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/line/DayDataService.java +++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/line/DayDataService.java @@ -20,4 +20,116 @@ public interface DayDataService { */ void dataToDayHandler(CalculatedParam calculatedParam); + /*** + * dataV转r_stat_data_v_d + * @author xuyang + * @date 2024/01/18 21:18 + * @param calculatedParam 查询条件 + */ + void dataVHardler(CalculatedParam calculatedParam); + + /*** + * dataI转r_stat_data_i_d + * @author xuyang + * @date 2024/01/18 21:18 + * @param calculatedParam 查询条件 + */ + void dataIHardler(CalculatedParam calculatedParam); + + /*** + * dataFlicker转r_stat_data_flicker_d + * @author xuyang + * @date 2024/01/18 21:18 + * @param calculatedParam 查询条件 + */ + void dataFlickerHardler(CalculatedParam calculatedParam); + + /*** + * dataFluc转r_stat_data_fluc_d + * @author xuyang + * @date 2024/01/18 21:18 + * @param calculatedParam 查询条件 + */ + void dataFlucHardler(CalculatedParam calculatedParam); + + /*** + * data_harmphasic_i转r_stat_data_harmphasic_i_d + * @author xuyang + * @date 2024/01/18 21:18 + * @param calculatedParam 查询条件 + */ + void dataHarmPhasicIHardler(CalculatedParam calculatedParam); + + /*** + * data_harmphasic_v转r_stat_data_harmphasic_v_d + * @author xuyang + * @date 2024/01/18 21:18 + * @param calculatedParam 查询条件 + */ + void dataHarmPhasicVHardler(CalculatedParam calculatedParam); + + /*** + * data_harmpower_p转r_stat_data_harmpower_p_d + * @author xuyang + * @date 2024/01/18 21:18 + * @param calculatedParam 查询条件 + */ + void dataHarmPowerPHardler(CalculatedParam calculatedParam); + + /*** + * data_harmpower_q转r_stat_data_harmpower_q_d + * @author xuyang + * @date 2024/01/18 21:18 + * @param calculatedParam 查询条件 + */ + void dataHarmPowerQHardler(CalculatedParam calculatedParam); + + /*** + * data_harmpower_s转r_stat_data_harmpower_s_d + * @author xuyang + * @date 2024/01/18 21:18 + * @param calculatedParam 查询条件 + */ + void dataHarmPowerSHardler(CalculatedParam calculatedParam); + + /*** + * data_harmrate_i转r_stat_data_harmrate_i_d + * @author xuyang + * @date 2024/01/18 21:18 + * @param calculatedParam 查询条件 + */ + void dataHarmRateIHardler(CalculatedParam calculatedParam); + + /*** + * data_harmrate_v转r_stat_data_harmrate_v_d + * @author xuyang + * @date 2024/01/18 21:18 + * @param calculatedParam 查询条件 + */ + void dataHarmRateVHardler(CalculatedParam calculatedParam); + + /*** + * data_inharm_i转r_stat_data_inharm_i_d + * @author xuyang + * @date 2024/01/18 21:18 + * @param calculatedParam 查询条件 + */ + void dataInHarmIHardler(CalculatedParam calculatedParam); + + /*** + * data_inharm_v转r_stat_data_inharm_v_d + * @author xuyang + * @date 2024/01/18 21:18 + * @param calculatedParam 查询条件 + */ + void dataInHarmVHardler(CalculatedParam calculatedParam); + + /*** + * data_plt转r_stat_data_plt_d + * @author xuyang + * @date 2024/01/18 21:18 + * @param calculatedParam 查询条件 + */ + void dataPltHardler(CalculatedParam calculatedParam); + }