252 lines
8.4 KiB
Go
252 lines
8.4 KiB
Go
package game
|
|
|
|
import (
|
|
"fmt"
|
|
"reflect"
|
|
"server/MergeConst"
|
|
"server/conf"
|
|
"server/game/internal"
|
|
GoUtil "server/game_util"
|
|
"strings"
|
|
"time"
|
|
|
|
"server/msg"
|
|
|
|
"server/pkg/github.com/name5566/leaf/gate"
|
|
"server/pkg/github.com/name5566/leaf/log"
|
|
|
|
"google.golang.org/protobuf/proto"
|
|
|
|
"server/db"
|
|
)
|
|
|
|
var (
|
|
Module = new(internal.Module)
|
|
ChanRPC = internal.ChanRPC
|
|
)
|
|
|
|
func handler(m interface{}, h interface{}) {
|
|
Module.Skeleton.RegisterChanRPC(reflect.TypeOf(m), h)
|
|
}
|
|
|
|
func RegisterHandlerRPC(param []interface{}) {
|
|
handler(&msg.ClientReq{}, HandleClientReq)
|
|
handler(&msg.AdminReq{}, HandleAdminReq)
|
|
}
|
|
|
|
func init() {
|
|
register()
|
|
db.InitDB()
|
|
db.InitRedis()
|
|
// db.TestGetAllKey()
|
|
GoUtil.RegisterEvent("GameModuleOnInit", RegisterHandlerRPC, nil)
|
|
G_getGameLogic()
|
|
}
|
|
|
|
func HandleAdminReq(args []interface{}) {
|
|
m := args[0].(*msg.AdminReq)
|
|
// 消息的发送者
|
|
a := args[1].(gate.Agent)
|
|
buf := m.GetInfo()
|
|
// log.Debug("admin 消息Func : %s", m.GetFunc())
|
|
AdminProcess(m.GetFunc(), []interface{}{a, buf})
|
|
}
|
|
|
|
func HandleClientReq(args []interface{}) {
|
|
defer func() {
|
|
if r := recover(); r != nil {
|
|
log.Error("HandleClientReq panic: %v", r)
|
|
}
|
|
}()
|
|
start := time.Now()
|
|
if G_GameLogicPtr.SeverInfo.Status == SERVER_STATUS_CLOSE || G_GameLogicPtr.SeverInfo.Status == SERVER_STATUS_MAINTAIN {
|
|
return // 服务器关闭或者维护中，不处理任何消息
|
|
}
|
|
m := args[0].(*msg.ClientReq)
|
|
// 消息的发送者
|
|
a := args[1].(gate.Agent)
|
|
buf := m.GetInfo()
|
|
// log.Debug("消息Func : %s", m.GetFunc())
|
|
switch m.GetFunc() {
|
|
case "ClientTick":
|
|
case "ReqChangePassword":
|
|
detail := &msg.ReqChangePassword{}
|
|
proto.Unmarshal(buf, detail)
|
|
accountInfo := db.GetAccountInfoFromDb(detail.UserName)
|
|
if accountInfo == nil {
|
|
ResChangePassword := &msg.ResChangePassword{}
|
|
ResChangePassword.ResultCode = MergeConst.Protocol_Error_Account_NoExsit
|
|
data, _ := proto.Marshal(ResChangePassword)
|
|
G_GameLogicPtr.PackResInfo(a, "ResChangePassword", data)
|
|
return
|
|
}
|
|
if accountInfo.UserPassword != detail.OldPwd && detail.OldPwd != "-1" {
|
|
ResChangePassword := &msg.ResChangePassword{}
|
|
ResChangePassword.ResultCode = MergeConst.Protocol_Error_Account_OR_PWD_ERROR
|
|
data, _ := proto.Marshal(ResChangePassword)
|
|
G_GameLogicPtr.PackResInfo(a, "ResChangePassword", data)
|
|
return
|
|
}
|
|
if strings.Count(detail.NewPwd, "")-1 < 6 {
|
|
ResChangePassword := &msg.ResChangePassword{}
|
|
ResChangePassword.ResultCode = MergeConst.Protocol_Error_Account_OR_PWD_Short
|
|
data, _ := proto.Marshal(ResChangePassword)
|
|
G_GameLogicPtr.PackResInfo(a, "ResChangePassword", data)
|
|
return
|
|
}
|
|
accountInfo.UserPassword = detail.NewPwd
|
|
err := db.UpdateAccountInfoToDb(accountInfo)
|
|
if err != nil {
|
|
ResChangePassword := &msg.ResChangePassword{}
|
|
ResChangePassword.ResultCode = MergeConst.Protocol_Error_Account_Fail
|
|
data, _ := proto.Marshal(ResChangePassword)
|
|
G_GameLogicPtr.PackResInfo(a, "ResChangePassword", data)
|
|
return
|
|
}
|
|
ResChangePassword := &msg.ResChangePassword{}
|
|
ResChangePassword.ResultCode = 0
|
|
data, _ := proto.Marshal(ResChangePassword)
|
|
G_GameLogicPtr.PackResInfo(a, "ResChangePassword", data)
|
|
case "ReqAdminInfo": // 后台接口
|
|
AdminProcess(m.GetFunc(), []interface{}{a, buf})
|
|
case "ReqLoginCode":
|
|
Detail := &msg.ReqLoginCode{}
|
|
proto.Unmarshal(buf, Detail)
|
|
Code, err := GeneratedCode(Detail.TelPhone)
|
|
ResLoginCode := &msg.ResLoginCode{}
|
|
if err != nil {
|
|
ResLoginCode.ResultCode = MergeConst.Protocol_Error_Account_Code_Error
|
|
ResLoginCode.Msg = err.Error()
|
|
}
|
|
ResLoginCode.Code = Code
|
|
data, _ := proto.Marshal(ResLoginCode)
|
|
G_GameLogicPtr.PackResInfo(a, "ResLoginCode", data)
|
|
case "ReqServerVersion":
|
|
G_GameLogicPtr.SendServerVersion(a)
|
|
case "ReqRegisterAccount":
|
|
detail := &msg.ReqRegisterAccount{}
|
|
log.Debug("player %s start register", detail.UserName)
|
|
proto.Unmarshal(buf, detail)
|
|
gl := G_getGameLogic()
|
|
defer func() {
|
|
if r := recover(); r != nil {
|
|
GoUtil.SendFeishuFatal(0, m.GetFunc(), fmt.Sprintf("username: %s, fatal: %s", detail.UserName, r))
|
|
log.Error("uid : %d, func : %s, fatal : %s", 0, m.GetFunc(), r)
|
|
}
|
|
}()
|
|
if gl.IsExsitAccount(detail.UserName) {
|
|
ResRegisterAccount := &msg.ResRegisterAccount{}
|
|
ResRegisterAccount.ResultCode = MergeConst.Protocol_Error_Account_Exist
|
|
data, _ := proto.Marshal(ResRegisterAccount)
|
|
gl.PackResInfo(a, "ResRegisterAccount", data)
|
|
break
|
|
}
|
|
gl.Db_AccountInfo.UserName = detail.UserName
|
|
gl.Db_AccountInfo.UserPassword = detail.UserPwd
|
|
if !gl.NewAccountInsertDataToDB() {
|
|
ResRegisterAccount := &msg.ResRegisterAccount{}
|
|
ResRegisterAccount.ResultCode = MergeConst.Protocol_Error_Account_Fail
|
|
data, _ := proto.Marshal(ResRegisterAccount)
|
|
gl.PackResInfo(a, "ResRegisterAccount", data)
|
|
break
|
|
}
|
|
ResRegisterAccount := &msg.ResRegisterAccount{}
|
|
ResRegisterAccount.ResultCode = 0
|
|
data, _ := proto.Marshal(ResRegisterAccount)
|
|
gl.PackResInfo(a, "ResRegisterAccount", data)
|
|
case "ReqLogin": // 登录请求
|
|
detail := &msg.ReqLogin{}
|
|
proto.Unmarshal(buf, detail)
|
|
accountInfo := db.GetAccountInfoFromDb(detail.UserName)
|
|
log.Debug("player %s start login", detail.UserName)
|
|
defer func() {
|
|
if r := recover(); r != nil {
|
|
GoUtil.SendFeishuFatal(0, m.GetFunc(), fmt.Sprintf("username: %s, fatal: %s", detail.UserName, r))
|
|
log.Error("uid : %d, func : %s, fatal : %s", 0, m.GetFunc(), r)
|
|
}
|
|
}()
|
|
ResLogin, accountInfo := VerifyUser(accountInfo, detail)
|
|
if ResLogin.ResultCode != 0 {
|
|
G_GameLogicPtr.PackLoginResInfo(a, ResLogin)
|
|
return
|
|
}
|
|
newPlayer := false
|
|
if ResLogin.DwUin > 0 {
|
|
PlayerInfo := G_GameLogicPtr.GetPlayer(ResLogin.DwUin)
|
|
err := G_GameLogicPtr.ReplaceExistPlayerAndAgent(a, PlayerInfo)
|
|
if err != nil {
|
|
PlayerInfo = G_GameLogicPtr.CreateNewPlayer(a, detail.UserName)
|
|
newPlayer = true
|
|
}
|
|
if PlayerInfo.PlayMod.getBaseMod().IdCardName == "" && conf.Server.IdVerify {
|
|
ResLogin.ResultCode = MergeConst.Protocol_Error_Id_Not_Verify
|
|
G_GameLogicPtr.PackLoginResInfo(a, ResLogin)
|
|
return
|
|
}
|
|
}
|
|
accountInfo.DeviceId = detail.Device
|
|
db.UpdateAccountInfoDeviceToDb(accountInfo)
|
|
p, _ := internal.Agents.Load(a)
|
|
if p != nil {
|
|
p.(*Player).lock.Lock() //加锁
|
|
defer p.(*Player).lock.Unlock() //解锁
|
|
log.Debug("player %s login success", detail.UserName)
|
|
p.(*Player).PlayMod.getBaseMod().DiviceId = detail.Device //加锁
|
|
p.(*Player).PushClientRes(ResLogin)
|
|
p.(*Player).LoginBackData()
|
|
p.(*Player).TeLog("Login_log", nil)
|
|
p.(*Player).ProcessTrigger()
|
|
}
|
|
log.Debug("uid : %d, init user process : %s, execTime : %v , isNew: %v", p.(*Player).M_DwUin, m.GetFunc(), time.Since(start), newPlayer)
|
|
case "ReqServerTime": // 获取服务器时间
|
|
detail := &msg.ReqServerTime{}
|
|
proto.Unmarshal(buf, detail)
|
|
res := &msg.ResServerTime{}
|
|
res.ServerTime = (int32)(time.Now().Unix())
|
|
data, _ := proto.Marshal(res)
|
|
G_getGameLogic().PackResInfo(a, "ResServerTime", data)
|
|
case "ReqOfflineReconnect": // 断线重连
|
|
ReqOfflineReconnectFunc(a, buf)
|
|
default:
|
|
p, ok := internal.Agents.Load(a)
|
|
if ok && p != G_GameLogicPtr.NotInitPlayer {
|
|
p.(*Player).lock.Lock() //加锁
|
|
backup := p.(*Player).BackUp() // 备份当前的 Player 值
|
|
defer func() {
|
|
if r := recover(); r != nil {
|
|
if m.GetFunc() != "ReqGmCommand" { // 如果不是 GM 命令，才记录日志和发送飞书告警
|
|
log.Error("uid : %d, func : %s, fatal : %s", p.(*Player).M_DwUin, m.GetFunc(), r)
|
|
GoUtil.SendFeishuFatal(int(p.(*Player).M_DwUin), m.GetFunc(), fmt.Sprintf("fatal : %s", r))
|
|
}
|
|
p.(*Player).Recover(backup) //还原Player的数据
|
|
}
|
|
backup.Reclaim() // 回收备份对象
|
|
p.(*Player).lock.Unlock() //解锁
|
|
}()
|
|
p.(*Player).args = make(map[string]interface{})
|
|
p.(*Player).args["func"] = m
|
|
p.(*Player).args["agent"] = a
|
|
err := RunNetProcessByKey(m.GetFunc(), []interface{}{a, buf})
|
|
if err != nil {
|
|
log.Error("uid : %d, func : %s, err : %s", p.(*Player).M_DwUin, m.GetFunc(), err)
|
|
p.(*Player).TeLog("func_exec_error", map[string]interface{}{
|
|
"method_name": m.GetFunc(),
|
|
"error_info": err.Error(),
|
|
})
|
|
p.(*Player).Recover(backup) //还原Player的数据
|
|
return
|
|
}
|
|
p.(*Player).ProcessTrigger()
|
|
p.(*Player).TeLog("func_exec_time", map[string]interface{}{
|
|
"method_name": m.GetFunc(),
|
|
"exec_time": fmt.Sprintf("%v", time.Since(start)),
|
|
})
|
|
}
|
|
}
|
|
p, b := internal.Agents.Load(a)
|
|
if b {
|
|
p.(*Player).SendClientRes()
|
|
}
|
|
//log.Debug("uid : %d, func : %s, execTime : %s ", p.(*Player).M_DwUin, m.GetFunc(), time.Since(start))
|
|
}
|