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" "git.hilo.cn/hilo-common/resource/mysql" "git.hilo.cn/hilo-common/resource/redisCli" "git.hilo.cn/hilo-common/sdk/tencentyun" "github.com/bluele/gcache" redis2 "github.com/go-redis/redis/v8" "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" "hilo-group/domain/model/user_m" "hilo-group/myerr" "hilo-group/myerr/bizerr" "runtime/debug" "strconv" "strings" "time" ) /** 1: 主要关注点:分布式事务一致性,高效。 2:存储介质:redis,理由:不重要,高频数据请求,持久化过程注意点:利用redis单次操作作为原子性,利用原子性的操作结果(判断更新数量,成败)来保证整个麦位的原子性操作。 3:分布式事务一致性(声网,服务器)。以服务端数据为准。客户端保持同声网数据一致。5分钟C端请求服务的信息,进行同步,纠正声网数据不一致问题。 4: 存储结构: ps: micUser持久话动作,没有归属于repo,因为需要处理并发下一致性问题。因此,在方法中,进行持久化, */ /** * redis记录。 micHasGroup -> set, 定于:可能麦上有人的群组(确保:麦上有人一定在该集合中), 增加时机:加入麦位之前, 减少时机:利用lua表达式控制顺序,没有人在麦上,则清理数据。(lua防止并发,麦上有人后,被移除出数据) micNumType -> groupUuid string, 有生命周期,缓存不存在的时候,就找数据库,更新:先删除缓存,再修改数据库。 核心:mic -> groupUuid Map(key:i, value:Mic) 为了减少redis的数据,当mic的值为默认值时,执行的HDel micUser -> groupUuid Map(key:i value:MicUser) userInMic -> map(key:extendId, value:MicUser) PS:userInMic同micUser 具有一致性。(原子操作)作用:用于查询某个用户在哪个麦上 */ //麦位数量类型 type MicNumType struct { model *domain.Model GroupUuid string T group_e.GroupMicNumType } const MaxMicNum = 20 //清理缓存 func (micNumType *MicNumType) ClearCache() { micNumType.model.Log.Infof("group_m MicNumType ClearCache groupUuid:%v", micNumType.GroupUuid) _, err := redisCli.GetRedis().Del(context.Background(), redis_key.GetPrefixGroupMicNumType(micNumType.GroupUuid)).Result() if err != nil { micNumType.model.Log.Errorf("group_m MicNumType ClearCache groupUuid:%v err:%v", micNumType.GroupUuid, err) } } //同步到缓存,用set,强制修改值 func (micNumType *MicNumType) AddCache() error { micNumType.model.Log.Infof("group_m MicNumType AddCache groupUuid:%v, groupMicNumType:%v", micNumType.GroupUuid, micNumType.T) _, err := redisCli.GetRedis().Set(context.Background(), redis_key.GetPrefixGroupMicNumType(micNumType.GroupUuid), strconv.Itoa(int(micNumType.T)), micExpire).Result() if err != nil { micNumType.model.Log.Errorf("MicNumType add redis set err:%v", err) return err } return nil } //获取数据,先从缓存中获取,没有则从数据库中获取,如果不存在,则同步到redis, 必须用setnx,避免同修改的时候,并发让缓存错误。 func GetMicNumType(model *domain.Model, groupUuid string) (group_e.GroupMicNumType, error) { t, err := redisCli.GetRedis().Get(context.Background(), redis_key.GetPrefixGroupMicNumType(groupUuid)).Result() if err != nil { if err != redis2.Nil { return 0, myerr.WrapErr(err) } else { //获取数据库的值,同步到缓存 groupInfo, _ := GetGroupInfo(model, groupUuid) if groupInfo == nil { return 0, bizerr.GroupNotFound } flag, err := redisCli.GetRedis().SetNX(context.Background(), redis_key.GetPrefixGroupMicNumType(groupUuid), strconv.Itoa(int(groupInfo.MicNumType)), micExpire).Result() model.Log.Infof("GetMicNumType redis SetNX groupUuid:%v, flag:%v, err:%v", groupUuid, flag, err) return groupInfo.MicNumType, nil } } else { groupMicNumType, err := strconv.ParseUint(t, 10, 8) if err != nil { return 0, nil } return group_e.GroupMicNumType(groupMicNumType), nil } } // 3天 const expireMinute = 60 * 60 * 24 * 3 const micExpire = expireMinute * time.Second //麦位基本信息。 type Mic struct { model *domain.Model //群组uuid GroupUuid string //麦位 I int //锁,是否有锁 true:锁了, false:没锁 Lock bool //麦位静音 MicForbid bool } //发言,注意(发言是在麦位上) type MicUser struct { model *domain.Model //群组uuid GroupUuid string //麦位 I int //麦中的人 ExternalId string //用户id UserId uint64 //用户cpId CpUserId uint64 //静音 true:静音,false:没有静音 Forbid bool //上麦的的时间戳 Timestamp int64 } //记录麦位上有谁。用于 type UserInMic struct { //群组uuid GroupUuid string //麦位 I int //userId UserId uint64 } //60*5 //const micInExpireScript = "local flag = redis.call('expire', '{prefixGroupMicUser}', '300') if flag == 1 then return redis.call('expire', '{prefixGroupUserMic}', '300') end return 0 " //先让user在那个麦上续时间,再让麦上有谁续时间? 目前日志统计中,并没有发现只执行一半的,全部执行成功。 const micInExpireScript = "local flag = redis.call('expire', '{prefixGroupMicUser}', '{micExpire}') if flag == 1 then return redis.call('expire', '{prefixGroupUserMic}', '{micExpire}') end return 0 " func UpdateMicExpire(model *domain.Model, groupUuid string, externalId string) error { micUser, err := GetMicUserByExternalId(model, externalId) if err != nil { return err } // if micUser != nil { if micUser.GroupUuid == groupUuid { //使用lua表达式 script := strings.Replace( strings.Replace( strings.Replace(micInExpireScript, "{micExpire}", strconv.Itoa(expireMinute), -1), "{prefixGroupMicUser}", redis_key.GetPrefixGroupMicUser(micUser.GroupUuid, micUser.I), -1), "{prefixGroupUserMic}", redis_key.GetPrefixGroupUserInMic(externalId), -1) //redisCli.GetRedis().ScriptFlush(context.Background()) n, err := redis2.NewScript(script).Run(context.Background(), redisCli.GetRedis(), []string{}).Result() if n == 0 { mylogrus.MyLog.Infof("UpdateMicExpire script result:n=%v", n) } if err != nil { return myerr.WrapErr(err) } //存在才更新。 /* if flag, err := redisCli.GetRedis().Expire(context.Background(), redis.GetPrefixGroupUserInMic(externalId), micExpire).Result(); err == nil { if flag { redisCli.GetRedis().Expire(context.Background(), redis.GetPrefixGroupMicUser(micUser.GroupUuid, micUser.I), micExpire) //基本一致,接受容错,如果担心错误,可以反向验证。目前不考虑。因为这个接口频率太高了。 } }*/ } } return nil } //12个小时 //2022-07-20 升级,判断是自己是否已经在别的麦上了 //const micInScript = "local flag = redis.call('SET', '{prefixGroupMicUser}', '{micUserStr}', 'ex', '{micExpire}', 'nx') if flag ~= false then redis.call('SETEX', '{prefixGroupUserMic}', '{micExpire}', '{groupUserStr}') return 1 end return 2 " const micInScript = "local flag = redis.call('EXISTS', '{prefixGroupUserMic}') if flag == 0 then local flag1 = redis.call('SET', '{prefixGroupMicUser}', '{micUserStr}', 'ex', '{micExpire}', 'nx') if flag1 ~= false then redis.call('SETEX', '{prefixGroupUserMic}', '{micExpire}', '{groupUserStr}') return 1 end return 2 end return 3" const micUpdateScript = "local flag = redis.call('EXISTS', '{prefixGroupUserMic}') if flag == 1 then local flag1 = redis.call('SET', '{prefixGroupMicUser}', '{micUserStr}', 'ex', '{micExpire}', 'xx') if flag1 ~= false then redis.call('SETEX', '{prefixGroupUserMic}', '{micExpire}', '{groupUserStr}') return 1 end return 2 end return 3" // //上麦(自己), //规则:1:加锁了不能上麦 2:麦上有人,不能上麦 //cpUserId如果有 func (mic *Mic) In(userId uint64, externalId string) error { // 群是否被封禁, 呃,,,呃,,,呃,,, banned := GroupBanned{ImGroupId: mic.GroupUuid} if err := banned.Get(mic.model); err != gorm.ErrRecordNotFound { return bizerr.GroupIsBanned } //判断群组设置上的麦 是否被关闭 groupInfo, err := GetGroupInfo(mic.model, mic.GroupUuid) if err != nil { return err } if groupInfo.MicOn == false { return bizerr.GroupInfoMicClosed } //麦被加锁了 if mic.Lock { return bizerr.GroupMicLock } //设置值到redis micUserStr, err := micUserToStr(MicUser{ GroupUuid: mic.GroupUuid, I: mic.I, ExternalId: externalId, UserId: userId, Forbid: false, Timestamp: time.Now().Unix(), }) if err != nil { return err } //加入到麦上可能有人的集合中。 groupMicHasIn(mic.model, mic.GroupUuid, userId) //lua上麦,让麦上的人同人在麦上,保持原子性操作 //清理脚本,不然redis占用内存越来越高,并且不会释放 groupUserStr, err := userInMicToStr(mic.GroupUuid, mic.I, userId) if err != nil { return err } script := strings.Replace(strings.Replace( strings.Replace( strings.Replace( strings.Replace(micInScript, "{micExpire}", strconv.Itoa(expireMinute), -1), "{prefixGroupMicUser}", redis_key.GetPrefixGroupMicUser(mic.GroupUuid, mic.I), -1), "{micUserStr}", micUserStr, -1), "{prefixGroupUserMic}", redis_key.GetPrefixGroupUserInMic(externalId), -1), "{groupUserStr}", groupUserStr, -1) r, err := redis2.NewScript(script).Run(context.Background(), redisCli.GetRedis(), []string{}).Result() mic.model.Log.Infof("micUser In micInScript:%v, result:%v", script, r) d := r.(int64) if err != nil { return myerr.WrapErr(err) } if d == int64(2) { return bizerr.GroupMicHasUser } if d == int64(3) { 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) // 发信令,让前端重新拉取,接受容错, sendSignalMsg(mic.model, mic.GroupUuid, GroupSystemMsg{ MsgId: group_e.GroupMicInSignal, Source: externalId, }, false) return nil } //上麦(自己), //规则:1:加锁了不能上麦 2:麦上有人,不能上麦 //cpUserId如果有 func (mic *Mic) Update(userId uint64, externalId string, cpUserId uint64, forbid bool) (err error) { defer func() { if err != nil { mic.model.Log.Errorf("MicUpdate fail,userId:%v,cpUserId:%v,err:%v", userId, cpUserId, err) } }() // 群是否被封禁, 呃,,,呃,,,呃,,, banned := GroupBanned{ImGroupId: mic.GroupUuid} if err := banned.Get(mic.model); err != gorm.ErrRecordNotFound { return bizerr.GroupIsBanned } //判断群组设置上的麦 是否被关闭 groupInfo, err := GetGroupInfo(mic.model, mic.GroupUuid) if err != nil { return err } if groupInfo.MicOn == false { return bizerr.GroupInfoMicClosed } //麦被加锁了 if mic.Lock { return bizerr.GroupMicLock } //设置值到redis micUserStr, err := micUserToStr(MicUser{ GroupUuid: mic.GroupUuid, I: mic.I, ExternalId: externalId, UserId: userId, CpUserId: cpUserId, Forbid: forbid, Timestamp: time.Now().Unix(), }) if err != nil { return err } //加入到麦上可能有人的集合中。 groupMicHasIn(mic.model, mic.GroupUuid, userId) //lua上麦,让麦上的人同人在麦上,保持原子性操作 //清理脚本,不然redis占用内存越来越高,并且不会释放 groupUserStr, err := userInMicToStr(mic.GroupUuid, mic.I, userId) if err != nil { return err } script := strings.Replace(strings.Replace( strings.Replace( strings.Replace( strings.Replace(micUpdateScript, "{micExpire}", strconv.Itoa(expireMinute), -1), "{prefixGroupMicUser}", redis_key.GetPrefixGroupMicUser(mic.GroupUuid, mic.I), -1), "{micUserStr}", micUserStr, -1), "{prefixGroupUserMic}", redis_key.GetPrefixGroupUserInMic(externalId), -1), "{groupUserStr}", groupUserStr, -1) r, err := redis2.NewScript(script).Run(context.Background(), redisCli.GetRedis(), []string{}).Result() mic.model.Log.Infof("micUser In micInScript:%v, result:%v", script, r) d := r.(int64) if err != nil { return myerr.WrapErr(err) } if d == int64(2) { return bizerr.GroupMicHasUser } if d == int64(3) { return bizerr.GroupMicUserHasIn } //离开动作已结束,增加到队列中 MicChangeRPush(mic.model, mic.GroupUuid, mic.I) // 发信令,让前端重新拉取,接受容错, sendSignalMsg(mic.model, mic.GroupUuid, GroupSystemMsg{ MsgId: group_e.GroupMicInSignal, Source: externalId, }, false) return nil } const micLeaveScript = "local flag = redis.call('DEL', '{prefixGroupMicUser}') if flag == 1 then return redis.call('Del', '{prefixGroupUserMic}') end return 2 " //离开麦(自己) //规则:1:自己的麦 func (micUser *MicUser) leave(operateUserId uint64, operateExternalId string) error { // if micUser == nil { return bizerr.GroupMicNoUser } // externalId := micUser.ExternalId // 超管处理 if flag, err := user_m.IsSuperManagerV2(micUser.model, operateUserId, micUser.UserId); err != nil { return err } else if !flag { if micUser.ExternalId != operateExternalId { //检查权限,管理人权限, 不过不拥有管理人权限,则抛出错误 if err := MgrPermission(micUser.model, micUser.GroupUuid, operateUserId, micUser.UserId); err != nil { return err } } } //设置值到redis //redisCli.GetRedis().ScriptFlush(context.Background()) script := strings.Replace(strings.Replace( micLeaveScript, "{prefixGroupMicUser}", redis_key.GetPrefixGroupMicUser(micUser.GroupUuid, micUser.I), -1), "{prefixGroupUserMic}", redis_key.GetPrefixGroupUserInMic(externalId), -1) r, err := redis2.NewScript(script).Run(context.Background(), redisCli.GetRedis(), []string{}).Result() d := r.(int64) micUser.model.Log.Infof("micUser leave micLeaveScript:%v, result:%v", script, d) if err != nil { return err } if d == 2 { //不在该麦位上,可能被redis,过期移除了。 //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) return nil } //邀请的翻译 var inviteMicMsgTranslate = map[string]string{} //邀请上麦 func InviteMicIn(model *domain.Model, groupUuid string, operateUserId uint64, beInvitedExternalId string) error { model.Log.Infof("mic InviteMicIn operateUserId:%d, beInvitedExternalId:%s", operateUserId, beInvitedExternalId) if err := CheckPermission(model, groupUuid, operateUserId); err != nil { return err } user, err := user_m.GetUser(model, operateUserId) if err != nil { return err } beInvitedUser, err := user_m.GetUserByExtId(model, beInvitedExternalId) if err != nil { return err } context, ok := inviteMicMsgTranslate[beInvitedUser.Language] if ok == false { context = inviteMicMsgTranslate["en"] } context = strings.Replace(context, "{nick}", user.Nick, -1) sendSignalMsg(model, groupUuid, GroupSystemMsg{ MsgId: group_e.GroupInviteMicInSignal, Source: user.ExternalId, Target: beInvitedExternalId, Content: context, }, false) return nil } // 用户操作下麦(自己或者管理人)fixme: 参数往往是错的 func (micUser *MicUser) LeaveByUser(operateUserId uint64, operateExternalId string) error { micUser.model.Log.Infof("mic LeaveByUser userId:%d", operateUserId) if err := micUser.leave(operateUserId, operateExternalId); err != nil { return err } // 发信令,让前端重新拉取,接受容错, sendSignalMsg(micUser.model, micUser.GroupUuid, GroupSystemMsg{ MsgId: group_e.GroupMicOutSignal, Source: operateExternalId, }, false) return nil } /*func (micUser *MicUser) LeaveBySocket(operateUserId uint64, operateExternalId string) error { micUser.model.Log.Infof("mic leaveBySocket userId:%d", operateUserId) if err := micUser.leave(operateUserId, operateExternalId); err != nil { return err } // 发信令,让前端重新拉取,接受容错, go func(groupId, externalId string) { defer func() { if r := recover(); r != nil { //打印错误堆栈信息 mylogrus.MyLog.Errorf("SendCustomMsg: LeaveBySocket SYSTEM ACTION PANIC: %v, stack: %v", r, string(debug.Stack())) } }() sendSignalMsg(groupId, GroupSystemMsg{ MsgId: group_e.GroupSocketMicOutSignal, Source: externalId, }) }(micUser.GroupUuid, operateExternalId) return nil }*/ //锁。(管理人加锁) //规则:1:麦上有人,不能锁 2:必须是管理人以上岗位 //Multi EXEC, 保证了加锁的时候,没有人 func (mic *Mic) MgrLock(userId uint64, externalId string) error { //获取麦上的人 micUser, err := GetMicUser(mic.model, mic.GroupUuid, mic.I) if err != nil { return err } // if micUser != nil { return bizerr.GroupMicHasUser } //判断权限 if err := CheckPermission(mic.model, mic.GroupUuid, userId); err != nil { return err } mic.Lock = true //设置值到redis micStr, err := micToStr(*mic) if err != nil { return err } if _, err = redisCli.GetRedis().HSet(context.Background(), redis_key.GetPrefixGroupMic(mic.GroupUuid), strconv.Itoa(mic.I), micStr).Result(); err != nil { return myerr.WrapErr(err) } MicChangeRPush(mic.model, mic.GroupUuid, mic.I) // 发信令,让前端重新拉取,接受容错, sendSignalMsg(mic.model, mic.GroupUuid, GroupSystemMsg{ MsgId: group_e.GroupMicLockSignal, Source: externalId, }, false) return nil } //去除锁。(管理人解锁) //规则,必须是管理人才能解锁 func (mic *Mic) MgrUnLock(userId uint64, externalId string) error { //判断权限 if err := CheckPermission(mic.model, mic.GroupUuid, userId); err != nil { return err } //判断权限 mic.Lock = false //移除 if _, err := redisCli.GetRedis().HDel(context.Background(), redis_key.GetPrefixGroupMic(mic.GroupUuid), strconv.Itoa(mic.I)).Result(); err != nil { return myerr.WrapErr(err) } // 发信令,让前端重新拉取,接受容错, sendSignalMsg(mic.model, mic.GroupUuid, GroupSystemMsg{ MsgId: group_e.GroupMicUnLockSignal, Source: externalId, }, false) MicChangeRPush(mic.model, mic.GroupUuid, mic.I) return nil //设置值到redis /* micStr, err := micToStr(*mic) if err != nil { return err } if _, err = redisCli.GetRedis().HSet(context.Background(), redis.GetPrefixGroupMic(mic.GroupUuid), strconv.Itoa(mic.I), micStr).Result(); err != nil { return myerr.WrapErr(err) } return nil*/ } // 麦位静音 func (mic *Mic) MgrMute(userId uint64, externalId string) error { //判断权限 if err := CheckPermission(mic.model, mic.GroupUuid, userId); err != nil { return err } mic.MicForbid = true //设置值到redis micStr, err := micToStr(*mic) if err != nil { return err } if _, err = redisCli.GetRedis().HSet(context.Background(), redis_key.GetPrefixGroupMic(mic.GroupUuid), strconv.Itoa(mic.I), micStr).Result(); err != nil { return myerr.WrapErr(err) } MicChangeRPush(mic.model, mic.GroupUuid, mic.I) // 发信令,让前端重新拉取,接受容错, sendSignalMsg(mic.model, mic.GroupUuid, GroupSystemMsg{ MsgId: group_e.GroupMicLockSignal, Source: externalId, }, false) return nil } // 麦位解除静音 func (mic *Mic) MgrUnMute(userId uint64, externalId string) error { //判断权限 if err := CheckPermission(mic.model, mic.GroupUuid, userId); err != nil { return err } // 移除 if _, err := redisCli.GetRedis().HDel(context.Background(), redis_key.GetPrefixGroupMic(mic.GroupUuid), strconv.Itoa(mic.I)).Result(); err != nil { return myerr.WrapErr(err) } // 发信令,让前端重新拉取,接受容错, sendSignalMsg(mic.model, mic.GroupUuid, GroupSystemMsg{ MsgId: group_e.GroupMicUnLockSignal, Source: externalId, }, false) MicChangeRPush(mic.model, mic.GroupUuid, mic.I) return nil //设置值到redis /* micStr, err := micToStr(*mic) if err != nil { return err } if _, err = redisCli.GetRedis().HSet(context.Background(), redis.GetPrefixGroupMic(mic.GroupUuid), strconv.Itoa(mic.I), micStr).Result(); err != nil { return myerr.WrapErr(err) } return nil*/ } //开麦, 管理人 同 自己能开麦 //规则:1:自己开麦 2:管理人开麦 func (micUser *MicUser) SpeechOpen(userId uint64, externalId string) error { if micUser == nil { return bizerr.GroupMicNoUser } else { if micUser.ExternalId == externalId { micUser.Forbid = false } else { //检查是不是管理人 if err := CheckPermission(micUser.model, micUser.GroupUuid, userId); err != nil { return err } micUser.Forbid = false } } //设置值到redis micUserStr, err := micUserToStr(*micUser) if err != nil { return err } if _, err = redisCli.GetRedis().Set(context.Background(), redis_key.GetPrefixGroupMicUser(micUser.GroupUuid, micUser.I), micUserStr, micExpire).Result(); err != nil { return myerr.WrapErr(err) } else { redisCli.GetRedis().Expire(context.Background(), redis_key.GetPrefixGroupUserInMic(externalId), micExpire) } MicChangeRPush(micUser.model, micUser.GroupUuid, micUser.I) // 发信令,让前端重新拉取,接受容错, sendSignalMsg(micUser.model, micUser.GroupUuid, GroupSystemMsg{ MsgId: group_e.GroupMicSpeechOpenSignal, Source: externalId, }, false) return nil } //禁麦, 管理人 同 自己能禁麦(特别注意:产品说,无论是否式管理人开启禁麦,自己同管理人都能关闭禁麦) //规则:1:自己禁麦 2:管理人禁麦 func (micUser *MicUser) SpeechClose(userId uint64, externalId, lang string) error { if micUser == nil { return bizerr.GroupMicNoUser } else { //自己 if micUser.ExternalId == externalId { micUser.Forbid = true } else if flag, err := user_m.IsSuperManager(micUser.model, micUser.UserId); err != nil { return err } else if flag { //不能让超级管理人移除 return bizerr.OfficialStaffLimit } else if flag, err := user_m.IsSuperManagerV2(micUser.model, userId, micUser.UserId); err != nil { return err } else if flag { //超级管理人,无敌状态 micUser.Forbid = true } else { //检查是不是管理人 if err := CheckPermission(micUser.model, micUser.GroupUuid, userId); err != nil { return err } //检查是否是贵族 if flag, err := noble_m.CheckNobleLevel(micUser.model.Db, micUser.UserId, 5); err != nil { return err } else if flag { return myerr.WrapErr(res_m.GetErrByLanguage(micUser.model.Db, common.MSG_ID_BAN_MIC_NOBLE_5, lang, bizerr.NobleNoMicSpeechCloseOverLevel5)) //return bizerr.NobleNoMicSpeechCloseLevel5 } micUser.Forbid = true } } //设置值到redis micUserStr, err := micUserToStr(*micUser) if err != nil { return err } if _, err := redisCli.GetRedis().Set(context.Background(), redis_key.GetPrefixGroupMicUser(micUser.GroupUuid, micUser.I), micUserStr, micExpire).Result(); err != nil { return myerr.WrapErr(err) } else { redisCli.GetRedis().Expire(context.Background(), redis_key.GetPrefixGroupUserInMic(externalId), micExpire) } MicChangeRPush(micUser.model, micUser.GroupUuid, micUser.I) // 发信令,让前端重新拉取,接受容错, sendSignalMsg(micUser.model, micUser.GroupUuid, GroupSystemMsg{ MsgId: group_e.GroupMicSpeechCloseSignal, Source: externalId, }, false) return nil } //群发消息 func (micUser *MicUser) ImMass(externalId string) error { if micUser == nil || micUser.ExternalId != externalId { return bizerr.GroupMicNoYou } //检查权限 if err := CheckPermission(micUser.model, micUser.GroupUuid, micUser.UserId); err != nil { return err } return nil } //检查权限,管理人权限, 不过不拥有管理人权限,则抛出错误 func MgrPermission(model *domain.Model, groupUuid string, userId1 uint64, userId2 uint64) error { if flag, err := IsRoleGreater(model, groupUuid, userId1, userId2); err != nil { return err } else { if flag == false { return bizerr.GroupMicNoPermission } } return nil } //检查权限 func CheckPermission(model *domain.Model, groupUuid string, userId uint64) error { role, err := GetRoleInGroup(model, userId, groupUuid) if err != nil { return err } if role == group_e.GROUP_VISITOR || role == group_e.GROUP_MEMBER { return bizerr.NoPrivileges } return nil } // 入参是内部使用的imGroupId,先进行转化 func sendSignalMsg(model *domain.Model, groupId string, msg GroupSystemMsg, isSyn bool) { groupId, err := ToTxGroupId(model, groupId) if err != nil { return } if isSyn { sendSignalMsgOnly(groupId, msg) } else { go func() { defer func() { if r := recover(); r != nil { //打印错误堆栈信息 mylogrus.MyLog.Errorf("sendSignalMsg SYSTEM ACTION PANIC: %v, stack: %v", r, string(debug.Stack())) } }() sendSignalMsgOnly(groupId, msg) }() } } //发送tengxunyun的系统消息 func sendSignalMsgOnly(groupId string, msg GroupSystemMsg) { buffer, err := json.Marshal(msg) if err == nil { if err = tencentyun.SendSystemMsg(mylogrus.MyLog.WithField("msgId", msg.MsgId), groupId, []string{}, string(buffer)); err != nil { mylogrus.MyLog.Warnf("SendSystemMsg failed for %s, msgId = %d", groupId, msg.MsgId) } } else { mylogrus.MyLog.Errorf("Marshall failure, msgId = %d : %s", msg.MsgId, err.Error()) } } //清理所有麦上的人,强制清理,没有抛出错误,用户接到封禁信令之后,退出麦(必须,用于容错redis清理错误),退出房间 func ClearMic(groupId string) { //清理10个,麦位从5个变成10 20211025, 改成20 20210628 for i := 1; i <= MaxMicNum; i++ { // micUserStr, err := redisCli.GetRedis().Get(context.Background(), redis_key.GetPrefixGroupMicUser(groupId, i)).Result() if err != nil { if err == redis2.Nil { mylogrus.MyLog.Infof("clearMic noUser groupId:%v, i:%v", groupId, i) } else { mylogrus.MyLog.Errorf("clearMic err groupId:%v, i:%v, err:%v", groupId, i, err) continue } } else { var micUser MicUser if err = json.Unmarshal([]byte(micUserStr), &micUser); err != nil { mylogrus.MyLog.Errorf("clearMic groupId:%v, i:%v, err:%v", groupId, i, err) continue } //删除 n, err := redisCli.GetRedis().Del(context.Background(), redis_key.GetPrefixGroupMicUser(groupId, i), redis_key.GetPrefixGroupUserInMic(micUser.ExternalId)).Result() mylogrus.MyLog.Infof("clearMic del groupId:%v, i:%v, result:%v, err:%v", groupId, i, n, err) //增加到队列中 MicEmptyRPush(domain.CreateModelNil(), groupId, i) } } } //检查改群组是否麦上有人. true:存在。 func CheckGroupMicHasUser(groupId string) (bool, error) { //麦位从5个变成10, 20211025 keys := make([]string, 0, 10) for i := 1; i <= MaxMicNum; i++ { keys = append(keys, redis_key.GetPrefixGroupMicUser(groupId, i)) /* n, err := redisCli.GetRedis().Exists(context.Background(), redis.GetPrefixGroupMicUser(groupId, i)).Result() if err != nil { return false, myerr.WrapErr(err) } if n > 0 { return true, nil }*/ } // if n, err := redisCli.GetRedis().Exists(context.Background(), keys...).Result(); err != nil { return false, myerr.WrapErr(err) } else { if n > 0 { return true, nil } else { return false, nil } } } //麦上进入了人,不是核心业务,为了辅助过滤。 func groupMicHasIn(model *domain.Model, groupId string, userId mysql.ID) { model.Log.Infof("groupMicHasIn groupId:%v", groupId) if n, err := redisCli.GetRedis().SAdd(context.Background(), redis_key.GetPrefixGroupMicHasIn(), groupId).Result(); err != nil { model.Log.Errorf("groupMicHasIn groupId:%v err:%v", groupId, err) } else { println(n) } // 下面的是只写,不查的。 todo 直接干掉??? // 只是知道用户在哪个时间点上了哪个群的麦,但是不知道上了哪个麦位置, 而且micUser已经有统计这些信息了 //if _, err := redisCli.GetRedis().ZAdd(context.Background(), redis_key.GetPrefixGroupMicHasInUserTime(), &redis2.Z{ // Score: float64(time.Now().Unix()), // Member: getMemberStr(groupId, userId), //}).Result(); err != nil { // model.Log.Errorf("groupMicHasIn redis:GetPrefixGroupMicHasInTime groupId:%v err:%v", groupId, err) //} } const micHasInScript = "local flag = redis.call('EXISTS', '{key1}', '{key2}', '{key3}', '{key4}', '{key5}', '{key6}', '{key7}', '{key8}', '{key9}', '{key10}', '{key11}', '{key12}', '{key13}', '{key14}', '{key15}', '{key16}', '{key17}', '{key18}', '{key19}', '{key20}') if flag == 0 then redis.call('Srem', '{key}', '{remKey}') end return flag " //获取麦上有人的群组 func GetMicHasInGroups() ([]string, error) { //清理lua缓存 //redisCli.GetRedis().ScriptFlush(context.Background()) //获取所有可能存在的人 groupUuids, err := redisCli.GetRedis().SMembers(context.Background(), redis_key.GetPrefixGroupMicHasIn()).Result() if err != nil { return nil, myerr.WrapErr(err) } return groupUuids, nil // 不需要下面的逐个麦位的判断了 // resultGroupUuids := make([]string, 0, len(groupUuids)) //循环lua判断是否, 最后的保证,(猜想:真正麦上有人的群没有很多) for n, r := range groupUuids { s := strings.Replace(micHasInScript, "{key}", redis_key.GetPrefixGroupMicHasIn(), -1) s = strings.Replace(s, "{remKey}", r, -1) for i := 1; i <= MaxMicNum; i++ { s = strings.Replace(s, "{key"+strconv.Itoa(i)+"}", redis_key.GetPrefixGroupMicUser(r, i), -1) } r, err := redis2.NewScript(s).Run(context.Background(), redisCli.GetRedis(), []string{}).Result() if err != nil { return nil, myerr.WrapErr(err) } d := r.(int64) if d > 0 { resultGroupUuids = append(resultGroupUuids, groupUuids[n]) } } return resultGroupUuids, nil } type micGroupNumKeyS struct{} // mic位数量缓存 var micGroupNumKey = micGroupNumKeyS{} var micGroupNumCache = gcache.New(10000).LRU().Build() // 获取麦上有人的群组&&麦上的人数 // 带lru缓存,1min func GetMicHasInGroupNum(model *domain.Model) (map[string]int64, error) { // get from cache if data, err := micGroupNumCache.Get(micGroupNumKey); err == nil { //model.Log.Infof("GetMicHasInGroupNum cache hit:%v", data) // 正服才缓存 if config.AppIsRelease() { return data.(map[string]int64), nil } } //清理lua缓存 //redisCli.GetRedis().ScriptFlush(context.Background()) //获取所有可能存在的人 groupUuids, err := redisCli.GetRedis().SMembers(context.Background(), redis_key.GetPrefixGroupMicHasIn()).Result() if err != nil { return nil, myerr.WrapErr(err) } // resultGroupUuids := make(map[string]int64, len(groupUuids)) //循环lua判断是否, 最后的保证,(猜想:真正麦上有人的群没有很多) for n, r := range groupUuids { s := strings.Replace(micHasInScript, "{key}", redis_key.GetPrefixGroupMicHasIn(), -1) s = strings.Replace(s, "{remKey}", r, -1) for i := 1; i <= MaxMicNum; i++ { s = strings.Replace(s, "{key"+strconv.Itoa(i)+"}", redis_key.GetPrefixGroupMicUser(r, i), -1) } //r, err := redis2.NewScript(s).Run(context.Background(), redisCli.GetRedis(), []string{}).Result() sha1, err := model.Redis.ScriptLoad(model, s).Result() if err != nil { return nil, myerr.WrapErr(err) } micNum, err := model.Redis.EvalSha(model, sha1, nil, nil).Int64() if err != nil { return nil, myerr.WrapErr(err) } //d := r.(int64) if micNum > 0 { resultGroupUuids[groupUuids[n]] = micNum } } // cache 1min _ = micGroupNumCache.SetWithExpire(micGroupNumKey, resultGroupUuids, time.Minute*15) //model.Log.Infof("GetMicHasInGroupNum cache miss:%v", resultGroupUuids) return resultGroupUuids, nil } // 获取麦上人数 func GetMicHasInGroupNumByList(model *domain.Model, groupIds []string) (map[string]int64, error) { resultGroupUuids := make(map[string]int64, len(groupIds)) micHasInKey := redis_key.GetPrefixGroupMicHasIn() for _, group := range groupIds { isMem, err := redisCli.GetRedis().SIsMember(context.Background(), micHasInKey, group).Result() if err != nil { model.Log.Errorf("GetMicHasInGroupNumByList err:%v", err) return nil, myerr.WrapErr(err) } if isMem { s := strings.Replace(micHasInScript, "{key}", micHasInKey, -1) s = strings.Replace(s, "{remKey}", group, -1) for i := 1; i <= MaxMicNum; i++ { s = strings.Replace(s, "{key"+strconv.Itoa(i)+"}", redis_key.GetPrefixGroupMicUser(group, i), -1) } //r, err := redis2.NewScript(s).Run(context.Background(), redisCli.GetRedis(), []string{}).Result() sha1, err := model.Redis.ScriptLoad(model, s).Result() if err != nil { return nil, myerr.WrapErr(err) } micNum, err := model.Redis.EvalSha(model, sha1, nil, nil).Int64() if err != nil { return nil, myerr.WrapErr(err) } //d := r.(int64) if micNum > 0 { resultGroupUuids[group] = micNum } } } return resultGroupUuids, nil } //获取麦上有人的群组&&麦上的数(有时间性,目前是24小时) func GetMicHasInPeriodGroupUser() (map[string][]uint64, error) { //清理超过12小时的 if _, err := redisCli.GetRedis().ZRemRangeByScore(context.Background(), redis_key.GetPrefixGroupMicHasInUserTime(), "0", strconv.FormatUint(uint64(time.Now().Unix()-24*60*60), 10)).Result(); err != nil { return nil, myerr.WrapErr(err) } groupUserIdstrs, err := redisCli.GetRedis().ZRange(context.Background(), redis_key.GetPrefixGroupMicHasInUserTime(), 0, -1).Result() if err != nil { return nil, myerr.WrapErr(err) } result := map[string][]uint64{} for i, _ := range groupUserIdstrs { tempGroupUid, tempUserId := analysisMemberStr(groupUserIdstrs[i]) if _, flag := result[tempGroupUid]; flag { result[tempGroupUid] = append(result[tempGroupUid], tempUserId) } else { result[tempGroupUid] = []uint64{tempUserId} } } return result, nil } //获取麦上有人的群组 func GetMicUserNum(groupUuid string) (uint64, error) { //清理lua缓存 //redisCli.GetRedis().ScriptFlush(context.Background()) //循环lua判断是否 s := strings.Replace(micHasInScript, "{key}", redis_key.GetPrefixGroupMicHasIn(), -1) s = strings.Replace(s, "{remKey}", groupUuid, -1) for i := 1; i <= MaxMicNum; i++ { s = strings.Replace(s, "{key"+strconv.Itoa(i)+"}", redis_key.GetPrefixGroupMicUser(groupUuid, i), -1) } r, err := redis2.NewScript(s).Run(context.Background(), redisCli.GetRedis(), []string{}).Result() if err != nil { return 0, myerr.WrapErr(err) } d := r.(uint64) return d, nil } func GetMicNum(micNumType group_e.GroupMicNumType) int { var micNum int = 0 if micNumType == group_e.OneMicNumType { micNum = 1 } else if micNumType == group_e.TwoMicNumType { micNum = 2 } else if micNumType == group_e.ThreeMicNumType { micNum = 3 } else if micNumType == group_e.FourMicNumType { micNum = 4 } else if micNumType == group_e.FiveMicNumType { micNum = 5 } else if micNumType == group_e.SixMicNumType { micNum = 6 } else if micNumType == group_e.SevenMicNumType { micNum = 7 } else if micNumType == group_e.EightMicNumType { micNum = 8 } else if micNumType == group_e.NineMicNumType { micNum = 9 } else if micNumType == group_e.TenMicNumType { micNum = 10 } else if micNumType == group_e.ElevenMicNumType { micNum = 11 } else if micNumType == group_e.TwelveMicNumType { micNum = 12 } else if micNumType == group_e.ThirteenMicNumType { micNum = 13 } else if micNumType == group_e.FourteenMicNumType { micNum = 14 } else if micNumType == group_e.FifteenMicNumType { micNum = 15 } else if micNumType == group_e.SixteenMicNumType { micNum = 16 } else if micNumType == group_e.SeventeenMicNumType { micNum = 17 } else if micNumType == group_e.EighteenMicNumType { micNum = 18 } else if micNumType == group_e.NineteenMicNumType { micNum = 19 } else if micNumType == group_e.TwentyMicNumType { micNum = 20 } return micNum } func init() { //初始化翻译 { inviteMicMsgTranslate["zh"] = "{nick} 邀请你上麦" inviteMicMsgTranslate["en"] = "{nick} invite you to take mic" inviteMicMsgTranslate["ar"] = "يدعوك٪ {nick} إلى أخذ الميكروفون" inviteMicMsgTranslate["tr"] = "{nick}, sizi mikrofonda konuşmaya davet ediyor" inviteMicMsgTranslate["id"] = "{nick} mengundangmu menggunakan mic" inviteMicMsgTranslate["ru"] = "{nick} пригласить тебя появиться у микрофона." inviteMicMsgTranslate["ko"] = "{nick} 당신에게 마이크 요청합니다" inviteMicMsgTranslate["pt"] = "{nick} convida você para pegar o mic" inviteMicMsgTranslate["th"] = "{nick}เชิญคุณเข้าร่วมไมค์" inviteMicMsgTranslate["ca"] = "{nick} te invito al micrófono" inviteMicMsgTranslate["hi"] = "{nick} ने आपको माइक लेने के लिए आमंत्रित करता है" inviteMicMsgTranslate["vi"] = "{nick} mời bạn lên Micrô" inviteMicMsgTranslate["ur"] = "{nick} کیطرف سے آپ کو مائیک کی دعوت دی گئی ہے" } }