FIC_Solar/SolarPower/Repository/Implement/AnalysisStationCombineRepository.cs

using Dapper;
using SolarPower.Helper;
using SolarPower.Models;
using SolarPower.Repository.Interface;
using System;
using System.Collections.Generic;
using System.Data;
using System.Linq;
using System.Threading.Tasks;

namespace SolarPower.Repository.Implement
{
    public class AnalysisStationCombineRepository : RepositoryBase<AnalysisStationCombine>, IAnalysisStationCombineRepository
    {
        public AnalysisStationCombineRepository(IDatabaseHelper databaseHelper) : base(databaseHelper)
        {
            tableName = "power_station";
        }

        public async Task<AnalysisStationCombine> GetPowerStationInfoList(ChartInput post)
        {
            var a = new AnalysisStationCombine();
            using (IDbConnection conn = _databaseHelper.GetConnection())
            {
                conn.Open();
                using (var trans = conn.BeginTransaction())
                {
                    try
                    {
                        string sql = "";
                        switch(post.SeacrhType)
                        {
                            case 0:
                                string timerange = Convert.ToDateTime(post.Timerange).ToString("yyyy-MM-dd");
                                sql = $@"SELECT m.*,n.* FROM
                                        (
                                            SELECT AVG(KWHKWP) AS All_KWH_KWP ,SUM(TOTALMONEY) AS All_money,
                                            SUM(TOTALKWH) AS All_kwh,SUM(TOTALCARBON) AS All_Carbon,
                                            AVG(PR) AS All_PR 
                                            from power_station_history_month
                                            WHERE PowerStationId IN @ids
                                        ) 
                                        AS m,
                                        (
                                            SELECT 
                                            SUM(b.TODAYKWH) AS Now_kwh,
                                            SUM(b.TODAYMONEY) AS Now_money,
                                            AVG(b.KWHKWP) AS Now_KWH_KWP ,
                                            AVG(b.PR) AS Now_PR,
                                            SUM(b.TODAYCARBON) AS Now_Carbon
                                            FROM (SELECT MAX(a.`TIMESTAMP`) AS maxTIMESTAMP FROM 
                                            (SELECT * FROM power_station_history_hour hr WHERE DATE_FORMAT(hr.`TIMESTAMP`,'%Y-%m-%d') = '{timerange}') a ) c
                                            LEFT JOIN 
                                            (SELECT * FROM power_station_history_hour hr WHERE DATE_FORMAT(hr.`TIMESTAMP`,'%Y-%m-%d') = '{timerange}' ) b
                                            ON c.maxTIMESTAMP = b.`TIMESTAMP`
                                            WHERE PowerStationId IN @ids
                                        )
                                        AS n";
                                break;
                            case 1:
                                var time = post.Timerange.Split('-');
                                sql = $@"SELECT m.*,n.* FROM
                                        (
                                            SELECT AVG(KWHKWP) AS All_KWH_KWP, SUM(TOTALMONEY) AS All_money,
                                            SUM(TOTALKWH) AS All_kwh, SUM(TOTALCARBON) AS All_Carbon,
                                            AVG(PR) AS All_PR
                                            from power_station_history_month
                                            WHERE PowerStationId IN @ids
                                        )
                                        AS m,
                                        (
                                            SELECT
                                            SUM(b.TODAYKWH) AS Now_kwh,
                                            SUM(b.MONEY) AS Now_money,
                                            AVG(b.KWHKWP) AS Now_KWH_KWP,
                                            AVG(b.PR) AS Now_PR,
                                            SUM(b.CARBON) AS Now_Carbon
                                            FROM power_station_history_day b
                                            WHERE PowerStationId IN @ids AND TIMESTAMP BETWEEN '{time[0]}' AND '{time[1]}'
                                        )
                                        AS n";
                                break;
                            case 2:
                                sql = $@"SELECT m.*,n.* FROM
                                         (
                                            SELECT 
                                            AVG(KWHKWP) AS All_KWH_KWP,
                                            SUM(TOTALMONEY) AS All_money,
                                            SUM(TOTALKWH) AS All_kwh,
                                            SUM(TOTALCARBON) AS All_Carbon,
                                            AVG(PR) AS All_PR
                                            from power_station_history_month
                                            WHERE PowerStationId IN @ids
                                         )
                                         AS m,
                                         (
                                            SELECT
                                            SUM(b.TODAYKWH) AS Now_kwh,
                                            SUM(b.MONEY) AS Now_money,
                                            AVG(b.KWHKWP) AS Now_KWH_KWP,
                                            AVG(b.PR) AS Now_PR,
                                            SUM(b.CARBON) AS Now_Carbon
                                            FROM power_station_history_day b
                                            WHERE PowerStationId IN @ids AND DATE_FORMAT(TIMESTAMP, '%Y-%m') = '{post.Timerange}'
                                         )
                                         AS n";
                                break;
                            case 3:
                                sql = $@"SELECT m.*,n.* FROM
                                         (
                                             SELECT AVG(KWHKWP) AS All_KWH_KWP, SUM(TOTALMONEY) AS All_money,
                                             SUM(TOTALKWH) AS All_kwh, SUM(TOTALCARBON) AS All_Carbon,
                                             AVG(PR) AS All_PR
                                             from power_station_history_month
                                             WHERE PowerStationId IN @ids
                                         )
                                         AS m,
                                         (
                                           SELECT

                                            SUM(b.MONTHKWH) AS Now_kwh,
                                            SUM(b.MONEY) AS Now_money,
                                            AVG(b.KWHKWP) AS Now_KWH_KWP,
                                            AVG(b.PR) AS Now_PR,
                                            SUM(b.CARBON) AS Now_Carbon
                                            FROM power_station_history_month b
                                            WHERE PowerStationId IN @ids AND DATE_FORMAT(TIMESTAMP, '%Y') = '{post.Timerange}'
                                         )
                                         AS n";
                                break;
                        }

                        a = await conn.QueryFirstOrDefaultAsync<AnalysisStationCombine>(sql,new { ids = post.StationIds});
                    }
                    catch (Exception exception)
                    {
                        throw exception;
                    }
                    finally
                    {
                        conn.Close();
                    }
                }
            }
            return a;
        }

    }
}