update

services/timer-service/internal/scheduler.go

@@ -3,7 +3,6 @@ package internal
 import (
 	"context"
 	"encoding/json"
-	"fmt"
 	"github.com/gogf/gf/container/gmap"
 	"github.com/gogf/gf/encoding/gjson"
 	"github.com/gogf/gf/v2/os/gcron"
@@ -55,12 +54,10 @@ func (t *TaskSchedule) AddMessageHandle(msg *rule.TaskLifecycleMessage) error {
 }
 
 func (t *TaskSchedule) RemoveMessageHandle(msg *rule.TaskLifecycleMessage) error {
-	fmt.Printf("before任务列表：%v", t.cron.Entries())
 	t.cron.Remove(msg.TaskId)
 	_ = t.tasks.Remove(msg.TaskId)
 
 	server.Log.Debugf("RemoveMessageHandle :%s", msg.TaskId)
-	fmt.Printf("after任务列表：%v", t.cron.Entries())
 	return nil
 }
 
@@ -85,7 +82,6 @@ func (t *TaskSchedule) UpdateMessageHandle(msg *rule.TaskLifecycleMessage) error
 
 func (t *TaskSchedule) SnapMessageHandle(msg *rule.TaskLifecycleMessage) error {
 	t.cron.Stop(msg.TaskId)
-
 	server.Log.Debugf("SnapMessageHandle :%s", msg.TaskId)
 	return nil
 }
@@ -93,14 +89,11 @@ func (t *TaskSchedule) SnapMessageHandle(msg *rule.TaskLifecycleMessage) error {
 func (t *TaskSchedule) StartMessageHandle(msg *rule.TaskLifecycleMessage) error {
 	t.cron.Start(msg.TaskId)
 	server.Log.Debugf("StartMessageHandle :%s", msg.TaskId)
-	server.Log.Debugf("taskId:%s,status:%d", msg.TaskId, t.cron.Search(msg.TaskId).Status())
 	return nil
 }
 
 func (t *TaskSchedule) StopMessageHandle(msg *rule.TaskLifecycleMessage) error {
 	t.cron.Stop(msg.TaskId)
-	t.cron.Entries()
 	server.Log.Debugf("StopMessageHandle :%s", msg.TaskId)
-	server.Log.Debugf("taskId:%s,status:%d", msg.TaskId, t.cron.Search(msg.TaskId).Status())
 	return nil
 }