From 225d11e2ddaa55d1d482201cb4d89c9486cdba69 Mon Sep 17 00:00:00 2001 From: wangxinhui <wangxinhui@hnkhzn.com> Date: 星期五, 20 六月 2025 12:27:52 +0800 Subject: [PATCH] 更新代码 --- 代码管理/WCS/WIDESEAWCS_Server/WIDESEAWCS_Server/Controllers/Task/TaskController.cs | 51 +++++++++++++++++++++++++++++++++++++++++++++++++-- 1 files changed, 49 insertions(+), 2 deletions(-) diff --git "a/\344\273\243\347\240\201\347\256\241\347\220\206/WCS/WIDESEAWCS_Server/WIDESEAWCS_Server/Controllers/Task/TaskController.cs" "b/\344\273\243\347\240\201\347\256\241\347\220\206/WCS/WIDESEAWCS_Server/WIDESEAWCS_Server/Controllers/Task/TaskController.cs" index aab8236..7e56cfb 100644 --- "a/\344\273\243\347\240\201\347\256\241\347\220\206/WCS/WIDESEAWCS_Server/WIDESEAWCS_Server/Controllers/Task/TaskController.cs" +++ "b/\344\273\243\347\240\201\347\256\241\347\220\206/WCS/WIDESEAWCS_Server/WIDESEAWCS_Server/Controllers/Task/TaskController.cs" @@ -1,4 +1,5 @@ -锘縰sing Microsoft.AspNetCore.Authorization; +锘縰sing HslCommunication.WebSocket; +using Microsoft.AspNetCore.Authorization; using Microsoft.AspNetCore.Http; using Microsoft.AspNetCore.Mvc; using WIDESEAWCS_Core; @@ -6,6 +7,7 @@ using WIDESEAWCS_DTO.TaskInfo; using WIDESEAWCS_ITaskInfoService; using WIDESEAWCS_Model.Models; +using WIDESEAWCS_Tasks; namespace WIDESEAWCS_WCSServer.Controllers.Task { @@ -14,9 +16,14 @@ public class TaskController : ApiBaseController<ITaskService, Dt_Task> { private readonly IHttpContextAccessor _httpContextAccessor; - public TaskController(ITaskService service, IHttpContextAccessor httpContextAccessor) : base(service) + private readonly IRouterExtension _routerExtension; + //private readonly WebSocketServer _webSocketServer; + + public TaskController(ITaskService service, IHttpContextAccessor httpContextAccessor, IRouterExtension routerExtension/*, WebSocketServer webSocketServer*/) : base(service) { _httpContextAccessor = httpContextAccessor; + _routerExtension = routerExtension; + //_webSocketServer = webSocketServer; } [HttpPost, Route("ReceiveTask"), AllowAnonymous] @@ -54,5 +61,45 @@ { return Service.RollbackTaskStatusToLast(taskNum); } + + /// <summary> + /// 鍥炲AGV瀹夊叏淇″彿 + /// </summary> + /// <param name="taskNum"></param> + /// <returns></returns> + [HttpPost, HttpGet, Route("SendSecureReplyToAgv")] + public WebResponseContent SendSecureReplyToAgv(int taskNum) + { + return Service.SendSecureReplyToAgv(taskNum); + } + + [HttpPost, HttpGet, Route("GetRouteEndPoint"), AllowAnonymous] + public WebResponseContent GetRouteEndPoint(string startPoint, int routeType) + { + return WebResponseContent.Instance.OK(data: _routerExtension.GetEndPoint(startPoint, routeType)); + } + [HttpPost, HttpGet, Route("AgvCarrying"), AllowAnonymous] + public WebResponseContent AgvCarrying(int row, int startColumn, int endColumn, int layer, int targetLayer) + { + return Service.AgvCarrying(row, startColumn, endColumn, layer, targetLayer); + } + //[HttpPost, HttpGet, Route("WebSocketPushMessage"), AllowAnonymous] + //public WebResponseContent WebSocketPushMessage(string message) + //{ + // try + // { + // _webSocketServer.PublishAllClientPayload(message); + // return WebResponseContent.Instance.OK(); + // } + // catch(Exception ex) + // { + // return WebResponseContent.Instance.Error(ex.Message); + // } + //} + [HttpPost, HttpGet, Route("RecWMSTaskCompleted"), AllowAnonymous] + public WebResponseContent RecWMSTaskCompleted(int taskNum) + { + return Service.RecWMSTaskCompleted(taskNum); + } } } -- Gitblit v1.9.3