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:07:30 +08:00
parent d3658f6940
commit c91970f192
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

@ -531,6 +531,7 @@ func RsisProcess(cr *core.Core) {
for { for {
rsi := <-cr.RsiProcessChan rsi := <-cr.RsiProcessChan
// logrus.Debug("mx: ", mx) // logrus.Debug("mx: ", mx)
fmt.Println("rsi recieved:", rsi)
go func(rsi *core.Rsi) { go func(rsi *core.Rsi) {
mrs := MyRsi{ mrs := MyRsi{
Rsi: *rsi, Rsi: *rsi,
@ -544,6 +545,7 @@ func StockRsisProcess(cr *core.Core) {
for { for {
srsi := <-cr.StockRsiProcessChan srsi := <-cr.StockRsiProcessChan
// logrus.Debug("mx: ", mx) // logrus.Debug("mx: ", mx)
fmt.Println("stockrsi recieved:", srsi)
go func(srsi *core.StockRsi) { go func(srsi *core.StockRsi) {
mrs := MyStockRsi{ mrs := MyStockRsi{
StockRsi: *srsi, StockRsi: *srsi,