From 959139e7a5d89e8498d731082a949310ae1c6fcf Mon Sep 17 00:00:00 2001
From: Junjie <DELL@qq.com>
Date: 星期五, 05 十二月 2025 14:32:29 +0800
Subject: [PATCH] #
---
src/main/java/com/zy/asrs/ws/ConsoleWebSocket.java | 43 +------------------------------------------
1 files changed, 1 insertions(+), 42 deletions(-)
diff --git a/src/main/java/com/zy/asrs/ws/ConsoleWebSocket.java b/src/main/java/com/zy/asrs/ws/ConsoleWebSocket.java
index d1e6de7..be15871 100644
--- a/src/main/java/com/zy/asrs/ws/ConsoleWebSocket.java
+++ b/src/main/java/com/zy/asrs/ws/ConsoleWebSocket.java
@@ -1,13 +1,6 @@
package com.zy.asrs.ws;
-import com.alibaba.fastjson.JSON;
-import com.core.common.R;
-import com.core.common.SpringUtils;
-import com.zy.asrs.controller.ConsoleController;
-import com.zy.asrs.controller.ForkLiftController;
-import com.zy.asrs.controller.LiftController;
-import com.zy.asrs.controller.ShuttleController;
-import com.zy.common.model.WebSocketMessage;
+
import lombok.Data;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;
@@ -71,40 +64,6 @@
*/
@OnMessage
public void onMessage(String message, Session session) throws IOException {
- ShuttleController shuttleController = SpringUtils.getBean(ShuttleController.class);
- ForkLiftController forkLiftController = SpringUtils.getBean(ForkLiftController.class);
- LiftController liftController = SpringUtils.getBean(LiftController.class);
- ConsoleController consoleController = SpringUtils.getBean(ConsoleController.class);
- WebSocketMessage socketMessage = JSON.parseObject(message, WebSocketMessage.class);
- if (socketMessage.getUrl().equals("/shuttle/table/shuttle/state")) {
- R result = shuttleController.shuttleStateTable();
- socketMessage.setData(JSON.toJSONString(result));
- this.sendMessage(JSON.toJSONString(socketMessage));
- } else if (socketMessage.getUrl().equals("/forkLift/table/lift/state")) {
- R result = forkLiftController.liftStateTable();
- socketMessage.setData(JSON.toJSONString(result));
- this.sendMessage(JSON.toJSONString(socketMessage));
- } else if (socketMessage.getUrl().equals("/lift/table/lift/state")) {
- R result = liftController.liftStateTable();
- socketMessage.setData(JSON.toJSONString(result));
- this.sendMessage(JSON.toJSONString(socketMessage));
- } else if (socketMessage.getUrl().equals("/console/map/auth")) {
- R result = consoleController.getMapFromRedis(Integer.parseInt(socketMessage.getData()));
- socketMessage.setData(JSON.toJSONString(result));
- this.sendMessage(JSON.toJSONString(socketMessage));
- } else if (socketMessage.getUrl().equals("/console/locMap/auth")) {
- R result = consoleController.getLocMap(Integer.parseInt(socketMessage.getData()));
- socketMessage.setData(JSON.toJSONString(result));
- this.sendMessage(JSON.toJSONString(socketMessage));
- } else if (socketMessage.getUrl().equals("/console/getMoveAdvancePath/auth")) {
- R result = consoleController.getMoveAdvancePath(Integer.parseInt(socketMessage.getData()));
- socketMessage.setData(JSON.toJSONString(result));
- this.sendMessage(JSON.toJSONString(socketMessage));
- } else if (socketMessage.getUrl().equals("/console/getLockPath/auth")) {
- R result = consoleController.getLockPath(Integer.parseInt(socketMessage.getData()));
- socketMessage.setData(JSON.toJSONString(result));
- this.sendMessage(JSON.toJSONString(socketMessage));
- }
// log.info("鏀跺埌鏉ヨ嚜杩炴帴锛�" + sessionId + "鐨勪俊鎭�:" + message);
}
--
Gitblit v1.9.1