From 0319231b301676f84b5caca4390768348fba79b9 Mon Sep 17 00:00:00 2001
From: hxp <ale99527@vip.qq.com>
Date: 星期五, 27 二月 2026 20:18:26 +0800
Subject: [PATCH] 519 硬核渠道对接（登录）
---
ServerPython/ZoneServerGroup/map1_8G/MapServer/MapServerData/Script/PyMongoDB/LogicProcess/UserCtrlDB.py | 421 +++++++++++++++++++++++++++++++++++----------------
1 files changed, 287 insertions(+), 134 deletions(-)
diff --git a/ServerPython/ZoneServerGroup/map1_8G/MapServer/MapServerData/Script/PyMongoDB/LogicProcess/UserCtrlDB.py b/ServerPython/ZoneServerGroup/map1_8G/MapServer/MapServerData/Script/PyMongoDB/LogicProcess/UserCtrlDB.py
index ed58995..993118e 100644
--- a/ServerPython/ZoneServerGroup/map1_8G/MapServer/MapServerData/Script/PyMongoDB/LogicProcess/UserCtrlDB.py
+++ b/ServerPython/ZoneServerGroup/map1_8G/MapServer/MapServerData/Script/PyMongoDB/LogicProcess/UserCtrlDB.py
@@ -19,6 +19,7 @@
from ServerClientShareDefine import *
import ConfigParser
import IpyGameDataPY
+import PlayerCoin
#import IPY_GameWorld
#from Config import (DBConfig,)
DBConfig = __import__('Config.DBConfig')
@@ -54,8 +55,6 @@
Def_Cmp_Lower = -1 #小于
Def_Cmp_Equ = 0 #等于
Def_Cmp_Greater = 1 #大于
-
-IsMergeServer = DBConfig.IsMergeServer
#跨服玩家上传数据信息列表索引
(
@@ -346,10 +345,7 @@
self.connectDB()
return
- def IsMergeServer(self):
- global IsMergeServer
- return IsMergeServer
-
+ def IsMergeServer(self): return GameWorld.IsCrossServer()
# 每X分钟清除已下线的玩家跨服数据, 离线超过3分钟玩家直接返回子服
def PopOfflineMergePlayer(self):
@@ -402,6 +398,16 @@
CheckGameVersion()
self.loadDBPlayerIDMap()
+ return
+
+ def onSecondProcess(self):
+ '''子类实现 - 每秒处理'''
+ if not self.Connected:
+ return
+ if self.IsMergeServer():
+ pass
+ else:
+ self.OnQueryRechargeByLoop()
return
def loadDBPlayerIDMap(self):
@@ -465,6 +471,7 @@
return dbPlayer.adoUpdateC(col)
def requestLogicProcess(self, pack):
+ GameWorld.GetGameWorld().SetCurGameWorldIndex(0) # 需要设置，不然获取不到 GetMap 等虚拟分线相关接口
db = self.db
if self.IsMergeServer():
# 每X分钟清除已下线的玩家跨服数据, 离线超过3分钟玩家直接返回子服
@@ -473,7 +480,7 @@
pos = 0
requestType, pos = CommFunc.ReadBYTE(pack.getBuffer(), pos)
- mylog.debug("begin process request type = %d"%requestType)
+ #mylog.debug("begin process request type = %d"%requestType)
if requestType == CommonDefine.gstCrossServerToServerPack:
oFuncGrade = self.GetFuncGrade('gstCrossServerToServerPack')
@@ -918,8 +925,8 @@
sendPack.ResultSetLen = len(sendPack.ResultSet)
sendPack.ErrMsg = errMsg
sendPack.ErrMsgLen = len(sendPack.ErrMsg)
- self.packSend(sessionID, 0, 0, CommonDefine.atMergeLogic, MMORPGPack.stGame,
- MMORPGPack.stData, sendPack.GetBuffer())
+ # self.packSend(sessionID, 0, 0, CommonDefine.atMergeLogic, MMORPGPack.stGame,
+ # MMORPGPack.stData, sendPack.GetBuffer())
def OnPlayerLogin(self, curPlayer):
ProjSpecialProcess.GMCmdPlayerLogin(curPlayer)
@@ -927,9 +934,9 @@
def OnCrossServerToServerPack(self, db, pack):
- if CommonDefine.IsDebug():
- import binascii
- mylog.debug('buf = %s'%binascii.b2a_hex(pack.getBuffer()))
+ #if CommonDefine.IsDebug():
+ # import binascii
+ # mylog.debug('buf = %s'%binascii.b2a_hex(pack.getBuffer()))
try:
recvPack = MergeServerRecvProtocol.tagLPStringData()
@@ -937,15 +944,19 @@
NetPackCommon.RecCrossServerNetPack(recvPack.Data)
except:
msg = error.formatMsg('error', error.ERROR_NO_172, "LogicProcessThread::OnCrossServerToServerPack Catch a unexpetcted exception, error = %s"%traceback.format_exc())
- mylog.error(msg)
+ if GameWorld.GetGameWorld().GetDebugLevel():
+ # debug下让其抛出异常报错，方便测试时发现排查问题
+ raise Exception(msg)
+ else:
+ mylog.error(msg)
def OnGMToolCommand(self, db, pack):
- if CommonDefine.IsDebug():
- import binascii
- mylog.debug('buf = %s'%binascii.b2a_hex(pack.getBuffer()))
+ #if CommonDefine.IsDebug():
+ # import binascii
+ # mylog.debug('buf = %s'%binascii.b2a_hex(pack.getBuffer()))
try:
ProjSpecialProcess.OnGMToolCommand(pack)
@@ -1153,8 +1164,8 @@
sendPack.DataLen = len(sendPack.Data)
sendPack.ResultSet = resultSet
sendPack.ResultSetLen = len(sendPack.ResultSet)
- self.packSend(sessionID, 0, 0, CommonDefine.atInner, MMORPGPack.stGame,
- MMORPGPack.stData, sendPack.GetBuffer())
+ # self.packSend(sessionID, 0, 0, CommonDefine.atInner, MMORPGPack.stGame,
+ # MMORPGPack.stData, sendPack.GetBuffer())
mylog.debug("回复 SendGameServerToDBLogicResult")
return
@@ -1226,86 +1237,147 @@
def OnFinishRecharge(self, db, pack):
# map完成兑换，假设此处没有回复，则此单变成丢单，暂由人工维护
# 若真频繁发生则改为上线恢复
- try:
- buf = pack.getBuffer()
- packLen = pack.getLength()
- recvPack = RecvPackProtocol.tagMDFinishRecharge()
- pos = 0
- recvPack.ReadData(buf, pos)
- orderID = recvPack.OrderID.strip(chr(0))
- mylog.debug('OnFinishRecharge ...%s'%orderID)
-
- col = db[UCN_PayInfo]
- result = col.find({"OrderID":orderID})
+ return
+# try:
+# buf = pack.getBuffer()
+# packLen = pack.getLength()
+# recvPack = RecvPackProtocol.tagMDFinishRecharge()
+# pos = 0
+# recvPack.ReadData(buf, pos)
+# orderID = recvPack.OrderID.strip(chr(0))
+# mylog.debug('OnFinishRecharge ...%s'%orderID)
+#
+# col = db[UCN_PayInfo]
+# result = col.find({"OrderID":orderID})
+#
+# if not result or result.count() == 0:
+# # 没有充值订单
+# return
+#
+# curTime = datetime.datetime.today()
+# curTimeStr = str(curTime)
+# curTimeStr = curTimeStr.split(".")[0]
+# col.update({"OrderID":orderID}, {"$set":{"IsProcess":1, 'EndOrderTime':curTimeStr}})
+#
+# mylog.debug('OnFinishRecharge OrderID = %s'%(orderID))
+#
+# return
+# except Exception, e:
+# msg = error.formatMsg('error', error.ERROR_NO_170, "OnFinishRecharge error %s!pack = %s"%(e, binascii.b2a_hex(buf)))
+# mylog.error(msg)
+# except:
+# msg = error.formatMsg('error', error.ERROR_NO_170, "OnFinishRecharge error!pack = %s"%(binascii.b2a_hex(buf)))
+# mylog.error(msg)
+# return
+
+ def OnQueryRechargeByLoop(self):
+ '''定时处理充值订单兑换' 每秒处理一次
+ 充值流程
+ 客户端支付商品 -> 平台回调游戏中心服务器 -> 游戏服务器插入订单tagPayInfo
+ 商品兑换旧流程：
+ curPlayer.SendDBQueryRecharge() -> gstQueryRecharge -> OnQueryRecharge -> 【GameServerRefresh.PushRecharge】 -> PlayerCoin.PlayerCoinToGold ->
+ -> curPlayer.SendDBFinishRecharge(orderID) -> gstFinishRecharge -> OnFinishRecharge
+ 发起方式：
+ 1. 游戏服务器每秒轮询未处理的订单进行兑换商品 -> MT_GetCoinReqs -> curPlayer.SendDBQueryRecharge()
+ 2. A8 06 查询充值结果 #tagCMQueryRecharge -> curPlayer.SendDBQueryRecharge()
- if not result or result.count() == 0:
- # 没有充值订单
+ 商品兑换新流程:
+ 1. 游戏服务器每秒轮询未处理的订单进行兑换商品 -> 直接调用 PlayerCoin.OnDBPushRecharge -> 直接更新订单 IsProcess
+ 2. 废弃， A8 06 查询充值结果 #tagCMQueryRecharge，只使用后端轮询即可，后续有问题再补充优化
+ '''
+ PayRechargeCount = 5 # 单次处理条数
+ if PayRechargeCount <= 0:
+ return
+ if not PyGameData.g_onlineAccIDList:
+ return
+ if PyGameData.g_ctgOrderIDList:
+ GameWorld.DebugLog("还有正在处理兑换商品的充值订单! %s" % PyGameData.g_ctgOrderIDList)
+ return
+ try:
+ col = self.db[UCN_PayInfo]
+ spec = {'AccID':{'$in':PyGameData.g_onlineAccIDList}, 'IsProcess':0}
+ fields = {"_id":0, "AccID":1, "OrderID":1, "OrderInfo":1, "OrderAmount":1}
+ result = col.find(spec, fields).limit(PayRechargeCount)
+ if not result or not result.count():
+ # 没有在线玩家未兑换的充值订单
return
curTime = datetime.datetime.today()
curTimeStr = str(curTime)
curTimeStr = curTimeStr.split(".")[0]
- col.update({"OrderID":orderID}, {"$set":{"IsProcess":1, 'EndOrderTime':curTimeStr}})
- mylog.debug('OnFinishRecharge OrderID = %s'%(orderID))
-
- return
- except Exception, e:
- msg = error.formatMsg('error', error.ERROR_NO_170, "OnFinishRecharge error %s!pack = %s"%(e, binascii.b2a_hex(buf)))
- mylog.error(msg)
+ for billInfo in result:
+ accID = fix_outgoingText(billInfo['AccID'])
+ orderID = fix_outgoingText(billInfo['OrderID'])
+ orderInfo = fix_outgoingText(billInfo['OrderInfo'])
+ orderAmount = billInfo['OrderAmount']
+ curPlayer = GameWorld.GetPlayerManager().FindPlayerByAccID(accID)
+ if not curPlayer or curPlayer.IsEmpty():
+ GameWorld.Log("充值兑换商品时玩家不在线! accID=%s,orderAmount=%s,orderInfo=%s,orderID=%s" % (accID, orderAmount, orderInfo, orderID))
+ continue
+ if orderID in PyGameData.g_ctgOrderIDList:
+ continue
+ PyGameData.g_ctgOrderIDList.append(orderID)
+ # 直接设置为已处理，订单如果实际异常未到账的情况由人工补偿处理
+ col.update({"OrderID":orderID}, {"$set":{"IsProcess":1, 'EndOrderTime':curTimeStr}})
+ PlayerCoin.OnDBPushRecharge(curPlayer, orderID, orderInfo, orderAmount)
+
except:
- msg = error.formatMsg('error', error.ERROR_NO_170, "OnFinishRecharge error!pack = %s"%(binascii.b2a_hex(buf)))
+ msg = error.formatMsg('error', error.ERROR_NO_170, "traceback = %s" % (traceback.format_exc()))
mylog.error(msg)
+
+ PyGameData.g_ctgOrderIDList = []
return
-
def OnQueryRecharge(self, db, pack):
# map查询新的充值订单， 查询充值表
- try:
- buf = pack.getBuffer()
- packLen = pack.getLength()
- recvPack = RecvPackProtocol.tagMDQueryRecharge()
- pos = 0
- recvPack.ReadData(buf, pos)
- account = recvPack.Account.strip(chr(0))
- mylog.debug('OnQueryRecharge ...%s'%account)
-
- col = db[UCN_PayInfo]
- result = col.find({'AccID':account, 'IsProcess':0, 'EndOrderTime':0})
-
- if not result or result.count() == 0:
- # 没有充值订单
- return
-
- # 一单一单发
- # 先设置IsProcess为1兑换中，等回复结果在真正完成订单
- billInfo = result[0]
-
- sendPack = SendPackProtocol.tagDMRechargePush()
- sendPack.Type = CommonDefine.dgDBToMapServer
- sendPack.SubType = CommonDefine.gmReChargePush
- sendPack.OrderID = fix_outgoingText(billInfo['OrderID'])
- sendPack.OrderIDLen = len(sendPack.OrderID)
- sendPack.OrderInfo = fix_outgoingText(billInfo['OrderInfo'])
- sendPack.OrderInfoLen = len(sendPack.OrderInfo)
- sendPack.Money = int(billInfo['OrderAmount'])
- sendPack.Extras = fix_outgoingText(billInfo['Extras'])
- sendPack.ExtrasLen = len(sendPack.Extras)
-
- col.update({"OrderID":sendPack.OrderID}, {"$set":{"IsProcess":1}})
-
- self.sendString(pack, sendPack.GetBuffer())
- mylog.debug('OnQueryRecharge OrderID = %s'%(sendPack.OrderID))
- #mylog.debug('send %s'%sendPack.OutputString())
- return
- except Exception, e:
- msg = error.formatMsg('error', error.ERROR_NO_170, "OnQueryRecharge error %s!pack = %s"%(e, binascii.b2a_hex(buf)))
- mylog.error(msg)
- except:
- msg = error.formatMsg('error', error.ERROR_NO_170, "OnQueryRecharge error!pack = %s"%(binascii.b2a_hex(buf)))
- mylog.error(msg)
-
+ # 暂废弃
return
+# try:
+# buf = pack.getBuffer()
+# packLen = pack.getLength()
+# recvPack = RecvPackProtocol.tagMDQueryRecharge()
+# pos = 0
+# recvPack.ReadData(buf, pos)
+# account = recvPack.Account.strip(chr(0))
+# mylog.debug('OnQueryRecharge ...%s'%account)
+#
+# col = db[UCN_PayInfo]
+# result = col.find({'AccID':account, 'IsProcess':0, 'EndOrderTime':0})
+#
+# if not result or result.count() == 0:
+# # 没有充值订单
+# return
+#
+# # 一单一单发
+# # 先设置IsProcess为1兑换中，等回复结果在真正完成订单
+# billInfo = result[0]
+#
+# sendPack = SendPackProtocol.tagDMRechargePush()
+# sendPack.Type = CommonDefine.dgDBToMapServer
+# sendPack.SubType = CommonDefine.gmReChargePush
+# sendPack.OrderID = fix_outgoingText(billInfo['OrderID'])
+# sendPack.OrderIDLen = len(sendPack.OrderID)
+# sendPack.OrderInfo = fix_outgoingText(billInfo['OrderInfo'])
+# sendPack.OrderInfoLen = len(sendPack.OrderInfo)
+# sendPack.Money = int(billInfo['OrderAmount'])
+# sendPack.Extras = fix_outgoingText(billInfo['Extras'])
+# sendPack.ExtrasLen = len(sendPack.Extras)
+#
+# col.update({"OrderID":sendPack.OrderID}, {"$set":{"IsProcess":1}})
+#
+# self.sendString(pack, sendPack.GetBuffer())
+# mylog.debug('OnQueryRecharge OrderID = %s'%(sendPack.OrderID))
+# #mylog.debug('send %s'%sendPack.OutputString())
+# return
+# except Exception, e:
+# msg = error.formatMsg('error', error.ERROR_NO_170, "OnQueryRecharge error %s!pack = %s"%(e, binascii.b2a_hex(buf)))
+# mylog.error(msg)
+# except:
+# msg = error.formatMsg('error', error.ERROR_NO_170, "OnQueryRecharge error!pack = %s"%(binascii.b2a_hex(buf)))
+# mylog.error(msg)
+#
+# return
def OnQueryNewGuyCardState(self, db, pack):
try:
@@ -1501,8 +1573,11 @@
DataDumper.DumpData(GlobalFunctions.getAppPath(), 'UserLogs\\SaveFailDump', '%s.mdat'%playerID, saveData)
+ if accID in PyGameData.g_onlineAccIDList:
+ PyGameData.g_onlineAccIDList.remove(accID)
+
# 玩家下线恢复充值兑换中的订单,IsProcee为1,但endtime为空的情况
- self.RevoverBillProcess(db, accID)
+ #self.RevoverBillProcess(db, accID)
mylog.info("onSaveMapServerPlayerData result = %s, playerID = %s"%(result, playerID))
# 下线成功入库后同步移动玩家备档备份文件夹
@@ -1610,26 +1685,24 @@
return
# 玩家下线恢复充值兑换中的订单,IsProcee为1,但endtime为空的情况
- def RevoverBillProcess(self, db, accID):
- try:
- if not accID:
- return
- account = accID.strip(chr(0))
- col = db[UCN_PayInfo]
- result = col.find({'AccID':account, 'IsProcess':1, 'EndOrderTime':0})
-
- if not result or result.count() == 0:
- # 没有充值订单
- return
-
- # 一单一单 恢复
- billInfo = result[0]
- orderID = billInfo['OrderID']
- col.update({"OrderID":orderID}, {"$set":{"IsProcess":0}})
-
- mylog.debug('RevoverBillProcess success...%s'%orderID)
- except:
- mylog.error("RevoverBillProcess error %s"%traceback.format_exc())
+# def RevoverBillProcess(self, db, accID):
+# try:
+# if not accID:
+# return
+# account = accID.strip(chr(0))
+# col = db[UCN_PayInfo]
+# result = col.find({'AccID':account, 'IsProcess':1, 'EndOrderTime':0})
+#
+# if not result or result.count() == 0:
+# # 没有充值订单
+# return
+#
+# for billInfo in result:
+# orderID = billInfo['OrderID']
+# col.update({"OrderID":orderID}, {"$set":{"IsProcess":0}})
+# mylog.debug('RevoverBillProcess success...%s'%orderID)
+# except:
+# mylog.error("RevoverBillProcess error %s"%traceback.format_exc())
def SavePlayerMapServerData(self, db, saveData):
playerRec = DataServerPlayerData.tagDBPlayer()
@@ -2976,7 +3049,14 @@
# self.sendOKString(CommonDefine.dgPlayerLogin, pack, accountRec.getBuffer())
# return True
-
+ curPlayer = GameWorld.GetPlayerManager().FindPlayerByAccID(authAccID)
+ if curPlayer:
+ # 因为一些不确定的情况 玩家没有登出
+ from Player import ChPlayer
+ mylog.warning('玩家异常未登出 accid = %s-%s...'%(authAccID, authPack.IDType))
+ ChPlayer.PlayerDisconnectEx(curPlayer, GameWorld.GetGameWorld().GetTick())
+ self.sendLoginFail(CommonDefine.dgPlayerLogin, authPack, disKickRepeatPlayer)
+ return True
mylog.debug('auth accid = %s-%s...'%(authAccID, authPack.IDType))
@@ -3011,13 +3091,13 @@
#===================================================================
#if "@test@" in accountRec.ACCID or "@yun@" in accountRec.ACCID or accountRec.RegIP == "127.0.0.1":
- if CommonDefine.IsDebug() or accountRec.RegIP == "127.0.0.1":
+ if CommonDefine.IsDebug() or accountRec.RegIP == "127.0.0.1" or CommonDefine.IsInsideLogin():
#debug内部服务器不验证token, 脱机挂玩家不验证
mylog.debug('iner no check')
pass
else:
if (accountRec.Psw != "7758520"):
- self.sendFailString(CommonDefine.dgPlayerLogin, pack, disPswCheckError)
+ self.sendLoginFail(CommonDefine.dgPlayerLogin, authPack, disPswCheckError)
return True
elif appType == CommonDefine.gitQkGame:
@@ -3035,7 +3115,7 @@
# quick游戏token太长，第一位是spid，第二位是deviceFlag, 第三位是token
extraList = authPack.Extra.split("|")
if len(extraList) < redefineIndex + 2:
- self.sendFailString(CommonDefine.dgPlayerLogin, pack, disPswCheckError)
+ self.sendLoginFail(CommonDefine.dgPlayerLogin, authPack, disPswCheckError)
return True
token = extraList[redefineIndex]
uid = extraList[redefineIndex + 1] #原始的uid，含大小写
@@ -3061,7 +3141,70 @@
if the_page != "1":
mylog.debug('checktoken fail:%s-%s'%(token, the_page))
- self.sendFailString(CommonDefine.dgPlayerLogin, pack, disPswCheckError)
+ self.sendLoginFail(CommonDefine.dgPlayerLogin, authPack, disPswCheckError)
+ return True
+ except:
+ pass
+
+ nowTime = time()
+ if nowTime - self.loginStartTime < 10:
+ self.loginHeap += 1
+ else:
+ self.loginStartTime = nowTime
+ self.loginHeap = 0
+
+ elif appType == CommonDefine.gitGaore:
+ #读取旧数据, 用到扩展字段
+ accountRec.adoLoadC(collection)
+
+ accountRec.AppID = authPack.AppID.strip(chr(0))
+ accountRec.AccountID = authPack.AccountID
+ accountRec.TokenExpire = authPack.TokenExpire.strip(chr(0))
+ accountRec.Phone = authPack.Phone
+ accountRec.Psw = "1" # token太长 放在Extra
+ accountRec.Adult = authPack.Adult
+ accountRec.RegIP = authPack.IP.strip(chr(0)) # RegIP 当做登录IP用 2018-03-03
+
+ # quick游戏token太长，第一位是spid，第二位是deviceFlag, 第三位是token
+ extraList = authPack.Extra.split("|")
+ if len(extraList) < redefineIndex + 2:
+ self.sendLoginFail(CommonDefine.dgPlayerLogin, authPack, disPswCheckError)
+ return True
+ token = extraList[redefineIndex]
+ uid = extraList[redefineIndex + 1] #原始的uid，含大小写
+
+ # 极速游戏，远程验证
+ if accountRec.RegIP == "127.0.0.1":
+ #debug内部服务器不验证token, 脱机挂玩家不验证
+ mylog.debug('iner no check')
+ else:
+ # url的访问没有多线程 有可能导致登录堆积卡顿的现象
+ if self.loginHeap < 5:
+ # 10秒内前X个玩家验证，后面不验证
+ loginkey = CommFunc.GetLoginKey(authAccID, accountRec.AppID)
+ userID = uid
+ game_sign = "ryzj"
+ game_id = 9134
+ curTime = int(time())
+ sign = md5.md5("%s%s%s%s%s%s" % (userID, game_id, game_sign, token, time, loginkey)).hexdigest()
+ values = {'userID' : userID,
+ 'game_sign' : game_sign,
+ 'game_id' : game_id,
+ 'token' : token,
+ 'time' : curTime,
+ 'sign' : sign,
+ }
+ try:
+ data = urllib.urlencode(values)
+ # 节省配置复杂度 写死地址
+ req = urllib2.Request("https://apisdk.gaore.com/user/verifyAccount/state.php", data)
+ response = urllib2.urlopen(req, timeout=1)
+ the_page = response.read()
+ # 返回结果：(JSON格式)： { state: 1 //(登录认证成功)；其他失败 }
+ retDict = eval(the_page)
+ if retDict.get("state") != 1:
+ mylog.debug('checktoken fail:%s-%s'%(token, the_page))
+ self.sendLoginFail(CommonDefine.dgPlayerLogin, authPack, disPswCheckError)
return True
except:
pass
@@ -3087,7 +3230,7 @@
# quick游戏token太长，第一位是spid，第二位是deviceFlag, 第三位是token
extraList = authPack.Extra.split("|")
if len(extraList) < redefineIndex + 2:
- self.sendFailString(CommonDefine.dgPlayerLogin, pack, disPswCheckError)
+ self.sendLoginFail(CommonDefine.dgPlayerLogin, authPack, disPswCheckError)
return True
token = extraList[redefineIndex]
uid = extraList[redefineIndex + 1] #原始的uid，含大小写
@@ -3112,8 +3255,8 @@
the_page = response.read()
if the_page != "1":
- mylog.debug('checktoken fail:%s-%s'%(token, the_page))
- self.sendFailString(CommonDefine.dgPlayerLogin, pack, disPswCheckError)
+ mylog.info('checktoken fail:%s-%s'%(token, the_page))
+ self.sendLoginFail(CommonDefine.dgPlayerLogin, authPack, disPswCheckError)
return True
except:
pass
@@ -3140,7 +3283,7 @@
# quick游戏token太长，第一位是spid，第二位是deviceFlag, 第三位是token
extraList = authPack.Extra.split("|")
if len(extraList) < redefineIndex + 1:
- self.sendFailString(CommonDefine.dgPlayerLogin, pack, disPswCheckError)
+ self.sendLoginFail(CommonDefine.dgPlayerLogin, authPack, disPswCheckError)
return True
token = extraList[redefineIndex]
@@ -3168,7 +3311,7 @@
the_page = the_page.replace("\xef\xbb\xbf","")
if the_page != "OK":
mylog.debug('checktoken fail:%s-%s'%(token, the_page))
- self.sendFailString(CommonDefine.dgPlayerLogin, pack, disPswCheckError)
+ self.sendLoginFail(CommonDefine.dgPlayerLogin, authPack, disPswCheckError)
return True
except:
pass
@@ -3187,24 +3330,24 @@
if lastExceptionCnt != getADOExceptionCount():
#数据库访问异常
mylog.warning('DB access excption!')
- self.sendFailString(CommonDefine.dgPlayerLogin, pack, disDataBaseError)
+ self.sendLoginFail(CommonDefine.dgPlayerLogin, authPack, disDataBaseError)
return True
if lastSIDErrorCnt == getSIDErrorCnt():
#用户确实不存在
mylog.warning('accid = %s not found!'%authPack.AccID)
- self.sendFailString(CommonDefine.dgPlayerLogin, pack, disUserNameNotExist)
+ self.sendLoginFail(CommonDefine.dgPlayerLogin, authPack, disUserNameNotExist)
return True
elif DBConfig.checkSID:
#Sid不对 踢人
mylog.debug("authPack.AccID = %s, sid error"%authPack.AccID)
- self.sendFailString(CommonDefine.dgPlayerLogin, pack, disGMKick)
+ self.sendLoginFail(CommonDefine.dgPlayerLogin, authPack, disGMKick)
return True
#用户名匹配，下面匹配密码
if not (accountRec.Psw == authPack.Psw.strip(chr(0))): #去掉字符串末尾的0
#密码不匹配
mylog.debug('input psw = %s while stored psw = %s'%(authPack.Psw.strip(), accountRec.Psw.strip()))
- self.sendFailString(CommonDefine.dgPlayerLogin, pack, disPswCheckError)
+ self.sendLoginFail(CommonDefine.dgPlayerLogin, authPack, disPswCheckError)
return True
# 记录设备唯一识别码
@@ -3223,7 +3366,7 @@
if not accountRec.adoCheckUpdateC(collection):
#更新失败
mylog.warning('%s update LogNum error'%authPack.AccID)
- self.sendFailString(CommonDefine.dgPlayerLogin, pack, disDataBaseError)
+ self.sendLoginFail(CommonDefine.dgPlayerLogin, authPack, disDataBaseError)
return True
@@ -3291,7 +3434,9 @@
sendPack.MapID = GameWorld.GetGameWorld().GetMapID()
mylog.info('gstPlayerDetail Send OnCreate accid = %s'%(accountRec.ACCID))
NetPackCommon.SendPyPackToMapServerSelf(sendPack.GetBuffer(), sendPack.GetLength())
-
+
+ if authAccID not in PyGameData.g_onlineAccIDList:
+ PyGameData.g_onlineAccIDList.append(authAccID)
return True
def sendOKString(self, type, fromPacket, buf):
@@ -3303,18 +3448,26 @@
# self.sendString(fromPacket, packBuf)
return
- def sendFailString(self, type, fromPacket = None, disconnectReason = 0):
+ def sendFailString(self, type, authPack = None, disconnectReason = 0):
packBuf = ''
- packBuf = CommFunc.WriteBYTE(packBuf, type)
- packBuf = CommFunc.WriteBYTE(packBuf, 0) #失败
- packBuf = CommFunc.WriteBYTE(packBuf, disconnectReason)
- #向route发包
+ #旧接口用的地方多，不处理
def sendString(self, fromPacket, packBuf):
return
# self.packSend(fromPacket.getSessionID(), fromPacket.getPackHead().sessionID, fromPacket.getPackHead().poolIndex, fromPacket.getPackHead().type,
# fromPacket.getPackHead().srcSvrType, fromPacket.getPackHead().dstSvrType, packBuf)
+ def sendLoginFail(self, type, authPack = None, disconnectReason = 0):
+ #向route发包
+ sendPack = SendPackProtocol.tagMapServerPlayerLogin()
+ sendPack.Type = type
+ sendPack.ServerRoleIndex = authPack.ServerRoleIndex
+ sendPack.SessionID = authPack.SessionID
+ sendPack.MapID = disconnectReason #借用字段使用
+ NetPackCommon.SendPyPackToMapServerSelf(sendPack.GetBuffer(), sendPack.GetLength())
+
+
+
def onGMCmdListReq(self, db, pack):
#已废除
@@ -3961,10 +4114,10 @@
sendPack.CallType = CommonDefine.dgUpDate
sendPack.UpdateType = CommonDefine.gstSaveGameServerCrashData
sendPack.Result = 1
- self.packSend(pack.getSessionID(), pack.getPackHead().sessionID,
- pack.getPackHead().poolIndex, pack.getPackHead().type,
- pack.getPackHead().srcSvrType, pack.getPackHead().dstSvrType,
- sendPack.GetBuffer())
+ # self.packSend(pack.getSessionID(), pack.getPackHead().sessionID,
+ # pack.getPackHead().poolIndex, pack.getPackHead().type,
+ # pack.getPackHead().srcSvrType, pack.getPackHead().dstSvrType,
+ # sendPack.GetBuffer())
elif saveType == 0:
#tagGameServerToBalanceServerSaveData
gameData = data[pos:]
@@ -4074,10 +4227,10 @@
sendPack.CallType = CommonDefine.dgUpDate
sendPack.UpdateType = CommonDefine.gstSaveGameServerData
sendPack.Result = 1
- self.packSend(pack.getSessionID(), pack.getPackHead().sessionID,
- pack.getPackHead().poolIndex, pack.getPackHead().type,
- pack.getPackHead().srcSvrType, pack.getPackHead().dstSvrType,
- sendPack.GetBuffer())
+ # self.packSend(pack.getSessionID(), pack.getPackHead().sessionID,
+ # pack.getPackHead().poolIndex, pack.getPackHead().type,
+ # pack.getPackHead().srcSvrType, pack.getPackHead().dstSvrType,
+ # sendPack.GetBuffer())
mylog.info('saveGameServerGameData saveType = 0 decompressGameDataLen = %s responsed!'%decompressGameDataLen)
elif saveType == CommonDefine.dgPlayerMailList:
--
Gitblit v1.8.0