From 52fa562281af29f0b52a017106b92b8cbfdd0fa2 Mon Sep 17 00:00:00 2001
From: "zhangkun9038@dingtalk.com" <zhangkun9038@dingtalk.com>
Date: Tue, 17 Dec 2024 00:32:19 +0800
Subject: [PATCH] =?UTF-8?q?=E4=B8=B4=E6=97=B6=E5=85=B3=E6=8E=89=EF=BC=8C?=
 =?UTF-8?q?=E9=AA=8C=E8=AF=81=E9=97=AE=E9=A2=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 main.go | 56 ++++++++++++++++++++++++++++----------------------------
 1 file changed, 28 insertions(+), 28 deletions(-)

diff --git a/main.go b/main.go
index 020824b..20c0f29 100644
--- a/main.go
+++ b/main.go
@@ -30,34 +30,34 @@ func main() {
 		md.LoopSubscribe(&cr, core.TICKERINFO_PUBLISH, vv)
 	}(rdsLs[0])
 
-	// 订阅 redis Candles
-	go func(vv *core.RedisConfig) {
-		allowed := os.Getenv("SIAGA_ACCEPTCANDLE") == "true"
-		if !allowed {
-			return
-		}
-		fmt.Println("start subscribe core.TICKERINFO_PUBLISH")
-		md.LoopSubscribe(&cr, core.ALLCANDLES_PUBLISH, vv)
-	}(rdsLs[0])
-
-	// 订阅 redis Max
-	go func(vv *core.RedisConfig) {
-		allowed := os.Getenv("SIAGA_ACCEPTMAX") == "true"
-		if !allowed {
-			return
-		}
-		md.LoopSubscribe(&cr, core.ALLMAXES_PUBLISH, vv)
-	}(rdsLs[0])
-
-	// 下面这个暂时不运行, 在环境变量里把它关掉
-	go func(vv *core.RedisConfig) {
-		allowed := os.Getenv("SIAGA_ACCEPTSERIES") == "true"
-		if !allowed {
-			return
-		}
-		md.LoopSubscribe(&cr, core.ALLSERIESINFO_PUBLISH, vv)
-	}(rdsLs[0])
-
+	// // 订阅 redis Candles
+	// go func(vv *core.RedisConfig) {
+	// 	allowed := os.Getenv("SIAGA_ACCEPTCANDLE") == "true"
+	// 	if !allowed {
+	// 		return
+	// 	}
+	// 	fmt.Println("start subscribe core.TICKERINFO_PUBLISH")
+	// 	md.LoopSubscribe(&cr, core.ALLCANDLES_PUBLISH, vv)
+	// }(rdsLs[0])
+	//
+	// // 订阅 redis Max
+	// go func(vv *core.RedisConfig) {
+	// 	allowed := os.Getenv("SIAGA_ACCEPTMAX") == "true"
+	// 	if !allowed {
+	// 		return
+	// 	}
+	// 	md.LoopSubscribe(&cr, core.ALLMAXES_PUBLISH, vv)
+	// }(rdsLs[0])
+	//
+	// // 下面这个暂时不运行, 在环境变量里把它关掉
+	// go func(vv *core.RedisConfig) {
+	// 	allowed := os.Getenv("SIAGA_ACCEPTSERIES") == "true"
+	// 	if !allowed {
+	// 		return
+	// 	}
+	// 	md.LoopSubscribe(&cr, core.ALLSERIESINFO_PUBLISH, vv)
+	// }(rdsLs[0])
+	//
 	go func() {
 		md.TickerInfoProcess(&cr)
 	}()