From d91a7c00581d7df884b4171e738a042585bbcee0 Mon Sep 17 00:00:00 2001
From: laodaming <11058467+laudamine@user.noreply.gitee.com>
Date: Thu, 10 Aug 2023 15:18:33 +0800
Subject: [PATCH] fix

---
 server/websocket/internal/logic/datatransferlogic.go | 12 +++++++-----
 1 file changed, 7 insertions(+), 5 deletions(-)

diff --git a/server/websocket/internal/logic/datatransferlogic.go b/server/websocket/internal/logic/datatransferlogic.go
index b386c83c..9884c18d 100644
--- a/server/websocket/internal/logic/datatransferlogic.go
+++ b/server/websocket/internal/logic/datatransferlogic.go
@@ -94,7 +94,7 @@ func (l *DataTransferLogic) DataTransfer(svcCtx *svc.ServiceContext, w http.Resp
 	)
 	isAuth, userInfo = l.checkAuth(svcCtx, r)
 	if !isAuth {
-		time.Sleep(time.Second) //兼容下火狐
+		time.Sleep(time.Second * 4) //兼容下火狐
 		rsp := websocket_data.DataTransferData{
 			T: constants.WEBSOCKET_UNAUTH,
 			D: nil,
@@ -130,10 +130,12 @@ func (l *DataTransferLogic) DataTransfer(svcCtx *svc.ServiceContext, w http.Resp
 	//保存连接
 	mapConnPool.Store(uniqueId, ws)
 	defer ws.close()
-	//把连接成功消息发回去
-	time.Sleep(time.Second) //兼容下火狐
-	b := ws.respondDataFormat(constants.WEBSOCKET_CONNECT_SUCCESS, uniqueId)
-	_ = conn.WriteMessage(websocket.TextMessage, b)
+	go func() {
+		//把连接成功消息发回去
+		time.Sleep(time.Second * 4) //兼容下火狐
+		b := ws.respondDataFormat(constants.WEBSOCKET_CONNECT_SUCCESS, uniqueId)
+		_ = conn.WriteMessage(websocket.TextMessage, b)
+	}()
 	//循环读客户端信息
 	go ws.readLoop()
 	//循环把数据发送给客户端