From ff26e2649b83610119bd794c5510c8cea52abd24 Mon Sep 17 00:00:00 2001
From: chenweijian <820961417@qq.com>
Date: Thu, 22 Jun 2023 13:21:22 +0800
Subject: [PATCH] =?UTF-8?q?cp=E8=A1=A5=E5=81=BF=E5=88=86=E6=95=B0?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 domain/service/event_s/cp_level.go   | 13 ++++++++++---
 domain/service/event_s/event_init.go |  1 +
 2 files changed, 11 insertions(+), 3 deletions(-)

diff --git a/domain/service/event_s/cp_level.go b/domain/service/event_s/cp_level.go
index 3ee55e5..0fbdb52 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 14d1079..5517a83 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() {
-- 
2.22.0