Skip to content

H
hilo-group
Commit 7fd4e7d2 authored by chenweijian's avatar chenweijian Committed by hujiebin
Browse files
Options

trtc导量

parent e9da5280
Show whitespace changes
Inline Side-by-side
Showing with 30 additions and 30 deletions
domain/service/group_s/group_op.go
View file @ 7fd4e7d2
...@@ -44,10 +44,10 @@ func (s *GroupService) CreateGroup(userId uint64, g *group_m.GroupInfo) error { ...@@ -44,10 +44,10 @@ func (s *GroupService) CreateGroup(userId uint64, g *group_m.GroupInfo) error {
if err := group_m.CreateGroupRole(model, g.ImGroupId, userId, group_e.GROUP_OWNER); err != nil { if err := group_m.CreateGroupRole(model, g.ImGroupId, userId, group_e.GROUP_OWNER); err != nil {
return err return err
} }
// 新房间标记成trtc房间 //// 新房间标记成trtc房间
if err := group_m.InitTRTC(model, g.ImGroupId); err != nil { //if err := group_m.InitTRTC(model, g.ImGroupId); err != nil {
model.Log.Errorf("CreateGroup g:%+v, err:%v", g, err) // model.Log.Errorf("CreateGroup g:%+v, err:%v", g, err)
} //}
return nil return nil
}) })
} }
......
route/group_r/group_op.go
View file @ 7fd4e7d2
...@@ -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"
...@@ -1763,36 +1762,37 @@ func GroupIn(c *gin.Context) (*mycontext.MyContext, error) { ...@@ -1763,36 +1762,37 @@ func GroupIn(c *gin.Context) (*mycontext.MyContext, error) {
provider := group_e.GroupProvider_SW provider := group_e.GroupProvider_SW
if group_m.IsUseTRTC(model, groupId) { if group_m.IsUseTRTC(model, groupId) {
provider = group_e.GroupProvider_TRTC provider = group_e.GroupProvider_TRTC
//total := int64(2000) total := int64(11000)
//if !config.AppIsRelease() { if !config.AppIsRelease() {
// total = 0 total = 30
//} }
//if group_m.CountTRTC(model) > total { if group_m.CountTRTC(model) > total {
// roomUser, err := group_m.GetRoomOnlineUser(myContext, groupId)
// if err == nil && roomUser.Total == 0 {
// if err := group_m.DeleteTRTC(model, groupId); err == nil {
// provider = group_e.GroupProvider_SW
// }
// }
//}
} else {
dayMaxCovertNum := int64(150)
numKey := rediskey.GetConvertToTRTCNum()
covertNum, err := redisCli.GetCacheInt64(numKey)
if time.Now().Unix() > 1682499704 && err == nil && covertNum <= dayMaxCovertNum {
//if false && 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) if err := group_m.DeleteTRTC(model, groupId); err == nil {
if err == nil && newNum <= dayMaxCovertNum { provider = group_e.GroupProvider_SW
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)
} }
} }
} }
} else {
// 增加trtc房间
//dayMaxCovertNum := int64(150)
//numKey := rediskey.GetConvertToTRTCNum()
//covertNum, err := redisCli.GetCacheInt64(numKey)
//if time.Now().Unix() > 1682499704 && err == nil && covertNum <= dayMaxCovertNum {
// //if false && time.Now().Unix() > 1682499704 {
// roomUser, err := group_m.GetRoomOnlineUser(myContext, groupId)
// if err == nil && roomUser.Total == 0 {
// 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)
// }
// }
//}
} }
if provider == group_e.GroupProvider_TRTC { if provider == group_e.GroupProvider_TRTC {
// 版本升级提示，旧版本(3.6.0以下)，提示升级 // 版本升级提示，旧版本(3.6.0以下)，提示升级
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment