tl_server_2
/
game_sync
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

绑定邀请人任务

This commit is contained in:
sk 2024-05-17 10:45:12 +08:00
parent 11af348377
commit fa34c9c8b2
3 changed files with 46 additions and 50 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
dbproxy/mq/c_invite.go
View File

@ -2,8 +2,6 @@ package mq
import (
"encoding/json"
"fmt"
"time"
"github.com/astaxie/beego/cache"
"mongo.games.com/goserver/core/broker"
@ -44,19 +42,19 @@ func init() {
return err
}
name := fmt.Sprintf("%v", log.InviteSnId)
b := InviteNumCache.Get(name)
n, _ := b.(int32)
if n > 0 {
n++
} else {
n, err = svc.GetInviteNum(log.Platform, log.InviteSnId)
//name := fmt.Sprintf("%v", log.InviteSnId)
//b := InviteNumCache.Get(name)
//n, _ := b.(int32)
//if n > 0 {
// n++
//} else {
n, err := svc.GetInviteNum(log.Platform, log.InviteSnId)
if err != nil {
logger.Logger.Errorf("BindInviteSnId error:%v", err)
return err
}
}
InviteNumCache.Put(name, n, int64(time.Hour.Seconds()))
//}
//InviteNumCache.Put(name, n, int64(time.Hour.Seconds()))
// 更新绑定数量
RabbitMQPublisher.Send(model.AckBindNum, &model.BindNum{

54
worldsrv/action_player.go
View File

@ -1879,33 +1879,6 @@ func CSExchangeChannel(s *netlib.Session, packetid int, data interface{}, sid in
return nil
}
func init() {
// 用户信息
common.Register(int(player_proto.PlayerPacketID_PACKET_CS_PLAYERDATA), player_proto.CSPlayerData{}, CSPlayerData)
// 查看别人信息
common.Register(int(player_proto.PlayerPacketID_PACKET_CS_QUERYPLAYER), player_proto.CSQueryPlayer{}, CSQueryPlayer)
// 修改个人信息
common.Register(int(player_proto.PlayerPacketID_PACKET_CSSavePlayerInfo), player_proto.CSSavePlayerInfo{}, CSSavePlayerInfo)
// 修改头像url
common.Register(int(player_proto.PlayerPacketID_PACKET_CS_HeadUrl), player_proto.CSHeadUrl{}, CSHeadUrl)
// 获取绑定手机号奖励
common.Register(int(player_proto.PlayerPacketID_PACKET_CSBindTelInfo), player_proto.CSBindTelInfo{}, CSBindTelInfo)
// 获取短信验证码
common.Register(int(player_proto.PlayerPacketID_PACKET_CSPlayerSMSCode), player_proto.CSPlayerSMSCode{}, CSPlayerSMSCode)
// 绑定手机号
common.Register(int(player_proto.PlayerPacketID_PACKET_CSBindTel), player_proto.CSBindTel{}, CSBindTel)
// 获取图片验证码
common.Register(int(player_proto.PlayerPacketID_PACKET_CS_GETIMAGEVERIFYCODE), player_proto.CSGetImageVerifyCode{}, CSGetImageVerifyCodeLocal)
// 验证图片验证码
common.Register(int(player_proto.PlayerPacketID_PACKET_CS_ImageVerifyCode), player_proto.CSImageVerifyCode{}, CSImageVerifyCode)
// 查询游戏账变记录
common.Register(int(player_proto.PlayerPacketID_PACKET_CSBillList), player_proto.CSBillList{}, CSBillList)
// 看广告一次
common.Register(int(player_proto.PlayerPacketID_PACKET_CSADV), player_proto.CSADV{}, CSADV)
// 开启兑换的渠道
common.Register(int(player_proto.PlayerPacketID_PACKET_CSExchangeChannel), player_proto.CSExchangeChannel{}, CSExchangeChannel)
}
func CSPlayerData(s *netlib.Session, packetid int, data interface{}, sid int64) error {
logger.Logger.Trace("CSPlayerDataHandler Process recv ", data)
cspl, ok := data.(*player_proto.CSPlayerData)
@ -2842,3 +2815,30 @@ func CSADV(s *netlib.Session, packetId int, data interface{}, sid int64) error {
logger.Logger.Tracef("SCADV %v", ret)
return nil
}
func init() {
// 用户信息
common.Register(int(player_proto.PlayerPacketID_PACKET_CS_PLAYERDATA), player_proto.CSPlayerData{}, CSPlayerData)
// 查看别人信息
common.Register(int(player_proto.PlayerPacketID_PACKET_CS_QUERYPLAYER), player_proto.CSQueryPlayer{}, CSQueryPlayer)
// 修改个人信息
common.Register(int(player_proto.PlayerPacketID_PACKET_CSSavePlayerInfo), player_proto.CSSavePlayerInfo{}, CSSavePlayerInfo)
// 修改头像url
common.Register(int(player_proto.PlayerPacketID_PACKET_CS_HeadUrl), player_proto.CSHeadUrl{}, CSHeadUrl)
// 获取绑定手机号奖励
common.Register(int(player_proto.PlayerPacketID_PACKET_CSBindTelInfo), player_proto.CSBindTelInfo{}, CSBindTelInfo)
// 获取短信验证码
common.Register(int(player_proto.PlayerPacketID_PACKET_CSPlayerSMSCode), player_proto.CSPlayerSMSCode{}, CSPlayerSMSCode)
// 绑定手机号
common.Register(int(player_proto.PlayerPacketID_PACKET_CSBindTel), player_proto.CSBindTel{}, CSBindTel)
// 获取图片验证码
common.Register(int(player_proto.PlayerPacketID_PACKET_CS_GETIMAGEVERIFYCODE), player_proto.CSGetImageVerifyCode{}, CSGetImageVerifyCodeLocal)
// 验证图片验证码
common.Register(int(player_proto.PlayerPacketID_PACKET_CS_ImageVerifyCode), player_proto.CSImageVerifyCode{}, CSImageVerifyCode)
// 查询游戏账变记录
common.Register(int(player_proto.PlayerPacketID_PACKET_CSBillList), player_proto.CSBillList{}, CSBillList)
// 看广告一次
common.Register(int(player_proto.PlayerPacketID_PACKET_CSADV), player_proto.CSADV{}, CSADV)
// 开启兑换的渠道
common.Register(int(player_proto.PlayerPacketID_PACKET_CSExchangeChannel), player_proto.CSExchangeChannel{}, CSExchangeChannel)
}

16
worldsrv/action_welfare.go
View File

@ -376,6 +376,12 @@ func CSBindInvite(s *netlib.Session, packetid int, data interface{}, sid int64)
}
}
if p.InviteSnId != 0 {
ret.OpRetCode = welfare.OpResultCode_OPRC_AlreadyBind
send()
return nil
}
task.New(nil, task.CallableWrapper(func(o *basic.Object) interface{} {
inviteSnId, err = model.GetSnIdByCode(p.Platform, msg.GetCode())
return nil
@ -387,22 +393,14 @@ func CSBindInvite(s *netlib.Session, packetid int, data interface{}, sid int64)
return
}
if p.InviteSnId != 0 {
ret.OpRetCode = welfare.OpResultCode_OPRC_AlreadyBind
send()
return
}
if inviteSnId == p.SnId {
ret.OpRetCode = welfare.OpResultCode_OPRC_BindSelf
send()
return
}
pp := PlayerMgrSington.GetPlayerBySnId(inviteSnId)
if pp != nil {
if pp.Platform != p.Platform {
send()
return
}
if pp.InviteSnId == p.SnId {
ret.OpRetCode = welfare.OpResultCode_OPRC_MyInvite
send()