namespace IStation.Application
{
    /// <summary>
    /// 调度决策
    /// </summary>
    [AllowAnonymous]
    [Route("Web/ScheduleDecision")]
    [ApiDescriptionSettings("Web", Name = "决策调度", Order = 2)]
    public class ScheduleDecision_Controller : IDynamicApiController, ITransient
    {
        private static readonly Service.ScheduleRequest _service_schedule_request = new();
        private static readonly Service.ScheduleScada _service_schedule_scada = new();
        private static readonly Service.ScheduleRule _service_schedule_rule = new();
        private static readonly Service.ScheduleConclusion _service_schedule_conclusion = new();
        private static readonly Service.SchedulePump _service_schedule_pump = new();

        private static readonly Service.Station _service_station = new();
        private static readonly Service.ScheduleConfig _service_schedule_config = new();

        private static readonly Service.AnalysisFactor _service_analysis_factor = new();
        private static readonly Service.AnalysisDeviation _service_analysis_deviation = new();

        private static readonly string _model_file = Path.Combine(
              Settings.ParasHelper.LocalFile.DataFolderDirectory,
              Settings.ParasHelper.LocalFile.HydraulicModelFile);


        /// <summary>
        /// 获取监测值
        /// </summary> 
        [Route("GetMonitorValue@V1.0")]
        [HttpGet]
        public ScheduleMonitorOutput GetMonitorValue()
        {

            GlobalHelper.GetMonitorRecordList(DateTime.Now, out List<Model.MonitorRecord> monitor_record_list, true);
            GlobalHelper.GetPipeFlagFlowAndPressureDict(monitor_record_list, out Dictionary<int, Tuple<double?, double?>> station1_pipe_flag_flow_pressure_dict, out Dictionary<int, Tuple<double?, double?>> station2_pipe_flag_flow_pressure_dict);
            var output = new ScheduleMonitorOutput();

            var target_flow1 = station1_pipe_flag_flow_pressure_dict.Sum(x => x.Value.Item1) ?? 0;
            var target_pressure1 = station1_pipe_flag_flow_pressure_dict.Average(x => x.Value.Item2) ?? 0;

            var target_flow2 = station2_pipe_flag_flow_pressure_dict.Sum(x => x.Value.Item1) ?? 0;
            var target_pressure2 = station2_pipe_flag_flow_pressure_dict.Average(x => x.Value.Item2) ?? 0;

            target_flow1.Round(1);
            target_pressure1.M2Mpa();
            target_pressure1.Round(5);

            target_flow2.Round(1);
            target_pressure2.M2Mpa();
            target_pressure2.Round(5);

            output.TargetFlow1 = target_flow1;
            output.TargetFlow2 = target_flow2;

            output.TargetPressure1 = target_pressure1;
            output.TargetPressure2 = target_pressure2;

            return output;
        }
         

