From 9a49f28cc47df8737349f31f66aac4b9d1b798d7 Mon Sep 17 00:00:00 2001
From: "zhangkun9038@dingtalk.com" <zhangkun9038@dingtalk.com>
Date: Tue, 17 Dec 2024 00:26:02 +0800
Subject: [PATCH] redisConf

---
 go.mod            | 2 +-
 go.sum            | 4 ++--
 modules/extent.go | 4 ++--
 3 files changed, 5 insertions(+), 5 deletions(-)

diff --git a/go.mod b/go.mod
index 01f6571..55a5575 100644
--- a/go.mod
+++ b/go.mod
@@ -6,7 +6,7 @@ go 1.21
 
 require (
 	github.com/go-redis/redis v6.15.9+incompatible
-	github.com/phyer/core v0.1.20
+	github.com/phyer/core v0.1.21
 	github.com/sirupsen/logrus v1.9.3
 )
 
diff --git a/go.sum b/go.sum
index 298ddda..b8ceedd 100644
--- a/go.sum
+++ b/go.sum
@@ -49,8 +49,8 @@ github.com/onsi/gomega v1.10.1/go.mod h1:iN09h71vgCQne3DLsj+A5owkum+a2tYe+TOCB1y
 github.com/onsi/gomega v1.17.0/go.mod h1:HnhC7FXeEQY45zxNK3PPoIUhzk/80Xly9PcubAlGdZY=
 github.com/onsi/gomega v1.18.1 h1:M1GfJqGRrBrrGGsbxzV5dqM2U2ApXefZCQpkukxYRLE=
 github.com/onsi/gomega v1.18.1/go.mod h1:0q+aL8jAiMXy9hbwj2mr5GziHiwhAIQpFmmtT5hitRs=
-github.com/phyer/core v0.1.20 h1:KqDlXB0IFWXpbx8UViRxC5+y2CRZ1K+f8GzQBVhq3Vw=
-github.com/phyer/core v0.1.20/go.mod h1:XZdniJiiZPzOU8+QHPFRQWdvJa6m5Ilj5VClWWI0OQg=
+github.com/phyer/core v0.1.21 h1:akZDwpqRGxtysvGun9PjyZcrysGIaWcphcWafxxZtig=
+github.com/phyer/core v0.1.21/go.mod h1:XZdniJiiZPzOU8+QHPFRQWdvJa6m5Ilj5VClWWI0OQg=
 github.com/phyer/texus v0.0.0-20241207132635-0e7fb63f8196 h1:P1sxgCsS0VIL38ufZzgUuZLLyY/B+po6kSY7ziNZT7E=
 github.com/phyer/texus v0.0.0-20241207132635-0e7fb63f8196/go.mod h1:iZexs5agdApNlp8HW/FqKgma4Ij1x8/o+ZLcMvY3f80=
 github.com/phyer/v5sdkgo v0.1.4 h1:mAxxjPJVTYGuGDarqOcFGkzj5AgqbbzJGsnYmmsbapU=
diff --git a/modules/extent.go b/modules/extent.go
index e3cb392..90e5f82 100644
--- a/modules/extent.go
+++ b/modules/extent.go
@@ -52,7 +52,7 @@ func GetRemoteRedisConfigList() ([]*core.RedisConfig, error) {
 }
 
 func LoopSubscribe(cr *core.Core, channelName string, redisConf *core.RedisConfig) {
-	redisRemoteCli := cr.RedisRemoteCli
+	redisRemoteCli, _ := cr.GetRedisCliFromConf(*redisConf)
 	suffix := ""
 	env := os.Getenv("GO_ENV")
 	if strings.Contains(env, "demoEnv") {
@@ -77,7 +77,7 @@ func LoopSubscribe(cr *core.Core, channelName string, redisConf *core.RedisConfi
 		ctype := ""
 		if strings.Contains(channelName, "allCandle") {
 			ctype = "candle"
-		} else if strings.Contains(channelName, "allMaXs") {
+		} else if strings.Contains(channelName, "allMaX") {
 			ctype = "maX"
 		} else if strings.Contains(channelName, "ticker") {
 			ctype = "tickerInfo"