From 2f71ce5847a2c07478d0d33a8bf4d8c42041662e Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E6=9D=8E=E5=85=89=E6=98=A5?= Date: Sat, 13 Aug 2022 22:31:40 +0800 Subject: [PATCH] - update redis lock --- const.go | 2 +- redis_lock.go | 8 ++++++-- 2 files changed, 7 insertions(+), 3 deletions(-) diff --git a/const.go b/const.go index d738db9..00f4c46 100644 --- a/const.go +++ b/const.go @@ -1,3 +1,3 @@ package dorm -const Version = "1.0.23" +const Version = "1.0.24" diff --git a/redis_lock.go b/redis_lock.go index 75158e9..db1ccd6 100644 --- a/redis_lock.go +++ b/redis_lock.go @@ -28,7 +28,9 @@ func (rl *RedisClientLock) Lock(ctx context.Context, key string, val string, ttl // 获取 get, err := rl.operation.Get(ctx, key).Result() if err != nil { - return resp, errors.New(fmt.Sprintf("获取异常：%s", err.Error())) + if err != RedisNotFound { + return resp, errors.New(fmt.Sprintf("获取异常：%s", err.Error())) + } } if get != "" { return resp, errors.New("上锁失败，已存在") @@ -58,7 +60,9 @@ func (rl *RedisClientLock) LockForever(ctx context.Context, key string, val stri // 获取 get, err := rl.operation.Get(ctx, key).Result() if err != nil { - return resp, errors.New(fmt.Sprintf("获取异常：%s", err.Error())) + if err != RedisNotFound { + return resp, errors.New(fmt.Sprintf("获取异常：%s", err.Error())) + } } if get != "" { return resp, errors.New("上锁失败，已存在")