This commit is contained in:
2023-10-25 17:29:51 +08:00

View File

@@ -37,7 +37,7 @@ func (s cronlog) Error(err error, msg string, keysAndValues ...any) {
jobLog := jobLogData{
JobID: job.Opts.JobId,
Timestamp: job.Timestamp,
SysJob: data.SysJob,
Data: data,
Result: err.Error(),
}
jobLog.SaveLog(common.STATUS_NO)
@@ -61,7 +61,7 @@ func (s cronlog) Completed(result any, msg string, keysAndValues ...any) {
jobLog := jobLogData{
JobID: job.Opts.JobId,
Timestamp: job.Timestamp,
SysJob: data.SysJob,
Data: data,
Result: result,
}
jobLog.SaveLog(common.STATUS_YES)
@@ -73,14 +73,14 @@ func (s cronlog) Completed(result any, msg string, keysAndValues ...any) {
type jobLogData struct {
JobID string
Timestamp int64
SysJob model.SysJob
Data JobData
Result any
}
// SaveLog 日志记录保存
func (jl *jobLogData) SaveLog(status string) {
// 读取任务信息
sysJob := jl.SysJob
sysJob := jl.Data.SysJob
// 任务ID与任务信息ID不相同
if jl.JobID == "" || jl.JobID != sysJob.JobID {
@@ -101,6 +101,7 @@ func (jl *jobLogData) SaveLog(status string) {
// 结果信息序列化字符串
jsonByte, _ := json.Marshal(map[string]any{
"name": resultNmae,
"crom": jl.Data.Repeat,
"message": jl.Result,
})
jobMsg := string(jsonByte)