diff --git a/cmd/test/main.go b/cmd/test/main.go index 0c8f2eb..cad0642 100644 --- a/cmd/test/main.go +++ b/cmd/test/main.go @@ -9,7 +9,7 @@ import ( func main() { a.NewApiClient() - reply, err := a.SetFinaIndicator("000012.SZ", "20230101") + reply, err := a.SetFinaIndicator("000029.SZ", "20230331") fmt.Println("Err", err) jsonBytes, _ := json.Marshal(reply.Data.Items) fmt.Println("Reply", string(jsonBytes)) diff --git a/internal/logic/a/fina_indicator.go b/internal/logic/a/fina_indicator.go index b530546..cf0eacf 100644 --- a/internal/logic/a/fina_indicator.go +++ b/internal/logic/a/fina_indicator.go @@ -67,6 +67,12 @@ func ReFinaIndicator(in *tushare.APIResponse) (bool, map[string]any) { func GetFinaIndicator() { for _, code := range GetStockCodes() { + var fCnt int64 + impl.DBService.Model(&models.StockFinaIndicator{}).Where("ts_code=?", code).Count(&fCnt) + if fCnt >= 11 { + continue + } + for _, period := range PeriodArgs { // 请求API reply, err := SetFinaIndicator(code, period)