        /// <summary>
        /// 计算
        /// </summary> 
        [Route("Calculate@V1.0")]
        [HttpPost]
        public DecisionCalcOutput Calculate([Required] ScheduleCalcInput input)
        {
            var receipt_time = DateTime.Now;
            var request_id = Yw.YitIdHelper.NextId();
            var station_info = _service_station.Get();
            if (station_info == null)
            {
                throw Yw.Dto.YOops.Oh(Yw.Dto.eResultCode.Error, Yw.Dto.InternalErrorCodes.A001, $"基础信息文件缺失!");
            }

            var target_flow1 = input.TargetFlow1;
            var target_mpa_pressure1 = input.TargetPressure1;

            var target_flow2 = input.TargetFlow2;
            var target_mpa_pressure2 = input.TargetPressure2;

            var target_pressure1 = Curve.PumpCalculateHelper.Mpa2M(target_mpa_pressure1);
            var target_pressure2 = Curve.PumpCalculateHelper.Mpa2M(target_mpa_pressure2);


            GlobalHelper.GetMonitorRecordList(receipt_time, out List<Model.MonitorRecord> monitor_record_list, true);


            var station1 = station_info.Station1;
            var station2 = station_info.Station2;
            var station1_schedule_config = _service_schedule_config.GetStation1();
            var station2_schedule_config = _service_schedule_config.GetStation2();
            var station1_flag_list = GlobalHelper.Station1FlagList;
            var station2_flag_list = GlobalHelper.Station2FlagList;


            var analysis_deviation_list = _service_analysis_deviation.GetList();
            var analysis_factor_list = _service_analysis_factor.GetList();

            GlobalHelper.GetStationOpenFlagList(monitor_record_list, out List<int> station1_open_flag_list, out List<int> station2_open_flag_list);
            GlobalHelper.GetStationFlagStateList(monitor_record_list, out List<int> station1_flag_maintenance_list, out List<int> station2_maintenance_flag_list, out List<int> station1_priority_flag_list, out List<int> station2_priority_flag_list);
            GlobalHelper.GetFlagInletWaterLevelDict(monitor_record_list, out Dictionary<int, double> station1_flag_inlet_water_level_dict, out Dictionary<int, double> station2_flag_inlet_water_level_dict);
            GlobalHelper.GetPipeFlagFlowAndPressureDict(monitor_record_list, out Dictionary<int, Tuple<double?, double?>> station1_pipe_flag_flow_pressure_dict, out Dictionary<int, Tuple<double?, double?>> station2_pipe_flag_flow_pressure_dict);
            GlobalHelper.GetFlagRpmAndFlowAndPressureDict(monitor_record_list, out Dictionary<int, Tuple<double?, double?>> station1_flag_rpm_pressure_dict, out Dictionary<int, Tuple<double?, double?, double?>> station2_flag_rpm_flow_pressure_dict);

            if (station1_flag_maintenance_list != null && station1_flag_maintenance_list.Any())
            {
                ScheduleLog.Info(request_id, "机泵检修", $"1输水:{Yw.Untity.IntListHelper.ToString(station1_flag_maintenance_list)}");
                station1_schedule_config.MustCloseFlagList.AddRange(station1_flag_maintenance_list);
            }
            if (station2_maintenance_flag_list != null && station2_maintenance_flag_list.Any())
            {
                ScheduleLog.Info(request_id, "机泵检修", $"2输水:{Yw.Untity.IntListHelper.ToString(station2_maintenance_flag_list)}");
                station2_schedule_config.MustCloseFlagList.AddRange(station2_maintenance_flag_list);
            }

            if (station1_priority_flag_list != null && station1_priority_flag_list.Any())
            {
                ScheduleLog.Info(request_id, "机泵优先", $"1输水:{Yw.Untity.IntListHelper.ToString(station1_priority_flag_list)}");
                station1_schedule_config.MustOpenFlagList.AddRange(station1_priority_flag_list);
            }
            if (station2_priority_flag_list != null && station2_priority_flag_list.Any())
            {
                ScheduleLog.Info(request_id, "机泵优先", $"2输水:{Yw.Untity.IntListHelper.ToString(station2_priority_flag_list)}");
                station2_schedule_config.MustOpenFlagList.AddRange(station2_priority_flag_list);
            }


            analysis_deviation_list = null;
            var helper = new Service.ScheduleHelper();

            helper.Initial(station1_open_flag_list, station1_schedule_config, analysis_deviation_list);
            var optimal_combine1 = helper.GetOptAnaCombine(station1, station1_flag_inlet_water_level_dict, target_flow1, target_pressure1);

            helper.Initial(station2_open_flag_list, station2_schedule_config, analysis_deviation_list);
            var optimal_combine2 = helper.GetOptAnaCombine(station2, station2_flag_inlet_water_level_dict, target_flow2, target_pressure2);

            if (optimal_combine1 == null && optimal_combine2 == null)
            {
                throw Yw.Dto.YOops.Oh(Yw.Dto.eResultCode.Error, Yw.Dto.InternalErrorCodes.A001, $"计算失败!");
            }


            var pump_id_mapping_dict = GlobalHelper.ModelPumpIdMappingDict;
            var pattern_id_mapping_dict = GlobalHelper.ModelPatternIdMappingDict;

            var output = new DecisionCalcOutput();
            output.PumpCompares1 = new List<DecisionPumpCompare>();
            output.PumpCompares2 = new List<DecisionPumpCompare>();

            if (optimal_combine1 != null)
            {
                optimal_combine1.Round();
                var pump_bp_dict = station1.ToDictionary(x => x.Flag, x => x.IsBp);
                foreach (var flag in GlobalHelper.Station1FlagList)
                {
                    var name = $"{flag}#泵";
                    var rpm_pressure = station1_flag_rpm_pressure_dict[flag];
                    var wl = station1_flag_inlet_water_level_dict[flag];
                    var compare = new DecisionPumpCompare();
                    compare.SrcWaterLevel = wl;
                    compare.Name = name;
                    compare.SrcSpeed = rpm_pressure.Item1;
                    compare.SrcPressure = rpm_pressure.Item2;
                    output.PumpCompares1.Add(compare);

                    var fre_pump = optimal_combine1.AnaFrePumps.Find(x => x.Flag == flag);
                    if (fre_pump != null)
                    {
                        var pressure = fre_pump.PressureDiff + wl;
                        compare.CalcSpeed = fre_pump.Speed;
                        compare.DiffSpeed = compare.CalcSpeed - compare.SrcSpeed;
                        compare.CalcFlow = fre_pump.Flow;
                        //compare.DiffFlow = compare.CalcFlow - compare.SrcFlow;
                        compare.DiffFlow = null;
                        compare.CalcPressure = Math.Round(pressure, 1);
                        compare.DiffPressure = compare.CalcPressure - compare.SrcPressure;

                        if (compare.DiffSpeed.HasValue)
                            compare.DiffSpeed = Math.Round(compare.DiffSpeed.Value, 1);
                        if (compare.DiffPressure.HasValue)
                            compare.DiffPressure = Math.Round(compare.DiffPressure.Value, 1);
                    }

                }

            }

            if (optimal_combine2 != null)
            {
                optimal_combine2.Round();
                var pump_bp_dict = station2.ToDictionary(x => x.Flag, x => x.IsBp);
                foreach (var flag in GlobalHelper.Station2FlagList)
                {
                    var name = $"{flag}#泵";
                    var rpm_pressure = station2_flag_rpm_flow_pressure_dict[flag];
                    var wl = station2_flag_inlet_water_level_dict[flag];
                    var compare = new DecisionPumpCompare();
                    compare.Name = name;
                    compare.SrcWaterLevel = wl;
                    compare.SrcSpeed = rpm_pressure.Item1;
                    compare.SrcFlow = rpm_pressure.Item2;
                    compare.SrcPressure = rpm_pressure.Item3;
                    output.PumpCompares2.Add(compare);

                    var fre_pump = optimal_combine2.AnaFrePumps.Find(x => x.Flag == flag);
                    if (fre_pump != null)
                    {
                        var pressure = fre_pump.PressureDiff + wl;

                        compare.CalcSpeed = fre_pump.Speed;
                        compare.DiffSpeed = compare.CalcSpeed - compare.SrcSpeed;
                        compare.CalcFlow = fre_pump.Flow;
                        compare.DiffFlow = compare.CalcFlow - compare.SrcFlow;
                        compare.CalcPressure = Math.Round(pressure,1);
                        compare.DiffPressure = compare.CalcPressure - compare.SrcPressure;

                        if (compare.DiffSpeed.HasValue)
                            compare.DiffSpeed = Math.Round(compare.DiffSpeed.Value, 1);
                        if (compare.DiffPressure.HasValue)
                            compare.DiffPressure = Math.Round(compare.DiffPressure.Value, 1);
                        if (compare.DiffFlow.HasValue)
                            compare.DiffFlow = Math.Round(compare.DiffFlow.Value, 1);
                    }
                }
            }


            return output;
        }
         
          
    }
}