blame | 历史 | 补丁 | 提交 | 提交对比 | 忽略空白
Shuxia Ning
2025-02-13 2f1cbec203dcff25df7a5c2b51b13ec558f2c3db 
 01-api/Service/IStation.Service/07-helper/02-schedule/ScheduleHelper.cs


@@ -1,7 +1,4 @@


using IStation.Application;


using IStation.Model;




namespace IStation.Service


namespace IStation.Service


{


    /// <summary>


    /// 调度分析辅助类


@@ -19,8 +16,7 @@


                this.Flag = flag;


            }


            public int Flag { get; set; }


        }




        } 


        #endregion




        #region Private Variable


@@ -37,7 +33,7 @@


        private readonly double _sel_opt_flow_deviation_ratio = 0.05;//可选方案的流量偏差比


        private readonly double _sel_opt_reasonable_flow_deviation_ratio = 0.005;//合理的方案的流量偏差比




        private readonly Service.AnalysisParameter _service_analysis_conclusion = new();


        private readonly Service.AnalysisParameter _service_analysis_parameter = new();


        private readonly Service.AnalysisDeviation _service_analysis_deviation = new();


        private readonly Service.AnalysisFactor _service_analysis_factor = new();




@@ -45,15 +41,16 @@


        private int _max_open_count;//最大开泵数量


        private List<int> _current_open_flag_list = null;// 当前开泵列表


        private List<int> _must_open_flag_list = null; // 必开泵列表  


        private List<int> _must_close_flag_list = null; // 必关泵列表   


        private List<int> _must_close_flag_list = null; // 必关泵列表


        private List<List<int>> _forbidden_flag_combine_list = null; // 禁用泵组合 


        private List<List<int>> _associative_flag_combine_list = null; // 关联泵组合 


        private List<List<int>> _same_section_flag_combine_list = null; // 同段泵组合  


        private List<Model.WaterSupplyLimit> _water_supply_limit_list = null; //供水限制列表


        private List<Model.FrequencyLimit> _frequency_limit_list = null; // 频率限制列表


        private Dictionary<int, double> _flag_cumulative_runtime_dict = null; // 泵累计运行时长字典


        private List<int> _priority_open_flag_list = null; // 优先开泵列表




        




        private List<Model.AnalysisDeviation> _analysis_deviation_list = null;//分析偏差




        #endregion


@@ -75,6 +72,7 @@


            _water_supply_limit_list = null;


            _frequency_limit_list = null;


            _flag_cumulative_runtime_dict = null;


            _priority_open_flag_list = null;


            if (schedule_config != null)


            {


                _min_open_count = schedule_config.MinOpenCount;


@@ -87,6 +85,7 @@


                _water_supply_limit_list = schedule_config.WaterSupplyLimitList;


                _frequency_limit_list = schedule_config.FrequencyLimitList;


                _flag_cumulative_runtime_dict = schedule_config.FlagCumulativeRuntimeDict;


                _priority_open_flag_list = schedule_config.PriorityOpenFlagList;


            }




            _analysis_deviation_list = analysis_deviation_list;


@@ -95,8 +94,7 @@






        #region OptAnaCombine






         


        /// <summary>


        /// 获取最优组合


        /// </summary>


@@ -107,7 +105,7 @@


        /// <returns></returns>


        public AnaCombine GetOptAnaCombine


            (


            List<Model.Pump> pump_list, 


            List<Model.Pump> pump_list,


            Dictionary<int, double> flag_inlet_water_level_dict,


            double target_flow,


            double target_pressure


@@ -131,6 +129,7 @@


            var water_supply_limit_list = _water_supply_limit_list;


            var frequency_limit_list = _frequency_limit_list;


            var flag_cumulative_runtime_dict = _flag_cumulative_runtime_dict;


            var priority_open_flag_list = _priority_open_flag_list;




            var pump_bp_dict = pump_list.ToDictionary(x => x.Flag, x => x.IsBp);


            var pump_nr_dict = pump_list.ToDictionary(x => x.Flag, x => x.Nr);


@@ -193,6 +192,10 @@


            {


                var water_supply_min = water_supply_limit_list.Min(x => x.Min);


                var water_supply_max = water_supply_limit_list.Max(x => x.Max);




#if DEBUG


                water_supply_min = 0;


#endif


                if (target_flow < water_supply_min || target_flow > water_supply_max)


                {


                    return default;


@@ -220,6 +223,18 @@


            {


                flag_cumulative_runtime_loss_ratio_dict = GetFlagCumulativeRuntimeLossRatioDict(flag_cumulative_runtime_dict);


            }


            #endregion




            #region 存在-优先开泵列表




            var priority_open_flag_list_remark = string.Empty;


            var exist_priority_open_flag_list = priority_open_flag_list != null && priority_open_flag_list.Count > 0;


            if (exist_priority_open_flag_list)


            {


                priority_open_flag_list = priority_open_flag_list.OrderBy(x => x).ToList();


                priority_open_flag_list_remark = IntListHelper.ToString(priority_open_flag_list);


            }




            #endregion




            #region 存在-当前开泵列表 (是否切泵)


@@ -260,6 +275,7 @@


            }




            #endregion






            #endregion




@@ -405,6 +421,23 @@


                        }


                    }




                    //优先开泵列表


                    if (exist_priority_open_flag_list)


                    {


                        //foreach (var flag in priority_open_flag_list)


                        //{


                        //    if (combine.Contains(flag))


                        //    {


                        //        combine_merit_ratio *= 1.05;


                        //    } 


                        //}




                        //目前逻辑 优先开泵==必开方案


                        var combine_remark = IntListHelper.ToString(combine.OrderBy(x => x));


                        if (!combine_remark.Contains(priority_open_flag_list_remark))


                            continue;


                    }




                    #endregion




                    var total_loss_ratio = Math.Pow(_start_stop_loss_coefficient, start_stop_count);//启停一次损失些能耗


