- update log

check_task.go

@@ -5,7 +5,6 @@ import (
 	"go.dtapp.net/gojobs/jobs_gorm_model"
 	"go.dtapp.net/gotime"
 	"gorm.io/gorm"
-	"log"
 )
 
 // CheckManyTask 多任务检查
@@ -15,11 +14,11 @@ func (c *Client) CheckManyTask(ctx context.Context, tx *gorm.DB, vs []jobs_gorm_
 			diffInSecondWithAbs := gotime.Current().DiffInSecondWithAbs(gotime.SetCurrent(v.UpdatedAt).Time)
 			if diffInSecondWithAbs >= v.Frequency*3 {
 				if c.config.debug == true {
-					log.Printf("[jobs.CheckManyTask]每隔%v秒任务：%v相差%v秒\n", v.Frequency, v.Id, diffInSecondWithAbs)
+					c.zapLog.WithTraceId(ctx).Sugar().Infof("[jobs.CheckManyTask]每隔%v秒任务：%v相差%v秒\n", v.Frequency, v.Id, diffInSecondWithAbs)
 				}
 				err := tx.Where("task_id = ?", v.Id).Where("run_id = ?", v.RunId).Delete(&jobs_gorm_model.TaskLogRun{}).Error
 				if err != nil {
-					log.Println("删除失败", err.Error())
+					c.zapLog.WithTraceId(ctx).Sugar().Errorf("删除失败：%s", err.Error())
 				}
 			}
 		}
@@ -31,11 +30,11 @@ func (c *Client) CheckSingleTask(ctx context.Context, tx *gorm.DB, v jobs_gorm_m
 	diffInSecondWithAbs := gotime.Current().DiffInSecondWithAbs(gotime.SetCurrent(v.UpdatedAt).Time)
 	if diffInSecondWithAbs >= v.Frequency*3 {
 		if c.config.debug == true {
-			log.Printf("[jobs.CheckManyTask]每隔%v秒任务：%v相差%v秒\n", v.Frequency, v.Id, diffInSecondWithAbs)
+			c.zapLog.WithTraceId(ctx).Sugar().Infof("[jobs.CheckManyTask]每隔%v秒任务：%v相差%v秒\n", v.Frequency, v.Id, diffInSecondWithAbs)
 		}
 		err := tx.Where("task_id = ?", v.Id).Where("run_id = ?", v.RunId).Delete(&jobs_gorm_model.TaskLogRun{}).Error
 		if err != nil {
-			log.Println("删除失败", err.Error())
+			c.zapLog.WithTraceId(ctx).Sugar().Errorf("删除失败：%s", err.Error())
 		}
 	}
 }

const.go

@@ -1,6 +1,6 @@
 package gojobs
 
 const (
-	Version       = "1.0.74"
+	Version       = "1.0.75"
 	SpecifyIpNull = "0.0.0.0"
 )

jobs_gorm_model/task_log_run.go

@@ -13,6 +13,7 @@ type TaskLogRun struct {
 	Arch       string    `gorm:"comment:系统架构" json:"arch"`                      // 系统架构
 	Gomaxprocs int       `gorm:"comment:CPU核数" json:"gomaxprocs"`               // CPU核数
 	GoVersion  string    `gorm:"comment:GO版本" json:"go_version"`                // GO版本
+	SdkVersion string    `gorm:"comment:SDK版本" json:"sdk_version"`              // SDK版本
 	MacAddrs   string    `gorm:"comment:Mac地址" json:"mac_addrs"`                // Mac地址
 	CreatedAt  time.Time `gorm:"autoCreateTime;comment:创建时间" json:"created_at"` // 创建时间
 }

jobs_mongo_model/task_log_run.go

