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 IStation.Calculation;
|
using IStation.Model;
|
|
namespace IStation.Application
|
{
|
/// <summary>
|
/// RunStatus
|
/// </summary>
|
[Route("Run/RunStatus/Mobile")]
|
[ApiDescriptionSettings("Run", Name = "运行状态(手机)", Order = 899)]
|
public class RunStatus_MobileController : IDynamicApiController
|
{
|
/// <summary>
|
/// 通过 ProductID 获取(手机)
|
/// </summary>
|
[Route("GetByProductID@V1.0")]
|
[HttpGet]
|
public int GetByProductID([FromQuery][Required] ProductIDUnderCorpInput input)
|
{
|
var corpId = input.CorpID;
|
var productId = input.ProductID;
|
var monitorMappingList = new Service.MonitorPointMapping().GetByObjectTypeAndObjectID(corpId,ObjectType.Product,productId);
|
if (monitorMappingList == null || monitorMappingList.Count < 1)
|
return RunStatus.UnKnown;
|
var monitorPointIds = monitorMappingList.Select(x => x.MonitorPointID).Distinct().ToList();
|
var monitorList = new Service.MonitorPoint().GetExSignalWithSignalTypeByIds(corpId,monitorPointIds,Model.eMonitorType.General,Model.Monitor.eCronType.Real);
|
if (monitorList == null || monitorList.Count < 1)
|
return RunStatus.UnKnown;
|
var monitorRunList = monitorList.Where(x => x.SignalList.First().SignalType.Identifier == IStation.SignalType.运行状态).ToList();
|
var monitorRunDefault= monitorRunList?.Find(x => x.Flags != null && x.Flags.Contains(IStation.LogicFlags.默认));
|
if (monitorRunDefault == null)
|
monitorRunDefault = monitorRunList?.FirstOrDefault();
|
if (monitorRunDefault == null)
|
return RunStatus.UnKnown;
|
var lastRecord = new Service.MonitorRealRecord().GetLastRecord(monitorRunDefault.CorpID, monitorRunDefault.ID, monitorRunDefault.SignalList.First().ID);
|
if (lastRecord == null)
|
return RunStatus.UnKnown;
|
if (!int.TryParse(lastRecord.DataValue, out int dataValue))
|
return RunStatus.UnKnown;
|
return dataValue;
|
}
|
|
/// <summary>
|
/// 通过 ProductIds 获取(手机)
|
/// </summary>
|
[Route("GetByProductIds@V1.0")]
|
[HttpGet]
|
public List<ProductRunStatusMobileDto> GetByProductIds([FromQuery][Required] ProductIdsUnderCorpInput input)
|
{
|
var corpId = input.CorpID;
|
var productIds = LongListHelper.ToList(input.ProductIds);
|
var vmList = new List<ProductRunStatusMobileDto>();
|
foreach (var productId in productIds)
|
{
|
var vm = new ProductRunStatusMobileDto();
|
vm.ProductID = productId;
|
vm.RunStatus = RunStatus.UnKnown;
|
vmList.Add(vm);
|
var monitorMappingList = new Service.MonitorPointMapping().GetByObjectTypeAndObjectID(corpId, ObjectType.Product, productId);
|
if (monitorMappingList == null || monitorMappingList.Count < 1)
|
continue;
|
var monitorPointIds = monitorMappingList.Select(x => x.MonitorPointID).Distinct().ToList();
|
var monitorList = new Service.MonitorPoint().GetExSignalWithSignalTypeByIds(corpId, monitorPointIds, Model.eMonitorType.General, Model.Monitor.eCronType.Real);
|
if (monitorList == null || monitorList.Count < 1)
|
continue;
|
var monitorRunList = monitorList.Where(x => x.SignalList.First().SignalType.Identifier == IStation.SignalType.运行状态).ToList();
|
var monitorRunDefault = monitorRunList?.Find(x => x.Flags != null && x.Flags.Contains(IStation.LogicFlags.默认));
|
if (monitorRunDefault == null)
|
monitorRunDefault = monitorRunList?.FirstOrDefault();
|
if (monitorRunDefault == null)
|
continue;
|
var lastRecord = new Service.MonitorRealRecord().GetLastRecord(monitorRunDefault.CorpID, monitorRunDefault.ID, monitorRunDefault.SignalList.First().ID);
|
if (lastRecord == null)
|
continue;
|
if (!int.TryParse(lastRecord.DataValue, out int dataValue))
|
continue;
|
vm.RunStatus = dataValue;
|
}
|
return vmList;
|
}
|
|
|
|
|
|
|
|
|
}
|
}
|
