|
|
@ -135,7 +135,6 @@ func (d *DataBases) BatchInsertChat2Cache(insertID string, msgList []*pbMsg.MsgD
|
|
|
|
return utils.Wrap(err, ""), 0
|
|
|
|
return utils.Wrap(err, ""), 0
|
|
|
|
}
|
|
|
|
}
|
|
|
|
promePkg.PromeInc(promePkg.SeqGetSuccessCounter)
|
|
|
|
promePkg.PromeInc(promePkg.SeqGetSuccessCounter)
|
|
|
|
promePkg.SeqGetSuccessCounter.Inc()
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
lastMaxSeq := currentMaxSeq
|
|
|
|
lastMaxSeq := currentMaxSeq
|
|
|
|
for _, m := range msgList {
|
|
|
|
for _, m := range msgList {
|
|
|
|