Commit 43e1f9a9 authored by iamhujiebin's avatar iamhujiebin

feat:增加耗时打点

parent f4eeba74
...@@ -7,6 +7,7 @@ import ( ...@@ -7,6 +7,7 @@ import (
"hilo-group/domain/event/mic_ev" "hilo-group/domain/event/mic_ev"
"hilo-group/domain/model/group_m" "hilo-group/domain/model/group_m"
"hilo-group/domain/service/group_mic_s" "hilo-group/domain/service/group_mic_s"
"time"
) )
func OnMicCheck() { func OnMicCheck() {
...@@ -52,11 +53,12 @@ func OnMicQueue() { ...@@ -52,11 +53,12 @@ func OnMicQueue() {
for true { for true {
model := domain.CreateModelNil() model := domain.CreateModelNil()
if onMic := mic_c.BLPopQueueOnMic(model); onMic != nil { 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 { 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) model.Log.Errorf("cron micIn GroupPowerOnMicExp err:%v", err)
} else { } else {
model.Log.Infof("cron micIn GroupPowerOnMicExp success, groupId:%v, userId:%v", onMic.GroupUuid, onMic.UserId) model.Log.Infof("cron micIn GroupPowerOnMicExp success, groupId:%v, userId:%v,cost:%vs", onMic.GroupUuid, onMic.UserId, time.Now().Sub(start).Seconds())
} }
// 用户上麦 // 用户上麦
......
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