fix

services/sync_hz_data.go

@@ -11,39 +11,39 @@ import (
 func SyncHzDataIndex(cont context.Context) (err error) {
 	fmt.Println("SyncHzDataIndex start:", time.Now().Format(utils.FormatDateTime))
 	//郑州交易所
-	err = SyncRankingFromZhengzhou()
-	if err != nil {
-		fmt.Println("SyncRankingFromZhengzhou Err:" + err.Error())
-		return
-	}
+	go SyncRankingFromZhengzhou()
+	//if err != nil {
+	//	fmt.Println("SyncRankingFromZhengzhou Err:" + err.Error())
+	//	return
+	//}
 
 	//大商所
-	err = SyncRankingFromDalian()
-	if err != nil {
-		fmt.Println("SyncRankingFromDalian Err:" + err.Error())
-		return
-	}
+	go SyncRankingFromDalian()
+	//if err != nil {
+	//	fmt.Println("SyncRankingFromDalian Err:" + err.Error())
+	//	return
+	//}
 
 	//上期所
-	err = SyncRankingFromShanghai()
-	if err != nil {
-		fmt.Println("SyncRankingFromDalian Err:" + err.Error())
-		return
-	}
+	go SyncRankingFromShanghai()
+	//if err != nil {
+	//	fmt.Println("SyncRankingFromDalian Err:" + err.Error())
+	//	return
+	//}
 
 	//中金所
-	err = SyncRankingFromCffex()
-	if err != nil {
-		fmt.Println("SyncRankingFromCffex Err:" + err.Error())
-		return
-	}
+	go SyncRankingFromCffex()
+	//if err != nil {
+	//	fmt.Println("SyncRankingFromCffex Err:" + err.Error())
+	//	return
+	//}
 
 	//上期能源
-	err = SyncRankingFromIne()
-	if err != nil {
-		fmt.Println("SyncRankingFromIne Err:" + err.Error())
-		return
-	}
+	go SyncRankingFromIne()
+	//if err != nil {
+	//	fmt.Println("SyncRankingFromIne Err:" + err.Error())
+	//	return
+	//}
 
 	//欧洲天然气
 	err = SyncRankingFromEic()