From 2d9e6c6654d68b8d21a6e035532e0373e27a4fae Mon Sep 17 00:00:00 2001 From: chenweijian <820961417@qq.com> Date: Mon, 28 Aug 2023 17:50:50 +0800 Subject: [PATCH] =?UTF-8?q?=E7=BE=A4=E7=BB=84=E4=BC=98=E5=8C=96?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- domain/service/group_s/group_list.go | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/domain/service/group_s/group_list.go b/domain/service/group_s/group_list.go index fe6a416..b8e1af9 100644 --- a/domain/service/group_s/group_list.go +++ b/domain/service/group_s/group_list.go @@ -4,7 +4,6 @@ import ( "context" "git.hilo.cn/hilo-common/_const/rediskey" "git.hilo.cn/hilo-common/domain" - "git.hilo.cn/hilo-common/resource/redisCli" "github.com/go-redis/redis/v8" "hilo-group/_const/enum/gift_e" "hilo-group/cv/gift_cv" @@ -68,13 +67,13 @@ func setToRedis(model *domain.Model, country string, groupList []string) error { // 写入redis key := rediskey.GetGroupCountrySortList(country) for idx, group := range groupList { - err := redisCli.GetRedis().ZRemRangeByRank(context.Background(), key, int64(idx), int64(idx)).Err() // 先删除旧的 + err := model.RedisCluster.ZRemRangeByRank(context.Background(), key, int64(idx), int64(idx)).Err() // 先删除旧的 if err != nil { model.Log.Errorf("setToRedis SortGroup key:%v, idx:%v, err:%v", key, idx, err) return err } // 插入 - err = redisCli.GetRedis().ZAdd(context.Background(), key, &redis.Z{Score: float64(idx), Member: group}).Err() + err = model.RedisCluster.ZAdd(context.Background(), key, &redis.Z{Score: float64(idx), Member: group}).Err() if err != nil { model.Log.Errorf("setToRedis SortGroup key:%v, idx:%v, group:%s, err:%v", key, idx, group, err) return err -- 2.22.0