diff --git a/cron/gift_cron/send_gift_redis.go b/cron/gift_cron/send_gift_redis.go index a393ae2369ae9c4286830a265925b0910e2c28ed..908b17f8233f7b679f2425016d3ead4cec441e00 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 19e1839065695c2009789b0e318121d2b21252a6..e2be39b218fb60b1bd9b2bf7f07547c91e0eedfb 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)