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

strategy: Persistence.Sync() after position change

Browse Source
This commit is contained in:
Andy Cheng 2022-06-07 16:04:40 +08:00
parent bf385899b9
commit ee26d6ce34
1 changed files with 4 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
pkg/strategy/supertrend/strategy.go
View File

@ -221,6 +221,8 @@ func (s *Strategy) ClosePosition(ctx context.Context, percentage fixedpoint.Valu
s.tradeCollector.Process()
_ = s.Persistence.Sync(s)
return err
}
@ -291,7 +293,6 @@ func (s *Strategy) calculateQuantity(currentPrice fixedpoint.Value) fixedpoint.V
func (s *Strategy) Run(ctx context.Context, orderExecutor bbgo.OrderExecutor, session *bbgo.ExchangeSession) error {
s.session = session
s.Market, _ = session.Market(s.Symbol)
// If position is nil, we need to allocate a new position for calculation
if s.Position == nil {
@ -323,8 +324,6 @@ func (s *Strategy) Run(ctx context.Context, orderExecutor bbgo.OrderExecutor, se
if err := s.ClosePosition(ctx, fixedpoint.One); err != nil {
s.Notify("can not close position")
}
_ = s.Persistence.Sync(s)
})
// Setup indicators
@ -422,12 +421,6 @@ func (s *Strategy) Run(ctx context.Context, orderExecutor bbgo.OrderExecutor, se
}
}
// Update balance for exchanges like FTX, which doesn't update balances automatically
balances, err := s.session.Exchange.QueryAccountBalances(ctx)
if err != nil {
s.session.GetAccount().UpdateBalances(balances)
}
orderForm := s.generateOrderForm(side, s.calculateQuantity(kline.GetClose()), types.SideEffectTypeMarginBuy)
log.Infof("submit open position order %v", orderForm)
order, err := orderExecutor.SubmitOrders(ctx, orderForm)
@ -439,6 +432,8 @@ func (s *Strategy) Run(ctx context.Context, orderExecutor bbgo.OrderExecutor, se
}
s.tradeCollector.Process()
_ = s.Persistence.Sync(s)
}
})