From 8462c457143856e8a98049f04c44bb28100e0999 Mon Sep 17 00:00:00 2001
From: junleea <354425203@qq.com>
Date: Wed, 26 Mar 2025 20:22:35 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8Dspark=E6=A8=A1=E5=9E=8B?=
 =?UTF-8?q?=E8=BF=94=E5=9B=9E=E6=B6=88=E6=81=AF=E5=AD=98=E5=82=A8=E7=B1=BB?=
 =?UTF-8?q?=E5=9E=8B=E9=94=99=E8=AF=AF?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 service/spark.go | 8 +++++---
 1 file changed, 5 insertions(+), 3 deletions(-)

diff --git a/service/spark.go b/service/spark.go
index caeff96..33b606e 100644
--- a/service/spark.go
+++ b/service/spark.go
@@ -170,9 +170,11 @@ func Spark(modelParam proto.ModelParam, question, channel string, SessionID, Use
 
 	conn.Close()
 	//将消息存入数据库
-	err, _ = dao.CreateMessage(SessionID, modelID, UserID, proto.UserAndModelMsgType, proto.MsgHasRead, answer)
-	if err != nil {
-		log.Println("spark create message error:", err)
+	err2, msgID := dao.CreateMessage(SessionID, modelID, UserID, proto.ModelToUserMsgType, proto.MsgHasRead, answer)
+	if err2 != nil {
+		log.Println("spark create message error:", err2)
+	} else {
+		log.Println("spark create message success,message id:", msgID)
 	}
 }