|
@@ -641,20 +641,22 @@ func AddEdbTask(cont context.Context) (err error) {
|
|
|
return
|
|
|
}
|
|
|
|
|
|
- //添加定时任务
|
|
|
+ //添加定时任务(没有设置通知时间就不进行定时任务通知了)
|
|
|
spec := ``
|
|
|
if noticeTime != "" {
|
|
|
noticeArr := strings.Split(noticeTime, ":")
|
|
|
if len(noticeArr) == 3 {
|
|
|
//spec = ` */20 * * * * * `
|
|
|
spec = fmt.Sprintf(` %s %s %s * * * `, noticeArr[2], noticeArr[1], noticeArr[0])
|
|
|
+
|
|
|
+ //定时任务开始的时间
|
|
|
+ tmpTask := task.NewTask(taskName, spec, tmpTaskFunc)
|
|
|
+
|
|
|
+ task.AddTask(taskName, tmpTask)
|
|
|
+ tmpEdbTaskNameMap[taskName] = true
|
|
|
}
|
|
|
}
|
|
|
- //定时任务开始的时间
|
|
|
- tmpTask := task.NewTask(taskName, spec, tmpTaskFunc)
|
|
|
|
|
|
- task.AddTask(taskName, tmpTask)
|
|
|
- tmpEdbTaskNameMap[taskName] = true
|
|
|
}
|
|
|
}
|
|
|
|