fix bug
This commit is contained in:
21
cmd/readd/main.go
Normal file
21
cmd/readd/main.go
Normal file
@@ -0,0 +1,21 @@
|
||||
package main
|
||||
|
||||
import (
|
||||
"git.apinb.com/dataset/stock/internal/config"
|
||||
"git.apinb.com/dataset/stock/internal/cron"
|
||||
"git.apinb.com/dataset/stock/internal/impl"
|
||||
)
|
||||
|
||||
var (
|
||||
ServiceKey = "stock"
|
||||
)
|
||||
|
||||
func main() {
|
||||
// 配置初始化
|
||||
config.New(ServiceKey)
|
||||
|
||||
// 创建实现层
|
||||
impl.NewImpl()
|
||||
|
||||
cron.UpdateTask()
|
||||
}
|
||||
@@ -14,15 +14,18 @@ func Boot() {
|
||||
os.MkdirAll("./markdata/", 0755)
|
||||
}
|
||||
|
||||
//首次先运行
|
||||
UpdateTask()
|
||||
|
||||
scheduler := cron.New()
|
||||
// 每天运行3次来更新数据
|
||||
scheduler.AddFunc("30 18 * * *", func() {
|
||||
updateTask()
|
||||
UpdateTask()
|
||||
})
|
||||
scheduler.Start()
|
||||
}
|
||||
|
||||
func updateTask() {
|
||||
func UpdateTask() {
|
||||
a.NewApiClient()
|
||||
// 获取股票列表
|
||||
a.GetStockBasic()
|
||||
|
||||
Reference in New Issue
Block a user