using HStation.WinFrmUI;
using Yw.Pump;

namespace PBS.WinFrmUI.Hydro
{
    /// <summary>
    /// 调度分析辅助类
    /// </summary>
    public partial class AnalysisHelper
    {
        private readonly static decimal _frequency_def = 50m;
        private readonly static decimal _frequency_min = 10m;
        private readonly static decimal _frequency_max = 50m;
        private readonly static decimal _frequency_space = 1m;//频率间隔
        private readonly static decimal _head_space = 0.1m;//扬程间隔



        /// <summary>
        /// 分析泵
        /// </summary> 
        /// <exception cref="Exception"></exception>
        public static async Task<Dictionary<long, List<AnalysisParameter>>> Analysis(long Id)
        {
            return await Task.Run(async () =>
            {
                List<(HStation.Vmo.AssetsPumpMainVmo Pump, Yw.Pump.CurveQH CurveQH, Yw.Pump.CurveQP CurveQP)> list = new();
                var assetsPackageMain = await BLLFactory<HStation.BLL.AssetsPackageMain>.Instance.GetByID(Id);
                if (assetsPackageMain != null)
                {
                    var mappingList = await BLLFactory<HStation.BLL.AssetsPackagePumpMapping>.Instance.GetByKitID(assetsPackageMain.ID);
                    if (mappingList != null && mappingList.Any())
                    {
                        var pumpMainIds = mappingList.Select(x => x.PumpMainID).ToList();
                        var pumpMainList = await BLLFactory<HStation.BLL.AssetsPumpMain>.Instance.GetByIds(pumpMainIds);
                        if (pumpMainList != null && pumpMainList.Any())
                        {
                            foreach (var pumpMain in pumpMainList)
                            {
                                var relation = await BLLFactory<HStation.BLL.PhartDiagramRelation>.Instance.GetDefaultExByObjectTypeAndObjectID(HStation.Assets.DataType.PumpMain, pumpMain.ID);
                                var diagram = await BLLFactory<Yw.BLL.PhartDiagramExtensions>.Instance.GetByID(relation.DiagramID);
                                var pumpCurve = diagram.GetDefaultPumpCurveViewMdoel();
                                list.Add((pumpMain, pumpCurve.CurveQH, pumpCurve.CurveQP));
                            }
                        }
                    }
                }

                return Analysis(list);
            });

        }


