feat：更换redis队列

cron/cron.go

@@ -14,7 +14,7 @@ func Init() {
 	//gift_cron.SendGiftEventInit()   // 礼物消息
 	//gift_cron.GiftRemark()          // 礼物消息补偿
 	gift_cron.SendGiftEvent()       // 礼物事件
-	//mic_cron.OnMicCheck()           // 检查上麦
+	mic_cron.OnMicCheck()           // 检查上麦
 	mic_cron.OnMicQueue()           // 检查上麦-队列操作
 	group_cron.GroupPowerExpClear() // 清理家族经验/等级
 	group_cron.GroupPowerMonthRankAct()

domain/cache/mic_c/queue.go

@@ -14,14 +14,14 @@ func QueueOnMic(model *domain.Model, onMic *mic_ev.OnMicEvent) error {
 	queue := mic_k.GetOnMicQueue()
 	onMic.Ts = time.Now().UnixNano() // 给一个时间戳
 	body, _ := json.Marshal(onMic)
-	return model.Redis.RPush(model, queue, string(body)).Err()
+	return model.RedisCluster.RPush(model, queue, string(body)).Err()
 }
 
 // redis pop on mic
 func BLPopQueueOnMic(model *domain.Model) *mic_ev.OnMicEvent {
 	var res *mic_ev.OnMicEvent
 	queue := mic_k.GetOnMicQueue()
-	strs, err := model.Redis.BLPop(model, time.Second, queue).Result()
+	strs, err := model.RedisCluster.BLPop(model, time.Second, queue).Result()
 	if err != nil {
 		if err != redis.Nil {
 			model.Log.Errorf("BLPopQueueOnMic fail:%v", err)