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

fix: binance futures sync issue

Browse Source
This commit is contained in:
zenix 2022-05-09 15:04:51 +09:00
parent 3af08abef2
commit c81af9ce91
2 changed files with 12 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
pkg/cmd/sync.go
View File

@ -20,7 +20,7 @@ func init() {
} }
var SyncCmd = &cobra.Command{ var SyncCmd = &cobra.Command{
Use: "sync --session=[exchange_name] --symbol=[pair_name] [--since=yyyy/mm/dd]", Use: "sync [--session=[exchange_name]] [--symbol=[pair_name]] [[--since=yyyy/mm/dd]]",
Short: "sync trades and orders history", Short: "sync trades and orders history",
SilenceUsage: true, SilenceUsage: true,
RunE: func(cmd *cobra.Command, args []string) error { RunE: func(cmd *cobra.Command, args []string) error {

20
pkg/exchange/binance/exchange.go
View File

@ -1347,17 +1347,19 @@ func (e *Exchange) QueryTrades(ctx context.Context, symbol string, options *type
req.FromID(int64(options.LastTradeID)) req.FromID(int64(options.LastTradeID))
} }
if options.StartTime != nil && options.EndTime != nil { // The parameter fromId cannot be sent with startTime or endTime.
if options.EndTime.Sub(*options.StartTime) < 24*time.Hour { // Mentioned in binance futures docs
req.StartTime(options.StartTime.UnixMilli()) if options.LastTradeID <= 0 {
if options.StartTime != nil && options.EndTime != nil {
if options.EndTime.Sub(*options.StartTime) < 24*time.Hour {
req.StartTime(options.StartTime.UnixMilli())
req.EndTime(options.EndTime.UnixMilli())
} else {
req.StartTime(options.StartTime.UnixMilli())
}
} else if options.EndTime != nil {
req.EndTime(options.EndTime.UnixMilli()) req.EndTime(options.EndTime.UnixMilli())
} else {
req.StartTime(options.StartTime.UnixMilli())
} }
} else if options.StartTime != nil {
req.StartTime(options.StartTime.UnixMilli())
} else if options.EndTime != nil {
req.EndTime(options.EndTime.UnixMilli())
} }
remoteTrades, err = req.Do(ctx) remoteTrades, err = req.Do(ctx)