update json marshal encoding

models/node_manager.go

@@ -39,9 +39,12 @@ type TaskResult struct {
 }
 
 type ApiResp struct {
-	Code int32       `json:"code"`
-	Msg  string      `json:"msg"`
-	Res  interface{} `json:"res"`
+	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"`
 }
 
 type HardwareRequire struct {

nm/task_msg.go

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