Merge branch 'dalian'

services/sync_hz_data.go

@@ -18,7 +18,7 @@ func SyncHzDataIndex(cont context.Context) (err error) {
 	//}
 
 	//大商所
-	go SyncRankingFromDalian()
+	//go SyncRankingFromDalian()
 	//if err != nil {
 	//	fmt.Println("SyncRankingFromDalian Err:" + err.Error())
 	//	return

services/task.go

@@ -39,6 +39,9 @@ func releaseTask() {
 	if utils.BusinessCode != utils.BusinessCodeRelease {
 		syncHzDataIndex := task.NewTask("syncHzDataIndex", "0 10,20,40,50 16,18 * * *", SyncHzDataIndex)
 		task.AddTask("syncHzDataIndex", syncHzDataIndex)
+
+		syncRankingFromDalian := task.NewTask("syncRankingFromDalian", "0 30,40,50 16,18 * * *", SyncRankingFromDalian)
+		task.AddTask("syncRankingFromDalian", syncRankingFromDalian)
 	}
 	// 定时统计交易所的持仓分析数据
 	initPositionTask := task.NewTask("initPositionTask", "0 20,40 16-18 * * *", data.InitPositionTask)

services/trade_dalian.go

@@ -1,6 +1,7 @@
 package services
 
 import (
+	"context"
 	"encoding/json"
 	"eta/eta_task/models/data_manage"
 	"eta/eta_task/utils"
@@ -9,7 +10,7 @@ import (
 )
 
 // 大连商品交易所持单排名
-func SyncRankingFromDalian() (err error) {
+func SyncRankingFromDalian(cont context.Context) (err error) {
 	var startDate string
 	maxDate, err := data_manage.GetBaseFromTradeDalianIndexMaxDate()
 	if err != nil || maxDate.IsZero() {