package com.iailab.module.ansteel.job.task; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.iailab.module.ansteel.power.dao.PeakValleyFlatDao; import com.iailab.module.ansteel.power.entity.PeakValleyFlatEntity; import com.iailab.module.data.api.point.DataPointApi; import com.iailab.module.data.api.point.dto.ApiPointValueDTO; import com.iailab.module.data.api.point.dto.ApiPointValueQueryDTO; import com.iailab.module.data.api.point.dto.ApiPointValueWriteDTO; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; import java.util.*; import java.util.List; import java.util.stream.Collectors; /** * 峰谷平累计量计算 * * @author DongYukun * @Description * @createTime 2025年5月5日 */ @Component("runPeakValleyFlatTask") public class RunPeakValleyFlatTask implements ITask { private Logger logger = LoggerFactory.getLogger(getClass()); @Autowired private PeakValleyFlatDao peakValleyFlatDao; @Autowired private DataPointApi dataPointApi; @Override public void run(String params) { try { Calendar calendar = Calendar.getInstance(); //查询峰谷平配置列表 List list = peakValleyFlatDao.selectList(new QueryWrapper<>()); //根据测点分组 Map> groupedByPointNo = list.stream() .collect(Collectors.groupingBy(PeakValleyFlatEntity::getPointNo)); groupedByPointNo.entrySet().stream().forEach(entry -> { Calendar cal = (Calendar) calendar.clone(); cal.set(Calendar.MILLISECOND, 0); cal.set(Calendar.SECOND, 0); cal.set(Calendar.MINUTE, 0); cal.set(Calendar.HOUR_OF_DAY, 0); Date endTime = calendar.getTime(); cal.add(Calendar.DAY_OF_YEAR, -1); Date startTime = cal.getTime(); cal.add(Calendar.DAY_OF_YEAR, -29); Date monthStartTime = cal.getTime(); //计算昨日的峰/谷累积量 double value = getSumValue(entry.getValue(), 1, calendar); //计算昨日总电耗 double totalValue = getSumValueTotal(entry.getValue().get(0).getPowerNo(), startTime, endTime); //计算前三十日峰/谷累积量 double valueMonth = getSumValueTotal(entry.getValue().get(0).getPointNoTotal(), monthStartTime, startTime)+value; //计算前三十日总电耗 double totalValueMonth = getSumValueTotal(entry.getValue().get(0).getPowerNo(), monthStartTime, endTime); logger.info("name:"+entry.getValue().get(0).getName()+";value:"+value+";totalValue:"+totalValue+";valueMonth:"+valueMonth+";totalValueMonth:"+totalValueMonth); //下发昨日占比 ApiPointValueWriteDTO percentDto = new ApiPointValueWriteDTO(); percentDto.setPointNo(entry.getValue().get(0).getPointNo()); double percent = totalValue == 0 ? 0 : value / totalValue * 100; percentDto.setValue(percent); dataPointApi.writePointRealValue(percentDto); //下发昨日峰/谷累积量 ApiPointValueWriteDTO totalDto = new ApiPointValueWriteDTO(); totalDto.setPointNo(entry.getValue().get(0).getPointNoTotal()); totalDto.setValue(totalValue); dataPointApi.writePointRealValue(totalDto); //下发前三十日占比 ApiPointValueWriteDTO monthDto = new ApiPointValueWriteDTO(); monthDto.setPointNo(entry.getValue().get(0).getPointNoMonth()); double percentMonth = totalValueMonth == 0 ? 0 : valueMonth / totalValueMonth * 100; monthDto.setValue(percentMonth); dataPointApi.writePointRealValue(monthDto); }); } catch (Exception ex) { logger.error("runPeakValleyFlatTask运行异常", ex); } } private Date getTime(String timeStr, int ago, Calendar calendar) { Calendar cal = (Calendar) calendar.clone(); String[] timeSplit = timeStr.split(":"); if (timeSplit.length != 2) { throw new IllegalArgumentException("时间配置格式不合法"); } //根据配置获取startTime、endTime cal.set(Calendar.MILLISECOND, 0); cal.set(Calendar.SECOND, 0); cal.set(Calendar.HOUR_OF_DAY, Integer.parseInt(timeSplit[0])); cal.set(Calendar.MINUTE, Integer.parseInt(timeSplit[1])); cal.add(Calendar.DAY_OF_YEAR, -ago); return cal.getTime(); } private List fillMissingData(List valueList, Date startTime, Date endTime) { if (valueList == null || valueList.isEmpty()) { return new ArrayList<>(); } // 过滤掉null元素 valueList = valueList.stream().filter(Objects::nonNull).collect(Collectors.toList()); if (valueList.isEmpty()) { return new ArrayList<>(); } List filledList = new ArrayList<>(); ApiPointValueDTO lastValidData = null; long totalMinutes = (endTime.getTime() - startTime.getTime()) / (60 * 1000); for (int i = 0; i <= totalMinutes; i++) { Date currentTime = new Date(startTime.getTime() + i * 60 * 1000); ApiPointValueDTO currentData = findDataForTime(valueList, currentTime); if (currentData != null) { filledList.add(currentData); lastValidData = currentData; } else if (lastValidData != null) { filledList.add(new ApiPointValueDTO() .setT(currentTime) .setV(lastValidData.getV())); } else { // 使用第一个非null数据的值 filledList.add(new ApiPointValueDTO() .setT(currentTime) .setV(valueList.get(0).getV())); } } return filledList; } private ApiPointValueDTO findDataForTime(List valueList, Date time) { long targetMinute = time.getTime() / (60 * 1000); return valueList.stream() .filter(Objects::nonNull) .filter(d -> d.getT() != null) .filter(d -> d.getT().getTime() / (60 * 1000) == targetMinute) .findFirst() .orElse(null); } private double getSumValue(List list, int ago, Calendar calendar) { double value = 0; for (int i = 0; i < list.size(); i++) { PeakValleyFlatEntity entity = list.get(i); ApiPointValueQueryDTO dto = new ApiPointValueQueryDTO(); Date startTime = getTime(entity.getStartTime(), ago, calendar); Date endTime = getTime(entity.getEndTime(), ago, calendar); dto.setPointNo(entity.getPowerNo()); dto.setStart(startTime); dto.setEnd(endTime); logger.info("开始查询,测点：" + entity.getPowerNo() + "startTime:" + startTime + "endTime:" + endTime); List valueList; //查找数据 try { valueList = dataPointApi.queryPointHistoryValue(dto); } catch (Exception e) { throw new RuntimeException("查询测点异常"); } //补全数据 valueList = fillMissingData(valueList, startTime, endTime); //累加 double sum = valueList.stream().mapToDouble(ApiPointValueDTO::getV).sum(); value = value + sum; } return value / 60; } private double getSumValueTotal(String pointNo, Date startTime, Date endTime) { ApiPointValueQueryDTO dto = new ApiPointValueQueryDTO(); dto.setPointNo(pointNo); dto.setStart(startTime); dto.setEnd(endTime); //查找数据 List valueList = dataPointApi.queryPointHistoryValue(dto); //补全数据 valueList = fillMissingData(valueList, startTime, endTime); //累加 return valueList.stream().mapToDouble(ApiPointValueDTO::getV).sum() / 60; } }