liuxiulin 1 năm trước cách đây
mục cha
commit
cda0aff7ee

+ 2 - 0
services/scene-access/internal/service/scene.go

@@ -58,6 +58,8 @@ func (s *SceneService) SubmitTaskLifecycle(args rpcs.ArgsSubmitTaskLifecycle, re
 	if err != nil {
 		return err
 	}
+	fmt.Println("---------------------")
+	fmt.Println(data)
 	return s.lifecycleManager.Publish("sparrow.task.timer.lifecycle", data)
 }
 

+ 0 - 2
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/v2/os/gcron"
 	"sparrow/pkg/rule"
@@ -56,7 +55,6 @@ func (t *TaskSchedule) RemoveMessageHandle(msg *rule.TaskLifecycleMessage) error
 	if err != nil {
 		server.Log.Errorf("remove taskid :%s error:%s", msg.TaskId, err)
 	}
-	fmt.Println("111111111111111111")
 	server.Log.Debugf("RemoveMessageHandle :%s", msg.TaskId)
 	return nil
 }