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")]
|
[ApiDescriptionSettings("Run", Name = "运行状态", Order = 900)]
|
public class RunStatus_Controller : IDynamicApiController
|
{
|
|
/// <summary>
|
/// 通过 MonitorPointGroupID 获取最后一条记录
|
/// </summary>
|
[Route("GetLastRecordByMonitorPointGroupID@V1.0")]
|
[HttpGet]
|
public MonitorObjectLastRunStatusRecord GetLastRecordByMonitorPointGroupID
|
(
|
[Required, Range(1, long.MaxValue, ErrorMessage = "CorpID 必须大于0")]
|
long CorpID,
|
[Required, Range(1, long.MaxValue, ErrorMessage = "MonitorPointGroupID 必须大于0")]
|
long MonitorPointGroupID
|
)
|
{
|
var monitor_group = new Service.MonitorPointGroup().GetByID(CorpID, MonitorPointGroupID);
|
if (monitor_group == null)
|
{
|
return default;
|
}
|
|
var monitor_list = new Service.MonitorPoint().GetExSignalWithSignalTypeByGroupID
|
(CorpID, MonitorPointGroupID, Model.eMonitorType.General, Model.Monitor.eCronType.Real);
|
var monitor_run_list = monitor_list?.Where(x => x.SignalList.First().SignalType.Identifier == IStation.SignalType.运行状态).ToList();
|
var monitor_run_default = monitor_run_list?.Find(x => x.Flags != null && x.Flags.Contains(IStation.LogicFlags.默认));
|
if (monitor_run_default == null)
|
monitor_run_default = monitor_run_list?.FirstOrDefault();
|
|
var vm = new MonitorObjectLastRunStatusRecord();
|
vm.CorpID = monitor_group.CorpID;
|
vm.ObjectType = IStation.ObjectType.MonitorPointGroup;
|
vm.ObjectID = monitor_group.ID;
|
vm.ObjectName = monitor_group.Name;
|
vm.RunStatus = IStation.RunStatus.Shut;
|
|
if (monitor_run_default != null)
|
{
|
var last_record = new Service.MonitorRealRecord().GetLastRecord(monitor_run_default.CorpID, monitor_run_default.ID, monitor_run_default.SignalList.First().ID);
|
if (last_record != null)
|
{
|
vm.DataTime =last_record.DataTime;
|
if (double.TryParse(last_record.DataValue, out double data_value))
|
{
|
vm.RunStatus = data_value > 0 ? IStation.RunStatus.Run : IStation.RunStatus.Shut;
|
}
|
}
|
}
|
|
return vm;
|
}
|
|
/// <summary>
|
/// 通过 MonitorPointGroupIds 获取最后一条记录
|
/// </summary>
|
[Route("GetLastRecordByMonitorPointGroupIds@V1.0")]
|
[HttpGet]
|
public List<MonitorObjectLastRunStatusRecord> GetLastRecordByMonitorPointGroupIds([FromQuery][Required] MonitorPointGroupIdsUnderCorpInput input)
|
{
|
var ids = LongListHelper.ToList(input.MonitorPointGroupIds);
|
var monitor_group_list = new Service.MonitorPointGroup().GetByIds(input.CorpID, ids);
|
if (monitor_group_list == null || monitor_group_list.Count < 1)
|
{
|
return default;
|
}
|
|
var service_monitor = new Service.MonitorPoint();
|
var service_record = new Service.MonitorRealRecord();
|
|
var vm_list = new List<MonitorObjectLastRunStatusRecord>();
|
foreach (var monitor_group in monitor_group_list)
|
{
|
var monitor_list = new Service.MonitorPoint().GetExSignalWithSignalTypeByGroupID
|
(input.CorpID, monitor_group.ID, Model.eMonitorType.General, Model.Monitor.eCronType.Real);
|
var monitor_run_list = monitor_list?.Where(x => x.SignalList.First().SignalType.Identifier == IStation.SignalType.运行状态).ToList();
|
var monitor_run_default = monitor_run_list?.Find(x => x.Flags != null && x.Flags.Contains(IStation.LogicFlags.默认));
|
if (monitor_run_default == null)
|
monitor_run_default = monitor_run_list?.FirstOrDefault();
|
|
var vm = new MonitorObjectLastRunStatusRecord();
|
vm.CorpID = monitor_group.CorpID;
|
vm.ObjectType = IStation.ObjectType.MonitorPointGroup;
|
vm.ObjectID = monitor_group.ID;
|
vm.ObjectName = monitor_group.Name;
|
vm.RunStatus = IStation.RunStatus.Shut;
|
vm_list.Add(vm);
|
|
if (monitor_run_default != null)
|
{
|
var last_record = new Service.MonitorRealRecord().GetLastRecord(monitor_run_default.CorpID, monitor_run_default.ID, monitor_run_default.SignalList.First().ID);
|
if (last_record != null)
|
{
|
vm.DataTime = last_record.DataTime;
|
if (double.TryParse(last_record.DataValue, out double data_value))
|
{
|
vm.RunStatus = data_value > 0 ? IStation.RunStatus.Run : IStation.RunStatus.Shut;
|
}
|
}
|
}
|
}
|
return vm_list;
|
|
}
|
|
|
/// <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<ProductRunStatusLogicDto> GetByProductIds([FromQuery][Required] ProductIdsUnderCorpInput input)
|
{
|
var corpId = input.CorpID;
|
var productIds = LongListHelper.ToList(input.ProductIds);
|
var vmList = new List<ProductRunStatusLogicDto>();
|
foreach (var productId in productIds)
|
{
|
var vm = new ProductRunStatusLogicDto();
|
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;
|
}
|
|
|
|
|
|
}
|
}
|
