eaxing_back_africa_main/Service/Ammeter/EmeterEnergyChangeService.cs

using Entity.Ammeter;
using HybirdFrameworkCore.Autofac.Attribute;
using Repository.Ammeter;

namespace Service.Ammeter;

[Scope("SingleInstance")]
public class EmeterEnergyChangeService : BaseServices<EmeterEnergyChange>
{
    private readonly EmeterEnergyChangeRepository _emeterEnergyChangeRep;

    public EmeterEnergyChangeService(EmeterEnergyChangeRepository emeterEnergyChangeRep)
    {
        _emeterEnergyChangeRep = emeterEnergyChangeRep;
    }

    public async Task<List<EmeterEnergyChange>> SevenDaysElectrical()
    {
        // 根据code分组,取最近7天数据,每天最大值-最小值=当日用电量,如果当天目前只有一条数据,取当天最大值-前一天最大值=当天耗电量
        string sql = @"
    WITH daily_max_min AS (
    SELECT 
        `code`,
        DATE(`upload_time`) AS `UploadTime`,
        MAX(`value`) AS `MaxValue`,
        MIN(`value`) AS `MinValue`,
        COUNT(*) AS `Count`
    FROM 
        `emeter_energy_change`
    WHERE 
        `upload_time` >= NOW() - INTERVAL 8 DAY
    GROUP BY 
        `code`, DATE(`upload_time`)
), previous_day_max AS (
    SELECT
        `code`,
        `UploadTime`,
        `MaxValue`,
        `MinValue`,
        `Count`,
        LAG(`MaxValue`) OVER (PARTITION BY `code` ORDER BY `UploadTime`) AS `PreviousMaxValue`
    FROM
        daily_max_min
), daily_consumption AS (
    SELECT 
        d.`code`,
        d.`UploadTime`,
        CASE
            WHEN d.`Count` > 1 THEN d.`MaxValue` - d.`MinValue`
            WHEN d.`Count` = 1 AND d.`PreviousMaxValue` IS NOT NULL THEN d.`MaxValue` - d.`PreviousMaxValue`
            ELSE 0
        END AS `DailyValue`
    FROM 
        previous_day_max d
    WHERE 
        d.`UploadTime` >= NOW() - INTERVAL 7 DAY
)
SELECT 
    `UploadTime`,
    SUM(`DailyValue`) AS `Value`
FROM 
    daily_consumption
GROUP BY 
    `UploadTime`
ORDER BY 
    `UploadTime`;



    ";

        List<EmeterEnergyChange> emeterEnergies = await _emeterEnergyChangeRep.SqlQueryable(sql);
        return emeterEnergies;
    }

    public async Task<List<EmeterEnergyChange>> GetAllElectricalData()
    {
        string sql = @"
        SELECT 
            code,
            MAX(value) - MIN(value) AS Value
        FROM 
            emeter_energy_change
        WHERE 
            upload_time >= DATE_SUB(NOW(), INTERVAL 1 MONTH)
        GROUP BY 
            code
        ORDER BY 
            code;
        
    ";
        List<EmeterEnergyChange> emeterEnergies = await _emeterEnergyChangeRep.SqlQueryable(sql);
        return emeterEnergies;
    }

    public async Task<List<EmeterEnergyChange>> GetTodayHourlyElectricalData()
    {
        string sql = @"
    WITH hourly_max_min AS (
        SELECT 
            `code`,
            DATE_FORMAT(`upload_time`, '%Y-%m-%d %H:00:00') AS `Hour`,
            MAX(`value`) AS `MaxValue`,
            MIN(`value`) AS `MinValue`,
            COUNT(*) AS `record_count`
        FROM 
            `emeter_energy_change`
        WHERE 
            DATE(`upload_time`) = CURDATE()
        GROUP BY 
            `code`, DATE_FORMAT(`upload_time`, '%Y-%m-%d %H:00:00')
    ), previous_hour_max AS (
        SELECT
            `code`,
            `Hour`,
            LAG(`MaxValue`) OVER (PARTITION BY `code` ORDER BY `Hour`) AS `PreviousMaxValue`
        FROM
            `hourly_max_min`
    )
    SELECT 
        h.`code`,
        h.`Hour`,
        CASE 
            WHEN h.`record_count` > 1 THEN h.`MaxValue` - h.`MinValue`
            ELSE h.`MaxValue` - COALESCE(p.`PreviousMaxValue`, 0)
        END AS `Value`
    FROM 
        `hourly_max_min` h
    LEFT JOIN 
        `previous_hour_max` p ON h.`code` = p.`code` AND h.`Hour` = p.`Hour`
    ORDER BY 
        h.`code`, h.`Hour`;
    ";
        List<EmeterEnergyChange> emeterEnergies = await _emeterEnergyChangeRep.SqlQueryable(sql);
        return emeterEnergies;
    }

    /// <summary>
    /// 根据分钟统计电量
    /// </summary>
    /// <returns></returns>
    public async Task<List<EmeterEnergyChange>> GetTodayMinutelyElectricalData()
    {
        string sql = @"
                WITH minute_max_min AS (
                    SELECT 
                        `code`,
                        DATE_FORMAT(`upload_time`, '%Y-%m-%d %H:%i:00') AS `Minute`,
                        MAX(`value`) AS `MaxValue`,
                        MIN(`value`) AS `MinValue`,
                        COUNT(*) AS `record_count`
                    FROM 
                        `emeter_energy_change`
                    WHERE 
                        `upload_time` >= NOW() - INTERVAL 1 HOUR
                    GROUP BY 
                        `code`, DATE_FORMAT(`upload_time`, '%Y-%m-%d %H:%i:00')
                ), previous_minute_max AS (
                    SELECT
                        `code`,
                        `Minute`,
                        LAG(`MaxValue`) OVER (PARTITION BY `code` ORDER BY `Minute`) AS `PreviousMaxValue`
                    FROM
                        `minute_max_min`
                )
                SELECT 
                    m.`code`,
                    m.`Minute`,
                    CASE 
                        WHEN m.`record_count` > 1 THEN m.`MaxValue` - m.`MinValue`
                        WHEN p.`PreviousMaxValue` IS NULL THEN 0
                        ELSE m.`MaxValue` - p.`PreviousMaxValue`
                    END AS `Value`
                FROM 
                    `minute_max_min` m
                LEFT JOIN 
                    `previous_minute_max` p ON m.`code` = p.`code` AND m.`Minute` = p.`Minute`
                ORDER BY 
                    m.`code`, m.`Minute`;
";

        List<EmeterEnergyChange> emeterEnergies = await _emeterEnergyChangeRep.SqlQueryable(sql);
        return emeterEnergies;
    }
    
    /// <summary>
    /// 获取交流电表实时数据
    /// </summary>
    /// <returns></returns>
    public async Task<List<EmeterEnergyChange>> GetEnergyMeterRealTime()
    {
        // 根据code分组,取最新时间的一条数据,数据范围7天
        string sql = @"
                SELECT t1.*
FROM emeter_energy_change t1
JOIN (
    SELECT code, MAX(upload_time) as latest_upload_time
    FROM emeter_energy_change
    WHERE upload_time >= NOW() - INTERVAL 7 DAY
    GROUP BY code
) t2 ON t1.code = t2.code AND t1.upload_time = t2.latest_upload_time
WHERE t1.upload_time >= NOW() - INTERVAL 7 DAY;
";

        List<EmeterEnergyChange> emeterEnergies = await _emeterEnergyChangeRep.SqlQueryable(sql);
        return emeterEnergies;
    }
}