From 0d54c5ee5847a8ca23ffb3c740d4063cfd44ab3d Mon Sep 17 00:00:00 2001 From: hujiebin Date: Thu, 31 Aug 2023 15:54:20 +0800 Subject: [PATCH] =?UTF-8?q?feat:group-consume=E6=9B=B4=E6=8D=A2=E5=88=B0?= =?UTF-8?q?=E9=9B=86=E7=BE=A4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- domain/cache/group_c/group.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/domain/cache/group_c/group.go b/domain/cache/group_c/group.go index 3dc6431..265ead8 100644 --- a/domain/cache/group_c/group.go +++ b/domain/cache/group_c/group.go @@ -83,17 +83,17 @@ func SetGroupMemberTTL(groupId string, ttl time.Duration) (bool, error) { func GetGroupConsume(groupId string) (uint64, error) { key := getGroupConsumeKey(groupId) - return redisCli.RedisClient.Get(context.Background(), key).Uint64() + return redisCli.RedisClusterClient.Get(context.Background(), key).Uint64() } func SetGroupConsume(groupId string, consume uint64, ttl time.Duration) error { key := getGroupConsumeKey(groupId) - return redisCli.RedisClient.Set(context.Background(), key, consume, ttl).Err() + return redisCli.RedisClusterClient.Set(context.Background(), key, consume, ttl).Err() } func ClearGroupConsume(groupId string) error { key := getGroupConsumeKey(groupId) - return redisCli.RedisClient.Del(context.Background(), key).Err() + return redisCli.RedisClusterClient.Del(context.Background(), key).Err() } // 增加编辑用户cd -- 2.22.0