diff --git a/cron/mic_cron/on_mic.go b/cron/mic_cron/on_mic.go index e5096874d3a8fc3cb2a24a701b57cf5954bbec4c..84d364e5132749630c8b270e40eb96cf82e88032 100644 --- a/cron/mic_cron/on_mic.go +++ b/cron/mic_cron/on_mic.go @@ -1,8 +1,10 @@ package mic_cron import ( + "fmt" "git.hilo.cn/hilo-common/domain" "github.com/robfig/cron" + "hilo-group/_const/redis_key/mic_k" "hilo-group/domain/cache/mic_c" "hilo-group/domain/event/mic_ev" "hilo-group/domain/model/group_m" @@ -24,6 +26,7 @@ func OnMicCheck() { return } for _, groupId := range groupIds { + onGroupMicKey := mic_k.GetGroupOnMicUser(groupId) // 同步在mic上的人 //遍历每个麦位 for i := 1; i <= group_m.MaxMicNum; i++ { micUser, err := group_m.GetMicUser(model, groupId, i) @@ -41,6 +44,11 @@ func OnMicCheck() { }); err != nil { model.Log.Errorf("QueueOnMic fail:%v", err) } + // 设置mic上的人 + model.Redis.HSet(model, onGroupMicKey, i, micUser.UserId) + } else { + // 删除mic上的人 + model.Redis.HDel(model, onGroupMicKey, fmt.Sprintf("%d", i)) } } }