新增提示和注释

services/purang/client.go

@@ -3,6 +3,7 @@ package purang
 import (
 	"bytes"
 	"encoding/json"
+	"eta/eta_crawler/utils"
 	"fmt"
 	"io"
 
@@ -96,6 +97,11 @@ func (c *Client) DoRequest(path string, params map[string]string) (*BaseResponse
 	if err := json.NewDecoder(bytes.NewReader(body)).Decode(&baseResp); err != nil {
 		return nil, fmt.Errorf("decode response failed: %v", err)
 	}
+	if baseResp.Code != "10000" {
+		err = fmt.Errorf("接口返回失败，code: %s, err: %s",baseResp.Code, baseResp.Message)
+		utils.FileLog.Info(string(body))
+		return nil, err
+	}
 	// var baseResp BaseResponse
 	// if err := json.Unmarshal([]byte(bodystr), &baseResp); err != nil {
 	// 	return nil, fmt.Errorf("decode response failed: %v", err)

services/purang/purang_data.go

@@ -20,6 +20,7 @@ func GetPurangDataTask(ctx context.Context) (err error) {
 }
 
 func GetPurangMarketData(startDate, endDate string) (err error) {
+	utils.FileLog.Info(fmt.Sprintf("GetPurangMarketData startDate: %s, endDate: %s", startDate, endDate))
 	defer func() {
 		if err != nil {
 			msg := fmt.Sprintf("GetPurangMarketData failed Error: %v", err)
@@ -122,6 +123,7 @@ func GetPurangMarketData(startDate, endDate string) (err error) {
 	if err != nil {
 		return err
 	}
+	utils.FileLog.Info("GetPurangMarketData end ")
 	return nil	
 }