using Microsoft.AspNetCore.Mvc;
|
using System.Net;
|
using System.Net.Http.Headers;
|
using Microsoft.Extensions.Hosting.Internal;
|
using Microsoft.AspNetCore.Http.Extensions;
|
using IStation.Untity;
|
using Furion.DynamicApiController;
|
using System.ComponentModel.DataAnnotations;
|
using Mapster;
|
|
|
namespace IStation.Application
|
{
|
/// <summary>
|
/// PumpCurve
|
/// </summary>
|
[Route("Product/PumpCurve/Logic")]
|
[ApiDescriptionSettings("Product", Name = "泵曲线", Order = 399)]
|
public class PumpCurve_LogicController : IDynamicApiController
|
{
|
|
|
/// <summary>
|
/// 通过 EnginePumpID 获取频率曲线(业务)
|
/// </summary>
|
[Route("GetHZByEnginePumpID@V1.0")]
|
[HttpGet]
|
public PumpHZCurveLogicDto GetHZByEnginePumpID
|
(
|
[Required,Range(1,long.MaxValue,ErrorMessage ="CorpID 必须大于0")]
|
long CorpID,
|
[Required,Range(1,long.MaxValue,ErrorMessage ="EnginePumpID 必须大于0")]
|
long EnginePumpID,
|
[Required]
|
double HZ
|
)
|
{
|
var pump = new Service.Product().GetChildPumpByEnginePumpID(CorpID, EnginePumpID);
|
if (pump == null)
|
{
|
throw new Exception("未检索到泵信息");
|
}
|
var curve = new Service.PumpCurveExMapping().GetDefaultWorkingByPumpID(pump.CorpID, pump.ID);
|
if (curve == null)
|
{
|
throw new Exception("未检索到泵曲线信息");
|
}
|
|
var vm = new PumpHZCurveLogicDto();
|
if (HZ > 49.5)
|
{
|
if (curve.CurveInfo != null && curve.CurveInfo.CurveQH != null)
|
{
|
vm.PointQH = curve.CurveInfo.CurveQH.GetFitPoints(20)?.Select(x=>new CurvePointDto(x.X,x.Y)).ToList();
|
if (curve.CurveInfo.CurveQP != null)
|
{
|
vm.PointQP = curve.CurveInfo.CurveQP.GetFitPoints(20)?.Select(x => new CurvePointDto(x.X, x.Y)).ToList();
|
}
|
}
|
}
|
else
|
{
|
if (curve.CurveInfo != null)
|
{
|
vm.PointQH = curve.CalcuCurveQhByHz(HZ).GetFitPoints(20)?.Select(x => new CurvePointDto(x.X, x.Y)).ToList();
|
vm.PointQP = curve.CalcuCurveQpByHz(HZ).GetFitPoints(20)?.Select(x => new CurvePointDto(x.X, x.Y)).ToList();
|
}
|
}
|
|
return vm;
|
}
|
|
/// <summary>
|
/// 通过 PumpID 获取频率曲线(业务)
|
/// </summary>
|
[Route("GetHzByPumpID@V1.0")]
|
[HttpGet]
|
public PumpHZCurveLogicDto GetHzByPumpID
|
(
|
[Required,Range(1,long.MaxValue,ErrorMessage ="CorpID 必须大于0")]
|
long CorpID,
|
[Required,Range(1,long.MaxValue,ErrorMessage ="PumpID 必须大于0")]
|
long PumpID,
|
[Required]
|
double HZ
|
)
|
{
|
var curve = new Service.PumpCurveExMapping().GetDefaultWorkingByPumpID(CorpID,PumpID);
|
if (curve == null)
|
{
|
throw new Exception("未检索到泵曲线信息");
|
}
|
|
var vm = new PumpHZCurveLogicDto();
|
if (HZ > 49.5)
|
{
|
if (curve.CurveInfo != null && curve.CurveInfo.CurveQH != null)
|
{
|
vm.PointQH = curve.CurveInfo.CurveQH.GetFitPoints(20)?.Select(x => new CurvePointDto(x.X, x.Y)).ToList();
|
if (curve.CurveInfo.CurveQP != null)
|
{
|
vm.PointQP = curve.CurveInfo.CurveQP.GetFitPoints(20)?.Select(x => new CurvePointDto(x.X, x.Y)).ToList();
|
}
|
}
|
}
|
else
|
{
|
if (curve.CurveInfo != null)
|
{
|
vm.PointQH = curve.CalcuCurveQhByHz(HZ).GetFitPoints(20)?.Select(x => new CurvePointDto(x.X, x.Y)).ToList();
|
vm.PointQP = curve.CalcuCurveQpByHz(HZ).GetFitPoints(20)?.Select(x => new CurvePointDto(x.X, x.Y)).ToList();
|
}
|
}
|
|
return vm;
|
}
|
|
/// <summary>
|
/// 计算泵并联曲线(业务)
|
/// </summary>
|
[Route("CalculateParallel@V1.0")]
|
[HttpPost]
|
public PumpParallelCurveLogicDto CalculateParallel([Required] PumpParallelCurveInput input)
|
{
|
|
var service = new Service.PumpCurveExMapping();
|
var curve_qh_list = new List<Model.CurveExpress>();
|
var curve_qp_list = new List<Model.CurveExpress>();
|
var h_min = double.MinValue;
|
var h_max = double.MaxValue;
|
|
foreach (var item in input.Items)
|
{
|
var curve = service.GetDefaultWorkingByPumpID(input.CorpID, item.PumpID);
|
if (curve == null)
|
continue;
|
if (item.HZ > 49.5)
|
{
|
if (curve.CurveInfo != null && curve.CurveInfo.CurveQH != null)
|
{
|
curve_qh_list.Add(curve.CurveInfo.CurveQH);
|
if (curve.CurveInfo.CurveQP != null)
|
{
|
curve_qp_list.Add(curve.CurveInfo.CurveQP);
|
}
|
}
|
}
|
else
|
{
|
var curve_qh = curve.CalcuCurveQhByHz(item.HZ);
|
if (curve_qh != null)
|
{
|
curve_qh_list.Add(curve_qh);
|
var curve_qp = curve.CalcuCurveQpByHz(item.HZ);
|
if (curve_qp != null)
|
{
|
curve_qp_list.Add(curve_qp);
|
}
|
}
|
}
|
|
var curve_qh_last = curve_qh_list.LastOrDefault();
|
if (curve_qh_last != null)
|
{
|
var curve_qh_first_point = curve_qh_last.GetFirstFitPoint();
|
h_max = Math.Min(h_max, curve_qh_first_point.Y);
|
var curve_qh_last_point = curve_qh_last.GetLastFitPoint();
|
h_min = Math.Max(h_min, curve_qh_last_point.Y);
|
|
}
|
}
|
|
if (curve_qh_list.Count < 2)
|
{
|
throw new Exception("NULL1");
|
}
|
if (h_max < h_min)
|
{
|
throw new Exception("NULL2");
|
}
|
|
double space_h = (h_max - h_min) / 19;
|
var points_qh_parallel = new List<Model.CurvePoint>();
|
var points_qp_parallel = new List<Model.CurvePoint>();
|
|
for (var h = h_min; h <= h_max; h = h + space_h)
|
{
|
double total_flow = 0;
|
double total_power = 0;
|
|
for (int j = 0; j < curve_qh_list.Count; j++)
|
{
|
var curve_qh = curve_qh_list[j];
|
var curve_qp = curve_qp_list[j];
|
var pts = Model.FitCurveHelper.GetInterPointX(curve_qh, h);
|
if (pts != null && pts.Count > 0)
|
{
|
var q = pts.Last().X;
|
total_flow += q;
|
total_power += curve_qp.GetFitPointY(q);
|
}
|
}
|
points_qh_parallel.Add(new Model.CurvePoint(total_flow, h));
|
points_qp_parallel.Add(new Model.CurvePoint(total_flow, total_power));
|
}
|
|
var vm = new PumpParallelCurveLogicDto();
|
vm.PointQH = Model.FitCurveHelper.GetFitPoints(points_qh_parallel, 20)?.Select(x => new CurvePointDto(x.X, x.Y)).ToList();
|
vm.PointQP = Model.FitCurveHelper.GetFitPoints(points_qp_parallel, 20)?.Select(x => new CurvePointDto(x.X, x.Y)).ToList();
|
|
return vm;
|
}
|
|
/// <summary>
|
/// 计算泵并联曲线拓展（包含单泵曲线）(业务)
|
/// </summary>
|
[Route("CalculateParallelEx@V1.0")]
|
[HttpPost]
|
public List<PumpParallelCurveExLogicDto> CalculateParallelEx([Required] PumpParallelCurveInput input)
|
{
|
|
var service_product = new Service.Product();
|
var service_curve = new Service.PumpCurveExMapping();
|
var vm_list = new List<PumpParallelCurveExLogicDto>();
|
var curve_qh_list = new List<Model.CurveExpress>();
|
var curve_qp_list = new List<Model.CurveExpress>();
|
var h_min = double.MinValue;
|
var h_max = double.MaxValue;
|
|
foreach (var item in input.Items)
|
{
|
var pump = service_product.GetByID(input.CorpID, item.PumpID);
|
if (pump == null)
|
continue;
|
var curve = service_curve.GetDefaultWorkingByPumpID(pump.CorpID, pump.ID);
|
if (curve == null)
|
continue;
|
if (item.HZ > 49.5)
|
{
|
if (curve.CurveInfo != null && curve.CurveInfo.CurveQH != null)
|
{
|
curve_qh_list.Add(curve.CurveInfo.CurveQH);
|
if (curve.CurveInfo.CurveQP != null)
|
{
|
curve_qp_list.Add(curve.CurveInfo.CurveQP);
|
}
|
}
|
}
|
else
|
{
|
var curve_qh = curve.CalcuCurveQhByHz(item.HZ);
|
if (curve_qh != null)
|
{
|
curve_qh_list.Add(curve_qh);
|
var curve_qp = curve.CalcuCurveQpByHz(item.HZ);
|
if (curve_qp != null)
|
{
|
curve_qp_list.Add(curve_qp);
|
}
|
}
|
}
|
|
var curve_qh_last = curve_qh_list.LastOrDefault();
|
if (curve_qh_last != null)
|
{
|
var curve_qh_first_point = curve_qh_last.GetFirstFitPoint();
|
h_max = Math.Min(h_max, curve_qh_first_point.Y);
|
var curve_qh_last_point = curve_qh_last.GetLastFitPoint();
|
h_min = Math.Max(h_min, curve_qh_last_point.Y);
|
}
|
var vm_parallel_curve = new PumpParallelCurveExLogicDto();
|
vm_parallel_curve.Type = 0;
|
vm_parallel_curve.Name = pump.Name;
|
vm_parallel_curve.PointQH = curve_qh_list.LastOrDefault()?.GetFitPoints(20)?.Select(x => new CurvePointDto(x.X, x.Y)).ToList();
|
vm_parallel_curve.PointQP = curve_qp_list.LastOrDefault()?.GetFitPoints(20)?.Select(x => new CurvePointDto(x.X, x.Y)).ToList();
|
vm_list.Add(vm_parallel_curve);
|
}
|
|
if (curve_qh_list.Count < 2)
|
{
|
throw new Exception("NULL1");
|
}
|
if (h_max < h_min)
|
{
|
throw new Exception("NULL2");
|
}
|
|
double space_h = (h_max - h_min) / 19;
|
var points_qh_parallel = new List<Model.CurvePoint>();
|
var points_qp_parallel = new List<Model.CurvePoint>();
|
|
for (var h = h_min; h <= h_max; h = h + space_h)
|
{
|
double total_flow = 0;
|
double total_power = 0;
|
|
for (int j = 0; j < curve_qh_list.Count; j++)
|
{
|
var curve_qh = curve_qh_list[j];
|
var curve_qp = curve_qp_list[j];
|
var pts = Model.FitCurveHelper.GetInterPointX(curve_qh, h);
|
if (pts != null && pts.Count > 0)
|
{
|
var q = pts.Last().X;
|
total_flow += q;
|
total_power += curve_qp.GetFitPointY(q);
|
}
|
}
|
points_qh_parallel.Add(new Model.CurvePoint(total_flow, h));
|
points_qp_parallel.Add(new Model.CurvePoint(total_flow, total_power));
|
}
|
|
var vm = new PumpParallelCurveExLogicDto();
|
vm.Type = 1;
|
vm.Name = "并联曲线";
|
vm.PointQH = Model.FitCurveHelper.GetFitPoints(points_qh_parallel, 20)?.Select(x => new CurvePointDto(x.X, x.Y)).ToList();
|
vm.PointQP = Model.FitCurveHelper.GetFitPoints(points_qp_parallel, 20)?.Select(x => new CurvePointDto(x.X, x.Y)).ToList();
|
vm_list.Insert(0, vm);
|
|
return vm_list;
|
}
|
|
/// <summary>
|
/// 计算机泵并联曲线(业务)
|
/// </summary>
|
[Route("CalculateEnginePumpParallel@V1.0")]
|
[HttpPost]
|
public PumpParallelCurveLogicDto CalculateEnginePumpParallel([Required] EnginePumpParallelCurveInput input)
|
{
|
var service_product = new Service.Product();
|
var service_curve = new Service.PumpCurveExMapping();
|
|
var curve_qh_list = new List<Model.CurveExpress>();
|
var curve_qp_list = new List<Model.CurveExpress>();
|
var h_min = double.MinValue;
|
var h_max = double.MaxValue;
|
|
foreach (var item in input.Items)
|
{
|
var pump = service_product.GetChildPumpByEnginePumpID(input.CorpID, item.EnginePumpID);
|
if (pump == null)
|
continue;
|
var curve = service_curve.GetDefaultWorkingByPumpID(pump.CorpID, pump.ID);
|
if (curve == null)
|
continue;
|
|
if (item.HZ > 49.5)
|
{
|
if (curve.CurveInfo != null && curve.CurveInfo.CurveQH != null)
|
{
|
curve_qh_list.Add(curve.CurveInfo.CurveQH);
|
if (curve.CurveInfo.CurveQP != null)
|
{
|
curve_qp_list.Add(curve.CurveInfo.CurveQP);
|
}
|
}
|
}
|
else
|
{
|
var curve_qh = curve.CalcuCurveQhByHz(item.HZ);
|
if (curve_qh != null)
|
{
|
curve_qh_list.Add(curve_qh);
|
var curve_qp = curve.CalcuCurveQpByHz(item.HZ);
|
if (curve_qp != null)
|
{
|
curve_qp_list.Add(curve_qp);
|
}
|
}
|
}
|
|
var curve_qh_last = curve_qh_list.LastOrDefault();
|
if (curve_qh_last != null)
|
{
|
var curve_qh_first_point = curve_qh_last.GetFirstFitPoint();
|
h_max = Math.Min(h_max, curve_qh_first_point.Y);
|
var curve_qh_last_point = curve_qh_last.GetLastFitPoint();
|
h_min = Math.Max(h_min, curve_qh_last_point.Y);
|
}
|
}
|
|
if (curve_qh_list.Count < 2)
|
{
|
throw new Exception("NULL1");
|
}
|
if (h_max < h_min)
|
{
|
throw new Exception("NULL2");
|
}
|
|
double space_h = (h_max - h_min) / 19;
|
var points_qh_parallel = new List<Model.CurvePoint>();
|
var points_qp_parallel = new List<Model.CurvePoint>();
|
|
for (var h = h_min; h <= h_max; h = h + space_h)
|
{
|
double total_flow = 0;
|
double total_power = 0;
|
|
for (int j = 0; j < curve_qh_list.Count; j++)
|
{
|
var curve_qh = curve_qh_list[j];
|
var curve_qp = curve_qp_list[j];
|
var pts = Model.FitCurveHelper.GetInterPointX(curve_qh, h);
|
if (pts != null && pts.Count > 0)
|
{
|
var q = pts.Last().X;
|
total_flow += q;
|
total_power += curve_qp.GetFitPointY(q);
|
}
|
}
|
points_qh_parallel.Add(new Model.CurvePoint(total_flow, h));
|
points_qp_parallel.Add(new Model.CurvePoint(total_flow, total_power));
|
}
|
|
var vm = new PumpParallelCurveLogicDto();
|
vm.PointQH = Model.FitCurveHelper.GetFitPoints(points_qh_parallel, 20)?.Select(x => new CurvePointDto(x.X, x.Y)).ToList();
|
vm.PointQP = Model.FitCurveHelper.GetFitPoints(points_qp_parallel, 20)?.Select(x => new CurvePointDto(x.X, x.Y)).ToList();
|
|
return vm;
|
}
|
|
/// <summary>
|
/// 计算机泵并联曲线拓展（包含单泵曲线）(业务)
|
/// </summary>
|
[Route("CalculateEnginePumpParallelEx@V1.0")]
|
[HttpPost]
|
public List<PumpParallelCurveExLogicDto> CalculateEnginePumpParallelEx([Required] EnginePumpParallelCurveInput input)
|
{
|
var service_product = new Service.Product();
|
var service_curve = new Service.PumpCurveExMapping();
|
var vm_list = new List<PumpParallelCurveExLogicDto>();
|
|
var curve_qh_list = new List<Model.CurveExpress>();
|
var curve_qp_list = new List<Model.CurveExpress>();
|
var h_min = double.MinValue;
|
var h_max = double.MaxValue;
|
|
foreach (var item in input.Items)
|
{
|
var engine_pump = service_product.GetByID(input.CorpID, item.EnginePumpID);
|
if (engine_pump == null)
|
continue;
|
var pump = service_product.GetChildPumpByEnginePumpID(engine_pump.CorpID, engine_pump.ID);
|
if (pump == null)
|
continue;
|
var curve = service_curve.GetDefaultWorkingByPumpID(pump.CorpID, pump.ID);
|
if (curve == null)
|
continue;
|
|
if (item.HZ > 49.5)
|
{
|
if (curve.CurveInfo != null && curve.CurveInfo.CurveQH != null)
|
{
|
curve_qh_list.Add(curve.CurveInfo.CurveQH);
|
if (curve.CurveInfo.CurveQP != null)
|
{
|
curve_qp_list.Add(curve.CurveInfo.CurveQP);
|
}
|
}
|
}
|
else
|
{
|
var curve_qh = curve.CalcuCurveQhByHz(item.HZ);
|
if (curve_qh != null)
|
{
|
curve_qh_list.Add(curve_qh);
|
var curve_qp = curve.CalcuCurveQpByHz(item.HZ);
|
if (curve_qp != null)
|
{
|
curve_qp_list.Add(curve_qp);
|
}
|
}
|
}
|
|
var curve_qh_last = curve_qh_list.LastOrDefault();
|
if (curve_qh_last != null)
|
{
|
var curve_qh_first_point = curve_qh_last.GetFirstFitPoint();
|
h_max = Math.Min(h_max, curve_qh_first_point.Y);
|
var curve_qh_last_point = curve_qh_last.GetLastFitPoint();
|
h_min = Math.Max(h_min, curve_qh_last_point.Y);
|
}
|
var vm_parallel_curve = new PumpParallelCurveExLogicDto();
|
vm_parallel_curve.Type = 0;
|
vm_parallel_curve.Name = engine_pump.Name;
|
vm_parallel_curve.PointQH = curve_qh_list.LastOrDefault()?.GetFitPoints(20)?.Select(x => new CurvePointDto(x.X, x.Y)).ToList();
|
vm_parallel_curve.PointQP = curve_qp_list.LastOrDefault()?.GetFitPoints(20)?.Select(x => new CurvePointDto(x.X, x.Y)).ToList();
|
vm_list.Add(vm_parallel_curve);
|
}
|
|
if (curve_qh_list.Count < 2)
|
{
|
throw new Exception("NULL1");
|
}
|
if (h_max < h_min)
|
{
|
throw new Exception("NULL2");
|
}
|
|
double space_h = (h_max - h_min) / 19;
|
var points_qh_parallel = new List<Model.CurvePoint>();
|
var points_qp_parallel = new List<Model.CurvePoint>();
|
|
for (var h = h_min; h <= h_max; h = h + space_h)
|
{
|
double total_flow = 0;
|
double total_power = 0;
|
|
for (int j = 0; j < curve_qh_list.Count; j++)
|
{
|
var curve_qh = curve_qh_list[j];
|
var curve_qp = curve_qp_list[j];
|
var pts = Model.FitCurveHelper.GetInterPointX(curve_qh, h);
|
if (pts != null && pts.Count > 0)
|
{
|
var q = pts.Last().X;
|
total_flow += q;
|
total_power += curve_qp.GetFitPointY(q);
|
}
|
}
|
points_qh_parallel.Add(new Model.CurvePoint(total_flow, h));
|
points_qp_parallel.Add(new Model.CurvePoint(total_flow, total_power));
|
}
|
|
var vm = new PumpParallelCurveExLogicDto();
|
vm.Type = 1;
|
vm.Name = "并联曲线";
|
vm.PointQH = Model.FitCurveHelper.GetFitPoints(points_qh_parallel, 20)?.Select(x => new CurvePointDto(x.X, x.Y)).ToList();
|
vm.PointQP = Model.FitCurveHelper.GetFitPoints(points_qp_parallel, 20)?.Select(x => new CurvePointDto(x.X, x.Y)).ToList();
|
vm_list.Insert(0, vm);
|
return vm_list;
|
}
|
|
|
|
|
|
|
|
}
|
}
|
