baoshiwei
2025-05-06 8dd7af51db4cf768fbf92002b5b62f7fb9d1c929
zhitan-system/src/main/java/com/zhitan/peakvalley/service/impl/PeakValleyServiceImpl.java
@@ -1,6 +1,5 @@
package com.zhitan.peakvalley.service.impl;
import cn.hutool.core.date.DateUtil;
import com.zhitan.common.enums.ElectricityTypeEnum;
import com.zhitan.common.enums.TimeType;
@@ -40,10 +39,16 @@
    CostPriceRelevancyMapper costPriceRelevancyMapper;
    /**
     * 查询统计数据
     * 查询尖峰平谷统计数据
     * @param dto 请求参数,包含模型代码、节点ID、查询时间、时间类型等
     * @return 按时间段分隔的统计结果列表
     *
     * @param dto 请求参数
     * @return 结果
     * 业务步骤:
     * 1. 根据查询时间确定起止时间范围
     * 2. 查询模型节点关联的指标信息
     * 3. 根据指标ID集合查询原始数据
     * 4. 按时间分组处理数据
     * 5. 循环遍历时间区间,统计各时段的费用和用电量
     */
    @Override
    public List<PeakValleyHourDataVO> getDataStatistics(ElectricityDataItemListDTO dto) {
@@ -119,6 +124,19 @@
    }
    /**
     * 按天维度进行尖峰平谷分时段分析
     * @param dto 请求参数,包含模型代码、节点ID、查询时间等
     * @return 包含日统计总览和图表数据的VO对象
     *
     * 业务步骤:
     * 1. 初始化统计容器和时间范围
     * 2. 查询关联指标并获取原始数据
     * 3. 按天聚合数据并计算各时段费用和用电量
     * 4. 生成费用/用电量折线图数据
     * 5. 计算总消耗量及各时段占比
     * 6. 汇总生成最终结果对象
     */
    @Override
    public PeakValleyDayVO segmentAnalysisDay(PeakValleyDTO dto) {
        PeakValleyDayVO peakValleyVO = new PeakValleyDayVO();
@@ -300,6 +318,19 @@
        return peakValleyVO;
    }
    /**
     * 按小时维度进行尖峰平谷分时段分析
     * @param dto 请求参数,包含模型代码、节点ID、查询时间等
     * @return 包含小时级数据和可视化图表的VO对象
     *
     * 业务步骤:
     * 1. 初始化统计容器和时间范围
     * 2. 查询关联指标并获取原始数据
     * 3. 按小时统计各时段费用和用电量
     * 4. 生成用电量折线图数据
     * 5. 计算总用电量及各时段占比饼图数据
     * 6. 汇总生成最终结果对象
     */
    @Override
    public PeakValleyHourVO segmentAnalysisHour(PeakValleyDTO dto) {
        PeakValleyHourVO peakValleyVO = new PeakValleyHourVO();
@@ -413,6 +444,17 @@
        return peakValleyVO;
    }
    /**
     * 导出小时级尖峰平谷分析数据
     * @param dto 请求参数,包含模型代码、节点ID、查询时间等
     * @return 小时级详细统计数据列表
     *
     * 业务步骤:
     * 1. 初始化时间范围
     * 2. 查询关联指标并获取原始数据
     * 3. 按小时统计各时段数据
     * 4. 生成可导出的详细数据列表
     */
    @Override
    public List<PeakValleyHourDataVO> segmentAnalysisHourExport(PeakValleyDTO dto) {
        List<PeakValleyHourDataVO> reportVOList = new ArrayList<>();
@@ -486,6 +528,13 @@
       return reportVOList;
    }
    /**
     * 自定义时段的尖峰平谷分析(预留接口)
     * @param dto 请求参数,包含自定义时间范围等
     * @return 分析结果对象
     *
     * 当前实现:暂未开发,返回空值
     */
    @Override
    public PeakValleyDayVO segmentAnalysisDayCustomize(PeakValleyDTO dto) {
        return null;