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>
|
/// PipeLine
|
/// </summary>
|
[Route("Main/PipeLine/Logic")]
|
[ApiDescriptionSettings("Main", Name = "管路", Order = 599)]
|
public class PipeLine_LogicController : IDynamicApiController
|
{
|
|
/// <summary>
|
/// 通过 BelongType 和 BelongID 获取管路信息(业务)
|
/// </summary>
|
[Route("GetByBelongTypeAndBelongID@V1.0")]
|
[HttpGet]
|
public List<PipeLineLogicDto> GetByBelongTypeAndBelongID([FromQuery][Required] BelongUnderCorpInput input)
|
{
|
var corpId = input.CorpID;
|
var belongType = input.BelongType;
|
var belongId = input.BelongID;
|
|
var cacheKey = $"Main_PipeLine_Logic_GetByBelongTypeAndBelongID_{corpId}_{belongType}_{belongId}";
|
var vm_list = MemoryCacheHelper.GetSet(cacheKey, () =>
|
{
|
var pipe_list = new Service.PipeLine().GetByBelongTypeAndBelongID(corpId, belongType, belongId);
|
if (pipe_list == null || pipe_list.Count < 1)
|
return default;
|
var vm_cache_list = pipe_list.Select(x => new PipeLineLogicDto(x)).ToList();
|
return vm_cache_list;
|
}, CacheHelper.CacheLevel4);
|
return vm_list;
|
}
|
|
/// <summary>
|
/// 通过 BelongType 和 BelongID 获取能效管路信息(业务)
|
/// </summary>
|
[Route("GetEtaByBelongTypeAndBelongID@V1.0")]
|
[HttpGet]
|
public List<PipeLineLogicDto> GetEtaByBelongTypeAndBelongID([FromQuery][Required] BelongUnderCorpInput input)
|
{
|
var corpId = input.CorpID;
|
var belongType = input.BelongType;
|
var belongId = input.BelongID;
|
|
var cacheKey = $"Main_PipeLine_Logic_GetEtaByBelongTypeAndBelongID_{corpId}_{belongType}_{belongId}";
|
var vm_list = MemoryCacheHelper.GetSet(cacheKey, () =>
|
{
|
var pipe_list = new Service.PipeLine().GetEtaListByBelongTypeAndBelongID(corpId, belongType, belongId);
|
if (pipe_list == null || pipe_list.Count < 1)
|
return default;
|
var vm_cache_list = pipe_list.Select(x => new PipeLineLogicDto(x)).ToList();
|
return vm_cache_list;
|
}, CacheHelper.CacheLevel4);
|
return vm_list;
|
}
|
|
/// <summary>
|
/// 通过 BelongType 和 BelongID 获取拓展泵性能曲线列表(业务)
|
/// </summary>
|
[Route("GetExPumpFeatCurveListByBelongTypeAndBelongID@V1.0")]
|
[HttpGet]
|
public List<PipeLineExPumpFeatCurveLogicDto> GetExPumpFeatCurveListByBelongTypeAndBelongID([FromQuery][Required] BelongUnderCorpInput input)
|
{
|
var corpId = input.CorpID;
|
var belongType = input.BelongType;
|
var belongId = input.BelongID;
|
|
var cacheKey = $"Main_PipeLine_Logic_GetExPumpFeatCurveListByBelongTypeAndBelongID_{corpId}_{belongType}_{belongId}";
|
var vm_list = MemoryCacheHelper.GetSet(cacheKey, () =>
|
{
|
var pipe_list = new Service.PipeLine().GetByBelongTypeAndBelongID(corpId, belongType, belongId);
|
if (pipe_list == null || pipe_list.Count < 1)
|
return default;
|
var pipe_engine_pump_list = pipe_list.Where(x => x.Catalog == PipeLine.EnginePump).OrderBy(x => x.SerialNO).ToList();
|
if (pipe_engine_pump_list.Count < 1)
|
return default;
|
var service_binding = new Service.PipeLineBinding();
|
var service_product = new Service.Product();
|
var service_property = new Service.ProductTypePropertyGroup();
|
var service_curve = new Service.PumpCurveExMapping();
|
var vm_cache_list = new List<PipeLineExPumpFeatCurveLogicDto>();
|
foreach (var pipe_engine_pump in pipe_engine_pump_list)
|
{
|
var binding_list = service_binding.GetUseByPipeLineID(pipe_engine_pump.CorpID, pipe_engine_pump.ID);
|
if (binding_list == null || binding_list.Count < 1)
|
continue;
|
var binding = binding_list.Find(x => x.BindingType == IStation.ObjectType.Product);
|
if (binding == null)
|
continue;
|
var pump = service_product.GetChildPumpByEnginePumpID(binding.CorpID, binding.BindingID);
|
if (pump == null)
|
continue;
|
var property_list = service_property.GetExItemsByProductTypeID(pump.CorpID, pump.ProductTypeID);
|
var curve = service_curve.GetDefaultWorkingByPumpID(pump.CorpID, pump.ID);
|
if (curve == null)
|
continue;
|
var vm_cache = new PipeLineExPumpFeatCurveLogicDto(pipe_engine_pump, pump, property_list, curve);
|
vm_cache_list.Add(vm_cache);
|
}
|
return vm_cache_list;
|
}, CacheHelper.CacheLevel3);
|
|
return vm_list;
|
}
|
|
/// <summary>
|
/// 通过 CorpID 获取机泵逻辑树(业务)
|
/// </summary>
|
[Route("GetEnginePumpLogicalTreeByCorpID@V1.0")]
|
[HttpGet]
|
public List<LogicCatalogExLogicalTreeItemsLogicDto> GetEnginePumpLogicalTreeByCorpID([FromQuery][Required] CorpIDInput input)
|
{
|
var corpId = input.CorpID;
|
var cacheKey = $"Main_PipeLine_Logic_GetEnginePumpLogicalTreeByCorpID_{corpId}";
|
var vm_list = MemoryCacheHelper.GetSet(cacheKey, () =>
|
{
|
|
#region 获取业务类别列表
|
|
var service_logic_catalog = new Service.LogicCatalog();
|
var catalog_list = service_logic_catalog.GetByCorpID(corpId);
|
if (catalog_list == null || catalog_list.Count < 1)
|
{
|
return default;
|
}
|
catalog_list = catalog_list.Where(x => x.UseStatus == Model.eUseStatus.Enable).ToList();
|
if (catalog_list.Count < 1)
|
{
|
return default;
|
}
|
|
#endregion
|
|
#region 获取业务清单列表
|
|
|
var vm_cache_list = new List<LogicCatalogExLogicalTreeItemsLogicDto>();
|
var service_logic_tree = new Service.LogicTree();
|
var service_logic_area = new Service.LogicArea();
|
var service_station = new Service.Station();
|
var service_pipe = new Service.PipeLine();
|
|
foreach (var catalog in catalog_list)
|
{
|
var logic_tree_list = service_logic_tree.GetExByCatalogID(corpId, catalog.ID);
|
var vm_logic_tree_item_list = new List<LogicalTreeItemDto>();
|
if (logic_tree_list != null || logic_tree_list.Count > 0)
|
{
|
foreach (var logic_tree in logic_tree_list)
|
{
|
var vm_logic_tree_item = new LogicalTreeItemDto();
|
vm_logic_tree_item.ID = $"{ObjectType.LogicTree}_{logic_tree.ID}";
|
var parentId = TreeParentIdsHelper.GetLastParentID(logic_tree.ParentIds);
|
if (parentId < 1)
|
{
|
vm_logic_tree_item.ParentID = string.Empty;
|
}
|
else
|
{
|
vm_logic_tree_item.ParentID = $"{ObjectType.LogicTree}_{parentId}";
|
}
|
|
vm_logic_tree_item.LogicalID = logic_tree.LogicID;
|
vm_logic_tree_item.LogicalType = logic_tree.LogicType;
|
vm_logic_tree_item.LogicalName = logic_tree.LogicName;
|
if (logic_tree.LogicType == ObjectType.LogicArea)
|
{
|
var logic_area = service_logic_area.GetByID(logic_tree.CorpID, logic_tree.LogicID);
|
vm_logic_tree_item.LogicalModel = new LogicAreaLogicDto(logic_area);
|
}
|
else if (logic_tree.LogicType == ObjectType.Station)
|
{
|
var station = service_station.GetByID(logic_tree.CorpID, logic_tree.LogicID);
|
vm_logic_tree_item.LogicalModel = new StationLogicDto(station);
|
}
|
vm_logic_tree_item.Children = new List<LogicalTreeItemDto>();
|
|
var vm_logic_tree_parent_item = vm_logic_tree_item_list.Find(t => t.ID == vm_logic_tree_item.ParentID);
|
if (vm_logic_tree_parent_item != null)
|
{
|
vm_logic_tree_parent_item.Children.Add(vm_logic_tree_item);
|
}
|
vm_logic_tree_item_list.Add(vm_logic_tree_item);
|
|
if (logic_tree.LogicType == ObjectType.Station)
|
{
|
var pipe_list = service_pipe.GetEnginePumpListByBelongTypeAndBelongID(logic_tree.CorpID, logic_tree.LogicType, logic_tree.LogicID);
|
if (pipe_list != null && pipe_list.Count > 0)
|
{
|
foreach (var pipe in pipe_list)
|
{
|
var vm_pipe = new LogicalTreeItemDto();
|
vm_pipe.ID = $"{ObjectType.PipeLine}_{pipe.ID}";
|
vm_pipe.ParentID = vm_logic_tree_item.ID;
|
vm_pipe.LogicalID = pipe.ID;
|
vm_pipe.LogicalType = ObjectType.PipeLine;
|
vm_pipe.LogicalName = pipe.Name;
|
vm_pipe.LogicalModel = new PipeLineLogicDto(pipe);
|
vm_pipe.Children = new List<LogicalTreeItemDto>();
|
vm_logic_tree_item.Children.Add(vm_pipe);
|
}
|
}
|
}
|
|
}
|
vm_logic_tree_item_list = vm_logic_tree_item_list.Where(t => string.IsNullOrEmpty(t.ParentID)).ToList();
|
}
|
vm_cache_list.Add(new LogicCatalogExLogicalTreeItemsLogicDto(catalog, vm_logic_tree_item_list));
|
}
|
|
#endregion
|
|
return vm_cache_list;
|
|
|
}, CacheHelper.CacheLevel3);
|
return vm_list;
|
}
|
|
/// <summary>
|
/// 通过 ID 获取泵频率曲线(业务)
|
/// </summary>
|
[Route("GetPumpHZCurveByID@V1.0")]
|
[HttpGet]
|
public PumpHZCurveLogicDto GetPumpHZCurveByID
|
(
|
[Required,Range(1,long.MaxValue,ErrorMessage ="CorpID 必须大于0")]
|
long CorpID,
|
[Required,Range(1,long.MaxValue,ErrorMessage ="ID 必须大于0")]
|
long ID,
|
[Required]
|
double HZ
|
)
|
{
|
|
var binding_list = new Service.PipeLineBinding().GetUseByPipeLineID(CorpID, ID);
|
if (binding_list == null || binding_list.Count < 1)
|
{
|
return default;
|
}
|
var binding = binding_list.Find(x => x.BindingType == ObjectType.Product);
|
if (binding == null)
|
{
|
return default;
|
}
|
var pump = new Service.Product().GetChildPumpByEnginePumpID(binding.CorpID, binding.BindingID);
|
if (pump == null)
|
{
|
return default;
|
}
|
var curve = new Service.PumpCurveExMapping().GetDefaultWorkingByPumpID(pump.CorpID, pump.ID);
|
if (curve == null)
|
{
|
return default;
|
}
|
|
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("CalculatePumpParallelCurve@V1.0")]
|
[HttpPost]
|
public PumpParallelCurveLogicDto CalculatePumpParallelCurve([Required] PipeLineParallelCurveInput input)
|
{
|
|
var service_pipe = new Service.PipeLine();
|
var service_binding = new Service.PipeLineBinding();
|
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 pipe = service_pipe.GetByID(input.CorpID, item.ID);
|
if (pipe == null)
|
continue;
|
var binding_list = service_binding.GetUseByPipeLineID(input.CorpID, item.ID);
|
if (binding_list == null || binding_list.Count < 1)
|
continue;
|
var binding = binding_list.Find(x => x.BindingType == ObjectType.Product);
|
if (binding == null)
|
continue;
|
var pump = service_product.GetChildPumpByEnginePumpID(binding.CorpID, binding.BindingID);
|
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("CalculatePipeLineParallelEx@V1.0")]
|
[HttpPost]
|
public List<PumpParallelCurveExLogicDto> CalculatePumpParallelCurveEx([Required] PipeLineParallelCurveInput input)
|
{
|
|
var service_pipe = new Service.PipeLine();
|
var service_binding = new Service.PipeLineBinding();
|
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 pipe = service_pipe.GetByID(input.CorpID, item.ID);
|
if (pipe == null)
|
continue;
|
var binding_list = service_binding.GetUseByPipeLineID(input.CorpID, item.ID);
|
if (binding_list == null || binding_list.Count < 1)
|
continue;
|
var binding = binding_list.Find(x => x.BindingType == ObjectType.Product);
|
if (binding == null)
|
continue;
|
var pump = service_product.GetChildPumpByEnginePumpID(binding.CorpID, binding.BindingID);
|
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 = pipe.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;
|
}
|
|
}
|
}
|
