|
using Admin.NET.Core.Service;
|
using Elastic.Clients.Elasticsearch;
|
|
namespace WCS.Application;
|
|
/// <summary>
|
/// 设备信息服务
|
/// </summary>
|
[ApiDescriptionSettings(ApplicationConst.GroupName, Order = 100)]
|
public class WcsDeviceService : IDynamicApiController, ITransient
|
{
|
private readonly SqlSugarRepository<WcsDevice> _wcsDeviceRep;
|
private readonly SysCacheService _sysCacheService;
|
public WcsDeviceService(SqlSugarRepository<WcsDevice> wcsDeviceRep, SysCacheService sysCacheService)
|
{
|
_wcsDeviceRep = wcsDeviceRep;
|
_sysCacheService = sysCacheService;
|
}
|
|
/// <summary>
|
/// 分页查询设备信息
|
/// </summary>
|
/// <param name="input"></param>
|
/// <returns></returns>
|
[HttpPost]
|
[ApiDescriptionSettings(Name = "Page")]
|
[DisplayName("分页查询设备信息")]
|
public async Task<SqlSugarPagedList<WcsDeviceOutput>> Page(PageWcsDeviceInput input)
|
{
|
if (input.Field.IsNullOrEmpty())
|
{
|
input.Field = "u.Id";
|
input.Order = "desc";
|
}
|
input.SearchKey = input.SearchKey?.Trim();
|
var query = _wcsDeviceRep.AsQueryable()
|
.WhereIF(!string.IsNullOrEmpty(input.SearchKey), u =>
|
u.Text.Contains(input.SearchKey)
|
)
|
.WhereIF(input.PlcId > 0, u => u.PlcId == input.PlcId)
|
.WhereIF(!string.IsNullOrWhiteSpace(input.Text), u => u.Text.Contains(input.Text.Trim()))
|
//处理外键和TreeSelector相关字段的连接
|
.LeftJoin<WcsPlc>((u, plcid) => u.PlcId == plcid.Id)
|
.Select((u, plcid) => new WcsDeviceOutput
|
{
|
Id = u.Id,
|
PlcId = u.PlcId,
|
DeviceType = (DeviceTypeEnum)u.DeviceType,
|
PlcIdIP = plcid.IP,
|
Level = (DeviceLevelEnum)u.Level,
|
DbNumber = u.DbNumber,
|
StationNum = u.StationNum,
|
PlcPos = u.PlcPos,
|
WcsPos = u.WcsPos,
|
PosType = u.PosType,
|
LedIP = u.LedIP,
|
Text = u.Text,
|
CreateTime = u.CreateTime,
|
UpdateTime = u.UpdateTime,
|
CreateUserId = u.CreateUserId,
|
CreateUserName = u.CreateUserName,
|
UpdateUserId = u.UpdateUserId,
|
UpdateUserName = u.UpdateUserName,
|
CreateOrgId = u.CreateOrgId,
|
CreateOrgName = u.CreateOrgName,
|
IsDelete = u.IsDelete,
|
});
|
return await query.OrderBuilder(input).ToPagedListAsync(input.Page, input.PageSize);
|
}
|
|
/// <summary>
|
/// 增加设备信息
|
/// </summary>
|
/// <param name="input"></param>
|
/// <returns></returns>
|
[HttpPost]
|
[ApiDescriptionSettings(Name = "Add")]
|
[DisplayName("增加设备信息")]
|
public async Task<long> Add(AddWcsDeviceInput input)
|
{
|
var entity = input.Adapt<WcsDevice>();
|
await _wcsDeviceRep.InsertAsync(entity);
|
return entity.Id;
|
}
|
|
/// <summary>
|
/// 删除设备信息
|
/// </summary>
|
/// <param name="input"></param>
|
/// <returns></returns>
|
[HttpPost]
|
[ApiDescriptionSettings(Name = "Delete")]
|
[DisplayName("删除设备信息")]
|
public async Task Delete(DeleteWcsDeviceInput input)
|
{
|
var entity = await _wcsDeviceRep.GetFirstAsync(u => u.Id == input.Id) ?? throw Oops.Oh(ErrorCodeEnum.D1002);
|
await _wcsDeviceRep.FakeDeleteAsync(entity); //假删除
|
//await _wcsDeviceRep.DeleteAsync(entity); //真删除
|
}
|
|
/// <summary>
|
/// 更新设备信息
|
/// </summary>
|
/// <param name="input"></param>
|
/// <returns></returns>
|
[HttpPost]
|
[ApiDescriptionSettings(Name = "Update")]
|
[DisplayName("更新设备信息")]
|
public async Task Update(UpdateWcsDeviceInput input)
|
{
|
var entity = input.Adapt<WcsDevice>();
|
await _wcsDeviceRep.AsUpdateable(entity).IgnoreColumns(ignoreAllNullColumns: true).ExecuteCommandAsync();
|
}
|
|
/// <summary>
|
/// 获取设备信息
|
/// </summary>
|
/// <param name="input"></param>
|
/// <returns></returns>
|
[HttpGet]
|
[ApiDescriptionSettings(Name = "Detail")]
|
[DisplayName("获取设备信息")]
|
public async Task<WcsDevice> Detail([FromQuery] QueryByIdWcsDeviceInput input)
|
{
|
return await _wcsDeviceRep.GetFirstAsync(u => u.Id == input.Id);
|
}
|
|
/// <summary>
|
/// 获取PlcId列表
|
/// </summary>
|
/// <returns></returns>
|
[ApiDescriptionSettings(Name = "WcsPlcPlcIdDropdown"), HttpGet]
|
[DisplayName("获取PlcId列表")]
|
public async Task<dynamic> WcsPlcPlcIdDropdown()
|
{
|
return await _wcsDeviceRep.Context.Queryable<WcsPlc>()
|
.Select(u => new
|
{
|
Label = u.Text,
|
Value = u.Id
|
}
|
).ToListAsync();
|
}
|
|
/// <summary>
|
/// 生成点位
|
/// </summary>
|
/// <param name="input"></param>
|
/// <returns></returns>
|
[HttpPost]
|
[ApiDescriptionSettings(Name = "GeneratePos")]
|
[DisplayName("生成点位")]
|
public async Task GeneratePos(GeneratePosInput input)
|
{
|
var modDevice = await _wcsDeviceRep.GetByIdAsync(input.Id);
|
|
var listPosition = new List<WcsPosition>();
|
listPosition.Add(new WcsPosition()
|
{
|
DeviceId = modDevice.Id,
|
StationNum = modDevice.StationNum,
|
PlcPos = input.Pos.ToString(),
|
PosType = PLCDataTypeEnum.String,
|
Text = "TaskNo"
|
});
|
listPosition.Add(new WcsPosition()
|
{
|
DeviceId = modDevice.Id,
|
StationNum = modDevice.StationNum,
|
PlcPos = (input.Pos + 4).ToString(),
|
PosType = PLCDataTypeEnum.UShort,
|
Text = "TaskType"
|
});
|
listPosition.Add(new WcsPosition()
|
{
|
DeviceId = modDevice.Id,
|
StationNum = modDevice.StationNum,
|
PlcPos = (input.Pos + 6).ToString(),
|
PosType = PLCDataTypeEnum.UShort,
|
Text = "StartLocatNo"
|
});
|
listPosition.Add(new WcsPosition()
|
{
|
DeviceId = modDevice.Id,
|
StationNum = modDevice.StationNum,
|
PlcPos = (input.Pos + 8).ToString(),
|
PosType = PLCDataTypeEnum.UShort,
|
Text = "EndLocatNo"
|
});
|
|
await _wcsDeviceRep.Context.Insertable(listPosition).ExecuteCommandAsync();
|
}
|
|
/// <summary>
|
/// 获取设备信息列表
|
/// </summary>
|
/// <param name="input"></param>
|
/// <returns></returns>
|
[HttpGet]
|
[ApiDescriptionSettings(Name = "List")]
|
[DisplayName("获取设备信息列表")]
|
public async Task<List<WcsDeviceOutput>> List([FromQuery] PageWcsDeviceInput input)
|
{
|
var list = await _wcsDeviceRep.AsQueryable()
|
.LeftJoin<WcsPlc>((a, b) => a.PlcId == b.Id)
|
.Where((a, b) => a.DeviceType == DeviceTypeEnum.Business)
|
.Select<WcsDeviceOutput>((a, b) => new WcsDeviceOutput() { Type = b.Type }, true)
|
.ToListAsync();
|
//获取跺机的状态
|
foreach (var modDevice in list)
|
{
|
if (_sysCacheService.ExistKey("PLCCONN" + modDevice.PlcId))
|
{
|
var cachePlc = _sysCacheService.Get<WcsPlc>("PLCCONN" + modDevice.PlcId);
|
modDevice.Status = cachePlc.IsConn;
|
if (modDevice.Status)
|
{
|
//读取plc的值
|
var modConn = PLCTaskAction.listPlcConn.FirstOrDefault(s => s != null && s.PlcId == modDevice.PlcId);
|
if (modConn == null)
|
{
|
continue;
|
}
|
try
|
{
|
var listPosition = await _wcsDeviceRep.Context.Queryable<WcsPosition>().Where(s => s.DeviceId == modDevice.Id).ToListAsync();
|
(var result, var plc) = modConn.GetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.PlcPos);
|
modDevice.Plc = Convert.ToString(plc);
|
(result, var wcs) = modConn.GetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos);
|
modDevice.Wcs = Convert.ToString(wcs);
|
//任务号
|
var modPositionTask = listPosition.FirstOrDefault(s => s.Text == "任务号");
|
(result, var taskNo) = modConn.GetPlcDBValue(modPositionTask.PosType, modDevice.DbNumber, modPositionTask.PlcPos, modPositionTask.StringLength);
|
modDevice.TaskNo = Convert.ToString(taskNo);
|
//任务类型
|
var modPositionTaskType = listPosition.FirstOrDefault(s => s.Text == "任务类型");
|
(result, var taskType) = modConn.GetPlcDBValue(modPositionTaskType.PosType, modDevice.DbNumber, modPositionTaskType.PlcPos);
|
modDevice.TaskType = (TaskTypeEnum)Convert.ToInt32(taskType);
|
//起始工位
|
var modPositionStartLocatNo = listPosition.FirstOrDefault(s => s.Text == "起始工位");
|
(result, var startLocatNo) = modConn.GetPlcDBValue(modPositionStartLocatNo.PosType, modDevice.DbNumber, modPositionStartLocatNo.PlcPos);
|
modDevice.StartLocatNo = Convert.ToString(startLocatNo);
|
//目的工位
|
var modPositionEndLocatNo = listPosition.FirstOrDefault(s => s.Text == "目的工位");
|
(result, var endLocatNo) = modConn.GetPlcDBValue(modPositionEndLocatNo.PosType, modDevice.DbNumber, modPositionEndLocatNo.PlcPos);
|
modDevice.EndLocatNo = Convert.ToString(endLocatNo);
|
//托盘码
|
var modPositionPalletNo = listPosition.FirstOrDefault(s => s.Text == "托盘码");
|
(result, var palletNo) = modConn.GetPlcDBValue(modPositionPalletNo.PosType, modDevice.DbNumber, modPositionPalletNo.PlcPos, modPositionPalletNo.StringLength);
|
modDevice.PalletNo = Convert.ToString(palletNo);
|
}
|
catch (Exception)
|
{
|
|
}
|
}
|
}
|
else
|
{
|
modDevice.Status = false;
|
}
|
|
//modDevice.TaskNo = "TK00001";
|
//modDevice.TaskType = TaskTypeEnum.In;
|
//modDevice.PalletNo = "2024209032";
|
//modDevice.StartLocatNo = "010101";
|
//modDevice.EndLocatNo = "020202";
|
//modDevice.Wcs = new Random().Next(100).ToString();
|
//modDevice.Plc = new Random().Next(100).ToString();
|
//modDevice.Status = true;
|
}
|
|
return list;
|
}
|
|
#region 分拣码垛
|
/// <summary>
|
/// 获取码垛机器人和拆垛机器人列表
|
/// </summary>
|
/// <returns></returns>
|
[HttpGet]
|
[ApiDescriptionSettings(Name = "WcsPackPlcList")]
|
[DisplayName("获取码垛机器人和拆垛机器人列表")]
|
public async Task<dynamic> WcsPackPlcList()
|
{
|
return await _wcsDeviceRep.Context.Queryable<WcsPlc>()
|
.Where(w => w.Type == PLCTypeEnum.RobotPalletizer || w.Type == PLCTypeEnum.StackingRobot)
|
.OrderBy(o => o.Type)
|
.Select(u => new
|
{
|
id = u.Id,
|
name = u.Text
|
}
|
).ToListAsync();
|
}
|
|
#endregion
|
}
|
