Merge remote-tracking branch 'origin/master' into fix/group_support

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)
+					//}
+				}
 			}
-		}
-	}()
+		}()
+	}
 }