From c90646febef0c2a0def6aedae2f0dfd9a01e5678 Mon Sep 17 00:00:00 2001 From: chenweijian <820961417@qq.com> Date: Thu, 24 Aug 2023 10:05:26 +0800 Subject: [PATCH] group support --- cron/gift_cron/send_gift_redis.go | 6 +++--- cron/group_cron/group_support.go | 4 ++-- 2 files changed, 5 insertions(+), 5 deletions(-) diff --git a/cron/gift_cron/send_gift_redis.go b/cron/gift_cron/send_gift_redis.go index a393ae2..908b17f 100644 --- a/cron/gift_cron/send_gift_redis.go +++ b/cron/gift_cron/send_gift_redis.go @@ -98,9 +98,9 @@ func groupPowerStar(model *domain.Model, sendGiftEvent *gift_ev.SendGiftEvent) { // 群组扶持增加流水数据 func groupSupportAddConsume(model *domain.Model, sendGiftEvent *gift_ev.SendGiftEvent) { - //if time.Now().Unix() <= 1692964800 { // cwj---- - // return nil - //} + if time.Now().Unix() <= 1692843600 { + return + } model.Log.Infof("groupSupportAddConsume UserId:%d, sendGiftEvent:%+v", sendGiftEvent.SendUserId, sendGiftEvent) if sendGiftEvent.SceneType != gift_e.GroupSceneType || sendGiftEvent.SceneUid == "" { model.Log.Infof("groupSupportAddConsume UserId:%d, sendGiftEvent:%+v", sendGiftEvent.SendUserId, sendGiftEvent) diff --git a/cron/group_cron/group_support.go b/cron/group_cron/group_support.go index 19e1839..e2be39b 100644 --- a/cron/group_cron/group_support.go +++ b/cron/group_cron/group_support.go @@ -97,7 +97,7 @@ func CalcGroupSupport_OldData() { return } c := cron.New() - spec := "0 55 9 24 8 ?" + spec := "0 30 10 24 8 ?" _ = c.AddFunc(spec, func() { defer utils.CheckGoPanic() var model = domain.CreateModelNil() @@ -105,7 +105,7 @@ func CalcGroupSupport_OldData() { model.Log.Infof("CalcGroupSupport_OldData start") beginTime, _, period := group_m.GetSupportLevelTime(time.Now()) - endTime := time.Unix(1692964800, 0) // cwj---- + endTime := time.Unix(1692843600, 0) g := gift_m.GiftOperate{SceneType: gift_e.GroupSceneType, Model: model} records, err := g.BatchGetConsumeByRange(beginTime, endTime) -- 2.22.0