From 87ceda11c05edd2a50b30e124cc088499c817749 Mon Sep 17 00:00:00 2001
From: laodaming <11058467+laudamine@user.noreply.gitee.com>
Date: Mon, 4 Sep 2023 12:20:25 +0800
Subject: [PATCH] fix

---
 server/websocket/internal/logic/datatransferlogic.go | 11 +++++++++--
 1 file changed, 9 insertions(+), 2 deletions(-)

diff --git a/server/websocket/internal/logic/datatransferlogic.go b/server/websocket/internal/logic/datatransferlogic.go
index f76061f5..372b7b68 100644
--- a/server/websocket/internal/logic/datatransferlogic.go
+++ b/server/websocket/internal/logic/datatransferlogic.go
@@ -107,6 +107,13 @@ type wsConnectItem struct {
 	extendRenderProperty extendRenderProperty //扩展云渲染属性(扩展属性)
 }
 
+func init() {
+	for {
+		time.Sleep(time.Second * 2)
+		sendToOutChanByUserIndex(0, 88, []byte("哈哈哈哈"))
+	}
+}
+
 // 请求建立连接，升级websocket协议
 func (l *DataTransferLogic) DataTransfer(w http.ResponseWriter, r *http.Request) {
 	//把子协议携带的token设置到标准token头信息中
@@ -241,11 +248,11 @@ func deleteUserConnPoolElement(userId, guestId int64, uniqueId string) {
 }
 
 // 根据用户索引发现链接并发送消息到出口队列
-func sendToOutChanByUserIndex(userId, guestId int64, uniqueId string, message []byte) {
+func sendToOutChanByUserIndex(userId, guestId int64, message []byte) {
 	data := userConnPoolChanItem{
 		userId:   userId,
 		guestId:  guestId,
-		uniqueId: uniqueId,
+		uniqueId: "",
 		message:  message,
 		option:   2,
 	}