using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Net;
|
using System.Net.Http;
|
using System.Web.Http;
|
using IStation.Model.Api;
|
using AutoMapper;
|
using IStation.WebApi.Models;
|
using IStation.Untity;
|
using Microsoft.Web.Http;
|
|
namespace IStation.WebApi.Controllers
|
{
|
/// <summary>
|
/// 管路标准api
|
/// </summary>
|
[RoutePrefix("v1/Standard/PipeLine")]
|
[ApiVersion("v1")]
|
public class PipeLine_StandardController : ApiController
|
{
|
|
/// <summary>
|
/// 通过 BelongType 和 BelongID 获取管路信息
|
/// </summary>
|
[Route("GetByBelongTypeAndBelongID")]
|
[HttpGet]
|
public Result GetByBelongTypeAndBelongID(long CorpID, string BelongType, long BelongID)
|
{
|
if (CorpID < 1)
|
{
|
return new Result(Code.Alert, "CorpID 参数错误");
|
}
|
if (string.IsNullOrEmpty(BelongType))
|
{
|
return new Result(Code.Alert, "BelongType 参数错误");
|
}
|
if (BelongID < 1)
|
{
|
return new Result(Code.Alert, "BelongID 参数错误");
|
}
|
|
var cacheKey = $"Standard_PipeLine_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 ViewModel.PipeLine(x)).ToList();
|
return vm_cache_list;
|
}, CacheHelper.CacheLevel4);
|
|
return new Result<List<ViewModel.PipeLine>>(vm_list);
|
}
|
|
/// <summary>
|
/// 通过 BelongType 和 BelongID 获取能效管路信息
|
/// </summary>
|
[Route("GetEtaByBelongTypeAndBelongID")]
|
[HttpGet]
|
public Result GetEtaByBelongTypeAndBelongID(long CorpID, string BelongType, long BelongID)
|
{
|
if (CorpID < 1)
|
{
|
return new Result(Code.Alert, "CorpID 参数错误");
|
}
|
if (string.IsNullOrEmpty(BelongType))
|
{
|
return new Result(Code.Alert, "BelongType 参数错误");
|
}
|
if (BelongID < 1)
|
{
|
return new Result(Code.Alert, "BelongID 参数错误");
|
}
|
|
var cacheKey = $"Standard_PipeLine_GetEtaByBelongTypeAndBelongID_{CorpID}_{BelongType}_{BelongID}";
|
var vm_list = MemoryCacheHelper.GetSet(cacheKey, () =>
|
{
|
var pipe_list = new Service.PipeLine().GetEtaByBelongTypeAndBelongID(CorpID, BelongType, BelongID);
|
if (pipe_list == null || pipe_list.Count < 1)
|
return default;
|
var vm_cache_list = pipe_list.Select(x => new ViewModel.PipeLine(x)).ToList();
|
return vm_cache_list;
|
}, CacheHelper.CacheLevel4);
|
|
return new Result<List<ViewModel.PipeLine>>(vm_list);
|
}
|
|
/// <summary>
|
/// 通过 BelongType 和 BelongID 获取拓展泵性能曲线列表
|
/// </summary>
|
[Route("GetExPumpFeatCurveListByBelongTypeAndBelongID")]
|
[HttpGet]
|
public Result GetExPumpFeatCurveListByBelongTypeAndBelongID(long CorpID, string BelongType, long BelongID)
|
{
|
if (CorpID < 1)
|
{
|
return new Result(Code.Alert, "CorpID 参数错误");
|
}
|
if (string.IsNullOrEmpty(BelongType))
|
{
|
return new Result(Code.Alert, "BelongType 参数错误");
|
}
|
if (BelongID < 1)
|
{
|
return new Result(Code.Alert, "BelongID 参数错误");
|
}
|
|
var cacheKey = $"Standard_PipeLine_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 == IStation.PipeLine.机泵).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<ViewModel.PipeLineExPumpFeatCurve>();
|
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.ObjectType == IStation.ObjectType.Product_设备);
|
if (binding == null)
|
continue;
|
var pump = service_product.GetChildPumpByEnginePumpID(binding.CorpID, binding.ObjectID);
|
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 ViewModel.PipeLineExPumpFeatCurve(pipe_engine_pump, pump, property_list, curve);
|
vm_cache_list.Add(vm_cache);
|
}
|
return vm_cache_list;
|
}, CacheHelper.CacheLevel3);
|
|
return new Result<List<ViewModel.PipeLineExPumpFeatCurve>>(vm_list);
|
}
|
|
/// <summary>
|
/// 通过 CorpID 获取机泵业务树
|
/// </summary>
|
[Route("GetEnginePumpLogicTreeByCorpID")]
|
[HttpGet]
|
public Result GetEnginePumpLogicTreeByCorpID(long CorpID)
|
{
|
if (CorpID < 1)
|
{
|
return new Result(Code.Alert, "CorpID 参数错误");
|
}
|
var cacheKey = $"Standard_PipeLine_GetEnginePumpLogicTreeByCorpID_{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.LogicCatalog.eUseStatus.Enable).ToList();
|
if (catalog_list.Count < 1)
|
{
|
return default;
|
}
|
|
#endregion
|
|
#region 获取业务清单列表
|
|
|
var vm_cache_list = new List<ViewModel.LogicCatalogExLogicalTreeItems>();
|
var service_logic_tree = new Service.LogicTree();
|
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<ViewModel.LogicalTreeItem>();
|
if (logic_tree_list != null || logic_tree_list.Count > 0)
|
{
|
foreach (var logic_tree in logic_tree_list)
|
{
|
var vm_logic_tree = new ViewModel.LogicTree(logic_tree);
|
var vm_logic_tree_item = new ViewModel.LogicalTreeItem();
|
vm_logic_tree_item.ID = $"{IStation.ObjectType.Logic_业务清单}_{vm_logic_tree.ID}";
|
if (vm_logic_tree.ParentID < 1)
|
{
|
vm_logic_tree_item.ParentID = string.Empty;
|
}
|
else
|
{
|
vm_logic_tree_item.ParentID = $"{IStation.ObjectType.Logic_业务清单}_{vm_logic_tree.ParentID}";
|
}
|
|
vm_logic_tree_item.LogicalID = vm_logic_tree.ID;
|
vm_logic_tree_item.LogicalType = IStation.ObjectType.Logic_业务清单;
|
vm_logic_tree_item.LogicalName = vm_logic_tree.ObjectName;
|
vm_logic_tree_item.LogicalModel = vm_logic_tree;
|
vm_logic_tree_item.Children = new List<ViewModel.LogicalTreeItem>();
|
|
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 (vm_logic_tree.ObjectType == IStation.ObjectType.Station_泵站)
|
{
|
var pipe_list = service_pipe.GetEnginePumpListByBelongTypeAndBelongID(vm_logic_tree.CorpID,vm_logic_tree.ObjectType,vm_logic_tree.ObjectID);
|
if (pipe_list != null && pipe_list.Count > 0)
|
{
|
foreach (var pipe in pipe_list)
|
{
|
var vm_pipe = new ViewModel.LogicalTreeItem();
|
vm_pipe.ID = $"{IStation.ObjectType.PipeLine_管路}_{pipe.ID}";
|
vm_pipe.ParentID = vm_logic_tree_item.ID;
|
vm_pipe.LogicalID = pipe.ID;
|
vm_pipe.LogicalType = IStation.ObjectType.PipeLine_管路;
|
vm_pipe.LogicalName = pipe.Name;
|
vm_pipe.LogicalModel = new ViewModel.PipeLine(pipe);
|
vm_pipe.Children = new List<ViewModel.LogicalTreeItem>();
|
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 ViewModel.LogicCatalogExLogicalTreeItems(catalog, vm_logic_tree_item_list));
|
}
|
|
#endregion
|
|
return vm_cache_list;
|
|
|
}, CacheHelper.CacheLevel3);
|
return new Result<List<ViewModel.LogicCatalogExLogicalTreeItems>>(vm_list);
|
}
|
|
/// <summary>
|
/// 通过 CorpID 获取机泵逻辑树
|
/// </summary>
|
[Route("GetEnginePumpLogicalTreeByCorpID")]
|
[HttpGet]
|
public Result GetEnginePumpLogicalTreeByCorpID(long CorpID)
|
{
|
if (CorpID < 1)
|
{
|
return new Result(Code.Alert, "CorpID 参数错误");
|
}
|
var cacheKey = $"Standard_PipeLine_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.LogicCatalog.eUseStatus.Enable).ToList();
|
if (catalog_list.Count < 1)
|
{
|
return default;
|
}
|
|
#endregion
|
|
#region 获取业务清单列表
|
|
|
var vm_cache_list = new List<ViewModel.LogicCatalogExLogicalTreeItems>();
|
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<ViewModel.LogicalTreeItem>();
|
if (logic_tree_list != null || logic_tree_list.Count > 0)
|
{
|
foreach (var logic_tree in logic_tree_list)
|
{
|
var vm_logic_tree_item = new ViewModel.LogicalTreeItem();
|
vm_logic_tree_item.ID = $"{IStation.ObjectType.Logic_业务清单}_{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 = $"{IStation.ObjectType.Logic_业务清单}_{parentId}";
|
}
|
|
vm_logic_tree_item.LogicalID = logic_tree.ObjectID;
|
vm_logic_tree_item.LogicalType = logic_tree.ObjectType;
|
vm_logic_tree_item.LogicalName = logic_tree.ObjectName;
|
if (logic_tree.ObjectType == IStation.ObjectType.Logic_业务区域)
|
{
|
var logic_area = service_logic_area.GetByID(logic_tree.CorpID,logic_tree.ObjectID);
|
vm_logic_tree_item.LogicalModel = new ViewModel.LogicArea(logic_area);
|
}
|
else if (logic_tree.ObjectType == IStation.ObjectType.Station_泵站)
|
{
|
var station = service_station.GetByID(logic_tree.CorpID,logic_tree.ObjectID);
|
vm_logic_tree_item.LogicalModel = new ViewModel.Station(station);
|
}
|
vm_logic_tree_item.Children = new List<ViewModel.LogicalTreeItem>();
|
|
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.ObjectType == IStation.ObjectType.Station_泵站)
|
{
|
var pipe_list = service_pipe.GetEnginePumpListByBelongTypeAndBelongID(logic_tree.CorpID, logic_tree.ObjectType, logic_tree.ObjectID);
|
if (pipe_list != null && pipe_list.Count > 0)
|
{
|
foreach (var pipe in pipe_list)
|
{
|
var vm_pipe = new ViewModel.LogicalTreeItem();
|
vm_pipe.ID = $"{IStation.ObjectType.PipeLine_管路}_{pipe.ID}";
|
vm_pipe.ParentID = vm_logic_tree_item.ID;
|
vm_pipe.LogicalID = pipe.ID;
|
vm_pipe.LogicalType = IStation.ObjectType.PipeLine_管路;
|
vm_pipe.LogicalName = pipe.Name;
|
vm_pipe.LogicalModel = new ViewModel.PipeLine(pipe);
|
vm_pipe.Children = new List<ViewModel.LogicalTreeItem>();
|
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 ViewModel.LogicCatalogExLogicalTreeItems(catalog, vm_logic_tree_item_list));
|
}
|
|
#endregion
|
|
return vm_cache_list;
|
|
|
}, CacheHelper.CacheLevel3);
|
return new Result<List<ViewModel.LogicCatalogExLogicalTreeItems>>(vm_list);
|
}
|
|
}
|
}
|
