using System.Diagnostics.CodeAnalysis;
|
using Serilog;
|
using WIDESEAWCS_Common.HttpEnum;
|
using WIDESEAWCS_Common.TaskEnum;
|
using WIDESEA_Core;
|
using WIDESEAWCS_Core;
|
using WIDESEAWCS_Core.Helper;
|
using WIDESEAWCS_DTO;
|
using WIDESEAWCS_DTO.TaskInfo;
|
using WIDESEAWCS_ITaskInfoService;
|
using WIDESEAWCS_Model.Models;
|
using WIDESEAWCS_QuartzJob.Models;
|
using WIDESEAWCS_QuartzJob.Service;
|
using WIDESEAWCS_Tasks;
|
|
namespace WIDESEAWCS_TaskInfoService.Flows
|
{
|
/// <summary>
|
/// 入库任务流程服务。
|
/// 负责入库任务接收初始化、状态推进及堆垛机完成处理。
|
/// </summary>
|
public class InboundTaskFlowService : IInboundTaskFlowService
|
{
|
private readonly IRouterService _routerService;
|
private readonly HttpClientHelper _httpClientHelper;
|
private readonly ILogger _logger;
|
|
/// <summary>
|
/// 初始化入库任务流程服务。
|
/// </summary>
|
/// <param name="routerService">路由服务。</param>
|
/// <param name="httpClientHelper">WMS接口调用帮助类。</param>
|
public InboundTaskFlowService(IRouterService routerService, HttpClientHelper httpClientHelper, ILogger logger)
|
{
|
_routerService = routerService;
|
_httpClientHelper = httpClientHelper;
|
_logger = logger;
|
}
|
|
/// <summary>
|
/// 接收WMS任务时初始化入库任务。
|
/// </summary>
|
/// <param name="task">任务实体。</param>
|
/// <param name="source">WMS任务原始数据。</param>
|
public WebResponseContent InitializeOnReceive([NotNull] Dt_Task task, [NotNull] WMSTaskDTO source)
|
{
|
WebResponseContent content = new WebResponseContent();
|
Dt_Router routers = _routerService.QueryNextRoute(source.SourceAddress);
|
if (routers.IsNullOrEmpty())
|
{
|
return content.Error("未找到路由信息");
|
}
|
|
task.TaskStatus = (int)TaskInStatusEnum.InNew;
|
task.CurrentAddress = source.SourceAddress;
|
task.NextAddress = routers.ChildPosi;
|
|
return content.OK();
|
}
|
|
/// <summary>
|
/// 推进入库任务状态，并在关键状态调用WMS接口。
|
/// </summary>
|
/// <param name="task">任务实体。</param>
|
/// <returns>推进结果。</returns>
|
public WebResponseContent MoveToNextStatus([NotNull] Dt_Task task)
|
{
|
if (task.TaskStatus >= (int)TaskInStatusEnum.InFinish)
|
return WebResponseContent.Instance.Error($"该任务状态不可跳转到下一步,任务号:【{task.TaskNum}】,任务状态:【{task.TaskStatus}】");
|
|
task.TaskStatus = task.TaskStatus.GetNextNotCompletedStatus<TaskInStatusEnum>();
|
if (task.TaskStatus <= 0)
|
return WebResponseContent.Instance.Error($"该任务状态不可跳转到下一步,任务号:【{task.TaskNum}】,任务状态:【{task.TaskStatus}】");
|
|
if (task.TaskStatus == (int)TaskInStatusEnum.Line_InFinish)
|
{
|
return GetWMSInboundLocation(task);
|
}
|
|
return UpdateWMSTaskStatus(task);
|
}
|
|
/// <summary>
|
/// 处理堆垛机入库完成动作。
|
/// </summary>
|
/// <param name="task">任务实体。</param>
|
/// <returns>处理结果。</returns>
|
public WebResponseContent CompleteStackerTask([NotNull] Dt_Task task)
|
{
|
WebResponseContent content = new WebResponseContent();
|
if (task.TaskStatus != (int)TaskInStatusEnum.SC_InExecuting)
|
{
|
return WebResponseContent.Instance.OK();
|
}
|
|
int nextStatus = task.TaskStatus.GetNextNotCompletedStatus<TaskInStatusEnum>();
|
task.TaskStatus = nextStatus;
|
task.ModifyDate = DateTime.Now;
|
task.Modifier = "System";
|
|
var result = _httpClientHelper.Post<WebResponseContent>(
|
nameof(ConfigKey.InboundFinishTaskAsync),
|
(new CreateTaskDto { PalletCode = task.PalletCode }).ToJson());
|
|
if (!result.IsSuccess || !result.Data.Status)
|
{
|
QuartzLogHelper.LogError(_logger, $"调用WMS接口失败,接口:【InboundFinishTaskAsync】,请求参数:【{task.PalletCode}】,错误信息:【{result.Data?.Message}】", "InboundTaskFlowService");
|
return content.Error($"通知WMS系统堆垛机入库完成失败,任务号:【{task.TaskNum}】,托盘号:【{task.PalletCode}】,错误信息:【{result.Data?.Message}】");
|
}
|
|
QuartzLogHelper.LogInfo(_logger, $"调用WMS接口成功,接口:【InboundFinishTaskAsync】,响应数据:【{result.Data?.Data}】,耗时:0ms", "InboundTaskFlowService");
|
return content.OK($"通知WMS系统堆垛机入库完成成功,任务号:【{task.TaskNum}】,托盘号:【{task.PalletCode}】");
|
}
|
|
/// <summary>
|
/// 从WMS获取入库目标地址并回写任务。
|
/// </summary>
|
/// <param name="task">任务实体。</param>
|
/// <returns>调用结果。</returns>
|
private WebResponseContent GetWMSInboundLocation(Dt_Task task)
|
{
|
string configKey = nameof(ConfigKey.GetTasksLocation);
|
string requestParam = new CreateTaskDto { PalletCode = task.PalletCode }.ToJson();
|
DateTime startTime = DateTime.Now;
|
|
var result = _httpClientHelper.Post<WebResponseContent>(
|
configKey,
|
requestParam);
|
|
if (!result.IsSuccess || !result.Data.Status)
|
{
|
QuartzLogHelper.LogError(_logger, $"调用WMS接口失败,接口:【{configKey}】,请求参数:【{requestParam}】,错误信息:【{result.Data?.Message}】", "InboundTaskFlowService");
|
return WebResponseContent.Instance.Error($"调用WMS接口获取任务目标地址失败,任务号:【{task.TaskNum}】,错误信息:【{result.Data?.Message}】");
|
}
|
|
QuartzLogHelper.LogInfo(_logger, $"调用WMS接口成功,接口:【{configKey}】,响应数据:【{result.Data?.Data}】,耗时:{(DateTime.Now - startTime).TotalMilliseconds}ms", "InboundTaskFlowService");
|
|
string? nextAddress = result.Data.Data?.ToString();
|
if (string.IsNullOrEmpty(nextAddress))
|
return WebResponseContent.Instance.Error($"调用WMS接口获取任务目标地址失败,任务号:【{task.TaskNum}】,错误信息:【未获取到有效的目标地址】");
|
|
task.CurrentAddress = task.NextAddress;
|
task.NextAddress = nextAddress;
|
task.TargetAddress = nextAddress;
|
|
return WebResponseContent.Instance.OK();
|
}
|
|
/// <summary>
|
/// 将任务状态同步到WMS。
|
/// </summary>
|
/// <param name="task">任务实体。</param>
|
/// <returns>同步结果。</returns>
|
private WebResponseContent UpdateWMSTaskStatus(Dt_Task task)
|
{
|
string configKey = nameof(ConfigKey.UpdateTaskByStatus);
|
string requestParam = new UpdateTaskDto { Id = task.TaskNum, NewStatus = task.TaskStatus, NextAddress = task.NextAddress, CurrentAddress = task.CurrentAddress }.ToJson();
|
DateTime startTime = DateTime.Now;
|
|
var result = _httpClientHelper.Post<WebResponseContent>(
|
configKey,
|
requestParam);
|
|
if (!result.IsSuccess || !result.Data.Status)
|
{
|
QuartzLogHelper.LogError(_logger, $"调用WMS接口失败,接口:【{configKey}】,请求参数:【{requestParam}】,错误信息:【{result.Data?.Message}】", "InboundTaskFlowService");
|
return WebResponseContent.Instance.Error($"调用WMS接口更新任务状态失败,任务号:【{task.TaskNum}】,错误信息:【{result.Data?.Message}】");
|
}
|
|
QuartzLogHelper.LogInfo(_logger, $"调用WMS接口成功,接口:【{configKey}】,响应数据:【{result.Data?.Data}】,耗时:{(DateTime.Now - startTime).TotalMilliseconds}ms", "InboundTaskFlowService");
|
return WebResponseContent.Instance.OK();
|
}
|
}
|
}
|
