using WIDESEA_DTO;
namespace WIDESEA_WMSServer.Controllers.Task;
///
/// 任务操作接口
///
[Route("api/[controller]")]
[ApiController]
public class TaskController : ApiBaseController
{
private readonly IHttpContextAccessor _httpContextAccessor;
private readonly IDt_TaskService _taskService;
private readonly ILocationInfoService _locationService;
public TaskController(IDt_TaskService taskService,
IHttpContextAccessor httpContextAccessor,
ILocationInfoService locationService) : base(taskService)
{
_httpContextAccessor = httpContextAccessor;
_taskService = taskService;
_locationService = locationService;
}
///
/// 任务完成
///
/// 任务号
/// 成功或失败
[HttpGet, Route("CompleteTaskAsync"), AllowAnonymous]
//[TypeFilter(typeof(ThrottleFilter), Arguments = new object[] { 5 })] // 5秒节流
public async Task CompleteTaskAsync(int taskNum)
{
return await _taskService.CompleteAsync(taskNum);
}
///
/// 请求任务巷道
///
/// 请求数据
///
[HttpPost, AllowAnonymous, Route("RequestTaskAsync")]
[TypeFilter(typeof(ThrottleFilter), Arguments = new object[] { 5 })] // 5秒节流
public async Task RequestTaskAsync([FromBody] RequestTaskDto input)
{
return await Service.RequestTaskAsync(input);
}
///
/// 请求任务货位
///
/// 请求数据
///
[HttpPost, AllowAnonymous, Route("RequestLocationTaskAsync")]
[TypeFilter(typeof(ThrottleFilter), Arguments = new object[] { 5 })] // 5秒节流
public async Task UpdateExistingTask([FromBody] RequestTaskDto input)
{
return await Service.UpdateExistingTask(input);
}
///
/// 空托盘入库请求
///
/// 请求数据
///
[HttpPost, AllowAnonymous, Route("RequestTrayInTaskAsync")]
[TypeFilter(typeof(ThrottleFilter), Arguments = new object[] { 5 })] // 5秒节流
public async Task RequestTrayInTaskAsync([FromBody] RequestTaskDto input)
{
return await Service.RequestTrayInTaskAsync(input);
}
///
/// 空托盘满盘出库请求
///
/// 请求数据
///
[HttpPost, AllowAnonymous, Route("RequestTrayOutTaskAsync")]
[TypeFilter(typeof(ThrottleFilter), Arguments = new object[] { 5 })] // 5秒节流
public async Task RequestTrayOutTaskAsync([FromBody] RequestOutTaskDto request)
{
return await Service.RequestTrayOutTaskAsync(request.Position, request.Tag, request.AreaCdoe, request.AreaCdoes, request.ProductionLine);
}
///
/// 任务状态修改
///
/// 请求数据
///
[HttpPost, AllowAnonymous, Route("UpdateTaskStatus")]
[TypeFilter(typeof(ThrottleFilter), Arguments = new object[] { 5 })] // 5秒节流
public async Task UpdateTaskStatus([FromBody] UpdateStatusDto input)
{
return await Service.UpdateTaskStatus(input.TaskNum, input.TaskState);
}
}