From 98db59ccb704eb44f535bbafe5694a83919e795b Mon Sep 17 00:00:00 2001
From: luxiaotao1123 <t1341870251@163.com>
Date: 星期三, 03 四月 2024 14:28:55 +0800
Subject: [PATCH] #
---
zy-asrs-flow/src/pages/map/websocket.js | 7 +++----
zy-asrs-flow/src/pages/map/index.jsx | 1 +
zy-asrs-flow/src/pages/map/utils.js | 4 ++++
zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/core/map/websocket/MockScheduler.java | 17 +++++++++++++++++
4 files changed, 25 insertions(+), 4 deletions(-)
diff --git a/zy-asrs-flow/src/pages/map/index.jsx b/zy-asrs-flow/src/pages/map/index.jsx
index 2fec0aa..a1c3cb2 100644
--- a/zy-asrs-flow/src/pages/map/index.jsx
+++ b/zy-asrs-flow/src/pages/map/index.jsx
@@ -105,6 +105,7 @@
websocket = new WebSocketClient('/ws/map/websocket');
websocket.connect();
+ websocket.onMessage = Utils.updateMapStatusInRealTime;
const handleResize = () => {
setWindowSize({
diff --git a/zy-asrs-flow/src/pages/map/utils.js b/zy-asrs-flow/src/pages/map/utils.js
index 8701f9b..19978e9 100644
--- a/zy-asrs-flow/src/pages/map/utils.js
+++ b/zy-asrs-flow/src/pages/map/utils.js
@@ -582,4 +582,8 @@
export const generateLocNo = (row, bay, lev) => {
return row + '-' + bay + '-' + lev;
+}
+
+export const updateMapStatusInRealTime = (data) => {
+ console.log('map: ' + data);
}
\ No newline at end of file
diff --git a/zy-asrs-flow/src/pages/map/websocket.js b/zy-asrs-flow/src/pages/map/websocket.js
index 1b4b9a5..39b9eba 100644
--- a/zy-asrs-flow/src/pages/map/websocket.js
+++ b/zy-asrs-flow/src/pages/map/websocket.js
@@ -6,7 +6,7 @@
this.url = WEBSOCKET_BASE_URL + path;
this.webSocket = null;
this.heartbeatInterval = null; // Store the interval ID
- this.heartbeatFrequency = 30000; // Heartbeat every 10 seconds
+ this.heartbeatFrequency = 30000; // Heartbeat every 30 seconds
}
connect() {
@@ -24,7 +24,7 @@
};
this.webSocket.onmessage = (event) => {
- console.log('websocket message received:', event.data);
+ // console.log('websocket message received:', event.data);
this.onMessage(event.data);
};
@@ -48,9 +48,8 @@
}
}
+ // Override
onMessage(data) {
- // 瀛愮被鍙兘浼氶噸鍐欒繖涓柟娉曟潵澶勭悊娑堟伅
- console.log('WebSocketClient: Message received:', data);
}
close() {
diff --git a/zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/core/map/websocket/MockScheduler.java b/zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/core/map/websocket/MockScheduler.java
new file mode 100644
index 0000000..72123df
--- /dev/null
+++ b/zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/core/map/websocket/MockScheduler.java
@@ -0,0 +1,17 @@
+package com.zy.asrs.wcs.core.map.websocket;
+
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+
+/**
+ * Created by vincent on 4/3/2024
+ */
+@Component
+public class MockScheduler {
+
+ @Scheduled(cron = "0/1 * * * * ? ")
+ public void mock() {
+ MapWebSocket.broadcast("test data");
+ }
+
+}
--
Gitblit v1.9.1