// Admin.NET 项目的版权、商标、专利和其他相关权利均受相应法律法规的保护。使用本项目应遵守相关法律法规和许可证的要求。
|
//
|
// 本项目主要遵循 MIT 许可证和 Apache 许可证（版本 2.0）进行分发和使用。许可证位于源代码树根目录中的 LICENSE-MIT 和 LICENSE-APACHE 文件。
|
//
|
// 不得利用本项目从事危害国家安全、扰乱社会秩序、侵犯他人合法权益等法律法规禁止的活动！任何基于本项目二次开发而产生的一切法律纠纷和责任，我们不承担任何责任！
|
|
using Admin.NET.Core.Service;
|
using AngleSharp.Dom;
|
using DocumentFormat.OpenXml.Vml.Office;
|
using Elastic.Clients.Elasticsearch.Tasks;
|
using Microsoft.AspNetCore.Http;
|
using WCS.Application.Entity;
|
namespace WCS.Application;
|
|
/// <summary>
|
/// 分拣任务表服务
|
/// </summary>
|
[ApiDescriptionSettings(ApplicationConst.GroupName, Order = 100)]
|
public class WcsCheckTaskService : IDynamicApiController, ITransient
|
{
|
private readonly SqlSugarRepository<WcsCheckTask> _wcsCheckTaskRep;
|
private readonly SqlSugarRepository<WcsDevice> _wcsDeviceRep;
|
private readonly SqlSugarRepository<WcsOderTask> _wcsOderTaskRep;
|
private readonly SqlSugarRepository<WcsMateialPzInfo> _wcsMateialPzInfoRep;
|
|
public WcsCheckTaskService(SqlSugarRepository<WcsCheckTask> wcsCheckTaskRep, SqlSugarRepository<WcsDevice> wcsDeviceRep, SqlSugarRepository<WcsOderTask> wcsOderTaskRep, SqlSugarRepository<WcsMateialPzInfo> wcsMateialPzInfoRep)
|
{
|
_wcsCheckTaskRep = wcsCheckTaskRep;
|
_wcsDeviceRep = wcsDeviceRep;
|
_wcsOderTaskRep = wcsOderTaskRep;
|
_wcsMateialPzInfoRep = wcsMateialPzInfoRep;
|
}
|
|
/// <summary>
|
/// 分页查询分拣任务表
|
/// </summary>
|
/// <param name="input"></param>
|
/// <returns></returns>
|
[HttpPost]
|
[ApiDescriptionSettings(Name = "Page")]
|
[DisplayName("分页查询分拣任务表")]
|
public async Task<SqlSugarPagedList<WcsCheckTaskOutput>> Page(PageWcsCheckTaskInput input)
|
{
|
input.SearchKey = input.SearchKey?.Trim();
|
var query = _wcsCheckTaskRep.AsQueryable()
|
.WhereIF(!string.IsNullOrEmpty(input.SearchKey), u =>
|
u.OrderNo.Contains(input.SearchKey)
|
|| u.RoboatNo.Contains(input.SearchKey)
|
|| u.LineNo.Contains(input.SearchKey)
|
|| u.Port.Contains(input.SearchKey)
|
|| u.LotNo.Contains(input.SearchKey)
|
|| u.SkuNo.Contains(input.SearchKey)
|
|| u.SkuName.Contains(input.SearchKey)
|
|| u.BoxType.Contains(input.SearchKey)
|
|| u.Status.Contains(input.SearchKey)
|
|| u.PZNo.Contains(input.SearchKey)
|
|| u.PalletNo.Contains(input.SearchKey)
|
)
|
.WhereIF(!string.IsNullOrWhiteSpace(input.OrderNo), u => u.OrderNo.Contains(input.OrderNo.Trim()))
|
.WhereIF(!string.IsNullOrWhiteSpace(input.RoboatNo), u => u.RoboatNo.Contains(input.RoboatNo.Trim()))
|
.WhereIF(!string.IsNullOrWhiteSpace(input.LineNo), u => u.LineNo.Contains(input.LineNo.Trim()))
|
.WhereIF(!string.IsNullOrWhiteSpace(input.Port), u => u.Port.Contains(input.Port.Trim()))
|
.WhereIF(!string.IsNullOrWhiteSpace(input.LotNo), u => u.LotNo.Contains(input.LotNo.Trim()))
|
.WhereIF(!string.IsNullOrWhiteSpace(input.SkuNo), u => u.SkuNo.Contains(input.SkuNo.Trim()))
|
.WhereIF(!string.IsNullOrWhiteSpace(input.SkuName), u => u.SkuName.Contains(input.SkuName.Trim()))
|
.WhereIF(!string.IsNullOrWhiteSpace(input.BoxType), u => u.BoxType.Contains(input.BoxType.Trim()))
|
.WhereIF(!string.IsNullOrWhiteSpace(input.Status), u => u.Status.Contains(input.Status.Trim()))
|
.WhereIF(!string.IsNullOrWhiteSpace(input.PZNo), u => u.PZNo.Contains(input.PZNo.Trim()))
|
.WhereIF(!string.IsNullOrWhiteSpace(input.PalletNo), u => u.PalletNo.Contains(input.PalletNo.Trim()))
|
.WhereIF(input.BoxInsert>0, u => u.BoxInsert == input.BoxInsert)
|
.WhereIF(input.BoxCount>0, u => u.BoxCount == input.BoxCount)
|
.WhereIF(input.Qty>0, u => u.Qty == input.Qty)
|
.WhereIF(input.FinishQty>0, u => u.FinishQty == input.FinishQty)
|
.WhereIF(input.BindTimeRange != null && input.BindTimeRange.Length == 2, u => u.BindTime >= input.BindTimeRange[0] && u.BindTime <= input.BindTimeRange[1])
|
.WhereIF(input.BindUserId>0, u => u.BindUserId == input.BindUserId)
|
.Select<WcsCheckTaskOutput>();
|
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(AddWcsCheckTaskInput input)
|
{
|
var entity = input.Adapt<WcsCheckTask>();
|
await _wcsCheckTaskRep.InsertAsync(entity);
|
return entity.Id;
|
}
|
|
/// <summary>
|
/// 删除分拣任务表
|
/// </summary>
|
/// <param name="input"></param>
|
/// <returns></returns>
|
[HttpPost]
|
[ApiDescriptionSettings(Name = "Delete")]
|
[DisplayName("删除分拣任务表")]
|
public async Task Delete(DeleteWcsCheckTaskInput input)
|
{
|
var entity = await _wcsCheckTaskRep.GetFirstAsync(u => u.Id == input.Id) ?? throw Oops.Oh(ErrorCodeEnum.D1002);
|
await _wcsCheckTaskRep.FakeDeleteAsync(entity); //假删除
|
//await _wcsCheckTaskRep.DeleteAsync(entity); //真删除
|
}
|
|
/// <summary>
|
/// 更新分拣任务表
|
/// </summary>
|
/// <param name="input"></param>
|
/// <returns></returns>
|
[HttpPost]
|
[ApiDescriptionSettings(Name = "Update")]
|
[DisplayName("更新分拣任务表")]
|
public async Task Update(UpdateWcsCheckTaskInput input)
|
{
|
var entity = input.Adapt<WcsCheckTask>();
|
await _wcsCheckTaskRep.AsUpdateable(entity).IgnoreColumns(ignoreAllNullColumns: true).ExecuteCommandAsync();
|
}
|
|
/// <summary>
|
/// 获取分拣任务表
|
/// </summary>
|
/// <param name="input"></param>
|
/// <returns></returns>
|
[HttpGet]
|
[ApiDescriptionSettings(Name = "Detail")]
|
[DisplayName("获取分拣任务表")]
|
public async Task<WcsCheckTask> Detail([FromQuery] QueryByIdWcsCheckTaskInput input)
|
{
|
return await _wcsCheckTaskRep.GetFirstAsync(u => u.Id == input.Id);
|
}
|
|
/// <summary>
|
/// 获取分拣任务表列表
|
/// </summary>
|
/// <param name="input"></param>
|
/// <returns></returns>
|
[HttpGet]
|
[ApiDescriptionSettings(Name = "List")]
|
[DisplayName("获取分拣任务表列表")]
|
public async Task<List<WcsCheckTaskOutput>> List([FromQuery] PageWcsCheckTaskInput input)
|
{
|
return await _wcsCheckTaskRep.AsQueryable().Select<WcsCheckTaskOutput>().ToListAsync();
|
}
|
|
/// <summary>
|
/// 手动绑定任务
|
/// </summary>
|
/// <param name="input"></param>
|
/// <returns></returns>
|
[HttpPost]
|
[ApiDescriptionSettings(Name = "BindTaskForPLC")]
|
[DisplayName("手动绑定任务")]
|
public async Task BindTaskForPLC(BindTaskPLCInput input)
|
{
|
var deviceInfo = await _wcsDeviceRep.GetByIdAsync(input.deviceId);
|
if (deviceInfo == null)
|
{
|
throw Oops.Oh("设备工位信息不存在");
|
}
|
var taskInfo = await _wcsOderTaskRep.GetByIdAsync(input.oderTaskId);
|
if (taskInfo == null)
|
{
|
throw Oops.Oh("任务信息不存在");
|
}
|
if (taskInfo.Status > TaskStatusEnum.Doing)
|
{
|
throw Oops.Oh("任务状态异常");
|
}
|
//物料品种信息
|
var skuInfo = await _wcsMateialPzInfoRep.Context.Queryable<WcsMateialPzInfo>().Where(w => w.SkuNo == taskInfo.SkuNo).FirstAsync();
|
if (skuInfo == null)
|
{
|
throw Oops.Oh("物料品种信息不存在");
|
}
|
//分拣任务信息
|
var checkTaskInfo = await _wcsCheckTaskRep.Context.Queryable<WcsCheckTask>().Where(w => w.Port == deviceInfo.StationNum).FirstAsync();
|
if (checkTaskInfo == null)
|
{
|
throw Oops.Oh("分拣任务信息不存在");
|
}
|
if (checkTaskInfo.Status != "0")
|
{
|
throw Oops.Oh("该工位已绑定任务，请勿再次绑定");
|
}
|
checkTaskInfo.OrderNo = taskInfo.OrderNo;
|
checkTaskInfo.LotNo = taskInfo.LotNo;
|
checkTaskInfo.SkuNo = taskInfo.SkuNo;
|
checkTaskInfo.SkuName = taskInfo.SkuName;
|
checkTaskInfo.BoxType = taskInfo.BoxType;
|
checkTaskInfo.Qty = taskInfo.Qty;
|
checkTaskInfo.Status = "1";//已绑定
|
checkTaskInfo.PZNo = skuInfo.PZNo;
|
|
#region#给PLC写入抓箱品种号
|
var modPlc = await _wcsDeviceRep.Context.Queryable<WcsPlc>().FirstAsync(s => s.Id == deviceInfo.PlcId);
|
if (modPlc == null)
|
{
|
throw Oops.Bah("找不到PLC信息");
|
}
|
PLCUtil modUtil = new PLCUtil(modPlc);
|
if (modUtil.Connected)
|
{
|
var ret = modUtil.SetPlcDBValue(checkTaskInfo.PosType, checkTaskInfo.DbNumber, checkTaskInfo.PlcPos, checkTaskInfo.PZNo);
|
if (ret.IsSucceed)
|
{
|
//写入流程字成功后更新分拣任务
|
await _wcsCheckTaskRep.AsUpdateable(checkTaskInfo).IgnoreColumns(ignoreAllNullColumns: true).ExecuteCommandAsync();
|
}
|
else
|
{
|
throw Oops.Bah("与PCL交互失败，绑定失败！");
|
}
|
}
|
else
|
{
|
throw Oops.Bah("PCL未连接，绑定失败！");
|
}
|
#endregion
|
}
|
|
/// <summary>
|
/// 任务强制结批
|
/// </summary>
|
/// <param name="input"></param>
|
/// <returns></returns>
|
[HttpPost]
|
[ApiDescriptionSettings(Name = "CloseTaskForPLC")]
|
[DisplayName("任务强制结批")]
|
public async Task CloseTaskForPLC(CloseTaskPLCInput input)
|
{
|
// 注释：演示模式不绑定分道。liudl 2024-10-30
|
//if (PLCTaskAction.boDemo)
|
//{
|
// //演示模式
|
// var checkTaskList2 = await _wcsCheckTaskRep.Context.Queryable<WcsCheckTask>().FirstAsync(w => w.Port == "208");
|
|
// var deviceInfo = await _wcsDeviceRep.Context.Queryable<WcsDevice>().FirstAsync(w => w.StationNum == "208");
|
// if (deviceInfo == null)
|
// {
|
// throw Oops.Bah($"找不到工位号：208的码垛工位信息");
|
// }
|
// var modPlc = await _wcsDeviceRep.Context.Queryable<WcsPlc>().FirstAsync(s => s.Id == deviceInfo.PlcId);
|
// if (modPlc == null)
|
// {
|
// throw Oops.Bah($"找不到工位号：208的设备信息");
|
// }
|
// PLCUtil modUtil = new PLCUtil(modPlc);
|
|
// var ret = modUtil.SetPlcDBValue(checkTaskList2.PosTypeLot, checkTaskList2.DbNumber, checkTaskList2.PosLot, "1");
|
// return;
|
//}
|
|
// 正常模式
|
if (string.IsNullOrWhiteSpace(input.lotNo))
|
{
|
throw Oops.Bah($"该工位未绑定任务！");
|
}
|
var checkTaskList = _wcsCheckTaskRep.Context.Queryable<WcsCheckTask>().Where(w => w.LotNo == input.lotNo && w.Status == "1").ToList();
|
if (checkTaskList.Count <= 0)
|
{
|
throw Oops.Bah("找不到该批次分拣任务信息");
|
}
|
foreach (var item in checkTaskList)
|
{
|
#region#给PLC写入结批批次号
|
var deviceInfo = await _wcsDeviceRep.Context.Queryable<WcsDevice>().FirstAsync(w => w.StationNum == item.Port);
|
if (deviceInfo == null)
|
{
|
throw Oops.Bah($"找不到工位号：{item.Port} 的码垛工位信息");
|
}
|
var modPlc = await _wcsDeviceRep.Context.Queryable<WcsPlc>().FirstAsync(s => s.Id == deviceInfo.PlcId);
|
if (modPlc == null)
|
{
|
throw Oops.Bah($"找不到工位号：{item.Port} 的设备信息");
|
}
|
PLCUtil modUtil = new PLCUtil(modPlc);
|
if (modUtil.Connected)
|
{
|
var ret = modUtil.SetPlcDBValue(item.PosTypeLot, item.DbNumber, item.PosLot, "0"); // 解绑分道
|
if (ret.IsSucceed)
|
{
|
//写入流程字成功后更新分拣任务
|
item.OrderNo = "";
|
item.TaskNo = "";
|
item.LotNo = "";
|
item.SkuNo = "";
|
item.SkuName = "";
|
item.BoxType = "";
|
item.Qty = 0;
|
item.PZNo = "";
|
item.Status = "0";//未绑定
|
|
//更新分拣任务
|
await _wcsCheckTaskRep.AsUpdateable(item).IgnoreColumns(ignoreAllNullColumns: true).ExecuteCommandAsync();
|
}
|
else
|
{
|
throw Oops.Bah("与PCL交互失败，结批失败！");
|
}
|
}
|
else
|
{
|
throw Oops.Bah("PCL未连接，结批失败！");
|
}
|
#endregion
|
}
|
}
|
}
|
