| | |
|---|
| | | Def_Cmp_Equ = 0 #等于
|
|---|
| | | Def_Cmp_Greater = 1 #大于
|
|---|
| | |
|
|---|
| | | IsMergeServer = DBConfig.IsMergeServer
|
|---|
| | |
|
|---|
| | | #跨服玩家上传数据信息列表索引
|
|---|
| | | (
|
|---|
| | | MergeRegPInfoIndex_LoginTime, # 登录时间 索引
|
|---|
| | |
|---|
| | | self.connectDB()
|
|---|
| | | return
|
|---|
| | |
|
|---|
| | | def IsMergeServer(self):
|
|---|
| | | global IsMergeServer
|
|---|
| | | return IsMergeServer
|
|---|
| | | |
|---|
| | | def IsMergeServer(self): return GameWorld.IsCrossServer()
|
|---|
| | |
|
|---|
| | | # 每X分钟清除已下线的玩家跨服数据, 离线超过3分钟玩家直接返回子服
|
|---|
| | | def PopOfflineMergePlayer(self):
|
|---|
| | |
|---|
| | | 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')
|
|---|
| | |
|---|
| | | 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)
|
|---|
| | |
|---|
| | | the_page = response.read()
|
|---|
| | |
|
|---|
| | | if the_page != "1":
|
|---|
| | | mylog.debug('checktoken fail:%s-%s'%(token, the_page))
|
|---|
| | | mylog.info('checktoken fail:%s-%s'%(token, the_page))
|
|---|
| | | self.sendFailString(CommonDefine.dgPlayerLogin, pack, disPswCheckError)
|
|---|
| | | return True
|
|---|
| | | except:
|
|---|
