From c91970f192b8fbe11552bafb2583edbf9445eaab Mon Sep 17 00:00:00 2001 From: "zhangkun9038@dingtalk.com" Date: Sun, 22 Dec 2024 00:07:30 +0800 Subject: [PATCH] stock rsi push to elasticsearch --- modules/extent.go | 2 ++ 1 file changed, 2 insertions(+) diff --git a/modules/extent.go b/modules/extent.go index 1567ff9..a3c577f 100644 --- a/modules/extent.go +++ b/modules/extent.go @@ -531,6 +531,7 @@ func RsisProcess(cr *core.Core) { for { rsi := <-cr.RsiProcessChan // logrus.Debug("mx: ", mx) + fmt.Println("rsi recieved:", rsi) go func(rsi *core.Rsi) { mrs := MyRsi{ Rsi: *rsi, @@ -544,6 +545,7 @@ func StockRsisProcess(cr *core.Core) { for { srsi := <-cr.StockRsiProcessChan // logrus.Debug("mx: ", mx) + fmt.Println("stockrsi recieved:", srsi) go func(srsi *core.StockRsi) { mrs := MyStockRsi{ StockRsi: *srsi,