add log

pkg/rpcs/task.go

@@ -7,9 +7,9 @@ type ArgsSubmitTask struct {
 }
 
 type ArgsSubmitTaskLifecycle struct {
-	TaskId string
-	Action string
-	Data   string
+	TaskId string `json:"task_id"`
+	Action string `json:"action"`
+	Data   string `json:"data"`
 }
 
 type ReplySubmitTask ReplyEmptyResult

services/apiprovider/actions.go

@@ -4,6 +4,7 @@ import (
 	"context"
 	"encoding/json"
 	"errors"
+	"fmt"
 	"github.com/gogf/gf/encoding/gjson"
 	"sparrow/pkg/productconfig"
 	"sparrow/pkg/rpcs"
@@ -444,13 +445,14 @@ func SubmitSceneTask(req *http.Request, r render.Render) {
 func SubmitTaskLifecycle(req *http.Request, r render.Render) {
 
 	var ruleReq rpcs.ArgsSubmitTaskLifecycle
+	fmt.Printf("------------%s", req.Body)
 	decoder := json.NewDecoder(req.Body)
 	err := decoder.Decode(&ruleReq)
 	if err != nil {
 		r.JSON(http.StatusOK, renderError(ErrWrongRequestFormat, err))
 		return
 	}
-
+	fmt.Printf("--------------------%s", ruleReq.TaskId)
 	reply := rpcs.ReplySubmitTask{}
 	err = server.RPCCallByName(nil, rpcs.SceneAccessServiceName, "SceneService.SubmitTaskLifecycle", ruleReq, &reply)
 	if err != nil {

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

@@ -58,7 +58,6 @@ func (s *SceneService) SubmitTaskLifecycle(args rpcs.ArgsSubmitTaskLifecycle, re
 	if err != nil {
 		return err
 	}
-	fmt.Printf("task_id:%s,action:%s,data:%v", args.TaskId, args.Action, args.Data)
 	return s.lifecycleManager.Publish("sparrow.task.timer.lifecycle", data)
 }