diff --git a/cron/cron.go b/cron/cron.go index d752a013d6f7a29b414b3a58158eecdf3b64bd3b..6acb656d97c4a059262038cf8fe915b098331f20 100644 --- a/cron/cron.go +++ b/cron/cron.go @@ -13,8 +13,8 @@ func Init() { } //gift_cron.SendGiftEventInit() // 礼物消息 //gift_cron.GiftRemark() // 礼物消息补偿 - gift_cron.SendGiftEvent() // 礼物事件 - //mic_cron.OnMicCheck() // 检查上麦 + gift_cron.SendGiftEvent() // 礼物事件 + mic_cron.OnMicCheck() // 检查上麦 mic_cron.OnMicQueue() // 检查上麦-队列操作 group_cron.GroupPowerExpClear() // 清理家族经验/等级 group_cron.GroupPowerMonthRankAct() diff --git a/domain/cache/mic_c/queue.go b/domain/cache/mic_c/queue.go index e717b86c592ebe343ef760b85fc7772fe597101d..c4d6277631ad4e380fae3607b1a49fd581d463a9 100644 --- a/domain/cache/mic_c/queue.go +++ b/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)