Jelajahi Sumber

新增同步爬虫数据日志

tuoling805 1 tahun lalu
induk
melakukan
608e570e63
2 mengubah file dengan 15 tambahan dan 1 penghapusan
  1. 11 0
      services/hz_data_api.go
  2. 4 1
      services/trade_zhengzhou.go

+ 11 - 0
services/hz_data_api.go

@@ -21,14 +21,25 @@ const (
 )
 
 func HttpPost(funcName, method string, postDataMap map[string]interface{}) (result string, err error) {
+	defer func() {
+		if err != nil {
+			fmt.Println("Sync hz crawler err:" + err.Error())
+			utils.FileLog.Info("Sync hz crawler err:" + err.Error())
+		}
+	}()
+	
 	bytesData, err := handlePostData(postDataMap)
 	if err != nil {
+		fmt.Println("handlePostData Err:" + err.Error())
 		return
 	}
 
+	fmt.Println("URL:" + HZ_DATA_API + method)
+	fmt.Println("Params:" + string(bytesData))
 	client := &http.Client{}
 	req, err := http.NewRequest("POST", HZ_DATA_API+method, bytes.NewReader(bytesData))
 	if err != nil {
+		fmt.Println("http.NewRequest Err:" + err.Error())
 		return "", err
 	}
 	req.Header.Set("content-type", "application/json")

+ 4 - 1
services/trade_zhengzhou.go

@@ -26,8 +26,11 @@ func SyncRankingFromZhengzhou() (err error) {
 	data["StartDate"] = startDate
 	//data["EndDate"] = endDate
 	result, err := HttpPost("SyncRankingFromZhengzhou", method, data)
+	if err != nil {
+		fmt.Println("SyncRankingFromZhengzhou HttpPost Err:", err.Error())
+	}
 	utils.FileLog.Info(result)
-	fmt.Println(result)
+	fmt.Println("SyncRankingFromZhengzhou result:", result)
 
 	respObj := new(data_manage.ZhengzhouIndexResp)
 	err = json.Unmarshal([]byte(result), &respObj)