|
|
@ -188,10 +188,11 @@ func checkMaxSeqWithMongo(operationID, ID string, diffusionType int) error {
|
|
|
|
}
|
|
|
|
}
|
|
|
|
if err != nil {
|
|
|
|
if err != nil {
|
|
|
|
if err == goRedis.Nil {
|
|
|
|
if err == goRedis.Nil {
|
|
|
|
return nil
|
|
|
|
|
|
|
|
}
|
|
|
|
} else {
|
|
|
|
return utils.Wrap(err, "GetUserMaxSeq failed")
|
|
|
|
return utils.Wrap(err, "GetUserMaxSeq failed")
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
}
|
|
|
|
msg, err := db.DB.GetNewestMsg(ID)
|
|
|
|
msg, err := db.DB.GetNewestMsg(ID)
|
|
|
|
if err != nil {
|
|
|
|
if err != nil {
|
|
|
|
return utils.Wrap(err, "GetNewestMsg failed")
|
|
|
|
return utils.Wrap(err, "GetNewestMsg failed")
|
|
|
|