From 43b8884ea5063f67bb5e79ceb9f682ebef9c2262 Mon Sep 17 00:00:00 2001 From: "zhangkun9038@dingtalk.com" Date: Sat, 21 Dec 2024 23:23:28 +0800 Subject: [PATCH] stock rsi push to elasticsearch --- modules/extent.go | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/modules/extent.go b/modules/extent.go index 5941d04..0b119bd 100644 --- a/modules/extent.go +++ b/modules/extent.go @@ -314,7 +314,9 @@ func MakeRsi(cr *core.Core, cl *core.Candle, count int) (error, int) { if duration > time.Duration(periodMins-1)*time.Minute { rsi.Confirm = true } - cr.RsiProcessChan <- &rsi + go func() { + cr.RsiProcessChan <- &rsi + }() percentK, percentD, err := CalculateStochRSI(rsiList, count, 3, 3) if err != nil { @@ -333,8 +335,10 @@ func MakeRsi(cr *core.Core, cl *core.Candle, count int) (error, int) { DVol: percentD[len(percentD)-1], Confirm: true, } + go func() { + cr.StockRsiProcessChan <- &srsi + }() - cr.StockRsiProcessChan <- &srsi return nil, 0 } func MakeMaX(cr *core.Core, cl *core.Candle, count int) (error, int) {