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-22 00:04:03 +08:00
parent cf2cc18a78
commit d3658f6940
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
modules/extent.go
View File

@ -315,6 +315,7 @@ func MakeRsi(cr *core.Core, cl *core.Candle, count int) (error, int) {
if duration > time.Duration(periodMins-1)*time.Minute { if duration > time.Duration(periodMins-1)*time.Minute {
rsi.Confirm = true rsi.Confirm = true
} }
fmt.Println("will send rsi")
go func() { go func() {
fmt.Println("make a rsi") 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) {
DVol: percentD[len(percentD)-1], DVol: percentD[len(percentD)-1],
Confirm: true, Confirm: true,
} }
fmt.Println("will send stockrsi")
go func() { go func() {
fmt.Println("make a stockrsi") fmt.Println("make a stockrsi")
cr.StockRsiProcessChan <- &srsi cr.StockRsiProcessChan <- &srsi