ó
|
ÒoÑ\c @ s0 d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z e j d Z g a g a d Z
|
d Z d Z d Z d Z d Z d g d Z i d g d
|
Z d g d Z d g d Z d g d Z d Z d Z d Z d Z d Z d Z d Z d Z d S( iÿÿÿÿNt EncodingText tagDBPlayerc C s t j } | j } | s6 t t j d d S| j } | sS t d St | j d d } t | } t
|
| t d S( Ns ²Ù×÷DBʧ°Ü£¡£¡£¡t ObjectIdt str( t IPY_GameServert IPY_DGDBOperResultt GetResultt __ResetDBOpert GameWorldt ErrLogt GetResultSett evalt replacet TranslateOutDBListt __DoLogic_DGDBOperResult( t indext tickt dbOperResultInfot resultt resultSett resultSetList( ( s .\\PlayerDBOper.pyt GetDGDBOperResultInfo9 s
|
|
c C s- t s
|
d St \ } } | r) | | | Sd S( N( t g_proccessCmdInfo( R t callFunct extendValueList( ( s .\\PlayerDBOper.pyR b s c C s" t j d | t j | d S( Ns Ìí¼ÓDBComand operList=%s( R t Logt g_dbCommandListt append( t operList( ( s .\\PlayerDBOper.pyt AddDBCommandLists s c C s t t d k r d St j j t j } | r t j j t j } | | t j t j k rj d St
|
t j d d St j j t j d t j d \ } } } t j | d } t j j d | t | t j d | | | g a t j j t j | d S( Ni s wait for DB responses overtimei i s send dbcommand:%s( t lenR R t GetGameWorldt GetDictByKeyt ChConfigt! Def_PlayerKey_IsStopSendDBCommandt Def_PlayerKey_SendDBComTickt TYPE_Tick_Timet TYPE_SendDBCommandTickR R t SetDictt popt cPicklet dumpst
|
SendDBOperR R ( R t isStopSendInfot sendTickt sendDictR R t sendMsg( ( s .\\PlayerDBOper.pyt PyDBProccess s$ c C s# g a t j j t j d d S( Ni ( R R R R& R! R" ( ( ( s .\\PlayerDBOper.pyR « s c C sD t | } i | d 6d d 6| d 6} | | | g } t | d S( Nt
|
collectiont insertt opert docs( t TranslateInDBListR ( R0 t dictInfoListR R t
|
resultListt operDictR ( ( s .\\PlayerDBOper.pyt InsertDBOper¼ s
|
|
c C sK t | } i | d 6d d 6| d 6| d 6} | | | g } t | d S( NR0 t findR2 t spect fields( t TranslateInDBDictR ( R0 t findDictR; R R R7 R ( ( s .\\PlayerDBOper.pyt
|
FindDBOperÍ s
|
"
|
c C s^ t | } t | } i | d 6d d 6| d 6i | d 6d 6} | | | g } t | d S( NR0 t updateR2 R: s $setR3 ( R< R ( R0 t tagFieldDictt
|
updateDictR R R7 R ( ( s .\\PlayerDBOper.pyt UpdateDBOperÝ s )
|
c C sD t | } i | d 6d d 6| d 6} | | | g } t | d S( NR0 t removeR2 R: ( R< R ( R0 R@ R R R7 R ( ( s .\\PlayerDBOper.pyt RemoveDBOperë s
|
|
c C s1 i | d 6d d 6} | | | g } t | d S( NR0 t dropR2 ( R ( R0 R R R7 R ( ( s .\\PlayerDBOper.pyt
|
DropDBOper÷ s
|
c C s4 g } x' | D] } t | } | j | q W| S( N( R< R ( R5 R6 t infoDictt resDict( ( s .\\PlayerDBOper.pyR4 s
|
c C s7 i } x* | j D] \ } } t | | | <q W| S( N( t itemst IncomingText( t tagDictt
|
resultDictt keyt value( ( s .\\PlayerDBOper.pyR< s c C s4 g } x' | D] } t | } | j | q W| S( N( t TranslateOutDBDictR ( R5 R6 RG RH ( ( s .\\PlayerDBOper.pyR s
|
c C s7 i } x* | j D] \ } } t | | | <q W| S( N( RI t OutgoingText( RK RL RM RN ( ( s .\\PlayerDBOper.pyRO + s c C s? t | t r; t d r& t j | St t d | d S| S( Ni i ( t
|
isinstancet unicodet EncodingListt base64t b64decodet UnicodeToEncoding( t text( ( s .\\PlayerDBOper.pyRP 7 s
|
|
c C s? t | t r; t d r& t j | St t d | d S| S( Ni i ( RQ R RS RT t b64encodet EncodingToUnicode( RW ( ( s .\\PlayerDBOper.pyRJ C s
|
|
c C sE y t | | } Wn% t j d | | f t d f SXt | f S( Ns3 ##EncodingToUnicode error, input=%s, srcEncoding=%st error( RR R R t Falset True( t srcEncodingt inputR ( ( s .\\PlayerDBOper.pyRY P s c C sE y | j | } Wn% t j d | | f t d f SXt | f S( Ns3 ##UnicodeToEncoding error, input=%s, dstEncoding=%st Error( t encodeR R R[ R\ ( t dstEncodingR^ R ( ( s .\\PlayerDBOper.pyRV ] s ( R R! R t ReadChConfigRT R( t GetEvalChConfigRS R R t Table_DBPlayerR R R R/ R t NoneR8 R> RB RD RF R4 R< R RO RP RJ RY RV ( ( ( s .\\PlayerDBOper.pyt <module> s6 ) ,
|
