修改指标数据同步

models/data_manage/base_from_usda_fas.go

@@ -17,8 +17,8 @@ type BaseFromUsdaFasIndex struct {
 	Frequency              string
 	Unit                   string
 	Sort                   int
-	StartDate              string `description:"开始日期"`
-	EndDate                string `description:"结束日期"`
+	StartDate              time.Time `description:"开始日期"`
+	EndDate                time.Time `description:"结束日期"`
 	EndValue               float64
 	Country                string `description:"国家"`
 	Commodity              string `description:"属性"`
@@ -26,11 +26,11 @@ type BaseFromUsdaFasIndex struct {
 	ModifyTime             time.Time
 }
 
-func (m *BaseFromUsdaFasIndex) AfterFind(db *gorm.DB) (err error) {
-	m.StartDate = utils.GormDateStrToDateStr(m.StartDate)
-	m.EndDate = utils.GormDateStrToDateStr(m.EndDate)
-	return
-}
+// func (m *BaseFromUsdaFasIndex) AfterFind(db *gorm.DB) (err error) {
+// 	m.StartDate = utils.GormDateStrToDateStr(m.StartDate)
+// 	m.EndDate = utils.GormDateStrToDateStr(m.EndDate)
+// 	return
+// }
 
 // BaseFromUsdaFasClassify UsdaFas原始数据分类表
 type BaseFromUsdaFasClassify struct {

services/sync_hz_data.go

@@ -46,135 +46,172 @@ func SyncHzDataIndex(cont context.Context) (err error) {
 	//}
 
 	//欧洲天然气
-	err = SyncRankingFromEic()
-	if err != nil {
-		fmt.Println("SyncRankingFromEic Err:" + err.Error())
-		return
-	}
+	go func() {
+		err = SyncRankingFromEic()
+		if err != nil {
+			utils.FileLog.Info("SyncRankingFromEic Err:" + err.Error())
+			fmt.Println("SyncRankingFromEic Err:" + err.Error())
+			return
+		}
+	}()
 
 	//谷歌出行数据
-	err = SyncChangesVisitorsCovid()
-	if err != nil {
-		fmt.Println("SyncChangesVisitorsCovid Err:" + err.Error())
-		return
-	}
+	go func() {
+		err = SyncChangesVisitorsCovid()
+		if err != nil {
+			utils.FileLog.Info("SyncChangesVisitorsCovid Err:" + err.Error())
+			fmt.Println("SyncChangesVisitorsCovid Err:" + err.Error())
+			return
+		}
+	}()
 
 	// EiaSteo
-	err = SyncEiaSteoClassify()
-	if err != nil {
-		fmt.Println("SyncEiaSteoClassify Err:" + err.Error())
-		return
-	}
-	err = SyncEiaSteoIndex()
-	if err != nil {
-		fmt.Println("SyncEiaSteoIndex Err:" + err.Error())
-		return
-	}
+	go func() {
+		err = SyncEiaSteoClassify()
+		if err != nil {
+			utils.FileLog.Info("SyncEiaSteoClassify Err:" + err.Error())
+			fmt.Println("SyncEiaSteoClassify Err:" + err.Error())
+			//return
+		}
+		err = SyncEiaSteoIndex()
+		if err != nil {
+			utils.FileLog.Info("SyncEiaSteoIndex Err:" + err.Error())
+			fmt.Println("SyncEiaSteoIndex Err:" + err.Error())
+			//return
+		}
+
+		//EiaSteo
+		err = SyncEiaSteoIndexDataV2()
+		if err != nil {
+			utils.FileLog.Info("SyncEiaSteoIndexDataV2 Err:" + err.Error())
+			fmt.Println("SyncEiaSteoIndexDataV2 Err:" + err.Error())
+			return
+		}
+	}()
 
 	// UN联合国数据
-	err = SyncComTradeIndex()
-	if err != nil {
-		fmt.Println("SyncComTradeIndexAndData Err:" + err.Error())
-		return
-	}
+	go func() {
+		err = SyncComTradeIndex()
+		if err != nil {
+			utils.FileLog.Info("SyncComTradeIndexAndData Err:" + err.Error())
+			fmt.Println("SyncComTradeIndexAndData Err:" + err.Error())
+			return
+		}
+	}()
 
 	// 美联储加息概率
-	err = SyncMeetingProbabilities()
-	if err != nil {
-		fmt.Println("SyncMeetingProbabilities Err:" + err.Error())
-		return
-	}
+	go func() {
+		err = SyncMeetingProbabilities()
+		if err != nil {
+			utils.FileLog.Info("SyncMeetingProbabilities Err:" + err.Error())
+			fmt.Println("SyncMeetingProbabilities Err:" + err.Error())
+			return
+		}
+	}()
 
 	//广期所
-	{
+	go func() {
 		//分类信息
 		err = SyncFromGuangzhouClassify()
 		if err != nil {
+			utils.FileLog.Info("SyncFromGuangzhouClassify Err:" + err.Error())
 			fmt.Println("SyncFromGuangzhouClassify Err:" + err.Error())
-			return
+			//return
 		}
 		//合约信息
 		err = SyncFromGuangzhouContract()
 		if err != nil {
+			utils.FileLog.Info("SyncFromGuangzhouContract Err:" + err.Error())
 			fmt.Println("SyncFromGuangzhouContract Err:" + err.Error())
-			return
+			//return
 		}
 		//指标信息
 		err = SyncFromGuangzhouIndex()
 		if err != nil {
+			utils.FileLog.Info("SyncFromGuangzhouIndex Err:" + err.Error())
 			fmt.Println("SyncFromGuangzhouIndex Err:" + err.Error())
-			return
+			//return
 		}
 		//数据
 		err = SyncFromGuangzhouTradeData()
 		if err != nil {
+			utils.FileLog.Info("SyncFromGuangzhouTradeData Err:" + err.Error())
 			fmt.Println("SyncFromGuangzhouTradeData Err:" + err.Error())
 			return
 		}
-	}
+	}()
 
 	//ICPI
-	{
+	go func() {
 		//分类信息
 		err = SyncBaseFromIcpiClassify()
 		if err != nil {
+			utils.FileLog.Info("SyncBaseFromIcpiClassify Err:" + err.Error())
 			fmt.Println("SyncBaseFromIcpiClassify Err:" + err.Error())
-			return
+			//return
 		}
 		//指标信息
 		err = SyncBaseFromIcpi()
 		if err != nil {
+			utils.FileLog.Info("SyncBaseFromIcpi Err:" + err.Error())
 			fmt.Println("SyncBaseFromIcpi Err:" + err.Error())
-			return
+			//return
 		}
 		err = SyncBaseFromIcpiData()
 		if err != nil {
+			utils.FileLog.Info("SyncBaseFromIcpiData Err:" + err.Error())
 			fmt.Println("SyncBaseFromIcpiData Err:" + err.Error())
 			return
 		}
-	}
+	}()
 
 	//美国农业部
-	{
+	go func() {
 		//分类信息
 		err = SyncBaseFromUsdaFasClassify()
 		if err != nil {
+			utils.FileLog.Info("SyncBaseFromUsdaFasClassify Err:" + err.Error())
 			fmt.Println("SyncBaseFromUsdaFasClassify Err:" + err.Error())
-			return
+			//return
 		}
 		//指标信息
 		err = SyncBaseFromUsdaFas()
 		if err != nil {
+			utils.FileLog.Info("SyncBaseFromUsdaFas Err:" + err.Error())
 			fmt.Println("SyncBaseFromUsdaFas Err:" + err.Error())
-			return
+			//return
 		}
 		err = SyncBaseFromUsdaFasData()
 		if err != nil {
+			utils.FileLog.Info("SyncBaseFromUsdaFasData Err:" + err.Error())
 			fmt.Println("SyncBaseFromUsdaFasData Err:" + err.Error())
-			return
+			//return
 		}
-	}
+	}()
 
 	//GPR地缘风险指数
-	{
+	go func() {
 		//分类信息
 		err = SyncBaseFromGprRiskClassify()
 		if err != nil {
+			utils.FileLog.Info("SyncBaseFromGprRiskClassify Err:" + err.Error())
 			fmt.Println("SyncBaseFromGprRiskClassify Err:" + err.Error())
-			return
+			//return
 		}
 		//指标信息
 		err = SyncBaseFromGprRisk()
 		if err != nil {
+			utils.FileLog.Info("SyncBaseFromGprRisk Err:" + err.Error())
 			fmt.Println("SyncBaseFromGprRisk Err:" + err.Error())
-			return
+			//return
 		}
 		err = SyncBaseFromGprRiskData()
 		if err != nil {
+			utils.FileLog.Info("SyncBaseFromGprRiskData Err:" + err.Error())
 			fmt.Println("SyncBaseFromGprRiskData Err:" + err.Error())
-			return
+			//return
 		}
-	}
+	}()
 
 	// 同步指标数据
 	SyncHzDataIndexData()
@@ -186,21 +223,13 @@ func SyncHzDataIndex(cont context.Context) (err error) {
 // SyncHzDataIndexData 同步指标数据
 func SyncHzDataIndexData() {
 	var err error
-	//EiaSteo
-	err = SyncEiaSteoIndexDataV2()
-	if err != nil {
-		fmt.Println("SyncEiaSteoIndexDataV2 Err:" + err.Error())
-		utils.FileLog.Info("SyncEiaSteoIndexDataV2 Err:" + err.Error())
-		return
-	}
-
 	// 同步un数据
 	err = SyncComTradeData()
 	if err != nil {
+		utils.FileLog.Info("SyncComTradeData Err:" + err.Error())
 		fmt.Println("SyncComTradeData Err:" + err.Error())
 		return
 	}
-
 	//
 	fmt.Println(err)
 }

services/usda_fas.go

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