phyer/siaga
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

stock rsi push to elasticsearch

Browse Source
This commit is contained in:
zhangkun9038@dingtalk.com 2024-12-21 23:59:45 +08:00
parent f76cd74808
commit cf2cc18a78
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
modules/extent.go
View File

@ -289,7 +289,7 @@ func MakeRsi(cr *core.Core, cl *core.Candle, count int) (error, int) {
cdl.RecursiveBubbleS(len(cdl.List), "asc") cdl.RecursiveBubbleS(len(cdl.List), "asc")
closeList := []float64{} closeList := []float64{}
ll := len(cdl.List) ll := len(cdl.List)
fmt.Println("candleList for rsi cal len:", ll) fmt.Println("candleList len:", ll)
for k, v := range cdl.List { for k, v := range cdl.List {
fmt.Println("candle in list", ll, k, v) fmt.Println("candle in list", ll, k, v)
closeList = append(closeList, ToFloat64(v.Data[4])) 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 rsi.Confirm = true
} }
go func() { go func() {
fmt.Println("make a rsi")
cr.RsiProcessChan <- &rsi cr.RsiProcessChan <- &rsi
}() }()
@ -337,6 +338,7 @@ func MakeRsi(cr *core.Core, cl *core.Candle, count int) (error, int) {
Confirm: true, Confirm: true,
} }
go func() { go func() {
fmt.Println("make a stockrsi")
cr.StockRsiProcessChan <- &srsi cr.StockRsiProcessChan <- &srsi
}() }()