OMC/be.ems
1
0
Fork 0
Code Issues Releases 3 Activity

fix: 调度任务记录日志不判断jobID

Browse Source
This commit is contained in:
TsMask
2023-10-30 09:26:54 +08:00
parent 64548dd3aa
commit 4adea63183
1 changed files with 0 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
src/framework/cron/log.go
View File

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