diff --git a/domain/service/event_s/cp_level.go b/domain/service/event_s/cp_level.go index 3ee55e5c69ea67a5c31f5863998fae09c811dfb8..0fbdb52cac71e4d291c13df27ae7f478076c895c 100644 --- a/domain/service/event_s/cp_level.go +++ b/domain/service/event_s/cp_level.go @@ -2,6 +2,7 @@ package event_s import ( "git.hilo.cn/hilo-common/domain" + "git.hilo.cn/hilo-common/resource/config" "git.hilo.cn/hilo-common/resource/redisCli" "github.com/jinzhu/now" "hilo-user/_const/enum/cp_e" @@ -76,8 +77,11 @@ func CpGiftEvent() { // 送礼增加cp等级 // 送礼增加cp排行榜 func CompensateCpScore() { + if !config.IsMaster() { + return + } model := domain.CreateModelNil() - num, err := redisCli.IncrNumExpire("scirpt:CompensateCpScore", 1, time.Hour*999) + num, err := redisCli.IncrNumExpire("scirpt:compensateCpScore", 1, time.Hour*999) if err != nil { model.Log.Errorf("CompensateCpScore err:%v", err) } @@ -98,8 +102,11 @@ func CompensateCpScore() { CreatedTime time.Time `json:"created_time"` } rows := make([]*GiftOperate, 0) - err = model.DB().Model(GiftOperate{}).Where("res_gift_id in (?)", - []int{3561, 3571, 3581, 3591, 3601, 3611, 3621, 3631, 3641, 3651, 3661, 3671, 3681, 3691, 3701, 3711}).Where("created_time < ?", "2023-06-22 11:20:15").Find(&rows).Error + err = model.DB().Model(GiftOperate{}). + Where("created_time < ?", "2023-06-22 11:20:15"). + Where("res_gift_id in (?)", + []int{3561, 3571, 3581, 3591, 3601, 3611, 3621, 3631, 3641, 3651, 3661, 3671, 3681, 3691, 3701, 3711}). + Find(&rows).Error if err != nil { model.Log.Errorf("CompensateCpScore err:%v", err) return diff --git a/domain/service/event_s/event_init.go b/domain/service/event_s/event_init.go index 14d10791780e443bedaaa10727789f7c96e8e1f0..5517a83c704c17c42ad3914e1e3a16a5c8292d66 100644 --- a/domain/service/event_s/event_init.go +++ b/domain/service/event_s/event_init.go @@ -16,6 +16,7 @@ func EventInit() { UserBagSendEvent() CpGiftEvent() CpSpaceVisitEvent() + CompensateCpScore() } func UserBagSendEvent() {