fix bug

services/task.go

@@ -5,7 +5,6 @@ import (
 	"fmt"
 	"github.com/beego/beego/v2/task"
 	"hongze/hongze_task_trial/services/data"
-	"hongze/hongze_task_trial/services/data/future_good"
 	"hongze/hongze_task_trial/utils"
 	"sync"
 	"time"
@@ -17,11 +16,7 @@ func Task() {
 	if utils.RunMode == "release" {
 		releaseTask()
 	}
-
 	task.StartTask()
-
-	ctx := new(context.Context)
-	RefreshData(*ctx)
 	fmt.Println("task end")
 }
 
@@ -33,7 +28,7 @@ func releaseTask() {
 	task.AddTask("syncHzDataIndex", syncHzDataIndex)
 
 	//刷新指标数据
-	refreshData := task.NewTask("refreshData", "0 1 0,19 * * *", RefreshData)
+	refreshData := task.NewTask("refreshData", "0 30 0,19 * * *", RefreshData)
 	task.AddTask("refreshData", refreshData)
 
 	syncBaseDataExt := task.NewTask("syncBaseDataExt", "0 */30 * * * * ", SyncBaseDataExt)
@@ -45,6 +40,7 @@ func releaseTask() {
 }
 
 func RefreshData(cont context.Context) (err error) {
+	fmt.Println("Refresh Start")
 	wg := sync.WaitGroup{}
 	wg.Add(6)
 	//同花顺
@@ -64,13 +60,12 @@ func RefreshData(cont context.Context) (err error) {
 	data.RefreshDataFromCalculateAll()
 	// 预测计算指标
 	data.RefreshPredictDataFromCalculateAll()
-	time.Sleep(5 * time.Second)
-	data.RefreshNotice()
-	// 刷新商品期货数据
-	{
-		future_good.RefreshFutureGoodDataFromThs()
-	}
-
+	//time.Sleep(5 * time.Second)
+	//
+	//// 刷新商品期货数据
+	//{
+	//	future_good.RefreshFutureGoodDataFromThs()
+	//}
 	fmt.Println("Refresh End")
 	return
 }