diff --git a/common/notify.go b/common/notify.go index 342fb39..54455d3 100644 --- a/common/notify.go +++ b/common/notify.go @@ -4,10 +4,13 @@ import ( "autogo/dbsql" "autogo/models" "errors" + "time" "gorm.io/gorm" ) +var DingTime = make(map[int]time.Time) + var NotifyList []models.Notify func InitNotifyInfos() error { diff --git a/crontask/monkey.go b/crontask/monkey.go index 96f2a2e..261d5a4 100644 --- a/crontask/monkey.go +++ b/crontask/monkey.go @@ -109,7 +109,15 @@ func CheckMonkeyTasks() { common.PushCorntaskLog("[autogo] 任务标记为FINISH, " + cast.ToString(v.Id)) common.PushMonkeyResult(v) } else { - common.PushCorntaskLog("任务状态似乎异常,task_id=" + cast.ToString(v.Id)) + if last_time, ok := common.DingTime[v.Id]; ok { + common.PushCorntaskLog("任务状态似乎异常,task_id=" + cast.ToString(v.Id)) + } else { + // 十分钟间隔报一次 + if time.Now().Unix()-60*10 > last_time.Unix() { + common.PushCorntaskLog("任务状态似乎异常,task_id=" + cast.ToString(v.Id)) + } + } + } } else { // 预期结束时间(任务开始时间+运行时间) < 当前时间,判断任务为运行正常结束