|
|
@ -38,7 +38,6 @@ func (d *DataBases) BatchInsertChat(userID string, msgList []*pbMsg.MsgDataToMQ,
|
|
|
|
msgListToMongoNext := make([]MsgInfo, 0)
|
|
|
|
msgListToMongoNext := make([]MsgInfo, 0)
|
|
|
|
seqUid := ""
|
|
|
|
seqUid := ""
|
|
|
|
seqUidNext := ""
|
|
|
|
seqUidNext := ""
|
|
|
|
//1,
|
|
|
|
|
|
|
|
log.Debug(operationID, "remain ", remain, "insertCounter ", insertCounter, "currentMaxSeq ", currentMaxSeq, userID, len(msgList))
|
|
|
|
log.Debug(operationID, "remain ", remain, "insertCounter ", insertCounter, "currentMaxSeq ", currentMaxSeq, userID, len(msgList))
|
|
|
|
for _, m := range msgList {
|
|
|
|
for _, m := range msgList {
|
|
|
|
log.Debug(operationID, "msg node ", m.String(), m.MsgData.ClientMsgID)
|
|
|
|
log.Debug(operationID, "msg node ", m.String(), m.MsgData.ClientMsgID)
|
|
|
|