From f4ebae17bb150e091492c1650788126d85056961 Mon Sep 17 00:00:00 2001 From: c9s Date: Fri, 7 Jan 2022 13:13:22 +0800 Subject: [PATCH] xmaker: when recover the trade, notify --- pkg/strategy/xmaker/strategy.go | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/pkg/strategy/xmaker/strategy.go b/pkg/strategy/xmaker/strategy.go index 4e0a53684..a1ba5bff6 100644 --- a/pkg/strategy/xmaker/strategy.go +++ b/pkg/strategy/xmaker/strategy.go @@ -832,7 +832,9 @@ func (s *Strategy) CrossRun(ctx context.Context, orderExecutionRouter bbgo.Order } else { for _, td := range trades { log.Infof("processing trade: %s", td.String()) - s.tradeCollector.ProcessTrade(td) + if s.tradeCollector.ProcessTrade(td) { + s.Notifiability.Notify("recovered trade", td) + } } }