Răsfoiți Sursa

增加sleep时间

ziwen 3 ani în urmă
părinte
comite
e84acd20c2

+ 2 - 0
services/commodity_trade_cffex.go

@@ -50,6 +50,8 @@ func cffexIndexCodeGenerator(shortName, indexName, suffix string) string {
 
 
 // SyncRankingFromCffex 中国金融期货交易所
 // SyncRankingFromCffex 中国金融期货交易所
 func SyncRankingFromCffex() {
 func SyncRankingFromCffex() {
+	n := utils.GetRandInt(10, 120)
+	time.Sleep(time.Duration(n) * time.Second)
 	allCode, err := models.GetIndexCodeFromMapping("CFFEX")
 	allCode, err := models.GetIndexCodeFromMapping("CFFEX")
 	if err != nil {
 	if err != nil {
 		fmt.Println("select Code err:", err)
 		fmt.Println("select Code err:", err)

+ 2 - 0
services/commodity_trade_ine.go

@@ -62,6 +62,8 @@ func IneIndexCodeGenerator(shortName, indexName,suffix string) string {
 
 
 // SyncRankingFromIne 上海能源交易中心持单排名
 // SyncRankingFromIne 上海能源交易中心持单排名
 func SyncRankingFromIne() {
 func SyncRankingFromIne() {
+	n := utils.GetRandInt(10, 120)
+	time.Sleep(time.Duration(n) * time.Second)
 	allCode, err := models.GetIndexCodeFromMapping("Ine")
 	allCode, err := models.GetIndexCodeFromMapping("Ine")
 	if err != nil {
 	if err != nil {
 		fmt.Println("select Code err:", err)
 		fmt.Println("select Code err:", err)

+ 2 - 0
services/commodity_trade_shanghai.go

@@ -62,6 +62,8 @@ func shIndexCodeGenerator(shortName, indexName,suffix string) string {
 
 
 // SyncRankingFromShangHai 上海商品交易所持单排名
 // SyncRankingFromShangHai 上海商品交易所持单排名
 func SyncRankingFromShangHai() {
 func SyncRankingFromShangHai() {
+	n := utils.GetRandInt(10, 120)
+	time.Sleep(time.Duration(n) * time.Second)
 	allCode, err := models.GetIndexCodeFromMapping("Z")
 	allCode, err := models.GetIndexCodeFromMapping("Z")
 	if err != nil {
 	if err != nil {
 		fmt.Println("select Code err:", err)
 		fmt.Println("select Code err:", err)

+ 2 - 0
services/commodity_trade_zhengzhou.go

@@ -36,6 +36,8 @@ func zIndexCodeGenerator(shortName, indexName,suffix string) string {
 
 
 //郑州商品交易所持单排名
 //郑州商品交易所持单排名
 func SyncRankingFromZhengzhou() {
 func SyncRankingFromZhengzhou() {
+	n := utils.GetRandInt(10, 120)
+	time.Sleep(time.Duration(n) * time.Second)
 	fmt.Println("start")
 	fmt.Println("start")
 	var err error
 	var err error
 	defer func() {
 	defer func() {