From 0a1a6194afec4242e8f5dc72b78707d73de800a5 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E9=92=B1=E7=BA=AF=E5=87=80?= <1113655791@qq.com> Date: Sun, 24 Aug 2025 20:20:53 +0800 Subject: [PATCH] =?UTF-8?q?=E5=8D=87=E7=BA=A7=E5=BC=95=E7=94=A8=E5=BA=93?= =?UTF-8?q?=E7=89=88=E6=9C=AC?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- extend/pull-kline-mysql.go | 2 +- extend/pull-kline.go | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/extend/pull-kline-mysql.go b/extend/pull-kline-mysql.go index 81a0220..e2a36c0 100644 --- a/extend/pull-kline-mysql.go +++ b/extend/pull-kline-mysql.go @@ -43,7 +43,7 @@ func (this *PullKlineMysql) Name() string { } func (this *PullKlineMysql) Run(ctx context.Context, m *tdx.Manage) error { - limit := chans.NewWaitLimit(uint(this.Config.Limit)) + limit := chans.NewWaitLimit(this.Config.Limit) //1. 获取所有股票代码 codes := this.Config.Codes diff --git a/extend/pull-kline.go b/extend/pull-kline.go index 0b721e3..067746b 100644 --- a/extend/pull-kline.go +++ b/extend/pull-kline.go @@ -105,7 +105,7 @@ func (this *PullKline) DayKlines(code string) (Klines, error) { } func (this *PullKline) Run(ctx context.Context, m *tdx.Manage) error { - limit := chans.NewWaitLimit(uint(this.Config.Limit)) + limit := chans.NewWaitLimit(this.Config.Limit) //1. 获取所有股票代码 codes := this.Config.Codes