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