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>
|
/// LogicTree
|
/// </summary>
|
[Route("Main/LogicTree/Logic")]
|
[ApiDescriptionSettings("Main", Name = "业务清单(业务)", Order = 997)]
|
public class LogicTree_LogicController : IDynamicApiController
|
{
|
|
/// <summary>
|
/// 通过 CorpID 获取树(业务)
|
/// </summary>
|
[Route("GetTreeByCorpID@V1.0")]
|
[HttpGet]
|
public List<LogicCatalogExItemsLogicDto> GetTreeByCorpID([FromQuery][Required] CorpIDInput input)
|
{
|
var corpId = input.CorpID;
|
var cacheKey = $"Main_LogicTree_Logic_GetTreeByCorpID_{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<LogicCatalogExItemsLogicDto>();
|
var service_logic_tree = new Service.LogicTree();
|
|
foreach (var catalog in catalog_list)
|
{
|
var logic_tree_list = service_logic_tree.GetExByCatalogID(corpId, catalog.ID);
|
var vm_logic_tree_list = new List<LogicTreeItemDto>();
|
if (logic_tree_list != null || logic_tree_list.Count > 0)
|
{
|
foreach (var logic_tree in logic_tree_list)
|
{
|
var vm_logic_tree_item = new LogicTreeItemDto(logic_tree);
|
var vm_logic_tree_parent_item = vm_logic_tree_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_list.Add(vm_logic_tree_item);
|
}
|
vm_logic_tree_list = vm_logic_tree_list.Where(t => t.ParentID == 0).OrderBy(t => t.SortCode).ToList();
|
}
|
vm_cache_list.Add(new LogicCatalogExItemsLogicDto(catalog, vm_logic_tree_list));
|
}
|
|
#endregion
|
|
return vm_cache_list;
|
|
|
}, CacheHelper.CacheLevel1);
|
return vm_list;
|
}
|
|
/// <summary>
|
/// 通过 CatalogID 获取(业务)
|
/// </summary>
|
[Route("GetTreeByCatalogID@V1.0")]
|
[HttpGet]
|
public List<LogicTreeItemDto> GetTreeByCatalogID([FromQuery][Required] CatalogIDUnderCorpInput input)
|
{
|
var corpId = input.CorpID;
|
var catalogId = input.CatalogID;
|
var cacheKey = $"Main_LogicTree_Logic_GetTreeByCatalogID_{corpId}_{catalogId}";
|
var vm_list = MemoryCacheHelper.GetSet(cacheKey, () =>
|
{
|
//获取业务清单
|
var logic_tree_list = new Service.LogicTree().GetExByCatalogID(corpId, catalogId);
|
if (logic_tree_list == null || logic_tree_list.Count < 1)
|
{
|
return default;
|
}
|
|
var vm_cache_list = new List<LogicTreeItemDto>();
|
foreach (var logic_tree in logic_tree_list)
|
{
|
var vm_cache_item = new LogicTreeItemDto(logic_tree);
|
var vm_cache_parent = vm_cache_list.Find(t => t.ID == vm_cache_item.ParentID);
|
if (vm_cache_parent != null)
|
{
|
vm_cache_parent.Children.Add(vm_cache_item);
|
}
|
vm_cache_list.Add(vm_cache_item);
|
}
|
return vm_cache_list.Where(t => t.ParentID == 0).OrderBy(t => t.SortCode).ToList();
|
}, CacheHelper.CacheLevel2);
|
|
return vm_list;
|
}
|
|
/// <summary>
|
/// 通过 CorpID 获取泵曲线逻辑树(业务)
|
/// </summary>
|
[Route("GetPumpCurveLogicalTreeByCorpID@V1.0")]
|
[HttpGet]
|
public List<LogicCatalogExLogicalTreeItemsLogicDto> GetPumpCurveLogicalTreeByCorpID([FromQuery][Required] CorpIDInput input)
|
{
|
var corpId = input.CorpID;
|
var cacheKey = $"Main_LogicTree_Logic_GetPumpCurveLogicalTreeByCorpID_{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_product = new Service.Product();
|
var service_product_property = new Service.ProductTypePropertyGroup();
|
var service_curve = new Service.PumpCurveExMapping();
|
|
foreach (var catalog in catalog_list)
|
{
|
var logic_tree_list = service_logic_tree.GetByCatalogID(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;
|
if (logic_tree.LogicType == ObjectType.LogicArea)
|
{
|
var logic_area = service_logic_area.GetByID(logic_tree.CorpID, logic_tree.LogicID);
|
vm_logic_tree_item.LogicalName = logic_area.Name;
|
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.LogicalName = station.Name;
|
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 pump_list = service_product.GetPumpListByBelongTypeAndBelongID(logic_tree.CorpID, logic_tree.LogicType, logic_tree.LogicID);
|
if (pump_list != null && pump_list.Count > 0)
|
{
|
foreach (var pump in pump_list)
|
{
|
var property_list = service_product_property.GetExItemsByProductTypeID(pump.CorpID, pump.ProductTypeID);
|
var vm_pump = new ProductLogicDto<Model.Pump>(pump, property_list);
|
var vm_pump_item = new LogicalTreeItemDto();
|
vm_pump_item.ID = $"{IStation.ObjectType.Product}_{pump.ID}";
|
vm_pump_item.ParentID = vm_logic_tree_item.ID;
|
vm_pump_item.LogicalID = vm_pump.ID;
|
vm_pump_item.LogicalType = IStation.ObjectType.Product;
|
vm_pump_item.LogicalName = vm_pump.Name;
|
vm_pump_item.LogicalModel = vm_pump;
|
vm_pump_item.Children = new List<LogicalTreeItemDto>();
|
vm_logic_tree_item.Children.Add(vm_pump_item);
|
|
var curve_list = service_curve.GetByPumpID(vm_pump.CorpID, vm_pump.ID);
|
if (curve_list != null && curve_list.Count > 0)
|
{
|
foreach (var curve in curve_list)
|
{
|
var vm_curve = new PumpCurveLogicDto(curve);
|
var vm_curve_item = new LogicalTreeItemDto();
|
vm_curve_item.ID = $"{ObjectType.PumpCurveMapping}_{vm_curve.MappingID}";
|
vm_curve_item.ParentID = vm_pump_item.ID;
|
vm_pump_item.LogicalID = vm_curve.MappingID;
|
vm_curve_item.LogicalType = ObjectType.PumpCurveMapping;
|
vm_curve_item.LogicalName = vm_curve.OtherName;
|
vm_curve_item.LogicalModel = vm_curve;
|
vm_pump_item.Children.Add(vm_curve_item);
|
}
|
}
|
}
|
}
|
}
|
|
}
|
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;
|
}
|
|
}
|
}
|
