From d4ab8c5b63ec70124b66c4350d620371eed6b5a9 Mon Sep 17 00:00:00 2001 From: "zhangkun9038@dingtalk.com" Date: Thu, 20 Feb 2025 08:32:07 +0800 Subject: [PATCH] add trump --- configs/basicConfig.json | 3 ++- main.go | 6 +++--- modules/extent.go | 10 ++++++++++ 3 files changed, 15 insertions(+), 4 deletions(-) diff --git a/configs/basicConfig.json b/configs/basicConfig.json index 6011019..ea332de 100644 --- a/configs/basicConfig.json +++ b/configs/basicConfig.json @@ -199,7 +199,8 @@ "OKB-USDT", "DOGE-USDT", "SOL-USDT", - "DYDX-USDT" + "DYDX-USDT", + "TRUMP-USDT" ], "softCandleSegmentList": [{ "startTime": "2021-12-04 20:00.000", diff --git a/main.go b/main.go index da6a1b7..efafd4a 100644 --- a/main.go +++ b/main.go @@ -77,9 +77,9 @@ func main() { }() // 这些暂时不运行, 以后要不要运行再说 - // go func() { - // core.CoasterProcess(&cr) - // }() + go func() { + md.CoasterProcess(&cr) + }() // go func() { // core.SeriesProcess(&cr) // }() diff --git a/modules/extent.go b/modules/extent.go index 27db57b..e471318 100644 --- a/modules/extent.go +++ b/modules/extent.go @@ -725,6 +725,16 @@ func MaXsProcess(cr *core.Core) { }(mx) } } + +func CoasterProcess(cr *core.Core) { + for { + ci := <-cr.CoasterChan + go func(coa *core.CoasterInfo) { + coa.Process(cr) + }(ci) + + } +} func RsisProcess(cr *core.Core) { for { rsi := <-cr.RsiProcessChan