add log

services/apiprovider/actions.go

@@ -431,7 +431,7 @@ func SubmitSceneTask(req *http.Request, r render.Render) {
 		r.JSON(http.StatusOK, renderError(ErrWrongRequestFormat, err))
 		return
 	}
-	fmt.Println("---------------------------")
+	fmt.Printf("type:%s,data:%s", ruleReq.Type, ruleReq.Data)
 	reply := rpcs.ReplySubmitTask{}
 	err = server.RPCCallByName(nil, rpcs.SceneAccessServiceName, "SceneService.SubmitTask", ruleReq, reply)
 	if err != nil {

services/scene-access/internal/service/manager/task_manager.go

@@ -1,6 +1,7 @@
 package manager
 
 import (
+	"fmt"
 	"github.com/streadway/amqp"
 	"sparrow/pkg/rule"
 )
@@ -23,6 +24,7 @@ func (a *TaskManager) Init() error {
 }
 
 func (a *TaskManager) Publish(topic string, msg []byte) error {
+	fmt.Println("==========================")
 	err := a.ch.Publish(rule.TaskExchange, topic, false, false, amqp.Publishing{
 		DeliveryMode: amqp.Persistent,
 		Body:         msg,

services/scene-access/internal/service/scene.go

@@ -36,6 +36,7 @@ func NewSceneService(mqAddr string) *SceneService {
 
 // SubmitTask rpc 提交一个任务
 func (s *SceneService) SubmitTask(args rpcs.ArgsSubmitTask, reply *rpcs.ReplyEmptyResult) error {
+	fmt.Println("-------")
 	var (
 		topic string
 	)
@@ -43,6 +44,8 @@ func (s *SceneService) SubmitTask(args rpcs.ArgsSubmitTask, reply *rpcs.ReplyEmp
 	case "timer":
 		topic = TimerTopic
 	}
+	fmt.Println("-----------------------")
+
 	return s.taskManager.Publish(topic, []byte(args.Data))
 }