Merge branch 'logfix'

services/changes_visitors_covid.go

@@ -23,7 +23,7 @@ func SyncChangesVisitorsCovid() (err error) {
 	data["Source"] = utils.DATA_SOURCE_GOOGLE_TRAVEL
 	data["StartDate"] = startDate
 	//data["EndDate"] = endDate
-	result, err := HttpPost(method, data)
+	result, err := HttpPost("SyncChangesVisitorsCovid", method, data)
 	utils.FileLog.Info(result)
 	fmt.Println(result)
 

services/com_trade.go

@@ -24,7 +24,7 @@ func SyncComTradeIndex() (err error) {
 	data["Source"] = utils.DATA_SOURCE_COM_TRADE
 	data["StartDate"] = startDate
 	//data["EndDate"] = endDate
-	result, err := HttpPost(method, data)
+	result, err := HttpPost("SyncComTradeIndex", method, data)
 	utils.FileLog.Info(result)
 	fmt.Println(result)
 
@@ -123,7 +123,7 @@ func SyncComTradeData() (err error) {
 		data["PageSize"] = 500 //
 
 		var result string
-		result, err = HttpPost(method, data)
+		result, err = HttpPost("SyncComTradeData", method, data)
 		utils.FileLog.Info(result)
 		fmt.Println(result)
 

services/eia_steo.go

@@ -23,7 +23,7 @@ func SyncEiaSteoIndex() (err error) {
 	data["Source"] = utils.DATA_SOURCE_EIA_STEO
 	data["StartDate"] = startDate
 	//data["EndDate"] = endDate
-	result, err := HttpPost(method, data)
+	result, err := HttpPost("SyncEiaSteoIndex", method, data)
 	utils.FileLog.Info(result)
 	fmt.Println(result)
 
@@ -77,7 +77,7 @@ func SyncEiaSteoIndexData() (err error) {
 		data["IndexCode"] = zv.IndexCode
 
 		var result string
-		result, err = HttpPost(method, data)
+		result, err = HttpPost("SyncEiaSteoIndexData", method, data)
 		utils.FileLog.Info(result)
 		fmt.Println(result)
 

services/hz_data_api.go

@@ -20,7 +20,7 @@ const (
 	HZ_DATA_API = "https://hzdataapi.hzinsights.com/hzdataapi/"
 )
 
-func HttpPost(method string, postDataMap map[string]interface{}) (result string, err error) {
+func HttpPost(funcName, method string, postDataMap map[string]interface{}) (result string, err error) {
 	bytesData, err := handlePostData(postDataMap)
 	if err != nil {
 		return
@@ -32,6 +32,7 @@ func HttpPost(method string, postDataMap map[string]interface{}) (result string,
 		return "", err
 	}
 	req.Header.Set("content-type", "application/json")
+	utils.FileLog.Info(fmt.Sprintf("请求函数:%s ;请求体:%s", funcName, req))
 	resp, err := client.Do(req)
 	if err != nil {
 		return "", err
@@ -41,6 +42,7 @@ func HttpPost(method string, postDataMap map[string]interface{}) (result string,
 		return "", err
 	}
 	result = string(body)
+	utils.FileLog.Info(fmt.Sprintf("请求函数:%s ;返回体:%s", funcName, result))
 	return
 }
 

services/trade_cffex.go

@@ -23,7 +23,7 @@ func SyncRankingFromCffex() (err error) {
 	data["Source"] = utils.DATA_SOURCE_CFFEX
 	data["StartDate"] = startDate
 	//data["EndDate"] = endDate
-	result, err := HttpPost(method, data)
+	result, err := HttpPost("SyncRankingFromCffex", method, data)
 	utils.FileLog.Info(result)
 	fmt.Println(result)
 

services/trade_dalian.go

@@ -23,7 +23,7 @@ func SyncRankingFromDalian() (err error) {
 	data["Source"] = utils.DATA_SOURCE_DL
 	data["StartDate"] = startDate
 	//data["EndDate"] = endDate
-	result, err := HttpPost(method, data)
+	result, err := HttpPost("SyncRankingFromDalian", method, data)
 	utils.FileLog.Info(result)
 	fmt.Println(result)
 

services/trade_ine.go

@@ -23,7 +23,7 @@ func SyncRankingFromIne() (err error) {
 	data["Source"] = utils.DATA_SOURCE_SHFE
 	data["StartDate"] = startDate
 	//data["EndDate"] = endDate
-	result, err := HttpPost(method, data)
+	result, err := HttpPost("SyncRankingFromIne", method, data)
 	utils.FileLog.Info(result)
 	fmt.Println(result)
 

services/trade_shanghai.go

@@ -23,7 +23,7 @@ func SyncRankingFromShanghai() (err error) {
 	data["Source"] = utils.DATA_SOURCE_SH
 	data["StartDate"] = startDate
 	//data["EndDate"] = endDate
-	result, err := HttpPost(method, data)
+	result, err := HttpPost("SyncRankingFromShanghai", method, data)
 	utils.FileLog.Info(result)
 	fmt.Println(result)
 

services/trade_zhengzhou.go

@@ -25,7 +25,7 @@ func SyncRankingFromZhengzhou() (err error) {
 	data["Source"] = utils.DATA_SOURCE_ZZ
 	data["StartDate"] = startDate
 	//data["EndDate"] = endDate
-	result, err := HttpPost(method, data)
+	result, err := HttpPost("SyncRankingFromZhengzhou", method, data)
 	utils.FileLog.Info(result)
 	fmt.Println(result)