初始化广州期货交易所的数据

services/data/trade_position_analysis.go

@@ -107,10 +107,10 @@ func InitPositionTask(cont context.Context) (err error) {
 }
 
 // InitGuangzhouPositionTask 初始化广期所持仓分析排名情况
-func InitGuangzhouPositionTask() (err error) {
+func InitGuangzhouPositionTask(cont context.Context) (err error) {
 	//exchanges := []string{"zhengzhou", "dalian", "shanghai", "cffex", "ine", "guangzhou"} //郑商所，大商所，上期所，中金所，上期能源
 	exchanges := []string{"guangzhou"} //郑商所，大商所，上期所，中金所，上期能源
-	for i := 40; i >= 0; i-- {
+	for i := 15; i >= 0; i-- {
 		startDate := time.Now().AddDate(0, 0, -i).Format(utils.FormatDate)
 		endDate := startDate
 		for _, v := range exchanges {

services/task.go

@@ -42,6 +42,10 @@ func releaseTask() {
 	initPositionTask := task.NewTask("initPositionTask", "0 20,40 16-18 * * *", data.InitPositionTask)
 	task.AddTask("initPositionTask", initPositionTask)
 
+	// 定时统计交易所的持仓分析数据
+	initGuangzhouPositionTask := task.NewTask("initPositionTask", "0 30 19 29 4 *", data.InitGuangzhouPositionTask)
+	task.AddTask("initGuangzhouPositionTask", initGuangzhouPositionTask)
+
 	//刷新指标数据
 	refreshData := task.NewTask("refreshData", "0 30 0,19 * * *", RefreshData)
 	task.AddTask("refreshData", refreshData)