dev cron

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

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=

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()
 }