diff --git a/cmd/test/main.go b/cmd/test/main.go index 73ed107..548dfd4 100644 --- a/cmd/test/main.go +++ b/cmd/test/main.go @@ -1,6 +1,7 @@ package main import ( + "fmt" "log" "time" @@ -23,7 +24,7 @@ func main() { impl.NewImpl() a.NewApiClient() - code := "002463.SZ" + code := "300541.SZ" end := time.Now().Format("20060102") var start string = "20230101" @@ -38,6 +39,7 @@ func main() { "end_date": end, } + log.Println("GetStockDaily", code, start, end) fields := []string{} reply, err := a.TushareClient.Daily(params, fields) if err != nil { @@ -72,6 +74,7 @@ func main() { } if len(records) > 0 { - impl.DBService.CreateInBatches(records, 100) + fmt.Println("Created", len(records)) + //impl.DBService.CreateInBatches(records, 100) } } diff --git a/internal/cron/boot.go b/internal/cron/boot.go index ac662c0..67a5686 100644 --- a/internal/cron/boot.go +++ b/internal/cron/boot.go @@ -14,6 +14,8 @@ func Boot() { os.MkdirAll("./markdata/", 0755) } + UpdateTask() + scheduler := cron.New() // 每天运行3次来更新数据 scheduler.AddFunc("0 18 * * *", func() { diff --git a/internal/logic/a/daily.go b/internal/logic/a/daily.go index 76fcd37..f3fbd3b 100644 --- a/internal/logic/a/daily.go +++ b/internal/logic/a/daily.go @@ -1,6 +1,7 @@ package a import ( + "encoding/json" "log" "time" @@ -32,7 +33,13 @@ func GetStockDaily() { reply, err := TushareClient.Daily(params, fields) if err != nil { log.Println("ERROR", "GetStockDaily", err) - return + continue + } + + if len(reply.Data.Items) == 0 { + json, _ := json.Marshal(reply) + log.Println("ERROR", "GetStockDailyReply", string(json)) + continue } records := make([]*models.StockDaily, 0) @@ -65,7 +72,7 @@ func GetStockDaily() { impl.DBService.CreateInBatches(records, 50) } - time.Sleep(200 * time.Microsecond) + time.Sleep(200 * time.Millisecond) } diff --git a/internal/logic/a/fina_indicator.go b/internal/logic/a/fina_indicator.go index 2477fcf..2d9d848 100644 --- a/internal/logic/a/fina_indicator.go +++ b/internal/logic/a/fina_indicator.go @@ -95,7 +95,7 @@ func GetFinaIndicator() { } } - time.Sleep(200 * time.Microsecond) + time.Sleep(200 * time.Millisecond) } } diff --git a/internal/logic/a/indicator.go b/internal/logic/a/indicator.go index 7fc13c8..c575a47 100644 --- a/internal/logic/a/indicator.go +++ b/internal/logic/a/indicator.go @@ -73,6 +73,6 @@ func GetStockIndicator() { impl.DBService.CreateInBatches(records, 100) } - time.Sleep(200 * time.Microsecond) + time.Sleep(200 * time.Millisecond) } }