callback kickoff

2 years ago · f3e71fec91
parent c2bd1d0d83
commit f3e71fec91
1 changed files with 2 additions and 2 deletions
--- a/pkg/common/db/RedisModel.go
+++ b/pkg/common/db/RedisModel.go
@ -253,8 +253,8 @@ func (d *DataBases) CleanUpOneUserAllMsgFromRedis(userID string, operationID str
 	if err != nil {
 		return utils.Wrap(err, "")
 	}
-	if err = d.RDB.Del(ctx, vals...).Err(); err != nil {
-		return utils.Wrap(err, "")
+	for _, v := range vals {
+		err = d.RDB.Del(ctx, v).Err()
 	}
 	return nil
 }