From cf2cc18a78cb6397649f2aea5e115ea4f9800c45 Mon Sep 17 00:00:00 2001
From: "zhangkun9038@dingtalk.com" <zhangkun9038@dingtalk.com>
Date: Sat, 21 Dec 2024 23:59:45 +0800
Subject: [PATCH] stock rsi push to elasticsearch
---
modules/extent.go | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
diff --git a/modules/extent.go b/modules/extent.go
index 8b176b7..ed1c701 100644
--- a/modules/extent.go
+++ b/modules/extent.go
@@ -289,7 +289,7 @@ func MakeRsi(cr *core.Core, cl *core.Candle, count int) (error, int) {
cdl.RecursiveBubbleS(len(cdl.List), "asc")
closeList := []float64{}
ll := len(cdl.List)
- fmt.Println("candleList for rsi cal len:", ll)
+ fmt.Println("candleList len:", ll)
for k, v := range cdl.List {
fmt.Println("candle in list", ll, k, v)
closeList = append(closeList, ToFloat64(v.Data[4]))
@@ -316,6 +316,7 @@ func MakeRsi(cr *core.Core, cl *core.Candle, count int) (error, int) {
rsi.Confirm = true
}
go func() {
+ fmt.Println("make a rsi")
cr.RsiProcessChan <- &rsi
}()
@@ -337,6 +338,7 @@ func MakeRsi(cr *core.Core, cl *core.Candle, count int) (error, int) {
Confirm: true,
}
go func() {
+ fmt.Println("make a stockrsi")
cr.StockRsiProcessChan <- &srsi
}()