using Quartz;
|
using SqlSugar;
|
using WIDESEA_Common.TaskEnum;
|
using WIDESEA_DTO.Basic;
|
using WIDESEA_IBasicService;
|
using WIDESEA_Model.Models;
|
|
namespace WIDESEA_WMSServer
|
{
|
[DisallowConcurrentExecution]
|
public class AgvTaskJob : IJob
|
{
|
private readonly ILogger<AgvTaskJob> _logger;
|
private readonly ISqlSugarClient _db;
|
private readonly IESSApiService _eSSApiService;
|
// 通过构造函数直接注入依赖
|
public AgvTaskJob(ILogger<AgvTaskJob> logger, ISqlSugarClient db, IESSApiService eSSApiService)
|
{
|
_logger = logger;
|
_db = db;
|
_eSSApiService = eSSApiService;
|
}
|
|
public async Task Execute(IJobExecutionContext context)
|
{
|
try
|
{
|
var tasks = await _db.Queryable<Dt_Task>()
|
.Where(x => x.TaskStatus == (int)TaskStatusEnum.New)
|
.ToListAsync();
|
foreach (var item in tasks)
|
{
|
TaskModel esstask = new TaskModel()
|
{
|
taskType = item.TaskType.GetTaskTypeGroup()==TaskTypeGroup.InboundGroup? "putaway": "carry",
|
taskGroupCode = "",
|
groupPriority = 0,
|
tasks = new List<TasksType>
|
{
|
new()
|
{
|
taskCode=item.TaskNum.ToString(),
|
taskPriority=0,
|
taskDescribe = new TaskDescribeType
|
{
|
containerCode = item.PalletCode,
|
containerType = "CT_KUBOT_STANDARD",
|
fromLocationCode = item.SourceAddress,
|
toStationCode = "",
|
toLocationCode = item.TargetAddress,
|
deadline = 0,
|
}
|
}
|
}
|
};
|
|
var result = await _eSSApiService.CreateTaskAsync(esstask);
|
if (result)
|
{
|
item.TaskStatus = (int)TaskStatusEnum.HasSent;
|
await _db.Updateable(item).ExecuteCommandAsync();
|
}
|
}
|
}
|
catch (Exception ex)
|
{
|
_logger.LogError(ex, "定时任务执行失败");
|
}
|
}
|
|
}
|
}
|
