diff --git a/cron/mic_cron/on_mic.go b/cron/mic_cron/on_mic.go index fb6137671a28b0e5ed3ef96c736612305748801b..fad371a27ff59ba8bfa088bf02946ba13faf203a 100644 --- a/cron/mic_cron/on_mic.go +++ b/cron/mic_cron/on_mic.go @@ -7,6 +7,7 @@ import ( "hilo-group/domain/event/mic_ev" "hilo-group/domain/model/group_m" "hilo-group/domain/service/group_mic_s" + "time" ) func OnMicCheck() { @@ -47,24 +48,27 @@ func OnMicCheck() { } func OnMicQueue() { - go func() { - for true { - model := domain.CreateModelNil() - if onMic := mic_c.BLPopQueueOnMic(model); onMic != nil { - // 群组上麦经验 - if err := group_mic_s.NewGroupPowerService(model.MyContext).IncrGroupPowerOnMicExpAndTime(onMic.GroupUuid, onMic.UserId, onMic.Timestamp); err != nil { - model.Log.Errorf("cron micIn GroupPowerOnMicExp err:%v", err) - } else { - model.Log.Infof("cron micIn GroupPowerOnMicExp success, groupId:%v, userId:%v", onMic.GroupUuid, onMic.UserId) - } + for i := 0; i < 4; i++ { + go func() { + for true { + model := domain.CreateModelNil() + if onMic := mic_c.BLPopQueueOnMic(model); onMic != nil { + start := time.Now() + // 群组上麦经验 + if err := group_mic_s.NewGroupPowerService(model.MyContext).IncrGroupPowerOnMicExpAndTime(onMic.GroupUuid, onMic.UserId, onMic.Timestamp); err != nil { + model.Log.Errorf("cron micIn GroupPowerOnMicExp err:%v", err) + } else { + model.Log.Infof("cron micIn GroupPowerOnMicExp success, groupId:%v, userId:%v,cost:%vs", onMic.GroupUuid, onMic.UserId, time.Now().Sub(start).Seconds()) + } - // 用户上麦 - //if err := mic_m.IncrUserOnMic(model, onMic.UserId, onMic.Timestamp); err != nil { - // model.Log.Errorf("cron micIn IncrUserOnMic err:%v", err) - //} else { - // model.Log.Infof("cron micIn IncrUserOnMic success,userId:%v", onMic.UserId) - //} + // 用户上麦 + //if err := mic_m.IncrUserOnMic(model, onMic.UserId, onMic.Timestamp); err != nil { + // model.Log.Errorf("cron micIn IncrUserOnMic err:%v", err) + //} else { + // model.Log.Infof("cron micIn IncrUserOnMic success,userId:%v", onMic.UserId) + //} + } } - } - }() + }() + } }