From 08d134ac414dec63a5e8b480c38d0dfad5b74edf Mon Sep 17 00:00:00 2001
From: junleea <354425203@qq.com>
Date: Sat, 22 Mar 2025 17:56:39 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=E9=87=8D=E5=A4=8D=E5=85=B3?=
 =?UTF-8?q?=E9=97=AD=E9=97=AE=E9=A2=98=EF=BC=8C=E4=BF=AE=E6=94=B9=E4=BC=9A?=
 =?UTF-8?q?=E8=AF=9D=E5=90=8D=E7=A7=B0?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 handler/im.go | 17 +++++++++--------
 1 file changed, 9 insertions(+), 8 deletions(-)

diff --git a/handler/im.go b/handler/im.go
index 8f7fa56..925a9fb 100644
--- a/handler/im.go
+++ b/handler/im.go
@@ -126,13 +126,13 @@ func subscribeAndHandleIMMessages(ws *websocket.Conn, userId int) {
 			if sessionID == 0 {
 				//创建会话
 				//会话名字为前10个字符，如果
-				var sessionName string
-				if len(data.Msg) > 10 {
-					sessionName = data.Msg[:10]
-				} else {
-					sessionName = data.Msg
-				}
-				err, sessionID = service.CreateSession(userId, sessionName)
+				//var sessionName string
+				//if len(data.Msg) > 10 {
+				//	sessionName = data.Msg[:10]
+				//} else {
+				//	sessionName = data.Msg
+				//}
+				err, sessionID = service.CreateSession(userId, data.Msg)
 				log.Println("create session id:", sessionID)
 				if err != nil {
 					log.Println("Create session error:", err)
@@ -154,7 +154,7 @@ func subscribeAndHandleIMMessages(ws *websocket.Conn, userId int) {
 	}()
 
 	go func() {
-		defer close(done)
+		//defer close(done)
 		//从redis订阅消息
 		for m := range ch {
 			msg := m.Payload // 获取消息,消息格式为json
@@ -169,6 +169,7 @@ func subscribeAndHandleIMMessages(ws *websocket.Conn, userId int) {
 				}
 			}
 		}
+		//查看done是否关闭
 	}()
 
 	//发送心跳包