From 577a8fefa199301e37bb61dc93176a7d74a114fe Mon Sep 17 00:00:00 2001 From: hujiebin Date: Wed, 6 Sep 2023 11:11:04 +0800 Subject: [PATCH] =?UTF-8?q?feat:=E5=90=8C=E6=AD=A5=E5=9C=A8mic=E4=B8=8A?= =?UTF-8?q?=E7=9A=84=E4=BA=BA?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- cron/mic_cron/on_mic.go | 8 ++++++++ 1 file changed, 8 insertions(+) diff --git a/cron/mic_cron/on_mic.go b/cron/mic_cron/on_mic.go index e509687..84d364e 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)) } } } -- 2.22.0