update container sign struct

models/node_manager.go

@@ -20,8 +20,8 @@ type DockerCmd struct {
 
 type TaskReq struct {
 	TaskId     string `json:"task_id"`
-	TaskParam  string `json:"task_param"`
-	TaskResult string `json:"task_result"`
+	TaskParam  []byte `json:"task_param"`
+	TaskResult []byte `json:"task_result"`
 }
 
 type TaskParam struct {

operate/docker.go

@@ -57,8 +57,8 @@ func NewDockerOp() *DockerOp {
 func (d *DockerOp) GetContainerSign(taskMsg *nodemanagerv1.PushTaskMessage, taskRes []byte) []byte {
 	reqBody := &models.TaskReq{
 		TaskId:     taskMsg.TaskId,
-		TaskParam:  bytes.NewBuffer(taskMsg.TaskParam).String(),
-		TaskResult: bytes.NewBuffer(taskRes).String(),
+		TaskParam:  taskMsg.TaskParam,
+		TaskResult: taskRes,
 	}
 	body, err := json.Marshal(reqBody)
 	if err != nil {