diff --git a/const.go b/const.go index ce38805..4d5a429 100644 --- a/const.go +++ b/const.go @@ -1,3 +1,3 @@ package gojobs -const Version = "1.0.58" +const Version = "1.0.59" diff --git a/go.mod b/go.mod index f98a6f2..e81055a 100644 --- a/go.mod +++ b/go.mod @@ -6,7 +6,7 @@ require ( github.com/go-redis/redis/v9 v9.0.0-beta.2 github.com/jasonlvhit/gocron v0.0.1 github.com/robfig/cron/v3 v3.0.1 - go.dtapp.net/dorm v1.0.25 + go.dtapp.net/dorm v1.0.26 go.dtapp.net/goarray v1.0.1 go.dtapp.net/goip v1.0.25 go.dtapp.net/golog v1.0.27 diff --git a/go.sum b/go.sum index 765e91a..e7ae9d6 100644 --- a/go.sum +++ b/go.sum @@ -536,8 +536,8 @@ github.com/youmark/pkcs8 v0.0.0-20201027041543-1326539a0a0a/go.mod h1:ul22v+Nro/ github.com/yuin/goldmark v1.2.1/go.mod h1:3hX8gzYuyVAZsxl0MRgGTJEmQBFcNTphYh9decYSb74= github.com/zenazn/goji v0.9.0/go.mod h1:7S9M489iMyHBNxwZnk9/EHS098H4/F6TATF2mIxtB1Q= github.com/ziutek/mymysql v1.5.4/go.mod h1:LMSpPZ6DbqWFxNCHW77HeMg9I646SAhApZ/wKdgO/C0= -go.dtapp.net/dorm v1.0.25 h1:nYvBaB4pvwbc+kk83XZ0F/tdDltKH99WNKJpg8m6BPU= -go.dtapp.net/dorm v1.0.25/go.mod h1:bHG7BmgeLaAlc56myYF63lwZAIuMeWRAqHBb/L84dLM= +go.dtapp.net/dorm v1.0.26 h1:UkNuEVwlwB/chWr4LV1qKdt2tpcoDvPmR3KbGGeMWts= +go.dtapp.net/dorm v1.0.26/go.mod h1:bHG7BmgeLaAlc56myYF63lwZAIuMeWRAqHBb/L84dLM= go.dtapp.net/goarray v1.0.1 h1:cHNHaJ2MFcuJPA1WKU2PM1EUZShS1vQqEH7n6YXsQVU= go.dtapp.net/goarray v1.0.1/go.mod h1:/MPhlFCAhQyeNV1M0v1PAOOX33Sg705fVjUgMO12IBQ= go.dtapp.net/goip v1.0.25 h1:GSgQkR7dc28TX8E1mF3wAy+EEGZ++tgqc8Q85OKZPEY= diff --git a/jobs_gorm_redis_get.go b/jobs_gorm_redis_get.go index 47862f9..673e0ce 100644 --- a/jobs_gorm_redis_get.go +++ b/jobs_gorm_redis_get.go @@ -4,6 +4,7 @@ import ( "context" "errors" "fmt" + "go.dtapp.net/dorm" "go.dtapp.net/gojobs/jobs_gorm_model" "go.dtapp.net/gostring" "math/rand" @@ -69,7 +70,7 @@ func (j *JobsGorm) GetSubscribeClientList(ctx context.Context) ([]string, error) // 扫描 values, err := j.redisClient.Keys(ctx, j.config.cornKeyPrefix+"_*").Result() if err != nil { - if err == errors.New("ERR wrong number of arguments for 'mget' command") { + if errors.Is(err, dorm.RedisKeysNotFound) { return []string{}, nil } return nil, errors.New(fmt.Sprintf("获取失败:%s", err.Error()))