From 6b0f2b80d7c65fd21daaa0130c1f1db685b890f1 Mon Sep 17 00:00:00 2001 From: c9s Date: Fri, 23 Oct 2020 00:21:03 +0800 Subject: [PATCH] add multiple spec support --- cmd/run.go | 3 ++- pkg/bbgo/trader.go | 10 ++++++---- 2 files changed, 8 insertions(+), 5 deletions(-) diff --git a/cmd/run.go b/cmd/run.go index 6c4066928..43979997b 100644 --- a/cmd/run.go +++ b/cmd/run.go @@ -83,7 +83,8 @@ var runCmd = &cobra.Command{ } trader.ReportPnL(notifier). - AverageCostBySymbols("BTCUSDT", "BNBUSDT").Of("max", "binance") + AverageCostBySymbols("BTCUSDT", "BNBUSDT"). + Of("max", "binance").When("@daily", "@hourly") err = trader.Run(ctx) if err != nil { diff --git a/pkg/bbgo/trader.go b/pkg/bbgo/trader.go index 78fcfcd46..b874e1fa8 100644 --- a/pkg/bbgo/trader.go +++ b/pkg/bbgo/trader.go @@ -81,10 +81,12 @@ func (reporter *AverageCostPnLReporter) Of(sessions ...string) *AverageCostPnLRe return reporter } -func (reporter *AverageCostPnLReporter) When(spec string) *AverageCostPnLReporter { - _, err := reporter.cron.AddJob(spec, reporter) - if err != nil { - panic(err) +func (reporter *AverageCostPnLReporter) When(specs ...string) *AverageCostPnLReporter { + for _,spec := range specs { + _, err := reporter.cron.AddJob(spec, reporter) + if err != nil { + panic(err) + } } return reporter