using Furion.DatabaseAccessor;
|
using Furion.DatabaseAccessor.Extensions;
|
using Furion.DependencyInjection;
|
using Furion.DynamicApiController;
|
using Furion.FriendlyException;
|
using iWare.Wms.Core;
|
using Mapster;
|
using Microsoft.AspNetCore.Mvc;
|
using Microsoft.EntityFrameworkCore;
|
using Microsoft.EntityFrameworkCore.Internal;
|
using System.Diagnostics;
|
using System.Linq.Dynamic.Core;
|
|
namespace iWare.Wms.Application
|
{
|
/// <summary>
|
/// 设备监控服务
|
/// </summary>
|
[ApiDescriptionSettings("数据查询服务", Name = "EquipmentCurrentMonitor", Order = 100)]
|
[Route("api/[Controller]")]
|
public class EquipmentCurrentMonitorService : IEquipmentCurrentMonitorService, IDynamicApiController, ITransient
|
{
|
private readonly IRepository<EquipmentCurrentMonitor,MasterDbContextLocator> _equipmentCurrentMonitorRep;
|
private readonly IRepository<EquipmentBaseInfo, MasterDbContextLocator> _equipmentBaseInfoRep;
|
private readonly IRepository<SysDictType, MasterDbContextLocator> _sysDictTypeRep;
|
private readonly IRepository<SysDictData, MasterDbContextLocator> _sysDictDataRep;
|
|
/// <summary>
|
/// 设备监控构造
|
/// </summary>
|
/// <param name="equipmentCurrentMonitorRep"></param>
|
/// <param name="equipmentBaseInfoRep"></param>
|
/// <param name="sysDictTypeRep"></param>
|
/// <param name="sysDictDataRep"></param>
|
public EquipmentCurrentMonitorService(
|
IRepository<EquipmentCurrentMonitor,MasterDbContextLocator> equipmentCurrentMonitorRep,
|
IRepository<EquipmentBaseInfo, MasterDbContextLocator> equipmentBaseInfoRep,
|
IRepository<SysDictType, MasterDbContextLocator> sysDictTypeRep,
|
IRepository<SysDictData, MasterDbContextLocator> sysDictDataRep
|
)
|
{
|
_equipmentCurrentMonitorRep = equipmentCurrentMonitorRep;
|
_equipmentBaseInfoRep = equipmentBaseInfoRep;
|
_sysDictTypeRep = sysDictTypeRep;
|
_sysDictDataRep = sysDictDataRep;
|
}
|
|
/// <summary>
|
/// 获取设备状态获取设备实时列表
|
/// </summary>
|
/// <param name="input"></param>
|
/// <returns></returns>
|
[HttpGet("page")]
|
public async Task<List<EquipmentCurrentMonitorOutput>> GetEquipmentLst([FromQuery] EquipmentCurrentMonitorSearch input)
|
{
|
|
var equipmentCurrentMonitors = await (from monitor in _equipmentCurrentMonitorRep.DetachedEntities
|
join baseinfo in _equipmentBaseInfoRep.DetachedEntities
|
on monitor.EquipmentID equals baseinfo.EquipmentId into joinedEmpty
|
from baseinfo2 in joinedEmpty.DefaultIfEmpty()
|
where monitor.EquipmentID != "HMI"
|
select new EquipmentCurrentMonitorOutput
|
{
|
Id = monitor.Id,
|
EquipmentID = monitor.EquipmentID,
|
EquipmentName = baseinfo2.EquipmentName,
|
EquipmentCurrentState = monitor.EquipmentCurrentState,
|
//EquipmentCurrentStateName = monitor.Value,
|
WorkingProcedure = monitor.WorkingProcedure,
|
WorkPieceID = monitor.WorkPieceID,
|
OnlineTime = monitor.OnlineTime,
|
WorkTime = monitor.WorkTime,
|
KnifeToolLife = monitor.KnifeToolLife,
|
SpindleCurrent = monitor.SpindleCurrent,
|
SpindleTorque = monitor.SpindleTorque,
|
SpindleLoad = monitor.SpindleLoad,
|
AlertTime = monitor.AlertTime,
|
FailureType = monitor.FailureType,
|
Alertmsg = monitor.Alertmsg,
|
Remarks = monitor.Remarks,
|
WarnType = monitor.WarnType,
|
Warnmsg=monitor.Warnmsg,
|
WarnTime=monitor.WarnTime
|
})
|
.ProjectToType<EquipmentCurrentMonitorOutput>()
|
.OrderBy(o => o.EquipmentID)
|
.ToListAsync();
|
//var equipmentCurrentMonitors = await _equipmentCurrentMonitorRep.DetachedEntities
|
// .LeftJoin(_equipmentBaseInfoRep.DetachedEntities, a => a.EquipmentID, b => b.EquipmentId, (a, b) => new { a, b })
|
// //.Join(_sysDictDataRep.DetachedEntities, e => e.a.EquipmentCurrentState, f => f.Code, (e, f) => new { e, f })
|
// //.Join(_sysDictTypeRep.DetachedEntities, g => g.f.TypeId, h => h.Id, (f, g) => new { f, g })
|
// //.Where(x => (x.g.Code.Equals("equipment_state") &&(string.IsNullOrEmpty(input.EquipmentCurrentState)?true:x.f.f.Code.Equals(input.EquipmentCurrentState))))
|
// .Select(s => new EquipmentCurrentMonitorOutput
|
// {
|
// Id = s.a.Id,
|
// EquipmentID = s.a.EquipmentID,
|
// EquipmentName = s.b.EquipmentName,
|
// EquipmentCurrentState = s.a.EquipmentCurrentState,
|
// //EquipmentCurrentStateName = s.a.Value,
|
// WorkingProcedure = s.a.WorkingProcedure,
|
// WorkPieceID = s.a.WorkPieceID,
|
// OnlineTime = s.a.OnlineTime,
|
// WorkTime = s.a.WorkTime,
|
// KnifeToolLife = s.a.KnifeToolLife,
|
// SpindleCurrent = s.a.SpindleCurrent,
|
// SpindleTorque = s.a.SpindleTorque,
|
// SpindleLoad = s.a.SpindleLoad,
|
// AlertTime = s.a.AlertTime,
|
// FailureType = s.a.FailureType,
|
// Alertmsg = s.a.Alertmsg,
|
// Remarks = s.a.Remarks,
|
// })
|
// .ProjectToType<EquipmentCurrentMonitorOutput>()
|
// .OrderBy( o => o.EquipmentID)
|
// .ToListAsync();
|
|
return equipmentCurrentMonitors;
|
}
|
|
/// <summary>
|
/// 查询设备状态相关信息
|
/// </summary>
|
/// <returns></returns>
|
[HttpGet("getEquipmentStatu")]
|
public async Task<List<EquipmentStatuOutput>> GetEquipmentStatu()
|
{
|
List<EquipmentStatuOutput> equipmentStatuInfoLst = new List<EquipmentStatuOutput>();
|
EquipmentStatuOutput statuOutput = new EquipmentStatuOutput();
|
statuOutput.EquipmentState = ((int)EnumEquipmentCurrentState.全部).ToString();
|
equipmentStatuInfoLst.Add(statuOutput);
|
statuOutput = new EquipmentStatuOutput();
|
statuOutput.EquipmentState = ((int)EnumEquipmentCurrentState.生产).ToString();
|
equipmentStatuInfoLst.Add(statuOutput);
|
statuOutput = new EquipmentStatuOutput();
|
statuOutput.EquipmentState = ((int)EnumEquipmentCurrentState.完成).ToString();
|
equipmentStatuInfoLst.Add(statuOutput);
|
statuOutput = new EquipmentStatuOutput();
|
statuOutput.EquipmentState = ((int)EnumEquipmentCurrentState.待机).ToString();
|
equipmentStatuInfoLst.Add(statuOutput);
|
statuOutput = new EquipmentStatuOutput();
|
statuOutput.EquipmentState = ((int)EnumEquipmentCurrentState.警告).ToString();
|
equipmentStatuInfoLst.Add(statuOutput);
|
statuOutput = new EquipmentStatuOutput();
|
statuOutput.EquipmentState = ((int)EnumEquipmentCurrentState.故障).ToString();
|
equipmentStatuInfoLst.Add(statuOutput);
|
statuOutput = new EquipmentStatuOutput();
|
statuOutput.EquipmentState = ((int)EnumEquipmentCurrentState.离线).ToString();
|
equipmentStatuInfoLst.Add(statuOutput);
|
|
equipmentStatuInfoLst = equipmentStatuInfoLst.OrderBy(o => o.EquipmentState).ToList();
|
|
foreach (EquipmentStatuOutput item in equipmentStatuInfoLst)
|
{
|
// 根据状态统计获取设备信息
|
int EquiPmentStatuCount = 0;
|
|
if (item.EquipmentState.Equals("0"))
|
{
|
EquiPmentStatuCount = await _equipmentCurrentMonitorRep.Where(o=>!o.EquipmentID.Contains("HMI"))
|
.CountAsync();
|
}
|
else
|
{
|
EquiPmentStatuCount = await _equipmentCurrentMonitorRep.Where(o => !o.EquipmentID.Contains("HMI"))
|
.Where(x => x.EquipmentCurrentState == item.EquipmentState)
|
.CountAsync();
|
}
|
|
item.EquipmentStateNum = EquiPmentStatuCount;
|
}
|
|
return equipmentStatuInfoLst;
|
}
|
}
|
}
|
