ó
|
Pphc @ 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 d d d d g Z' d Z( d Z) d Z* e j+ Z+ d Z, d e j f d YZ- d Z. e/ d k re. 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 ProjSpecialProcesst 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 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 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. L s c C s t j s t t _ n d S( N( t
|
PyGameDatat g_UserCtrlDBFirstInitR ( RE t db( ( s* .\\ServersRoute\LogicProcess\UserCtrlDB.pyt onConnectedOKa 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 packSendBySessionIDR/ t atWorldLogicR t stMapt stCenterGatet GetBuffer( RE t mapIDt buft ServerMgrt sendViaSessionIDt SessionIDt PoolIndext packBuf( ( s* .\\ServersRoute\LogicProcess\UserCtrlDB.pyt sendMapStringi 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( RE t
|
fromPacketR] ( ( s* .\\ServersRoute\LogicProcess\UserCtrlDB.pyt
|
sendStringy 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 St j d | j t S( Ni s begin process request type = %dR1 s %s not processed!( R t ReadBYTEt getBufferR t debugR/ R1 t GetFuncGradet Startt OnQueryServerInfot EndR R2 t warningt outputString( RE RI 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 Rj R t tagDRServerIDToMapIDR/ t dgServerIDToMapIDt TypeR t GetServerDictByTheGroupIDRQ t Countt
|
ServerInfot tagSeverInfot ServerIDt MapIDt appendt OutputStringRg RV ( RE RI Rq t sendPackt
|
serverDictt keyt severInfo( ( s* .\\ServersRoute\LogicProcess\UserCtrlDB.pyRm 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 inRK i iÿÿÿÿs0 OnMergerChildToCenter sendString toGameServer %s( R Rj R RM RN Ri R t tagLPStringDatat ReadDataR t tagDGMergerChildToGameStringDataR/ t dgMergerChildToCenterRx t DataLent DataRR t atInnerR t stGameRU RV R ( RE RI Rq RY RZ R[ R\ RX t recvPackRr 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 inRK i iÿÿÿÿs8 OnMergeChildToCenterPlayerData sendString toMapServer %s( R Rj R RM RN Ri R t tagLPPlayerDataR R t tagDMMergePlayerDataR/ t dgDBToMapServerRx t gmMergePlayerDatat SubTypeR R t PlayerIDRR R R t stRouteRU RV R ( RE RI Rq RY RZ R[ R\ RX R Rr 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 ( RE RI Rq t msg( ( s* .\\ServersRoute\LogicProcess\UserCtrlDB.pyR é s " ( t __name__t
|
__module__R. RJ R^ Rg Ru Rm R R R ( ( ( s* .\\ServersRoute\LogicProcess\UserCtrlDB.pyR, K 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__(0 RB t binasciiR- RG t DBCommon.CommonDefineR/ t DBCommonR R t CommonR R t ProtocolR R R R t MangoDBCommonR R
|
R R R R t ServerClientShareDefineR t ConfigR t
|
__import__R5 R t
|
EventShellR R t Collections.CollectionDefinet NetR t GMToolLogicProcessR R R# R$ R" t IsMergeServerR+ R, R£ R ( ( ( s* .\\ServersRoute\LogicProcess\UserCtrlDB.pyt <module> s6
|
|
".
|
|
|
ª
|
