using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace IStation.Calculation.DispatchAna
{
    /// <summary>
    /// 泰和泵站调度方案计算器
    /// </summary>
    internal class Calculator_KeepStatus_SHYS_泰和泵站 : CalculatorBase_SHYS_泰和泵站, IKeepStatusCalc
    {
        public Calculator_KeepStatus_SHYS_泰和泵站()
        {
        }
        Model.RequestParasComplex _request_paras;
        List<long> _open_machine_IdList ;
        /// <summary>
        /// 初始化参数
        /// </summary>
        /// <param name="complex_request_paras"></param>
        /// <param name="eta_ana_records"></param>
        /// <param name="open_machine_ids"></param>
        public  void IntialRequest(
            IStation.Calculation.DispatchAna.Model.RequestParasComplex complex_request_paras,
            IStation.Calculation.DispatchAna.Model.EtaAnaRecord4Station eta_ana_records,
            List<long> open_machine_ids)
        {
            this._request_paras = complex_request_paras;
            this._open_machine_IdList = open_machine_ids;
        }




        /// <summary>
        /// 计算保持当前开机状态
        /// </summary> 
        /// <param name="error_info">错误信息</param>
        /// <returns></returns>
        public Model.AnaScheme Calc(out string error_info)
        {
            if (_open_machine_IdList == null || _open_machine_IdList.Count == 0)
            {
                error_info = "ERROR 25";
                return null;
            }
            error_info = null;
            if (_request_paras == null)
            {
                error_info = "ERROR 30";
                return null;
            }

            if (_request_paras.OutletPipePara == null || _request_paras.OutletPipePara.Count < 2)
            {
                error_info = "ERROR 35";
                return null;
            }
            double pipe1_TargetFlow = _request_paras.OutletPipePara[0].TargetFlow;
            double pipe2_TargetFlow = _request_paras.OutletPipePara[1].TargetFlow;
            if (pipe1_TargetFlow < 10 && pipe2_TargetFlow < 10)
            {
                return default;
            }

            double pipe1_TargetPess = _request_paras.OutletPipePara[0].TargetPress;
            double pipe2_TargetPess = _request_paras.OutletPipePara[1].TargetPress;


            double inlet_press = 0;//压力
            if (_request_paras.InletPipePara != null && _request_paras.InletPipePara.Count > 0)
            {
                inlet_press = _request_paras.InletPipePara.First().Value;
            }
            double water_level = inlet_press * 102;


            // 根据流量判断阀门开关状态
            bool isOpenMiddleValve46 = false;
            bool isOpenMiddleValve67 = true;
            GetValveStatusByFlow(pipe1_TargetFlow, pipe2_TargetFlow, out isOpenMiddleValve46, out isOpenMiddleValve67);



            List<Model.MachineDetail> allMachineList = null;
            if (!BuildMachineList(
                out allMachineList,
                out error_info))
            {
                error_info = "机泵组无法构建,ERROR 70,错误信息:" + error_info;
                return null;
            }

            if (isOpenMiddleValve46 && isOpenMiddleValve67)//阀门开的状态下 两管相连数据相加求平均值
            {
                double outlet_press = 0;
                if (pipe1_TargetPess > 0.1 && pipe2_TargetPess > 0.1)
                {
                    outlet_press = (pipe1_TargetPess + pipe2_TargetPess) / 2;
                }
                else
                {
                    if (pipe1_TargetPess > 0.01)
                        outlet_press = pipe1_TargetPess;
                    else if (pipe2_TargetPess > 0.01)
                        outlet_press = pipe2_TargetPess;
                    else
                        return null;
                }
                Common.DispatchAnaGeneralHelper压力 calc_pipe_helper =
                    new Common.DispatchAnaGeneralHelper压力();
                calc_pipe_helper.InitialParas(
                    pipe1_TargetFlow + pipe2_TargetFlow,
                    water_level,true ,
                    outlet_press,false ,
                    null, null,
                    allMachineList, null, out error_info);

                return calc_pipe_helper.CalcKeepStatus(_open_machine_IdList);
            }
            else  
            { 
                Common.DispatchAnaGeneralHelper压力 calc_pipe1_helper
                    = new Common.DispatchAnaGeneralHelper压力();

                Common.DispatchAnaGeneralHelper压力 calc_pipe2_helper
                    = new Common.DispatchAnaGeneralHelper压力();

 
                //
                List<long> pipe1_machineIds = null;
                List<long> pipe2_machineIds = null;

                GetPipeMachineList(isOpenMiddleValve46, isOpenMiddleValve67,
                    out pipe1_machineIds, out pipe2_machineIds);

                if (pipe2_TargetFlow < 30)
                {//只开一号泵二号泵   
                    calc_pipe1_helper.InitialParas(
                        pipe1_TargetFlow,
                        water_level,true ,
                        pipe1_TargetPess,false ,
                        null, null,
                        (from x in allMachineList where pipe1_machineIds.Contains(x.MachineID) select x).ToList(), null, out error_info);

                    return calc_pipe1_helper.CalcKeepStatus(_open_machine_IdList);
                }
                else if (pipe1_TargetFlow < 30)
                {
                    calc_pipe2_helper.InitialParas(
                        pipe2_TargetFlow,
                        water_level, true,
                        pipe2_TargetPess, false,
                        null, null,
                        (from x in allMachineList where pipe2_machineIds.Contains(x.MachineID) select x).ToList(), null, out error_info);

                    return calc_pipe2_helper.CalcKeepStatus(_open_machine_IdList);
                }




                calc_pipe1_helper.InitialParas(
                    pipe1_TargetFlow,
                    water_level, true,
                    pipe1_TargetPess, false,
                     null, null,
                    (from x in allMachineList where pipe1_machineIds.Contains(x.MachineID) select x).ToList(), null, out error_info);
                var pipe1_result = calc_pipe1_helper.CalcKeepStatus(_open_machine_IdList);


                calc_pipe2_helper.InitialParas(
                    pipe2_TargetFlow,
                    water_level,true ,
                    pipe2_TargetPess,false ,
                    null, null,
                    (from x in allMachineList where pipe2_machineIds.Contains(x.MachineID) select x).ToList(), null, out error_info);

                var pipe2_result = calc_pipe2_helper.CalcKeepStatus(_open_machine_IdList);

                if (pipe1_result == null || pipe2_result == null)
                    return default;



                var connect_scheme = new Model.AnaScheme();
                connect_scheme.ID = 1;
                connect_scheme.TotalWrkQ = pipe1_result.TotalWrkQ + pipe2_result.TotalWrkQ;
                connect_scheme.TotalWrkH = (pipe1_result.TotalWrkH + pipe2_result.TotalWrkH) / 2;
                connect_scheme.TotalWrkP = pipe1_result.TotalWrkP + pipe2_result.TotalWrkP;
                connect_scheme.TotalWrkE = IStation.Common.PumpParaHelper.CalculateE(connect_scheme.TotalWrkQ, connect_scheme.TotalWrkH, connect_scheme.TotalWrkP);
                connect_scheme.UWP = CalculateUWP(connect_scheme.TotalWrkP, connect_scheme.TotalWrkQ, connect_scheme.TotalWrkH);
                connect_scheme.WP = CalculateWP(connect_scheme.TotalWrkP, connect_scheme.TotalWrkQ);

                connect_scheme.Items = new List<Model.AnaSchemeItem>();
                if (pipe1_result.Items != null && pipe1_result.Items.Count > 0)
                    connect_scheme.Items.AddRange(pipe1_result.Items);
                if (pipe2_result.Items != null && pipe2_result.Items.Count > 0)
                    connect_scheme.Items.AddRange(pipe2_result.Items);


                return connect_scheme;
            }

 
        }
    }
}