From c8e573f97339c734e1f251061741c4eb9c36a01e Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E6=9D=8E=E5=85=89=E6=98=A5?= <gc@dtapp.net>
Date: Sat, 25 Jun 2022 10:40:34 +0800
Subject: [PATCH] - update jobs

---
 utils/gojobs/jobs_gorm.go      | 5 +++++
 utils/gojobs/jobs_gorm_etcd.go | 4 ++++
 2 files changed, 9 insertions(+)

diff --git a/utils/gojobs/jobs_gorm.go b/utils/gojobs/jobs_gorm.go
index 8ca1f1f0..c1bf4b39 100644
--- a/utils/gojobs/jobs_gorm.go
+++ b/utils/gojobs/jobs_gorm.go
@@ -27,6 +27,7 @@ type ConfigJobsGorm struct {
 	MainService int               // 主要服务
 	Db          *gorm.DB          // 数据库
 	Redis       *dorm.RedisClient // 缓存数据库服务
+	Debug       bool              // 是否开启调测
 }
 
 // JobsGorm Gorm数据库驱动
@@ -73,6 +74,10 @@ func NewJobsGorm(config *ConfigJobsGorm) (*JobsGorm, error) {
 		return nil, errors.New(fmt.Sprintf("创建任务模型失败：%v\n", err))
 	}
 
+	if c.config.Debug == true {
+		log.Printf("jobs：%+v\n", c)
+	}
+
 	return c, nil
 }
 
diff --git a/utils/gojobs/jobs_gorm_etcd.go b/utils/gojobs/jobs_gorm_etcd.go
index 5affc4dd..e9a3899a 100644
--- a/utils/gojobs/jobs_gorm_etcd.go
+++ b/utils/gojobs/jobs_gorm_etcd.go
@@ -4,6 +4,7 @@ import (
 	"errors"
 	"fmt"
 	"go.dtapp.net/library/utils/gojobs/jobs_gorm_model"
+	"log"
 	"math/rand"
 	"time"
 )
@@ -20,6 +21,9 @@ func (j *JobsGorm) GetEtcdIssueAddress(server *Etcd, v jobs_gorm_model.Task) (ad
 		appointIpStatus = true
 	}
 	workers, err := server.ListWorkers()
+	if j.config.Debug == true {
+		log.Printf("客户端列表：%+v\n", workers)
+	}
 	if err != nil {
 		return address, errors.New(fmt.Sprintf("获取在线客户端列表失败：%s", err.Error()))
 	}