Merge branch 'dev_aagame_rtp_new' into dev_aagame

call/config.go

@@ -2678,6 +2678,9 @@ func LoadConfigRtpControl() (err error) {
 }
 
 func GetConfigRtpControl() []*common.ConfigRtpControl {
+	if len(configRtpControl) == 0 {
+		LoadConfigRtpControl()
+	}
 	return configRtpControl
 }
 
@@ -2712,6 +2715,9 @@ func GetConfigRtpTemplate() []*common.ConfigRtpTemplate {
 }
 
 func GetConfigRtpTemplateId() string {
+	if len(configTemplates) == 0 {
+		LoadConfigRtpTemplate()
+	}
 	for _, v := range configTemplates {
 		if v.Open == 1 && v.TemplateId != "" {
 			return v.TemplateId

modules/web/providers/sn/handler.go

@@ -3,7 +3,9 @@ package sn
 import (
 	"context"
 	"encoding/json"
+	"errors"
 	"fmt"
+	"github.com/go-redis/redis/v8"
 	"io/ioutil"
 	"server/call"
 	"server/common"
@@ -185,6 +187,10 @@ func GameBet(c *gin.Context) {
 	resp.Msg = "success"
 	log.Debug("sn gameBetResp, %s:%+v", account, resp)
 	a.Data = resp
+	go func() {
+		defer util.Recover()
+		checkControl(uid)
+	}()
 }
 
 func Settle(c *gin.Context) {
@@ -602,7 +608,7 @@ func GameControlCallback(c *gin.Context) {
 		return
 	}
 	defer func() {
-		err = Control(uid, util.ToInt(req.ControlId))
+		err = Control(uid, util.ToInt(req.ControlId), "", 0)
 		if err != nil {
 			log.Error("sn control err, %s", err.Error())
 		}
@@ -627,21 +633,78 @@ func checkSpecialControl(result string) bool {
 
 const specialControlRtp = 85
 
-func Control(uid int, controlId int) error {
-	if controlId == 0 {
-		controlId = 1
+func checkControl(uid int) {
+	result, err := db.Redis().GetRedis().Get(context.Background(), fmt.Sprintf("player:%v:sn:status", uid)).Result()
+	if err != nil {
+		if errors.Is(err, redis.Nil) {
+			return
+		}
+		log.Error("get user sn status err, %s", err.Error())
+		return
+	}
+	if result == "" {
+		log.Error("get user sn status is nil, %d", uid)
+		return
+	}
+	//log.Debug("sn control update, uid:%d status:%s", uid, result)
+	controlInfos := strings.Split(result, "|")
+	rtp := util.ToInt(controlInfos[0])
+	templateId := controlInfos[1]
+	rtpNow := getControlRtp(uid)
+	totalRecharge, defaultValue, templateIdNow := getControlTemplate(uid)
+	var update bool
+	if templateId != "" && templateId != templateIdNow { // 直接更新
+		update = true
+	}
+	if templateId == "" && rtp != rtpNow {
+		update = true
 	}
+	if update {
+		log.Debug("sn control update, uid:%d old info:%d|%s new info:%d|%s(%d|%d)", uid, rtp, templateId, rtpNow, templateIdNow, totalRecharge, defaultValue)
+		Control(uid, 0, templateIdNow, rtpNow)
+	}
+}
+
+func getControlRtp(uid int) int {
 	rtp := call.GetRtpControlV1(uid)
 	result, _ := db.Redis().GetRedis().Get(context.Background(), fmt.Sprintf("player:%v:games:at", uid)).Result()
 	if rtp > specialControlRtp && checkSpecialControl(result) {
 		rtp = specialControlRtp
 		log.Debug("rtpControl special, uid:%d result:%s, rtp:%d", uid, result, specialControlRtp)
 	}
+	return rtp
+}
+
+func getControlTemplate(uid int) (int64, int, string) {
 	templateId := call.GetConfigRtpTemplateId()
 	if templateId == "" && DefaultTemplateId != "" {
 		log.Debug("sn cfg templateId is nil")
 		templateId = DefaultTemplateId
 	}
+	defaultTemplateRecharge := 300 * common.DecimalDigits
+	userInfo, _ := call.GetUserInfo(uid)
+	channelInfo := call.GetChannelByID(userInfo.ChannelID)
+	if channelInfo.TemplateRecharge > 0 {
+		defaultTemplateRecharge = channelInfo.TemplateRecharge
+	}
+	rechargeInfo := call.GetRechargeInfo(uid)
+	if rechargeInfo.TotalRecharge >= int64(defaultTemplateRecharge) {
+		templateId = ""
+	}
+	//log.Debug("sn control template, uid:%d %d|%d %s", uid, rechargeInfo.TotalRecharge, defaultTemplateRecharge, templateId)
+	return rechargeInfo.TotalRecharge, defaultTemplateRecharge, templateId
+}
+
+func Control(uid int, controlId int, templateId string, rtp int) error {
+	if controlId == 0 {
+		controlId = 1
+	}
+	var totalRecharge int64
+	var defaultValue int
+	if rtp == 0 && templateId == "" {
+		rtp = getControlRtp(uid)
+		totalRecharge, defaultValue, templateId = getControlTemplate(uid)
+	}
 	req := &ControlReq{
 		BaseReq: BaseReq{
 			SnAccount: SnAccount,
@@ -661,18 +724,7 @@ func Control(uid int, controlId int) error {
 		},
 	}
 
-	defaultTemplateRecharge := 300 * common.DecimalDigits
-	userInfo, _ := call.GetUserInfo(uid)
-	channelInfo := call.GetChannelByID(userInfo.ChannelID)
-	if channelInfo.TemplateRecharge > 0 {
-		defaultTemplateRecharge = channelInfo.TemplateRecharge
-	}
-	rechargeInfo := call.GetRechargeInfo(uid)
-	if rechargeInfo.TotalRecharge >= int64(defaultTemplateRecharge) {
-		req.TemplateId = ""
-	}
-
-	log.Debug("sn control req, %+v", *req)
+	log.Debug("sn control req, %+v templateInfo(%d|%d)", *req, totalRecharge, defaultValue)
 	reqBody, _ := json.Marshal(req)
 	var tmpValue map[string]interface{}
 	json.Unmarshal(reqBody, &tmpValue)
@@ -685,10 +737,13 @@ func Control(uid int, controlId int) error {
 		return err
 	}
 	if resp.Code != CodeRequestSuccess && resp.Code != CodeRequestExist {
-		log.Error("control err, %+v", resp)
-		return fmt.Errorf("control err, %+v ", resp)
+		log.Error("sn control err, %+v", resp)
+		return fmt.Errorf("sn control err, %+v ", resp)
+	}
+	err = db.Redis().GetRedis().Set(context.Background(), fmt.Sprintf("player:%v:sn:status", uid), fmt.Sprintf("%d|%s", rtp, templateId), 0).Err()
+	if err != nil {
+		log.Error("sn control, set user sn status err, %s", err.Error())
 	}
-
 	return nil
 }