revoke msg Pb

This commit is contained in:
wangchuxiao
2023-05-22 15:15:01 +08:00
parent fc49325bb8
commit 6a6283f2e4
5 changed files with 336 additions and 171 deletions
+1 -1
View File
@@ -283,7 +283,7 @@ func (db *commonMsgDatabase) DelMsgBySeqsInOneDoc(ctx context.Context, docID str
}
for i, v := range seqMsgs {
if err = db.msgDocDatabase.UpdateMsgStatusByIndexInOneDoc(ctx, docID, v, indexes[i], constant.MsgDeleted); err != nil {
return nil, err
log.ZError(ctx, "UpdateMsgStatusByIndexInOneDoc", err, "docID", docID, "msg", v, "index", indexes[i])
}
}
return unExistSeqs, nil