blackteay/open-im-server
1
0
Fork 0
mirror of https://github.com/openimsdk/open-im-server.git synced 2025-04-06 04:15:46 +08:00
Code Issues Packages Projects Releases Wiki Activity

msg cache

Browse Source
This commit is contained in:
wenxu12345 2022-05-24 21:34:02 +08:00 committed by Xinwei Xiong(cubxxw-openim)
parent daa716a083
commit 7e38335f0c
2 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
internal/msg_transfer/logic/db.go
View File

@ -22,8 +22,8 @@ func saveUserChat(uid string, msg *pbMsg.MsgDataToMQ) error {
// return db.DB.SaveUserChatMongo2(uid, pbSaveData.MsgData.SendTime, &pbSaveData) // return db.DB.SaveUserChatMongo2(uid, pbSaveData.MsgData.SendTime, &pbSaveData)
} }
func saveUserChatList(userID string, msgList []*pbMsg.MsgDataToMQ, operationID string) error { func saveUserChatList(userID string, msgList []*pbMsg.MsgDataToMQ, operationID string) (error, uint64) {
log.Info(operationID, utils.GetSelfFuncName(), "args ", userID, len(msgList)) 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) return db.DB.BatchInsertChat2Cache(userID, msgList, operationID)
} }

4
pkg/common/db/mongoModel.go
View File

@ -799,6 +799,10 @@ func getSeqUid(uid string, seq uint32) string {
return indexGen(uid, seqSuffix) return indexGen(uid, seqSuffix)
} }
func GetSeqUid(uid string, seq uint32) string {
return getSeqUid(uid, seq)
}
func getMsgIndex(seq uint32) int { func getMsgIndex(seq uint32) int {
seqSuffix := seq / singleGocMsgNum seqSuffix := seq / singleGocMsgNum
var index uint32 var index uint32