From 46ecd675764a32e7e2004e3f14a664e9264a6c6a Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E6=9D=8E=E5=85=89=E6=98=A5?= Date: Tue, 28 Jun 2022 09:52:48 +0800 Subject: [PATCH] - update jobs --- utils/gojobs/jobs_gorm.go | 10 +++++++--- 1 file changed, 7 insertions(+), 3 deletions(-) diff --git a/utils/gojobs/jobs_gorm.go b/utils/gojobs/jobs_gorm.go index 33e7e857..7db0f1df 100644 --- a/utils/gojobs/jobs_gorm.go +++ b/utils/gojobs/jobs_gorm.go @@ -85,17 +85,21 @@ func NewJobsGorm(attrs ...*OperationAttr) (*JobsGorm, error) { switch c.config.lockType { case lockTypeRedis: + if c.db.redisClient == nil { - return nil, errors.New("需要配REDIS驱动") + return nil, errors.New("没有设置REDIS驱动") } c.service.lockRedisClient = golock.NewLockRedis(c.db.redisClient) + case lockTypeEtcd: + if c.db.etcdClient == nil { - return nil, errors.New("需要配置ETCD驱动") + return nil, errors.New("没有设置ETCD驱动") } c.service.lockEtcdClient = golock.NewLockEtcd(c.db.etcdClient) + default: - return nil, errors.New("需要配置缓存驱动") + return nil, errors.New("驱动为空") } err := c.service.gormClient.AutoMigrate(