ó
|
v-9hc @ s· d d l Z 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 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 Z. e/ d k r³e. n d S( iÿÿÿÿN( t *( 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 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 sP e 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 ( RE 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 packSendBySessionIDR. t atWorldLogicR t stMapt stCenterGatet GetBuffer( RE 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( RE 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 d t j t j t St j d | j t S( Ni s begin process request type = %dR0 s/ taskkill /f /t /FI "IMAGENAME eq EventServer*"s %s not processed!( R t ReadBYTEt getBufferR t debugR. R0 t GetFuncGradet Startt OnQueryServerInfot EndR R1 R2 t ost systemR t CallStopt CallExitt 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 Ru 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 dgMergerChildToCenterR| t DataLent DataRR t atInnerR t stGameRU RV R ( RE RI Ru RY RZ R[ R\ RX 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 inRK i iÿÿÿÿs8 OnMergeChildToCenterPlayerData sendString toMapServer %s( R Rj R RM RN Ri R t tagLPPlayerDataR R t tagDMMergePlayerDataR. t dgDBToMapServerR| t gmMergePlayerDatat SubTypeR R t PlayerIDRR R R t stRouteRU RV R ( RE RI Ru RY RZ R[ R\ RX R Rv R
( ( s* .\\ServersRoute\LogicProcess\UserCtrlDB.pyt OnMergeChildToCenterPlayerDataÔ s* (
|
t __name__t
|
__module__R- RJ R^ Rg Ry Rm R R ( ( ( s* .\\ServersRoute\LogicProcess\UserCtrlDB.pyR+ L s ! c C s d d l } | j d d S( Niÿÿÿÿt pause( Ro Rp ( Ro ( ( s* .\\ServersRoute\LogicProcess\UserCtrlDB.pyt testö s t __main__(0 Ro 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 t tracebackt Collections.CollectionDefinet NetR t GMToolLogicProcessR t CmdShellR R R" R# R! t IsMergeServerR* R+ R R ( ( ( s* .\\ServersRoute\LogicProcess\UserCtrlDB.pyt <module> s8
|
|
".
|
|
|
ª
|
