去掉多余的注释

models/data_manage/base_from_trade_guangzhou.go

@@ -160,6 +160,12 @@ func GetAllBaseFromTradeGuangzhouDataList(startDate string) (list []*BaseFromTra
 	return
 }
 
+// 设置after find函数
+func (m *BaseFromTradeGuangzhouData) AfterFind(db *gorm.DB) (err error) {
+	m.DataTime = utils.GormDateStrToDateStr(m.DataTime)
+	return
+}
+
 type BaseFromTradeGuangzhouDataResp struct {
 	Ret     int
 	Msg     string

services/changes_visitors_covid.go

@@ -24,8 +24,8 @@ func SyncChangesVisitorsCovid() (err error) {
 	data["StartDate"] = startDate
 	//data["EndDate"] = endDate
 	result, err := HttpPost("SyncChangesVisitorsCovid", method, data)
-	utils.FileLog.Info(result)
-	fmt.Println(result)
+	//utils.FileLog.Info(result)
+	//fmt.Println(result)
 
 	respObj := new(data_manage.ChangesVisitorsCovidIndexResp)
 	err = json.Unmarshal([]byte(result), &respObj)

services/com_trade.go

@@ -124,8 +124,8 @@ func SyncComTradeData() (err error) {
 
 		var result string
 		result, err = HttpPost("SyncComTradeData", method, data)
-		utils.FileLog.Info(result)
-		fmt.Println(result)
+		//utils.FileLog.Info(result)
+		//fmt.Println(result)
 
 		respObj := new(data_manage.ComTradeIndexDataResp)
 		err = json.Unmarshal([]byte(result), &respObj)

services/eia_steo.go

@@ -92,8 +92,8 @@ func SyncEiaSteoIndexData() (err error) {
 			utils.FileLog.Info("HttpPost err:", err)
 			return
 		}
-		utils.FileLog.Info(result)
-		fmt.Println(result)
+		//utils.FileLog.Info(result)
+		//fmt.Println(result)
 
 		respObj := new(data_manage.EiaSteoIndexDataResp)
 		err = json.Unmarshal([]byte(result), &respObj)

services/eic.go

@@ -24,8 +24,8 @@ func SyncRankingFromEic() (err error) {
 	data["StartDate"] = startDate
 	//data["EndDate"] = endDate
 	result, err := HttpPost("SyncRankingFromEic", method, data)
-	utils.FileLog.Info(result)
-	fmt.Println(result)
+	//utils.FileLog.Info(result)
+	//fmt.Println(result)
 
 	respObj := new(data_manage.EicIndexResp)
 	err = json.Unmarshal([]byte(result), &respObj)

services/gpr_risk.go

@@ -25,8 +25,8 @@ func SyncBaseFromGprRisk() (err error) {
 	data["StartDate"] = startDate
 	//data["EndDate"] = endDate
 	result, err := HttpPost("SyncRankingFromGprRisk", method, data)
-	utils.FileLog.Info(result)
-	fmt.Println(result)
+	//utils.FileLog.Info(result)
+	//fmt.Println(result)
 
 	respObj := new(data_manage.GprRiskIndexResp)
 	err = json.Unmarshal([]byte(result), &respObj)
@@ -57,8 +57,8 @@ func SyncBaseFromGprRiskClassify() (err error) {
 	if err != nil {
 		fmt.Println("SyncBaseFromGprRiskClassify HttpPost Err:", err.Error())
 	}
-	utils.FileLog.Info(result)
-	fmt.Println("SyncBaseFromGprRiskClassify result:", result)
+	//utils.FileLog.Info(result)
+	//fmt.Println("SyncBaseFromGprRiskClassify result:", result)
 
 	respObj := new(data_manage.GprRiskClassifyResp)
 	err = json.Unmarshal([]byte(result), &respObj)
@@ -124,8 +124,8 @@ func SyncBaseFromGprRiskData() (err error) {
 
 		var result string
 		result, err = HttpPost("SyncBaseFromGprRiskData", method, data)
-		utils.FileLog.Info(result)
-		fmt.Println(result)
+		//utils.FileLog.Info(result)
+		//fmt.Println(result)
 
 		respObj := new(data_manage.BaseFromGprRiskDataResp)
 		err = json.Unmarshal([]byte(result), &respObj)

services/icpi.go

@@ -25,8 +25,8 @@ func SyncBaseFromIcpi() (err error) {
 	data["StartDate"] = startDate
 	//data["EndDate"] = endDate
 	result, err := HttpPost("SyncRankingFromIcpi", method, data)
-	utils.FileLog.Info(result)
-	fmt.Println(result)
+	//utils.FileLog.Info(result)
+	//fmt.Println(result)
 
 	respObj := new(data_manage.IcpiIndexResp)
 	err = json.Unmarshal([]byte(result), &respObj)

services/trade_cffex.go

@@ -24,8 +24,8 @@ func SyncRankingFromCffex() (err error) {
 	data["StartDate"] = startDate
 	//data["EndDate"] = endDate
 	result, err := HttpPost("SyncRankingFromCffex", method, data)
-	utils.FileLog.Info(result)
-	fmt.Println(result)
+	//utils.FileLog.Info(result)
+	//fmt.Println(result)
 
 	respObj := new(data_manage.CffexIndexResp)
 	err = json.Unmarshal([]byte(result), &respObj)

services/trade_guangzhou.go

@@ -19,8 +19,8 @@ func SyncFromGuangzhouClassify() (err error) {
 		fmt.Println("SyncFromGuangzhouClassify HttpPost Err:", err.Error())
 		return err
 	}
-	utils.FileLog.Info("SyncFromGuangzhouClassify:" + result)
-	fmt.Println("SyncFromGuangzhouClassify result:", result)
+	//utils.FileLog.Info("SyncFromGuangzhouClassify:" + result)
+	//fmt.Println("SyncFromGuangzhouClassify result:", result)
 
 	respObj := new(data_manage.GuangzhouClassifyResp)
 	err = json.Unmarshal([]byte(result), &respObj)
@@ -59,8 +59,8 @@ func SyncFromGuangzhouIndex() (err error) {
 	if err != nil {
 		fmt.Println("SyncFromGuangzhou HttpPost Err:", err.Error())
 	}
-	utils.FileLog.Info(result)
-	fmt.Println("SyncFromGuangzhouIndex result:", result)
+	//utils.FileLog.Info(result)
+	//fmt.Println("SyncFromGuangzhouIndex result:", result)
 
 	respObj := new(data_manage.GuangzhouIndexResp)
 	err = json.Unmarshal([]byte(result), &respObj)
@@ -100,8 +100,8 @@ func SyncFromGuangzhouContract() (err error) {
 	if err != nil {
 		fmt.Println("SyncFromGuangzhouContract HttpPost Err:", err.Error())
 	}
-	utils.FileLog.Info(result)
-	fmt.Println("SyncFromGuangzhouContract result:", result)
+	//utils.FileLog.Info(result)
+	//fmt.Println("SyncFromGuangzhouContract result:", result)
 
 	respObj := new(data_manage.GuangzhouContractResp)
 	err = json.Unmarshal([]byte(result), &respObj)
@@ -154,6 +154,7 @@ func SyncFromGuangzhouTradeData() (err error) {
 	}
 	for _, dv := range allData {
 		tmpKey := dv.IndexCode + "_" + dv.DataTime
+		//fmt.Println("GetAllBaseFromTradeGuangzhouDataList tmpKey:", tmpKey)
 		existDataMap[tmpKey] = dv
 	}
 
@@ -169,8 +170,8 @@ func SyncFromGuangzhouTradeData() (err error) {
 
 		var result string
 		result, err = HttpPost("SyncFromGuangzhouTradeData", method, data)
-		utils.FileLog.Info(result)
-		fmt.Println(result)
+		//utils.FileLog.Info(result)
+		//fmt.Println(result)
 
 		respObj := new(data_manage.BaseFromTradeGuangzhouDataResp)
 		err = json.Unmarshal([]byte(result), &respObj)
@@ -189,6 +190,7 @@ func SyncFromGuangzhouTradeData() (err error) {
 		if respObj.Data.List != nil && len(respObj.Data.List) > 0 {
 			for _, dv := range respObj.Data.List {
 				tmpKey := dv.IndexCode + "_" + dv.DataTime
+				//fmt.Println("SyncFromGuangzhouTradeData2 tmpKey:", tmpKey)
 				if _, ok := existDataMap[tmpKey]; !ok {
 					addDataList = append(addDataList, dv)
 					existDataMap[tmpKey] = dv

services/trade_shanghai.go

@@ -24,8 +24,8 @@ func SyncRankingFromShanghai() (err error) {
 	data["StartDate"] = startDate
 	//data["EndDate"] = endDate
 	result, err := HttpPost("SyncRankingFromShanghai", method, data)
-	utils.FileLog.Info(result)
-	fmt.Println(result)
+	//utils.FileLog.Info(result)
+	//fmt.Println(result)
 
 	respObj := new(data_manage.ShanghaiIndexResp)
 	err = json.Unmarshal([]byte(result), &respObj)

services/usda_fas.go

@@ -39,11 +39,11 @@ func SyncBaseFromUsdaFas() (err error) {
 	UsdaFasObj := new(data_manage.BaseFromUsdaFasIndex)
 
 	for _, zv := range respObj.Data {
-		newID, err := UsdaFasObj.InsertOrUpdateBaseFromUsdaFasIndex(zv)
+		_, err := UsdaFasObj.InsertOrUpdateBaseFromUsdaFasIndex(zv)
 		if err != nil {
 			fmt.Println("InsertOrUpdateBaseFromUsdaFasIndex error:", err)
 		}
-		fmt.Println("InsertOrUpdateBaseFromUsdaFasIndex new indexID:", newID)
+		//fmt.Println("InsertOrUpdateBaseFromUsdaFasIndex new indexID:", newID)
 	}
 	return err
 }
@@ -124,8 +124,8 @@ func SyncBaseFromUsdaFasData() (err error) {
 
 		var result string
 		result, err = HttpPost("SyncBaseFromUsdaFasData", method, data)
-		utils.FileLog.Info(result)
-		fmt.Println(result)
+		//utils.FileLog.Info(result)
+		//fmt.Println(result)
 
 		respObj := new(data_manage.BaseFromUsdaFasDataResp)
 		err = json.Unmarshal([]byte(result), &respObj)