From 097a19a80c2c4e5bfa41b0d48b818c20f030aea5 Mon Sep 17 00:00:00 2001
From: lxw <810412026@qq.com>
Date: 星期二, 07 三月 2023 17:39:43 +0800
Subject: [PATCH] 监控层，运维层首页+跳转页
---
src/main/java/com/whyc/webSocket/DevOpSkipSocket.java | 24 ++++++++++++++++++------
1 files changed, 18 insertions(+), 6 deletions(-)
diff --git a/src/main/java/com/whyc/webSocket/DevOpSkipSocket.java b/src/main/java/com/whyc/webSocket/DevOpSkipSocket.java
index 1d6fbfa..c512778 100644
--- a/src/main/java/com/whyc/webSocket/DevOpSkipSocket.java
+++ b/src/main/java/com/whyc/webSocket/DevOpSkipSocket.java
@@ -1,6 +1,7 @@
package com.whyc.webSocket;
import com.whyc.config.WebSocketConfig;
+import com.whyc.dto.Response;
import com.whyc.service.StationInfService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
@@ -28,6 +29,7 @@
private static StationInfService service;
+
private Session session;
@Autowired
@@ -38,11 +40,16 @@
@OnOpen
public void onOpen(Session session, EndpointConfig config) {
this.session = session;
+
+ }
+
+ @OnMessage
+ public void onMessage(Session session, String message) {
/*HttpSession httpSession = (HttpSession) config.getUserProperties().get("httpSession");
UserInf user = (UserInf) httpSession.getAttribute("user");
final int userId = user.getUId().intValue();*/
final int userId = 1001;
- thread = new Thread("Thread_stationRt") {
+ thread = new Thread("Thread_devOpSkip") {
@Override
public void run() {
while (runFlag && !isInterrupted()) {
@@ -52,7 +59,16 @@
if (session.isOpen()) {
//鎺ㄩ�佷俊鎭�
synchronized (session) {
- session.getBasicRemote().sendObject(service.getSystemAll(userId));
+ Map<String, Object> map = new HashMap<>();
+ //杩愮淮灞傞椤碉細澶撮儴缁熻
+ Response skipHeadRes = service.getDevOpSkipHead(userId);
+ map.put("skipHeadRes", skipHeadRes);
+ if (!message.equals("0")) {
+ //鎸囧畾绔欑偣璇︽儏绗竴娆¤烦杞満鎴縤d涓�0锛歮essage
+ Response stationRes = service.getDevOpSkipStation(userId, message);
+ map.put("stationRes", stationRes);
+ }
+ session.getBasicRemote().sendObject(new Response<>().setII(1, true, map, "绠＄悊鍛橀椤佃烦杞�"));
}
threadFlagMap.put(thread.getId(), false);
}
@@ -75,10 +91,6 @@
}
//灏嗙嚎绋嬪瓨鍌�,渚夸簬璋冪敤瀹氫綅
threadMap.put(session.getId(), this.thread);
- }
-
- @OnMessage
- public void onMessage(Session session, String message) {
}
@OnClose
--
Gitblit v1.9.1