|
@@ -3,7 +3,6 @@ package internal
|
|
|
import (
|
|
|
"context"
|
|
|
"encoding/json"
|
|
|
- "fmt"
|
|
|
"github.com/gogf/gf/container/gmap"
|
|
|
"github.com/gogf/gf/v2/os/gcron"
|
|
|
"sparrow/pkg/rule"
|
|
@@ -27,8 +26,6 @@ func (t *TaskSchedule) AddTask(msg []byte) error {
|
|
|
if err != nil {
|
|
|
return err
|
|
|
}
|
|
|
- fmt.Printf("task_id:%s,corn:%s,actions:%v,", task.TaskId, task.Cron, task.Actions)
|
|
|
- fmt.Printf("tasks:%s", t.tasks)
|
|
|
// 如果已经存在相同任务Id
|
|
|
if t.tasks.Contains(task.TaskId) {
|
|
|
return nil
|
|
@@ -42,7 +39,6 @@ func (t *TaskSchedule) AddTask(msg []byte) error {
|
|
|
if err != nil {
|
|
|
return err
|
|
|
}
|
|
|
- fmt.Println("-----------------------")
|
|
|
t.tasks.Set(task.TaskId, entity)
|
|
|
server.Log.Debugf("add a new timer task :%s", task.TaskId)
|
|
|
return nil
|