...
 
Commits (9)
...@@ -2,7 +2,6 @@ package group_r ...@@ -2,7 +2,6 @@ package group_r
import ( import (
"encoding/json" "encoding/json"
"git.hilo.cn/hilo-common/_const/rediskey"
"git.hilo.cn/hilo-common/domain" "git.hilo.cn/hilo-common/domain"
"git.hilo.cn/hilo-common/mycontext" "git.hilo.cn/hilo-common/mycontext"
"git.hilo.cn/hilo-common/mylogrus" "git.hilo.cn/hilo-common/mylogrus"
...@@ -1757,20 +1756,21 @@ func GroupIn(c *gin.Context) (*mycontext.MyContext, error) { ...@@ -1757,20 +1756,21 @@ func GroupIn(c *gin.Context) (*mycontext.MyContext, error) {
if group_m.IsUseTRTC(model, groupId) { if group_m.IsUseTRTC(model, groupId) {
provider = group_e.GroupProvider_TRTC provider = group_e.GroupProvider_TRTC
} else { } else {
dayMaxCovertNum := int64(20) //dayMaxCovertNum := int64(20)
numKey := rediskey.GetConvertToTRTCNum() //numKey := rediskey.GetConvertToTRTCNum()
covertNum, err := redisCli.GetCacheInt64(numKey) //covertNum, err := redisCli.GetCacheInt64(numKey)
if time.Now().Unix() > 1682499704 && err == nil && covertNum <= dayMaxCovertNum { //if time.Now().Unix() > 1682499704 && err == nil && covertNum <= dayMaxCovertNum {
if time.Now().Unix() > 1682499704 {
roomUser, err := group_m.GetRoomOnlineUser(myContext, groupId) roomUser, err := group_m.GetRoomOnlineUser(myContext, groupId)
if err == nil && roomUser.Total == 0 { if err == nil && roomUser.Total == 0 {
newNum, err := redisCli.IncrNumExpire(numKey, 1, time.Hour*24) //newNum, err := redisCli.IncrNumExpire(numKey, 1, time.Hour*24)
if err == nil && newNum <= dayMaxCovertNum { //if err == nil && newNum <= dayMaxCovertNum {
if err := group_m.InitTRTC(model, groupId); err != nil { if err := group_m.InitTRTC(model, groupId); err != nil {
return myContext, err 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)
//}
} }
} }
} }
......