@@ -6,17 +6,18 @@ import (
 
 // TaskLogRun 任务执行日志模型
 type TaskLogRun struct {
-	Id         primitive.ObjectID `json:"id,omitempty" bson:"_id,omitempty"`                // 记录编号
-	TaskId     uint               `json:"task_id,omitempty" bson:"task_id,omitempty"`       // 任务编号
-	RunId      string             `json:"run_id,omitempty" bson:"run_id,omitempty"`         // 执行编号
-	OutsideIp  string             `json:"outside_ip,omitempty" bson:"outside_ip,omitempty"` // 外网ip
-	InsideIp   string             `json:"inside_ip,omitempty" bson:"inside_ip,omitempty"`   // 内网ip
-	Os         string             `json:"os,omitempty" bson:"os,omitempty"`                 // 系统类型
-	Arch       string             `json:"arch,omitempty" bson:"arch,omitempty"`             // 系统架构
-	Gomaxprocs int                `json:"gomaxprocs,omitempty" bson:"gomaxprocs,omitempty"` // CPU核数
-	GoVersion  string             `json:"go_version,omitempty" bson:"go_version,omitempty"` // GO版本
-	MacAddrs   string             `json:"mac_addrs,omitempty" bson:"mac_addrs,omitempty"`   // Mac地址
-	CreatedAt  primitive.DateTime `json:"created_at,omitempty" bson:"created_at,omitempty"` // 创建时间
+	Id         primitive.ObjectID `json:"id,omitempty" bson:"_id,omitempty"`                  // 记录编号
+	TaskId     uint               `json:"task_id,omitempty" bson:"task_id,omitempty"`         // 任务编号
+	RunId      string             `json:"run_id,omitempty" bson:"run_id,omitempty"`           // 执行编号
+	OutsideIp  string             `json:"outside_ip,omitempty" bson:"outside_ip,omitempty"`   // 外网ip
+	InsideIp   string             `json:"inside_ip,omitempty" bson:"inside_ip,omitempty"`     // 内网ip
+	Os         string             `json:"os,omitempty" bson:"os,omitempty"`                   // 系统类型
+	Arch       string             `json:"arch,omitempty" bson:"arch,omitempty"`               // 系统架构
+	Gomaxprocs int                `json:"gomaxprocs,omitempty" bson:"gomaxprocs,omitempty"`   // CPU核数
+	GoVersion  string             `json:"go_version,omitempty" bson:"go_version,omitempty"`   // GO版本
+	SdkVersion string             `json:"sdk_version,omitempty" bson:"sdk_version,omitempty"` // SDK版本
+	MacAddrs   string             `json:"mac_addrs,omitempty" bson:"mac_addrs,omitempty"`     // Mac地址
+	CreatedAt  primitive.DateTime `json:"created_at,omitempty" bson:"created_at,omitempty"`   // 创建时间
 }
 
 func (TaskLogRun) TableName() string {

jobs_xorm_model/task_log_run.go

@@ -11,6 +11,7 @@ type TaskLogRun struct {
 	Arch       string `json:"arch"`                      // 系统架构
 	Gomaxprocs int    `json:"gomaxprocs"`                // CPU核数
 	GoVersion  string `json:"go_version"`                // GO版本
+	SdkVersion string `json:"sdk_version"`               // SDK版本
 	MacAddrs   string `json:"mac_addrs"`                 // Mac地址
 	CreatedAt  string `xorm:"created" json:"created_at"` // 创建时间
 }

run.go

@@ -124,6 +124,7 @@ func (c *Client) RunAddLog(id uint, runId string) error {
 				Arch:       c.config.arch,
 				Gomaxprocs: c.config.maxProCs,
 				GoVersion:  c.config.version,
+				SdkVersion: c.config.runVersion,
 				MacAddrs:   c.config.macAddrS,
 				CreatedAt:  primitive.NewDateTimeFromTime(gotime.Current().Time),
 			})
@@ -138,6 +139,7 @@ func (c *Client) RunAddLog(id uint, runId string) error {
 		Arch:       c.config.arch,
 		Gomaxprocs: c.config.maxProCs,
 		GoVersion:  c.config.version,
+		SdkVersion: c.config.runVersion,
 		MacAddrs:   c.config.macAddrS,
 	}).Error
 }