namespace IStation.Application
|
{
|
/// <summary>
|
/// 调度
|
/// </summary>
|
[Route("ChenHang/Dispatch")]
|
[ApiDescriptionSettings("Web", Name = "优化调度", Order = 3)]
|
public class OptimalSchedule_Controller : IDynamicApiController
|
{
|
private readonly Service.ScheduleRequest _service_schedule_request = new();
|
private readonly Service.ScheduleConclusion _service_schedule_conclusion = new();
|
private readonly Service.SchedulePump _service_schedule_pump = new();
|
|
/// <summary>
|
///获取泵站列表
|
/// </summary>
|
[Route("GetStationList@V1.0")]
|
[HttpGet]
|
public List<StationTreeItemOutput> GetStationList()
|
{
|
var station1 = new StationTreeItemOutput()
|
{
|
ID = 1,
|
Name = "陈行1输",
|
SortCode = 1
|
};
|
|
var station2 = new StationTreeItemOutput()
|
{
|
ID = 2,
|
Name = "陈行2输",
|
SortCode = 2
|
};
|
return new List<StationTreeItemOutput>() { station1, station2 };
|
}
|
|
/// <summary>
|
/// 调度
|
/// </summary>
|
[AllowAnonymous]
|
[Route("Calculate@V1.0")]
|
[HttpPost]
|
public OptScheduleOutput Calculate([Required] OptScheduleStationInput input)
|
{
|
var stationId = input.StationID;
|
var e_station = stationId == 1 ? IStation.eDockingStation.Ch1s : IStation.eDockingStation.Ch2s;
|
var receipt_time = DateTime.Now;
|
var request_id = Yw.YitIdHelper.NextId();
|
var log_title = string.Empty;
|
|
var station = new Service.Station().Get();
|
|
|
var water_level = input.WaterLevel;
|
var target_flow = input.TargetFlow;
|
var target_pressure = input.TargetPressure;
|
var target_head = Curve.PumpCalculateHelper.Mpa2M(target_pressure) - water_level;
|
|
log_title = "需水请求";
|
Log.Info(request_id, log_title, $"water_level:{water_level},target_flow:{target_flow},target_pressure:{target_pressure},target_head:{target_head}");
|
Log.Debug(request_id, log_title, JsonHelper.Object2Json(input));
|
|
List<Model.Pump> pumps = null;
|
List<int> flags_part1 = null, flags_part2 = null, current_open_pump_flags = null;
|
|
if (e_station == IStation.eDockingStation.Ch1s)
|
{
|
pumps = station.S1;
|
flags_part1 = station.S1FlagsPart1;
|
flags_part2 = station.S1FlagsPart2;
|
}
|
else
|
{
|
pumps = station.S2;
|
flags_part1 = station.S2FlagsPart1;
|
flags_part2 = station.S2FlagsPart2;
|
}
|
|
var helper = new IStation.Algorithm.ScheduleHelper();
|
var optimal_combine = helper.Calc(pumps, flags_part1, flags_part2, target_flow, target_head);
|
|
var schedule_request = new Model.ScheduleRequest();
|
schedule_request.ID = request_id;
|
if (stationId == 1)
|
{
|
schedule_request.WaterLevel1 = water_level;
|
schedule_request.TargetFlow1 = target_flow;
|
schedule_request.TargetPressure1 = target_pressure;
|
schedule_request.ScheduleStatus1 = optimal_combine != null;
|
}
|
else
|
{
|
schedule_request.WaterLevel2 = water_level;
|
schedule_request.TargetFlow2 = target_flow;
|
schedule_request.TargetPressure2 = target_pressure;
|
schedule_request.ScheduleStatus2 = optimal_combine != null;
|
}
|
|
schedule_request.TotalTimeSpent = (DateTime.Now - receipt_time).TotalSeconds;
|
schedule_request.ReceptionTime = receipt_time;
|
|
Model.ScheduleConclusion schedule_solution = null;
|
List<Model.SchedulePump> schedule_pump_list = null;
|
OptScheduleOutput output = null;
|
|
var msg = "计算成功";
|
log_title = "调度返回";
|
if (optimal_combine == null)
|
{
|
Log.Info(request_id, log_title, $"{stationId}:调度计算失败，无法满足目标流量:{target_flow},目标压力:{target_pressure}!");
|
Yw.Dto.YOops.Oh(Yw.Dto.eResultCode.Error, Yw.Dto.InternalErrorCodes.A001, $"{stationId}:调度计算失败，无法满足目标流量:{target_flow},目标压力:{target_pressure}!");
|
}
|
else
|
{
|
|
schedule_solution = new Model.ScheduleConclusion();
|
schedule_solution.ID = Yw.YitIdHelper.NextId();
|
schedule_solution.RequestID = request_id;
|
schedule_solution.Station = e_station;
|
schedule_solution.TotalFlow = optimal_combine.Flow;
|
schedule_solution.TotalHead = optimal_combine.Head;
|
schedule_solution.TotalPower = optimal_combine.Power;
|
schedule_solution.TotalEfficiency = optimal_combine.Efficiency;
|
schedule_solution.WP = optimal_combine.WP;
|
schedule_solution.UWP = optimal_combine.UWP;
|
schedule_solution.Flags = IntListHelper.ToString(optimal_combine.Flags);
|
schedule_solution.MeritRatio = optimal_combine.MeritRatio;
|
schedule_pump_list = new List<Model.SchedulePump>();
|
|
output = new OptScheduleOutput();
|
output.Station = new OptScheduleStationOutput();
|
output.Station.TotalFlow = optimal_combine.Flow;
|
output.Station.TotalPressure = Math.Round(Curve.PumpCalculateHelper.M2Mpa(optimal_combine.Head), 4);
|
output.Station.TotalPower = optimal_combine.Power;
|
output.Station.TotalEfficiency = optimal_combine.Efficiency;
|
output.Station.WP = optimal_combine.WP;
|
output.Station.UWP = optimal_combine.UWP;
|
output.Pumps = new List<OptSchedulePumpOutput>();
|
|
|
foreach (var combine in optimal_combine.Combines)
|
{
|
foreach (var fre_pump in combine.FrePumps)
|
{
|
var flag = fre_pump.Flag;
|
var chPump = new OptSchedulePumpOutput();
|
chPump.ID = flag;
|
chPump.Name = flag + "#";
|
chPump.Flow = fre_pump.Flow;
|
chPump.Head = fre_pump.Head;
|
chPump.Power = fre_pump.Power;
|
chPump.Efficiency = fre_pump.Efficiency;
|
chPump.Frequency = fre_pump.Frequency;
|
chPump.Speed = fre_pump.Speed;
|
chPump.Status = 1;
|
output.Pumps.Add(chPump);
|
|
var schedule_pump = new Model.SchedulePump();
|
schedule_pump.RequestID = request_id;
|
schedule_pump.Station = e_station;
|
schedule_pump.Flag = flag;
|
schedule_pump.Flow = fre_pump.Flow;
|
schedule_pump.Head = fre_pump.Head;
|
schedule_pump.Power = fre_pump.Power;
|
schedule_pump.Efficiency = fre_pump.Efficiency;
|
schedule_pump.Frequency = fre_pump.Frequency;
|
schedule_pump.Speed = fre_pump.Speed;
|
schedule_pump_list.Add(schedule_pump);
|
}
|
}
|
}
|
|
|
Log.Info(request_id, log_title, msg);
|
try
|
{
|
log_title = "存储方案";
|
var bol = false;
|
bol = _service_schedule_request.Insert(schedule_request) > 0;
|
if (!bol)
|
{
|
Log.Info(request_id, log_title, "schedule_request 插入异常");
|
Log.Debug(request_id, log_title, JsonHelper.Object2Json(schedule_request));
|
}
|
|
if (schedule_solution != null)
|
{
|
bol = _service_schedule_conclusion.Insert(schedule_solution) > 0;
|
if (!bol)
|
{
|
Log.Info(request_id, log_title, "schedule_solution 插入异常");
|
Log.Debug(request_id, log_title, JsonHelper.Object2Json(schedule_solution));
|
}
|
}
|
|
|
if (schedule_pump_list != null)
|
{
|
bol = _service_schedule_pump.Inserts(schedule_pump_list);
|
if (!bol)
|
{
|
Log.Info(request_id, log_title, "schedule_pump_list 插入异常");
|
Log.Debug(request_id, log_title, JsonHelper.Object2Json(schedule_pump_list));
|
}
|
}
|
}
|
catch (Exception ex)
|
{
|
Log.Error(request_id, log_title, "数据库异常!", ex);
|
}
|
return output;
|
}
|
|
|
|
}
|
}
|
