From e8bfe39dac6dfd943381177ee7c9b62b0ac202ca Mon Sep 17 00:00:00 2001
From: yanweidong <david.yan>
Date: Mon, 26 Jan 2026 23:55:26 +0800
Subject: [PATCH] dev cron

---
 go.mod                |  1 +
 go.sum                |  2 ++
 internal/cron/boot.go | 20 ++++++++++++++++----
 3 files changed, 19 insertions(+), 4 deletions(-)

diff --git a/go.mod b/go.mod
index 5a80a0d..4ac0a94 100644
--- a/go.mod
+++ b/go.mod
@@ -51,6 +51,7 @@ require (
 	github.com/quic-go/qpack v0.6.0 // indirect
 	github.com/quic-go/quic-go v0.59.0 // indirect
 	github.com/redis/go-redis/v9 v9.17.2 // indirect
+	github.com/robfig/cron/v3 v3.0.1
 	github.com/skip2/go-qrcode v0.0.0-20200617195104-da1b6568686e // indirect
 	github.com/twitchyliquid64/golang-asm v0.15.1 // indirect
 	github.com/ugorji/go/codec v1.3.1 // indirect
diff --git a/go.sum b/go.sum
index d4f3fda..64af219 100644
--- a/go.sum
+++ b/go.sum
@@ -112,6 +112,8 @@ github.com/quic-go/quic-go v0.59.0 h1:OLJkp1Mlm/aS7dpKgTc6cnpynnD2Xg7C1pwL6vy/SA
 github.com/quic-go/quic-go v0.59.0/go.mod h1:upnsH4Ju1YkqpLXC305eW3yDZ4NfnNbmQRCMWS58IKU=
 github.com/redis/go-redis/v9 v9.17.2 h1:P2EGsA4qVIM3Pp+aPocCJ7DguDHhqrXNhVcEp4ViluI=
 github.com/redis/go-redis/v9 v9.17.2/go.mod h1:u410H11HMLoB+TP67dz8rL9s6QW2j76l0//kSOd3370=
+github.com/robfig/cron/v3 v3.0.1 h1:WdRxkvbJztn8LMz/QEvLN5sBU+xKpSqwwUO1Pjr4qDs=
+github.com/robfig/cron/v3 v3.0.1/go.mod h1:eQICP3HwyT7UooqI/z+Ov+PtYAWygg1TEWWzGIFLtro=
 github.com/rogpeppe/go-internal v1.14.1 h1:UQB4HGPB6osV0SQTLymcB4TgvyWu6ZyliaW0tI/otEQ=
 github.com/rogpeppe/go-internal v1.14.1/go.mod h1:MaRKkUm5W0goXpeCfT7UZI6fk/L7L7so1lCWt35ZSgc=
 github.com/skip2/go-qrcode v0.0.0-20200617195104-da1b6568686e h1:MRM5ITcdelLK2j1vwZ3Je0FKVCfqOLp5zO6trqMLYs0=
diff --git a/internal/cron/boot.go b/internal/cron/boot.go
index 599c045..a9c28fa 100644
--- a/internal/cron/boot.go
+++ b/internal/cron/boot.go
@@ -1,15 +1,27 @@
 package cron
 
-import "git.apinb.com/dataset/stock/internal/logic/a"
+import (
+	"git.apinb.com/dataset/stock/internal/logic/a"
+	"github.com/robfig/cron/v3"
+)
 
 func Boot() {
+	scheduler := cron.New()
+	// 每天运行3次来更新数据
+	scheduler.AddFunc("* 1,20,22 * * *", func() {
+		updateTask()
+	})
+	scheduler.Start()
+}
+
+func updateTask() {
 	a.NewApiClient()
 	// 获取股票列表
-	//a.GetStockBasic()
+	a.GetStockBasic()
 	// 获取股票日线
-	//a.GetStockDaily()
+	a.GetStockDaily()
 	// 获取股票指标
-	//a.GetStockIndicator()
+	a.GetStockIndicator()
 	// 获取股票财务指标数据
 	a.GetFinaIndicator()
 }