ó
|
Yã&hc @ sÙ d d l Z d d l Z d d l Td d l Z d d l Td d l Z d d l Z d d l Z d d l Z d d l j
|
Z
|
d d l m Z m Z m Z m Z m Z m Z d d l Td d l Z e d Z d d l m Z d d l Z d d l Z d d l Td d l Z d d l m Z m Z m Z d d l Z d d l Z d d l! Z! d d l" Z" d d l# Z# d d l$ Z$ d d l% Z% d d l& Z& d d l' Z' d d l( m) Z) m* Z* d d l+ Z+ d d l, m- Z- m. Z. m/ Z/ m0 Z0 d d l1 m2 Z2 m3 Z3 m4 Z4 m5 Z5 m6 Z6 d d l7 Z7 d d l8 Z8 d d l9 Z9 d d l: Z: d
|
d d d d d g Z; d Z< d Z= d Z> e j? a? e@ d \ ZA ZB ZC ZD d ZE d d lF ZF eF jG aH eF jG aI d ZJ d ZK d ZL d e9 j9 f d YZM d S( iÿÿÿÿN( t *( t getADOExceptionCountt getSIDErrorCntt addADOExceptionCountt seqt fix_outgoingTextt fix_incomingTexts Config.DBConfig( t string_at( t CommFunct mylogt
|
CommFuncEx( t DataServerGameDatat DataServerPlayerData( t GlobalFunctionst DBControllert errort
|
DataDumper( t
|
MMORPGPackt RecvPackProtocolt SendPackProtocolt MergeServerRecvProtocolt MergeServerSendProtocolt weekdayt yeart montht dayt hourt minutei i i c C s¶ d d l } t j } t j } | | f } d } d } d } y6t j } | j t j j t j
|
d | j d d } | j d d } t j } | j | j | j }
|
|
|
j | d | | | f } |
|
j | |
|
j | } t j d | t | } d } | r.| d
|
r.| d } n | | k rZt j d | | | | f n t j d |
|
j Wn7 t k
|
r} t j d | n t j d n X| | f S( Niÿÿÿÿi t s GameVersion.init configt GameIDt Versions GameVersion:%s|%s|%ss% IDDispatch CheckGameVersion recv:%st resultt versionsT CheckGameVersion,gameID=%s,groupID=%s,curVersion=%s is not equal to centerVersion=%ss! IDDispatch CheckGameVersion OK!s1 IDDispatch CheckGameVersion Connect Exception %ss6 IDDispatch CheckGameVersion Connect unknown Exception( t sockett DBConfigt IDDispatchServerIPt IDDispatchServerPortt ConfigParsert readt ost patht joinR t
|
getAppPatht gett GroupIDt AF_INETt SOCK_STREAMt connectt sendt recvR t infot evalt PegasusCollectorProxyt ErrorReportt closet ExceptionR ( R" t hostt portt addrt BUF_SIZEt
|
curVersiont centerVersiont cfGameVert gameIDt groupIDt clientt datat dataRecvt
|
resultDictt e( ( s .\\UserCtrlDB.pyt CheckGameVersionJ sB " c C s t j t | _ t j d d d l } d d l } t j } t j
|
} | | f } d } yë | j | j | j } | j | d } | j | | j | }
|
t j d |
|
t |
|
} | r<| d r<| d } | d } g } x/ t | | d D] } | j i | d
|
6 qW| t } | j | q<n | j Wn7 t k
|
rm} t j d | n t j d n Xt | _ t j d S( Ns IDDispatch CallDispatchPlayerIDiÿÿÿÿi t PIDs IDDispatch recv:%sR t minIDt maxIDi t PlayerIDs5 IDDispatch CallDispatchPlayerID Connect Exception %ss: IDDispatch CallDispatchPlayerID Connect unknown Exception( t lockPlayerIDt acquiret Truet isDispatchingPlayerIDR R3 R" t timeR# R$ R% R. R/ R0 R1 R2 R4 t xranget appendt UCN_Dispatch_PlayerIDt insertR7 R8 R t Falset release( t dbt selfR" RP R9 R: R; R< RB RC RD RE RI RJ t recst idt
|
collectionRF ( ( s .\\UserCtrlDB.pyt CallDispatchPlayerIDy sD
|
|
|
|
|
|
c C s® t j t | _ t j d d d l } d d l } t j } t j
|
} | | f } d } y| j | j | j }
|
|
|
j | d } |
|
j | |
|
j | } t j d | t | } | rR| d rR| d } | d } g } x/ t | | d D] } | j i | d
|
6 qW| t } | j | | j | | | | qRn |
|
j Wn7 t k
|
r} t j d | n t j d n Xt | _ t j d S( Ns IDDispatch CallDispatchFamilyIDiÿÿÿÿi t FIDs IDDispatch recv:%sR RI RJ i t FamilyIDs5 IDDispatch CallDispatchFamilyID Connect Exception %ss: IDDispatch CallDispatchFamilyID Connect unknown Exception( t lockFamilyIDRM RN t isDispatchingFamilyIDR R3 R" RP R# R$ R% R. R/ R0 R1 R2 R4 RQ RR t UCN_Dispatch_FamilyIDRT t CallBackToSendFamilyIDPackR7 R8 R RU RV ( RW t fromPackt typeRX R" RP R9 R: R; R< RB RC RD RE RI RJ RY RZ R[ RF ( ( s .\\UserCtrlDB.pyt CallDispatchFamilyID sF
|
|
|
|
|
|
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 hasattrRN t getattrRd t intt Def_Cmp_Greatert Def_Cmp_Lowert Def_Cmp_Equ( t curTimet timeInfot indext callObjt
|
curCallObjt wday( ( s .\\UserCtrlDB.pyt CompareActTimeÍ s" t
|
UserCtrlDBc B sï e Z d Z d Z d Z d Z d Z d Z d Z d Z d Z
|
d Z d
|
Z d Z d Z d Z d Z d Z d Z d Z d Z d Z d Z d Z d Z d Z d Z d Z d Z d Z d Z d Z d Z e! d Z" e! d Z# d! Z$ d" Z% d# Z& d$ Z' d% Z( d& Z) d' Z* d( Z+ d) Z, d* Z- d+ Z. d, Z/ d- Z0 d. Z1 d/ Z2 d0 Z3 e! d1 Z4 e! d2 Z5 d3 Z6 d4 Z7 d5 Z8 d6 Z9 d7 Z: d8 Z; d9 Z< d: Z= d; Z> e? d< d= Z@ d> ZA d? ZB d@ ZC dA ZD dB ZE dC ZF dD ZG dE ZH dF ZI dG ZJ dH ZK dI ZL dJ ZM dK ZN dL ZO dM ZP dN ZQ dO ZR dP ZS dQ ZT dR ZU dS ZV dT ZW dU ZX dV ZY dW ZZ dX Z[ dY Z\ dZ Z] d[ Z^ d\ Z_ d] Z` d^ Za d_ Zb d` Zc da Zd db Ze dc Zf dd Zg de Zh df Zi dg Zj dh Zk di Zl dj Zm dk Zn dl Zo dm Zp RS(n c C s t j j | d t | _ d | _ t j r@ t j | _
|
n t j t j | _
|
t | _ t | _ d | _ t | _ t | _ | j d S( NRu i ( t CtrlDBt __init__RU t Connectedt NoneRW R# t base64R t Base64StringManipulatort
|
translatort EncodeStringManipulatort encodingRO R` t loginHeapRP t loginStartTimet lastCleanMergePlayerTimet connectDB( RX ( ( s .\\UserCtrlDB.pyRw ì s Z
|
c C s t S( N( t IsMergeServer( RX ( ( s .\\UserCtrlDB.pyR X s c C s» t j } | s d St } d } | | j | k r9 d S| | _ x[ | j D]M \ } } | t | t k ru qO n | | t | k r qO n | j | qO Wt j d t
|
| d S( Niô s! PopOfflineMergePlayer hascnt = %s( t
|
PyGameDatat g_mergeRegisterPlayerDictRP R t itemst MergeRegPInfoIndex_LogoutTimet MergeRegPInfoIndex_LoginTimet popR t debugt len( RX R
Rn t Def_CleanTimet accIDt packInfo( ( s .\\UserCtrlDB.pyt PopOfflineMergePlayer^ s c C sà | j s¿ t j d t j t j f t j t j t j d t | _ t
|
j t j t j d | j sl d S| j t j | _ t | _ t j d t j t j f t j d | j n d S( Ns !!!!!!!!!!!connect %s:%st auto_start_requestt
|
connections !!!!!!!!!!!connect %s:%s ok!s login on user db ok!( Rx R R3 R# t
|
USER_DB_IPt USER_DB_PORTt pymongot
|
ConnectionRU R R t LoginMongoDBt userdb_usert
|
userdb_pwdt USER_DB_NAMERW RN t onConnectedOK( RX ( ( s .\\UserCtrlDB.pyR v s !! c C s t | _ d S( N( RU Rx ( RX ( ( s .\\UserCtrlDB.pyt
|
disconnect s c C s* t j s& t t _ | j t n d S( N( R t g_UserCtrlDBFirstInitRN t _UserCtrlDB__PlayerBackupSaveRG ( RX ( ( s .\\UserCtrlDB.pyR s
|
|
|
c C s | j } | j r" | j n d } t j | j | \ } } t j d | | t j k r | j
|
d } | j | j | | | j n | t j k râ | j
|
d } | j | j | | | j t S| t j k r(| j
|
d } | j | j | | | j t S| t j k rn| j
|
d } | j | j | | | j t S| t j k r´| j
|
d } | j | j | | | j t S| t j k rú| j
|
d } | j | j | | | j t S| t j k r@| j
|
d } | j | j | | | j t S| t j k r| j
|
d
|
} | j | j | | | j t S| t j k rÌ| j
|
d } | j | j | | | j t S| t j k r| j
|
d } | j | j | | | j t S| t j! k rX| j
|
d } | j | j" | | | j t S| t j# k r| j
|
d } | j | j$ | | | j t S| t j% k rä| j
|
d } | j | j& | | | j t S| t j' k r*| j
|
d } | j | j( | | | j t S| t j) k r=t S| t j* k r| j
|
d } | j | j+ | | | j t S| t j, k r`t- j. rÎt/ j0 d t/ j1 d t j, } t j2 | t t3 S| j
|
d } | j | j r$| j4 | | sRt j/ d | j5 j6 qRn. | j7 | | sRt j/ d | j5 j6 n | j t S| t j8 k r¦| j
|
d } | j | j9 | | | j t S| t j: k rì| j
|
d } | j | j; | | | j t S| t j< k r2| j
|
d } | j | j= | | | j t S| t j> k rx| j
|
d } | j | j? | | | j t S| t j@ k r¾| j
|
d } | j | jA | | | j t S| t jB k r| j
|
d } | j | jC | | | j t S| t jD k rJ| j
|
d } | j | jE | | | j t S| t jF k r| j
|
d } | j | jG | | | j t S| t jH k rÖ| j
|
d } | j | jI | | | j t S| t jJ k r | j
|
d } | j | jK | | | j t S| t jL k rb| j
|
d! } | j | jM | | | j t S| t jN k r¨| j
|
d" } | j | jO | | | j t S| t jP k rî| j
|
d# } | j | jQ | | | j t S| t jR k r4 | j
|
d$ } | j | jS | | | j t S| t jT k rz | j
|
d% } | j | jU | | | j t S| t jV k rÀ | j
|
d& } | j | jW | | | j t S| t jX k r
|
| j
|
d' } | j | jY | | | j t S| t jZ k rL
|
| j
|
d( } | j | j[ | | | j t S| t j\ k r
|
| j
|
d) } | j | j] | | | j t S| t j^ k rØ
|
| j
|
d* } | j | j_ | | | j t S| t j` k r | j
|
d+ } | j | ja | | | j t S| t jb k rd | j
|
d, } | j | jc | | | j t S| t jd k rª | j
|
d- } | j | je | | | j t S| t jf k rð | j
|
d. } | j | jg | | | j t S| t jh k r6 | j
|
d/ } | j | ji | | | j t S| t jj k r| | j
|
d0 } | j | jk | | | j t S| t jl k r | j
|
d1 } | j | jm | | | j t S| t jn k r | j
|
d2 } | j | jo | | | j t S| t jp k rN | j
|
d3 } | j | jq | | | j t S| t jr k r | j
|
d4 } | j | js | | | j t S| t jt k rÚ | j
|
d5 } | j | ju | | | j t S| t jv k r | j
|
d6 } | j | jw | | | j t S| t jx k rf| j
|
d7 } | j | jy | | | j t S| t jz k r¬| j
|
d8 } | j | j{ | | | j t S| t j| k rò| j
|
d9 } | j | j} | | | j t S| t j~ k r8| j
|
d: } | j | j | | | j t S| t j k r~| j
|
d; } | j | j | | | j t St j d< | j t S(= Ni s begin process request type = %dt gstDiapatchFamilyIDt gstGeneralDBOpert
|
gstDBLogict gstMergeQueryRegisterResultt gstMergeRegisterPlayert gstMergePlayerDatat gstQueryNewGuyCardStatet gstQueryRecharget gstFinishRecharget gstUpdateNewGuyCardStatet gstSaveGameServerDatat gstGetGameServerPlayerDatat gstGMCommandListReqt gstPlayerLogint gstSaveGameServerPlayerSaveDatat DeployErrorsN DbSaveServer is open, type = %d request should be send to PyMongoDBSaveServert gstUpdates< onSaveMapServerPlayerDataMergeServer failed!sessionID = 0x%Xs1 onSaveMapServerPlayerData failed!sessionID = 0x%Xt gstSavePlayerInfot gstInsertAcct gstPlayerIDMarkDeletedt
|
gstGetCoint gstCoinChanget gstCheckPlayerExistt gstOnDayt gstSavePlayerGMOPert gstGetExpiationCountt gstGetPetExpiationCountt gstGetExpiationt gstGetPetExpiationt gstUpdateServerDataVersionNOt gstMapServerInfot gstUpdateTotalSavePointt gstGetPlayerMailStatet gstGetMailDetailt gstGetPlayerMailt gstAddPlayerMailByAccIDt gstDeleteMailt gstUpdateMailt gstQueryCanSendMailt gstAccIDSendPrizet gstCheckItemPrizet gstCheckLoadAcct gstAddAccItemt gstUpdateTelLockStatet gstUpdateAccAdultt gstAddExpiationt gstAddPetExpiationt gstServerMergeDeleteRolet gstServerMergeUpdateAccStatet gstServerMergeChangeNamet gstInsertImpeacht gstGMToolCmdUserDBRequestt gstMergerChildToCentert gstPrepareCreateRoles %s not processed!( RW R R R t ReadBYTEt getBufferR R t CommonDefineR t GetFuncGradet Startt OnDiapatchFamilyIDt EndR t OnGeneralDBOperRN R t OnGameServerToDBLogicR¡ t OnMergeQueryRegisterResultR¢ t OnMergeRegisterPlayerByCacheR£ t OnMergeChildToCenterPlayerDataR¤ t OnQueryNewGuyCardStateR¥ t OnQueryRechargeR¦ t OnFinishRechargeR§ t onCheckUpdateNewGuyCardStateR¨ t onSaveGameServerDataR© t onGetGameServerPlayerDataRª t onGMCmdListReqR« t onAuthenticationt gstGetGameServerPlayerLoginDataR¬ t onSaveGameServerPlayerSaveDataR® R# t IsOpenDbSaveServerR t formatMsgt ERROR_NO_56R RU t$ onSaveMapServerPlayerDataMergeServert getPackHeadt sessionIDt onSaveMapServerPlayerDataR¯ t OnSavePlayerInfoR° t OnInsertAccR± t OnPlayerIDMarkDeletedR² t OnGetCoinR³ t OnCoinChangeR´ t OnCheckPlayerExistRµ t OnDayR¶ t OnSavePlayerGMOPerR· t OnGetExpiationCountR¸ t OnGetPetExpiationCountR¹ t OnGetExpiationRº t OnGetPetExpiationR» t OnUpdateServerDataVersionNOR¼ t OnMapServerInfoR½ t OnUpdateTotalSavePointR¾ t OnGetPlayerMailStateR¿ t OnGetMailDetailRÀ t OnGetPlayerMailRÁ t OnAddPlayerMailByAccIDRÂ t OnDeleteMailRÃ t OnUpdateMailRÄ t OnQueryCanSendMailRÅ t OnAccIDSendPrizeRÆ t OnCheckItemPrizeRÇ t OnCheckLoadAccRÈ t OnAddAccItemRÉ t OnUpdateTelLockStateRÊ t OnUpdateAccAdultRË t OnAddExpiationRÌ t OnAddPetExpiationRÍ t OnServerMergeDeleteRoleRÎ t OnServerMergeUpdateAccStateRÏ t OnServerMergeChangeNameRÐ t OnInsertImpeachRÑ t OnGMToolCmdUserDBRequestRÒ t OnMergerChildToCenterRÓ t OnPrepareCreateRolet warningt outputString( RX t packRW t post requestTypet
|
oFuncGradet msg( ( s .\\UserCtrlDB.pyt requestLogicProcess s
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
#
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
c C s{ t j } t j | _ | | _ x+ t | | d D] } | j j | q5 Wt | j | _
|
| j | | j d S( Ni ( R t tagDGCanUseFamilyIDListRÖ t dgDiapatchFamilyIDt Typet
|
UpdateTypet ranget FamilyIDListRR R t Countt
|
sendStringt GetBuffer( RX Rc R! RI RJ t sendPackRZ ( ( s .\\UserCtrlDB.pyRb @ s c C sÔ | j } t j } d } | j | | t j d | j | j d k ry| t } | j } t j d | | s | j
|
d k rî | j r¡ d Sd d l } | j d t d | | | j | f } | j t j d qÐt j }
|
t j |
|
_ | j |
|
_ x" | D] } |
|
j j | d qWt |
|
j |
|
_ | j | |
|
j t j d |
|
j nW | j rd Sd d l } | j d t d | | | j | f } | j t j d
|
d S( Ni s OnDiapatchFamilyID pack = %ss: OnDiapatchFamilyID db[UCN_Dispatch_FamilyID] result = %siÿÿÿÿt targett argss CallType 0 need dispatchR^ s# CallType 0 sendPack.FamilyIDList %ss CallType 1 need dispatch( RÕ R t tagGDRequestCanUseFamilyIDListt ReadDataR R t OutputStringt CallTypeRa t findt countR` t threadingt ThreadRe t startR R RÖ R R R! R# RR R R$ R% R& ( RX RW R t buft recvPackR R[ R R0 t tR' t rec( ( s .\\UserCtrlDB.pyRÙ J s>
|
'
|
'
|
c C s t j } t j | _ | | _ | | _ t | j | _ | | _ t | j | _
|
| j | d d t j t j t j | j d S( Ni ( R t tagDGGeneralDBOperResultRÖ t dgDBOperResultR t Resultt ResultSetR t ResultSetLent ErrMsgt ErrMsgLent packSendt atMergeLogicR t stGamet stDataR& ( RX Rï R t resultSett errMsgR' ( ( s .\\UserCtrlDB.pyt sendGameServerDBOperResultq s c C sÒ | j } t j } d } | j | | t j d | j d } y t j | j
|
} WnP t k
|
r³ } t j d | j
|
| j r¯ | j | j d d d n d SXt | t s| j rÿ t j d | j
|
| j | j d d d n d S| j d } | sQt j d | j rM| j | j d d d n d St | t st j d | | j r| j | j d d d
|
n d S| | } | j d }
|
|
|
sõt j d | j rñ| j | j d d d n d St |
|
t sAt j d |
|
| j r=| j | j d d d n d S|
|
j }
|
|
|
d k rd } d } y | j Wn_ t k
|
r±} t j d | | f d } t | } n$ t j d | d } d } n X| j rý| j | j | d | n d S|
|
d k rÖ| j d } d } d } y | j | t t Wnh t k
|
r} t j d | | | f d } t | } n* t j d | | f d } d } n X| j rÒ| j | j | d | n d S|
|
d k rÉ| j d } | j d } d } d } y | j | | t t t t Wnn t k
|
rp} t j d | | | | f d } t | } n- t j d | | | f d } d } n X| j rÅ| j | j | d | n d S|
|
d k r| j d } d } d } y | j | t Wnh t k
|
rE} t j d | | | f d } t | } n* t j d | | f d } d } n X| j r| j | j | d | n d S|
|
d k r½| j d } | j d i } d } d } d } y4 | i k rû| j | } n | j | | } Wne t k
|
rL} t j d! | | f d } t | } n* t j d! | | f d } d } n X| j r¹| rt t | } n | j | j | | | n d St j d" |
|
d S(# Ni s pack = %ss cPickle.loads('%s') failed!R s OperDict parse failed!s %s is not a dict!R[ s collection not specified!s collection name:%s not valid!s collection name not valid!t opers oper not specified!s oper:%s not valid!s oper not valid!t dropi s drop %s failed!error = %ss drop %s failed!unknown error!s unknown exception!RT t docss# insert %s into %s failed!error = %ss+ insert %s into %s failed!unknown exception!t updatet specs0 update %s failed!spec = %s, doc = %s, error = %ss= update %s failed!spec = %s, doc = %s,unknown exception occur!t removes+ remove from %s failed!spec = %s, error = %ss3 remove from %s failed!spec = %s, unknown exception!R. t fieldss %s.find(%s) failed!s oper %s not support!( RÕ R t tagGDGameServerGeneralDBOperR+ R R R, Ry t cPicklet loadst OperDictR8 R t
|
NeedReturnRD t getSessionIDt
|
isinstancet dictR, t
|
basestringt lowerRF t strRT RU RN RH RJ R. t list( RX RW R R3 R4 R t operDictRF t colNamet colRE R t errorMsgt doc_or_docst docRI t
|
spec_or_idRK RB ( ( s .\\UserCtrlDB.pyRÛ | s
|
|
|
|
|
|
c C s | j } t j } d } | j | | | j } t j d | j | t j k r | j
|
} | j | } | r d } t j d | nW | j | | \ } }
|
t j d | | f | rì t j |
|
} | j | | n | j | j | | | d S| t j k rA| j
|
} | j } | j | | d S| t j k rt j | j } | j | j d | t | d Sd S( Ni s pack = %si s$ packData get from cache. playerID=%ss+ packData get from db. playerID=%s,result=%s( RÕ R t tagGDGameServerToDBLogicR+ t QueryTypeR R R, RÖ t gstDBLogic_PlayerPackDataReqt IDt getPlayerPackDatat GetPlayerDataByPlayerIDRz t b64encodet updPlayerPackDatat SendGameServerToDBLogicResultRQ t gstDBLogic_PlayerPackDataUpdt Datat gstDBLogic_GMCmdt GMShellt DBGMCommandRV ( RX RW R R3 R4 R t queryTypet playerIDt packDataR t
|
playerDatat dbAnswerList( ( s .\\UserCtrlDB.pyRÜ s: "c C s± t j } t j | _ | | _ | j | _ | j | _ | j | _ t | j | _
|
| | _ t | j | _ | j | d d t j t j t j | j t j d d S( sñ »Ø¸´GameServer·¢Ë͵ÄSendDBLogic£¬¿ÉÒÔ²»»Ø¸´£¬ÓɾßÌåÀàÐ;ö¶¨
|
@param result: ½á¹û£º1³É¹¦£¬0ʧ°Ü
|
@param recvPack: GameServer·¢À´µÄÊý¾Ý°ü£¬Data¿ÉÔÖµ·µ»Ø£¬Ò²¿ÉÐ޸ĺ󷵻أ¬ÓɾßÌåÀàÐ;ö¶¨
|
@param resultSet: »Ø¸´Êý¾Ý
|
i s" »Ø¸´ SendGameServerToDBLogicResultN( R t tagDGGameServerToDBLogicResultRÖ t dgDBGameServerToDBLogicResultR R9 Rb R` Ri R t DataLenR: R; R> t atInnerR R@ RA R& R R ( RX Rï R R4 RB R' ( ( s .\\UserCtrlDB.pyRg 4 s c C s¶ t j } | | _ | t } | j | i | d 6 } | sV t j d | j d St j d | j i | j d 6} | t } | j
|
| | t j t } | t } | j
|
| | t j } | t } | j
|
| | t j } | t } | j
|
| | t j }
|
| t } | j
|
| | t j } | t } | j
|
| | t j } | t } | j
|
| | t j } | t } | j
|
| | t j } | t } | j
|
| | t j } | t } | j
|
| | t j } | t } | j
|
| | t j } | t! } | j
|
| | t j" } | t# } | j
|
| | t j$ } t j% } | j j& | _ | t' } | j( | } d | j) | | | |
|
| | | | | | | | | | f S( NRK s0 GetPlayerDataByPlayerID Exception playerID = %si R s
|
accid = %si ( i s (* R t tagDBPlayerRK t UCN_DBPlayert
|
adoLoadCExR R R3 t AccIDt UCN_RoleItemt readPlayerPackSaveDatat tagRoleItemRN t UCN_RoleMissiont tagRoleMissiont UCN_RoleMissionDictt tagRoleMissionDictt UCN_RoleSkillt tagRoleSkillt UCN_RoleBufft tagRoleBufft UCN_RoleRepeatTimet tagRoleRepeatTimet UCN_PlayerHorseTablet tagPlayerHorseTablet
|
UCN_GMOpert tagGMOpert UCN_RolePett
|
tagRolePett UCN_PetSkillt tagPetSkillt UCN_RoleNomalDictt tagRoleNomalDictt UCN_PlayerDienstgradt tagPlayerDienstgradt UCN_BattleFormationt tagBattleFormationt tagDBGMIPRU t
|
UCN_DBGMIPt adoQueryIndexRÕ ( RX RW Rn t dbPlayerR[ t loadOKt queryDictt itemDatat missionDatat roleMissionDictDatat roleSkillDatat roleBuffDatat roleRepeatTimeDatat roleHorseDatat
|
gmOperDatat rolePetDatat petSkillDatat roleNormalDictDatat roleDienstgradDatat battleFormationDatat gmIPt gmIPData( ( s .\\UserCtrlDB.pyRd I sR
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
c C s t j } | j } t j } d } | j | | | j j t d } t j
|
d | | j } t j j | } | s t j d | d St j }
|
t j |
|
_ | j | g r!d |
|
_ | j | j | j j d t j t j t j |
|
j t j d | d Sd |
|
_ | |
|
_ t | |
|
_ d |
|
_! d |
|
_" | j | j | j j d t j t j t j |
|
j d S( Ni s accID = %s.s client not found!sessionID = %ss query failed!spec = %si R (# R R
RÕ R t tagLPQueryRegisterResultR+ Ry t stript chrR R RQ t MergeProxyClientMgrt getMergeProxyClientMgrt findClientBySessionIDR R t tagMPQueryRegisterResultRÖ t dgMergeQueryNewAccountR R, R9 R> Rî Rï R? R t stNoSenseR& t AccountR t
|
AccountLent Pwdt PwdLen( RX RW R R
R3 R4 R R t clientSessionIDRB R' ( ( s .\\UserCtrlDB.pyRÝ s6 * *c C sH t j } y | j } t j } d } | j | | t j } t j | _
|
| j } t j } d } | j | | t | }
|
d |
|
k rd | _ d | _ t | j | _ | j | j | j j d t j t j t j | j t j d d S| j d k rd | _ d | _ t | j | _ | j | j | j j d t j t j t j | j t j d d S| j } t j j | } | sÃt j d | d S| j! } | j } | j" j# j$ t% d } | j& j$ } d | _ | | _' t | | _( d
|
| _) d | _* | j | j | j j d t j t j t j | j t j+ d | | | | f t, d | | g | | <Wn t- k
|
rÿ} t. j/ d t. j0 d | t1 j2 t3 j4 | f } t j. | nE t. j/ d t. j5 d t1 j2 t3 j4 | f } t j. | n Xd S( sß »º´æ¿ç·þÍæ¼ÒÉÏ´«Êý¾ÝÐÅÏ¢
|
Ä¿Ç°Õ˺š¢Íæ¼ÒID¡¢½ÇÉ«Ãû¾ùÒÑÈ·±£Î¨Ò»£¬¹ÊÎÞÐèÔÙÖØÐÂÉú³ÉеÄÕ˺ż°½ÇÉ«ÐÅÏ¢
|
Ö±½Ó½ÓÊÕ¸üлº´æ¼´¿É£¬Íæ¼ÒµÇ½¿ç·þ·þÎñÆ÷ʱֱ½Ó´Ó»º´æÊý¾ÝÖнâÎö½ÇÉ«Êý¾Ý£¬´Ó¶ø½ÚÊ¡db´æÈ¡²½Öè
|
i iÿÿÿÿs Player data length not enough!s player data too short!Ns Player data error!s player data error!s client not found!sessionID = %si R s3 player %s accID=%s, playerID=%s, %s register PK ok!R s8 OnMergeRegisterPlayer error %s!traceback = %s, pack = %ss5 OnMergeRegisterPlayer error!traceback = %s, pack = %s(6 R R
RÕ R t tagLPRegisterPlayerR+ R t tagMPRegisterPlayerResultRÖ t dgMergeRegisterResultR Ri R Rv t readDataR R9 t ErrorMsgt ErrorMsgLenR> RQ Rî Rï R? R R² R& R R RK R R® R¯ RA Ry RU R« R¬ t
|
PlayerNameR³ R´ Rµ R¶ R3 RP R8 R Rë t ERROR_NO_175t tracebackt
|
format_exct binasciit b2a_hext ERROR_NO_176( RX RW R R
R3 R4 R t loginResultPackRp t playerRect dbPlayerReadLenR· RB RA Rn R t
|
playerNameRF R ( ( s .\\UserCtrlDB.pyRÞ ¬ sj * * * 41c C s y| j } | j } t j } d } | j | | | j j t d } t j d | | t
|
} | j i | d 6 } | s | j d k r£ d St j j }
|
t |
|
} | j d d } | j i | d 6i i d d 6| d 6d 6 t j d | d SWn t k
|
r`} t j d
|
t j d | t j | f } t j | n9 t j d
|
t j d t j | } t j | n Xd S( Ni s OnFinishRecharge ...%st OrderIDs .i t IsProcesst EndOrderTimes $sets OnFinishRecharge OrderID = %sR s# OnFinishRecharge error %s!pack = %ss OnFinishRecharge error!pack = %s( RÕ t getLengthR t tagMDFinishRechargeR+ RÉ R« R¬ R R t UCN_PayInfoR. R/ t datetimet todayRV t splitRH R8 R Rë t ERROR_NO_170RÂ RÃ ( RX RW R R3 t packLenR4 R t orderIDRZ R Rn t
|
curTimeStrRF R ( ( s .\\UserCtrlDB.pyRâ õ s2
|
,+%c C sB y¸| j } | j } t j } d } | j | | | j j t d } t j d | | t
|
} | j i | d 6d d 6d d 6 } | s | j d k r± d S| d }
|
t j } t j | _ t j | _ t |
|
d | _ t | j | _ t |
|
d | _ t | j | _ t |
|
d | _ t |
|
d | _ t | j | _ | j i | j d 6i i d
|
d 6d 6 | j | | j t j d | j d SWn t! k
|
r} t" j# d t" j$ d | t% j& | f } t j" | n9 t" j# d t" j$ d t% j& | } t j" | n Xd S( Ni s OnQueryRecharge ...%sRy RÊ RË RÉ t OrderInfot OrderAmountt Extrasi s $sets OnQueryRecharge OrderID = %sR s" OnQueryRecharge error %s!pack = %ss OnQueryRecharge error!pack = %s(' RÕ RÌ R t tagMDQueryRechargeR+ R³ R« R¬ R R RÎ R. R/ R t tagDMRechargePushRÖ t dgDBToMapServerR t gmReChargePusht SubTypeR RÉ R t
|
OrderIDLenRÖ t OrderInfoLenRj t MoneyRØ t ExtrasLenRH R% R& R8 R Rë RÒ RÂ RÃ ( RX RW R R3 RÓ R4 R t accountRZ R t billInfoR' RF R ( ( s .\\UserCtrlDB.pyRá sD
|
$
|
(+%c C s¦ yë| j } | j } t j } d } | j | | t j d | j t j } t
|
j | _ t
|
j | _ | j | _ | j | _ t j } | j | _ | j | _ | t } t }
|
| j | st|
|
t k r+d | _ d | _ d | _ | j | | j t j d | j d Sd | _ d | _ d | _ | j | | j t j d | j d S| j | _ | j | _ | j | _ | j | _ | j | _ | j | | j t j d | j | j f d SWn t k
|
r8} t j d t j! d | t" j# | f } t j | n9 t j d t j! d
|
t" j# | } t j | n Xd | _ d | _ d | _ | j | | j d S( Ni s% OnQueryNewGuyCardState cardID = %s...R s- OnQueryNewGuyCardState cardID = %s not found!i s. OnQueryNewGuyCardState query error!cardID = %ss+ OnQueryNewGuyCardState cardID = %s state:%sR s) OnQueryNewGuyCardState error %s!pack = %ss& OnQueryNewGuyCardState error!pack = %s($ RÕ RÌ R t tagMDIsMediaCardUsedR+ R R t CardIDR t tagDMIsMediaCardUsedRÖ RÛ R t gmQueryNewGuyCardStateRÝ t CardIDLenR t tagDBNewGuyCardStatet UCN_DBNewGuyCardStateR t adoLoadt IsUsedt UserDataLent UserDataR% R& R t CardTypet ValidTimeR R8 R Rë RÒ RÂ RÃ ( RX RW R R3 RÓ R4 R R' t objRZ t lastExceptionCntRF R ( ( s .\\UserCtrlDB.pyRà I sb
|
+% c C s yt| j } | j } t j } d } | j | | t j } t j | _ t j
|
| _ | j | _ | j | _ t j d | j t j } | j | _ | j | _ | j | _ | j | _ | j | _ | j | _ | j | _ | t } | j | s@d | _ | j | | j t j d | j d Sd | _ | j | | j t j d | j Wn t k
|
rÁ}
|
t j d t j d |
|
t! j" | f } t j | n9 t j d t j d t! j" | } t j | n Xd | _ | j | | j d S( Ni s onCheckUpdateNewGuyCardState %ss/ onCheckUpdateNewGuyCardState failed!cardID = %si s0 onCheckUpdateNewGuyCardState success!cardID = %sR s/ onCheckUpdateNewGuyCardState error %s!pack = %ss, onCheckUpdateNewGuyCardState error!pack = %s(# RÕ RÌ R t tagMDCheckUpdateMediaCardStateR+ R t tagDMCheckUpdateMediaCardResultRÖ RÛ R t gmUpdateNewGuyCardStateRÝ Rè Rå R R R, R Ré Rì Rí Rî Rï Rð Rê t adoCheckUpdateR9 R% R& R8 R Rë t ERROR_NO_171RÂ RÃ ( RX RW R R3 RÓ R4 R R' Rñ RZ RF R ( ( s .\\UserCtrlDB.pyRã sJ
|
+% c C së | j r d Sd } t j } | j | j | } | j sG d S| t } t j } | j j
|
| _ | j | sÎ | j r¶ t j d t j d | j } t j | n t j d | j d S| j | _ | j | d S( s ±£´æÍæ¼ÒÐÅÏ¢Ni R s load account failed, accid = %ss0 OnSavePlayerInfo load account failed, accid = %s( R R t tagGDSavePlayerInfoR+ RÕ t GeTuiClientIDt UCN_DSAccountR t tagDSAccountRy RU t ACCIDt adoLoadCR Rë t ERROR_NO_57R R t
|
adoUpdateC( RX RW R R t
|
PlayerInfoRZ t PlayerAccR ( ( s .\\UserCtrlDB.pyRñ ® s$
|
c C su d } t j } | j | j | } | j | j | } t j d d | j d t j
|
| j | j f d S( s ½øÈë´´½ÇÂñµãi i)# s: OperatorID=%s&Step=%s&AccountID=%s&Flag=1000&DeviceFlag=%si N( R t tagLDPrepareCreateRoleR+ RÕ t GetAccountFromTableRy R5 t EventReportt AppIDR t GetPlatformAccIDt
|
DeviceFlag( RX RW R R R Râ ( ( s .\\UserCtrlDB.pyR Ê s c C s t j } d } | j | | t | } d | k rF t d d f S| | 7} | j } | d k rr t d d f St j d | t | | j f S( Ni iÿÿÿÿR s __ReadPlayerID playerID = %s(
|
R Rv R» R RU RK R R3 RN Ry ( RX RW t saveDataRÆ R RÇ Rn ( ( s .\\UserCtrlDB.pyt __ReadPlayerIDÔ s
|
c C sH t j } d } | j } | j } t j | | \ } } | t j k rDt j | | \ } } | } t j | | \ }
|
} | } t j | | \ } } | t j
|
k r>t j | | | | \ } } t j t | } |
|
| k s_t t j } | | | | | d } | j | | | | t d f Sn! | j | | | | t d f S| j | | \ } } } | | k råt | | t <| | | t _ t | | | t _ t j d | | | j j f n | r:t j } t j | _ t j | _! | | _" | | _# | j$ | | j% n | | f Sd S( Ni i sQ onSaveMapServerPlayerDataMergeServer result = %s, playerID = %s, sessionID = 0x%X(& R R
RÕ RÌ R RÔ RÖ t gstPlayerDetailt ReadDWORDR t stMint
|
ReadStringt ToDWORDt crc32R¬ RA t onSavePlayerDataCRCErrorRU t _UserCtrlDB__ReadPlayerIDRP R t MergeRegPInfoIndex_PackDataRi R Rt R R3 Rî Rï R t tagDBUpdateReturnt dgUpDateR- R! R9 RK R% R& ( RX RW R R
R R3 t lengthRd t
|
needReturnt
|
packCrcPost packCrct serverTypePost
|
serverTypeR t calcCrct serverTypeDataR Rn R t updateReturn( ( s .\\UserCtrlDB.pyRí á sJ
|
|
c C so d } | j } | j } t j | | \ } } | t j k rkt j | | \ } } | } t j | | \ } } | }
|
t j | | \ } } | t j k r5t j | | | | \ } } t j
|
t | } | | k sVt t j } | |
|
| | |
|
d } | j | | | | t d f Sn! | j | | | | t d f St } d } t j r| j | | \ } } } n | j | | \ } } } | s | j j } t j d t j d | } t j | t j t j d d | | | n | r^t j } t j | _! t j | _" | | _# | | _$ | j% | | j& n | j' | | t j( d | | | j j f t) j* j+ t j, t- | } t) j* j. | rat) j* j+ | d } x t) j/ | D]t } | j0 t j1 sqæn t) j* j+ | | } t) j* j. t) j* j+ | | sMt2 j3 | | qæt) j4 | qæWn | | f Sd S(
|
s# Íæ¼ÒÏÂÏߣ¬±£´æÍæ¼ÒÔÚMapServerµÄÊý¾Ýi i R s& Player save data failed!sessionID = %ss UserLogs\SaveFailDumps %s.mdatsF onSaveMapServerPlayerData result = %s, playerID = %s, sessionID = 0x%Xt BackupN(5 RÕ RÌ R RÔ RÖ R
|
R R R R R R R¬ RA R RU R# t PackSavet SavePlayerMapServerDataExt SavePlayerMapServerDataRî Rï R Rë t ERROR_NO_59R R t DumpDataR R+ R R R R- R! R9 RK R% R& t RevoverBillProcessR3 R( R) R* t PlayerBakRootRV t existst listdirt endswitht PlayerBakFileTypet shutilt moveRJ ( RX RW R R R3 R Rd R R R R R R R R R Rn R Rï R R t PlayerBakDirt
|
BakCopyDirt filenamet fullPath( ( s .\\UserCtrlDB.pyRð sf
|
|
' # !c C s< | j } | j r d St j s9 t j j t j r= d St j d t j xät j t j D]Ð\ } } } | j
|
d r qd n x©| D]¡} | j
|
t j s q n t | d k rÔ t j d | d SyM t j j | | } t | d } | j } | j t j | } Wn t j d | d SXt j rd| j | | \ } }
|
} n | j | | \ } }
|
} | st j d | d St j j t j t |
|
d } t j j t j j | | s t j | | t j d |
|
| | f q t j | t j d |
|
| | f q Wqd Wd S(
|
Ns& Íæ¼Ò±¸µµÂ·¾¶ DBConfig.PlayerBakRoot=%sR i sN Íæ¼Ò±¸µµ¸öÊýÒì³£: The number of backup files is greater than one. filenames=%st rbs Íæ¼Ò±¸µµ´ò¿ªÊ§°Ü. %ss Íæ¼Ò±¸µµÈë¿âʧ°Ü fail. %ss/ Íæ¼Ò±¸µµÈë¿â³É¹¦: playerID=%s,accID=%s, move %ss1 Íæ¼Ò±¸µµÈë¿â³É¹¦: playerID=%s,accID=%s, remove %s( RW R R# R% R( R) R& R R3 t walkR( R) R t fatalR* t openR' R7 t zlibt
|
decompressR R R! RV R* R+ RJ ( RX RW t parentt _t filenamesR. R/ t fileHandlerR R Rn R R- ( ( s .\\UserCtrlDB.pyt __PlayerBackupSave\ sJ "
|
!! "c
|
C s} t j d | y* t | | j d j d d } Wn d } n Xt j j t j t
|
| d | } t j j | s d | } t j | d Sy8 t | d } | j } | j t j | } Wn d | } t j | d SXt j r | j | | \ } } } n | j | | \ } } } | sYd | } t j | d Sd
|
| | | f } t j | d S( Ns ===Ö´ÐÐÍæ¼ÒÖ¸¶¨±¸µµÈë¿â: %ss .R7 i R s ²»´æÔÚ¸ÃÍæ¼Ò±¸µµÎļþ: %sR0 s Íæ¼ÒÖ¸¶¨±¸µµ´ò¿ªÊ§°Ü: %ss Íæ¼ÒÖ¸¶¨±¸µµÈë¿âʧ°Ü: %ss. Íæ¼ÒÖ¸¶¨±¸µµÈë¿â³É¹¦: playerID=%s,accID=%s, %s( R R3 Rj Rp RÑ R( R) R* R# R% RV R& R3 R' R7 R4 R5 R R R! (
|
RX RW t bakFileNameRn R/ R R9 R R R ( ( s .\\UserCtrlDB.pyt SavePlayerDataByBackup s: *
|
$
|
|
|
|
c C s× y¸ | s d S| j t d } | t } | j i | d 6d d 6d d 6 } | si | j d k rm d S| d } | d } | j i | d 6i i d d 6d 6 t j d | Wn t j d | n Xd S(
|
Ni Ry i RÊ RË RÉ s $sets RevoverBillProcess success...%ss RevoverBillProcess error %s( R« R¬ RÎ R. R/ RH R R R ( RX RW R Râ RZ R Rã RÔ ( ( s .\\UserCtrlDB.pyR$ ¶ s
|
$
|
|
%c C sl t j } d } | j | | t | } d | k rF t d d f S| | 7} t j d | j | j d k r t d d f S| j j | _ | t
|
} | j d } | j | j | sÔ t | j d f S| j | j | | j d } | j | | j | j | t t j | | t 7} | j | j d } | j | | j | j | t t j | | 7} | j | j d } | j | | j | j | t t j | | 7} | j | j d } | j | | j | j | t t j | | 7} | j | j d
|
} | j | | j | j | t t j | | 7} | j | j d } | j | | j | j | t t j | | 7} | j | j d } | j | | j | j | t t j | | 7} | j | j d } | j | j | j | j | | | j | | j | j | t! t j" | | 7} t# j$ | | \ } } t j% } x3 t& | D]% }
|
| | j | | t | 7} qW| j d } | j | | j | j | t' t j( | | 7} | j | j d } | j | | j | j | t) t j* | | 7} | j | j d } | j | | j | j | t+ t j, | | 7} | j | j d } | j | | j | j | t- t j. | | 7} | j | j d } | j | | j | j | t/ t j0 | | 7} | j | t | k sYt1 t | j | j f S( Ni iÿÿÿÿR s$ Saving player data,playerID = %s....t' gstSaveMapServerCrashData_1_tagDBPlayert% SavePlayerMapServerData_1_tagRoleItemt( SavePlayerMapServerData_1_tagRoleMissiont, SavePlayerMapServerData_1_tagRoleMissionDictt& SavePlayerMapServerData_1_tagRoleSkillt% SavePlayerMapServerData_1_tagRoleBufft+ SavePlayerMapServerData_1_tagRoleRepeatTimet- SavePlayerMapServerData_1_tagPlayerHorseTablet% SavePlayerMapServerData_1_gmOperCheckt$ SavePlayerMapServerData_1_tagRolePett% SavePlayerMapServerData_1_tagPetSkillt* SavePlayerMapServerData_1_tagRoleNomalDictt- SavePlayerMapServerData_1_tagPlayerDienstgradt, SavePlayerMapServerData_1_tagBattleFormation(2 R Rv R» R RU R R3 RK Ry RU Rw R× RØ Rÿ RÚ t recPlayerLogofft savePlayerDataRz R| RN R} R~ R R R R R R R
R R R t gmOperCheckR R R R R RQ R R R R R R R R R R t AssertionError( RX RW R RÆ R RÇ R[ R t gmIPCntt gmIPRect i( ( s .\\UserCtrlDB.pyR! Ë s
|
|
|
|
|
,
|
|
)
|
|
)
|
|
)
|
|
)
|
|
)
|
|
)
|
|
|
) #
|
)
|
|
)
|
|
)
|
|
)
|
|
)
|
c C s~ t j } d } | j | | t | } d | k rF t d d f S| | 7} t j d | j | j d k r t d d f S| j j | _ | t
|
} | j d } | j | j | sÔ t | j d f S| j | j d k rý | j | n | j d } | j | | j | j | t t j | | t 7} | j | j d } | j | | j | j | t t j | | 7} | j | j d } | j | | j | j | t t j | | 7} | j | j d } | j | | j | j | t t j | | 7} | j | j d
|
} | j | | j | j | t t j | | 7} | j | j d } | j | | j | j | t t j | | 7} | j | j d } | j | | j | j | t t j | | 7} | j | j d } | j | j! | j | j | | | j | | j | j | t" t j# | | 7} t$ j% | | \ } } t j& } x3 t' | D]% }
|
| | j | | t | 7} q®W| j d } | j | | j | j | t( t j) | | 7} | j | j d } | j | | j | j | t* t j+ | | 7} | j | j d } | j | | j | j | t, t j- | | 7} | j | j d } | j | | j | j | t. t j/ | | 7} | j | j d } | j | | j | j | t0 t j1 | | 7} | j | t | k skt2 t | j | j f S( Ni iÿÿÿÿR s$ Saving player data,playerID = %s....t' SavePlayerMapServerDataEx_1_tagDBPlayert' SavePlayerMapServerDataEx_1_tagRoleItemt* SavePlayerMapServerDataEx_1_tagRoleMissiont. SavePlayerMapServerDataEx_1_tagRoleMissionDictt( SavePlayerMapServerDataEx_1_tagRoleSkillt' SavePlayerMapServerDataEx_1_tagRoleBufft- SavePlayerMapServerDataEx_1_tagRoleRepeatTimet/ SavePlayerMapServerDataEx_1_tagPlayerHorseTablet' SavePlayerMapServerDataEx_1_gmOperCheckt& SavePlayerMapServerDataEx_1_tagRolePett' SavePlayerMapServerDataEx_1_tagPetSkillt, SavePlayerMapServerDataEx_1_tagRoleNomalDictt/ SavePlayerMapServerDataEx_1_tagPlayerDienstgradt. SavePlayerMapServerDataEx_1_tagBattleFormation(3 R Rv R» R RU R R3 RK Ry RU Rw R× RØ Rÿ RÚ t CountryLastWeekHornorRK t savePlayerDataExRz R| RN R} R~ R R R R R R R
R R R RM R R R R R RQ R R R R R R R R R R RN ( RX RW R RÆ R RÇ R[ R RO RP RQ ( ( s .\\UserCtrlDB.pyR : s
|
|
|
|
|
,
|
|
)
|
|
)
|
|
)
|
|
)
|
|
)
|
|
)
|
|
|
) #
|
)
|
|
)
|
|
)
|
|
)
|
|
)
|
c
|
C s÷ d } t | } t j | | \ } } | | 8} t j } x° t | D]¢ } | j | j | | | } | | 7} | | 8} | j t j
|
k rM | j | | t t j t | j t j | j d t j | j | j f qM qM Wd S( Ni s EndTime = %s.Reason = %s( R R R R R RQ t clearR» t OperRÖ t gmForbidAcct onForbiddenUpdateRN R
|
t TDateTime_NowRj t EndTimet GMAccIDt TDateTimeToStringt Msg(
|
RX R Rn RC R R t cntt gmOperRecRQ t readLen( ( s .\\UserCtrlDB.pyRM ª s
|
|
|
|
4c C s t j } | | k r" i | | <n | j d | } | j | | } | j d | }
|
|
|
j |
|
j d } t j | | \ } } t j d | | | f | } t | } i } | rê | | d <| | d <d | d <n xt
|
| D]ö } | j d | }
|
|
|
j | j |
|
j | j d
|
| }
|
|
|
j | j | | | } |
|
j | d k rt j d t | d S| | 7} | rÕ| j d | }
|
|
|
j | j |
|
j n | j | d | d <q÷ W| rd } xòt r yx | j d | }
|
|
|
j | j i | d 6| d t |
|
j | | | | <t j d | | | | | f PWq t j j k
|
r} t j | k rµ| d 7} q n t t j d | j j t j d d | f t j d | | | f Pq Xq Wnâ d } xÙ t rñyo | j d | }
|
|
|
j | j i | d 6 |
|
j d | | | <t j d | | | | | f PWqt j j k
|
rí} t j | k rÅ| d 7} qn t t j d | | | | f PqXqW| j | S( s ±£´æÍæ¼ÒÎïÆ·µÈÊý¾Ý£¬ÓÅ»¯°æs savePlayerDataEx_%s_Alls savePlayerDataEx_%s_removei s' saving %s data, playerID = %s, cnt = %sRK R$ i t
|
__PackSaves savePlayerDataEx_%s_clears savePlayerDataEx_%s_readDataiÿÿÿÿs %sNs savePlayerDataEx_%s_makeSIDs savePlayerDataEx_%s_updatet upsertsA update end %s data, playerID = %s, cnt = %s, playerDataCntInfo=%ss %s.%s:docs = %si s0 update failed!docs = %s, error = %s, trycnt = %dsA remove end %s data, playerID = %s, cnt = %s, playerDataCntInfo=%ss7 remove failed!%s playerID = %s, error = %s, trycnt = %d( R t g_playerDataCntInfoR× RØ RÚ R R R R3 R RQ Rb R» RÃ t makeSIDt getRecordRN RH R t errorst OperationFailureR# t TryCntOnWriteFailR t __class__t __name__t inspectt stackR RJ ( RX Rn RW t collectionNamet
|
structNameRC t checkSIDRp t oAllFuncGradeR[ R R Rk R6 R R] RQ Rm t trycntt err( ( s .\\UserCtrlDB.pyRa » s
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
!
|
.
|
|
!
|
|
c C s t j } | | k r" i | | <n | j d | } | j | | } | j d | }
|
|
|
j | j i | d 6 |
|
j d } t j | | \ } } t j d | | | | f | } t
|
| } g } x,t | D] } | j d | }
|
|
|
j | j |
|
j | j d | }
|
|
|
j | j | | | } |
|
j | d k rt j d t | d
|
S| | 7} | rÅ| j d | }
|
|
|
j | j |
|
j n | j d | }
|
|
|
j | j } |
|
j | j | qç Wt
|
| rd } xó t rÿyM | j d | }
|
|
|
j | j | t t |
|
j | | | | <PWq t j j k
|
rû} t j | k r¨| d 7} q n t t j d | j j t j d d | f t j d | | | f Pq Xq Wn d | | | <| j | S( s ±£´æÍæ¼ÒÎïÆ·Êý¾Ýs savePlayerData_%s_Alls savePlayerData_%s_removeRK i s; saving %s data for player playerID = %s cnt = %s, data = %ss savePlayerData_%s_clears savePlayerData_%s_readDataiÿÿÿÿs %sNs savePlayerData_%s_makeSIDs savePlayerData_%s_getRecords savePlayerData_%s_inserti s %s.%s:docs = %si s0 Insert failed!docs = %s, error = %s, trycnt = %d(! R Rp R× RØ RJ RÚ R R R R R RQ Rb R» R3 Rà Rq Rr RR RN RT RU R Rs Rt R# Ru R Rv Rw Rx Ry R ( RX Rn RW Rz R{ RC R| Rp R} R[ R R Rk R6 R RG RQ Rm R] R~ R ( ( s .\\UserCtrlDB.pyRL sx
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
.
|
c C s d S( N( ( RX R ( ( s .\\UserCtrlDB.pyRK d s c
|
C s t t j } t j d t j d | j j | f } t j | t j
|
t j d | | t j } d } t | } d | j | | | k r¢ n1 | j | | j t j rÓ | j | j d n t j } t j | _ t j | _ d | _ | j | | j d S( NR s sessionID = 0x%x dump to file %st UserLogsi iÿÿÿÿi i ( RV t uuidt uuid4R Rë t ERROR_NO_60Rî Rï R R R# R R+ R Rv R R» t updatePlayerAccStateRK RÖ t pysForbiddent sendAccForbiddenLogReqRy R R R R- R
|
R! R9 R% R& (
|
RX RW R t saveDataWithCRCt dumpFileNameR RÆ R R R ( ( s .\\UserCtrlDB.pyR | s + c C s d S( N( ( RX t accidt isForbidden( ( s .\\UserCtrlDB.pyR s c C sÐ | t } t j } | | _ t } | j | } | s° | t k s~ t j d | j j t
|
j d d | f t St j d | j j t
|
j d d | f t S| | _ | j | sÌ t St S( s ·âºÅs7 %s.%s SID error found on reading data of playerID = %s!i i s %s.%s playerID = %s not found!( Rw R Rv RK R Rý R R Rv Rw Rx Ry RU R t AccStateRÿ RN ( RX RW Rn t newStateR[ R] t lastSIDErrorCntt ret( ( s .\\UserCtrlDB.pyR s
|
.. c C sh t j } | j | j d | j | j d k rd | j t j | j t
|
j | d d Sd S( s$ Íæ¼ÒÏÂÏߣ¬±£´æÍæ¼ÒÔÚGameServerµÄÊý¾Ýi i R N( R t* tagGameServerToBalanceServerPlayerSaveDataR+ RÕ RÌ RP t setSrcSvrTypeR t stLogint sendOKStringRÖ t dgPlayerSaveGameServerData( RX RW R t saveGameServerPlayerDataReq( ( s .\\UserCtrlDB.pyRé µ s c C s d S( N( ( RX RW R ( ( s .\\UserCtrlDB.pyt onGetGameServerPlayerLoginDataÆ s c
|
C s¾ yt j } | j | j t j } t j | _ | j | _ t
|
j } | j j | _ d | _ | t } t } t } | j | i t | j d 6| j d 6 rÞ t j d | j d | _ d | _ nx | t k sd | _ t | _ nT | t k sDt j r/d | _ t | _ qVd | _ d | _ n d | _ d | _ | j | | j t j d | j Wn6 t j d t j d t! j" } t j | n Xd S( Ni Ry t IsDeleteds player of accid = %s exists!i s1 onCreateRoleServerCheckIsHaveRole ok, Accid = %s!R s) Catch a unexpetcted exception, error = %s(# R t tagCSIsHaveRoleR+ RÕ R t tagDRequestResultRÖ t" gstCreateRoleServerCheckIsHaveRoleR Ry R Rv RU R Rw R R Rx R R R3 R9 t ExAttrt disDataBaseErrorR# R| t disAccStateErrorR% R& R R Rë t ERROR_NO_62RÀ RÁ (
|
RX RW R R4 R' t PlayerR[ Rò R R ( ( s .\\UserCtrlDB.pyt! onCreateRoleServerCheckIsHaveRoleÞ s@
|
, "c C sá y¤ t j } | j | j t j } t j | _ | j | _ d | _
|
| j | | j rp d | _ n d | _ | j | | j t j d | j Wn6 t j d t j d t j } t j | n Xd S( Ni i s2 onCreateRoleServerCheckPlayerExist ok, Accid = %s!R s) Catch a unexpetcted exception, error = %s( R t tagCSCheckPlayerNameExistR+ RÕ R R RÖ t# gstCreateRoleServerCheckPlayerExistR Ry R9 t hasPlayerByPlayerNameR¾ R R% R& R R R Rë t ERROR_NO_63RÀ RÁ ( RX RW R R4 R' R ( ( s .\\UserCtrlDB.pyt" onCreateRoleServerCheckPlayerExist
|
s "c C sx | j t j | j | | \ } } } } | r^ | j t j | | t j d | n | j t j | | d S( Ns' send created player info for accid = %s(
|
R R R t
|
CreateRoleR RÖ t dgCreatePlayerR R t sendFailString( RX RW R t Suct disCodet AccIdRC ( ( s .\\UserCtrlDB.pyt onCreatePlayer s c C sË y | j | | \ } } } } t j } t j | _ | | _ | | _ | r] d | _ n | | _ t j
|
d | | j | | j Wn6 t j d t j d t j } t j | n Xd S( Ni s' send created player info for accid = %sR s) Catch a unexpetcted exception, error = %s( R¥ R R RÖ t$ gstCreateRoleServerRequestCreateRoleR R9 Ry R R R R% R& R Rë t ERROR_NO_64RÀ RÁ ( RX RW R R¨ R© Rª RC R' R ( ( s .\\UserCtrlDB.pyt# onCreateRoleServerRequestCreateRole, s "c C s[ t j d | t } | j } | s | j ry d } x: | d k rt | j rt | j s] t St d | d 7} q; Wt St | | t S| j } | t
|
j k r© t S| d k r| j rd } x: | d k r | j r | j sé t St d | d 7} qÇ Wt St | | t S| j r#t Sd d l } | j d t d | | f } | j t S( Ns CheckEmptyPlayerIDCount starti i i iÿÿÿÿR( R) ( R R RS R. RO RN t sleepRU R\ R/ R# t IDDispatchPlayeIDLimitR0 R1 R2 ( RX RW R[ R t try_countt emptyCntR0 R5 ( ( s .\\UserCtrlDB.pyt CheckEmptyPlayerIDCountA sD
|
|
|
|
c C s; | t } | j } | r7 | d } | j | | Sd S( NRK iÿÿÿÿ( RS t find_oneRJ ( RX RW R[ R6 t newID( ( s .\\UserCtrlDB.pyt PopEmptyPlayerIDp s
|
|
c C sE t j } | s+ t | t d t j t j S| j | | j | S( NRK ( R# t UseIDDispatchServerR Rw t PLAYERID_FEEDt PLAYERID_STEPR³ R¶ ( RX RW R· ( ( s .\\UserCtrlDB.pyt DispatchNewPlayerIDz s
|
c C s0 t j } | | _ | t } | j | | S( N( R Rû Rü Rú Rë ( RX R RW t accountDataR[ ( ( s .\\UserCtrlDB.pyR
s
|
|
c C s | t } | j | i t | j d 6| j d 6 r] t j d | j d t | j d f S| j | | j r t j d | j d t
|
| j d f St j t j | _ | j | } | d k r t j d t j d | j } t j | d t | j d f S| | _ d
|
t | | _ t j d | j | j f | j | st j d t j d | j } t j | d t | j d f S| j | sàt j d t j d | j } t j | d t | j d f St j d | j | j f d } t j | d } | } | } | } | }
|
| } | } | } | } | } | } | } | } | } | j | | | | |
|
| | | | | | | | | } t | } d } t j | | } t j | d } | | } t j d | j d d | j | f } | j | j | } t j! d d | j" d t j# | j | j$ f t% j& i | j" d 6| j d 6t j# | j d 6| j' d 6| j$ d 6 } t j! d | t( j) | | S( NRy R s player of accid = %s exists!i R s! player of playerName = %s exists!iÿÿÿÿR s# PlayerID Dispatch failed!accid = %st roles. Before insert role!accid = %s, PlayerName = %ss insert player failed!accid = %ss* insert role ok!accid = %s, PlayerName = %ss' send created player info for accid = %si i)# s: OperatorID=%s&Step=%s&AccountID=%s&Flag=1000&DeviceFlag=%si t
|
OperatorIDt RoleIDt AccountIDt JobR iO (* Rw Rx R Ry R R R t disCreatePlayerError_PlayerExistR¢ R¾ t' disCreatePlayerError_PlayerNameConflictR
|
Ri Rf t CreateRoleTimeRº R Rë t ERROR_NO_65R RK RV R t
|
adoInsertCRë t ERROR_NO_66R t
|
WriteDWORDRÕ R t WriteBYTER R5 R R R R t urllibt urlencodeRÀ t DataRecordPackt DR_CreateRole( RX RW t createPlayerR[ t newPlayerIDR R R t missionDictDatat skillDatat bufDatat repeatTimeDatat horseDataR¢ t gmPermitDatat petDataR¤ t normalDictDatat dienstgradDataR§ t allDatat crct dataCrct dataWithCrcR Râ t
|
playerInfo( ( s .\\UserCtrlDB.pyR¥ sv
|
, D
|
&
|
|
c C s= | t } | j i t | d 6d d 6 } | j d k S( NR¾ i R ( Rw R. R R/ ( RX RW RÈ R[ t resultCollection( ( s .\\UserCtrlDB.pyR¢ ä s
|
#c C s d } | j | j d } | j sF t j | | j } | S| } t | d } | j d rî | d } d }
|
t j |
|
| }
|
t j d | | | f x= t | D]/ } | j
|
| d | d |
|
| j 7}
|
q· W|
|
S| r| j | | S| j | | Sd S( NR i i Rn R$ s$ ####reading %s of player %s,cnt = %ss %s( R. t limitR/ R RÇ RW t has_keyR R RQ t
|
readRecordRÕ t adoQueryCustomCt adoQueryCustom( RX RZ t queryR{ R| R3 RG Rñ R] t docCntR RQ ( ( s .\\UserCtrlDB.pyR{ ê s&
|
c C s | j d | } | j d } t j | | \ } } t j d | | | f | } t | } d }
|
t j |
|
| }
|
xt | D]÷} | j d | } | j | j | j
|
| j d | } | j | j | | | } | j
|
| d k r)t j d t | d S| | 7} d } t j | d r`| j } | | _ n t j | d
|
r| r| j } | j | d } t j | | | _ qn t j | d rÔt j | | _ n t j | d r<| r<| j } | | j k r-| j | d } t j | | | _ q9| | _ q<n | rv| j d | } | j | j | j
|
n |
|
| j 7}
|
q W| j
|
| |
|
f S( s »ñÈ¡¿ç·þÍæ¼Òͬ²½Êý¾Ý»º´æbuffer s getMergePlayerDataBuffer_%s_Alli s9 getMergePlayerDataBuffer %s data, playerID = %s, cnt = %sR s! getMergePlayerDataBuffer_%s_clears$ getMergePlayerDataBuffer_%s_readDataiÿÿÿÿs %sRK t PetIDi t TruckIDt OwnerIDs# getMergePlayerDataBuffer_%s_makeSID( i s ( R× RØ R R R R R RÇ RQ Rb RÚ R» R Rà R
|
t hasFieldRK Rå RÖ t makePetIDt makeTruckIDt TructIDRç Rq RÕ ( RX RÎ R{ RC R| R} R Rk R6 R R RQ R Rm t orgPlayerIDt oldPetIDt petIndext
|
oldOwnerID( ( s .\\UserCtrlDB.pyt getMergePlayerDataBuffer
|
s`
|
|
|
|
|
|
|
|
|
|
c C sW t j } | j } t j d | | | k r? | j | | S| | } | t } d S( s »ñÈ¡¿ç·þÍæ¼ÒÏêϸÐÅÏ¢ s) getting mergePlayer detail for accid = %sN( R R
Ry R R t onGetPlayerDetailR ( RX RW t authPackR
t
|
queryAccidt regPlayerInfoR4 ( ( s .\\UserCtrlDB.pyt onGetMergePlayerDetailH
|
s
|
|
|
c 7 C sô t j } | j } t j d | t r- d St j } | | _ d | _ | t } t
|
} t } | j | i t | j d 6| j d 6 } | t
|
k s¼ | j t j t t d S| j | j i }
|
| t k sdt j | j s>t j r>t j | _ | j | t j d | | j | j d q>n t j rd| j t j t t d Sn t } i | j d 6} t } | | } | j | | t j t! } t" j# | d } |
|
j | } | på| d k oå| d | k } t j d | | d | f t% } | | } | j | | t j& } t" j# | d } |
|
j | } | pn| d k on| d | k } t j d | | d | f t' } | | } | j | | t j( } t" j# | d } |
|
j | } | p÷| d k o÷| d | k } t j d | | d | f t) } | | } | j | | t j* } t" j# | d } |
|
j | } | p| d k o| d | k } t j d | | d | f t+ } | | } | j | | t j, } t" j# | d } |
|
j | } | p | d k o | d | k } t j d | | d | f t- } | | } | j | | t j. } t" j# | d } |
|
j | } | p| d k o| d | k } t j d | | d | f t/ } | | } | j | | t j0 } t" j# | d } |
|
j | } | p| d k o| d | k } t j d | | d | f t1 } | | } | j | | t j2 } t" j# | d } |
|
j | } | p¤| d k o¤| d | k } t j d | | d | f t3 } | | } | j | | t j4 } t" j# | d } |
|
j | } | p-| d k o-| d | k } t j d | | d | f t5 } | | } | j | | t j6 }! t" j# |! d }" |
|
j | } | p¶| d k o¶|" d | k } t j d | |" d | f t7 } | | } | j | | t j8 }# t" j# |# d }$ |
|
j | } | p?| d k o?|$ d | k } t j d | |$ d | f t9 } | | } | j | | t j: }% t" j# |% d }& |
|
j | } | pÈ| d k oÈ|& d | k } t j d | |& d | f t; } | | } | j | | t j< }' t" j# |' d }( |
|
j | } | pQ| d k oQ|( d | k } t j d | |( d | f | r t j d | t= j> d
|
| t? j? }) |) j@ tA jB jC tD jE d |) jF d d oï|) jG d d d k }* |* r | j t j t t d Sn | j t jH k rü | jI | t jJ | }+ |+ rÆ |+ jK tL jM k rt | j t j t t d Sd tL jN |+ jK |+ jO f }, | jP | | |+ jQ |, t j d | |, f q(
|
d }, | jP | | d |, t j d | |, f n, | j t j k r(
|
| j t j t t d St jR }- | jS |- _ | tT } |- jU | }. t" j# |. d }/ t j d |/ d | jV | | | | | | | | |. | |! |# |% |' }0 tW |0 }1 d }2 t" jX |2 |1 }2 t" jY |2 d }2 |2 |0 }3 tZ j[ }4 t j |4 _\ | j] |4 _] | j^ |4 _^ | j_ |4 _` |3 |4 _a tb |3 |4 _c | td }5 t je }6 | |6 _ |6 jf |5 |6 jV |4 _g |6 jh |4 _i tj jk jl |4 _m tn jo |4 jp |4 jq t j d | | j f d S( Ns$ getting player detail for accid = %si Ry R s AccID = %s check SID failed!i RK s %s cnt = %s, lastCnt=%ss# ###dgPlayerInit cntError accid = %ss login data cntError accid=%ss PyMongoDataServer.init datasett DataCntErrorKicks" Time past.EndTime = %s.Reason = %ss$ auto unforbidden accid = %s msg = %ss No forbidden oper found!R s gmIP cnt = %ss- gstPlayerDetail Send accid = %s playerID = %s(r R Rp Ry R R3 RU R Rv R Rw R R Rx R R§ RÖ t dgPlayerInitR R R, RK t isAccStateForbiddenR R# R| t pysSIDCheckErrorForbiddenRÿ R R R Rz R{ R| RN R R Ry R} R~ R R R R R R R
R R R R R R R R R R R R R R R R5 R6 R& R' R( R) R* R R+ t
|
has_optiont getintR
t extractGMOperRd Rg R
|
Rf Ri Rj t unFobbidenAccRh R RU R R RÕ R RÇ RÈ R t tagMapServerPlayerLoginR t ServerRoleIndext SessionIDt IPt ClientIPt PlayerInfoPackR t PlayerInfoPackLenRú Rû Rý t PlayerAccountInfoRÌ t PlayerAccountInfoLent GameWorldt GetGameWorldt GetMapIDt MapIDt NetPackCommont SendPyPackToMapServerSelfR& t GetLength(7 RX RW Rò Rp Ró R R[ Rò R R t playerDataCntInfot cntErrorR Rz R t itemCntt lastCntR t
|
missionCntR t missonDictCntR t skillCntR t bufCntR t repeatTimeCntR¡ t horseCntR¢ t gmOperCntR£ t petCntR¤ t petSkillCntR¥ t dictCntR¦ t roleDienstgradCntR§ t battleFormationCntt dbIniR÷ Rl R R¨ R© RO RØ RÙ RÚ RÛ R' RZ t dbDoc( ( s .\\UserCtrlDB.pyRñ m
|
sV 4
|
,
|
"
|
"
|
"
|
"
|
"
|
"
|
"
|
"
|
"
|
"
|
"
|
"
|
" "*
|
D
|
|
c C so t j | _ | t } | j | i t | j d 6| j d 6 | j | j | j t
|
t j d | | d S( NRy R i ( RÖ t pysNormalR Rw t adoUpdateExCR Ry R Re RK RU R
|
Rf ( RX RW R t gmAccidR R[ ( ( s .\\UserCtrlDB.pyRþ ¸ s
|
*c C sF t j d | | | t | | | | f | j | j | d S( Ns` accid = %s playerID = %s isForbidden = %s operTime = %s timeLimit = %s operGMAccid = %s msg = %s( R R3 t ctimeR RU ( RX R Rn R t operTimet timeLimitt operGMAccidR ( ( s .\\UserCtrlDB.pyRe Á s #
|
c C s
d } t j | | \ } } t j d | | f t j } x= t | D]/ } | | j | | 7} | j | k rN | SqN Wd S( Ni s accid = %s gmOperCnt = %s(
|
R R R R3 R R RQ R» Rc Ry ( RX R t gmOperR¢ R t operCntRl RQ ( ( s .\\UserCtrlDB.pyRý Ý s c C s0 | t } t | j i | d 6d g } | S( Nt LeaderIDRb ( t UCN_FamilyInfoRW R. ( RX RW t leaderIDR[ t familyInfoSnap( ( s .\\UserCtrlDB.pyt getFamilyLeaderFamilyIDë s
|
"c C sb | t } t | j i t | d 6d d 6t j d 6 } | j r^ | j j | d } n | S( s ²éѯ´¦ÓںϷþ״̬µÄ½ÇÉ«ÁбíRy i R R N( Rw RW R. R RÖ t pysServerMergeR| t transform_outgoingRy ( RX RW R R[ t
|
playerList( ( s .\\UserCtrlDB.pyt queryMergePlayerListð s
|
|
3 c C s± t j } | j | j d | j t j } | j j j t
|
d | _ | j } | | _ t j d | | j f | t } t | j } d } | t j k r¦| j | | j j t
|
d | _ | j | _ | j j t
|
d | _ | j | _ | j j t
|
d | _ | j | _ | j j t
|
d | _ t j sj| j d k rzt j d qm | j d k rm | j t j | t t SnÇ| t j! k rÅ| j | | j j t
|
d | _ | j | _ | j j t
|
d | _ | j | _ d | _ | j | _ | j j t
|
d | _ | j" j# d } t$ | | d k r| j t j | t t S| | }
|
| | d } | j d k r¹t j d qm | j% d
|
k ri |
|
d 6t& j' | | j d 6| d 6} y t( j) | } t* j+ d | } t* j, | d d } | j- } | d k rtt j d |
|
| f | j t j | t t SWqqXn t. } | | j/ d k r°| j% d 7_% qm | | _/ d | _% n¨| t j0 k rä| j | | j j t
|
d | _ | j | _ | j j t
|
d | _ | j | _ d | _ | j | _ | j j t
|
d | _ | j" j# d } t$ | | d k r¡| j t j | t t S| | }
|
| | d } | j d k rØt j d qm | j% d
|
k r¡i |
|
d 6t& j' | | j d 6| d 6} y t( j) | } t* j+ d | } t* j, | d d } | j- } | d k rt j d |
|
| f | j t j | t t SWq¡q¡Xn t. } | | j/ d k rÏ| j% d 7_% qm | | _/ d | _% n| t j1 k r;| j | | j j t
|
d | _ | j | _ | j j t
|
d | _ | j | _ d | _ | j | _ | j j t
|
d | _ | j" j# d } t$ | | d k rÀ| j t j | t t S| | }
|
| j d k rét j d qm | j% d
|
k røi |
|
d 6| j d 6t& j2 | d 6} yÌ t( j) | } t3 j4 j# d } d j5 | d d | } t j | t* j+ | } t* j, | d d } | j- } | j6 d d } | d k rêt j d |
|
| f | j t j | t t SWqøqøXn t. } | | j/ d k r&| j% d 7_% qm | | _/ d | _% n2t7 } t8 } | j | s | t7 k rt j9 d | j t j | t: t S| t8 k rÏt j9 d | j | j t j | t; t St3 j< r t j d | j | j t j | t= t Sn | j | j j t
|
d k sm t j d | j j | j j f | j t j | t t S| j" rÍ | j" j# d } t$ | d k rÍ t> j> | d j? | _@ | jA | d qÍ n tB jC d! d" | j d t& j2 | | j@ f | jD d 7_D tE jF tE jG | _H | jI | s`
|
t j9 d# | j | j t j | t: t St jJ } | j | _ d | _K | tL } t7 } t8 } | jM | i tN | j d$ 6| jK d% 6 r t jO d& | j | jP rü
|
| jQ | | q | jR | | n| t7 k s" t S| t8 k s5 t Sd | _S d | _T d' | _U d | _V d | _W d | _X d | _Y tZ j[ j\ | _] | j] | _^ | j] | __ d | _` d | _a d | _b d | _c d | _d | je | | \ } } } } | sö t Stf jg } t jh | _i | jj | _j | jk | _k | j | _l | | _m t$ | | _n | j | _o | j | _p tZ j[ j\ | _] t jO d( | j tq jr | js | jt t S() s ÕʺÅÈÏÖ¤i s auth accid = %s-%s...i s 127.0.0.1s iner no checkt 7758520t 1s |i i t tokent product_codet uids2 http://checkuser.sdk.quicksdk.net/v2/checkUserInfot timeouts checktoken fail:%s-%si
|
s1 http://checkuser.happilygame.com/v2/checkUserInfot tokenkeyt channelt guids /i s /centerapi/checkuser.php?s R t OKs DB access excption!s accid = %s not found!s authPack.AccID = %s, sid errors$ input psw = %s while stored psw = %siþÿÿÿi)# s: OperatorID=%s&Step=%s&AccountID=%s&Flag=1000&DeviceFlag=%ss %s update LogNum errorRy R s player of accid = %s exists!i' s( gstPlayerDetail Send OnCreate accid = %s(u R t tagDataServerPlayerLoginR+ RÕ RÌ R Rû Ry RU R« R¬ Rü R R t IDTypeRú Rj RÖ t
|
gitFreeSDKRý R R¿ t TokenExpiret Phonet Pswt AdultR t RegIPt IsDebugR§ t dgPlayerLogint disPswCheckErrorRN t gitQkGamet ExtraRÑ R R R t GetLoginKeyRÉ RÊ t urllib2t Requestt urlopenR' RP R t gitHYGamet gitX7R R# t ReportUrlR* t replaceR R R R t disUserNameNotExistR| t disGMKickt md5t hexdigestR t SetClientVersionR5 R t LogNumR
|
Ri Rf t LastLoginTimet adoCheckUpdateCRv R Rw Rx R R3 R Rõ Rñ t LVt Sext Hairt HairColort
|
PlayerTypeRÀ t CountryR R R
|
R t DataMapIDt CopyMapIDt PosXt PosYt HPt UseGoldTypet UseSilverTypeR¥ R Rÿ Rø R R R R R R R R R R R& R ( RX RW R Rò t
|
accountRect authAccIDR[ t appTypet redefineIndext extraListR5 R7 t valuesRC t reqt responset the_paget nowTimet urlListt tmpurlRò R t infoListR R¨ R© Rª R' ( ( s .\\UserCtrlDB.pyRç ù s² !
|
|
|
|
|
|
|
|
|
|
|
!) #
|
, c C s d S( N( ( RX Rd t
|
fromPacketR3 ( ( s .\\UserCtrlDB.pyR F s i c C s@ d } t j | | } t j | d } t j | | } d S( NR i ( R RÈ ( RX Rd Rt t disconnectReasont packBuf( ( s .\\UserCtrlDB.pyR§ O s c C s d S( N( ( RX Rt Rv ( ( s .\\UserCtrlDB.pyR% V s c C s d S( N( ( RX RW R ( ( s .\\UserCtrlDB.pyRæ \ s c N C sc d } | t } t j } | | j | 7} t j d | t } t j } | | j | 7} t j d | t } t j } | | j | 7} t j d | t
|
} t j } | | j | 7} t j d | t } t j } | | j | 7} t j d | t } t j }
|
| |
|
j | 7} t j d | t } t j } | | j | 7} t j d | t } t j } | | j | 7} t j d | t } t j } | | j | 7} t j d
|
| t } t j } | | j | 7} t j d | t } t j } | | j | 7} t j d | t } t j } | | j | 7} t j d | t } t j } | | j | 7} t j d | t } t j } | | j | 7} t j d | t } t j! } | | j | 7} t j d | t" } t j# } | | j | 7} t j d | t$ } t j% } | | j | 7} t j d | t& } t j' } | | j | 7} t j d | t( } t j) } | | j | 7} t j d | t* } t j+ } | | j | 7} t j d | t, } t j- } | | j | 7} t j d | t. } t j/ } | | j | 7} t j d | t0 } t j1 } | | j | 7} t j d | t2 } t j3 } | | j | 7} t j d | t4 } t j5 } | | j | 7} t j d | t6 } t j7 } | | j | 7} t j d | t8 } t j9 } | | j | 7} t j d | t: } t j; } | | j | 7} t j d | t< } t j= }! | |! j | 7} t j d | t> } t j? }" | |" j | 7} t j d | t@ } t jA }# | |# j | 7} t j d | tB } t jC }$ | |$ j | 7} t j d! | tD } t jE }% | |% j | 7} t j d" | tF } t jG }& | |& j | 7} t j d# | tH } t jI }' | |' j | 7} t j d$ | tJ } t jK }( | |( j | 7} t j d% | tL } t jM }) | |) j | 7} t j d& | tN } t jO }* | |* j | 7} t j d' | tP } t jQ }+ | |+ j | 7} t j d( | tR } t jS }, | |, j | 7} t j d) | tT } t jU }- | |- j | 7} t j d* | tV } t jW }. | |. j | 7} t j d+ | tX } t jY }/ | |/ j | 7} t j d, | tZ } t j[ }0 | |0 j | 7} t j d- | t\ } t j] }1 | |1 j | 7} t j d. | t^ } t j_ }2 | |2 j | 7} t j d/ | t` } t ja }3 | |3 j | 7} t j d0 | tb } t jc }4 | |4 j | 7} t j d1 | td } t je }5 | |5 j | 7} | tf } t jg }6 | |6 j | 7} t j d2 | th } t ji }7 | |7 j | 7} t j d3 | tj } t jk }8 | |8 j | 7} t j d4 | tl } t jm }9 | |9 j | 7} t j d5 | tn } t jo }: | |: j | 7} t j d6 | tp } t jq }; | |; j | 7} t j d7 | tr } t js }< | |< j | 7} t j d8 | tt } t ju }= | |= j | 7} t j d9 | tv } t jw }> | |> j | 7} t j d: | tx } t jy }? | |? j | 7} t j d; | tz } t j{ }@ | |@ j | 7} t j d< | t| } t j} }A | |A j | 7} t j d= | t~ } t j }B | |B j | 7} t j d> | t } t j }C | |C j | 7} t j d? | t } t j }D | |D j | 7} t j d@ | t } t j
}E | |E j | 7} t j dA | t } t j }F | |F j | 7} t j dB | t } t j }G | |G j | 7} t j dC | t } t j }H | |H j | 7} t j dD | t } t j }I | |I j | 7} t j dE | t } t j }J | |J j | 7} t j dF y t j | dG }K Wn7 t j dH t j dI t j }L t j |L d SXd }M t j |M t j }M |M |K 7}M | j | t j |M t j dJ t | d S(K NR s tagDBGameRec oks tagDBPyFuncTeam oks tagDBPyFuncTeamMem oks tagDBPlayerRecData oks tagDBPyMineAreaAward oks tagDBPyMineAreaRecord oks tagDBPyMineAreaItem oks tagDBPyCouple oks tagDBPyUnNotifyLoveGiftRec oks tagDBPyCharmValueRec oks tagDBPyPlayerIntimacy oks! tagDBCrossPersonalCompensation oks tagDBCrossBillboard oks tagDBAssistThanks oks tagDBAssist oks tagPlayerViewCachePy oks tagDBAuctionAttention oks tagDBAuctionRecord oks tagDBAuctionItem oks tagDBCrossPKUnNotifyOverInfo oks tagDBCrossPKBillboard oks tagDBPyXMZZ oks tagDBPySealDemonRecord oks tagDBPyBossAttention oks tagDBPyBourseItemLastPrice oks tagDBPyBourseRecord oks tagDBPyFamilyStoreItem oks tagDBPyPlayerFriend oks tagPlayerEnemy oks tagDBPyPlayerContacts oks tagDBPyPlayerBlack oks tagPersonalSocial oks tagPlayerTeamTable oks tagTeamMemberTable oks tagFamilyInfo oks tagPlayerFamily oks tagDBFamilyVS oks tagGameWorldEvent oks tagDBMissionPub oks tagDBIPManage oks tagDBGameServerEventTrig oks tagDBCountryInfo oks tagDBCountryFamilyWarResult oks tagDBCountryFamilyWarRace oks tagDBCountryFamilyWarRequest oks tagDBBillboard oks tagDBGoldOrderForm oks tagDBOverdueGoldOrderForm oks tagDBFamilyTech oks tagDBPlayerLabel oks tagDBPlayerRecall oks tagDBVsReward oks tagDBFamilyReward oks tagDBFamilyRewardRec oks tagDBFamilyAction oks tagGameFBPassRec oks tagUniversalGameRec oks tagGameGroup oks tagGameGroupMember oks tagGameGroupMutualInfo oks tagGameBourseItem oks tagHighLadderPlayer oks tagDBHighLadderItem oks tagHighLadderVSRec oks tagDBCompensationItem oks tagDBPersonalCompensation oks! tagDBEntireCompensationRequire oks tagCompensationPlayerRec oks tagPlayerViewCache oki R2 s2 Compress game server player data failed!error =
|
%ss) Game server player data send ok! len = %d(¡ t UCN_DBGameRecR t tagDBGameRect adoQueryAllR R t UCN_DBPyFuncTeamt tagDBPyFuncTeamt UCN_DBPyFuncTeamMemt tagDBPyFuncTeamMemt UCN_DBPlayerRecDatat tagDBPlayerRecDatat UCN_DBPyMineAreaAwardt tagDBPyMineAreaAwardt UCN_DBPyMineAreaRecordt tagDBPyMineAreaRecordt UCN_DBPyMineAreaItemt tagDBPyMineAreaItemt UCN_DBPyCouplet tagDBPyCouplet UCN_DBPyUnNotifyLoveGiftRect tagDBPyUnNotifyLoveGiftRect UCN_DBPyCharmValueRect tagDBPyCharmValueRect UCN_DBPyPlayerIntimacyt tagDBPyPlayerIntimacyt UCN_DBCrossPersonalCompensationt tagDBCrossPersonalCompensationt UCN_DBCrossBillboardt tagDBCrossBillboardt UCN_DBAssistThankst tagDBAssistThankst UCN_DBAssistt tagDBAssistt UCN_PlayerViewCachePyt tagPlayerViewCachePyt UCN_DBAuctionAttentiont tagDBAuctionAttentiont UCN_DBAuctionRecordt tagDBAuctionRecordt UCN_DBAuctionItemt tagDBAuctionItemt UCN_DBCrossPKUnNotifyOverInfot tagDBCrossPKUnNotifyOverInfot UCN_DBCrossPKBillboardt tagDBCrossPKBillboardt UCN_DBPyXMZZt tagDBPyXMZZt UCN_DBPySealDemonRecordt tagDBPySealDemonRecordt UCN_DBPyBossAttentiont tagDBPyBossAttentiont UCN_DBPyBourseItemLastPricet tagDBPyBourseItemLastPricet UCN_DBPyBourseRecordt tagDBPyBourseRecordt UCN_DBPyFamilyStoreItemt tagDBPyFamilyStoreItemt UCN_DBPyPlayerFriendt tagDBPyPlayerFriendt UCN_PlayerEnemyt tagPlayerEnemyt UCN_DBPyPlayerContactst tagDBPyPlayerContactst UCN_DBPyPlayerBlackt tagDBPyPlayerBlackt UCN_PersonalSocialt tagPersonalSocialt UCN_PlayerTeamTablet tagPlayerTeamTablet UCN_TeamMemberTablet tagTeamMemberTableR+ t tagFamilyInfot UCN_PlayerFamilyt tagPlayerFamilyt UCN_DBFamilyVSt tagDBFamilyVSt UCN_GameWorldEventt tagGameWorldEventt UCN_DBMissionPubt tagDBMissionPubt UCN_DBIPManaget tagDBIPManaget UCN_DBGameServerEventTrigt tagDBGameServerEventTrigt UCN_DBCountryInfot tagDBCountryInfot UCN_DBCountryFamilyWarResultt tagDBCountryFamilyWarResultt UCN_DBCountryFamilyWarRacet tagDBCountryFamilyWarRacet UCN_DBCountryFamilyWarRequestt tagDBCountryFamilyWarRequestt UCN_DBBillboardt tagDBBillboardt UCN_DBGoldOrderFormt tagDBGoldOrderFormt UCN_DBOverdueGoldOrderFormt tagDBOverdueGoldOrderFormt UCN_DBUnclaimedGoldFormt tagDBUnclaimedGoldFormt UCN_DBFamilyTecht tagDBFamilyTecht UCN_DBPlayerLabelt tagDBPlayerLabelt UCN_DBPlayerRecallt tagDBPlayerRecallt UCN_DBVsRewardt tagDBVsRewardt UCN_DBFamilyRewardt tagDBFamilyRewardt UCN_DBFamilyRewardRect tagDBFamilyRewardRect UCN_DBFamilyActiont tagDBFamilyActiont UCN_GameFBPassRect tagGameFBPassRect UCN_UniversalGameRect tagUniversalGameRect UCN_GameGroupt tagGameGroupt UCN_GameGroupMembert tagGameGroupMembert UCN_GameGroupMutualInfot tagGameGroupMutualInfot UCN_GameBourseItemt tagGameBourseItemt UCN_HighLadderPlayert tagHighLadderPlayert UCN_DBHighLadderItemt tagDBHighLadderItemt UCN_HighLadderVSRect tagHighLadderVSRect UCN_DBCompensationItemt tagDBCompensationItemt UCN_DBPersonalCompensationt tagDBPersonalCompensationt UCN_DBEntireCompensationRequiret tagDBEntireCompensationRequiret UCN_CompensationPlayerRect tagCompensationPlayerRect UCN_PlayerViewCachet tagPlayerViewCacheR4 t compressR Rë t ERROR_NO_75RÀ RÁ R2 R RÇ t VersionNoDefinet$ GAMESERVER_GAMEWORLD_DATA_VERSION_NOt sendGameServerStringRÖ t dgGameServerDataR3 R (N RX RW R RC R[ t DBGameRect DBPyFuncTeamt DBPyFuncTeamMemt DBPlayerRecDatat DBPyMineAreaAwardt DBPyMineAreaRecordt DBPyMineAreaItemt
|
DBPyCouplet DBPyUnNotifyLoveGiftRect DBPyCharmValueRect DBPyPlayerIntimacyt DBCrossPersonalCompensationt DBCrossBillboardt DBAssistThankst DBAssistt PlayerViewCachePyt AuctionAttentionInfot AuctionRecordInfot AuctionItemInfot crossPKOverInfot crossPKt XMZZt sealDemonRecordt bossAttentiont bourseItemLastPricet bourseRecordt familyStoreItemt playerFriendt playerEnemyt playerContactst playerBlacklistt playerSocialt
|
playerTeamt
|
teamMembert
|
familyInfot playerFamilyt familyVSt gameWorldEventt
|
missionPubt ipManaget gameServerEventTrigt countryInfot countryFamilyWarResultt countryFamilyWarRacet countryFamilyWarReqt billboardt goldOrderFormt overdueGoldOrderFormt unclaimeGoldFormt
|
familyTecht
|
playrLabelt playerRecallt
|
dbVSRewardt dbFamilyRewardt dbFamilyRewardRect dbFamilyActiont dbGameFBPassRect dbUniversalGameRect dbGameGroupt dbGameGroupMembert dbGameGroupMutualInfot dbGameBourseItemt dbHighLadderPlayert dbDBHighLadderItemt dbHighLadderVSRect dbDBCompensationItemt dbDBPersonalCompensationt dbDBEntireCompensationRequiret dbCompensationPlayerRect dbPlayerViewCachet compressDataR t SendData( ( s .\\UserCtrlDB.pyRå ` sF
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
"
|
c C sh d } t j | j | \ } } t j | j | \ } } | j | | | j | | | d S( Ni ( R RÔ RÕ t saveGameServerGameData( RX RW R R R Rd ( ( s .\\UserCtrlDB.pyRä ¹ s # c C s | t j k rì
|
t j | | \ } } t j | | \ } } t j | | \ } } t j | | \ }
|
} t j | | |
|
\ } } |
|
rW
|
| t j k st j d t j
|
d | t j f } t j | t j t j j t j t j d d | t Sym t j | } | j d d \ } } t | } t j d | | | f t j | | | | } Wn6 t j d t j d t j } t j | qd
|
Xt j d
|
t! | d } yE| j" | | t# t$ j% | } | j" | | t& t$ j' | } | j" | | t( t$ j) | } | j" | | t* t$ j+ | } | j" | | t, t$ j- | } | j" | | t. t$ j/ | } | j" | | t0 t$ j1 | } | j" | | t2 t$ j3 | } | j" | | t4 t$ j5 | } | j" | | t6 t$ j7 | } | j" | | t8 t$ j9 | } | j" | | t: t$ j; | } | j" | | t< t$ j= | } | j" | | t> t$ j? | } | j" | | t@ t$ jA | } | j" | | tB t$ jC | } | j" | | tD t$ jE | } | j" | | tF t$ jG | } | j" | | tH t$ jI | } | j" | | tJ t$ jK | } | j" | | tL t$ jM | } | j" | | tN t$ jO | } | j" | | tP t$ jQ | } | j" | | tR t$ jS | } | j" | | tT t$ jU | } | j" | | tV t$ jW | } | j" | | tX t$ jY | } | j" | | tZ t$ j[ | } | j" | | t\ t$ j] | } | j" | | t^ t$ j_ | } | j" | | t` t$ ja | } | j" | | tb t$ jc | } | j" | | td t$ je | } | j" | | tf t$ jg | } | j" | | th t$ ji | } | j" | | tj t$ jk | } | j" | | tl t$ jm | } | j" | | tn t$ jo | } | j" | | tp t$ jq | } | j" | | tr t$ js | } | j" | | tt t$ ju | } | j" | | tv t$ jw | } | j" | | tx t$ jy | } | j" | | tz t$ j{ | } | j" | | t| t$ j} | } | j" | | t~ t$ j | } | j" | | t t$ j | } | j" | | t t$ j | } | j" | | t t$ j
| } | j" | | t t$ j | } | j" | | t t$ j | } | j" | | t t$ j | } | j" | | t t$ j | } | j" | | t t$ j | } | j" | | t t$ j | } | j" | | t t$ j | } | j" | | t t$ j | } | j" | | t t$ j | } | j" | | t t$ j | } | j" | | t t$ j | } | j" | | t t$ j | } | j" | | t t$ j | } | j" | | t t$ j¡ | } | j" | | t¢ t$ j£ | } | j" | | t¤ t$ j¥ | } | j" | | t¦ t$ j§ | } | j" | | t¨ t$ j© | } | j" | | tª t$ j« | } | j" | | t¬ t$ j | } | j" | | t® t$ j¯ | } t j d Wn9 t j° k
|
rF
|
t j d t j± d } t j | n Xt j d n t j d t² j³ } t j´ | _µ t j¶ | _· d | _¸ | j¹ | jº | j» j¼ | j» j½ | j» j¾ | j» j¿ | j» jÀ | jÁ n
|
| d k r| | } d } | r[ym t j | } | j d d \ } } t | } t j d | | | f t j | | | | } Wn6 t j d t j d t j } t j | qhXt! | } t j d | d } yE| j" | | t# t$ j% | } | j" | | t& t$ j' | } | j" | | t( t$ j) | } | j" | | t* t$ j+ | } | j" | | t, t$ j- | } | j" | | t. t$ j/ | } | j" | | t0 t$ j1 | } | j" | | t2 t$ j3 | } | j" | | t4 t$ j5 | } | j" | | t6 t$ j7 | } | j" | | t8 t$ j9 | } | j" | | t: t$ j; | } | j" | | t< t$ j= | } | j" | | t> t$ j? | } | j" | | t@ t$ jA | } | j" | | tB t$ jC | } | j" | | tD t$ jE | } | j" | | tF t$ jG | } | j" | | tH t$ jI | } | j" | | tJ t$ jK | } | j" | | tL t$ jM | } | j" | | tN t$ jO | } | j" | | tP t$ jQ | } | j" | | tR t$ jS | } | j" | | tT t$ jU | } | j" | | tV t$ jW | } | j" | | tX t$ jY | } | j" | | tZ t$ j[ | } | j" | | t\ t$ j] | } | j" | | t^ t$ j_ | } | j" | | t` t$ ja | } | j" | | tb t$ jc | } | j" | | td t$ je | } | j" | | tf t$ jg | } | j" | | th t$ ji | } | j" | | tj t$ jk | } | j" | | tl t$ jm | } | j" | | tn t$ jo | } | j" | | tp t$ jq | } | j" | | tr t$ js | } | j" | | tt t$ ju | } | j" | | tv t$ jw | } | j" | | tx t$ jy | } | j" | | tz t$ j{ | } | j" | | t| t$ j} | } | j" | | t~ t$ j | } | j" | | t t$ j | } | j" | | t t$ j | } | j" | | t t$ j
| } | j" | | t t$ j | } | j" | | t t$ j | } | j" | | t t$ j | } | j" | | t t$ j | } | j" | | t t$ j | } | j" | | t t$ j | } | j" | | t t$ j | } | j" | | t t$ j | } | j" | | t t$ j | } | j" | | t t$ j | } | j" | | t t$ j | } | j" | | t t$ j | } | j" | | t t$ j | } | j" | | t t$ j¡ | } | j" | | t¢ t$ j£ | } | j" | | t¤ t$ j¥ | } | j" | | t¦ t$ j§ | } | j" | | t¨ t$ j© | } | j" | | tª t$ j« | } | j" | | t¬ t$ j | } | j" | | t® t$ j¯ | } t j d Wqht j° k
|
rWt j d t jà d } t j | qhXn t j d | d k rt² j³ } t j´ | _µ t jÄ | _· d | _¸ | j¹ | jº | j» j¼ | j» j½ | j» j¾ | j» j¿ | j» jÀ | jÁ t j d | qno | t jÅ k r?| jÆ | | d t$ jÇ | n@ | t jÈ k rn| jÆ | | d t$ jÉ | n t jÊ d | d S( NR2 sW Save game server crash data error:data version conflict!versionNO = %s, db version = %st tagGDGameServerGameDatas 0.mdats |i s' disCompresspydata len %s, GameData = %sR s4 Decompress game server world data failed!error =
|
%ss= Decompress game server world data success, len = %d!saving...i s Save game server world data ok!s Short data buf, ignore...s Save game server player data ok!s Empty crash data,ignore...s5 Decompress game server world data failed! error =
|
%ss= Decompress game server world data success, len = %s!saving...sI saveGameServerGameData saveType = 0 decompressGameDataLen = %s responsed!t tagDBMailListt tagDBMailItemLists saveType = %s not processed!(Ë RÖ t dgGameServerCrashDataR t ReadWORDR R R R R Rë t ERROR_NO_76R R2 R R# R( R) R* R R+ t DUMP_PATHRN R4 R5 RÑ Rj R RÂ t a2b_hext ERROR_NO_77RÀ RÁ R3 R t savegameServerWorldDataRw R Rx Rz R{ R| R} R~ R R R R R R R
R R R R R R R R R R R R R R R R R R R R R R R R R R R R¡ R¢ R£ R¤ R¥ R¦ R§ R¨ R© Rª R« R¬ R R® R¯ R° R± R² R³ R´ Rµ R¶ R· R¸ R¹ Rº R» R+ R¼ R½ R¾ R¿ RÀ RÁ RÂ RÃ RÄ RÅ RÆ RÇ RÈ RÉ RÊ RË RÌ RÍ RÎ RÏ RÐ RÑ RÒ RÓ RÔ RÕ RÖ R× RØ RÙ RÚ RÛ RÜ RÝ RÞ Rß Rà Rá Râ Rã Rä Rå Ræ Rç Rè Ré Rê Rë Rì Rí Rî Rï Rð Rñ Rò Ró Rô Rõ Rö R÷ Rø Rù Rú Rû Rü Rý Rþ Rÿ R R R t ShortBuft ERROR_NO_78R R R R- t gstSaveGameServerCrashDataR! R9 R> RQ Rî Rï t poolIndexRd t
|
srcSvrTypet
|
dstSvrTypeR& t ERROR_NO_80t ERROR_NO_81R¨ t dgPlayerMailListt savePlayerMailDataRS t dgPlayerMailItemListRT R ( RX RW R RC R t saveTypeR t markt versionNORÙ t gameDataLent gameDataR t decompressGameDatat pyDataLent pyDataHext gameDataReadPosR' t decompressGameDataLen( ( s .\\UserCtrlDB.pyRQ â s® % . "
|
" c C sÛ | t | k r$ t j | n t j | | \ } } t j d | | | f | | } | } | | _ | j | g }
|
xw t d | D]f } | j
|
| j | | t | } | d k rÞ t j | n | | 7} |
|
j | j q W|
|
s | Sd } xÅ t rÖy | j |
|
t t PWqt j j k
|
rÒ} t j | k rg| d 7} qn t t j d | j j t j d d | f t j d t j d | | | f } t j | | SXqW| S( Ns Saving %s cnt = %s playerID = %si iÿÿÿÿi s %s.%s:rec = %si R s4 Insert failed!PlayerID = %s, error = %s, trycnt = %d( R RÖ R\ R R R R3 RK t adoDeleteByIndexRQ Rb R» RR Rr RN RT RU R Rs t PyMongoErrorR# Ru R Rv Rw Rx Ry R Rë t ERROR_NO_152( RX Rn RC R Rz R{ RW t recCntR[ R6 RG RQ Rm R~ R R ( ( s .\\UserCtrlDB.pyt saveGameServerPlayerData sB
|
|
|
|
.% c C sì | t | k r; t j d | | f t j | n t j | | \ } } t j d | | f | | } | j | g } | } x¯ t d | D] }
|
| j | j
|
| | t | } | j d | k r!t j d | j j t j d d |
|
f t j | n | | 7} | j | j q W| sL| Sd } xt rçyç d } t t | } | | k r| j | t t n¨ t t j | t | } t | | } t j d | | f x_ t | D]Q }
|
|
|
| } |
|
| d
|
k r| | } n | | | | !} | j | t t qëWPWqUt j j k
|
rã} t j | k ry| d
|
7} qUn t! t j d | j j" t j d d | f t j d | j j" t j d d | | f | SXqUW| S( Ns !!!Saving Error %s cnt = %ss Saving %s cnt = %si iÿÿÿÿs! %s.%s readData failed, index = %si i i s" insertTimes=%s,perTimeCount=%si s %s.%s save %s failed!s %s.%s, error = %s, trycnt = %si i (# R R R3 RÖ R\ R R t drop_collectionRQ Rb R» t
|
dumpStringR Rv t _UserCtrlDB__name_Rx Ry RR Rr RN RV RT RU Rj t matht ceilt floatR" R Rs Rt R# Ru R Rw ( RX RC R Rz R{ RW Rt R[ RG R6 RQ Rm R~ t max_sizet
|
docsStrLent insertTimest perTimeCountR2 t insDocsR ( ( s .\\UserCtrlDB.pyR[ / s\
|
|
|
.
|
|
|
.1 c C s¬ | t | k r$ t j | n t j | | \ } } t j d | | | } | } xEt d | D]4} | j | | t | }
|
d |
|
k r¯ t j | n | |
|
7} d } xâ t r£yG | j
|
i | j d 6| j d 6 | j
|
i | j d 6| j d 6 PWq t j j k
|
r} t j | k r | d 7} q q t t j d | j j t j d d | j f t j d | j | | f | SXq Wqp W| S(
|
Ns' Saving PlayerDeleteFriend data Cnt = %si iÿÿÿÿRK t FriendIDi s %s.%s:PlayerID = %si s5 delete failure!PlayerID = %s, error = %s, trycnt = %d( R RÖ R\ R R R R3 RQ R+ RN RJ RK R R Rs Rt R# Ru R Rv Rw Rx Ry R ( RX RC R t
|
packStructRz RW Rt R[ R6 RQ Rm R~ R ( ( s .\\UserCtrlDB.pyt savePlayerDeleteFriendDataj s4
|
|
!! 1 c C s | rt | d k rD t j d t j d | } t j | d Sd } t j | | \ } } t j d | | f | | } | } t | }
|
x{ t | D]Z } | j | j
|
| | |
|
} d | k rè t j | n | | 7} | j | q¥ Wn t j d | d S( Ni R s- invalid player mail data, collectionName = %si s Saving %s cnt = %siÿÿÿÿs0 empty player mail list data, collectionName = %s( R R Rë t ERROR_NO_82R R R R3 RQ Rb R» RÖ R\ t adoInsert( RX RC Rz R{ RW R R Rt R[ R6 t datalenRQ Rm ( ( s .\\UserCtrlDB.pyRe s&
|
|
|
c
|
C s | j } d } t | } y¯ t j } | j | | | } t j } | j | j d | j t
|
j t
|
j | _ | t } | j | s² | j t j | d t S| j t j | d t SWn? t j d t j d | j t j f } t j | n Xt S( Ni R R s* Insert Acc failed, accid = %s, error =
|
%s( RÕ R R t tagBDStringTypeSendR+ R Rû R» Ri Rt R
|
Ri Rf t RegisterTimeRú RÅ R§ RÖ t dgInsertAccRU R RN R Rë t ERROR_NO_83Rü RÀ RÁ R (
|
RX RW R RC R R t oTypeSendt AccR[ R ( ( s .\\UserCtrlDB.pyRò ¨ s&
|
+c C s# | j } t | } d } y¿ t j } | j | | | } | t } t j } | j | _ t } | j
|
| s | t k r t St j r t Sn d | _ | j | i t | j d 6| j d 6 sØ t St SWn? t j d t j d | j t j f }
|
t j |
|
n Xt S( Ni i Ry RK R s; OnPlayerIDMarkDeleted failed! Playerid = %d, exception = %s( RÕ R R t tagMarkPlayerDeletedR+ Rw R Rv RK R Rý RU R# R| R R" R Ry RN R Rë t ERROR_NO_84RÀ RÁ R ( RX RW R RC R R t oMarkPlayerDeletedRZ t oPlayert SidErrorCntR ( ( s .\\UserCtrlDB.pyRó ¿ s.
|
, +c C s yÓ t j } | j | j | t } t j } | j | _ | j | sd t
|
j d t St
|
j d t j | j | j f t j } t j | _ | j | _ | j | | j t
|
j d t SWn6 t j d t j d t j } t
|
j | n Xt S( Ns" gstGetCoin, not found match records% Type = %d, AccId = %s, GoldCoins = %ds process gstGetCoin okR s' OnGetCoin catch excepption, error =
|
%s( R t tagDGetValueByAccR+ RÕ t UCN_AccCoinsR t tagAccCoinsR Ry Rë R R3 RU RÖ R² t GoldCoinsR t tagDServerValueTypet dgCoinR t ValueR% R& RN R Rë t ERROR_NO_85RÀ RÁ ( RX RW R t oDGetValueByAccRZ t oAccCoinst oSvrValueR ( ( s .\\UserCtrlDB.pyRô æ s(
|
# "c C s. yðt j } | j | j t j d | j | j | j f | t } t
|
j } | j | _ t j } t j | _ | j | sµ t j d | j | | j t St j d t j | j | j | j f | j | j k rt j d | j | | j t S| j | j 8_ | j | j 7_ | j | s| j | | j t j d t j d t j | j | j f } t j | t S| j | _ | j | | j t j | _ | j | _ | j | | j Wn7 t j d t j d t j! } t j | t SXt" S( Ns3 gstCoinChange, AccId = %s, PlayerID = %d, coin = %ds" gstGetCoin, not found match recordsE Type = %d, AccId = %s, PlayerID = %d, Before exchange GoldCoins = %ds not enough coin to exchangeR sE Type = %d, AccId = %s, PlayerID = %d, update exchange GoldCoins fails OnCoinChange throw exception
|
%s(# R t tagMDCoinChangeReqR+ RÕ R R3 R RK t CoinR R R Ry R R RÖ t dgCoinChangeResultR Rë R% R& RU R³ R t UseGoldCoinst adoUpdateR Rë t ERROR_NO_87R R t ERROR_NO_88RÀ RÁ RN ( RX RW R t oCoinChangeReqRZ R t retPackR ( ( s .\\UserCtrlDB.pyRõ sF #
|
) . " c C s yÕ t j } | j | j t j } t j } | j | _ d | _
|
| t } t j | _ | j | _ t | j | _ | j | i t | j d 6| j
|
d 6 | _ | j | _ | j | | j Wn7 t j d t j d t j } t j | t SXt S( Ni R¾ R R s% OnCheckPlayerExist catch exception
|
%s( R t tagBDCheckNameExistR+ RÕ R t tagDBPlayerNameIsExistR Rv t NameR¾ R Rw RÖ t dgCheckPlayerExistR- R t NameLenRx R R9 RK R% R& R Rë t ERROR_NO_89RÀ RÁ R RU RN ( RX RW R t curPackR¥ R RZ R ( ( s .\\UserCtrlDB.pyRö D s&
|
/ " c C s t j d d S( Ns process gstOnDay in the future!( R R ( RX RW R ( ( s .\\UserCtrlDB.pyR÷ \ s c C s | j } d } t j | | \ } } d | j | | d t j | | k r t j d t j d | } t j | t
|
St S( Ni iÿÿÿÿR R s) Save Player GM Oper failed, playerid = %d( RÕ R R RL R R R Rë t ERROR_NO_90R RU RN ( RX RW R RC R t PlayerIdR ( ( s .\\UserCtrlDB.pyRø h s ( c C s t j } | j | j | t } | j i t | j d 6 j } t j
|
} t j | _ | | _ | j | | j t S( NRy ( R R R+ RÕ t UCN_ExpiationR. R R R/ R R RÖ t dgGetExpiationCountR R R% R& RN ( RX RW R R¬ RZ t recCountR¥ ( ( s .\\UserCtrlDB.pyRù r s
|
% c C s t j } | j | j | t } | j i t | j d 6 j } t j
|
} t j | _ | | _ | j | | j t S( NRy ( R R R+ RÕ t UCN_PetExpiationR. R R R/ R R RÖ t dgGetPetExpiationCountR R R% R& RN ( RX RW R R¬ RZ R± R¥ ( ( s .\\UserCtrlDB.pyRú s
|
% c C sª t j } | j | j | j } t j } t j | _ d | _ | t
|
} | j i t | j d 6 } | t
|
} xþ| D]ö} | j | k r Pn t j }
|
| d |
|
_ t | d |
|
_ | d |
|
_ | d |
|
_ | d |
|
_ | d |
|
_ | d |
|
_ | d |
|
_ | d
|
|
|
_ | d |
|
_ | d |
|
_ | d |
|
_ | d |
|
_ | d |
|
_ | d |
|
_ | d |
|
_ | d |
|
_ | d |
|
_ | d |
|
_! | d |
|
_" | d |
|
_# t | d |
|
_$ | d |
|
_% | d |
|
_& | d |
|
_' | d |
|
_( | d |
|
_) | d |
|
_* | d |
|
_+ | d |
|
_, | d |
|
_- | d! |
|
_. t | d" |
|
_/ | d# |
|
_0 | d$ |
|
_1 | d% |
|
_2 | d& |
|
_3 | d' |
|
_4 | d( |
|
_5 | d) |
|
_6 t | d* |
|
_7 | d+ |
|
_8 | d, |
|
_9 | d- |
|
_: | d. |
|
_; | d/ |
|
_< | d0 |
|
_= | d1 |
|
_> t | d2 |
|
_? | j@ jA |
|
| jB i |
|
j d 6 | j d3 7_ q W| j d k rtC S| jD | | jE tF S(4 Ni Ry t ExpiationIndext ExpiationTimet Goldt GoldPapert Silvert SilverPapert
|
ItemTypeIDR$ t IsLockedt ItemPlaceTypet ItemPlaceIndext IsBindt
|
ItemStarLVt IdentifyPart CurDurgt MaxDurgt CanPlaceStoneCountt ItemPropertyt SoulPropertyt Makert MakerNamet Stone1t Stone2t Stone3t Stone4t Stone5t Stone6t Stone7t Stone8t Stone9t
|
RemainHourt
|
CreateTimet ElementEffectt IsSuitet FitLVt EquipAddSkillCntt
|
ExpireTimet BaseAtkPlust BaseDefPlust AddSkillDatat BaseHPt BaseMagicDeft EquipMinAtkValuet Proficiencyt RelMaxAddSkillCntt FamilyActiveValueRí Rî i (G R t tagMDGetExpiationExR+ RÕ R$ R t tagDMGetExpiationExResultRÖ t dgGetExpiationR R¯ R. R R t tagExpiationR´ R Ry Rµ R¶ R· R¸ R¹ Rº R» R¼ R½ R¾ R¿ RÀ RÁ RÂ RÃ RÄ RÅ RÆ RÇ RÈ RÉ RÊ RË RÌ RÍ RÎ RÏ RÐ RÑ RÒ RÓ RÔ RÕ RÖ R× RØ RÙ RÚ RÛ RÜ RÝ RÞ Rß Rà Rí Rî t DatasRR RJ RU R% R& RN ( RX RW R R¬ t needCountR' R[ t
|
expiationst colDelt curDatat expiation( ( s .\\UserCtrlDB.pyRû s
|
|
7c C sª t j } | j | j | t } t j } | j | _ | j | } t j
|
} t j | _ | j | _ | j | _ | j | | j | s¦ t St S( N( R R R+ RÕ R² R t tagPetExpiationR Ry Rë R RÖ t dgGetPetExpiationR Ri RÌ Rt R% R& RU RN ( RX RW R R¬ RZ t dbDataR R' ( ( s .\\UserCtrlDB.pyRü ] s
|
c C s¤ t j } d | j | j k rT t j d t j d d } t j | t S| t } | j
|
| j | s t j d t j d } t j | t St S( s ·þÎñÆ÷Êý¾Ý¿â°æ±¾Ë¢ÐÂiÿÿÿÿR s tagServerDataVersionNO:%Ss lack of pack datas* insert tagServerDataVersionNO data failed!( R t tagServerDataVersionNOR» RÕ R Rë t ERROR_NO_91R RU t UCN_ServerDataVersionNORF R
t ERROR_NO_92RN ( RX RW R t dbRecvR RZ ( ( s .\\UserCtrlDB.pyR» s
|
|
c C s t j } | j | j t j } d | j | j k rl t j d t j
|
d } t j | t St | _ t | d d t j t j | _ | t } | j | i | j d 6t | j d 6 st j d t j d | j | j | j f } t j | t St S( NiÿÿÿÿR s$ tagDBMapServerInfo:lack of pack datat tagDBMapServerInfot LogIndext LogIDRj s: OnMapServerInfo failed:LogID = %s, LogIndex = %s, Msg = %s( R R R+ RÕ R Ró R» Ri R Rë t ERROR_NO_93R RU RP t TimeR R# t LOGINDEX_FEEDt LOGINDEX_STEPRô t UCN_DBMapServerInfot adoCheckUpdateExRõ R Rj t ERROR_NO_94RN ( RX RW R R4 Rí R RZ ( ( s .\\UserCtrlDB.pyRþ s !
|
,. c C s| y t j d WnW t j d t j d t | j t | j t j } t j | t
|
SXt j d t S( Ns% begin process gstUpdateTotalSavePointR sM OnUpdateTotalSavePoint throw a exception, packdata = %s, packdata len = %d
|
%ss# end process gstUpdateTotalSavePoint( R R3 R Rë t ERROR_NO_96RÃ RÕ R RÀ RÁ RU RN ( RX RW R R ( ( s .\\UserCtrlDB.pyRÿ ² s B c C sp y2t j } | j | j | t } | j i | j d 6i t j d 6d 6 j } | t j
|
k rw t j } nJ | j i | j d 6t j d 6 j } | d k r¸ t j } n t j } t j } | | _ | j j t j k rt j | j _ | j | j _ n | j | t j | j Wn7 t j d t j d t j } t! j | t" SXt# S( Nt ReceverIDt MailTypes $nei R s) OnGetPlayerMailState throw a exception
|
%s($ R t tagDBGetMailListReqR+ RÕ t UCN_DBMailListR. RK RÖ t wmtSaveR/ t MAX_PLAYER_MAIL_COUNTt pmiFullt wmtUnReadedt pmiNewLettert pmiNullR t tagPlayerMailInfot InfoTypeRî R` R R@ t stRoutet RouteServerIndexR_ R t dgPlayerMailStateR& R Rë t ERROR_NO_97RÀ RÁ R RU RN ( RX RW R R4 RZ t docCountt stateR' R ( ( s .\\UserCtrlDB.pyR Ô s,
|
0 ) " c
|
C sB yt j } | j | j | t } t j } | j | _ | j | } | t } t j
|
} | j | _ | j | s t j d | j t St j } t j | _ | j | _ t | j | _ | | _ t | | _ | j | | j Wn7 t j d t j d t j } t j | t SXt S( s È¡µÃÍæ¼ÒÓʼþÏêÇés mail list not exist! mailid = %sR s$ OnGetMailDetail throw a exception
|
%s(! R t tagDBGetMailDetailReqR+ RÕ t UCN_DBMailItemListR RT t MailIDR R RS Rë R R RU R t tagDBMailDetailViewRÖ t dgMailDetailR t MailDetailDataR t MailDetailDataLent MailItemDatat MailItemDataLenR% R& R Rë t ERROR_NO_98RÀ RÁ RN (
|
RX RW R R4 RZ t dbMailItemListR t
|
dbMailListR' R ( ( s .\\UserCtrlDB.pyR õ s2
|
|
" c
|
C so y1t j } | j | j t j } t j | _ | t } | j
|
i | j d 6i t j d 6d 6 } x | D] } t j } t | d | _ | d | _ t | d | _ t | d | _ | d | _ | d | _ | d | _ | j j | qu Wt | j | _ | j | | j Wn7 t j d
|
t j d t j } t! j | t" SXt# S( NRþ s $ltt ExistTimeR Rÿ t
|
SenderNamet Titlet
|
LetterTypet TitleUseSysMessageR s$ OnGetPlayerMail throw a exception
|
%s($ R R R+ RÕ R t tagDBGetPlayerMailRÖ t
|
dgMailListR R R. RK t MailExistTimet tagDBMailInfoR R Rÿ R R R R R t MailRR R t MailCountR% R& R Rë t ERROR_NO_99RÀ RÁ R RU RN (
|
RX RW R R4 R' RZ RG R] t mainInfoR ( ( s .\\UserCtrlDB.pyR s0
|
* " c C s t } t j } yt j } | j | j | j | _ | j | _ xÕt r#t j } d | j
|
| j k r¢ t j d t j d } t j | Pn | t } | j i t | j d 6d d 6 } | j d k rü t j d | j Pn | t } | j i | j d 6 j d k rTt j d t j d } t j | Pn t j }
|
| j |
|
_ | d d
|
|
|
_ | j |
|
_ | j |
|
_ | j |
|
_ | j |
|
_ | j |
|
_ | j |
|
_ | j |
|
_ | j! |
|
_! t" |
|
j! |
|
_# | j$ |
|
_$ | j% |
|
_% |
|
j& | r t } n PqO WWn6 t j d t j' d t( j) } t j | n Xt* j+ | _, | j- | | j. | S( NiÿÿÿÿR s+ tagDBMailList_SaveSysMail lack of pack dataRy i R s" not exist player role , accid = %sR s+ OnAddPlayerMailByAccID: exist a same mailidRK s+ OnAddPlayerMailByAccID throw a exception
|
\s(/ RU R R R+ RÕ Ri Rt RN R t tagDBMailList_SaveSysMailR» R Rë t ERROR_NO_100R Rw R. R Ry R/ R3 R R t ERROR_NO_101RS t SenderIDRþ Rÿ R R Rà R R t ContentR t
|
ContentLenR t ContentUseSysMessageR
t ERROR_NO_102RÀ RÁ RÖ t dgAddPlayerMailByAccIDR R% R& ( RX RW R R R' R4 t curMailR RZ RG R] ( ( s .\\UserCtrlDB.pyR 4 s\
|
&
|
% " c C s5 y÷ t j } | j | j | t } t j } | j | _ | j | s t j
|
d t j d t | j } t j | t S| t } t j } | j | _ | j | sö t j
|
d t j d t | j } t j | t SWn7 t j
|
d t j d t j } t j | t SXt S( NR s DeleteMail fail:data = %ss! OnDeleteMail throw a exception
|
%s( R t tagDBDeleteMailR+ RÕ R R RS R Rq R Rë t ERROR_NO_103RÃ R RU R RT t ERROR_NO_104t ERROR_NO_105RÀ RÁ RN ( RX RW R R4 RZ R] R ( ( s .\\UserCtrlDB.pyR l s,
|
(
|
( " c C sÄ yt j } | j | j | t } t j } | j | _ | j | sÊ t j
|
t j d d | j j | j f | j t j d t j d | j j | j f } t j | t S| j râ | j | _ n | j rú | j | _ n | j rd | _ n | j rK| j | _ d | _ d | _ d | _ d | _ n | j | s×t j
|
t j d d | j j | j f t | j t j d t j d | j | j j f } t j | t S| j! r
| t" } | j | _ | j# | s
t j
|
t j d d | j j | j f t | j t j d t j$ d | j | j j f } t j | t Sn Wn7 t j d t j% d t& j' } t j | t SXt( S( Ns UserLogs\UpdateMailFailDumps
|
%d_%s.mdatR sD update mail fail, load tagDBMailList fail, session = %d, mailid = %si s, update mail fail, maiid = %s, sessionid = %ds! OnUpdateMail throw a exception
|
%s() R t tagDBUpdateMailR+ RÕ R R RS R Rë R R# R R+ Rî Rï R Rë t ERROR_NO_106R RU t UpdateMailTypeRÿ t UpdateLetterTypeR t GetAllMoneyRà t
|
ReturnMailR, Rþ R R¡ RÃ t ERROR_NO_107t
|
GetAllItemR Rq t ERROR_NO_108t ERROR_NO_109RÀ RÁ RN ( RX RW R R4 RZ R] R ( ( s .\\UserCtrlDB.pyR sR
|
8. >.
|
>. " c C sm y/t j } | j | j t j } t j | _ | j | _ t
|
| j | _ | t } | j i t | j d 6d d 6 } | j s© d | _ d | _ no | d d | _ | t } | j i | j d 6i t j d 6d 6 j } | t j k rd | _ n d | _ | j | | j Wn7 t j d t j d
|
t j } t j | t SXt S( NRy i R RK Rþ s $neRÿ i R s' OnQueryCanSendMail throw a exception
|
%s( R R¦ R+ RÕ R R§ RÖ t dgQueryCanSendMailR- R¨ R Rª Rw R. R R/ RK R9 R R R R% R& R Rë t ERROR_NO_110RÀ RÁ R RU RN ( RX RW R R4 R' RZ RG R/ R ( ( s .\\UserCtrlDB.pyR ¾ s0
|
&
|
0 " c C s t j } t j | _ t } xØt røyt j } | j | j | t
|
} d } xÚ t r5yW | j i i t d 6d 6t | j d 6d d 6i i d d 6d 6t t t t PWq\ t j j k
|
r1t j | k rî | d 7} q\ n t } t t j d t j d
|
| j | f } t j | Pq\ Xq\ W| s@Pn | j i t | j d 6d d 6 j d } | j r
| d }
|
|
|
d } |
|
d | _ |
|
d | _ |
|
d | _ d } x¹ t rwy6 | j i | d 6i i d d 6d 6t t t t PWq¿t j j k
|
rst j | k r0| d 7} q¿n t } t t j d t j d
|
| j | f } t j | Pq¿Xq¿W| s
Pq
n | j i t | j d 6d d 6 j | _! Wn< t j d t j" d t# j$ } t j | t } n XPq! W| j% | | j& | S( Ni s $ltt ExpiredTimeRy t IsAccepti s $seti R s6 OnAccIDSendPrize!Update failed!AccID = %s, trycnt = %dt
|
CheckValuet PrizeIDt PrizeNumR¾ s% OnAccIDSendPrize throw a exception
|
%s(' R t tagDPlayerGetItemRÖ t dgAccIDSendPrizeR RN R R R+ RÕ t UCN_AccIDSendPrizeRH RP R R RU R Rs Rt R# Ru R R Rë t ERROR_NO_111R R. RÞ R/ t ItemIDR$ R¾ t ERROR_NO_112t RemainItemCountt ERROR_NO_113RÀ RÁ R% R& ( RX RW R R' R R4 RZ R~ R RG R] RE ( ( s .\\UserCtrlDB.pyR ß sn
|
R
|
% /
|
|
1
|
% 3"
|
c C sf y(t j } | j | j d d l } | j } | t } | j i t | j d 6d d 6 j
|
} | j | } | t j d k r t j d | | f n | j } t j } t j | _ | | _ | j | | j | j | } | t j d k r't j d | n Wn7 t j d t j d t j }
|
t j |
|
t SXt S(
|
NiÿÿÿÿRy i RD g @@s4 OnCheckItemPrize db process time = %s, PrizeCnt = %ss sendString process time = %sR s% OnCheckItemPrize throw a exception
|
%s( R R R+ RÕ t timeitt default_timerRJ R. R R R/ R# t ProfileThresholdR R R R RÖ t dgCheckItemPrizeResultR R R% R& R Rë t ERROR_NO_114RÀ RÁ RU RN ( RX RW R R4 RP t startTickRZ t PrizeCntt processTimeR' R ( ( s .\\UserCtrlDB.pyR s.
|
, " c C sv y8t j } | j | j | t } t j } | j | _ t j
|
t j } | j | sÀ d | _ | | _ | j | sÀ | j t j | t j d | j | j f t Sn | j d 7_ | | _ | j | s| j t j | t j d | j | j f t S| j t j | | j Wn7 t j d t j d t j } t j | t SXt S( Ni s %s Update Error !doc.LogNum = %di R s# OnCheckLoadAcc throw a exception
|
%s( R R R+ RÕ Rú R Rû R Rü R
|
Ri Rf Rý RW R RÅ R§ RÖ RF R R3 RU RX Rÿ R t dgPlayerAccLoadR Rë t ERROR_NO_115RÀ RÁ RN ( RX RW R R4 RZ R] t strNowR ( ( s .\\UserCtrlDB.pyR > s4
|
" c C s, yît j } | j | j t j } | j | j t j d | j | j | j
|
f | t } t j } t j d | _ | j | _ | j | _ | j
|
| _ t d | _ d | _ d | _ t | _ | j | _ t j } | j | st j d | j | j | j | j
|
f | j | _ | j j | _ | j | _ | j
|
| _ d | _ | j! | t" t# j$ | j% t& S| j | _ | j j | _ | j | _ | j
|
| _ d
|
| _ | j! | t" t# j$ | j% Wn7 t' j( d t' j) d t* j+ } t j' | t& SXt, S( Ns< Type == gstAddAccItem, accid = %s, itemID = %d, itemCnt = %di im i i i< RÈ i sb Type == gstAddAccItem, transactionIDStr = %s, accid = %s, itemID = %d, itemCnt = %d, Insert Error!i R s! OnAddAccItem throw a exception
|
%siª iðg i@\ i Õ!(- R R R+ RÕ t tagIRAddItemRi R R R RL t ItemCntRJ R t tagAccIDSendPrizeR t GetTransactionIDStrRE Ry RF RG RP RC t PrizeReasonRD t SendPrizeTimeR¾ R t tagIAddItemResultR
t Lengtht AccLenR$ R9 R% R¬ RÖ t dgAddAccItemOKR& RU R Rë t ERROR_NO_116RÀ RÁ RN ( RX RW R R4 t recvDataRZ R] R' R ( ( s .\\UserCtrlDB.pyR
|
c sL #
|
) $" c C s yÄ t j } | j | j t j } | j | j | t } t j } | j
|
| _ | j | } | j | _ | j | sà t j d t j d | j
|
| j f } t j | t SWnF t j d t j d | j
|
| j t j f } t j | t SXt S( NR s? OnUpdateTelLockState!Update failed!ACCID = %s,TelLockState = %ssH OnUpdateTelLockState ACCID = %s, TelLockState = %s, throw a exception
|
%s( R R R+ RÕ R t tagDSAccount_UpdateTelLockStateR» Ri Rú Rû Ry Rü Rý t TelLockStateRY R Rë t ERROR_NO_117R RU t ERROR_NO_118RÀ RÁ RN ( RX RW R R4 Rf RZ R] R R ( ( s .\\UserCtrlDB.pyR s&
|
( 1 c C s yÄ t j } | j | j t j } | j | j | t } t j } | j
|
| _ | j | } | j | _ | j | sà t j d t j d | j
|
| j f } t j | t SWn7 t j d t j d t j } t j | t SXt S( NR s4 OnUpdateAccAdult!Update failed!ACCID = %s,Adult = %ss% OnUpdateAccAdult throw a exception
|
%s( R R R+ RÕ R t tagDSAccount_UpdateAdultR» Ri Rú Rû Ry Rü Rý RC RY R Rë t ERROR_NO_121R RU t ERROR_NO_122RÀ RÁ RN ( RX RW R R4 Rf RZ R] R R ( ( s .\\UserCtrlDB.pyR Æ s&
|
( " c C s yÝ t j } | j | j | t } t j } | j | j t | d d t
|
j t
|
j | _ | j | r d | _ n d | _ t j } t j | _ | j | _ t | j | _ | j | | j Wn7 t j d t j d t j } t j | t SXt S( NRä R´ i i R s# OnAddExpiation throw a exception
|
%s( R R R+ RÕ R¯ R Rä R» Ri R R# t tagExpiation_ExpiationIndex_FEEDt tagExpiation_ExpiationIndex_STEPR´ R
t ADOResultRÖ t dgAddExpiationOKR R Rt R% R& R Rë t ERROR_NO_123RÀ RÁ R RU RN ( RX RW R R4 RZ R] R' R ( ( s .\\UserCtrlDB.pyR é s,
|
" c C s yÝ t j } | j | j | t } t j } | j | j t | d d t
|
j t
|
j | _ | j | r d | _ n d | _ t j } t j | _ | j | _ t | j | _ | j | | j Wn7 t j d t j d t j } t j | t SXt S( NRë R´ i i R s& OnAddPetExpiation throw a exception
|
%s( R R R+ RÕ R² R Rë R» Ri R R# t# tagPetExpiation_ExpiationIndex_FEEDt# tagPetExpiation_ExpiationIndex_STEPR´ R
Rp RÖ t dgAddPetExpiationOKR R Rt R% R& R Rë t ERROR_NO_124RÀ RÁ R RU RN ( RX RW R R4 RZ R] R' R ( ( s .\\UserCtrlDB.pyR s,
|
" c C s7 yùt j } | j | j t j } d | j | j k r | j t j
|
| t j d t j d } t j | t Sd } xWt ráyÈ | t } t j } | j | _ | j | } d | _ | j | t j }
|
| j |
|
_ |
|
j | } | j |
|
_ | j |
|
_ | j |
|
_ | j |
|
_ | j |
|
_ | j |
|
_ |
|
j | PWq t j j! k
|
rÝt" j# | k r| d 7} q n t j d t j$ d | j | j | f } t j | | j t j
|
| t SXq W| j% t j
|
| d Wn7 t j d t j& d t' j( } t j | t SXt S( NiÿÿÿÿR s2 tagDBPlayer_DeleteRoleUpdateRole:lack of pack datai i s[ OnServerMergeDeleteRole!Update failed!DeletePlayerID = %s, UpdatePlayerID = %s, trycnt = %dR s, OnServerMergeDeleteRole throw a exception
|
%s() R R R+ RÕ R t tagDBPlayer_DeleteRoleUpdateRoleR» Ri R§ RÖ t dgServerMergeDeleteRoleR Rë t ERROR_NO_125R RU RN Rw Rv t DeletePlayerIDRK Rý R Rÿ t UpdatePlayerIDR¶ R· R¸ R¹ t WarehouseGoldt WarehouseSilverR Rs Rt R# Ru t ERROR_NO_126R t ERROR_NO_127RÀ RÁ ( RX RW R R4 Rf R R~ RZ R] t Rett updatedoc( ( s .\\UserCtrlDB.pyR ( sV
|
|
+ " c
|
C st y6t j } | j | j t j } | j | j d } xØ t r yO | t } t j
|
} | j | _ | j | } | j | _ | j | PWqG t j j k
|
rt j | k rÑ | d 7} qG n t j d t j d | j | f } t j | | j t j | t SXqG W| j t j | d Wn7 t j d t j d t j } t j | t SXt S( Ni i R sD OnServerMergeUpdateAccState!Update failed!PlayerID = %s, trycnt = %dR s0 OnServerMergeUpdateAccState throw a exception
|
%s( R R R+ RÕ R t tagDBPlayer_ChangeAccStateR» Ri RN Rw Rv RK Rý R Rÿ R Rs Rt R# Ru R Rë t ERROR_NO_128R R§ RÖ t dgServerMergeUpdateAccStateRU R t ERROR_NO_129RÀ RÁ (
|
RX RW R R4 Rf R~ RZ R] R R ( ( s .\\UserCtrlDB.pyR k s:
|
|
% " c C sÎ yst j } | j | j t j } | j | j t j d | j
|
| j f d } xt rqy | t } | j i t | j d 6 j r¨ d | _ n d | _ t j } t j | _ | j | _ t | j | _ | j | | j PWqd t j j k
|
rmt j | k r7| d 7} qd n t j d t j d | j
|
| f } t j | t! SXqd WWn7 t j d t j" d t# j$ } t j | t! SXt j d | j
|
| j f t S( Ns6 OnServerMergeChangeName playerID = %s, newName = %s...i R¾ i R s@ OnServerMergeChangeName!Update failed!PlayerID = %s, trycnt = %ds, OnServerMergeChangeName throw a exception
|
%ss7 OnServerMergeChangeName playerID = %s, newName = %s ok!(% R R R+ RÕ R t tagDBPlayer_ChangeNameR» Ri R R3 RK R¾ RN Rw R. R R/ Rp RÖ t dgServerMergeChangeNameR R Rt R% R& R Rs Rt R# Ru R Rë t ERROR_NO_131RU t ERROR_NO_132RÀ RÁ ( RX RW R R4 Rf R~ RZ R' R ( ( s .\\UserCtrlDB.pyR s@
|
% -
|
% " c C sà y¢ t j } | j | j t j } | j | j t | d d t j t j
|
| _ | t } | j | s¡ t j d t j d } t j | t SWn7 t j d t j d t j } t j | t SXt S( Nt tagDBImpeacht ImpeachIndexR s+ OnInsertImpeach!insert tagDBImpeach failed!s, OnServerMergeChangeName throw a exception
|
%s( R R R+ RÕ R R Ri R R# t tagDBImpeach_ImpeachIndex_FEEDt tagDBImpeach_ImpeachIndex_STEPR t UCN_DBImpeachR
R Rë t ERROR_NO_133R RU t ERROR_NO_134RÀ RÁ RN ( RX RW R R4 R] RZ R ( ( s .\\UserCtrlDB.pyR â s$
|
" c C s t S( N( RN ( RX RW R ( ( s .\\UserCtrlDB.pyR ö 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 int
|
CenterGatei iÿÿÿÿs0 OnMergerChildToCenter sendString toGameServer %s( R R t MongoDBServert getServerMgrt getClientSessionIDByNameRÕ R t tagLPStringDataR+ R t tagDGMergerChildToGameStringDataRÖ t dgMergerChildToCenterR Rt Ri t packSendBySessionIDRu R R@ RA R& RN ( RX RW R t ServerMgrt sendViaSessionIDR t PoolIndexR3 R4 R R' ( ( s .\\UserCtrlDB.pyR þ 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 inR i iÿÿÿÿs8 OnMergeChildToCenterPlayerData sendString toMapServer %s( R R R R R RÕ R t tagLPPlayerDataR+ R t tagDMMergePlayerDataRÖ RÛ R t gmMergePlayerDataRÝ Rt Ri RK R Ru R R
|
RA R& RN ( RX RW R R R R R R3 R4 R R' ( ( s .\\UserCtrlDB.pyRß s* c * C s t j d | t j } | | _ d | _ | t } t } t } | j | i t
|
| j d 6| j d 6 } | t k s¤ t j d t | j f d Si | j d 6} | t } | j | | t j t } t j | d }
|
| t } | j | | t j } t j | d } | t } | j | | t j } t j | d } | t } | j | | t j } t j | d } | t } | j | | t j } t j | d } | t } | j | | t j } t j | d } | t } | j | | t j } t j | d } | t } | j | | t j } t j | d } | t! } | j | | t j" } t j | d } | t# } | j | | t j$ } t j | d } | t% } | j | | t j& } t j | d } | t' } | j | | t j( } t j | d } | t) } | j | | t j* }! t j |! d }" t j+ }# | j, |# _ | t- } |# j. | }$ t j |$ d }% t j/ d |% d | j0 | | | | | | | | |$ | | | | |! }& t1 j2 j3 t4 j5 d }' t1 j2 j6 |' s7t1 j7 |' n t8 t1 j2 j3 |' d | d
|
}( d d l9 }) |( j: |& |( j; |( j< d S( Ns$ DumpSinglePlayerDataByAcc accid = %si Ry R s= DumpSinglePlayerDataByAcc Exception accid = %s,playerID = %sRK s gmIP cnt = %st DumpPlayerDatas %s.pdsavet wbiÿÿÿÿ(= R R3 R Rv Ry R Rw R R Rx R Ró RK Rz R{ R| RN R R R} R~ R R R R R R R
R R R R R R R R R R R R R R R R RU R R R RÕ R( R) R* R R+ R& t mkdirR3 t structt writet flushR7 (* RX RW Râ R R[ Rò R R R R R R R R R R R R R R R R¡ R R¢ R R£ R R¤ R R¥ R R¦ R R§ R R¨ R© RO RØ t DumpDirR9 R¢ ( ( s .\\UserCtrlDB.pyt DumpSinglePlayerDataByAcc; s
|
,
|
|
|
|
|
|
|
|
|
|
|
|
|
|
D"
|
c C s t j j t j d } t j j | sD t j | t d f St j j | d | } d } y) t | d } | j } | j
|
Wn t d f SXt j } d } | j | | t | } d | k rà t d f S| | 7} t j d | j | j d k rt d f S| j j | _ | t }
|
| j |
|
sOt | j f S| | j | j | t t j | | t 7} | | j | j | t t j | | 7} | | j | j | t t j | | 7} | | j | j | t t j | | 7} | | j | j | t t j! | | 7} | | j | j | t" t j# | | 7} | | j | j | t$ t j% | | 7} | j& | j | j | | | | j | j | t' t j( | | 7} t) j* | | \ } } t j+ } x3 t, | D]% } | | j | | t | 7} qèW| | j | j | t- t j. | | 7} | | j | j | t/ t j0 | | 7} | | j | j | t1 t j2 | | 7} | | j | j | t3 t j4 | | 7} | | j | j | t5 t j6 | | 7} | t | k söt7 t | j f S( NR i s %s.pdsaveR R0 iÿÿÿÿs$ Saving player data,playerID = %s....(8 R( R) R* R R+ R& R¡ RU R3 R' R7 R Rv R» R R R3 RK Ry RU Rw RY Ra Rz R| RN R} R~ R R R R R R R
R R R RM R R R R R RQ R R R R R R R R R R RN ( RX RW Râ R¥ t FileDirR R9 RÆ R RÇ R[ RO RP RQ ( ( s .\\UserCtrlDB.pyt SaveSinglePlayerDataFromDumpFile¨ sZ
|
|
|
|
|
,)))))) ) #)))))c C sj t j t j t j j t j t j d } | t j t j
|
t j j t j t j d 7} | t j t j t j j t j t j d 7} | t j t j t j j t j t j d 7} | t j t j t j j t j t j d 7} | t j t j t j j t j t j d 7} | t j t j t j j t j t j d 7} | t j t j t j j t j t j d 7} | t j t j t j j t j t j d 7} | t j t j t j j t j t j d
|
7} | t j t j t j j t j t j d 7} | t j t j t j j t j t j d 7} | t j t j t j j t j t j d 7} | t j t j t j j t j t j d 7} | t j t j t j j t j t j d 7} | t j t j t j j t j t j d 7} | t j t j t j j t j t j d 7} | t j t j t j j t j t j d 7} | t j t j t j j t j t j d 7} | t j t j t j j t j t j d 7} | t j t j t j j t j t j d 7} | t j t j t j j t j t j d 7} | t j t j t j j t j t j d 7} y
t j! | d } d } t" j# | t j$ } t" j% | t& | | } t' j( d t& | t& | f t) j* | t& | Wn6 t+ j, d t+ j- d t. j/ } t' j0 | n Xd S( Ns tagChinNPC.txts tagNPCRefresh.txts tagChinSkill.txts tagChinExp.txts tagChinItem.txts tagTransportRefresh.txts tagChinShopItem.txts tagBornRefresh.txts tagChinMixItem.txts tagBuildEquip.txts tagSuiteActivation.txts tagSuiteEffect.txts tagRepeatEvent.txts tagEffectRefresh.txts tagChinMap.txts tagDBStoreItem.txts tagOnMissionDelete.txts
|
tagPet.txts tagPetGrade.txts tagPetFriendliness.txts tagPetExp.txts tagNPC_Item_Pet.txts tagFlyObjBaseInfo.txti R s( Load game sys data for len = %s - %s ok!R2 s) Compress game sys data failed!error =
|
%s(1 R t sysDBLoadFromFilet
|
tagChinNPCR( R) R* R R+ RÖ t
|
SYSDB_PATHt tagNPCRefresht tagChinSkillt
|
tagChinExpt tagChinItemt tagTransportRefresht tagChinShopItemt tagBornRefresht tagChinMixItemt tagBuildEquipt tagSuiteActivationt tagSuiteEffectt tagRepeatEventt tagEffectRefresht
|
tagChinMapt tagDBStoreItemt tagOnMissionDeletet tagPett tagPetGradet tagPetFriendlinesst tagPetExpt tagNPC_Item_Pett tagFlyObjBaseInfoR4 R R RÈ t
|
dgGameDatat WriteStringR R R3 R R R Rë t ERROR_NO_53RÀ RÁ R2 ( RX t sysDatat compressSysDataRC R ( ( s .\\UserCtrlDB.pyt OnGetGameDataõ sÌ #"(q Rw t
|
__module__Rw R R R R R R Rb RÙ RD RÛ RÜ Rg Rd RÝ RÞ Râ Rá Rà Rã Rñ R R Rí Rð R R< R$ R! R RM RU Ra RL RK R R R Ré R R R¤ R« R® R³ R¶ Rº R R¥ R¢ R{ Rð Rõ Rñ Rþ Re Rý R. R2 Rç R Ry R§ R% Ræ Rå Rä RQ Ru R[ R Re Rò Ró Rô Rõ Rö R÷ Rø Rù Rú Rû Rü R» Rþ Rÿ R R R R R R R R R R R
|
R R R R R R R R R R Rß R¦ R¨ RÇ ( ( ( s .\\UserCtrlDB.pyRu ë sä l
|
ÿ ®
|
' & A " I $ 0 : +
|
3 H 4 & o p ^ K , /
|
X D % ÿ L ÿ N ÿ Z ) ÿ # + ; ! ' B
|
Ï + " ! " 8 5 ! @ % = & # C % R m M(N R( R4 RP RÏ RÂ R RT R R t DBCommon.CommonDefineRÖ t MangoDBCommonR R R R R R t ServerClientShareDefineR& t
|
__import__R# t ctypesR RÀ Rx t Collections.CollectionDefinet CommonR R R
|
R5 R* RÉ RK t jsonRM Ry t syst hashlibt CollectionsR R R t DBCommonR R R R t ProtocolR R R R R RË R Rv Rz Rg Rl Rm Rk R R" R R R t MergeRegPInfoIndex_GroupIDRG t threadt allocate_lockRL R_ R\ Re Rt Ru ( ( ( s .\\UserCtrlDB.pyt <module> sd
|
|
.
|
|
"( , & .
|
