#region GetOptAnaCombine
|
|
//IStation.Service.ScheduleRequest _service_schedule_request = new();
|
//IStation.Service.ScheduleScada _service_schedule_scada = new();
|
//IStation.Service.ScheduleRule _service_schedule_rule = new();
|
//IStation.Service.ScheduleConclusion _service_schedule_conclusion = new();
|
//IStation.Service.SchedulePump _service_schedule_pump = new();
|
|
//IStation.Service.Station _service_station = new();
|
//IStation.Service.ScheduleConfig _service_schedule_config = new();
|
|
//var station_info = _service_station.Get();
|
|
|
//double target_flow1 = 25360.896;
|
//double target_head1 = IStation.Curve.PumpCalculateHelper.Mpa2M(0.3178);
|
|
//IStation.GlobalHelper.GetRealTimeZyScadaList(out List<IStation.Model.ZyScada> zy_scada_list, true);
|
|
//var station1 = station_info.Station1;
|
//var station1_schedule_config = _service_schedule_config.GetStation1();
|
|
//IStation.GlobalHelper.GetStationOpenFlagList(zy_scada_list, out List<int> station1_open_flag_list, out List<int> station2_open_flag_list);
|
//IStation.GlobalHelper.GetFlagInletWaterLevelDict(zy_scada_list, out Dictionary<int, double> station1_flag_inlet_water_level_dict, out Dictionary<int, double> station2_flag_inlet_water_level_dict);
|
|
//var helper = new IStation.Algorithm.ScheduleHelper();
|
//helper.Initial(station1_open_flag_list, station1_schedule_config);
|
//var optimal_test = helper.GetOptAnaCombine(station1, station1_flag_inlet_water_level_dict, target_flow1, target_head1);
|
|
#endregion
|
#region 模型单时刻验证
|
|
//IStation.HydraulicModelValidationHelper.Execute();
|
|
#endregion
|
#region 模型历史数据验证
|
|
//using IStation;
|
|
//IStation.ConfigHelper.DeleteDataBase(IStation.Settings.ParasHelper.DataBase.SQLite.ScheduleConnectString);
|
//IStation.ConfigHelper.DeleteDataBase(IStation.Settings.ParasHelper.DataBase.SQLite.HydraulicConnectString);
|
//IStation.ConfigHelper.InitScheduleDB();
|
//IStation.ConfigHelper.InitHydraulicDB();
|
//IStation.HistoryScadaValidHelper.Analysis();
|
|
#endregion
|
#region 模型历史数据偏差统计
|
//var minQ = 5000;
|
//var maxQ = 140000;
|
//var spaceQ = 2500;
|
//IStation.HistoryScadaValidHelper.Statistics(
|
// minQ,
|
// maxQ,
|
// spaceQ,
|
// out List<IStation.AvgStatisticsS1ViewModel> avg_statistics_station1_vm_list,
|
// out List<IStation.AvgStatisticsS2ViewModel> avg_statistics_station2_vm_list);
|
|
|
//var AvgStatisticsS1ViewModelList_json = Yw.JsonHelper.Object2FormatJson(avg_statistics_station1_vm_list);
|
//var AvgStatisticsS2ViewModelList_json = Yw.JsonHelper.Object2FormatJson(avg_statistics_station2_vm_list);
|
|
//File.WriteAllText("D:\\AvgStatisticsS1ViewModelList.json", AvgStatisticsS1ViewModelList_json);
|
//File.WriteAllText("D:\\AvgStatisticsS2ViewModelList.json", AvgStatisticsS2ViewModelList_json);
|
|
#endregion
|
#region 单泵累计运行时长统计
|
|
//using IStation;
|
//using IStation.Algorithm;
|
//var is_zy_scada_debug = true;
|
|
|
//GlobalHelper.GetRealTimeZyScadaList(out List<IStation.Model.ZyScada> zy_scada_list, is_zy_scada_debug);
|
//GlobalHelper.GetStationOpenFlagList(zy_scada_list, out List<int> station1_open_flag_list, out List<int> station2_open_flag_list);
|
|
|
//Dictionary<int, double> station1_flag_cumulative_run_time_dict = new()
|
//{
|
// { 11, 690.1 },
|
// { 12, 718.8 },
|
// { 13, 0 },
|
// { 14, 690.1 },
|
// { 15, 69.6 },
|
// { 16, 396 },
|
// { 17, 718.8 },
|
// { 18, 0 }
|
//};
|
|
//Dictionary<int, double> station2_flag_cumulative_run_time_dict = new()
|
//{
|
// { 21, 0 },
|
// { 22, 521 },
|
// { 23, 716 },
|
// { 24, 198 },
|
// { 25, 415 },
|
// { 26, 435 },
|
// { 27, 92 }
|
//};
|
|
|
|
|
|
//var config = new IStation.Service.ScheduleConfig().Get();
|
//var same_section_flag_combine_list1 = config.Station1.SameSectionFlagCombineList;
|
|
//var must_open_flag_list1 = config.Station1.MustOpenFlagList;
|
//var must_close_flag_list1 = config.Station1.MustCloseFlagList;
|
//var forbidden_flag_combine_list1 = config.Station1.ForbiddenFlagCombineList;
|
//var associative_flag_combine_list1 = config.Station1.AssociativeFlagCombineList;
|
|
//var same_section_flag_combine_list2 = config.Station2.SameSectionFlagCombineList;
|
//var must_open_flag_list2 = config.Station2.MustOpenFlagList;
|
//var must_close_flag_list2 = config.Station2.MustCloseFlagList;
|
//var forbidden_flag_combine_list2 = config.Station2.ForbiddenFlagCombineList;
|
//var associative_flag_combine_list2 = config.Station2.AssociativeFlagCombineList;
|
|
|
//var level_in = 5 * 24;
|
//var list_all = new List<Tuple<int, double, bool>>();
|
//foreach (var item in station1_flag_cumulative_run_time_dict)
|
//{
|
// var flag = item.Key;
|
// var level = item.Value / level_in;
|
// level = Math.Round(level, 2);
|
|
// var bol= station1_open_flag_list.Contains(flag);
|
// list_all.Add(new(flag, level, bol));
|
//}
|
|
//foreach (var item in station2_flag_cumulative_run_time_dict)
|
//{
|
// var flag = item.Key;
|
// var level = item.Value / level_in;
|
// var num = item.Value % level_in;
|
// level = Math.Round(level, 2);
|
// num = Math.Round(num, 2);
|
|
// var bol = station2_open_flag_list.Contains(flag);
|
// list_all.Add(new(flag, level, bol));
|
//}
|
|
//list_all = list_all.OrderBy(x => x.Item2).ThenBy(x => x.Item1).ToList();
|
////foreach (var item in list_all)
|
////{
|
//// Console.WriteLine($"{item.Item1} level:{item.Item2} num:{item.Item3}");
|
////}
|
|
|
//var list_list_list = new List<List<Tuple<int, double,bool>>>();
|
|
//foreach (var item in same_section_flag_combine_list1)
|
//{
|
// var list = new List<Tuple<int, double, bool>>();
|
// foreach (var v in item)
|
// {
|
// var flag = v;
|
// var run_time = station1_flag_cumulative_run_time_dict[v];
|
|
// if (must_open_flag_list1.Contains(flag))
|
// {
|
// continue;
|
// }
|
// if (must_close_flag_list1.Contains(flag))
|
// {
|
// continue;
|
// }
|
|
// var node = list_all.Find(x => x.Item1 == flag);
|
// list.Add(node);
|
// }
|
// list_list_list.Add(list);
|
//}
|
|
|
//foreach (var item in same_section_flag_combine_list2)
|
//{
|
// var list = new List<Tuple<int, double, bool>>();
|
// foreach (var v in item)
|
// {
|
// var flag = v;
|
// var run_time = station2_flag_cumulative_run_time_dict[v];
|
|
// if (must_open_flag_list2.Contains(flag))
|
// {
|
// continue;
|
// }
|
// if (must_close_flag_list2.Contains(flag))
|
// {
|
// continue;
|
// }
|
|
// var node = list_all.Find(x => x.Item1 == flag);
|
// list.Add(node);
|
// }
|
// list_list_list.Add(list);
|
//}
|
|
|
|
//foreach (var item in list_list_list)
|
//{
|
// Console.WriteLine("");
|
// foreach (var v in item)
|
// {
|
// var run = v.Item3 ? " v" : " x";
|
// Console.WriteLine($"{v.Item1} level:{v.Item2} run:{run}");
|
// }
|
//}
|
//Console.WriteLine("");
|
//Console.WriteLine("");
|
//foreach (var item in list_list_list)
|
//{
|
// Console.WriteLine("");
|
// foreach (var v in item)
|
// {
|
// var run = v.Item3 ? " v" : " x";
|
// var r = Math.Round(v.Item2 / 100, 2);
|
// var value = 1 - r;
|
// Console.WriteLine($"{v.Item1} {value} {run}");
|
// }
|
//}
|
|
|
|
|
|
|
|
//var config = new IStation.Service.ScheduleConfig().Get();
|
//var same_section_flag_combine_list1 = config.Station1.SameSectionFlagCombineList;
|
|
//var must_open_flag_list1 = config.Station1.MustOpenFlagList;
|
//var must_close_flag_list1 = config.Station1.MustCloseFlagList;
|
//var forbidden_flag_combine_list1 = config.Station1.ForbiddenFlagCombineList;
|
//var associative_flag_combine_list1 = config.Station1.AssociativeFlagCombineList;
|
|
//var same_section_flag_combine_list2 = config.Station2.SameSectionFlagCombineList;
|
//var must_open_flag_list2 = config.Station2.MustOpenFlagList;
|
//var must_close_flag_list2 = config.Station2.MustCloseFlagList;
|
//var forbidden_flag_combine_list2 = config.Station2.ForbiddenFlagCombineList;
|
//var associative_flag_combine_list2 = config.Station2.AssociativeFlagCombineList;
|
|
//var max_hour = 24 * 20;
|
//Console.WriteLine(max_hour);
|
//var list = new List<List<Tuple<int, double, bool>>>();
|
//foreach (var item in same_section_flag_combine_list1)
|
//{
|
// var list_list = new List<Tuple<int, double, bool>>();
|
// foreach (var v in item)
|
// {
|
// var flag = v;
|
// var run_time = station1_flag_cumulative_run_time_dict[v];
|
|
// if (must_open_flag_list1.Contains(flag))
|
// {
|
// continue;
|
// }
|
// if (must_close_flag_list1.Contains(flag))
|
// {
|
// continue;
|
// }
|
// if (station1_open_flag_list.Contains(flag))
|
// {
|
// list_list.Add(new(v, run_time, true));
|
// }
|
// else
|
// {
|
// list_list.Add(new(v, run_time, false));
|
// }
|
// }
|
// list.Add(list_list);
|
//}
|
|
|
//foreach (var item in same_section_flag_combine_list2)
|
//{
|
// var list_list = new List<Tuple<int, double, bool>>();
|
// foreach (var v in item)
|
// {
|
// var flag = v;
|
// var run_time = station2_flag_cumulative_run_time_dict[v];
|
|
// if (must_open_flag_list2.Contains(flag))
|
// {
|
// continue;
|
// }
|
// if (must_close_flag_list2.Contains(flag))
|
// {
|
// continue;
|
// }
|
// if (station2_open_flag_list.Contains(flag))
|
// {
|
// list_list.Add(new(v, run_time, true));
|
// }
|
// else
|
// {
|
// list_list.Add(new(v, run_time, false));
|
// }
|
// }
|
// list.Add(list_list);
|
//}
|
|
//foreach (var item in list)
|
//{
|
// Console.WriteLine("");
|
// foreach (var v in item)
|
// {
|
// var str = v.Item3 ? "" : "————";
|
// var str1 = "";
|
// if (v.Item2 > max_hour)
|
// {
|
// str1 = "xxx";
|
// }
|
// Console.WriteLine($"{v.Item1}:{str}{v.Item2}{str1}");
|
// }
|
// var max = item.Where(x => x.Item3).OrderBy(x => x.Item2).Last();
|
// var min = item.Where(x => !x.Item3).OrderBy(x => x.Item2).First();
|
// Console.WriteLine($"min:{min.Item1}-{min.Item2} max:{max.Item1}-{max.Item2}");
|
//}
|
|
|
//using IStation.Algorithm;
|
//using IStation.Curve;
|
//using IStation.Epanet.Network.Structures;
|
|
//List<Tuple<List<int>, double>> GetRatio(Dictionary<int,double> dict)
|
//{
|
|
// var list=new List<Tuple<int,double,double>>();
|
// foreach (var item in dict)
|
// {
|
// var flag = item.Key;
|
// var level = item.Value / 7;
|
// var num = item.Value % 7;
|
// list.Add(new (flag, level,num));
|
// }
|
|
// return default;
|
|
//}
|
|
|
|
|
#endregion
|
#region 定时保存实时数据
|
////创建一个定时器，设置间隔时间为5000毫秒（即5秒）
|
|
|
//using IStation;
|
|
//int count = 3600;
|
//int index = 0;
|
//do
|
//{
|
// Thread.Sleep(600);
|
// var log = HistoryScadaHelper.GetRealTimeZyScadaList(out List<IStation. Model.ZyScada> zy_scada_list);
|
// index++;
|
// Console.WriteLine(index);
|
//} while (index < count);
|
#endregion
|
#region ScadaModelValidHelper
|
|
// using IStation;
|
|
//ScadaModelValidHelper.Analysis3();
|
|
#endregion
|
|
|
#region
|
|
using System.Text;
|
|
var station = new IStation.Service.Station().Get();
|
var all_pump_list = new List<IStation.Model.Pump>();
|
all_pump_list.AddRange(station.Station1);
|
all_pump_list.AddRange(station.Station2);
|
|
var str_build = new StringBuilder();
|
var service=new IStation.Service.AnalysisParameter();
|
foreach (var pump in all_pump_list)
|
{
|
var run_flag = IStation.Algorithm.RunFlagHelper.GetRunFlag(pump.Flag,pump.IsBp);
|
var cl_list = service.GetList(run_flag);
|
var cl_by_hz_group=cl_list.GroupBy(x=>x.Hz).ToDictionary(x=>x.Key,x=>x.OrderBy(x=>x.PressureDiff).ToList());
|
|
foreach (var item in cl_by_hz_group)
|
{
|
var hz = item.Key;
|
var list = item.Value;
|
decimal min_pressure_diff = (decimal)list.First().PressureDiff;
|
decimal max_pressure_diff = (decimal)list.Last().PressureDiff;
|
|
for (decimal pre_diff = min_pressure_diff; pre_diff <= max_pressure_diff; pre_diff += 0.1m)
|
{
|
if (!list.Exists(x=>x.PressureDiff==(double)pre_diff))
|
{
|
str_build.AppendLine($"{pump.Flag}# {hz}hz {pre_diff}压差");
|
}
|
}
|
}
|
}
|
|
var info = str_build.ToString();
|
File.WriteAllText(@"D:\info2.txt",info);
|
Console.WriteLine(str_build.ToString());
|
|
#endregion
|
|
|
Console.WriteLine();
|
Console.WriteLine();
|
Console.WriteLine("OK");
|
Console.ReadKey();
|
