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)
 	}
 }