diff --git a/src/framework/cron/log.go b/src/framework/cron/log.go index b233fed1..22e2a79c 100644 --- a/src/framework/cron/log.go +++ b/src/framework/cron/log.go @@ -35,7 +35,6 @@ func (s cronlog) Error(err error, msg string, keysAndValues ...any) { if data, ok := job.Data.(JobData); ok { // 日志数据 jobLog := jobLogData{ - JobID: job.Opts.JobId, Timestamp: job.Timestamp, Data: data, Result: err.Error(), @@ -59,7 +58,6 @@ func (s cronlog) Completed(result any, msg string, keysAndValues ...any) { if data, ok := job.Data.(JobData); ok { // 日志数据 jobLog := jobLogData{ - JobID: job.Opts.JobId, Timestamp: job.Timestamp, Data: data, Result: result, @@ -71,7 +69,6 @@ func (s cronlog) Completed(result any, msg string, keysAndValues ...any) { // jobLogData 日志记录数据 type jobLogData struct { - JobID string Timestamp int64 Data JobData Result any @@ -82,11 +79,6 @@ func (jl *jobLogData) SaveLog(status string) { // 读取任务信息 sysJob := jl.Data.SysJob - // 任务ID与任务信息ID不相同 - if jl.JobID == "" || jl.JobID != sysJob.JobID { - return - } - // 任务日志不需要记录 if sysJob.SaveLog == "" || sysJob.SaveLog == common.STATUS_NO { return