- update

const.go

@@ -1,3 +1,3 @@
 package gojobs
 
-const Version = "1.0.58"
+const Version = "1.0.59"

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

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=

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()))