@@ -477,54 +510,7 @@


                return default;




            //先修正组合曲线和模型的偏差扬程


            var combine_deviation_factor_dict = GetCombineDeviationFactorDict(target_flow, combine);


             


            if (GlobalHelper.IsStation1(combine))


            {


                var err_combine = new List<Tuple<double, List<int>>>()


                {


                    new (23500, new List<int>(){12,13,14,15,17 })


                };




                var exist_err_combine = err_combine.Find(x => x.Item2.SequenceEqual(combine));


                if (exist_err_combine != null)


                {


                    ScheduleLog.Info(-1, "测试", $"目标:{target_pressure}");


                    if (target_flow > exist_err_combine.Item1)


                    {


                        var dev_diff = 0.5;


                        foreach (var flag in combine)


                        {


                            var dev_pressure = combine_deviation_factor_dict[flag];


                            combine_deviation_factor_dict[flag] = dev_pressure - dev_diff;


                            //combine_deviation_factor_dict[flag] = 0;


                            ScheduleLog.Info(-1, "测试", $"{flag}#:压力偏差{dev_pressure}-{dev_diff}={dev_pressure - dev_diff:N4}");


                        }


                    }


                }


            }


            else


            {


                //var err_combine = new List<Tuple<double, List<int>>>()


                //{


                //    new (29000, new List<int>(){22,23,26})


                //};


                //var exist_err_combine = err_combine.Find(x => x.Item2.SequenceEqual(combine));


                //if (exist_err_combine != null)


                //{


                //    ScheduleLog.Info(-1, "测试", $"目标:{target_pressure}");


                //    if (target_flow > exist_err_combine.Item1)


                //    {


                //        foreach (var flag in combine)


                //        {




                //            combine_deviation_factor_dict[flag] = 0;


                //            ScheduleLog.Info(-1, "测试", $"{flag}#:压力偏差{0}");


                //        }


                //    }


                //}


            }




            var combine_deviation_factor_dict = GetCombineDeviationFactorDict(target_flow, combine); 


            var conclusion_ex_list_list = new List<List<AnalysisConclusionViewModel>>();


            var conclusion_ex_list_dict = new Dictionary<int, List<AnalysisConclusionViewModel>>();


            double max_supply_flow = 0;


@@ -545,13 +531,13 @@


                if (exist_frequency_limit_list && frequency_limit_flag_dict.ContainsKey(flag))


                {


                    var limit = frequency_limit_flag_dict[flag];


                    conclusion_list = _service_analysis_conclusion.GetList(run_flag, limit.Min, limit.Max, current_pressure_diff);


                    conclusion_list = _service_analysis_parameter.GetList(run_flag, limit.Min, limit.Max, current_pressure_diff);


                }


                else


                {




                    //定频泵 可能最小压差超过目标压差


                    var min_pressure_diff_conclusion = _service_analysis_conclusion.GetMinPressureDiff(run_flag);


                    var min_pressure_diff_conclusion = _service_analysis_parameter.GetMinPressureDiff(run_flag);


                    if (min_pressure_diff_conclusion != null && min_pressure_diff_conclusion.PressureDiff > current_pressure_diff)


                    {


                        conclusion_list = new List<Model.AnalysisParameter>() { min_pressure_diff_conclusion };


@@ -561,7 +547,7 @@


                        var is_bp = pump_bp_dict[flag];


                        if (is_bp)


                        {


                            conclusion_list = _service_analysis_conclusion.GetList(run_flag, current_pressure_diff);


                            conclusion_list = _service_analysis_parameter.GetList(run_flag, current_pressure_diff);


                        }


                        else


                        {