Merge remote-tracking branch 'origin/master' into fix/group_country

_const/redis_key/mic_k/keys.go

@@ -13,6 +13,8 @@ const (
 
 	MicGroupPowerOnMic = MicPrefix + "groupPower:${userId}:${date}" // 家族内群上麦分钟数
 	MicUserOnMic       = MicPrefix + "user:onMic:${tz}:${userId}:${date}"
+
+	MicGroupOnMic = MicPrefix + "group:onMic:${groupId}" // 在群组麦位上的人 hset field:micIndex member:userId
 )
 
 func GetUserMicDayInvite(userId mysql.ID) string {
@@ -31,3 +33,10 @@ func GetMicGroupPowerOnMic(userId uint64) string {
 func GetUserOnMicKey(userId uint64, tz, date string) string {
 	return redis_key.ReplaceKey(MicUserOnMic, tz, fmt.Sprintf("%d", userId), date)
 }
+
+// 获取群组麦位上的人
+// 可能会有数据不一致,已原来麦位的key为准
+// 这里用户快速获取群上麦位的人用，代替大量mget命令慢查询
+func GetGroupOnMicUser(groupId string) string {
+	return redis_key.ReplaceKey(MicGroupOnMic, groupId)
+}

domain/cache/group_c/enter_room.go

@@ -54,10 +54,10 @@ func GetUserRecentRooms(model *domain.Model, userId uint64, offset, limit int64)
 	roomEnterTime = make(map[string]int64)
 	userKey := group_k.GetUserEnterRoomUserKey(userId)
 	res, err := model.Redis.ZRangeByScoreWithScores(model, userKey, &redis.ZRangeBy{
-		Min:    fmt.Sprintf("%d", time.Now().AddDate(0, -3, 0).Unix()),
-		Max:    "+inf",
-		Offset: offset,
-		Count:  limit,
+		Min: fmt.Sprintf("%d", time.Now().AddDate(0, -3, 0).Unix()),
+		Max: "+inf",
+		//Offset: offset,
+		//Count:  limit,
 	}).Result()
 	if err != nil {
 		return

domain/model/group_m/factory.go

@@ -13,6 +13,7 @@ import (
 	"gorm.io/gorm"
 	"hilo-group/_const/enum/group_e"
 	"hilo-group/_const/redis_key"
+	"hilo-group/_const/redis_key/mic_k"
 	"hilo-group/myerr"
 	"strconv"
 	"strings"
@@ -242,6 +243,20 @@ func BatchGetAllMicUser(model *domain.Model, groupIds []string) (map[string][]my
 	if len(groupIds) <= 0 {
 		return result, nil
 	}
+	// 获取群组中上麦用户
+	for _, groupId := range groupIds {
+		groupMicUserKey := mic_k.GetGroupOnMicUser(groupId)
+		userIds, err := model.Redis.HVals(model, groupMicUserKey).Result()
+		if err != nil {
+			model.Log.Errorf("BatchGetAllMicUser fail:%v", err)
+		}
+		for _, userIdStr := range userIds {
+			if userId, _ := strconv.ParseUint(userIdStr, 10, 64); userId > 0 {
+				result[groupId] = append(result[groupId], userId)
+			}
+		}
+	}
+	return result, nil
 
 	keys := make([]string, 0)
 	for _, g := range groupIds {

domain/model/group_m/mic.go

@@ -3,6 +3,7 @@ package group_m
 import (
 	"context"
 	"encoding/json"
+	"fmt"
 	"git.hilo.cn/hilo-common/domain"
 	"git.hilo.cn/hilo-common/mylogrus"
 	"git.hilo.cn/hilo-common/resource/config"
@@ -14,6 +15,7 @@ import (
 	"gorm.io/gorm"
 	"hilo-group/_const/enum/group_e"
 	"hilo-group/_const/redis_key"
+	"hilo-group/_const/redis_key/mic_k"
 	"hilo-group/common"
 	"hilo-group/domain/model/noble_m"
 	"hilo-group/domain/model/res_m"
@@ -255,6 +257,10 @@ func (mic *Mic) In(userId uint64, externalId string) error {
 		return bizerr.GroupMicUserHasIn
 	}
 
+	// 增加群组中上麦用户
+	groupMicUserKey := mic_k.GetGroupOnMicUser(mic.GroupUuid)
+	mic.model.Redis.HSet(mic.model, groupMicUserKey, mic.I, userId)
+
 	//离开动作已结束，增加到队列中
 	MicChangeRPush(mic.model, mic.GroupUuid, mic.I)
 
@@ -385,6 +391,10 @@ func (micUser *MicUser) leave(operateUserId uint64, operateExternalId string) er
 		//return bizerr.GroupMicErr
 	}
 
+	// 减少群组中上麦用户
+	groupMicUserKey := mic_k.GetGroupOnMicUser(micUser.GroupUuid)
+	micUser.model.Redis.HDel(micUser.model, groupMicUserKey, fmt.Sprintf("%d", micUser.I))
+
 	//离开动作已结束，增加到队列中
 	MicChangeRPush(micUser.model, micUser.GroupUuid, micUser.I)
 

domain/model/tim_m/user.go

@@ -387,10 +387,10 @@ func getOnlineStatus(extIds []string) ([]interface{}, error) {
 	for _, e := range extIds {
 		keys = append(keys, redis_key.GetOnLineStatusKey(e))
 	}
-	return redisCli.RedisClient.MGet(context.Background(), keys...).Result()
+	return redisCli.RedisClusterClient.MGet(context.Background(), keys...).Result()
 }
 
 func setOnlineStatus(extId string, status uint, ttl time.Duration) error {
 	key := redis_key.GetOnLineStatusKey(extId)
-	return redisCli.RedisClient.Set(context.Background(), key, status, ttl).Err()
+	return redisCli.RedisClusterClient.Set(context.Background(), key, status, ttl).Err()
 }