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 | 39 ++++++++++++++++++++++++--------------- 1 files changed, 24 insertions(+), 15 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 739828f..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" @@ -17,13 +17,13 @@ { private readonly IHttpContextAccessor _httpContextAccessor; private readonly IRouterExtension _routerExtension; - private readonly WebSocketServer _webSocketServer; + //private readonly WebSocketServer _webSocketServer; - public TaskController(ITaskService service, IHttpContextAccessor httpContextAccessor, IRouterExtension routerExtension, WebSocketServer webSocketServer) : base(service) + public TaskController(ITaskService service, IHttpContextAccessor httpContextAccessor, IRouterExtension routerExtension/*, WebSocketServer webSocketServer*/) : base(service) { _httpContextAccessor = httpContextAccessor; _routerExtension = routerExtension; - _webSocketServer = webSocketServer; + //_webSocketServer = webSocketServer; } [HttpPost, Route("ReceiveTask"), AllowAnonymous] @@ -78,19 +78,28 @@ { return WebResponseContent.Instance.OK(data: _routerExtension.GetEndPoint(startPoint, routeType)); } - - [HttpPost, HttpGet, Route("WebSocketPushMessage"), AllowAnonymous] - public WebResponseContent WebSocketPushMessage(string message) + [HttpPost, HttpGet, Route("AgvCarrying"), AllowAnonymous] + public WebResponseContent AgvCarrying(int row, int startColumn, int endColumn, int layer, int targetLayer) { - try - { - _webSocketServer.PublishAllClientPayload(message); - return WebResponseContent.Instance.OK(); - } - catch(Exception ex) - { - return WebResponseContent.Instance.Error(ex.Message); - } + 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