部分日表算法
This commit is contained in:
@@ -155,7 +155,6 @@ public class MeasurementExecutor extends BaseExecutor {
|
||||
}
|
||||
|
||||
|
||||
|
||||
/**
|
||||
* 监测点报表_日表(r_stat_data_*_d)
|
||||
* @author xy
|
||||
@@ -169,4 +168,67 @@ public class MeasurementExecutor extends BaseExecutor {
|
||||
dayDataService.dataVHandler(bindCmp.getRequestData());
|
||||
}
|
||||
|
||||
@LiteflowMethod(value = LiteFlowMethodEnum.IS_ACCESS, nodeId = "dataI", nodeType = NodeTypeEnum.COMMON)
|
||||
public boolean dataIToDayAccess(NodeComponent bindCmp) {
|
||||
return isAccess(bindCmp);
|
||||
}
|
||||
@LiteflowMethod(value = LiteFlowMethodEnum.PROCESS, nodeId = "dataI", nodeType = NodeTypeEnum.COMMON)
|
||||
public void dataIToDayProcess(NodeComponent bindCmp) {
|
||||
dayDataService.dataIHandler(bindCmp.getRequestData());
|
||||
}
|
||||
|
||||
@LiteflowMethod(value = LiteFlowMethodEnum.IS_ACCESS, nodeId = "dataFlicker", nodeType = NodeTypeEnum.COMMON)
|
||||
public boolean dataFlickerToDayAccess(NodeComponent bindCmp) {
|
||||
return isAccess(bindCmp);
|
||||
}
|
||||
@LiteflowMethod(value = LiteFlowMethodEnum.PROCESS, nodeId = "dataFlicker", nodeType = NodeTypeEnum.COMMON)
|
||||
public void dataFlickerToDayProcess(NodeComponent bindCmp) {
|
||||
dayDataService.dataFlickerHandler(bindCmp.getRequestData());
|
||||
}
|
||||
|
||||
@LiteflowMethod(value = LiteFlowMethodEnum.IS_ACCESS, nodeId = "dataFluc", nodeType = NodeTypeEnum.COMMON)
|
||||
public boolean dataFlucToDayAccess(NodeComponent bindCmp) {
|
||||
return isAccess(bindCmp);
|
||||
}
|
||||
@LiteflowMethod(value = LiteFlowMethodEnum.PROCESS, nodeId = "dataFluc", nodeType = NodeTypeEnum.COMMON)
|
||||
public void dataFlucToDayProcess(NodeComponent bindCmp) {
|
||||
dayDataService.dataFlucHandler(bindCmp.getRequestData());
|
||||
}
|
||||
|
||||
@LiteflowMethod(value = LiteFlowMethodEnum.IS_ACCESS, nodeId = "dataHarmPhasicI", nodeType = NodeTypeEnum.COMMON)
|
||||
public boolean dataHarmPhasicIToDayAccess(NodeComponent bindCmp) {
|
||||
return isAccess(bindCmp);
|
||||
}
|
||||
@LiteflowMethod(value = LiteFlowMethodEnum.PROCESS, nodeId = "dataHarmPhasicI", nodeType = NodeTypeEnum.COMMON)
|
||||
public void dataHarmPhasicIToDayProcess(NodeComponent bindCmp) {
|
||||
dayDataService.dataHarmPhasicIHandler(bindCmp.getRequestData());
|
||||
}
|
||||
|
||||
@LiteflowMethod(value = LiteFlowMethodEnum.IS_ACCESS, nodeId = "dataHarmPhasicV", nodeType = NodeTypeEnum.COMMON)
|
||||
public boolean dataHarmPhasicVToDayAccess(NodeComponent bindCmp) {
|
||||
return isAccess(bindCmp);
|
||||
}
|
||||
@LiteflowMethod(value = LiteFlowMethodEnum.PROCESS, nodeId = "dataHarmPhasicV", nodeType = NodeTypeEnum.COMMON)
|
||||
public void dataHarmPhasicVToDayProcess(NodeComponent bindCmp) {
|
||||
dayDataService.dataHarmPhasicVHandler(bindCmp.getRequestData());
|
||||
}
|
||||
|
||||
@LiteflowMethod(value = LiteFlowMethodEnum.IS_ACCESS, nodeId = "dataHarmPowerP", nodeType = NodeTypeEnum.COMMON)
|
||||
public boolean dataHarmPowerPToDayAccess(NodeComponent bindCmp) {
|
||||
return isAccess(bindCmp);
|
||||
}
|
||||
@LiteflowMethod(value = LiteFlowMethodEnum.PROCESS, nodeId = "dataHarmPowerP", nodeType = NodeTypeEnum.COMMON)
|
||||
public void dataHarmPowerPToDayProcess(NodeComponent bindCmp) {
|
||||
dayDataService.dataHarmPowerPHandler(bindCmp.getRequestData());
|
||||
}
|
||||
|
||||
@LiteflowMethod(value = LiteFlowMethodEnum.IS_ACCESS, nodeId = "dataHarmPowerQ", nodeType = NodeTypeEnum.COMMON)
|
||||
public boolean dataHarmPowerQToDayAccess(NodeComponent bindCmp) {
|
||||
return isAccess(bindCmp);
|
||||
}
|
||||
@LiteflowMethod(value = LiteFlowMethodEnum.PROCESS, nodeId = "dataHarmPowerQ", nodeType = NodeTypeEnum.COMMON)
|
||||
public void dataHarmPowerQToDayProcess(NodeComponent bindCmp) {
|
||||
dayDataService.dataHarmPowerQHandler(bindCmp.getRequestData());
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
@@ -16,4 +16,60 @@ public interface IDayDataService {
|
||||
*/
|
||||
void dataVHandler(CalculatedParam calculatedParam);
|
||||
|
||||
/***
|
||||
* dataI转r_stat_data_i_d
|
||||
* @author xuyang
|
||||
* @date 2025/01/18 21:18
|
||||
* @param calculatedParam 查询条件
|
||||
*/
|
||||
void dataIHandler(CalculatedParam calculatedParam);
|
||||
|
||||
/***
|
||||
* dataFlicker转r_stat_data_flicker_d
|
||||
* @author xuyang
|
||||
* @date 2025/01/18 21:18
|
||||
* @param calculatedParam 查询条件
|
||||
*/
|
||||
void dataFlickerHandler(CalculatedParam calculatedParam);
|
||||
|
||||
/***
|
||||
* dataFluc转r_stat_data_fluc_d
|
||||
* @author xuyang
|
||||
* @date 2025/01/18 21:18
|
||||
* @param calculatedParam 查询条件
|
||||
*/
|
||||
void dataFlucHandler(CalculatedParam calculatedParam);
|
||||
|
||||
/***
|
||||
* dataHarmPhasicI转r_stat_data_harmphasic_i_d
|
||||
* @author xuyang
|
||||
* @date 2025/01/18 21:18
|
||||
* @param calculatedParam 查询条件
|
||||
*/
|
||||
void dataHarmPhasicIHandler(CalculatedParam calculatedParam);
|
||||
|
||||
/***
|
||||
* dataHarmPhasicV转r_stat_data_harmphasic_v_d
|
||||
* @author xuyang
|
||||
* @date 2025/01/18 21:18
|
||||
* @param calculatedParam 查询条件
|
||||
*/
|
||||
void dataHarmPhasicVHandler(CalculatedParam calculatedParam);
|
||||
|
||||
/***
|
||||
* dataHarmPowerP转r_stat_data_harmpower_p_d
|
||||
* @author xuyang
|
||||
* @date 2025/01/18 21:18
|
||||
* @param calculatedParam 查询条件
|
||||
*/
|
||||
void dataHarmPowerPHandler(CalculatedParam calculatedParam);
|
||||
|
||||
/***
|
||||
* dataHarmPowerQ转r_stat_data_harmpower_q_d
|
||||
* @author xuyang
|
||||
* @date 2025/01/18 21:18
|
||||
* @param calculatedParam 查询条件
|
||||
*/
|
||||
void dataHarmPowerQHandler(CalculatedParam calculatedParam);
|
||||
|
||||
}
|
||||
|
||||
@@ -3,15 +3,14 @@ package com.njcn.algorithm.serviceimpl.line;
|
||||
import cn.hutool.core.collection.CollUtil;
|
||||
import com.njcn.algorithm.pojo.bo.CalculatedParam;
|
||||
import com.njcn.algorithm.service.line.IDayDataService;
|
||||
import com.njcn.dataProcess.api.DataVFeignClient;
|
||||
import com.njcn.dataProcess.api.PqDataVerifyFeignClient;
|
||||
import com.njcn.dataProcess.api.*;
|
||||
import com.njcn.dataProcess.enums.DataCleanEnum;
|
||||
import com.njcn.dataProcess.param.LineCountEvaluateParam;
|
||||
import com.njcn.dataProcess.pojo.dto.CommonMinuteDto;
|
||||
import com.njcn.dataProcess.pojo.dto.DataVDto;
|
||||
import com.njcn.dataProcess.pojo.dto.*;
|
||||
import com.njcn.dataProcess.pojo.po.PqDataVerify;
|
||||
import com.njcn.dataProcess.util.TimeUtils;
|
||||
import com.njcn.influx.constant.InfluxDbSqlConstant;
|
||||
import com.njcn.influx.pojo.po.DataHarmPowerQ;
|
||||
import lombok.RequiredArgsConstructor;
|
||||
import lombok.extern.slf4j.Slf4j;
|
||||
import org.apache.commons.collections4.ListUtils;
|
||||
@@ -36,6 +35,22 @@ public class DayDataServiceImpl implements IDayDataService {
|
||||
private final static Integer NUM = 100;
|
||||
@Resource
|
||||
private DataVFeignClient dataVFeignClient;
|
||||
@Resource
|
||||
private DataIFeignClient dataIFeignClient;
|
||||
@Resource
|
||||
private DataFlickerFeignClient dataFlickerFeignClient;
|
||||
@Resource
|
||||
private DataFlucFeignClient dataFlucFeignClient;
|
||||
@Resource
|
||||
private DataHarmphasicIFeignClient dataHarmphasicIFeignClient;
|
||||
@Resource
|
||||
private DataHarmphasicVFeignClient dataHarmphasicVFeignClient;
|
||||
@Resource
|
||||
private DataHarmpowerPFeignClient dataHarmpowerPFeignClient;
|
||||
@Resource
|
||||
private DataHarmpowerQFeignClient dataHarmpowerQFeignClient;
|
||||
|
||||
|
||||
@Resource
|
||||
private PqDataVerifyFeignClient pqDataVerifyFeignClient;
|
||||
|
||||
@@ -70,7 +85,7 @@ public class DayDataServiceImpl implements IDayDataService {
|
||||
dto.setLineId(item.getLineId());
|
||||
dto.setPhasicType(item2.getPhasicType());
|
||||
dto.setValueType(item3.getValueType());
|
||||
dto.setQualityFlag(item.getQualityFlag());
|
||||
dto.setQualityFlag(Objects.equals(item.getQualityFlag(),"null") ? "0" : item.getQualityFlag());
|
||||
channelDataVHandler(item3,valueTypes,dto,true);
|
||||
result.add(dto);
|
||||
});
|
||||
@@ -84,6 +99,324 @@ public class DayDataServiceImpl implements IDayDataService {
|
||||
}
|
||||
}
|
||||
|
||||
@Override
|
||||
public void dataIHandler(CalculatedParam calculatedParam) {
|
||||
logger.info("{},dataI表转r_stat_data_i_d算法开始=====》", LocalDateTime.now());
|
||||
List<DataIDto> result = new ArrayList<>();
|
||||
//远程接口获取分钟数据
|
||||
LineCountEvaluateParam lineParam = new LineCountEvaluateParam();
|
||||
lineParam.setStartTime(TimeUtils.getBeginOfDay(calculatedParam.getDataDate()));
|
||||
lineParam.setEndTime(TimeUtils.getEndOfDay(calculatedParam.getDataDate()));
|
||||
//以100个监测点分片处理
|
||||
List<List<String>> pendingIds = ListUtils.partition(calculatedParam.getIdList(),NUM);
|
||||
pendingIds.forEach(list->{
|
||||
lineParam.setLineId(list);
|
||||
//添加异常数据时间点
|
||||
getAbnormalData(lineParam);
|
||||
//获取原始数据
|
||||
List<CommonMinuteDto> partList = dataIFeignClient.getBaseData(lineParam).getData();
|
||||
if (CollUtil.isNotEmpty(partList)) {
|
||||
partList.forEach(item->{
|
||||
//相别
|
||||
List<CommonMinuteDto.PhasicType> phasicTypeList = item.getPhasicTypeList();
|
||||
phasicTypeList.forEach(item2->{
|
||||
//数据类型
|
||||
List<CommonMinuteDto.ValueType> valueTypeList = item2.getValueTypeList();
|
||||
//获取平均值集合
|
||||
CommonMinuteDto.ValueType valueTypes = valueTypeList.stream().filter(type-> type.getValueType().equalsIgnoreCase(InfluxDbSqlConstant.AVG_WEB)).findFirst().orElse(null);
|
||||
valueTypeList.forEach(item3->{
|
||||
DataIDto dto = new DataIDto();
|
||||
dto.setTime(item.getTime());
|
||||
dto.setLineId(item.getLineId());
|
||||
dto.setPhasicType(item2.getPhasicType());
|
||||
dto.setValueType(item3.getValueType());
|
||||
dto.setQualityFlag(Objects.equals(item.getQualityFlag(),"null") ? "0" : item.getQualityFlag());
|
||||
channelDataIHandler(item3,valueTypes,dto,true);
|
||||
result.add(dto);
|
||||
});
|
||||
});
|
||||
});
|
||||
}
|
||||
});
|
||||
if (CollUtil.isNotEmpty(result)) {
|
||||
//存储数据
|
||||
dataIFeignClient.addList(result);
|
||||
}
|
||||
}
|
||||
|
||||
@Override
|
||||
public void dataFlickerHandler(CalculatedParam calculatedParam) {
|
||||
logger.info("{},dataFlicker表转r_stat_data_flicker_d算法开始=====》", LocalDateTime.now());
|
||||
List<String> valueList = Arrays.asList("AVG","MAX","MIN","CP95");
|
||||
List<DataFlickerDto> result = new ArrayList<>();
|
||||
//远程接口获取分钟数据
|
||||
LineCountEvaluateParam lineParam = new LineCountEvaluateParam();
|
||||
lineParam.setStartTime(TimeUtils.getBeginOfDay(calculatedParam.getDataDate()));
|
||||
lineParam.setEndTime(TimeUtils.getEndOfDay(calculatedParam.getDataDate()));
|
||||
//以100个监测点分片处理
|
||||
List<List<String>> pendingIds = ListUtils.partition(calculatedParam.getIdList(),NUM);
|
||||
pendingIds.forEach(list->{
|
||||
lineParam.setLineId(list);
|
||||
//添加异常数据时间点
|
||||
getAbnormalData(lineParam);
|
||||
//获取原始数据
|
||||
List<CommonMinuteDto> partList = dataFlickerFeignClient.getBaseData(lineParam).getData();
|
||||
if (CollUtil.isNotEmpty(partList)) {
|
||||
partList.forEach(item->{
|
||||
//相别
|
||||
List<CommonMinuteDto.PhasicType> phasicTypeList = item.getPhasicTypeList();
|
||||
phasicTypeList.forEach(item2->{
|
||||
//数据类型
|
||||
List<CommonMinuteDto.ValueType> valueTypeList = item2.getValueTypeList();
|
||||
valueTypeList.forEach(item3->{
|
||||
valueList.forEach(item4->{
|
||||
DataFlickerDto dto = new DataFlickerDto();
|
||||
dto.setTime(item.getTime());
|
||||
dto.setLineId(item.getLineId());
|
||||
dto.setPhasicType(item2.getPhasicType());
|
||||
dto.setValueType(item4);
|
||||
dto.setQualityFlag(Objects.equals(item.getQualityFlag(),"null") ? "0" : item.getQualityFlag());
|
||||
channelDataFlickerHandler(item3,dto,item4,true);
|
||||
result.add(dto);
|
||||
});
|
||||
});
|
||||
});
|
||||
});
|
||||
}
|
||||
});
|
||||
if (CollUtil.isNotEmpty(result)) {
|
||||
//存储数据
|
||||
dataFlickerFeignClient.addList(result);
|
||||
}
|
||||
}
|
||||
|
||||
@Override
|
||||
public void dataFlucHandler(CalculatedParam calculatedParam) {
|
||||
logger.info("{},dataFluc表转r_stat_data_fluc_d算法开始=====》", LocalDateTime.now());
|
||||
List<String> valueList = Arrays.asList("AVG","MAX","MIN","CP95");
|
||||
List<DataFlucDto> result = new ArrayList<>();
|
||||
//远程接口获取分钟数据
|
||||
LineCountEvaluateParam lineParam = new LineCountEvaluateParam();
|
||||
lineParam.setStartTime(TimeUtils.getBeginOfDay(calculatedParam.getDataDate()));
|
||||
lineParam.setEndTime(TimeUtils.getEndOfDay(calculatedParam.getDataDate()));
|
||||
//以100个监测点分片处理
|
||||
List<List<String>> pendingIds = ListUtils.partition(calculatedParam.getIdList(),NUM);
|
||||
pendingIds.forEach(list->{
|
||||
lineParam.setLineId(list);
|
||||
//添加异常数据时间点
|
||||
getAbnormalData(lineParam);
|
||||
//获取原始数据
|
||||
List<CommonMinuteDto> partList = dataFlucFeignClient.getBaseData(lineParam).getData();
|
||||
if (CollUtil.isNotEmpty(partList)) {
|
||||
partList.forEach(item->{
|
||||
//相别
|
||||
List<CommonMinuteDto.PhasicType> phasicTypeList = item.getPhasicTypeList();
|
||||
phasicTypeList.forEach(item2->{
|
||||
//数据类型
|
||||
List<CommonMinuteDto.ValueType> valueTypeList = item2.getValueTypeList();
|
||||
valueTypeList.forEach(item3->{
|
||||
valueList.forEach(item4->{
|
||||
DataFlucDto dto = new DataFlucDto();
|
||||
dto.setTime(item.getTime());
|
||||
dto.setLineId(item.getLineId());
|
||||
dto.setPhasicType(item2.getPhasicType());
|
||||
dto.setValueType(item4);
|
||||
dto.setQualityFlag(Objects.equals(item.getQualityFlag(),"null") ? "0" : item.getQualityFlag());
|
||||
channelDataFlucHandler(item3,dto,item4,true);
|
||||
result.add(dto);
|
||||
});
|
||||
});
|
||||
});
|
||||
});
|
||||
}
|
||||
});
|
||||
if (CollUtil.isNotEmpty(result)) {
|
||||
//存储数据
|
||||
dataFlucFeignClient.addList(result);
|
||||
}
|
||||
}
|
||||
|
||||
@Override
|
||||
public void dataHarmPhasicIHandler(CalculatedParam calculatedParam) {
|
||||
logger.info("{},dataHarmPhasicI表转r_stat_data_harmphasic_i_d算法开始=====》", LocalDateTime.now());
|
||||
List<DataHarmPhasicIDto> result = new ArrayList<>();
|
||||
//远程接口获取分钟数据
|
||||
LineCountEvaluateParam lineParam = new LineCountEvaluateParam();
|
||||
lineParam.setStartTime(TimeUtils.getBeginOfDay(calculatedParam.getDataDate()));
|
||||
lineParam.setEndTime(TimeUtils.getEndOfDay(calculatedParam.getDataDate()));
|
||||
//以100个监测点分片处理
|
||||
List<List<String>> pendingIds = ListUtils.partition(calculatedParam.getIdList(),NUM);
|
||||
pendingIds.forEach(list->{
|
||||
lineParam.setLineId(list);
|
||||
//添加异常数据时间点
|
||||
getAbnormalData(lineParam);
|
||||
//获取原始数据
|
||||
List<CommonMinuteDto> partList = dataHarmphasicIFeignClient.getBaseData(lineParam).getData();
|
||||
if (CollUtil.isNotEmpty(partList)) {
|
||||
partList.forEach(item->{
|
||||
//相别
|
||||
List<CommonMinuteDto.PhasicType> phasicTypeList = item.getPhasicTypeList();
|
||||
phasicTypeList.forEach(item2->{
|
||||
//数据类型
|
||||
List<CommonMinuteDto.ValueType> valueTypeList = item2.getValueTypeList();
|
||||
//获取平均值集合
|
||||
CommonMinuteDto.ValueType valueTypes = valueTypeList.stream().filter(type-> type.getValueType().equalsIgnoreCase(InfluxDbSqlConstant.AVG_WEB)).findFirst().orElse(null);
|
||||
valueTypeList.forEach(item3->{
|
||||
DataHarmPhasicIDto dto = new DataHarmPhasicIDto();
|
||||
dto.setTime(item.getTime());
|
||||
dto.setLineId(item.getLineId());
|
||||
dto.setPhasicType(item2.getPhasicType());
|
||||
dto.setValueType(item3.getValueType());
|
||||
dto.setQualityFlag(Objects.equals(item.getQualityFlag(),"null") ? "0" : item.getQualityFlag());
|
||||
channelDataHarmPhasicIHandler(item3,valueTypes,dto,true);
|
||||
result.add(dto);
|
||||
});
|
||||
});
|
||||
});
|
||||
}
|
||||
});
|
||||
if (CollUtil.isNotEmpty(result)) {
|
||||
//存储数据
|
||||
dataHarmphasicIFeignClient.addList(result);
|
||||
}
|
||||
}
|
||||
|
||||
@Override
|
||||
public void dataHarmPhasicVHandler(CalculatedParam calculatedParam) {
|
||||
logger.info("{},dataHarmPhasicV表转r_stat_data_harmphasic_v_d算法开始=====》", LocalDateTime.now());
|
||||
List<DataHarmPhasicVDto> result = new ArrayList<>();
|
||||
//远程接口获取分钟数据
|
||||
LineCountEvaluateParam lineParam = new LineCountEvaluateParam();
|
||||
lineParam.setStartTime(TimeUtils.getBeginOfDay(calculatedParam.getDataDate()));
|
||||
lineParam.setEndTime(TimeUtils.getEndOfDay(calculatedParam.getDataDate()));
|
||||
//以100个监测点分片处理
|
||||
List<List<String>> pendingIds = ListUtils.partition(calculatedParam.getIdList(),NUM);
|
||||
pendingIds.forEach(list->{
|
||||
lineParam.setLineId(list);
|
||||
//添加异常数据时间点
|
||||
getAbnormalData(lineParam);
|
||||
//获取原始数据
|
||||
List<CommonMinuteDto> partList = dataHarmphasicVFeignClient.getBaseData(lineParam).getData();
|
||||
if (CollUtil.isNotEmpty(partList)) {
|
||||
partList.forEach(item->{
|
||||
//相别
|
||||
List<CommonMinuteDto.PhasicType> phasicTypeList = item.getPhasicTypeList();
|
||||
phasicTypeList.forEach(item2->{
|
||||
//数据类型
|
||||
List<CommonMinuteDto.ValueType> valueTypeList = item2.getValueTypeList();
|
||||
//获取平均值集合
|
||||
CommonMinuteDto.ValueType valueTypes = valueTypeList.stream().filter(type-> type.getValueType().equalsIgnoreCase(InfluxDbSqlConstant.AVG_WEB)).findFirst().orElse(null);
|
||||
valueTypeList.forEach(item3->{
|
||||
DataHarmPhasicVDto dto = new DataHarmPhasicVDto();
|
||||
dto.setTime(item.getTime());
|
||||
dto.setLineId(item.getLineId());
|
||||
dto.setPhasicType(item2.getPhasicType());
|
||||
dto.setValueType(item3.getValueType());
|
||||
dto.setQualityFlag(Objects.equals(item.getQualityFlag(),"null") ? "0" : item.getQualityFlag());
|
||||
channelDataHarmPhasicVHandler(item3,valueTypes,dto,true);
|
||||
result.add(dto);
|
||||
});
|
||||
});
|
||||
});
|
||||
}
|
||||
});
|
||||
if (CollUtil.isNotEmpty(result)) {
|
||||
//存储数据
|
||||
dataHarmphasicVFeignClient.addList(result);
|
||||
}
|
||||
}
|
||||
|
||||
@Override
|
||||
public void dataHarmPowerPHandler(CalculatedParam calculatedParam) {
|
||||
logger.info("{},dataHarmPowerP表转r_stat_data_harmpower_p_d算法开始=====》", LocalDateTime.now());
|
||||
List<DataHarmPowerPDto> result = new ArrayList<>();
|
||||
//远程接口获取分钟数据
|
||||
LineCountEvaluateParam lineParam = new LineCountEvaluateParam();
|
||||
lineParam.setStartTime(TimeUtils.getBeginOfDay(calculatedParam.getDataDate()));
|
||||
lineParam.setEndTime(TimeUtils.getEndOfDay(calculatedParam.getDataDate()));
|
||||
//以100个监测点分片处理
|
||||
List<List<String>> pendingIds = ListUtils.partition(calculatedParam.getIdList(),NUM);
|
||||
pendingIds.forEach(list->{
|
||||
lineParam.setLineId(list);
|
||||
//添加异常数据时间点
|
||||
getAbnormalData(lineParam);
|
||||
//获取原始数据
|
||||
List<CommonMinuteDto> partList = dataHarmpowerPFeignClient.getBaseData(lineParam).getData();
|
||||
if (CollUtil.isNotEmpty(partList)) {
|
||||
partList.forEach(item->{
|
||||
//相别
|
||||
List<CommonMinuteDto.PhasicType> phasicTypeList = item.getPhasicTypeList();
|
||||
phasicTypeList.forEach(item2->{
|
||||
//数据类型
|
||||
List<CommonMinuteDto.ValueType> valueTypeList = item2.getValueTypeList();
|
||||
//获取平均值集合
|
||||
CommonMinuteDto.ValueType valueTypes = valueTypeList.stream().filter(type-> type.getValueType().equalsIgnoreCase(InfluxDbSqlConstant.AVG_WEB)).findFirst().orElse(null);
|
||||
valueTypeList.forEach(item3->{
|
||||
DataHarmPowerPDto dto = new DataHarmPowerPDto();
|
||||
dto.setTime(item.getTime());
|
||||
dto.setLineId(item.getLineId());
|
||||
dto.setPhasicType(item2.getPhasicType());
|
||||
dto.setValueType(item3.getValueType());
|
||||
dto.setQualityFlag(Objects.equals(item.getQualityFlag(),"null") ? "0" : item.getQualityFlag());
|
||||
channelDataHarmPowerPHandler(item3,valueTypes,dto,true);
|
||||
result.add(dto);
|
||||
});
|
||||
});
|
||||
});
|
||||
}
|
||||
});
|
||||
if (CollUtil.isNotEmpty(result)) {
|
||||
//存储数据
|
||||
dataHarmpowerPFeignClient.addList(result);
|
||||
}
|
||||
}
|
||||
|
||||
@Override
|
||||
public void dataHarmPowerQHandler(CalculatedParam calculatedParam) {
|
||||
logger.info("{},dataHarmPowerQ表转r_stat_data_harmpower_q_d算法开始=====》", LocalDateTime.now());
|
||||
List<DataHarmPowerQDto> result = new ArrayList<>();
|
||||
//远程接口获取分钟数据
|
||||
LineCountEvaluateParam lineParam = new LineCountEvaluateParam();
|
||||
lineParam.setStartTime(TimeUtils.getBeginOfDay(calculatedParam.getDataDate()));
|
||||
lineParam.setEndTime(TimeUtils.getEndOfDay(calculatedParam.getDataDate()));
|
||||
//以100个监测点分片处理
|
||||
List<List<String>> pendingIds = ListUtils.partition(calculatedParam.getIdList(),NUM);
|
||||
pendingIds.forEach(list->{
|
||||
lineParam.setLineId(list);
|
||||
//添加异常数据时间点
|
||||
getAbnormalData(lineParam);
|
||||
//获取原始数据
|
||||
List<CommonMinuteDto> partList = dataHarmpowerQFeignClient.getBaseData(lineParam).getData();
|
||||
if (CollUtil.isNotEmpty(partList)) {
|
||||
partList.forEach(item->{
|
||||
//相别
|
||||
List<CommonMinuteDto.PhasicType> phasicTypeList = item.getPhasicTypeList();
|
||||
phasicTypeList.forEach(item2->{
|
||||
//数据类型
|
||||
List<CommonMinuteDto.ValueType> valueTypeList = item2.getValueTypeList();
|
||||
//获取平均值集合
|
||||
CommonMinuteDto.ValueType valueTypes = valueTypeList.stream().filter(type-> type.getValueType().equalsIgnoreCase(InfluxDbSqlConstant.AVG_WEB)).findFirst().orElse(null);
|
||||
valueTypeList.forEach(item3->{
|
||||
DataHarmPowerQDto dto = new DataHarmPowerQDto();
|
||||
dto.setTime(item.getTime());
|
||||
dto.setLineId(item.getLineId());
|
||||
dto.setPhasicType(item2.getPhasicType());
|
||||
dto.setValueType(item3.getValueType());
|
||||
dto.setQualityFlag(Objects.equals(item.getQualityFlag(),"null") ? "0" : item.getQualityFlag());
|
||||
channelDataHarmPowerQHandler(item3,valueTypes,dto,true);
|
||||
result.add(dto);
|
||||
});
|
||||
});
|
||||
});
|
||||
}
|
||||
});
|
||||
if (CollUtil.isNotEmpty(result)) {
|
||||
//存储数据
|
||||
dataHarmpowerQFeignClient.addList(result);
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
//获取异常数据集合
|
||||
public void getAbnormalData(LineCountEvaluateParam lineParam) {
|
||||
lineParam.setTableName(DataCleanEnum.DataV.getCode());
|
||||
@@ -181,6 +514,365 @@ public class DayDataServiceImpl implements IDayDataService {
|
||||
dto.setV50(getData(type,valueType.getValueList().get(60),scheme));
|
||||
}
|
||||
|
||||
public void channelDataIHandler(CommonMinuteDto.ValueType pojo1, CommonMinuteDto.ValueType pojo2, DataIDto dto, boolean scheme) {
|
||||
CommonMinuteDto.ValueType valueType;
|
||||
String type;
|
||||
if (dto.getValueType().equalsIgnoreCase(InfluxDbSqlConstant.CP95) && !scheme) {
|
||||
valueType = pojo2;
|
||||
type = "CP95";
|
||||
} else {
|
||||
valueType = pojo1;
|
||||
type = pojo1.getValueType();
|
||||
}
|
||||
//按照指标集合排列顺序取值
|
||||
dto.setINeg(getData(type,valueType.getValueList().get(0),scheme));
|
||||
dto.setIPos(getData(type,valueType.getValueList().get(1),scheme));
|
||||
dto.setIThd(getData(type,valueType.getValueList().get(2),scheme));
|
||||
dto.setIUnbalance(getData(type,valueType.getValueList().get(3),scheme));
|
||||
dto.setIZero(getData(type,valueType.getValueList().get(4),scheme));
|
||||
dto.setRms(getData(type,valueType.getValueList().get(5),scheme));
|
||||
|
||||
dto.setI1(getData(type,valueType.getValueList().get(6),scheme));
|
||||
dto.setI2(getData(type,valueType.getValueList().get(7),scheme));
|
||||
dto.setI3(getData(type,valueType.getValueList().get(8),scheme));
|
||||
dto.setI4(getData(type,valueType.getValueList().get(9),scheme));
|
||||
dto.setI5(getData(type,valueType.getValueList().get(10),scheme));
|
||||
dto.setI6(getData(type,valueType.getValueList().get(11),scheme));
|
||||
dto.setI7(getData(type,valueType.getValueList().get(12),scheme));
|
||||
dto.setI8(getData(type,valueType.getValueList().get(13),scheme));
|
||||
dto.setI9(getData(type,valueType.getValueList().get(14),scheme));
|
||||
dto.setI10(getData(type,valueType.getValueList().get(15),scheme));
|
||||
|
||||
dto.setI11(getData(type,valueType.getValueList().get(16),scheme));
|
||||
dto.setI12(getData(type,valueType.getValueList().get(17),scheme));
|
||||
dto.setI13(getData(type,valueType.getValueList().get(18),scheme));
|
||||
dto.setI14(getData(type,valueType.getValueList().get(19),scheme));
|
||||
dto.setI15(getData(type,valueType.getValueList().get(20),scheme));
|
||||
dto.setI16(getData(type,valueType.getValueList().get(21),scheme));
|
||||
dto.setI17(getData(type,valueType.getValueList().get(22),scheme));
|
||||
dto.setI18(getData(type,valueType.getValueList().get(23),scheme));
|
||||
dto.setI19(getData(type,valueType.getValueList().get(24),scheme));
|
||||
dto.setI20(getData(type,valueType.getValueList().get(25),scheme));
|
||||
|
||||
dto.setI21(getData(type,valueType.getValueList().get(26),scheme));
|
||||
dto.setI22(getData(type,valueType.getValueList().get(27),scheme));
|
||||
dto.setI23(getData(type,valueType.getValueList().get(28),scheme));
|
||||
dto.setI24(getData(type,valueType.getValueList().get(29),scheme));
|
||||
dto.setI25(getData(type,valueType.getValueList().get(30),scheme));
|
||||
dto.setI26(getData(type,valueType.getValueList().get(31),scheme));
|
||||
dto.setI27(getData(type,valueType.getValueList().get(32),scheme));
|
||||
dto.setI28(getData(type,valueType.getValueList().get(33),scheme));
|
||||
dto.setI29(getData(type,valueType.getValueList().get(34),scheme));
|
||||
dto.setI30(getData(type,valueType.getValueList().get(35),scheme));
|
||||
|
||||
dto.setI31(getData(type,valueType.getValueList().get(36),scheme));
|
||||
dto.setI32(getData(type,valueType.getValueList().get(37),scheme));
|
||||
dto.setI33(getData(type,valueType.getValueList().get(38),scheme));
|
||||
dto.setI34(getData(type,valueType.getValueList().get(39),scheme));
|
||||
dto.setI35(getData(type,valueType.getValueList().get(40),scheme));
|
||||
dto.setI36(getData(type,valueType.getValueList().get(41),scheme));
|
||||
dto.setI37(getData(type,valueType.getValueList().get(42),scheme));
|
||||
dto.setI38(getData(type,valueType.getValueList().get(43),scheme));
|
||||
dto.setI39(getData(type,valueType.getValueList().get(44),scheme));
|
||||
dto.setI40(getData(type,valueType.getValueList().get(45),scheme));
|
||||
|
||||
dto.setI41(getData(type,valueType.getValueList().get(46),scheme));
|
||||
dto.setI42(getData(type,valueType.getValueList().get(47),scheme));
|
||||
dto.setI43(getData(type,valueType.getValueList().get(48),scheme));
|
||||
dto.setI44(getData(type,valueType.getValueList().get(49),scheme));
|
||||
dto.setI45(getData(type,valueType.getValueList().get(50),scheme));
|
||||
dto.setI46(getData(type,valueType.getValueList().get(51),scheme));
|
||||
dto.setI47(getData(type,valueType.getValueList().get(52),scheme));
|
||||
dto.setI48(getData(type,valueType.getValueList().get(53),scheme));
|
||||
dto.setI49(getData(type,valueType.getValueList().get(54),scheme));
|
||||
dto.setI50(getData(type,valueType.getValueList().get(55),scheme));
|
||||
}
|
||||
|
||||
public void channelDataFlickerHandler(CommonMinuteDto.ValueType pojo1, DataFlickerDto dto, String valueType, boolean scheme) {
|
||||
dto.setFluc(getData(valueType,pojo1.getValueList().get(0),scheme));
|
||||
dto.setPlt(getData(valueType,pojo1.getValueList().get(1),scheme));
|
||||
dto.setPst(getData(valueType,pojo1.getValueList().get(2),scheme));
|
||||
}
|
||||
|
||||
public void channelDataFlucHandler(CommonMinuteDto.ValueType pojo1, DataFlucDto dto, String valueType, boolean scheme) {
|
||||
dto.setFluc(getData(valueType,pojo1.getValueList().get(0),scheme));
|
||||
dto.setFluccf(getData(valueType,pojo1.getValueList().get(1),scheme));
|
||||
}
|
||||
|
||||
public void channelDataHarmPhasicIHandler(CommonMinuteDto.ValueType pojo1, CommonMinuteDto.ValueType pojo2, DataHarmPhasicIDto dto, boolean scheme) {
|
||||
CommonMinuteDto.ValueType valueType;
|
||||
String type;
|
||||
if (dto.getValueType().equalsIgnoreCase(InfluxDbSqlConstant.CP95) && !scheme) {
|
||||
valueType = pojo2;
|
||||
type = "CP95";
|
||||
} else {
|
||||
valueType = pojo1;
|
||||
type = pojo1.getValueType();
|
||||
}
|
||||
//按照指标集合排列顺序取值
|
||||
dto.setI1(getData(type,valueType.getValueList().get(0),scheme));
|
||||
dto.setI2(getData(type,valueType.getValueList().get(1),scheme));
|
||||
dto.setI3(getData(type,valueType.getValueList().get(2),scheme));
|
||||
dto.setI4(getData(type,valueType.getValueList().get(3),scheme));
|
||||
dto.setI5(getData(type,valueType.getValueList().get(4),scheme));
|
||||
dto.setI6(getData(type,valueType.getValueList().get(5),scheme));
|
||||
dto.setI7(getData(type,valueType.getValueList().get(6),scheme));
|
||||
dto.setI8(getData(type,valueType.getValueList().get(7),scheme));
|
||||
dto.setI9(getData(type,valueType.getValueList().get(8),scheme));
|
||||
dto.setI10(getData(type,valueType.getValueList().get(9),scheme));
|
||||
dto.setI11(getData(type,valueType.getValueList().get(10),scheme));
|
||||
|
||||
dto.setI12(getData(type,valueType.getValueList().get(11),scheme));
|
||||
dto.setI13(getData(type,valueType.getValueList().get(12),scheme));
|
||||
dto.setI14(getData(type,valueType.getValueList().get(13),scheme));
|
||||
dto.setI15(getData(type,valueType.getValueList().get(14),scheme));
|
||||
dto.setI16(getData(type,valueType.getValueList().get(15),scheme));
|
||||
dto.setI17(getData(type,valueType.getValueList().get(16),scheme));
|
||||
dto.setI18(getData(type,valueType.getValueList().get(17),scheme));
|
||||
dto.setI19(getData(type,valueType.getValueList().get(18),scheme));
|
||||
dto.setI20(getData(type,valueType.getValueList().get(19),scheme));
|
||||
dto.setI21(getData(type,valueType.getValueList().get(20),scheme));
|
||||
|
||||
dto.setI22(getData(type,valueType.getValueList().get(21),scheme));
|
||||
dto.setI23(getData(type,valueType.getValueList().get(22),scheme));
|
||||
dto.setI24(getData(type,valueType.getValueList().get(23),scheme));
|
||||
dto.setI25(getData(type,valueType.getValueList().get(24),scheme));
|
||||
dto.setI26(getData(type,valueType.getValueList().get(25),scheme));
|
||||
dto.setI27(getData(type,valueType.getValueList().get(26),scheme));
|
||||
dto.setI28(getData(type,valueType.getValueList().get(27),scheme));
|
||||
dto.setI29(getData(type,valueType.getValueList().get(28),scheme));
|
||||
dto.setI30(getData(type,valueType.getValueList().get(29),scheme));
|
||||
|
||||
dto.setI31(getData(type,valueType.getValueList().get(30),scheme));
|
||||
dto.setI32(getData(type,valueType.getValueList().get(31),scheme));
|
||||
dto.setI33(getData(type,valueType.getValueList().get(32),scheme));
|
||||
dto.setI34(getData(type,valueType.getValueList().get(33),scheme));
|
||||
dto.setI35(getData(type,valueType.getValueList().get(34),scheme));
|
||||
dto.setI36(getData(type,valueType.getValueList().get(35),scheme));
|
||||
dto.setI37(getData(type,valueType.getValueList().get(36),scheme));
|
||||
dto.setI38(getData(type,valueType.getValueList().get(37),scheme));
|
||||
dto.setI39(getData(type,valueType.getValueList().get(38),scheme));
|
||||
dto.setI40(getData(type,valueType.getValueList().get(39),scheme));
|
||||
|
||||
dto.setI41(getData(type,valueType.getValueList().get(40),scheme));
|
||||
dto.setI42(getData(type,valueType.getValueList().get(41),scheme));
|
||||
dto.setI43(getData(type,valueType.getValueList().get(42),scheme));
|
||||
dto.setI44(getData(type,valueType.getValueList().get(43),scheme));
|
||||
dto.setI45(getData(type,valueType.getValueList().get(44),scheme));
|
||||
dto.setI46(getData(type,valueType.getValueList().get(45),scheme));
|
||||
dto.setI47(getData(type,valueType.getValueList().get(46),scheme));
|
||||
dto.setI48(getData(type,valueType.getValueList().get(47),scheme));
|
||||
dto.setI49(getData(type,valueType.getValueList().get(48),scheme));
|
||||
dto.setI50(getData(type,valueType.getValueList().get(49),scheme));
|
||||
}
|
||||
|
||||
public void channelDataHarmPhasicVHandler(CommonMinuteDto.ValueType pojo1, CommonMinuteDto.ValueType pojo2, DataHarmPhasicVDto dto, boolean scheme) {
|
||||
CommonMinuteDto.ValueType valueType;
|
||||
String type;
|
||||
if (dto.getValueType().equalsIgnoreCase(InfluxDbSqlConstant.CP95) && !scheme) {
|
||||
valueType = pojo2;
|
||||
type = "CP95";
|
||||
} else {
|
||||
valueType = pojo1;
|
||||
type = pojo1.getValueType();
|
||||
}
|
||||
//按照指标集合排列顺序取值
|
||||
dto.setV1(getData(type,valueType.getValueList().get(0),scheme));
|
||||
dto.setV2(getData(type,valueType.getValueList().get(1),scheme));
|
||||
dto.setV3(getData(type,valueType.getValueList().get(2),scheme));
|
||||
dto.setV4(getData(type,valueType.getValueList().get(3),scheme));
|
||||
dto.setV5(getData(type,valueType.getValueList().get(4),scheme));
|
||||
dto.setV6(getData(type,valueType.getValueList().get(5),scheme));
|
||||
dto.setV7(getData(type,valueType.getValueList().get(6),scheme));
|
||||
dto.setV8(getData(type,valueType.getValueList().get(7),scheme));
|
||||
dto.setV9(getData(type,valueType.getValueList().get(8),scheme));
|
||||
dto.setV10(getData(type,valueType.getValueList().get(9),scheme));
|
||||
dto.setV11(getData(type,valueType.getValueList().get(10),scheme));
|
||||
|
||||
dto.setV12(getData(type,valueType.getValueList().get(11),scheme));
|
||||
dto.setV13(getData(type,valueType.getValueList().get(12),scheme));
|
||||
dto.setV14(getData(type,valueType.getValueList().get(13),scheme));
|
||||
dto.setV15(getData(type,valueType.getValueList().get(14),scheme));
|
||||
dto.setV16(getData(type,valueType.getValueList().get(15),scheme));
|
||||
dto.setV17(getData(type,valueType.getValueList().get(16),scheme));
|
||||
dto.setV18(getData(type,valueType.getValueList().get(17),scheme));
|
||||
dto.setV19(getData(type,valueType.getValueList().get(18),scheme));
|
||||
dto.setV20(getData(type,valueType.getValueList().get(19),scheme));
|
||||
dto.setV21(getData(type,valueType.getValueList().get(20),scheme));
|
||||
|
||||
dto.setV22(getData(type,valueType.getValueList().get(21),scheme));
|
||||
dto.setV23(getData(type,valueType.getValueList().get(22),scheme));
|
||||
dto.setV24(getData(type,valueType.getValueList().get(23),scheme));
|
||||
dto.setV25(getData(type,valueType.getValueList().get(24),scheme));
|
||||
dto.setV26(getData(type,valueType.getValueList().get(25),scheme));
|
||||
dto.setV27(getData(type,valueType.getValueList().get(26),scheme));
|
||||
dto.setV28(getData(type,valueType.getValueList().get(27),scheme));
|
||||
dto.setV29(getData(type,valueType.getValueList().get(28),scheme));
|
||||
dto.setV30(getData(type,valueType.getValueList().get(29),scheme));
|
||||
|
||||
dto.setV31(getData(type,valueType.getValueList().get(30),scheme));
|
||||
dto.setV32(getData(type,valueType.getValueList().get(31),scheme));
|
||||
dto.setV33(getData(type,valueType.getValueList().get(32),scheme));
|
||||
dto.setV34(getData(type,valueType.getValueList().get(33),scheme));
|
||||
dto.setV35(getData(type,valueType.getValueList().get(34),scheme));
|
||||
dto.setV36(getData(type,valueType.getValueList().get(35),scheme));
|
||||
dto.setV37(getData(type,valueType.getValueList().get(36),scheme));
|
||||
dto.setV38(getData(type,valueType.getValueList().get(37),scheme));
|
||||
dto.setV39(getData(type,valueType.getValueList().get(38),scheme));
|
||||
dto.setV40(getData(type,valueType.getValueList().get(39),scheme));
|
||||
|
||||
dto.setV41(getData(type,valueType.getValueList().get(40),scheme));
|
||||
dto.setV42(getData(type,valueType.getValueList().get(41),scheme));
|
||||
dto.setV43(getData(type,valueType.getValueList().get(42),scheme));
|
||||
dto.setV44(getData(type,valueType.getValueList().get(43),scheme));
|
||||
dto.setV45(getData(type,valueType.getValueList().get(44),scheme));
|
||||
dto.setV46(getData(type,valueType.getValueList().get(45),scheme));
|
||||
dto.setV47(getData(type,valueType.getValueList().get(46),scheme));
|
||||
dto.setV48(getData(type,valueType.getValueList().get(47),scheme));
|
||||
dto.setV49(getData(type,valueType.getValueList().get(48),scheme));
|
||||
dto.setV50(getData(type,valueType.getValueList().get(49),scheme));
|
||||
}
|
||||
|
||||
public void channelDataHarmPowerPHandler(CommonMinuteDto.ValueType pojo1, CommonMinuteDto.ValueType pojo2, DataHarmPowerPDto dto, boolean scheme) {
|
||||
CommonMinuteDto.ValueType valueType;
|
||||
String type;
|
||||
if (dto.getValueType().equalsIgnoreCase(InfluxDbSqlConstant.CP95) && !scheme) {
|
||||
valueType = pojo2;
|
||||
type = "CP95";
|
||||
} else {
|
||||
valueType = pojo1;
|
||||
type = pojo1.getValueType();
|
||||
}
|
||||
//按照指标集合排列顺序取值
|
||||
dto.setDf(getData(type,valueType.getValueList().get(0),scheme));
|
||||
dto.setPf(getData(type,valueType.getValueList().get(1),scheme));
|
||||
dto.setP(getData(type,valueType.getValueList().get(2),scheme));
|
||||
|
||||
dto.setP1(getData(type,valueType.getValueList().get(3),scheme));
|
||||
dto.setP2(getData(type,valueType.getValueList().get(4),scheme));
|
||||
dto.setP3(getData(type,valueType.getValueList().get(5),scheme));
|
||||
dto.setP4(getData(type,valueType.getValueList().get(6),scheme));
|
||||
dto.setP5(getData(type,valueType.getValueList().get(7),scheme));
|
||||
dto.setP6(getData(type,valueType.getValueList().get(8),scheme));
|
||||
dto.setP7(getData(type,valueType.getValueList().get(9),scheme));
|
||||
dto.setP8(getData(type,valueType.getValueList().get(10),scheme));
|
||||
dto.setP9(getData(type,valueType.getValueList().get(11),scheme));
|
||||
dto.setP10(getData(type,valueType.getValueList().get(12),scheme));
|
||||
dto.setP11(getData(type,valueType.getValueList().get(13),scheme));
|
||||
|
||||
dto.setP12(getData(type,valueType.getValueList().get(14),scheme));
|
||||
dto.setP13(getData(type,valueType.getValueList().get(15),scheme));
|
||||
dto.setP14(getData(type,valueType.getValueList().get(16),scheme));
|
||||
dto.setP15(getData(type,valueType.getValueList().get(17),scheme));
|
||||
dto.setP16(getData(type,valueType.getValueList().get(18),scheme));
|
||||
dto.setP17(getData(type,valueType.getValueList().get(19),scheme));
|
||||
dto.setP18(getData(type,valueType.getValueList().get(20),scheme));
|
||||
dto.setP19(getData(type,valueType.getValueList().get(21),scheme));
|
||||
dto.setP20(getData(type,valueType.getValueList().get(22),scheme));
|
||||
dto.setP21(getData(type,valueType.getValueList().get(23),scheme));
|
||||
|
||||
dto.setP22(getData(type,valueType.getValueList().get(24),scheme));
|
||||
dto.setP23(getData(type,valueType.getValueList().get(25),scheme));
|
||||
dto.setP24(getData(type,valueType.getValueList().get(26),scheme));
|
||||
dto.setP25(getData(type,valueType.getValueList().get(27),scheme));
|
||||
dto.setP26(getData(type,valueType.getValueList().get(28),scheme));
|
||||
dto.setP27(getData(type,valueType.getValueList().get(29),scheme));
|
||||
dto.setP28(getData(type,valueType.getValueList().get(30),scheme));
|
||||
dto.setP29(getData(type,valueType.getValueList().get(31),scheme));
|
||||
dto.setP30(getData(type,valueType.getValueList().get(32),scheme));
|
||||
dto.setP31(getData(type,valueType.getValueList().get(33),scheme));
|
||||
|
||||
dto.setP32(getData(type,valueType.getValueList().get(34),scheme));
|
||||
dto.setP33(getData(type,valueType.getValueList().get(35),scheme));
|
||||
dto.setP34(getData(type,valueType.getValueList().get(36),scheme));
|
||||
dto.setP35(getData(type,valueType.getValueList().get(37),scheme));
|
||||
dto.setP36(getData(type,valueType.getValueList().get(38),scheme));
|
||||
dto.setP37(getData(type,valueType.getValueList().get(39),scheme));
|
||||
dto.setP38(getData(type,valueType.getValueList().get(40),scheme));
|
||||
dto.setP39(getData(type,valueType.getValueList().get(41),scheme));
|
||||
dto.setP40(getData(type,valueType.getValueList().get(42),scheme));
|
||||
dto.setP41(getData(type,valueType.getValueList().get(43),scheme));
|
||||
|
||||
dto.setP42(getData(type,valueType.getValueList().get(44),scheme));
|
||||
dto.setP43(getData(type,valueType.getValueList().get(45),scheme));
|
||||
dto.setP44(getData(type,valueType.getValueList().get(46),scheme));
|
||||
dto.setP45(getData(type,valueType.getValueList().get(47),scheme));
|
||||
dto.setP46(getData(type,valueType.getValueList().get(48),scheme));
|
||||
dto.setP47(getData(type,valueType.getValueList().get(49),scheme));
|
||||
dto.setP48(getData(type,valueType.getValueList().get(50),scheme));
|
||||
dto.setP49(getData(type,valueType.getValueList().get(51),scheme));
|
||||
dto.setP50(getData(type,valueType.getValueList().get(52),scheme));
|
||||
}
|
||||
|
||||
public void channelDataHarmPowerQHandler(CommonMinuteDto.ValueType pojo1, CommonMinuteDto.ValueType pojo2, DataHarmPowerQDto dto, boolean scheme) {
|
||||
CommonMinuteDto.ValueType valueType;
|
||||
String type;
|
||||
if (dto.getValueType().equalsIgnoreCase(InfluxDbSqlConstant.CP95) && !scheme) {
|
||||
valueType = pojo2;
|
||||
type = "CP95";
|
||||
} else {
|
||||
valueType = pojo1;
|
||||
type = pojo1.getValueType();
|
||||
}
|
||||
//按照指标集合排列顺序取值
|
||||
dto.setQ(getData(type,valueType.getValueList().get(0),scheme));
|
||||
|
||||
dto.setQ1(getData(type,valueType.getValueList().get(1),scheme));
|
||||
dto.setQ2(getData(type,valueType.getValueList().get(2),scheme));
|
||||
dto.setQ3(getData(type,valueType.getValueList().get(3),scheme));
|
||||
dto.setQ4(getData(type,valueType.getValueList().get(4),scheme));
|
||||
dto.setQ5(getData(type,valueType.getValueList().get(5),scheme));
|
||||
dto.setQ6(getData(type,valueType.getValueList().get(6),scheme));
|
||||
dto.setQ7(getData(type,valueType.getValueList().get(7),scheme));
|
||||
dto.setQ8(getData(type,valueType.getValueList().get(8),scheme));
|
||||
dto.setQ9(getData(type,valueType.getValueList().get(9),scheme));
|
||||
dto.setQ10(getData(type,valueType.getValueList().get(10),scheme));
|
||||
|
||||
dto.setQ11(getData(type,valueType.getValueList().get(11),scheme));
|
||||
dto.setQ12(getData(type,valueType.getValueList().get(12),scheme));
|
||||
dto.setQ13(getData(type,valueType.getValueList().get(13),scheme));
|
||||
dto.setQ14(getData(type,valueType.getValueList().get(14),scheme));
|
||||
dto.setQ15(getData(type,valueType.getValueList().get(15),scheme));
|
||||
dto.setQ16(getData(type,valueType.getValueList().get(16),scheme));
|
||||
dto.setQ17(getData(type,valueType.getValueList().get(17),scheme));
|
||||
dto.setQ18(getData(type,valueType.getValueList().get(18),scheme));
|
||||
dto.setQ19(getData(type,valueType.getValueList().get(19),scheme));
|
||||
dto.setQ20(getData(type,valueType.getValueList().get(20),scheme));
|
||||
|
||||
dto.setQ21(getData(type,valueType.getValueList().get(21),scheme));
|
||||
dto.setQ22(getData(type,valueType.getValueList().get(22),scheme));
|
||||
dto.setQ23(getData(type,valueType.getValueList().get(23),scheme));
|
||||
dto.setQ24(getData(type,valueType.getValueList().get(24),scheme));
|
||||
dto.setQ25(getData(type,valueType.getValueList().get(25),scheme));
|
||||
dto.setQ26(getData(type,valueType.getValueList().get(26),scheme));
|
||||
dto.setQ27(getData(type,valueType.getValueList().get(27),scheme));
|
||||
dto.setQ28(getData(type,valueType.getValueList().get(28),scheme));
|
||||
dto.setQ29(getData(type,valueType.getValueList().get(29),scheme));
|
||||
dto.setQ30(getData(type,valueType.getValueList().get(30),scheme));
|
||||
|
||||
dto.setQ31(getData(type,valueType.getValueList().get(31),scheme));
|
||||
dto.setQ32(getData(type,valueType.getValueList().get(32),scheme));
|
||||
dto.setQ33(getData(type,valueType.getValueList().get(33),scheme));
|
||||
dto.setQ34(getData(type,valueType.getValueList().get(34),scheme));
|
||||
dto.setQ35(getData(type,valueType.getValueList().get(35),scheme));
|
||||
dto.setQ36(getData(type,valueType.getValueList().get(36),scheme));
|
||||
dto.setQ37(getData(type,valueType.getValueList().get(37),scheme));
|
||||
dto.setQ38(getData(type,valueType.getValueList().get(38),scheme));
|
||||
dto.setQ39(getData(type,valueType.getValueList().get(39),scheme));
|
||||
dto.setQ40(getData(type,valueType.getValueList().get(40),scheme));
|
||||
|
||||
dto.setQ41(getData(type,valueType.getValueList().get(41),scheme));
|
||||
dto.setQ42(getData(type,valueType.getValueList().get(42),scheme));
|
||||
dto.setQ43(getData(type,valueType.getValueList().get(43),scheme));
|
||||
dto.setQ44(getData(type,valueType.getValueList().get(44),scheme));
|
||||
dto.setQ45(getData(type,valueType.getValueList().get(45),scheme));
|
||||
dto.setQ46(getData(type,valueType.getValueList().get(46),scheme));
|
||||
dto.setQ47(getData(type,valueType.getValueList().get(47),scheme));
|
||||
dto.setQ48(getData(type,valueType.getValueList().get(48),scheme));
|
||||
dto.setQ49(getData(type,valueType.getValueList().get(49),scheme));
|
||||
dto.setQ50(getData(type,valueType.getValueList().get(50),scheme));
|
||||
}
|
||||
|
||||
//数据类型处理
|
||||
//cp95值的计算有点区别，会用到cp95的集合或者平均值的集合
|
||||
public Double getData(String valueType, List<Double> list, boolean scheme) {
|
||||
|
||||
Reference in New Issue
Block a user