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); } }