ó
|
ÿóíhc @ 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* 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 .\\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 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 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 .\\LogicProcess\UserCtrlDB.pyR- M s c C s t j s t t _ n d S( N( t
|
PyGameDatat g_UserCtrlDBFirstInitR ( RD t db( ( s .\\LogicProcess\UserCtrlDB.pyt onConnectedOKb s c C s t j } | j d d } d } d } d } t j | | } t j | | } t j | t | | } | j | | | t j
|
t j t j | d S( Nt RouteServeri iÿÿÿÿt ( R t getServerMgrt getClientSessionIDByNameR t WriteBYTEt
|
WriteDWORDt WriteStringt lent packSendBySessionIDR. t atWorldLogicR t stMapt stCenterGate( RD t packTypet mapIDt buft ServerMgrt sendViaSessionIDt SessionIDt PoolIndext packBuf( ( s .\\LogicProcess\UserCtrlDB.pyt sendMapStringj 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( RD t
|
fromPacketR] ( ( s .\\LogicProcess\UserCtrlDB.pyt
|
sendString{ s 3c C s\ t j } | j d d } d } d } | j | | | t j t j t j | j d S( NRJ i iÿÿÿÿ(
|
R RL RM RR R. t atInnerR t stRouteRU t GetBuffer( RD t sendPackRY RZ R[ R\ ( ( s .\\LogicProcess\UserCtrlDB.pyt SendRoutePack s c 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 = %dR/ s/ taskkill /f /t /FI "IMAGENAME eq EventServer*"s %s not processed!( R t ReadBYTEt getBufferR t debugR. R/ t GetFuncGradet Startt OnQueryServerInfot EndR R0 R1 t ost systemR t CallStopt CallExitt warningt outputString( RD RH t packt post requestTypet
|
oFuncGrade( ( s .\\LogicProcess\UserCtrlDB.pyt requestLogicProcess s*
|
|
|
|
|
|
c C s¦ t j d t j } t j | _ t j } t | | _
|
g | _ x@ | D]8 } t j } | | _ | | | _ | j j | qP W| j | | j d S( Ns OnQueryServerInfo in( R Ro R t tagDRServerIDToMapIDR. t dgServerIDToMapIDt TypeR t GetServerDictByTheGroupNammeRQ t Countt
|
ServerInfot tagSeverInfot ServerIDt MapIDt appendRg Rj ( RD RH Rz Rk t
|
serverDictt keyt severInfo( ( s .\\LogicProcess\UserCtrlDB.pyRr ° s c C s§ t j d t j t j } t j | _ t j } t
|
| | _ g | _ x@ | D]8 } t j } | | _ | | | _ | j j | qZ W| j | d S( Nt NotifyRouteServerInfo( R Ro R t ReloadServerIDToMapIDDictR R R. R R R RQ R R R
R R R Rl ( RD Rk R R R ( ( s .\\LogicProcess\UserCtrlDB.pyR Å s
|
(
|
t __name__t
|
__module__R- RI R^ Rg Rl R~ Rr R ( ( ( s .\\LogicProcess\UserCtrlDB.pyR+ L s " c C s d d l } | j d d S( Niÿÿÿÿt pause( Rt Ru ( Rt ( ( s .\\LogicProcess\UserCtrlDB.pyt testß s t __main__(/ Rt RA t binasciiR, RF 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__R4 t tracebackt Collections.CollectionDefinet NetR t GMToolLogicProcessR t CmdShellR R R" R# R! R* R+ R R ( ( ( s .\\LogicProcess\UserCtrlDB.pyt <module> s6
|
|
".
|
|
|
