x
This commit is contained in:
parent
9d056c9139
commit
fe9d0fa3df
@ -142,11 +142,9 @@ var handleMessage = func(msgs ...interface{}) interface{} {
|
||||
return nil
|
||||
case "任务列表":
|
||||
rt := ""
|
||||
k := 1
|
||||
for i := range Config.Repos {
|
||||
for j := range Config.Repos[i].Task {
|
||||
rt += fmt.Sprintf("%d: %s\t%s\n", k, Config.Repos[i].Task[j].Name, Config.Repos[i].Task[j].Cron)
|
||||
k++
|
||||
rt += fmt.Sprintf("%s\t%s\n", Config.Repos[i].Task[j].Title, Config.Repos[i].Task[j].Cron)
|
||||
}
|
||||
}
|
||||
return rt
|
||||
|
||||
@ -114,6 +114,9 @@ func (rp *Repo) addTask() {
|
||||
for i := range rp.Task {
|
||||
task := &rp.Task[i]
|
||||
eid, err := c.AddFunc(task.Cron, func() {
|
||||
if Cdle {
|
||||
return
|
||||
}
|
||||
logs.Info("执行任务 %s %s ", task.Title, task.Cron)
|
||||
runTask(task)
|
||||
})
|
||||
|
||||
Loading…
Reference in New Issue
Block a user