update json marshal encoding

models/node_manager.go

@@ -39,12 +39,12 @@ type TaskResult struct {
 }
 
 type ApiResp struct {
-	TaskId     string `json:"task_id"`
-	TaskResult []byte `json:"task_result"`
-	TaskUid    string `json:"task_uid"`
-	TaskFee    string `json:"task_fee"`
-	IsSuccess  bool   `json:"is_success"`
-	TaskError  string `json:"task_error"`
+	TaskId     string   `json:"task_id"`
+	TaskResult []string `json:"task_result"`
+	TaskUid    string   `json:"task_uid"`
+	TaskFee    string   `json:"task_fee"`
+	IsSuccess  bool     `json:"is_success"`
+	TaskError  string   `json:"task_error"`
 }
 
 type HardwareRequire struct {

nm/task_msg.go

@@ -289,23 +289,23 @@ func (t *TaskHandler) ComputeTaskHandler(taskMsg *nodeManagerV1.PushTaskMessage)
 						}
 					}
 					if len(apiRes) > 1 {
-						fileCacheBody := bytes.NewBuffer([]byte{})
-						encoder := json.NewEncoder(fileCacheBody)
-						encoder.SetEscapeHTML(false)
-						err := encoder.Encode(apiRes)
-						if err != nil {
-							log.WithError(err).Error("encoder Encode")
-						}
 						res := &models.ApiResp{
 							IsSuccess:  true,
-							TaskResult: fileCacheBody.Bytes(),
+							TaskResult: apiRes,
 						}
-						apiResBody, err := json.Marshal(res)
+						apiResBody := bytes.NewBuffer([]byte{})
+						encoder := json.NewEncoder(apiResBody)
+						encoder.SetEscapeHTML(false)
+						err := encoder.Encode(res)
 						if err != nil {
-							log.WithError(err).Error("json marshal upload oss uri")
+							log.WithError(err).Error("encoder Encode")
 						}
-						log.WithField("apiResBody", string(apiResBody)).Info("model resp")
-						taskExecResult.TaskRespBody = apiResBody
+						//apiResBody, err := json.Marshal(res)
+						//if err != nil {
+						//	log.WithError(err).Error("json marshal upload oss uri")
+						//}
+						log.WithField("apiResBody", string(apiResBody.Bytes())).Info("model resp")
+						taskExecResult.TaskRespBody = apiResBody.Bytes()
 					}
 				}
 			}