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>
|
/// MonitorPoint
|
/// </summary>
|
[Route("Monitor/MonitorPoint/Mobile")]
|
[ApiDescriptionSettings("Monitor", Name = "监测点(手机)", Order = 788)]
|
public class MonitorPoint_MobileController : IDynamicApiController
|
{
|
/// <summary>
|
/// 通过 ProductID 获取
|
/// </summary>
|
[Route("GetByProductID@V1.0")]
|
[HttpGet]
|
public List<MonitorPointExSignalListMobileDto> GetByProductID([FromQuery][Required] ProductIDUnderCorpInput input)
|
{
|
var corpId=input.CorpID;
|
var productId = input.ProductID;
|
var cacheKey = $"Monitor_MonitorPoint_Mobile_GetByProductID_{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);
|
var vmCacheList = monitorList?.Where(x => x.UseStatus == Model.eUseStatus.Enable).Select(x => new MonitorPointExSignalListMobileDto(x)).ToList();
|
return vmCacheList;
|
|
}, CacheHelper.CacheLevel3);
|
return vm_list;
|
}
|
|
/// <summary>
|
/// 通过 StationID 获取（手机）
|
/// </summary>
|
[Route("GetByMeterID@V1.0")]
|
[HttpGet]
|
public List<MonitorPointExSignalListMobileDto> GetByMeterID([FromQuery][Required] MeterIDUnderCorpInput input)
|
{
|
var corpId = input.CorpID;
|
var meterId = input.MeterID;
|
var cacheKey = $"Monitor_MonitorPoint_Mobile_GetByMeterID_{corpId}_{meterId}";
|
var vm_list = MemoryCacheHelper.GetSet(cacheKey, () => {
|
var monitorMappingList = new Service.MonitorPointMapping().GetByObjectTypeAndObjectID(corpId, ObjectType.Product, meterId);
|
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);
|
var vmCacheList = monitorList?.Where(x => x.UseStatus == Model.eUseStatus.Enable).Select(x => new MonitorPointExSignalListMobileDto(x)).ToList();
|
return vmCacheList;
|
|
}, CacheHelper.CacheLevel3);
|
return vm_list;
|
}
|
|
/// <summary>
|
/// 通过 MeterID 获取KPI
|
/// </summary>
|
/// <param name="CorpID">客户标识</param>
|
/// <param name="StationID">泵站标识</param>
|
/// <param name="Count">KPI数量</param>
|
[Route("GetKpiByStationID@V1.0")]
|
[HttpGet]
|
public List<MonitorPointExSignalListMobileDto> GetKpiByStationID
|
(
|
[Required, Range(1, long.MaxValue, ErrorMessage = "CorpID 必须大于0")]
|
long CorpID,
|
[Required, Range(1, long.MaxValue, ErrorMessage = "StationID 必须大于0")]
|
long StationID,
|
int Count = 2
|
)
|
{
|
var cacheKey = $"Monitor_MonitorPoint_Mobile_GetKpiByStationID_{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.UseStatus== Model.eUseStatus.Enable&& x.Flags != null && x.Flags.Contains(LogicFlags.KPI))
|
.OrderBy(x => x.ImportanceIndex == null ? int.MaxValue : x.ImportanceIndex.Value).ToList();
|
|
var vmCacheList = new List<MonitorPointExSignalListMobileDto>();
|
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 MonitorPointExSignalListMobileDto(monitor_kpi);
|
vmCacheList.Add(vm);
|
}
|
}
|
return vmCacheList;
|
}, CacheHelper.CacheLevel4);
|
return vm_list;
|
|
}
|
|
/// <summary>
|
/// 通过 StationID 获取分组列表
|
/// </summary>
|
[Route("GetGroupListByStationID@V1.0")]
|
[HttpGet]
|
public List<MonitorPointGroupMobileDto> GetGroupListByStationID([FromQuery][Required] StationIDUnderCorpInput input)
|
{
|
var corpId = input.CorpID;
|
var stationId = input.StationID;
|
var cacheKey = $"Monitor_MonitorPoint_Mobile_GetGroupListByStationID_{corpId}_{stationId}";
|
var vm_list = MemoryCacheHelper.GetSet(cacheKey, () => {
|
|
var monitorList = new Service.MonitorPoint().GetExSignalWithSignalTypeByBelongTypeAndBelongID(corpId,ObjectType.Station,stationId);
|
monitorList = monitorList?.Where(x=>x.UseStatus== Model.eUseStatus.Enable).ToList();
|
if (monitorList == null || monitorList.Count < 1)
|
return default;
|
var vmCacheList = new List<MonitorPointGroupMobileDto>();
|
var monitorGroupList = new Service.MonitorPointGroup().GetByBelongTypeAndBelongID(corpId, ObjectType.Station, stationId);
|
if (monitorGroupList != null || monitorGroupList.Count > 0)
|
{
|
foreach (var monitorGroup in monitorGroupList)
|
{
|
if (monitorList.Exists(t => t.GroupID == monitorGroup.ID))
|
{
|
var vmGroup = new MonitorPointGroupMobileDto();
|
vmGroup.ID=monitorGroup.ID;
|
vmGroup.Name=monitorGroup.Name;
|
vmGroup.Description=monitorGroup.Description;
|
vmGroup.Items = new List<MonitorPointExSignalListMobileDto>();
|
vmCacheList.Add(vmGroup);
|
}
|
}
|
}
|
|
foreach (var monitor in monitorList)
|
{
|
var item=new MonitorPointExSignalListMobileDto(monitor);
|
var vmGroup = vmCacheList.Find(t=>t.ID==monitor.GroupID);
|
if (vmGroup == null)
|
{
|
vmGroup = new MonitorPointGroupMobileDto();
|
vmGroup.ID = 0;
|
vmGroup.Name = "未分组";
|
vmGroup.Description = string.Empty;
|
vmGroup.Items = new List<MonitorPointExSignalListMobileDto>();
|
vmCacheList.Add(vmGroup);
|
}
|
vmGroup.Items.Add(item);
|
}
|
|
|
return vmCacheList;
|
|
}, CacheHelper.CacheLevel2);
|
return vm_list;
|
}
|
|
/// <summary>
|
/// 通过 StationID 获取常规分组列表
|
/// </summary>
|
[Route("GetGeneralGroupListByStationID@V1.0")]
|
[HttpGet]
|
public List<MonitorPointGroupMobileDto> GetGeneralGroupListByStationID([FromQuery][Required] StationIDUnderCorpInput input)
|
{
|
var corpId = input.CorpID;
|
var stationId = input.StationID;
|
var cacheKey = $"Monitor_MonitorPoint_Mobile_GetGeneralGroupListByStationID_{corpId}_{stationId}";
|
var vm_list = MemoryCacheHelper.GetSet(cacheKey, () => {
|
|
var monitorList = new Service.MonitorPoint().GetExSignalWithSignalTypeByBelongTypeAndBelongID(corpId, ObjectType.Station, stationId,Model.eMonitorType.General);
|
monitorList = monitorList?.Where(x=>x.UseStatus== Model.eUseStatus.Enable).ToList();
|
if (monitorList == null || monitorList.Count < 1)
|
return default;
|
var vmCacheList = new List<MonitorPointGroupMobileDto>();
|
var monitorGroupList = new Service.MonitorPointGroup().GetByBelongTypeAndBelongID(corpId, ObjectType.Station, stationId);
|
if (monitorGroupList != null || monitorGroupList.Count > 0)
|
{
|
foreach (var monitorGroup in monitorGroupList)
|
{
|
if (monitorList.Exists(t => t.GroupID == monitorGroup.ID))
|
{
|
var vmGroup = new MonitorPointGroupMobileDto();
|
vmGroup.ID = monitorGroup.ID;
|
vmGroup.Name = monitorGroup.Name;
|
vmGroup.Description = monitorGroup.Description;
|
vmGroup.Items = new List<MonitorPointExSignalListMobileDto>();
|
vmCacheList.Add(vmGroup);
|
}
|
}
|
}
|
|
foreach (var monitor in monitorList)
|
{
|
var item = new MonitorPointExSignalListMobileDto(monitor);
|
var vmGroup = vmCacheList.Find(t => t.ID == monitor.GroupID);
|
if (vmGroup == null)
|
{
|
vmGroup = new MonitorPointGroupMobileDto();
|
vmGroup.ID = 0;
|
vmGroup.Name = "未分组";
|
vmGroup.Description = string.Empty;
|
vmGroup.Items = new List<MonitorPointExSignalListMobileDto>();
|
vmCacheList.Add(vmGroup);
|
}
|
vmGroup.Items.Add(item);
|
}
|
|
|
return vmCacheList;
|
|
}, CacheHelper.CacheLevel2);
|
return vm_list;
|
}
|
|
}
|
}
|
