namespace Yw.Application
|
{
|
/// <summary>
|
/// HealthQuotaEvaluationHandOnline
|
/// </summary>
|
[Route("Health/Quota/Evaluation/Online/Logic")]
|
[ApiDescriptionSettings("Health", Name = "指标在线评价(业务)", Order = 900)]
|
public class HealthQuotaEvaluationHandOnline_LogicController : IDynamicApiController
|
{
|
|
/// <summary>
|
/// 通过 EquipmentID 获取
|
/// </summary>
|
[Route("GetByEquipmentID@V1.0")]
|
[HttpGet]
|
public List<MonitorPointOnlineLogicDto> GetByEquipmentID([FromQuery][Required] EquipmentIDInput input)
|
{
|
var equipmentId = input.EquipmentID;
|
|
#region 获取所有设备
|
|
var serviceEquipment = new Service.Equipment();
|
var allEquipmentList = serviceEquipment.GetChildAndSelfByID(equipmentId);
|
if (allEquipmentList == null || allEquipmentList.Count < 1)
|
{
|
throw Oops.Oh(ErrorCodes.D001, $"EquipmentID:{equipmentId}");
|
}
|
|
#endregion
|
|
#region 获取设备测点映射
|
|
var allEquipmentIds = allEquipmentList.Select(x => x.ID).Distinct().ToList();
|
var serviceMonitorMapping = new Service.EquipmentMonitorMapping();
|
var allMonitorMappingList = serviceMonitorMapping.GetByEquipmentIds(allEquipmentIds);
|
if (allMonitorMappingList == null || allMonitorMappingList.Count < 1)
|
{
|
return default;
|
}
|
|
#endregion
|
|
#region 获取所有测点
|
|
var allMonitorIds = allMonitorMappingList.Select(x => x.MonitorPointID).Distinct().ToList();
|
var serviceMonitor = new Service.MonitorPoint();
|
var allMonitorList = serviceMonitor.GetExSignalWithSignalTypeByIds(allMonitorIds);
|
if (allMonitorList == null || allMonitorList.Count < 1)
|
{
|
return default;
|
}
|
|
#endregion
|
|
#region 获取所有测点组
|
|
var allGroupIds = allMonitorList.Select(x => x.GroupID).Distinct().ToList();
|
var serviceMonitorGroup = new Service.MonitorPointGroup();
|
var allGroupList = serviceMonitorGroup.GetByIds(allGroupIds);
|
if (allGroupList == null || allGroupList.Count < 1)
|
{
|
return default;
|
}
|
|
#endregion
|
|
#region 获取所有绑定
|
|
var allSignalIds = allMonitorList.SelectMany(x => x.SignalList.Select(t => t.ID)).ToList();
|
var allBindingList = new Service.HealthQuotaEvaluationModelBinding().GetValidBySignalIds(allSignalIds);
|
if (allBindingList == null || allBindingList.Count < 1)
|
{
|
return default;
|
}
|
|
#endregion
|
|
#region 获取所有绑定模型
|
|
var allModelIds = allBindingList.Select(x => x.ModelID).Distinct().ToList();
|
var allModelList = new Yw.Service.HealthQuotaEvaluationModel().GetByIds(allModelIds);
|
if (allModelList == null || allModelList.Count < 1)
|
{
|
return default;
|
}
|
|
#endregion
|
|
#region 遍历构造
|
|
var serviceMonitorRecord = new Lazy<Service.MonitorRecord>(() => new Service.MonitorRecord());
|
var serviceEvaluateRecord = new Lazy<Service.HealthQuotaEvaluationRecord>(() => new Service.HealthQuotaEvaluationRecord());
|
var vmList = new List<MonitorPointOnlineLogicDto>();
|
foreach (var group in allGroupList)
|
{
|
var monitorList = allMonitorList.Where(x => x.GroupID == group.ID).OrderBy(x => x.SortCode).ToList();
|
if (monitorList == null || monitorList.Count < 1)
|
continue;
|
foreach (var monitor in monitorList)
|
{
|
var vm = new MonitorPointOnlineLogicDto(monitor);
|
foreach (var signal in monitor.SignalList)
|
{
|
var binding = allBindingList.Find(x => x.SignalID == signal.ID);
|
if (binding != null)
|
{
|
var model = allModelList.Find(x => x.ID == binding.ModelID);
|
if (model != null)
|
{
|
if (model.Way == eEvaluateWay.Hand)
|
{
|
var lastRecord = serviceMonitorRecord.Value.GetLastRecord(signal.ID);
|
if (lastRecord != null)
|
{
|
var lastEvaluateRecord = serviceEvaluateRecord.Value.GetLastRecord(signal.ID);
|
var vmSignal = new SignalOnlineLogicDto(signal, lastRecord, model, lastEvaluateRecord);
|
vm.SignalList.Add(vmSignal);
|
}
|
}
|
}
|
}
|
}
|
if (vm.SignalList.Count > 0)
|
{
|
vmList.Add(vm);
|
}
|
}
|
}
|
|
return vmList;
|
#endregion
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
}
|
}
|
