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

河北超高压算法调整

Browse Source
This commit is contained in:
xuyang
2024-01-19 08:45:53 +08:00
parent 61df7a2ca6
commit 3c9aaa1608
3 changed files with 712 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

99
pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/executor/MeasurementExecutor.java
View File

@@ -213,6 +213,105 @@ public class MeasurementExecutor extends BaseExecutor {
dayDataService.dataToDayHandler(bindCmp.getRequestData()); 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) * 算法名: 暂无-----监测点数据完整性_日表(r_stat_integrity_d)
* *

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

@@ -91,6 +91,507 @@ public class DayDataServiceImpl implements DayDataService {
private final DataInHarmRateVMapper dataInHarmRateVMapper; private final DataInHarmRateVMapper dataInHarmRateVMapper;
private final DataPltMapper dataPltMapper; private final DataPltMapper dataPltMapper;
@Override
public void dataVHardler(CalculatedParam calculatedParam) {
log.info(LocalDateTime.now() + "dataV表转r_stat_data_v_d开始=====》");
List<DataV> list1 = new ArrayList<>();
List<RStatDataVDPO> dataVPOList = new ArrayList<>();
List<DayV> dayVList = new ArrayList<>();
List<String> lineIds = calculatedParam.getIdList();
//河北数据量较大，单个监测点执行
List<List<String>> 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<String> pendingId : pendingIds) {
//获取dataV数据
List<DataV> 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<DataI> list2 = new ArrayList<>();
List<RStatDataIDPO> dataIPOList = new ArrayList<>();
List<DayI> dayIList = new ArrayList<>();
List<String> lineIds = calculatedParam.getIdList();
//河北数据量较大，单个监测点执行
List<List<String>> 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<String> pendingId : pendingIds) {
//获取dataI数据
List<DataI> 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<DataFlicker> list3 = new ArrayList<>();
List<RStatDataFlickerDPO> dataFlickerPOList = new ArrayList<>();
List<DayFlicker> dayFlickerList = new ArrayList<>();
List<String> lineIds = calculatedParam.getIdList();
//河北数据量较大，单个监测点执行
List<List<String>> 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<String> pendingId : pendingIds) {
//获取dataFlicker数据
List<DataFlicker> 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<DataFluc> list4 = new ArrayList<>();
List<RStatDataFlucDPO> dataFlucPOList = new ArrayList<>();
List<DayFluc> dayFlucList = new ArrayList<>();
List<String> lineIds = calculatedParam.getIdList();
//河北数据量较大，单个监测点执行
List<List<String>> 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<String> pendingId : pendingIds) {
//获取dataFluc数据
List<DataFluc> 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<DataHarmPhasicI> list5 = new ArrayList<>();
List<RStatDataHarmphasicIDPO> dataHarmPhasicIPOList = new ArrayList<>();
List<DayHarmPhasicI> dayHarmPhasicIList = new ArrayList<>();
List<String> lineIds = calculatedParam.getIdList();
//河北数据量较大，单个监测点执行
List<List<String>> 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<String> pendingId : pendingIds) {
//获取DataHarmPhasicI数据
List<DataHarmPhasicI> 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<DataHarmPhasicV> list6 = new ArrayList<>();
List<RStatDataHarmphasicVDPO> dataHarmPhasicVPOList = new ArrayList<>();
List<DayHarmPhasicV> dayHarmPhasicVList = new ArrayList<>();
List<String> lineIds = calculatedParam.getIdList();
//河北数据量较大，单个监测点执行
List<List<String>> 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<String> pendingId : pendingIds) {
//获取DataHarmPhasicV数据
List<DataHarmPhasicV> 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<DataHarmPowerP> list7 = new ArrayList<>();
List<RStatDataHarmpowerPDPO> dataHarmPowerPPOList = new ArrayList<>();
List<DayHarmPowerP> dayHarmPowerPList = new ArrayList<>();
List<String> lineIds = calculatedParam.getIdList();
//河北数据量较大，单个监测点执行
List<List<String>> 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<String> pendingId : pendingIds) {
//获取data_harmpower_p数据
List<DataHarmPowerP> 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<DataHarmPowerQ> list8 = new ArrayList<>();
List<RStatDataHarmpowerQDPO> dataHarmPowerQPOList = new ArrayList<>();
List<DayHarmPowerQ> dayHarmPowerQList = new ArrayList<>();
List<String> lineIds = calculatedParam.getIdList();
//河北数据量较大，单个监测点执行
List<List<String>> 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<String> pendingId : pendingIds) {
//获取data_harmpower_q数据
List<DataHarmPowerQ> 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<DataHarmPowerS> list9 = new ArrayList<>();
List<RStatDataHarmpowerSDPO> dataHarmPowerSPOList = new ArrayList<>();
List<DayHarmPowerS> dayHarmPowerSList = new ArrayList<>();
List<String> lineIds = calculatedParam.getIdList();
//河北数据量较大，单个监测点执行
List<List<String>> 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<String> pendingId : pendingIds) {
//获取data_harmpower_s数据
List<DataHarmPowerS> 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<DataHarmRateI> list10 = new ArrayList<>();
List<RStatDataHarmrateIDPO> dataHarmRateIPOList = new ArrayList<>();
List<DayHarmRateI> dayHarmRateIList = new ArrayList<>();
List<String> lineIds = calculatedParam.getIdList();
//河北数据量较大，单个监测点执行
List<List<String>> 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<String> pendingId : pendingIds) {
//获取data_harmrate_i数据
List<DataHarmRateI> 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<DataHarmRateV> list11 = new ArrayList<>();
List<RStatDataHarmrateVDPO> dataHarmRateVPOList = new ArrayList<>();
List<DayHarmRateV> dayHarmRateVList = new ArrayList<>();
List<String> lineIds = calculatedParam.getIdList();
//河北数据量较大，单个监测点执行
List<List<String>> 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<String> pendingId : pendingIds) {
//获取data_harmrate_v数据
List<DataHarmRateV> 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<DataInHarmI> list12 = new ArrayList<>();
List<RStatDataInharmIDPO> dataInHarmIPOList = new ArrayList<>();
List<DayInHarmI> dayInHarmIList = new ArrayList<>();
List<String> lineIds = calculatedParam.getIdList();
//河北数据量较大，单个监测点执行
List<List<String>> 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<String> pendingId : pendingIds) {
//获取data_inharm_i数据
List<DataInHarmI> 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<DataInHarmV> list13 = new ArrayList<>();
List<RStatDataInharmVDPO> dataInHarmVPOList = new ArrayList<>();
List<DayInHarmV> dayInHarmVList = new ArrayList<>();
List<String> lineIds = calculatedParam.getIdList();
//河北数据量较大，单个监测点执行
List<List<String>> 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<String> pendingId : pendingIds) {
//获取data_inharm_v数据
List<DataInHarmV> 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<DataPlt> list16 = new ArrayList<>();
List<RStatDataPltDPO> dataPltPOList = new ArrayList<>();
List<DayPlt> dayPltList = new ArrayList<>();
List<String> lineIds = calculatedParam.getIdList();
//河北数据量较大，单个监测点执行
List<List<String>> 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<String> pendingId : pendingIds) {
//获取data_plt数据
List<DataPlt> 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 @Override
@Transactional(rollbackFor = {Exception.class}) @Transactional(rollbackFor = {Exception.class})
public void dataToDayHandler(CalculatedParam calculatedParam) { public void dataToDayHandler(CalculatedParam calculatedParam) {

112
pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/line/DayDataService.java
View File

@@ -20,4 +20,116 @@ public interface DayDataService {
*/ */
void dataToDayHandler(CalculatedParam<?> calculatedParam); 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);
} }