batch to mongo

3 years ago · 17695927d5
parent ea8638c843
commit 17695927d5
1 changed files with 2 additions and 1 deletions
--- a/pkg/common/db/batch_insert_chat.go
+++ b/pkg/common/db/batch_insert_chat.go
@ -27,7 +27,8 @@ func (d *DataBases) BatchInsertChat(userID string, msgList []*pbMsg.MsgDataToMQ,
 		return utils.Wrap(err, "")
 	}

-	remain := currentMaxSeq % uint64(GetSingleGocMsgNum())
+	//4999
+	remain := uint64(GetSingleGocMsgNum()) - (currentMaxSeq % uint64(GetSingleGocMsgNum()))
 	insertCounter := uint64(0)
 	msgListToMongo := make([]MsgInfo, 0)
 	msgListToMongoNext := make([]MsgInfo, 0)