msg cache

3 years ago · daa716a083
parent d8814ad09f
commit daa716a083
1 changed files with 2 additions and 1 deletions
--- a/internal/msg_transfer/logic/db.go
+++ b/internal/msg_transfer/logic/db.go
@ -24,5 +24,6 @@ func saveUserChat(uid string, msg *pbMsg.MsgDataToMQ) error {

 func saveUserChatList(userID string, msgList []*pbMsg.MsgDataToMQ, operationID string) error {
 	log.Info(operationID, utils.GetSelfFuncName(), "args ", userID, len(msgList))
-	return db.DB.BatchInsertChat(userID, msgList, operationID)
+	//return db.DB.BatchInsertChat(userID, msgList, operationID)
+	return db.DB.BatchInsertChatBoth(userID, msgList, operationID)
 }