release #14

Merged
mfangming merged 2 commits from release into dev 1 year ago
  1. 28
      call/user.go
  2. 10
      modules/web/handler/vip.go

@ -7,6 +7,7 @@ import (
"fmt" "fmt"
"math/rand" "math/rand"
"reflect" "reflect"
"regexp"
"server/common" "server/common"
"server/config" "server/config"
"server/db" "server/db"
@ -196,17 +197,26 @@ func NewUser(info *common.PlayerDBInfo, ip, share, fbc, fbp, agent string) error
// fb绑定 // fb绑定
func FBBind(ip string, uid, cid int, fbc, fbp, agent string) { func FBBind(ip string, uid, cid int, fbc, fbp, agent string) {
// 优先ip绑定 // 优先ip绑定
pa := &common.PlayerADData{IP: ip, ChannelID: cid} // pa := &common.PlayerADData{IP: ip, ChannelID: cid}
db.Mysql().GetLast(pa) var ret []common.PlayerADData
if pa.ID != 0 { _, err := db.Mysql().QueryAll(fmt.Sprintf("ip = '%s' and channel_id = %d ", ip, cid), "id asc", &common.PlayerADData{}, &ret)
if pa.UID == 0 { if err != nil {
db.Mysql().Update(pa, map[string]interface{}{"uid": uid}) log.Error("fbbind err:%v", err)
} else {
newPa := &common.PlayerADData{UID: uid, IP: ip, ChannelID: cid, FBC: pa.FBC, FBP: pa.FBP, UserAgent: agent}
db.Mysql().Create(newPa)
}
return return
} }
for _, pa := range ret {
// 判断fbc 是否满足要求
re := regexp.MustCompile(`^fb\.1\.\d+\.[a-zA-Z0-9\-_]+$`)
if re.MatchString(pa.FBC) {
if pa.UID == 0 {
db.Mysql().Update(pa, map[string]interface{}{"uid": uid})
} else {
newPa := &common.PlayerADData{UID: uid, IP: ip, ChannelID: cid, FBC: pa.FBC, FBP: pa.FBP, UserAgent: agent}
db.Mysql().Create(newPa)
}
return
}
}
// 绑定fb数据 // 绑定fb数据
if len(fbc) != 0 || len(fbp) != 0 { if len(fbc) != 0 || len(fbp) != 0 {

@ -144,7 +144,7 @@ func DrawVipBonus(c *gin.Context) {
bonus := con.Bonus bonus := con.Bonus
if bonus <= 0 { if bonus <= 0 {
a.Code = values.CodeParam a.Code = values.CodeParam
a.Msg = "reward invalid" a.Msg = "इनम अम"
return return
} }
newDraws := vip.Draws | flag newDraws := vip.Draws | flag
@ -193,7 +193,7 @@ func DrawVipCashback(c *gin.Context) {
db.Mysql().UpdateResW(&common.VipData{}, map[string]interface{}{"profit_time": now.Unix(), "cashback": 0, "profit": 0}, db.Mysql().UpdateResW(&common.VipData{}, map[string]interface{}{"profit_time": now.Unix(), "cashback": 0, "profit": 0},
fmt.Sprintf("uid = %v and profit_time = %v", a.UID, vip.ProfitTime)) fmt.Sprintf("uid = %v and profit_time = %v", a.UID, vip.ProfitTime))
a.Code = values.CodeParam a.Code = values.CodeParam
a.Msg = "reward invalid" a.Msg = "इनम अम"
return return
} else { } else {
cashback = vip.Profit * con.Cashback / 1000 cashback = vip.Profit * con.Cashback / 1000
@ -208,7 +208,7 @@ func DrawVipCashback(c *gin.Context) {
db.Mysql().UpdateResW(&common.VipData{}, map[string]interface{}{"profit_time": now.Unix(), "cashback": 0, "profit": 0}, db.Mysql().UpdateResW(&common.VipData{}, map[string]interface{}{"profit_time": now.Unix(), "cashback": 0, "profit": 0},
fmt.Sprintf("uid = %v and profit_time = %v", a.UID, vip.ProfitTime)) fmt.Sprintf("uid = %v and profit_time = %v", a.UID, vip.ProfitTime))
a.Code = values.CodeParam a.Code = values.CodeParam
a.Msg = "reward invalid" a.Msg = "इनम अम"
return return
} else { } else {
cashback = vip.Profit * con.Cashback / 1000 cashback = vip.Profit * con.Cashback / 1000
@ -220,7 +220,7 @@ func DrawVipCashback(c *gin.Context) {
if cashback <= 0 { if cashback <= 0 {
a.Code = values.CodeParam a.Code = values.CodeParam
a.Msg = "reward invalid" a.Msg = "इनम अम"
return return
} }
@ -233,7 +233,7 @@ func DrawVipCashback(c *gin.Context) {
if err != nil || rows == 0 { if err != nil || rows == 0 {
log.Error("err:%v", err) log.Error("err:%v", err)
a.Code = values.CodeParam a.Code = values.CodeParam
a.Msg = "reward invalid" a.Msg = "इनम अम"
return return
} }
_, err = call.UpdateCurrencyPro(&common.UpdateCurrency{ _, err = call.UpdateCurrencyPro(&common.UpdateCurrency{

Loading…
Cancel
Save