From 6d3ca39315766845d56203eb666c88b9f048e255 Mon Sep 17 00:00:00 2001 From: chenweijian <820961417@qq.com> Date: Wed, 26 Apr 2023 16:53:08 +0800 Subject: [PATCH] trtc --- route/group_r/group_op.go | 17 ++++++++++++----- 1 file changed, 12 insertions(+), 5 deletions(-) diff --git a/route/group_r/group_op.go b/route/group_r/group_op.go index 4502ac1..0741834 100644 --- a/route/group_r/group_op.go +++ b/route/group_r/group_op.go @@ -2,6 +2,7 @@ package group_r import ( "encoding/json" + "git.hilo.cn/hilo-common/_const/rediskey" "git.hilo.cn/hilo-common/domain" "git.hilo.cn/hilo-common/mycontext" "git.hilo.cn/hilo-common/mylogrus" @@ -1756,14 +1757,20 @@ func GroupIn(c *gin.Context) (*mycontext.MyContext, error) { if group_m.IsUseTRTC(model, groupId) { provider = group_e.GroupProvider_TRTC } else { - if time.Now().Unix() > 1683820800 { // todo 1683820800=5月2号，等过审再修改 + dayMaxCovertNum := int64(20) + numKey := rediskey.GetConvertToTRTCNum() + covertNum, err := redisCli.GetCacheInt64(numKey) + if time.Now().Unix() > 1683820800 && err == nil && covertNum <= dayMaxCovertNum { // todo 1683820800=5月2号，等过审再修改 roomUser, err := group_m.GetRoomOnlineUser(myContext, groupId) if err == nil && roomUser.Total == 0 { - if err := group_m.InitTRTC(model, groupId); err != nil { - return myContext, err + newNum, err := redisCli.IncrNumExpire(numKey, 1, time.Hour*24) + if err == nil && newNum <= dayMaxCovertNum { + if err := group_m.InitTRTC(model, groupId); err != nil { + return myContext, err + } + provider = group_e.GroupProvider_TRTC + model.Log.Infof("auto shift trtc room groupId:%v,%+v-%v", groupId, roomUser, err) } - provider = group_e.GroupProvider_TRTC - model.Log.Infof("auto shift trtc room groupId:%v,%+v-%v", groupId, roomUser, err) } } } -- 2.22.0