From 1c578fb5979a50cb4599180123b5f890ae1e500e Mon Sep 17 00:00:00 2001
From: junleea <354425203@qq.com>
Date: Sat, 22 Mar 2025 17:26:21 +0800
Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E7=94=A8=E6=88=B7=E5=8F=91?=
 =?UTF-8?q?=E9=80=81=E6=B6=88=E6=81=AF=E4=BF=9D=E5=AD=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 handler/im.go | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/handler/im.go b/handler/im.go
index 644b947..3b4211d 100644
--- a/handler/im.go
+++ b/handler/im.go
@@ -115,7 +115,6 @@ func subscribeAndHandleIMMessages(ws *websocket.Conn, userId int) {
 				} else {
 					sessionName = data.Msg
 				}
-
 				err, sessionID = service.CreateSession(userId, sessionName)
 				log.Println("create session id:", sessionID)
 				if err != nil {
@@ -123,6 +122,11 @@ func subscribeAndHandleIMMessages(ws *websocket.Conn, userId int) {
 					return
 				}
 			}
+			//将消息存入数据库
+			err, _ = service.CreateMessage(1, int(sessionID), userId, 2, data.Msg, 1)
+			if err != nil {
+				return
+			} //机器人id为2,消息类型为1,状态为1
 			//需要后续处理
 			err, _ = service.WSReceiveMessageService(userId, int(sessionID), chanel, data)
 			if err != nil {