From f373bbf83d9d2a7e5f96118d7dcd658c9fea8bc8 Mon Sep 17 00:00:00 2001
From: feiyu02 <risaku@163.com>
Date: 星期四, 14 八月 2025 17:27:44 +0800
Subject: [PATCH] 2025.8.14 1. 新增文件导入场景信息接口 2. 新增导出接口文档接口
---
src/main/kotlin/cn/flightfeather/supervision/socket/processor/WebSocketReceiver.kt | 15 ++++++++++++++-
1 files changed, 14 insertions(+), 1 deletions(-)
diff --git a/src/main/kotlin/cn/flightfeather/supervision/socket/processor/WebSocketReceiver.kt b/src/main/kotlin/cn/flightfeather/supervision/socket/processor/WebSocketReceiver.kt
index d8c42f9..6f6d837 100644
--- a/src/main/kotlin/cn/flightfeather/supervision/socket/processor/WebSocketReceiver.kt
+++ b/src/main/kotlin/cn/flightfeather/supervision/socket/processor/WebSocketReceiver.kt
@@ -2,7 +2,11 @@
import cn.flightfeather.supervision.common.log.BizLog
import cn.flightfeather.supervision.common.log.WorkStreamLogInfo
+import cn.flightfeather.supervision.common.utils.Constant
+import cn.flightfeather.supervision.socket.WebSocketMessage
+import cn.flightfeather.supervision.socket.WebSocketMessageParser
import org.springframework.stereotype.Component
+import java.time.LocalDateTime
/**
* webSocket娑堟伅鎺ユ敹绠＄悊
@@ -10,7 +14,7 @@
* @author feiyu02
*/
@Component
-class WebSocketReceiver(private val bizLog: BizLog) {
+class WebSocketReceiver(private val bizLog: BizLog, private val webSocketSender: WebSocketSender) {
/**
* 鎺ユ敹娑堟伅澶勭悊
@@ -21,4 +25,13 @@
bizLog.info(WorkStreamLogInfo("8FAqSPnAA8ry4ExX", "鏈辨寮�", "鍦ㄤ笂娴峰箍鍙戠矇鐓ょ伆鏈夐檺鍏徃鏂板涓�涓棶棰�"))
}
}
+
+ /**
+ * 鎺ユ敹蹇冭烦娑堟伅澶勭悊
+ */
+ fun onReceiveHeartMsg(msg: String, sessionId: String) {
+ val content = WebSocketMessageParser.encodeMessage(WebSocketMessage(Constant.SocketHeartMessageType.HEART_MESSAGE_TYPE.value,
+ LocalDateTime.now()))
+ webSocketSender.sendMsg(content, sessionId)
+ }
}
\ No newline at end of file
--
Gitblit v1.9.3