        /// <summary>
        /// 分析泵
        /// </summary>
        /// <param name="list"></param>
        /// <exception cref="Exception"></exception>
        public static Dictionary<long, List<AnalysisParameter>> Analysis(List<(HStation.Vmo.AssetsPumpMainVmo Pump, Yw.Pump.CurveQH CurveQH, Yw.Pump.CurveQP CurveQP)> list)
        {
            if (list == null || list.Count < 1)
            {
                return default;
            }
            var dict = new Dictionary<long, List<AnalysisParameter>>();
            var ana_pump_list = new List<AnaPump>();
            foreach (var item in list)
            {
                var pump = item.Pump;
                var ana_pump = new AnaPump(item.Pump, item.CurveQH, item.CurveQP);
                if (!ana_pump.AllowCalc)
                {
                    throw new Exception("曲线数据异常!");
                }
                var ana_pump_fre_item_list = new List<AnaPumpFreItem>();

                ana_pump_fre_item_list = GetAnaPumpFreItems(_frequency_def, _frequency_min, _frequency_max, _frequency_space, item.CurveQH, item.CurveQP);
                ana_pump.AnaPumpFreItems = ana_pump_fre_item_list;
                ana_pump_list.Add(ana_pump);
            }

            if (!ana_pump_list.Any())
            {
                return default;
            }
            for (int i = 0; i < ana_pump_list.Count; i++)
            {
                var pump = ana_pump_list[i];
                var ana_pump_fre_items = pump.AnaPumpFreItems;
                if (ana_pump_fre_items == null || !ana_pump_fre_items.Any())
                    continue;
                var analysis_conclusion_list = new List<List<AnalysisParameter>>();
                foreach (var freItem in ana_pump_fre_items)
                {
                    var flag = pump.Flag; 
                    var analysis_pump_list_count = ana_pump_fre_items.Count(); 
                    for (int analysis_pump_index = 0; analysis_pump_index < analysis_pump_list_count; analysis_pump_index++)
                    {
                        var analysis_pump = ana_pump_fre_items[analysis_pump_index];
                        var curveQH = analysis_pump.CurveQH.FeatCurve;
                        var curveQP = analysis_pump.CurveQP.FeatCurve;
                        var qhPtList = curveQH.GetPointList().OrderBy(x => x.Y);
                        var maxY = qhPtList.Last().Y;
                        var minY = qhPtList.First().Y;


                        decimal max_head = (decimal)Math.Ceiling(maxY);
                        decimal min_head = (decimal)Math.Floor(minY);

                        var current_list_count = (int)((max_head - min_head) / _head_space) + 1;
                        var current_analysis_conclusion_list = new List<AnalysisParameter>(current_list_count);
                        for (decimal head = min_head; head <= max_head; head += _head_space)
                        {
                            var flow = curveQH.GetPointsX((double)head)?.FirstOrDefault() ?? 0d;
                            if (flow < 1)
                            {
                                continue;
                            }

                            double differV = 0;
                            //if (pump.Oc != null)
                            //{
                            //    //1输和2输都是用的进口液位，不考虑进口口径
                            //    differV =  CalculateHelper.CalculateOtherPress(flow, null, pump.Oc, null, null);
                            //}

                            var analysis_conclusion = new AnalysisParameter();
                            analysis_conclusion.PumpID = flag;
                            analysis_conclusion.Hz = analysis_pump.Frequency;
                            analysis_conclusion.Head = (double)head;
                            analysis_conclusion.PressureDiff = (double)head - differV;
                            analysis_conclusion.Flow = flow;
                            analysis_conclusion.Power = curveQP.GetPointY(flow);
                            analysis_conclusion.UWP = Yw.Pump.CalculationHelper.CalcuUWP(analysis_conclusion.Power, analysis_conclusion.Flow, analysis_conclusion.Head);
                            analysis_conclusion.WP = Yw.Pump.CalculationHelper.CalcuWP(analysis_conclusion.Power, analysis_conclusion.Flow);



                            int digits = 1;
                            analysis_conclusion.Hz = Math.Round(analysis_conclusion.Hz, digits);
                            analysis_conclusion.Head = Math.Round(analysis_conclusion.Head, digits);
                            analysis_conclusion.PressureDiff = Math.Round(analysis_conclusion.PressureDiff, digits);
                            analysis_conclusion.Flow = Math.Round(analysis_conclusion.Flow, digits);
                            analysis_conclusion.Power = Math.Round(analysis_conclusion.Power, digits);
                            analysis_conclusion.WP = Math.Round(analysis_conclusion.WP, digits);
                            analysis_conclusion.UWP = Math.Round(analysis_conclusion.UWP, digits);
                            current_analysis_conclusion_list.Add(analysis_conclusion);
                        }
                        analysis_conclusion_list.Add(current_analysis_conclusion_list);
                    }

                }

                dict[pump.Flag]=(analysis_conclusion_list.SelectMany(x => x).ToList());
            }

            return dict;

        }



        /// <summary>
        /// 获取分析泵变频项
        /// </summary>  
        private static List<AnaPumpFreItem> GetAnaPumpFreItems(
             decimal fre_def,
             decimal fre_min,
             decimal fre_max,
             decimal fre_space,
             Yw.Pump.CurveQH qh,
             Yw.Pump.CurveQP qp)
        {

            var list = new List<AnaPumpFreItem>();
            for (decimal fre = fre_max; fre >= fre_min; fre -= fre_space)
            {
                var hz = (double)Math.Round(fre, 1);
                var hz0 = Math.Round(hz, 0);

                var qh_pt_list = qh.GetPointListByN((double)fre_def, (double)fre);
                var qp_pt_list = qp.GetPointListByN((double)fre_def, (double)fre);


                var freItem = new AnaPumpFreItem();
                freItem.Frequency = hz;
                freItem.CurveQH = new CurveQH(qh.FeatType, qh_pt_list);
                freItem.CurveQP = new CurveQP(qp.FeatType, qp_pt_list);
                list.Add(freItem);
            }

            return list;
        }





    }
}