143 lines
4.3 KiB
Go
143 lines
4.3 KiB
Go
package clawdoll
|
||
|
||
import (
|
||
"mongo.games.com/game/common"
|
||
"mongo.games.com/game/gamesrv/base"
|
||
"mongo.games.com/game/protocol/clawdoll"
|
||
"mongo.games.com/game/protocol/machine"
|
||
"mongo.games.com/goserver/core/logger"
|
||
"mongo.games.com/goserver/core/netlib"
|
||
)
|
||
|
||
type CSPlayerOpPacketFactory struct {
|
||
}
|
||
|
||
type CSPlayerOpHandler struct {
|
||
}
|
||
|
||
func (f *CSPlayerOpPacketFactory) CreatePacket() interface{} {
|
||
pack := &clawdoll.CSCLAWDOLLOp{}
|
||
return pack
|
||
}
|
||
|
||
func (h *CSPlayerOpHandler) Process(s *netlib.Session, packetid int, data interface{}, sid int64) error {
|
||
logger.Logger.Trace("CSPlayerOpHandler Process recv ", data)
|
||
if msg, ok := data.(*clawdoll.CSCLAWDOLLOp); ok {
|
||
p := base.PlayerMgrSington.GetPlayer(sid)
|
||
if p == nil {
|
||
logger.Logger.Warn("CSPlayerOpHandler p == nil")
|
||
return nil
|
||
}
|
||
scene := p.GetScene()
|
||
if scene == nil {
|
||
logger.Logger.Warn("CSPlayerOpHandler p.scene == nil")
|
||
return nil
|
||
}
|
||
|
||
if scene.KeyGameDif != common.GameDifClawdoll {
|
||
logger.Logger.Error("CSPlayerOpHandler gameId Error ", scene.GameId)
|
||
return nil
|
||
}
|
||
if !scene.HasPlayer(p) {
|
||
return nil
|
||
}
|
||
sp := scene.GetScenePolicy()
|
||
if sp != nil {
|
||
sp.OnPlayerOp(scene, p, int(msg.GetOpCode()), msg.GetParams())
|
||
}
|
||
return nil
|
||
}
|
||
return nil
|
||
}
|
||
func MSDollMachineoCoinResultHandler(session *netlib.Session, packetId int, data interface{}) error {
|
||
logger.Logger.Tracef("收到返回上分结果！！！！！！！！！！")
|
||
if msg, ok := data.(*machine.MSDollMachineoPerateResult); ok {
|
||
switch msg.TypeId {
|
||
case 1:
|
||
if msg.Result == 1 {
|
||
logger.Logger.Tracef("上分成功！！！！！！！！！！！！snid = ", msg.Snid)
|
||
} else {
|
||
logger.Logger.Tracef("上分失败！！！！！！！！！！！！snid = ", msg.Snid)
|
||
}
|
||
case 2:
|
||
if msg.Result == 1 {
|
||
logger.Logger.Tracef("下抓成功！！！！！！！！！！！！snid = ", msg.Snid)
|
||
} else {
|
||
logger.Logger.Tracef("下抓失败！！！！！！！！！！！！snid = ", msg.Snid)
|
||
}
|
||
}
|
||
}
|
||
return nil
|
||
}
|
||
|
||
type CSGetTokenPacketFactory struct {
|
||
}
|
||
|
||
type CSGetTokenHandler struct {
|
||
}
|
||
|
||
func (f *CSGetTokenPacketFactory) CreatePacket() interface{} {
|
||
pack := &clawdoll.CSCLAWDOLLGetToken{}
|
||
return pack
|
||
}
|
||
|
||
func (h *CSGetTokenHandler) Process(s *netlib.Session, packetid int, data interface{}, sid int64) error {
|
||
//转发到娃娃机主机
|
||
logger.Logger.Tracef("CSGetTokenHandler")
|
||
if msg, ok := data.(*clawdoll.CSCLAWDOLLGetToken); ok {
|
||
p := base.PlayerMgrSington.GetPlayer(sid)
|
||
if p == nil {
|
||
logger.Logger.Warn("CSGetTokenHandler p == nil")
|
||
return nil
|
||
}
|
||
pack := &machine.SMGetToken{}
|
||
pack.Snid = p.SnId
|
||
pack.AppId = msg.Appid
|
||
scene := p.GetScene()
|
||
if scene == nil {
|
||
return nil
|
||
}
|
||
sceneEx, ok := scene.ExtraData.(*SceneEx)
|
||
if !ok {
|
||
return nil
|
||
}
|
||
serverSecret := sceneEx.GetMachineServerSecret(msg.Appid, p.Platform)
|
||
logger.Logger.Tracef("获取娃娃机serverSecret = %v", serverSecret)
|
||
if serverSecret == "" {
|
||
return nil
|
||
}
|
||
pack.ServerSecret = serverSecret
|
||
sceneEx.SendToMachine(int(machine.DollMachinePacketID_PACKET_SMGetToken), pack)
|
||
}
|
||
return nil
|
||
}
|
||
|
||
// 娃娃机返回token 通知客户端
|
||
func MSSendTokenHandler(session *netlib.Session, packetId int, data interface{}) error {
|
||
logger.Logger.Tracef("MSSendTokenHandler")
|
||
if msg, ok := data.(*machine.MSSendToken); ok {
|
||
//给客户端返回token
|
||
token := msg.Token
|
||
p := base.PlayerMgrSington.GetPlayer(int64(msg.Snid))
|
||
if p == nil {
|
||
logger.Logger.Warn("MSSendTokenHandler p == nil")
|
||
return nil
|
||
}
|
||
pack := &clawdoll.SCCLAWDOLLSendToken{
|
||
Token: token,
|
||
}
|
||
p.SendToClient(int(clawdoll.CLAWDOLLPacketID_PACKET_SC_SENDTOKEN), pack)
|
||
}
|
||
return nil
|
||
}
|
||
func init() {
|
||
common.RegisterHandler(int(clawdoll.CLAWDOLLPacketID_PACKET_CS_PLAYEROP), &CSPlayerOpHandler{})
|
||
netlib.RegisterFactory(int(clawdoll.CLAWDOLLPacketID_PACKET_CS_PLAYEROP), &CSPlayerOpPacketFactory{})
|
||
netlib.Register(int(machine.DollMachinePacketID_PACKET_MSDollMachineoPerateResult), &machine.MSDollMachineoPerateResult{}, MSDollMachineoCoinResultHandler)
|
||
//客户端请求token
|
||
common.RegisterHandler(int(clawdoll.CLAWDOLLPacketID_PACKET_CS_GETTOKEN), &CSGetTokenHandler{})
|
||
netlib.RegisterFactory(int(clawdoll.CLAWDOLLPacketID_PACKET_CS_GETTOKEN), &CSGetTokenPacketFactory{})
|
||
//获取token返回
|
||
netlib.Register(int(machine.DollMachinePacketID_PACKET_MSSendToken), &machine.MSSendToken{}, MSSendTokenHandler)
|
||
}
|