ó
|
¨t0hc @ sÁ d d l Td d l Td d l Z d d l Z d d l j Z d d l m Z m Z d d l m
|
Z
|
m Z d d l m Z m Z m Z m Z d d l m Z m Z m Z m Z m Z m Z d d l Td d l m Z d d l m Z e d Z d d l Z d d
|
l m Z m! Z! d d l" Td d l# m$ Z$ d d l% m& Z& d d l' m( Z( d d d d d d g Z) d Z* d Z+ d Z, e j- Z- d Z. d e j f d YZ/ d Z0 e1 d k r½e0 n d S( iÿÿÿÿ( t *N( t errort DBController( t CommFunct mylog( t RecvPackProtocolt SendPackProtocolt MergeServerRecvProtocolt MergeServerSendProtocol( t getADOExceptionCountt getSIDErrorCntt addADOExceptionCountt seqt fix_outgoingTextt fix_incomingText( t
|
MMORPGPack( t ServersConfigs Config.DBConfig( t EventProcesst EventReport( t MongoDBServer( t ProjSpecialProcess( t Commandst weekdayt yeart montht dayt hourt minutei i c C sà x¼ t t D]® \ } } | | d k r/ q n t | | t k rH d St | | } t | t k r | d } | | | k r d Sq n | | | k r¦ q n | | | k rº t St SWt S( Ns -i (
|
t enumeratet ATTR_CALL_TIMEt hasattrt Truet getattrt typet intt Def_Cmp_Greatert Def_Cmp_Lowert Def_Cmp_Equ( t curTimet timeInfot indext callObjt
|
curCallObjt wday( ( s* .\\ServersRoute\LogicProcess\UserCtrlDB.pyt CompareActTime. s" t
|
UserCtrlDBc B sY e Z d Z d Z d Z d Z d Z d Z d Z d Z d Z
|
RS( c C sÉ t j j | d d | t j t j t j t j f | j d d <| j t j
|
t j | j t j t j t j t j r t j | _ n t j t j | _ d | _ t | _ t | _ d S( NR- i i ( t CtrlDBt __init__t CommonDefinet gstMergerChildToCentert gstQueryServerIDInfot gstRefreshRouteServerStatet gstNotifyCloseServert priorityQueueListt setServert DBConfigt
|
USER_DB_IPt USER_DB_PORTt setDataBaset USER_DB_NAMEt userdb_usert
|
userdb_pwdt base64R t Base64StringManipulatort
|
translatort EncodeStringManipulatort encodingt loginHeapt timet loginStartTimet lastCleanMergePlayerTime( t selft ctrlDBMgr( ( s* .\\ServersRoute\LogicProcess\UserCtrlDB.pyR/ M s c C s t j s t t _ n d S( N( t
|
PyGameDatat g_UserCtrlDBFirstInitR ( RG t db( ( s* .\\ServersRoute\LogicProcess\UserCtrlDB.pyt onConnectedOKc s c C s t j } | j d d } d } d } d } t j | | } t j | t | | } | j | | | t j t
|
j t
|
j | j d S( Nt RouteServeri iÿÿÿÿt ( R t getServerMgrt getClientSessionIDByNameR t
|
WriteDWORDt WriteStringt lent packSendBySessionIDR0 t atWorldLogicR t stMapt stCenterGatet GetBuffer( RG t mapIDt buft ServerMgrt sendViaSessionIDt SessionIDt PoolIndext packBuf( ( s* .\\ServersRoute\LogicProcess\UserCtrlDB.pyt sendMapStringk s c C sV | j | j | j j | j j | j j | j j | j j | d S( N( t packSendt getSessionIDt getPackHeadt sessionIDt poolIndexR! t
|
srcSvrTypet
|
dstSvrType( RG t
|
fromPacketR_ ( ( s* .\\ServersRoute\LogicProcess\UserCtrlDB.pyt
|
sendString{ s 3c C só d } t j | j | \ } } t j d | | t j k r{ | j d } | j | j | | | j
|
t S| t j k r± | j d } | j | j
|
t S| t j k rØ t j t j t St j d | j t S( Ni s begin process request type = %dR2 s %s not processed!( R t ReadBYTEt getBufferR t debugR0 R2 t GetFuncGradet Startt OnQueryServerInfot EndR R3 R4 R t CallStopt CallExitt warningt outputString( RG RK t packt post requestTypet
|
oFuncGrade( ( s* .\\ServersRoute\LogicProcess\UserCtrlDB.pyt requestLogicProcess s(
|
|
|
|
|
|
c C s× t j d t j } t j | _ t j } t | | _
|
g | _ xZ | D]R } t j } | | _ | | | _ t j d | | j f | j j | qP Wt j d | j | j | | j d S( Ns OnQueryServerInfo ins OnQueryServerInfo in %s %ss- OnQueryServerInfo sendString toRouteServer %s( R Rl R t tagDRServerIDToMapIDR0 t dgServerIDToMapIDt TypeR t GetServerDictByTheGroupIDRS t Countt
|
ServerInfot tagSeverInfot ServerIDt MapIDt appendt OutputStringRi RX ( RG RK Ru t sendPackt
|
serverDictt keyt severInfo( ( s* .\\ServersRoute\LogicProcess\UserCtrlDB.pyRo s c C sÛ t j d t j } | j d d } d } d } | j } t j } d } | j | | t j
|
}
|
t j |
|
_ | j |
|
_ | j |
|
_ | j | | | t j t j t j |
|
j t j d | j t S( Ns OnMergerChildToCenter inRM i iÿÿÿÿs0 OnMergerChildToCenter sendString toGameServer %s( R Rl R RO RP Rk R t tagLPStringDatat ReadDataR t tagDGMergerChildToGameStringDataR0 t dgMergerChildToCenterR| t DataLent DataRT t atInnerR t stGameRW RX R ( RG RK Ru R[ R\ R] R^ RZ t recvPackRv R
( ( s* .\\ServersRoute\LogicProcess\UserCtrlDB.pyt OnMergerChildToCenterµ s& c C sü t j d t j } | j d d } d } d } | j } t j } d } | j | | t j
|
}
|
t j |
|
_ t j |
|
_ | j |
|
_ | j |
|
_ | j |
|
_ | j | | | t j t j t j |
|
j t j d | j |
|
j g t S( Ns! OnMergeChildToCenterPlayerData inRM i iÿÿÿÿs8 OnMergeChildToCenterPlayerData sendString toMapServer %s( R Rl R RO RP Rk R t tagLPPlayerDataR R t tagDMMergePlayerDataR0 t dgDBToMapServerR| t gmMergePlayerDatat SubTypeR R t PlayerIDRT R R t stRouteRW RX R ( RG RK Ru R[ R\ R] R^ RZ R Rv R
( ( s* .\\ServersRoute\LogicProcess\UserCtrlDB.pyt OnMergeChildToCenterPlayerDataÓ s* c C sR y t j | | Wn7 t j d t j d t j } t j | t SXt S( NR sB OnGMToolCmdUserDBRequest Catch a unexpetcted exception, error = %s(
|
R t OnGMToolCmdUserDBRequestR t formatMsgt ERROR_NO_172t tracebackt
|
format_excR t FalseR ( RG RK Ru t msg( ( s* .\\ServersRoute\LogicProcess\UserCtrlDB.pyR ñ s " ( t __name__t
|
__module__R/ RL R` Ri Ry Ro R R R ( ( ( s* .\\ServersRoute\LogicProcess\UserCtrlDB.pyR- L s c C s d d l } | j d d S( Niÿÿÿÿt pause( t ost system( R¥ ( ( s* .\\ServersRoute\LogicProcess\UserCtrlDB.pyt testý s t __main__(2 RD t binasciiR. RI t DBCommon.CommonDefineR0 t DBCommonR R t CommonR R t ProtocolR R R R t MangoDBCommonR R
|
R R R R t ServerClientShareDefineR t ConfigR t
|
__import__R7 R t
|
EventShellR R t Collections.CollectionDefinet NetR t GMToolLogicProcessR t CmdShellR R R$ R% R# t IsMergeServerR, R- R§ R¢ ( ( ( s* .\\ServersRoute\LogicProcess\UserCtrlDB.pyt <module> s8
|
|
".
|
|
|
±
|
