lychiyu/bbgo_origin
1
0
Fork 0
mirror of https://github.com/c9s/bbgo.git synced 2024-09-20 08:11:08 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

trade: query trades from db paginately

Browse Source
This commit is contained in:
Yu-Cheng 2023-10-31 12:36:59 +08:00
parent 3491b93c53
commit 1d2e46eca8
1 changed files with 15 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
pkg/service/trade.go
View File

@ -23,7 +23,12 @@ type QueryTradesOptions struct {
Sessions []string
Symbol string
LastGID int64
Since *time.Time
// inclusive
Since *time.Time
// exclusive
Until *time.Time
// ASC or DESC
Ordering string
@ -272,11 +277,19 @@ func (s *TradeService) Query(options QueryTradesOptions) ([]types.Trade, error)
sel := sq.Select("*").
From("trades")
if options.LastGID != 0 {
sel = sel.Where(sq.Gt{"gid": options.LastGID})
}
if options.Since != nil {
sel = sel.Where(sq.GtOrEq{"traded_at": options.Since})
}
if options.Until != nil {
sel = sel.Where(sq.Lt{"traded_at": options.Until})
}
sel = sel.Where(sq.Eq{"symbol": options.Symbol})
if options.Symbol != "" {
sel = sel.Where(sq.Eq{"symbol": options.Symbol})
}
if options.Exchange != "" {
sel = sel.Where(sq.Eq{"exchange": options.Exchange})
@ -412,4 +425,3 @@ func SelectLastTrades(ex types.ExchangeName, symbol string, isMargin, isFutures,
OrderBy("traded_at DESC").
Limit(limit)
}