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: supertrend strategy control

Browse Source
This commit is contained in:
Andy Cheng 2022-05-30 16:35:10 +08:00
parent 44469ed3aa
commit 756284378b
1 changed files with 19 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -207,6 +207,9 @@ func (s *Strategy) ClosePosition(ctx context.Context, percentage fixedpoint.Valu
}
s.orderStore.Add(createdOrders...)
s.tradeCollector.Process()
return err
}
@ -291,10 +294,26 @@ func (s *Strategy) Run(ctx context.Context, orderExecutor bbgo.OrderExecutor, se
// StrategyController
s.Status = types.StrategyStatusRunning
s.OnSuspend(func() {
_ = s.Persistence.Sync(s)
})
s.OnEmergencyStop(func() {
// Close 100% position
_ = s.ClosePosition(ctx, fixedpoint.NewFromFloat(1.0))
_ = s.Persistence.Sync(s)
})
// Setup indicators
s.SetupIndicators()
session.MarketDataStream.OnKLineClosed(func(kline types.KLine) {
// StrategyController
if s.Status != types.StrategyStatusRunning {
return
}
// skip k-lines from other symbols or other intervals
if kline.Symbol != s.Symbol || kline.Interval != s.Interval {
return
@ -355,7 +374,6 @@ func (s *Strategy) Run(ctx context.Context, orderExecutor bbgo.OrderExecutor, se
s.orderStore.Add(order...)
}
// check if there is a canceled order had partially filled.
s.tradeCollector.Process()
})