using MES.Service.DB;
|
using MES.Service.Dto.service;
|
using MES.Service.Modes;
|
|
namespace MES.Service.service.Warehouse;
|
|
public class XbRackingTaskSyxtLogManager : Repository<XbRackingTaskSyxtLog>
|
{
|
/// <summary>
|
/// 核验任务单号是否存在
|
/// </summary>
|
/// <param name="dto">任务完成上报参数</param>
|
/// <returns>任务单号是否存在</returns>
|
public bool ValidateTaskExists(TaskCompleteReportDto dto)
|
{
|
if (dto == null || string.IsNullOrWhiteSpace(dto.TaskCode))
|
{
|
return false;
|
}
|
|
var task = Context.Queryable<XbRackingTaskSyxtLog>()
|
.Where(t => t.TaskCode == dto.TaskCode)
|
.Any();
|
|
return task;
|
}
|
|
/// <summary>
|
/// 任务完成上报
|
/// </summary>
|
/// <param name="dto">任务完成上报参数</param>
|
/// <returns>统一响应结果</returns>
|
public RackingTaskResponse TaskCompleteReport(TaskCompleteReportDto dto)
|
{
|
if (dto == null)
|
{
|
return RackingTaskResponse.Fail("参数不能为空");
|
}
|
|
if (string.IsNullOrWhiteSpace(dto.TaskCode))
|
{
|
return RackingTaskResponse.Fail("任务号不能为空");
|
}
|
|
if (string.IsNullOrWhiteSpace(dto.PalletCode))
|
{
|
return RackingTaskResponse.Fail("托盘编码不能为空");
|
}
|
|
try
|
{
|
// 步骤1：验证任务号是否存在
|
var task = Context.Queryable<XbRackingTaskSyxtLog>()
|
.Where(t => t.TaskCode == dto.TaskCode)
|
.First();
|
|
if (task == null)
|
{
|
return RackingTaskResponse.Fail($"任务号[{dto.TaskCode}]不存在");
|
}
|
|
// 步骤2：验证托盘编码是否匹配
|
if (task.PalletCode != dto.PalletCode)
|
{
|
return RackingTaskResponse.Fail($"托盘编码不匹配，期望[{task.PalletCode}]，实际[{dto.PalletCode}]");
|
}
|
|
// 步骤3：转换库位编码为中文
|
string? locCodeChinese = null;
|
if (!string.IsNullOrEmpty(dto.LocCode))
|
{
|
// 验证库位编码格式
|
if (dto.LocCode.Length != 6 || !dto.LocCode.All(char.IsDigit))
|
{
|
return RackingTaskResponse.Fail("库位编码格式错误，应为6位数字");
|
}
|
|
// 转换库位编码
|
locCodeChinese = ConvertLocCodeToChinese(dto.LocCode);
|
}
|
|
// 步骤4：更新任务日志表
|
var updateResult = Context.Updateable<XbRackingTaskSyxtLog>()
|
.SetColumns(t => t.LocCode == dto.LocCode)
|
.SetColumns(t => t.LocCodeChinese == locCodeChinese)
|
.SetColumns(t => t.Code == "200")
|
.SetColumns(t => t.JsonMessage == "任务完成")
|
.SetColumns(t => t.CodeMessage == "任务完成")
|
.Where(t => t.TaskCode == dto.TaskCode)
|
.ExecuteCommand();
|
|
if (updateResult <= 0)
|
{
|
return RackingTaskResponse.Fail("更新任务日志失败");
|
}
|
|
return RackingTaskResponse.Success();
|
}
|
catch (Exception ex)
|
{
|
return RackingTaskResponse.Fail($"更新任务日志失败：{ex.Message}");
|
}
|
}
|
|
/// <summary>
|
/// 将库位编码转换为中文描述
|
/// </summary>
|
/// <param name="locCode">库位编码，格式如"010203"</param>
|
/// <returns>中文描述，格式如"1排2层3列"</returns>
|
private string ConvertLocCodeToChinese(string locCode)
|
{
|
// 解析排号（前两位）
|
int row = int.Parse(locCode.Substring(0, 2));
|
// 解析层号（中间两位）
|
int level = int.Parse(locCode.Substring(2, 2));
|
// 解析列号（后两位）
|
int column = int.Parse(locCode.Substring(4, 2));
|
|
return $"{row}排{level}层{column}列";
|
}
|
|
|
/// <summary>
|
/// 异常任务上报
|
/// </summary>
|
/// <param name="dto">异常任务上报参数</param>
|
/// <returns>统一响应结果</returns>
|
public RackingTaskResponse TaskErrorReport(TaskErrorReportDto dto)
|
{
|
if (dto == null)
|
{
|
return RackingTaskResponse.Fail("参数不能为空");
|
}
|
|
if (string.IsNullOrWhiteSpace(dto.TaskCode))
|
{
|
return RackingTaskResponse.Fail("任务号不能为空");
|
}
|
|
if (string.IsNullOrWhiteSpace(dto.PalletCode))
|
{
|
return RackingTaskResponse.Fail("托盘编码不能为空");
|
}
|
|
if (string.IsNullOrWhiteSpace(dto.ErrorMessage))
|
{
|
return RackingTaskResponse.Fail("错误信息不能为空");
|
}
|
|
try
|
{
|
// 步骤1：验证任务号是否存在
|
var task = Context.Queryable<XbRackingTaskSyxtLog>()
|
.Where(t => t.TaskCode == dto.TaskCode)
|
.First();
|
|
if (task == null)
|
{
|
return RackingTaskResponse.Fail($"任务号[{dto.TaskCode}]不存在");
|
}
|
|
// 步骤2：验证托盘编码是否匹配
|
if (task.PalletCode != dto.PalletCode)
|
{
|
return RackingTaskResponse.Fail($"托盘编码不匹配，期望[{task.PalletCode}]，实际[{dto.PalletCode}]");
|
}
|
|
// 步骤3：更新任务日志表
|
var updateResult = Context.Updateable<XbRackingTaskSyxtLog>()
|
.SetColumns(t => t.Code == "500")
|
.SetColumns(t => t.JsonMessage == dto.ErrorMessage)
|
.SetColumns(t => t.CodeMessage == dto.ErrorMessage)
|
.Where(t => t.TaskCode == dto.TaskCode)
|
.ExecuteCommand();
|
|
if (updateResult <= 0)
|
{
|
return RackingTaskResponse.Fail("更新任务日志失败");
|
}
|
|
return RackingTaskResponse.Success();
|
}
|
catch (Exception ex)
|
{
|
return RackingTaskResponse.Fail($"更新任务日志失败：{ex.Message}");
|
}
|
}
|
}
|
