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;
|
using Microsoft.AspNetCore.Http;
|
using Furion.DependencyInjection;
|
using Microsoft.AspNetCore.Authorization;
|
using Furion.DataEncryption;
|
using Furion.FriendlyException;
|
|
namespace IStation.Application
|
{
|
/// <summary>
|
/// 监测
|
/// </summary>
|
[AllowAnonymous]
|
[Route("LargeScreen/Szjt/Monitor")]
|
[ApiDescriptionSettings("LargeScreen", Name = "苏州金庭(监测)", Order = 999)]
|
public class SzjtMonitor_Controller : IDynamicApiController, ITransient
|
{
|
private readonly IHttpContextAccessor _httpContextAccessor;
|
|
/// <summary>
|
///
|
/// </summary>
|
public SzjtMonitor_Controller(IHttpContextAccessor httpContextAccessor)
|
{
|
_httpContextAccessor = httpContextAccessor;
|
}
|
|
private const long _corpId = 3;
|
|
/// <summary>
|
/// 通过 StationID 获取KPI
|
/// </summary>
|
/// <param name="StationID">泵站标识</param>
|
/// <param name="Count">KPI数量</param>
|
[Route("GetMonitorPointKpiListByStationID")]
|
[HttpGet]
|
public List<SzjtMonitorPointExSignalListDto> GetMonitorPointKpiListByStationID
|
(
|
[Required, Range(1, long.MaxValue, ErrorMessage = "StationID 必须大于0")]
|
long StationID,
|
int Count = 2
|
)
|
{
|
var cacheKey = $"LargeScreen_Szjt_Monitor_GetMonitorPointKpiListByStationID_{_corpId}_{StationID}_{Count}";
|
var vm_list = MemoryCacheHelper.GetSet(cacheKey, () =>
|
{
|
//最后kpi记录列表
|
var monitor_list = new Service.MonitorPoint().GetExSignalWithSignalTypeByBelongTypeAndBelongID
|
(_corpId, ObjectType.Station, StationID, Model.eMonitorType.General, Model.Monitor.eCronType.Real);
|
var monitor_kpi_list = monitor_list?.Where(x => x.Flags != null && x.Flags.Contains(LogicFlags.KPI))
|
.OrderBy(x => x.ImportanceIndex == null ? int.MaxValue : x.ImportanceIndex.Value).ToList();
|
|
var vmCacheList = new List<SzjtMonitorPointExSignalListDto>();
|
if (monitor_kpi_list != null)
|
{
|
var take_count = monitor_kpi_list.Count > Count ? Count : monitor_kpi_list.Count;
|
monitor_kpi_list = monitor_kpi_list.Take(take_count).ToList();
|
|
foreach (var monitor_kpi in monitor_kpi_list)
|
{
|
var vm = new SzjtMonitorPointExSignalListDto(monitor_kpi);
|
vmCacheList.Add(vm);
|
}
|
}
|
return vmCacheList;
|
}, CacheHelper.CacheLevel4);
|
return vm_list;
|
|
}
|
|
|
/// <summary>
|
/// 通过 ProductID 获取常规实时测点列表
|
/// </summary>
|
[Route("GetGeneralRealMonitorPointListByProductID")]
|
[HttpGet]
|
public List<SzjtMonitorPointExSignalListDto> GetGeneralRealMonitorPointListByProductID([FromQuery][Required] ProductIDInput input)
|
{
|
var productId = input.ProductID;
|
var cacheKey = $"LargeScreen_Szjt_Monitor_GetGeneralRealMonitorPointListByProductID_{_corpId}_{productId}";
|
var vm_list = MemoryCacheHelper.GetSet(cacheKey, () =>
|
{
|
var monitorMappingList = new Service.MonitorPointMapping().GetByObjectTypeAndObjectID(_corpId, ObjectType.Product, productId);
|
if (monitorMappingList == null || monitorMappingList.Count < 1)
|
return default;
|
var monitorIds = monitorMappingList.Select(x => x.MonitorPointID).Distinct().ToList();
|
var monitorList = new Service.MonitorPoint().GetExSignalWithSignalTypeByIds(_corpId, monitorIds, Model.eMonitorType.General, Model.Monitor.eCronType.Real);
|
var vmCacheList = monitorList?.Select(x => new SzjtMonitorPointExSignalListDto(x)).ToList();
|
return vmCacheList;
|
|
}, CacheHelper.CacheLevel3);
|
return vm_list;
|
}
|
|
/// <summary>
|
/// 通过 BelongType 和 BelongID 获取常规实时列表
|
/// </summary>
|
[Route("GetGeneralRealMonitorPointListByBelongTypeAndBelongID")]
|
[HttpGet]
|
public List<SzjtMonitorPointExSignalListDto> GetGeneralRealMonitorPointListByBelongTypeAndBelongID([FromQuery][Required] BelongInput input)
|
{
|
var corpId = _corpId;
|
var belongType = input.BelongType;
|
var belongId = input.BelongID;
|
var cacheKey = $"LargeScreen_Szjt_Monitor_GetGeneralRealMonitorPointListByBelongTypeAndBelongID_{corpId}_{belongType}_{belongId}";
|
var vm_list = MemoryCacheHelper.GetSet(cacheKey, () =>
|
{
|
|
var monitorList = new Service.MonitorPoint().GetExSignalWithSignalTypeByBelongTypeAndBelongID
|
(corpId, belongType, belongId, Model.eMonitorType.General, Model.Monitor.eCronType.Real);
|
var vmCacheList = monitorList?.Select(x => new SzjtMonitorPointExSignalListDto(x)).ToList();
|
return vmCacheList;
|
|
}, CacheHelper.CacheLevel3);
|
|
return vm_list;
|
}
|
|
|
|
|
}
|
}
|
