fix del

2 years ago · 331d90f198
parent 34370e4cad
commit 331d90f198
1 changed files with 1 additions and 1 deletions
--- a/pkg/common/db/controller/msg.go
+++ b/pkg/common/db/controller/msg.go
@ -681,7 +681,7 @@ func (db *commonMsgDatabase) DeleteUserMsgsBySeqs(ctx context.Context, userID st
 	for _, msg := range msgs {
 		cacheSeqs = append(cacheSeqs, msg.Seq)
 	}
-	if err := db.cache.UserDeleteMsgs(ctx, conversationID, cacheSeqs, userID); err != nil {
+	if err := db.cache.UserDeleteMsgs(ctx, conversationID, cacheSeqs, userID); err != nil && errs.Unwrap(err) != redis.Nil {
 		return err
 	}