github/injoyai-tdx
1
0
Fork 0
mirror of https://github.com/injoyai/tdx.git synced 2025-11-26 21:25:35 +08:00
Code Issues Packages Projects Releases Wiki Activity

优化

Browse Source
This commit is contained in:
钱纯净
2024-10-30 22:45:06 +08:00
parent 4b091bf3ff
commit 749373fbc4
1 changed files with 12 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
client.go
View File

@@ -234,12 +234,12 @@ func (this *Client) GetStockMinuteTradeAll(exchange protocol.Exchange, code stri
resp := &protocol.StockMinuteTradeResp{} resp := &protocol.StockMinuteTradeResp{}
size := uint16(1800) size := uint16(1800)
for i := uint16(0); ; i += size { for i := uint16(0); ; i += size {
r, err := this.GetStockMinuteTrade(exchange, code, i, i+size) r, err := this.GetStockMinuteTrade(exchange, code, i, size)
if err != nil { if err != nil {
return nil, err return nil, err
} }
resp.Count += r.Count resp.Count += r.Count
resp.List = append(resp.List, r.List...) resp.List = append(r.List, resp.List...)
if r.Count < size { if r.Count < size {
break break
@@ -269,7 +269,7 @@ func (this *Client) GetStockHistoryMinuteTradeAll(exchange protocol.Exchange, co
resp := &protocol.StockMinuteTradeResp{} resp := &protocol.StockMinuteTradeResp{}
size := uint16(2000) size := uint16(2000)
for i := uint16(0); ; i += size { for i := uint16(0); ; i += size {
r, err := this.GetStockMinuteTrade(exchange, code, i, i+size) r, err := this.GetStockMinuteTrade(exchange, code, i, size)
if err != nil { if err != nil {
return nil, err return nil, err
} }
@@ -299,18 +299,25 @@ func (this *Client) GetStockKline(Type protocol.TypeKline, req *protocol.StockKl
func (this *Client) GetStockKlineAll(Type protocol.TypeKline, exchange protocol.Exchange, code string) (*protocol.StockKlineResp, error) { func (this *Client) GetStockKlineAll(Type protocol.TypeKline, exchange protocol.Exchange, code string) (*protocol.StockKlineResp, error) {
resp := &protocol.StockKlineResp{} resp := &protocol.StockKlineResp{}
size := uint16(800) size := uint16(800)
var last *protocol.StockKline
for i := uint16(0); ; i += size { for i := uint16(0); ; i += size {
r, err := this.GetStockKline(Type, &protocol.StockKlineReq{ r, err := this.GetStockKline(Type, &protocol.StockKlineReq{
Exchange: exchange, Exchange: exchange,
Code: code, Code: code,
Start: i, Start: i,
Count: i + size, Count: size,
}) })
if err != nil { if err != nil {
return nil, err return nil, err
} }
if last != nil && len(r.List) > 0 {
last.Last = r.List[len(r.List)-1].Close
}
if len(r.List) > 0 {
last = r.List[0]
}
resp.Count += r.Count resp.Count += r.Count
resp.List = append(resp.List, r.List...) resp.List = append(r.List, resp.List...)
if r.Count < size { if r.Count < size {
break break
} }