fix:商品数据调整

services/task.go

@@ -167,10 +167,14 @@ func releaseTask() {
 	incrementCompany := task.NewTask("incrementCompany", "0 0 9 * * 1 ", IncrementCompany)
 	task.AddTask("上周增量客户列表", incrementCompany)
 
-	//刷新指标数据
+	// 刷新指标数据
 	refreshData := task.NewTask("refreshData", "0 1 0,19 * * *", RefreshData)
 	task.AddTask("refreshData", refreshData)
 
+	// 刷新商品数据
+	refreshFutureGoodData := task.NewTask("refreshFutureGoodData", "0 30 0,19 * * *", RefreshFutureGoodData)
+	task.AddTask("refreshFutureGoodData", refreshFutureGoodData)
+
 	//刷新交易所指标数据
 	refreshTradeData := task.NewTask("refreshData", "0 1 4 * * *", RefreshTradeData)
 	task.AddTask("refreshTradeData", refreshTradeData)
@@ -297,6 +301,13 @@ func RefreshData(cont context.Context) (err error) {
 	return
 }
 
+// RefreshFutureGoodData 刷新商品数据
+func RefreshFutureGoodData(cont context.Context) (err error) {
+	future_good.RefreshFutureGoodDataFromThs()
+	fmt.Println("Refresh End")
+	return
+}
+
 // RefreshTradeData 刷新交易所数据
 func RefreshTradeData(cont context.Context) (err error) {
 	wg := sync.WaitGroup{}