fix bug

services/apiprovider/actions.go

@@ -4,7 +4,6 @@ import (
 	"context"
 	"encoding/json"
 	"errors"
-	"fmt"
 	"github.com/gogf/gf/encoding/gjson"
 	"sparrow/pkg/productconfig"
 	"sparrow/pkg/rpcs"
@@ -431,9 +430,8 @@ func SubmitSceneTask(req *http.Request, r render.Render) {
 		r.JSON(http.StatusOK, renderError(ErrWrongRequestFormat, err))
 		return
 	}
-	fmt.Printf("type:%s,data:%s", ruleReq.Type, ruleReq.Data)
 	reply := rpcs.ReplySubmitTask{}
-	err = server.RPCCallByName(nil, rpcs.SceneAccessServiceName, "SceneService.SubmitTask", ruleReq, reply)
+	err = server.RPCCallByName(nil, rpcs.SceneAccessServiceName, "SceneService.SubmitTask", ruleReq, &reply)
 	if err != nil {
 		server.Log.Errorf("submit sceneTask error: %v", err)
 		r.JSON(http.StatusOK, renderError(ErrSystemFault, err))
@@ -454,7 +452,7 @@ func SubmitTaskLifecycle(req *http.Request, r render.Render) {
 	}
 
 	reply := rpcs.ReplySubmitTask{}
-	err = server.RPCCallByName(nil, rpcs.SceneAccessServiceName, "SceneService.SubmitTaskLifecycle", ruleReq, reply)
+	err = server.RPCCallByName(nil, rpcs.SceneAccessServiceName, "SceneService.SubmitTaskLifecycle", ruleReq, &reply)
 	if err != nil {
 		r.JSON(http.StatusOK, renderError(ErrWrongSecret, errors.New("invalid secret key")))
 		server.Log.Errorf("submit taskLifecycle error: %v", err)

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

@@ -1,7 +1,6 @@
 package manager
 
 import (
-	"fmt"
 	"github.com/streadway/amqp"
 	"sparrow/pkg/rule"
 )
@@ -24,7 +23,6 @@ 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,7 +36,6 @@ func NewSceneService(mqAddr string) *SceneService {
 
 // SubmitTask rpc 提交一个任务
 func (s *SceneService) SubmitTask(args rpcs.ArgsSubmitTask, reply *rpcs.ReplyEmptyResult) error {
-	fmt.Println("-------")
 	var (
 		topic string
 	)
@@ -44,7 +43,6 @@ func (s *SceneService) SubmitTask(args rpcs.ArgsSubmitTask, reply *rpcs.ReplyEmp
 	case "timer":
 		topic = TimerTopic
 	}
-	fmt.Println("-----------------------")
 
 	return s.taskManager.Publish(topic, []byte(args.Data))
 }