|
@@ -83,16 +83,20 @@ func syncDataNodeExecute() (err error) {
|
|
|
return
|
|
|
}
|
|
|
var result models.EtaBridgeKnowledgeResourceResp
|
|
|
- if err := json.Unmarshal(bBody, &result); err != nil {
|
|
|
- errMsgList = append(errMsgList, err.Error())
|
|
|
+ if er := json.Unmarshal(bBody, &result); er != nil {
|
|
|
+ errMsgList = append(errMsgList, er.Error())
|
|
|
+ err = er
|
|
|
+ return
|
|
|
}
|
|
|
if result.Code != 200 {
|
|
|
fmt.Println("eta_bridge同步数据节点失败")
|
|
|
errMsgList = append(errMsgList, result.Msg)
|
|
|
+ return
|
|
|
}
|
|
|
if result.Data.Code != "000000" {
|
|
|
fmt.Println("eta_bridge请求数据中心-市场简况接口同步数据节点失败")
|
|
|
errMsgList = append(errMsgList, result.Data.Msg)
|
|
|
+ return
|
|
|
}
|
|
|
err = ViewPointBatchSave(result.Data.Data.Records)
|
|
|
if err != nil {
|