namespace IStation
|
{
|
/// <summary>
|
/// 模型验证辅助类
|
/// </summary>
|
public class HydraulicModelValidationHelperJob
|
{
|
private static readonly string _hydraulic_model_file = Path.Combine(
|
Settings.ParasHelper.LocalFile.DataFolderDirectory,
|
Settings.ParasHelper.LocalFile.HydraulicModelFile);
|
|
private static readonly Dictionary<string, double> _pump_nr_dict = new() {
|
{ "Pump11",590},
|
{ "Pump12",590},
|
{ "Pump13",590},
|
{ "Pump14",590},
|
//{ "Pump15",590},
|
//{ "Pump16",590},
|
{ "Pump17",590},
|
{ "Pump18",590},
|
|
{ "Pump21",740},
|
{ "Pump22",495},
|
{ "Pump23",495},
|
{ "Pump24",495},
|
{ "Pump25",495},
|
{ "Pump26",495},
|
{ "Pump27",740}
|
};
|
|
private static readonly List<string> _MPa = new();
|
private static readonly List<string> _kPa = new();
|
|
/// <summary>
|
///
|
/// </summary>
|
public static void Execute()
|
{
|
var verification_id = 1;
|
var current_time = DateTime.Now;
|
|
if (!File.Exists(_hydraulic_model_file))
|
{
|
// Log.Info(verification_id, $"模型验证计划任务中,水力模型文件不存在,自动跳过当前数据!");
|
// return;
|
}
|
var hydraulic_model_validation_config = new IStation.Service.HydraulicModelValidationConfig().Get();
|
if (hydraulic_model_validation_config == null)
|
{
|
// Log.Info(verification_id, "模型验证计划任务中,水力模型验证文件不存在,自动跳过当前数据!");
|
//return;
|
}
|
if (!Settings.ParasHelper.ZyDocking.Enable)
|
{
|
//Log.Info(verification_id, "模型验证计划任务中,Scada对接接口未启用,自动跳过当前数据!");
|
// return;
|
}//
|
|
|
|
var fileName = "D:\\ScadaDebug.json";
|
var json = File.ReadAllText(fileName);
|
var hydraulic_model_scada_list = Yw.JsonHelper.Json2Object<List<IStation.Model.HydraulicModelScada>>(json);
|
|
if (!hydraulic_model_scada_list.Any())
|
{
|
//Log.Info(verification_id, "模型验证计划任务中,接收Scada数据为空,自动跳过当前数据!");
|
// return;
|
}
|
else
|
{
|
// var json = Yw.JsonHelper.Object2Json(hydraulic_model_scada_list);
|
//Log.Debug(verification_id, json);
|
}
|
|
var flow_id_mapping_dict = hydraulic_model_validation_config.FlowIdMappingDict;
|
var pressure_id_mapping_dict = hydraulic_model_validation_config.PressureIdMappingDict;
|
var pattern_id_mapping_dict = hydraulic_model_validation_config.PatternIdMappingDict;
|
|
var pressure_id_kPa_list = hydraulic_model_validation_config.PressureIdkPaList;
|
|
var pattern_list = new List<IStation.Hydraulic.Pattern>();
|
var time_value = new IStation.Hydraulic.TimeValue
|
{
|
Time = current_time,
|
Value = new Dictionary<string, double>()
|
};
|
|
foreach (var hydraulic_model_scada in hydraulic_model_scada_list)
|
{
|
var tag = hydraulic_model_scada.Tag;
|
var value = hydraulic_model_scada.Value;
|
foreach (var item in flow_id_mapping_dict)
|
{
|
if (item.Value != tag)
|
continue;
|
time_value.Value.Add(tag, value ?? 0);
|
}
|
|
foreach (var item in pressure_id_mapping_dict)
|
{
|
if (item.Value != tag)
|
continue;
|
var pressure_value = value ?? 0;
|
if (pressure_id_kPa_list.Contains(tag))
|
{
|
pressure_value /= 1000;
|
}
|
pressure_value = IStation.Curve.PumpCalculateHelper.Mpa2M(pressure_value);
|
time_value.Value.Add(tag, pressure_value);
|
}
|
|
foreach (var item in pattern_id_mapping_dict)
|
{
|
if (item.Value != tag)
|
continue;
|
var pattern_id = item.Key;
|
var factor = value;
|
if (_pump_nr_dict.ContainsKey(pattern_id))
|
{
|
factor /= _pump_nr_dict[pattern_id];
|
factor = factor < 0 ? 0 : factor;
|
}
|
var pattern = new IStation.Hydraulic.Pattern
|
{
|
Id = pattern_id,
|
FactorList = new List<float>()
|
};
|
if (factor.HasValue)
|
pattern.FactorList.Add((float)factor.Value);
|
pattern_list.Add(pattern);
|
}
|
}
|
|
// Log.Info(verification_id, _hydraulic_model_file);//text
|
var hydraulic_model_record_list = IStation.Hydraulic.ModeVerifyHelper.Verify(verification_id, _hydraulic_model_file, flow_id_mapping_dict, pressure_id_mapping_dict, pattern_list, time_value);
|
if (hydraulic_model_record_list == null || !hydraulic_model_record_list.Any())
|
{
|
// Log.Info(verification_id, "模型验证计划任务中,模型验证数据为空，自动跳过当前数据!");
|
// return;
|
}
|
|
var hydraulic_model_validation = new Model.HydraulicModelValidation();
|
hydraulic_model_validation.ID = verification_id;
|
hydraulic_model_validation.Time = current_time;
|
//hydraulic_model_validation.Config = Yw.JsonHelper.Object2Json(hydraulic_model_validation_config);
|
|
var bol = new IStation.Service.HydraulicModelValidation().Insert(hydraulic_model_validation) > 0;
|
if (!bol)
|
{
|
//Log.Info(verification_id, "模型验证计划任务中,水力模型验证,保存失败!");
|
}
|
|
bol = new IStation.Service.HydraulicModelScada().Inserts(hydraulic_model_scada_list);
|
if (!bol)
|
{
|
// Log.Info(verification_id, "模型验证计划任务中,水力模型Scada,保存失败!");
|
}
|
|
bol = new IStation.Service.HydraulicModelRecord().Inserts(hydraulic_model_record_list);
|
if (!bol)
|
{
|
// Log.Info(verification_id, "模型验证计划任务中,水力模型记录,保存失败!");
|
}
|
|
// Log.Info(verification_id, $"模型验证计划任务中,水力模型验证,[{current_time:G}]验证成功!");
|
|
|
}
|
|
|
}
|
}
|
