ó
|
ɾhc @ sR 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 Z d d l
|
j Z d d l m Z m Z m Z m Z m Z m Z d d l m Z m Z m Z m Z d d l m Z m Z m Z m Z d d l m Z m Z d d l m! Z! m" Z" m# Z# m$ Z$ m% Z% m& Z& d d l' Td d l m( Z( d d l) Z) e* d Z+ d d
|
l, m- Z- d d l. Z. d d l/ m0 Z0 m1 Z1 d d l2 Z2 d d l3 Td d l Z d d l4 m5 Z5 d d l6 m7 Z7 d d l8 m9 Z9 d d l 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 lA ZA d d lB ZB d d lC ZC d d lD ZD d d lE ZE d d d d d d g ZF d ZG d ZH d ZI e+ jJ aJ eK d \ ZL ZM ZN ZO d ZP d d lQ ZQ eQ jR aS eQ jR aT d ZU d ZV d ZW d e j f d YZX d ZY eZ d k rNeY n d S(! iÿÿÿÿN( t *( t SingletonObjectt
|
DataDumpert GlobalFunctionst VersionNoDefinet errort DBController( t CommFunct
|
CommFuncExt mylogt RandowPswGenerator( t RecvPackProtocolt SendPackProtocolt MergeServerRecvProtocolt MergeServerSendProtocol( t DataServerPlayerDatat DataServerLogData( t getADOExceptionCountt getSIDErrorCntt addADOExceptionCountt seqt fix_outgoingTextt fix_incomingText( t
|
MMORPGPacks Config.DBConfig( t string_at( t EventProcesst EventReport( t MongoDBServer( t ProjSpecialProcess( t GMShell( t FileLogt weekdayt yeart montht dayt hourt minutei i i c C s¡ d d l } t j } t j } | | f } d } d } d } y!t j } | 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 rEt 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 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( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyt CheckGameVersionK 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 R8 R+ t timeR, R- R. R3 R4 R5 R6 R7 R9 t xranget appendt UCN_Dispatch_PlayerIDt insertR< R= R t Falset release( t dbt selfR+ RU R> R? R@ RA RG RH RI RJ RN RO t recst idt
|
collectionRK ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyt CallDispatchPlayerIDz 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) RN RO i t FamilyIDs5 IDDispatch CallDispatchFamilyID Connect Exception %ss: IDDispatch CallDispatchFamilyID Connect unknown Exception( t lockFamilyIDRR RS t isDispatchingFamilyIDR R8 R+ RU R, R- R. R3 R4 R5 R6 R7 R9 RV RW t UCN_Dispatch_FamilyIDRY t CallBackToSendFamilyIDPackR< R= R RZ R[ ( R\ t fromPackt typeR] R+ RU R> R? R@ RA RG RH RI RJ RN RO R^ R_ R` RK ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\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 hasattrRS t getattrRi t intt Def_Cmp_Greatert Def_Cmp_Lowert Def_Cmp_Equ( t curTimet timeInfot indext callObjt
|
curCallObjt wday( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\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> d< d= Z? d> Z@ d? ZA d@ ZB dA ZC dB ZD dC ZE dD ZF dE ZG dF ZH dG ZI dH ZJ dI ZK dJ ZL dK ZM dL ZN dM ZO dN ZP dO ZQ dP ZR dQ ZS dR ZT dS ZU dT ZV dU ZW dV ZX dW ZY dX ZZ dY Z[ dZ Z\ d[ Z] d\ Z^ d] Z_ d^ Z` d_ Za d` Zb da Zc db Zd dc Ze dd Zf de Zg df Zh dg Zi dh Zj di Zk dj Zl dk Zm dl Zn dm Zo dn Zp do Zq dp Zr dq Zs dr Zt ds Zu RS(t c A C s t j j | d d | t j t j f | j d d <t j t j f | j d d <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 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 j0 t j1 t j2 t j3 t j4 t j5 t j6 t j7 t j8 t j9 t j: t j; t j< t j= t j> t j? t j@ t jA t jB t jC t jD t jE t jF t jG t jH fA | j d d <| jI tJ jK tJ jL | jM tJ jN tJ jO tJ jP tJ jQ r7tR jS | _T n tR jU tJ jV | _T tW | _X tW | _Y d | _Z t[ | _\ t[ | _] d S( NRz i i i i (^ t CtrlDBt __init__t CommonDefinet gstUpdatet gstSaveMapServerCrashDatat priorityQueueListt gstSaveGameServerDatat gstSavePlayerGMOPert gstPlayerLogint gstPlayerDetailt gstCreatePlayert gstCheckPlayerExistt gstQueryCanSendMailt gstGetPlayerMailt gstGetMailDetailt gstUpdateMailt gstDeleteMailt gstOnDayt gstFamilyVSt gstGetPlayerMailStatet
|
gstGetCoint gstCoinChanget gstPlayerBillboardLVt gstAccIDSendPrizet gstInsertAcct gstGMCommandListReqt gstAddAccItemt gstCheckItemPrizet gstCheckLoadAcct gstUpdatePswLV2t gstGetExpiationCountt gstGetExpiationt gstAddExpiationt gstAddPlayerMailByAccIDt gstServerMergeDeleteRolet gstServerMergeChangeNamet gstServerMergeUpdatePlayert gstQueryIsFamilyLeadert gstServerMergeUpdateAccStatet gstMapServerInfot gstCreatePett gstSaveRunGataInfot gstPlayerIDMarkDeletedt gstGetMapServerPlayerDatat gstGetGameServerPlayerDatat gstSaveGameServerPlayerSaveDatat gstSaveGameServerCrashDatat gstGetBillboardInfot gstGetGameServerPlayerLoginDatat gstUpdateServerDataVersionNOt gstUpdateTelLockStatet gstGetPetExpiationt gstGetPetExpiationCountt gstAddPetExpiationt gstUpdateTotalSavePointt gstSavePlayerInfot gstUpdateAccAdultt$ gstCreateRoleServerRequestCreateRolet# gstCreateRoleServerCheckPlayerExistt" gstCreateRoleServerCheckIsHaveRolet gstQueryNewGuyCardStatet gstUpdateNewGuyCardStatet gstGMToolCmdUserDBRequestt gstMergeRegisterPlayert gstMergeQueryRegisterResultt gstGeneralDBOpert gstDiapatchFamilyIDt gstMergerChildToCentert gstPrepareCreateRolet gstQueryRecharget gstFinishRecharget gstMergePlayerDatat
|
gstDBLogict setServerR, t
|
USER_DB_IPt USER_DB_PORTt setDataBaset USER_DB_NAMEt userdb_usert
|
userdb_pwdt base64R t Base64StringManipulatort
|
translatort EncodeStringManipulatort encodingRZ RT Re t loginHeapRU t loginStartTimet lastCleanMergePlayerTime( R] t ctrlDBMgr( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyR| í s¢ c C s t S( N( t IsMergeServer( R] ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRÔ N 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_mergeRegisterPlayerDictRU RÒ t itemst MergeRegPInfoIndex_LogoutTimet MergeRegPInfoIndex_LoginTimet popR t debugt len( R] RÖ Rs t Def_CleanTimet accIDt packInfo( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyt PopOfflineMergePlayerT s c C s: t j s6 t t _ t | j | | j | n d S( N( RÕ t g_UserCtrlDBFirstInitRS RL t _UserCtrlDB__PlayerBackupSavet loadDBPlayerPackData( R] R\ ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyt onConnectedOKl s c C s | j r n | j | d S( s ×ÓÀàʵÏÖ - ÿÃë´¦ÀíN( RÔ t OnQueryRechargeByLoop( R] R\ ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyt onSecondProcesst s c C s` | 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 re| 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 r7| 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 j! d | 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 rt| j d } | j
|
| j* | | | j t S| t j+ k rÙ| j d } | j
|
| j r»| j, | | n | j- | | | j t S| t j. k r | j d } | j
|
| j/ | | | j t S| t j0 k re| j d } | j
|
| j1 | | | j t S| t j2 k r«| j d } | j
|
| j3 | | | j t S| t j4 k rñ| j d } | j
|
| j5 | | | j t S| t j6 k rt S| t j7 k rJ| j d } | j
|
| j8 | | | j t S| t j9 k r't: j; rt< j= d t< j> d t j9 } t j? | t t@ S| j d } | j
|
| j rë| jA | | st j< d | jB jC qn. | jD | | st j< d | jB jC n | j t S| t jE k rm| j d } | j
|
| jF | | | j t S| t jG k r³| j d } | j
|
| jH | | | j t S| t jI k rù| j d } | j
|
| jJ | | | j t S| t jK k r?| j d! } | j
|
| jL | | | j t S| t jM k r
| j d" } | j
|
| jN | | | j t S| t jO k rË| j d# } | j
|
| jP | | | j t S| t jQ k r | j d$ } | j
|
| jR | | | j t S| t jS k rW | j d% } | j
|
| jT | | | j t S| t jU k r | j d& } | j
|
| jV | | | j t S| t jW k rã | j d' } | j
|
| jX | | | j t S| t jY k r)
|
| j d( } | j
|
| jZ | | | j t S| t j[ k ro
|
| 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 ja k rA | j d, } | j
|
| jb | | | j t S| t jc k r | j d- } | j
|
| jd | | | j t S| t je k rÍ | j d. } | j
|
| jf | | | j t S| t jg k r | j d/ } | j
|
| jh | | | j t S| t ji k rY | j d0 } | j
|
| jj | | | j t S| t jk k r | j d1 } | j
|
| jl | | | j t S| t jm k rå | j d2 } | j
|
| jn | | | j t S| t jo k r+ | j d3 } | j
|
| jp | | | j t S| t jq k rq | j d4 } | j
|
| jr | | | j t S| t js k r· | j d5 } | j
|
| jt | | | j t S| t ju k rý | j d6 } | j
|
| jv | | | j t S| t jw k rC| j d7 } | j
|
| jx | | | j t S| t jy k r| j d8 } | j
|
| jz | | | j t S| t j{ k rÏ| j d9 } | 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 rs| j d? } | j
|
| j | | | j t S| t j k r¹| j d@ } | j
|
| j | | | j t S| t j k rÿ| j dA } | j
|
| j | | | j t S| t j k rE| j dB } | j
|
| j | | | j t St j dC | j t S(D Ni s begin process request type = %dR½ R¼ RÃ R» Rº RÂ R· RÀ RÁ R¸ s recv map server crash data!R R R§ R R R R
R¶ Rµ R´ R¨ t DeployErrorsN DbSaveServer is open, type = %d request should be send to PyMongoDBSaveServerR~ s< onSaveMapServerPlayerDataMergeServer failed!sessionID = 0x%Xs1 onSaveMapServerPlayerData failed!sessionID = 0x%XR² 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 gstInsertImpeachR¹ R¾ R¿ s %s not processed!( RÔ Rà R t ReadBYTEt getBufferR RÛ R} R½ t GetFuncGradet Startt OnDiapatchFamilyIDt EndR¼ t OnGeneralDBOperRS RÃ t OnGameServerToDBLogicR» t OnMergeQueryRegisterResultRº t OnMergeRegisterPlayerByCacheRÂ t OnMergeChildToCenterPlayerDataR· t OnQueryNewGuyCardStateRÀ t OnQueryRechargeRÁ t OnFinishRechargeR¸ t onCheckUpdateNewGuyCardStateR R8 t onSaveMapServerCrashDataR t onSaveGameServerDataR§ t onGetGameServerPlayerDataR t onGMCmdListReqR t onAuthenticationR t onGetMergePlayerDetailt onGetPlayerDetailR
t onCreatePlayerR¶ t! onCreateRoleServerCheckIsHaveRoleRµ t" onCreateRoleServerCheckPlayerExistR´ t# onCreateRoleServerRequestCreateRoleR« R¨ t onSaveGameServerPlayerSaveDataR~ R, t IsOpenDbSaveServerR t formatMsgt ERROR_NO_56Rç RZ 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( R] R\ t packt post requestTypet
|
oFuncGradet msg( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\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 FamilyIDListRW RÜ t Countt
|
sendStringt GetBuffer( R] Rh R; RN RO t sendPackR_ ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRg 1 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 dispatchRc s# CallType 0 sendPack.FamilyIDList %ss CallType 1 need dispatch( Rê R t tagGDRequestCanUseFamilyIDListt ReadDataR RÛ t OutputStringt CallTypeRf t findt countRe t threadingt ThreadRj t startR R8 R} R9 R: R; R= RW RÜ R> R? R@ ( R] R\ R2 t buft recvPackR3 R` R) RJ t tRA t rec( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRí ; 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@ ( R] R R) t resultSett errMsgRA ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyt sendGameServerDBOperResultb 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!RY 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!RH t fieldss %s.find(%s) failed!s oper %s not support!( Rê R t tagGDGameServerGeneralDBOperRE R RÛ RF t Nonet cPicklet loadst OperDictR= R0 t
|
NeedReturnR^ t getSessionIDt
|
isinstancet dictR1 t
|
basestringt lowerR` t strRY RZ RS Rb Rd RH t list( R] R\ R2 RM RN R3 t operDictRK t colNamet colR_ R) t errorMsgt doc_or_docst docRc t
|
spec_or_idRe R\ ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRï m 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 tagGDGameServerToDBLogicRE t QueryTypeR RÛ RF R} t gstDBLogic_PlayerPackDataReqt IDt getPlayerPackDatat GetPlayerDataByPlayerIDRË t b64encodet updPlayerPackDatat SendGameServerToDBLogicResultRl t gstDBLogic_PlayerPackDataUpdt Datat gstDBLogic_GMCmdR t DBGMCommandRq ( R] R\ R2 RM RN R3 t queryTypet playerIDt packDataR) t
|
playerDatat dbAnswerList( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\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: RS R} R{ R RÜ t DataLenRT RU RX t atInnerR RZ R[ R@ R RÛ ( R] R R) RN R\ RA ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyR $ 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( NRP s0 GetPlayerDataByPlayerID Exception playerID = %si R% s
|
accid = %si ( i s (* R t tagDBPlayerRP t UCN_DBPlayert
|
adoLoadCExR R0 R8 t AccIDt UCN_RoleItemt readPlayerPackSaveDatat tagRoleItemRS 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 tagDBGMIPRp t
|
UCN_DBGMIPt adoQueryIndexRê ( R] R\ R t dbPlayerR` t loadOKt queryDictt itemDatat missionDatat roleMissionDictDatat roleSkillDatat roleBuffDatat roleRepeatTimeDatat roleHorseDatat
|
gmOperDatat rolePetDatat petSkillDatat roleNormalDictDatat roleDienstgradDatat battleFormationDatat gmIPt gmIPData( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyR 9 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 tagLPQueryRegisterResultRE R t stript chrR RÛ Rl t MergeProxyClientMgrt getMergeProxyClientMgrt findClientBySessionIDR0 R t tagMPQueryRegisterResultR} t dgMergeQueryNewAccountR: R1 RS RX R R RY R t stNoSenseR@ t AccountRÜ t
|
AccountLent Pwdt PwdLen( R] R\ R2 RÖ RM RN R3 RÞ t clientSessionIDRG RA ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRñ y 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 tagLPRegisterPlayerRE R t tagMPRegisterPlayerResultR} t dgMergeRegisterResultR: R R R t readDataRÜ RS t ErrorMsgt ErrorMsgLenRX Rl R R RY R RÌ R@ R R0 RP RÇ RÈ RÉ RF R Rp RÅ RÆ t
|
PlayerNameRÍ RÎ RÏ RÐ R8 RU R= R R t ERROR_NO_175t tracebackt
|
format_exct binasciit b2a_hext ERROR_NO_176( R] R\ R2 RÖ RM RN R3 t loginResultPackR t playerRect dbPlayerReadLenRÑ RG RF R RÞ t
|
playerNameRK R6 ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\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 tagMDFinishRechargeRE Rã RÅ RÆ R RÛ t UCN_PayInfoRH RI t datetimet todayRq t splitRb R= R R t ERROR_NO_170RÜ RÝ ( R] R\ R2 RM t packLenRN R3 t orderIDRu R) Rs t
|
curTimeStrRK R6 ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRö ä s2
|
,+%c C sA d } d } | d k r d St j s) d St } | t j | k rI d S| t _ y²| t } i i t j d 6d 6d d 6d d 6} i d d 6d d 6} | j | | j | d } | sË | j rÏ d Sg } xJ | D]B }
|
|
|
d } | | k rÜ | j | t | | k r Pq qÜ qÜ W| s,d St
|
j } t j | _ t i d
|
d 6t | d 6d d 6 | _ t | j | _ t
|
j } | j | j t j | _ t j } | j d d } d } d } | j | | | t j t j t j | j Wn6 t j d t j d t j! } t" j | n Xd S( Ni i i s $inR Rä Rå t _idi t GMT_GetCoinReqst pack_typet AccIDListt gbkt codingt
|
CenterGateiÿÿÿÿR s traceback = %s(# RÕ t g_onlineAccIDListRU t g_queryRechargeByLoopTimeRè RH t limitRI RW RÜ R t tagGMCommandR} t gstGMToolCommandR: Rq t Cmdt CmdLenRE R@ t bgDBGMCommandR t getServerMgrt getClientSessionIDByNamet packSendBySessionIDR R RZ R[ R R Rì RÚ RÛ R ( R] R\ t PayRechargeIntervalt PayRechargeCountRs Ru Rc Re R) t unRechargeAccIDListt billInfoRÞ t curPackRN t ServerMgrt sendViaSessionIDt SessionIDt PoolIndexR6 ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRå sZ
|
%
|
* "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 ...%sR 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 tagMDQueryRechargeRE RÍ RÅ RÆ R RÛ Rè RH RI R t tagDMRechargePushR} t dgDBToMapServerR: t gmReChargePusht SubTypeR Rã RÜ t
|
OrderIDLenR t OrderInfoLenRo t MoneyR t ExtrasLenRb R? R@ R= R R Rì RÜ RÝ ( R] R\ R2 RM Rí RN R3 t accountRu R) R RA RK R6 ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\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 tagMDIsMediaCardUsedRE R RÛ t CardIDR t tagDMIsMediaCardUsedR} R R: t gmQueryNewGuyCardStateR t CardIDLenR t tagDBNewGuyCardStatet UCN_DBNewGuyCardStateR t adoLoadt IsUsedt UserDataLent UserDataR? R@ R0 t CardTypet ValidTimeR1 R= R R Rì RÜ RÝ ( R] R\ R2 RM Rí RN R3 RA t objRu t lastExceptionCntRK R6 ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRô o 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 tagMDCheckUpdateMediaCardStateRE R t tagDMCheckUpdateMediaCardResultR} R R: t gmUpdateNewGuyCardStateR R R R RÛ RF R R R R! R" R# R$ R t adoCheckUpdateRS R? R@ R= R R t ERROR_NO_171RÜ RÝ ( R] R\ R2 RM Rí RN R3 RA R% Ru RK R6 ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\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 tagGDSavePlayerInfoRE Rê t GeTuiClientIDt UCN_DSAccountR t tagDSAccountR Rp t ACCIDt adoLoadCR R t ERROR_NO_57R R0 t
|
adoUpdateC( R] R\ R2 R3 t
|
PlayerInfoRu t PlayerAccR6 ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\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 tagLDPrepareCreateRoleRE Rê t GetAccountFromTableR R: R t AppIDR t GetPlatformAccIDt
|
DeviceFlag( R] R\ R2 R3 R4 R ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\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 R RÕ RÜ RZ RP R R8 RS R ( R] R\ t saveDataRà R3 Rá R ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\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} R t ReadDWORDR t stMint
|
ReadStringt ToDWORDt crc32RÆ R[ t onSavePlayerDataCRCErrorRZ t _UserCtrlDB__ReadPlayerIDRU RØ t MergeRegPInfoIndex_PackDataR RÜ R R R8 R R R t tagDBUpdateReturnt dgUpDateRG R; RS RP R? R@ ( R] R\ R2 RÖ R3 RM t lengthRi t
|
needReturnt
|
packCrcPost packCrct serverTypePost
|
serverTypeR; t calcCrct serverTypeDataR) R RÞ t updateReturn( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyR sJ
|
|
c C s d } | j } | j } t j | | \ } } | t j k rt 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 | t' j( k rt' j( j) | n | j* | | t j+ d | | | j j f t, j- j. t j/ t0 | } t, j- j1 | rt, j- j. | d } x t, j2 | D]t } | j3 t j4 s&qn t, j- j. | | } t, j- j1 t, j- j. | | sot5 j6 | | qt, j) | qWn | | 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(7 Rê Ræ R Ré R} R R= R R> R? R@ RA RÆ R[ RB RZ R, t PackSavet SavePlayerMapServerDataExt SavePlayerMapServerDataR R R R t ERROR_NO_59R R t DumpDataR t
|
getAppPathR RE RF RG R; RS RP R? R@ RÕ R÷ Rd t RevoverBillProcessR8 t ost patht joint PlayerBakRootRq t existst listdirt endswitht PlayerBakFileTypet shutilt move( R] R\ R2 R3 RM RG Ri RH RI RJ RK RL R; RM RN R) R RÞ R R6 RO t PlayerBakDirt
|
BakCopyDirt filenamet fullPath( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyR
|
: sj
|
|
' # !c C sQ | j r d St j s0 t j j t j r4 d St j d t j xt j t j D]î\ } } } | j d r q[ n xÇ| D]¿} | j t j
|
s¤ q n t | d k rÕ t j d | t d d SyM t j j | | } t | d } | j } | j t j | } Wn# t j d | t d d SXt j ro| j | | \ } }
|
} n | j | | \ } }
|
} | s¯t j d | t 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 Wq[ Wd S( s7 Íæ¼Ò±¸µµÈë¿â - ½öÔÚÆô¶¯dbÁ´½Ó³É¹¦ºó´¥·¢Ò»´Î
|
Ns& Íæ¼Ò±¸µµÂ·¾¶ DBConfig.PlayerBakRoot=%sRP i sN Íæ¼Ò±¸µµ¸öÊýÒì³£: The number of backup files is greater than one. filenames=%siÿÿÿÿt rbs Íæ¼Ò±¸µµ´ò¿ªÊ§°Ü. %ss Íæ¼Ò±¸µµÈë¿âʧ°Ü fail. %ss/ Íæ¼Ò±¸µµÈë¿â³É¹¦: playerID=%s,accID=%s, move %ss1 Íæ¼Ò±¸µµÈë¿â³É¹¦: playerID=%s,accID=%s, remove %s( RÔ R, R[ RX RY R\ R R8 t walkR^ R_ RÜ t fatalt exitRZ t openR0 R< t zlibt
|
decompressRQ RR RS Rq R` Ra Rd ( R] R\ t parentt _t filenamesRd Re t fileHandlerR; R) R RÞ Rc ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyt __PlayerBackupSave
sN "
|
|
|
|
!! "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 | } | GHt j | d Sy8 t | d } | j } | j t j | } Wn$ d | } | GHt j | d SXt j r'| j | | \ } } } n | j | | \ } } } | shd | } | GHt j | d Sd
|
| | | f } | GHt j | d S( Ns ===Ö´ÐÐÍæ¼ÒÖ¸¶¨±¸µµÈë¿â: %ss .Rn i RP s ²»´æÔÚ¸ÃÍæ¼Ò±¸µµÎļþ: %sRf s Íæ¼ÒÖ¸¶¨±¸µµ´ò¿ªÊ§°Ü: %ss Íæ¼ÒÖ¸¶¨±¸µµÈë¿âʧ°Ü: %ss. Íæ¼ÒÖ¸¶¨±¸µµÈë¿â³É¹¦: playerID=%s,accID=%s, %s( R R8 Ro Ru Rë RX RY RZ R, R[ Rq R\ Rj R0 R< Rk Rl RQ RR RS (
|
R] R\ t bakFileNameR Re R6 Rp R; R) RÞ ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyt SavePlayerDataByBackup» sB *
|
$
|
|
|
|
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 R i Rä Rå Rã s $sets RevoverBillProcess success...%ss RevoverBillProcess error %s( RÅ RÆ Rè RH RI Rb R RÛ R ( R] R\ RÞ R Ru R) R Rî ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRW å 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 R RÕ RÜ RZ R R8 RP R Rp R Rë Rì R3 Rî t recPlayerLogofft savePlayerDataR R RS R R R R R R R R R R R¡ R¢ t gmOperCheckR£ R¤ R R= R¯ RV R¥ R¦ R§ R¨ R© Rª R« R¬ R R® t AssertionError( R] R\ R; Rà R3 Rá R` R5 t gmIPCntt gmIPRect i( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRS ú 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 R RÕ RÜ RZ R R8 RP R Rp R Rë Rì R3 Rî t CountryLastWeekHornorR t savePlayerDataExR R RS R R R R R R R R R R R¡ R¢ R R£ R¤ R R= R¯ RV R¥ R¦ R§ R¨ R© Rª R« R¬ R R® R
( R] R\ R; Rà R3 Rá R` R5 R R R ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRR i 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¤ RV t clearRÕ t OperR} t gmForbidAcct onForbiddenUpdateRS R t TDateTime_NowRo t EndTimet GMAccIDt TDateTimeToStringt Msg(
|
R] RÞ R RH R3 RG t cntt gmOperRecR t readLen( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyR Ù 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 = %sRP 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 R8 RÜ RV R RÕ RÝ t makeSIDt getRecordRS Rb t pymongot errorst OperationFailureR, t TryCntOnWriteFailR t __class__t __name__t inspectt stackR Rd ( R] R R\ t collectionNamet
|
structNameRH t checkSIDR§ t oAllFuncGradeR` R5 R3 R¢ RP RG Rx R R¤ t trycntt err( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyR ê 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_removeRP 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Õ R§ Rë Rì Rd Rî R R= R RÛ RÜ RV R RÕ R8 RÝ R¨ R© RW RS RY RZ Rª R« R¬ R, R R R® R¯ R° R± R ( R] R R\ R² R³ RH R´ R§ Rµ R` R5 R3 R¢ RP RG Ra R R¤ Rx R¶ R· ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyR H sx
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
.
|
c C s
|
t j } | j | _ | j | _ | j | _ | j | _ | j | _ | j | _ | j | _ | j | _ | j
|
| _
|
| j | _ | j | _ | j | _ t | _ | j | _ d | _ d } t j | t j } t j | | j | j } | j | d S( Ni R% ( R t tagDBPlayerLogInfoOnLogOffR RØ t AccStatet LVt Goldt GoldPapert Silvert SilverPapert GMLevelt Jobt
|
HappyPointt TJGTimet Statet TJGStateRU t LastLogoffTimeRP t IsOnlineR t WriteBYTER} t gstSavePlayerInfoLogOnLogOfft WriteStringRæ Rê t sendDBRequest( R] R² t reqt sendBuf( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyR 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 ( Rq t uuidt uuid4R R t ERROR_NO_60R R R R RU R RV R R RÜ RÕ t updatePlayerAccStateRP R} t pysForbiddent sendAccForbiddenLogReqR R RE RF RG R R; RS R? R@ (
|
R] R\ R2 t saveDataWithCRCt dumpFileNameR6 Rà R3 RG RO ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRB ª s + c C sw t j } | | _ | | _ t | _ d } t j | t j } t j
|
| | j | j } | j | d S( NR% ( R t tagDBPlayerInfoLogForbiddenR t IsForbiddenRU t ForbiddenTimeR RÇ R} t gstSavePlayerInfoLogOnForbiddenRÉ Ræ Rê RÊ ( R] t accidt isForbiddent accForbiddenLogReqt accForbiddenLogReqPackBuf( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\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!( R R R RP R R1 R R0 R® R¯ R° R± RZ RÛ R¹ R3 RS ( R] R\ R t newStateR` Rx t lastSIDErrorCntt ret( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\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* tagGameServerToBalanceServerPlayerSaveDataRE Rê Ræ Rk t setSrcSvrTypeR t stLogint sendOKStringR} t dgPlayerSaveGameServerData( R] R\ R2 t saveGameServerPlayerDataReq( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyR â s c C s d S( N( ( R] R\ R2 ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\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 R t IsDeleteds player of accid = %s exists!i s1 onCreateRoleServerCheckIsHaveRole ok, Accid = %s!R s) Catch a unexpetcted exception, error = %s(# R t tagCSIsHaveRoleRE Rê R t tagDRequestResultR} R¶ R: R R R Rp Rè R R R R R R R8 RS t ExAttrt disDataBaseErrorR, R´ t disAccStateErrorR? R@ RÛ R R t ERROR_NO_62RÚ RÛ (
|
R] R\ R2 RN RA t PlayerR` R& Rß R6 ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyR 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 tagCSCheckPlayerNameExistRE Rê R Rê R} Rµ R: R RS t hasPlayerByPlayerNameRØ Rë R? R@ R RÛ R R t ERROR_NO_63RÚ RÛ ( R] R\ R2 RN RA R6 ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyR 7 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( R] R\ R2 t Suct disCodet AccIdRH ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRÿ M 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} R´ R: RS R Rë R RÛ R? R@ R R t ERROR_NO_64RÚ RÛ ( R] R\ R2 Rö R÷ Rø RH RA R6 ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyR Y s "c C s` t j d | t } | j } | GH| s | j r~ d } x: | d k ry | j ry | j sb t St d | d 7} q@ Wt St | | t S| j } | t
|
j k r® t S| d k r| j r
|
d } 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ÿÿÿÿRB RC ( R RÛ RX RH RT RS t sleepRZ Ra RI R, t IDDispatchPlayeIDLimitRJ RK RL ( R] R\ R` R) t try_countt emptyCntRJ RO ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyt CheckEmptyPlayerIDCountn sF
|
|
|
|
c C s; | t } | j } | r7 | d } | j | | Sd S( NRP iÿÿÿÿ( RX t find_oneRd ( R] R\ R` RP t newID( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyt PopEmptyPlayerID s
|
|
c C sV t j } | s+ t | t d t j t j Sd d l } | j | d GH| j | S( NRP iÿÿÿÿs CheckEmptyPlayerIDCount OK( R, t UseIDDispatchServerR R t PLAYERID_FEEDt PLAYERID_STEPt threadRþ R ( R] R\ R R ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyt DispatchNewPlayerID¨ s c C s0 t j } | | _ | t } | j | | S( N( R R/ R0 R. R ( R] RÞ R\ t accountDataR` ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyR7 µ s
|
|
c C sy t j } | j | j d | j d d | _ | j j | _ d | j k } | t } | j
|
| i t | j d 6| j d 6 r¶ t j d | j d t | j d f S| rù | j | | j rù t j d | j d t | j d f St j t j | _ | j | } | d k rkt j d
|
t j d | j } t j | d t | j d f S| | _ | rÂ| j | j d j t j | _ t j d | j | j | f n t j d | j | j f | j | s-t 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 } t' j( } t) j* | _+ d | _, t- | _. d | _/ | j | _ d | j | j | j0 | j1 f | _2 t3 | j2 | _4 | j5 | j6 t7 j8 } | j | _ | j | _ | j0 | _0 | j9 | _9 t- | _: | j | _ d } t# j& | t) j; } t# j< | | j | j } | j5 | | j= | j | } t> j? d d | j@ d t# jA | j | jB f tC jD i | j@ d 6| j d 6t# jA | j d 6| j1 d 6| jB d 6 } t> j? d | | S( Ni i s %sR Rè s player of accid = %s exists!R% s! player of playerName = %s exists!iÿÿÿÿR s# PlayerID Dispatch failed!accid = %sRô sF createNameByFormatPlayerID!accid = %s, PlayerName = %s, newPlayerID=%ss. 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 = %siP s AccID=%s&Name=%s&Sex=%s&Job=%si)# s: OperatorID=%s&Step=%s&AccountID=%s&Flag=1000&DeviceFlag=%si t
|
OperatorIDt RoleIDt AccountIDRÀ R: iO (E R R RÕ Rê Ræ Rè R Rp RØ R R R R R0 t disCreatePlayerError_PlayerExistRñ t' disCreatePlayerError_PlayerNameConflictR R R t CreateRoleTimeR R R t ERROR_NO_65Rì RP t decodet encodeR, RÏ RÛ t
|
adoInsertCR t ERROR_NO_66R t
|
WriteDWORDRA RÇ R t tagDBServerLogRecR} t gstSavePlayerLogR: R RU t Timet MapIDt SexRÀ R¡ RÜ t MsgLenRÊ R@ R t tagDBPlayerInfoLogCreateRolet Facet PlayerRegisterTimet gstSavePlayerInfoLogOnCreateRÉ R7 R: R R8 R9 R: t urllibt urlencode( R] R\ R2 t createPlayert createNameByFormatPlayerIDR` t newPlayerIDR6 Rµ R¶ t missionDictDatat skillDatat bufDatat repeatTimeDatat horseDataR¼ t gmPermitDatat petDataR¾ t normalDictDatat dienstgradDataRÁ t allDatat crct dataCrct dataWithCrcR) t dbServerLogRect createRoleLogRÌ R t
|
playerInfo( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRó ¼ s° #
|
, %# D
|
! &
|
|
c C s= | t } | j i t | d 6d d 6 } | j d k S( NRØ i Rè ( R RH R RI ( R] R\ Râ R` t resultCollection( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRñ 0
|
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 R¥ R> s$ ####reading %s of player %s,cnt = %ss %s( RH Rù RI R R Rr t has_keyR RÛ RV t
|
readRecordRê t adoQueryCustomCt adoQueryCustom( R] Ru t queryR³ R´ RM Ra R% Rx t docCntR) R ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyR 6
|
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 %sRP t PetIDi t TruckIDt OwnerIDs# getMergePlayerDataBuffer_%s_makeSID( i s ( Rë Rì R R= R RÛ RÜ R RV R Rî RÕ R0 RÝ R t hasFieldRP R: R} t makePetIDt makeTruckIDt TructIDR< R¨ Rê ( R] R" R³ RH R´ Rµ R3 R¢ RP RG R) R R5 R¤ t orgPlayerIDt oldPetIDt petIndext
|
oldOwnerID( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyt getMergePlayerDataBufferP
|
s`
|
|
|
|
|
|
|
|
|
|
c C s t j } t j } | j | j d | j t j d | j | j j
|
j t d } | | k r | j | | S| | } | t } t | j } d } t j | | } t j | d } | | j }
|
| j t j | |
|
t j d | d S( s »ñÈ¡¿ç·þÍæ¼ÒÏêϸÐÅÏ¢ i s) getting mergePlayer detail for accid = %sR% s# onGetMergePlayerDetail OK! accID=%sN( RÕ RÖ R t tagPlayerDetailReqRE Rê Ræ R RÛ R Rp RÅ RÆ Rþ RD RA R R R RÇ Rä R} t dgPlayerInit( R] R\ R2 RÖ t getPlayerDetailReqt
|
queryAccidt regPlayerInfoRN R- R. R/ ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRý
|
s"
|
|
c ; C sª t j } t j } | j | j d | j t j d | j | j j
|
j t d } y | j | | } WnV | j t j | t t j d t j d | t t j f } t j | d SXt | d k r|t j } t | | _ xW| D]O} yêt j }
|
g } y | j | | d } WnM | j t j | t t j d t j d | t f } t j | d SXt | d k rt | d k rû| j t j | t t j d t j d | t f } t j | d S| d d |
|
_ n d |
|
_ | d |
|
_ | d |
|
_! | d
|
|
|
_" | d |
|
_# | d |
|
_$ | d |
|
_% | d |
|
_& | d |
|
_' | d |
|
_( | d |
|
_) | d |
|
_* | d |
|
_+ | d |
|
_, | d |
|
_- | d |
|
_. | d |
|
_/ | j0 j1 |
|
Wq t2 k
|
rW} | j t j | t t j d t j3 d | | t f } t j | d SXq W| j4 t j5 | | j6 d St7 j8 } | j | _ d | _9 | t: } t; } t< } | j= | i t> | j d 6| j9 d 6 } | t; k s| j t j | t d S| j? | j i } t j d | | j | f | t< k sÓt j@ | jA stB jC rt jD | _A | jE | t jF d | | jG | j d qn tB jC rÓ| j t j | tH d Sn tI } i | j d 6} tJ } | | } | jK | | t7 jL tM } tN jO | d } | j? | } | pT| d k oT| d | k } t j d | | d | f tQ } | | } | jK | | t7 jR } tN jO | d } | j? | } | pÝ| d k oÝ| d | k } t j d | | d | f tS } | | } | jK | | t7 jT } tN jO | d } | j? | } | pf| d k of| d | k } t j d | | d | f tU } | | } | jK | | t7 jV } tN jO | d } | j? | } | pï| d k oï| d | k } t j d | | d | f tW } | | } | jK | | t7 jX } tN jO | d } | j? | } | px| d k ox| d | k } t j d | | d | f tY } | | } | jK | | t7 jZ }! tN jO |! d }" | j? | } | p| d k o|" d | k } t j d | |" d | f t[ } | | } | jK | | t7 j\ }# tN jO |# d }$ | j? | } | p| d k o|$ d | k } t j d | |$ d | f t] } | | } | jK | | t7 j^ }% tN jO |% d }& | j? | } | p | d k o |& d | k } t j d | |& d | f t_ } | | } | jK | | t7 j` }' tN jO |' d }( | j? | } | p | d k o |( d | k } t j d | |( d | f ta } | | } | jK | | t7 jb }) tN jO |) d }* | j? | } | p%
|
| d k o%
|
|* d | k } t j d | |* d | f tc } | | } | jK | | t7 jd }+ tN jO |+ d }, | j? | } | p®
|
| d k o®
|
|, d | k } t j d | |, d | f te } | | } | jK | | t7 jf }- tN jO |- d }. | j? | } | p7 | d k o7 |. d | k } t j d | |. d | f tg } | | } | jK | | t7 jh }/ tN jO |/ d }0 | j? | } | pÀ | d k oÀ |0 d | k } t j d | |0 d | f | r t j d | ti jj d | tk jk }1 |1 jl tm jn jo tp jq d |1 jr d! d" o^ |1 js d! d" d k }2 |2 r | j t j | tH d Sn | jA t jt k rk | ju | t jv |% }3 |3 r5 |3 jw tx jy k rã | j t j | tH d Sd# tx jz |3 jw |3 j{ f } | j| | | |3 j} | t j d$ | | f q d% } | j| | | d& | t j d$ | | f n, | jA t jD k r | j t j | tH d St7 j~ }4 | j
|
|4 _ | t } |4 j | }5 tN jO |5 d }6 t j d' |6 d | j | | | | | |! |# |% |5 |' |) |+ |- |/ }7 t |7 }8 d& }9 tN j |9 |8 }9 tN j |9 d }9 |9 |7 }: | j4 t j | |: t j d( | | j f d S() Ni s$ getting player detail for accid = %sR s( kick accid = %s reason = %s, error :
|
%sRP s kick accid = %s reason = %si R} RØ RÀ R Rº t STRt PNEt PHYt CONR» R¼ R½ R¾ t WarehouseGoldt WarehouseSilvert
|
FightPowers* exception = %s:kick accid = %s reason = %sR Rè s. accid = %s,playerID = %s, playerDataCntInfo=%ss AccID = %s check SID failed!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§ R RF RE Rê Ræ R R8 R Rp RÅ RÆ t queryMergePlayerListRõ R} RG Rì R R t ERROR_NO_67RÚ RÛ RÜ R t tagServerMergeInfot PlayerCountt tagServerMergePlayert getFamilyLeaderFamilyIDt ERROR_NO_68t ERROR_NO_69t LeaderFamilyIDRP t NameRÀ R Rº t TotalSTRt TotalPNEt TotalPHYt TotalCONR» R¼ R½ R¾ RO RP RQ t PlayersRW t KeyErrort ERROR_NO_70Rä t dgServerMergeR@ R R Rè R R R R R R1 t isAccStateForbiddenR¹ R, R´ t pysSIDCheckErrorForbiddenR3 RÛ RÓ Rí RZ R R R RS R R= Rg 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/ R0 RX RY RZ R RV t
|
has_optiont getintRÒ t extractGMOperR R R R R R¡ t unFobbidenAccR R¯ R° R± RA R RÇ (; R] R\ R2 R§ RH RI t
|
playerListR6 RA t
|
playerDictt singlePlayert leaderFamilyInfot whyR² R` R& Rß R³ t playerDataCntInfot cntErrorR´ R² 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 dbIniRS R£ RÂ RÃ R R, R- R. R/ ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRþ »
|
s¦ + " " %
|
,
|
"
|
"
|
"
|
"
|
"
|
"
|
"
|
"
|
"
|
"
|
"
|
"
|
" "*
|
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( NR Rè i ( R} t pysNormalR¹ R t adoUpdateExCR R Rè R RP RZ R R ( R] R\ R² t gmAccidR6 R` ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRk õ s
|
*c
|
C sà t j d | | | t | | | | f | j | j | d } t j | t j } t j
|
} | j | _ | | _ | | _ | | _ | | _ | | _ | | _ t j | | j | j } | j | d S( Ns` accid = %s playerID = %s isForbidden = %s operTime = %s timeLimit = %s operGMAccid = %s msg = %sR% ( R R8 t ctimeRÓ Rp R RÇ R} t gstAccForbiddenLogR t tagAccForbiddenLogR RP R t OperTimet TimeLimitR R¡ RÉ Ræ Rê RÊ (
|
R] RÚ R RÛ t operTimet timeLimitt operGMAccidR6 RÜ t accForbiddenLog( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyR þ 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 R8 R R¤ RV RÕ R Rg ( R] RÚ t gmOperR¼ R3 t operCntR£ R ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRj s c C s0 | t } t | j i | d 6d g } | S( Nt LeaderIDR} ( t UCN_FamilyInfoRr RH ( R] R\ t leaderIDR` t familyInfoSnap( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRY ' s
|
"c C sb | t } t | j i t | d 6d d 6t j d 6 } | j r^ | j j | d } n | S( s ²éѯ´¦ÓںϷþ״̬µÄ½ÇÉ«ÁбíR i Rè R¹ N( R Rr RH R R} t pysServerMergeRÍ t transform_outgoingRg ( R] R\ RÚ R` Rl ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRT , s
|
|
3 c ( C sz t j } | j | j d | j t j } | j j j t
|
d } | | _ t j } | j r° | | k r° t j d | | j t j | | j t St 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# s°| j" d k rÀt j d qE | j d k rE | j$ t j | t% t SnY| 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|
|
| } t |
|
| d
|
} t t* } |
|
d } | j" d k r t j d qE | j+ d k rt, j- | } d | | | t, j. | | j f } t/ j/ | j0 } i | d 6| d 6| d 6| d 6} t j d | | f yX t1 j2 | } t3 j4 d | d i d | d 6} t3 j5 | d d } | j6 } Wqt3 j7 k
|
rS} t j d | | j | f | j$ t j | t8 t St9 k
|
r} t j d | | j | f qXn t* } | | j: d k r´| j+ d
|
7_+ qE | | _: d | _+ n|| 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|
|
| } t |
|
| d
|
} t t* } |
|
d } | j" d k rût j d qE | j+ d k rct, j- | } d | | | t, j. | | j f } t/ j/ | j0 } i | d 6| d 6| d 6| d 6} t j d | | f yX t1 j2 | } t3 j4 d | d i d | d 6} t3 j5 | d d } | j6 } Wqct3 j7 k
|
r0} t j d | | j | f | j$ t j | t8 t St9 k
|
r_} t j d | | j | f qcXn t* } | | j: d k r| j+ d
|
7_+ qE | | _: d | _+ n| 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 qE | j+ d k r i | d 6t, j. | | j d 6| d 6} y t1 j2 | } t3 j4 d | } t3 j5 | d d
|
} | j6 } | d k rt t j d | | f | j$ t j | t% t SWq q Xn t* } | | j: d k r° | j+ d
|
7_+ qE | | _: d | _+ n| 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 qE | j+ d k r¡ i | d 6t, j. | | j d 6| d 6} y t1 j2 | } t3 j4 d | } t3 j5 | d d
|
} | j6 } | d k r t j d | | f | j$ t j | t% t SWq¡ q¡ Xn t* } | | j: d k rÏ | j+ d
|
7_+ qE | | _: d | _+ na| 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 qE | j+ d k rÀ i | d 6t, j? | | j d 6| d 6} y t1 j2 | } t3 j4 d | } t3 j5 | d d
|
} | j6 } | d k r² t j d | | f | j$ t j | t% t SWqÀ qÀ Xn t* } | | j: d k rî | j+ d
|
7_+ qE | | _: d | _+ nB| 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 rt j d qE | j+ d k rái | d 6| d 6} y t1 j2 | } t3 j4 d | } t3 j5 | d d
|
} | j6 } tA jB | } | jC d! t k rÓt j d | | f | j$ t j | t% t SWqáqáXn t* } | | j: d k r| j+ d
|
7_+ qE | | _: d | _+ n! | t jD 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
|
} n* | t jE 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 qE | j+ d k rxi d" d# 6| d$ 6| d% 6} | jF } | jG d& } x& | D] } | d' | | | f 7} q{W| d( 7} t/ j/ | j0 } | jH i | d 6 y t1 j2 | } t3 j4 d) | } t3 j5 | d d
|
} | j6 } tA jB | } | jC d! d k rjt j d | | f | j$ t j | t% t SWqxqxXn t* } | | j: d k r¦| j+ d
|
7_+ qE | | _: d | _+ n | t jI k rT| 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 } | } | j" d k rÝt j d qE d* } tJ jK t/ j/ d+ | | | f j0 j0 } | | k rE t j d, | | f | j$ t j | t% t Snñ| t jL 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 r0| j$ t j | t% t S|
|
| } |
|
| d
|
} | j } | } | j" d k rvt j d qE d- } tJ jK t/ j/ d+ | | | f j0 j0 } | | k rE t j d, | | f | j$ t j | t% t SnX| t jM 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 qE | j+ d k ryi | d. 6t, jN | d/ 6| d0 6d1 d2 6d3 d4 6} t jO } | tP }! | jQ |! i | d5 6 sd& | d6 <d& | d7 <d& | d8 <n6 | jR | d6 <| jS j t
|
d | d7 <| jT | d8 <y¥ t1 j2 | } d9 | }" t3 j4 |" } t3 j5 | d d
|
} | j6 } tA jB | } | jC d! d
|
k rkt j d: |" | | f | j$ t j | t% t SWqyqyXn t* } | | j: d k r§| j+ d
|
7_+ qE | | _: d | _+ n| t jU 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 qE | j+ d k rÐi | d; 6| j d< 6t, j- | d= 6} yÌ t1 j2 | } tV jW j( d> }# d> jX |# d? d@ | }$ t j |$ t3 j4 |$ } t3 j5 | d d
|
} | j6 } | jY dA d& } | dB k rÂt j d | | f | j$ t j | t% t SWqÐqÐXn t* } | | j: d k rþ| j+ d
|
7_+ qE | | _: d | _+ n2tZ }% t[ }& | j | sá |% tZ k rj t j\ dC | j$ t j | t] t S|& t[ k r§ t j\ dD | j | j$ t j | t^ t StV j_ rá t j dE | j | j$ t j | t` t Sn | j | j j t
|
d k sE t j dF | j j | j j f | j$ t j | t% t S| j' r¥ | j' j( d }' t) |' d? k r¥ t/ j/ |' d
|
j0 | _a | jb |' dG q¥ n tc jd dH dI | j d
|
t, j- | | ja f | je d
|
7_e tf jg tf jh | _i | jj | s8 t j\ dJ | j | j$ t j | t] t S| j t j | | j | t jk k rv t jk jl | n t S(K s ÕʺÅÈÏÖ¤i s% auth mergeServer Player accid = %s...s auth accid = %s-%s...i s 127.0.0.1s iner no checkt 7758520t 1s |i iÿÿÿÿi s gameId=%s&time=%s&uid=%s%st gameIdRU t uidt signs
|
sign %s-%ss( https://sdk-passport.fjsanxia.com/check?t headerss Bearer t Authorizationt timeouts login HTTPError %s:%s-%ss login error %s:%s-%si
|
t tokent product_codes2 http://checkuser.sdk.quicksdk.net/v2/checkUserInfos checktoken fail:%s-%ss1 http://checkuser.happilygame.com/v2/checkUserInfos2 https://hwsdk.happilygame.com/webapi/checkUserInfot statusi%> t app_idt mem_idt
|
user_tokenR% s %s=%s&s( app_key=6290E687980CE9D6421A56F1D6EB0777s- http://g02.api.yiigames.com/api/cp/user/checkt lwo1pt7ndzchxngxvi1myi4d3jm7s4rfs %s%s%ss checktoken fail: sign=%s != %st o696upr9feibuvr022ftbzklo3375ht1t access_tokent areaidt gvers 0.0.0t sdkvert SohaGamet
|
clientnameR t roleidt rolenamet rolelevels' https://soap.soha.vn/api/a/GET/me/info?s checktoken fail:%s-%s-%st tokenkeyt channelt guids /i s /centerapi/checkuser.php?s 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 error(m R t tagDataServerPlayerLoginRE Rê Ræ R R/ R Rp RÅ RÆ R0 RÕ RÖ RÔ R R8 Rä R} t dgPlayerLoginRS RÛ t IDTypeR. Ro t
|
gitFreeSDKR1 R8 R
|
t TokenExpiret Phonet Pswt Adultt IPt RegIPt IsDebugRõ t disPswCheckErrort gitGTGamet ExtraRë RÜ RU RÐ R R9 t GetLoginKeyt md5t hexdigestR R t urllib2t Requestt urlopenR0 t HTTPErrort disTimeErrorR= RÑ t gitGTGameIOSt gitQkGamet gitHYGamet gitHYGMGamet GetLoginKeyByPidt gitHYGTGamet jsonRi R1 t gitMLGTGamet gitMLGTGameJFt keyst sortRb t gitHYYNGamet hashlibt sha1t gitHYEnglisht gitVNGamet GetPlayerServerIDR R R RP RØ Rº t gitX7R, t ReportUrlRZ t replaceR R R0 Rì t disUserNameNotExistR´ t disGMKickR: t SetClientVersionR: R t LogNumR R R t LastLoginTimet adoCheckUpdateCR÷ RW (( R] R\ R2 t authPackt
|
accountRect authAccIDRÖ R` t appTypet redefineIndext extraListR RE t timeIntt opuidR t signStrR t valuesRH RË t responset the_pageRK t nowTimeRJ t keyListt kt timestampt secrett checkSignR¨ Rà t playerColt urlStrt urlListt tmpurlR& Rß t infoList( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRü 4 sê
|
>
|
|
%
|
$ $
|
|
%
|
$ $
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
1
|
1
|
|
|
|
|
|
|
|
|
|
!) # c C sY d } t j | | } t j | d } t j | t | | } | j | | d S( NR% i ( R RÇ RÉ RÜ R? ( R] Ri t
|
fromPacketRM t packBuf( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRä ? s
|
i c C sP d } t j | | } t j | d } t j | | } | j | | d S( NR% i ( R RÇ R? ( R] Ri Rú t disconnectReasonRû ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRõ G s
|
c C sV | j | j | j j | j j | j j | j j | j j | d S( N( RX Rl R R t poolIndexRi t
|
srcSvrTypet
|
dstSvrType( R] Rú Rû ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyR? O s 3c C s@ t j } | j } d } t | } | j | | | | j j j r¯t j d j
|
d | j j j t j
|
d | j j j | j j f | j t j k r(t j d t j d | j j j | j t j f } t j | t j d j d t j t j d d | j | d S| j j t j k r@t j r~| j j j } t j d
|
t | t | f n t j d t j! t" j# t$ | j j j t j! } | | j j% k r¬t j d t j& d | | j j% f } t j | t j d j d t j t j d d | j | d SqÒt j d t j' d | j j% } t j | t j d j d t j t j d d | j | d Sn# t j d j
|
d t j
|
d x t( | j j j D]z }
|
| j j j) |
|
} | j* t+ | j, | j- | j. | | \ } } | rèt j d j
|
d |
|
d | f qèqèW| j j j r·t j d j
|
d t j
|
d | j j j | j j f n t/ j0 } t j1 | _2 d | _3 | j | _ | j4 | j5 | j j6 | j j | j j7 | j j8 | j j9 | j: d S( Ni t MapServerRestoreLogs$ ±£´æMapServer±ÀÀ£Êý¾Ý,Íæ¼ÒÊýÁ¿ÊÇ: %ss7 Saving MapServer Crash Data, count = %d, poolIndex = %dRh sM Saving MapServer Crash Data Error! count = %d version(%d)!=currentVersion(%d)sD ±ÀÀ£Êý¾Ý°æ±¾Ð£Ñéʧ°Ü£¡Èç¹ûÊÇ°æ±¾Éý¼¶£¬ÇëÏÈÓþɰ汾½øÐбÀÀ£Êý¾Ýµ¼È룡s UserLogs\SaveFailDumps# tagMDSaveMapServerCrashData_%d.mdats: crashData.SaveStream.StreamData.getBuffer() = %s, len = %ds CommonDefine.DATASAVE_MARK = %dR sC Saving MapServer Crash Data CRC Error! CalcCRC = %0x, PackCRC = %0xs ±ÀÀ£Êý¾ÝCRCУÑéʧ°Ü£¡s4 Saving MapServer Crash Data CRC Error! PackCRC = %0xs1 ±ÀÀ£Êý¾ÝCRCÔÚÆäËû·þÎñÒÑУÑéʧ°Ü£¡¾ßÌå¿É²é¿´Ö÷ÈÕÖ¾s ÎÞ±ÀÀ£Êý¾Ý!s) hvae processed mapserver empty crash datas µÚ%s¸öÍæ¼Ò,PlayerID = %si s ±ÀÀ£Êý¾Ý±£´æ³É¹¦£¡s: Saving MapServer Crash Data OK! count = %d, poolIndex = %d(; R t tagMDSaveMapServerCrashDataRê RÜ RÕ t
|
SaveStreamt
|
StreamDataR> R t getLoggerR8 R R Rý t VersionNOR t SERVER_DATA_VERSION_NOR R t ERROR_NO_71Rh R RU R RV R t CRCCheckErrorServerTypeR R> R} t
|
DUMPPACKETRÛ RÝ t DATASAVE_MARKR R@ RA t CRCt ERROR_NO_72t ERROR_NO_73RV t AllPlayerStreamt setBufferR R t LenR
|
R RE t dgUpdateMapServerCrashDataRG RS RX Rl R Ri Rþ Rÿ R@ ( R] R\ R2 t crashDataRM R3 RG R6 t debugdatat CalcCRCR t
|
PlayerDataR) R RA ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRø S s` #)4 # &'( #" # +, 3c C s d S( N( ( R] R\ R2 ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\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 Rh 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 tagPlayerViewCacheRk t compressR R t ERROR_NO_75RÚ RÛ Rh R R R t$ GAMESERVER_GAMEWORLD_DATA_VERSION_NOt sendGameServerStringR} t dgGameServerDataR8 RÜ (N R] R\ R2 RH 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 compressDataR6 t SendData( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRú sF
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
"
|
c C sh d } t j | j | \ } } t j | j | \ } } | j | | | j | | | d S( Ni ( R Ré Rê t saveGameServerGameData( R] R\ R2 R3 RH Ri ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRù í s # c C sC | t j k rü t j } | t j | <| j d } t t j | k rü t j j } | j d d d } x\ | D]T } | j | k s{ | j t j k r¨ q{ n t j | j =| d 7} | d k r{ Pq{ q{ Wt j
|
d | | t t j f qü n t j | } | | _ t t | _ | | _ t | j | _ | S( Ni t keyc S s | j S( N( t UpdTime( t r( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyt <lambda> s i id s cacheCntMax=%s,delCnt=%s,%s( RÕ t g_packDataDictR t tagDBPlayerPackDatat getPackDataCntMaxRÜ Rì RÓ RP R R8 Ro RU Rñ t PackDatat PackDataSize( R] R R t pdObjt cacheCntMaxt dataListt delCntt d( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyR s, !
|
) c C s9 | t j k r d St j | } t t | _ | j S( NR% ( RÕ Rô Ro RU Rñ R÷ ( R] R Rù ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyR~ 2 s
|
c C s8 | j r | d k r d Sd S| d k r0 d Sd Sd S( Ni iè i id iô ( RÔ ( R] t cntType( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRö : s c C sÑ t j d i t _ | t } | j i i d d 6d t d d j | j d } zA x: | D]2 } t j
|
} | j | | t j | j <~ qa WWd | j Xt j d t t j t j d d S( NsL --------------------- do loadDBPlayerPackData Start ------------------------i Rð t no_cursor_timeoutt
|
batch_sizeid s PyGameData.g_packDataDict cnt=%ssJ --------------------- do loadDBPlayerPackData End ------------------------( R R8 RÕ Rô t UCN_DBPlayerPackDataRH RS Rù Rö R Rõ R5 RP R< RÜ ( R] R\ R` t cursorRP Rù ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRã G s
|
7 c C sW t j d | t } | j | t j j } t | } | j d } t j d | | f | | k r´ | j d d d t
|
| | } t | } t j d | n d } d } d } x}t
|
rEyî xç | | k r»d } d }
|
g } x | rv| |
|
} | | k rPn | | } | j } t t | } | | | k rRPn | j | |
|
d
|
7}
|
| | 7} qö Wt j d | |
|
| f | sPn | j | t t
|
| |
|
7} qÕ WWn t j | k rÿ| d
|
7} t j d | t j f qÉ n t t j d | j j t j d d | t j f n XPqÉ Wt j d d S( NsL --------------------- do saveDBPlayerPackData Start ------------------------i s docs cnt=%s,maxSaveCnt=%sRð c S s | j S( N( Rñ ( Rò ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRó f s t reverses sort maxSaveCnt docCnt=%si i i s) insert start=%s,insCount=%s,insLen=%ss trycnt=%s,%ss %s.%s, trycnt = %s, %si sJ --------------------- do saveDBPlayerPackData End ------------------------i i ( R R8 R t drop_collectionRÕ Rô Rì RÜ Rö RÓ RS R© Rq RW RY RZ R, R RÚ RÛ R R R® R¯ R° R± ( R] R\ R` Rû R9 t
|
maxSaveCntt max_sizeR¶ RL t insLent insCountt insDocst recIndexRP Rx t docLen( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyt saveDBPlayerPackData[ s`
|
|
|
|
|
|
; c C sÑ | t j k rH t j | | \ } } t j | | \ } } t j | | \ } } t j | | \ }
|
} t j | | |
|
\ } } |
|
rª
|
| t j k st j d t j
|
d | t j f } t j | t j d j d t j t j j t j t j d d | t SyR t j | } | j d d \ } } t | } t j | | | | } WnL t j d t j d
|
t j } t j | t j d j d qÀ
|
Xt j! d t" | d } y[| j# | | t$ t% j& | } | j# | | t' t% j( | } | j# | | t) t% j* | } | j# | | t+ t% j, | } | j# | | t- t% j. | } | j# | | t/ t% j0 | } | j# | | t1 t% j2 | } | j# | | t3 t% j4 | } | j# | | t5 t% j6 | } | j# | | t7 t% j8 | } | j# | | t9 t% j: | } | j# | | t; t% j< | } | j# | | t= t% j> | } | j# | | t? t% j@ | } | j# | | tA t% jB | } | j# | | tC t% jD | } | j# | | tE t% jF | } | j# | | tG t% jH | } | j# | | tI t% jJ | } | j# | | tK t% jL | } | j# | | tM t% jN | } | j# | | tO t% jP | } | j# | | tQ t% jR | } | j# | | tS t% jT | } | j# | | tU t% jV | } | j# | | tW t% jX | } | j# | | tY t% jZ | } | j# | | t[ t% j\ | } | j# | | t] t% j^ | } | j# | | t_ t% j` | } | j# | | ta t% jb | } | j# | | tc t% jd | } | j# | | te t% jf | } | j# | | tg t% jh | } | j# | | ti t% jj | } | j# | | tk t% jl | } | j# | | tm t% jn | } | j# | | to t% jp | } | j# | | tq t% jr | } | j# | | ts t% jt | } | j# | | tu t% jv | } | j# | | tw t% jx | } | j# | | ty t% jz | } | 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® | } | j# | | t¯ t% j° | } t j! d t j d j! d WnO t j± k
|
r
|
t j d t j² d } t j | t j d j d n Xt j d j! d t j! d n t j d 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 } | ryR t j | } | j d d \ } } t | } t j | | | | } Wn6 t j d t jà d t j } t j | q©Xt" | } 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% j0 | } | j# | | t1 t% j2 | } | j# | | t3 t% j4 | } | j# | | t5 t% j6 | } | j# | | t7 t% j8 | } | j# | | t9 t% j: | } | j# | | t; t% j< | } | j# | | t= t% j> | } | j# | | t? t% j@ | } | j# | | tA t% jB | } | j# | | tC t% jD | } | j# | | tE t% jF | } | j# | | tG t% jH | } | j# | | tI t% jJ | } | j# | | tK t% jL | } | j# | | tM t% jN | } | j# | | tO t% jP | } | j# | | tQ t% jR | } | j# | | tS t% jT | } | j# | | tU t% jV | } | j# | | tW t% jX | } | j# | | tY t% jZ | } | j# | | t[ t% j\ | } | j# | | t] t% j^ | } | j# | | t_ t% j` | } | j# | | ta t% jb | } | j# | | tc t% jd | } | j# | | te t% jf | } | j# | | tg t% jh | } | j# | | ti t% jj | } | j# | | tk t% jl | } | j# | | tm t% jn | } | j# | | to t% jp | } | j# | | tq t% jr | } | j# | | ts t% jt | } | j# | | tu t% jv | } | j# | | tw t% jx | } | j# | | ty t% jz | } | 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® | } | j# | | t¯ t% j° | } t j! d Wq©t j± k
|
rt j d t jÄ d } t j | q©Xn t j! d | d k rNt³ j´ } t jµ | _¶ t jÅ | _¸ d | _¹ | jº | j» | j¼ j½ | j¼ j¾ | j¼ j¿ | j¼ jÀ | j¼ jÁ | j t j! d | n | jÆ | no | t jÇ k r| jÈ | | d t% jÉ | n@ | t jÊ k r¼| jÈ | | d t% jË | n t jÌ d | d S( NRh sW Save game server crash data error:data version conflict!versionNO = %s, db version = %st GameServerDataRestoreLogsJ ±ÀÀ£Êý¾Ý°æ±¾ºÅУÑéʧ°Ü(Èç¹ûÊǸüа汾£¬ÇëÆô¶¯¾É°æ±¾·þÎñÆ÷µ¼Èë±ÀÀ£Êý¾ÝÊÔÊÔ)t tagGDGameServerGameDatas 0.mdats |i R s4 Decompress game server world data failed!error =
|
%ss! ±ÀÀ£Êý¾Ý½âѹʧ°Ü£¬¿ÉÄÜÊÇÊý¾ÝËð»µ.s= Decompress game server world data success, len = %d!saving...i s Save game server world data ok!s ϵͳ±ÀÀ£Êý¾Ý±£´æ³É¹¦!s Short data buf, ignore...s ±ÀÀ£Êý¾Ý¿ÉÄܲ»ÍêÕûs ±¾´ÎGameServer±ÀÀ£Êý¾Ý±£´æ³É¹¦£¡s Save game server player data ok!s ÎÞ±ÀÀ£Êý¾Ý...s5 Decompress game server world data failed! error =
|
%ss= Decompress game server world data success, len = %s!saving...s Empty crash data,ignore...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 Rh R R R RU RX RY RZ R RV t DUMP_PATHRS Rk Rl Rë Ro RÜ t a2b_hext ERROR_NO_77RÚ RÛ R8 RÜ t savegameServerWorldDataR 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/ R0 R1 R2 R3 R4 R5 R6 R7 R8 R9 R: R; R< R= R> R? R@ RA RB RC RD RE RF RG RH RI RJ RK RL RM RN RO RP RQ RR RS RT RU RV RW RX RY RZ R R[ R\ R] R^ R_ R` Ra Rb Rc Rd Re Rf Rg Rh Ri Rj Rk Rl Rm Rn Ro Rp Rq Rr Rs Rt Ru Rv Rw Rx Ry 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¡ t ShortBuft ERROR_NO_78R RE RF RG R© R; RS RX Rl R R Rý Ri Rþ Rÿ R@ t ERROR_NO_80t ERROR_NO_81R R t dgPlayerMailListt savePlayerMailDataR t dgPlayerMailItemListR R0 ( R] R\ R2 RH R3 t saveTypeRH t markt versionNOR- t gameDataLent gameDataR6 t decompressGameDatat pyDataLent pyDataHext gameDataReadPosRA t decompressGameDataLen( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRï 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 R8 RP t adoDeleteByIndexRV R RÕ RW R© RS RY RZ Rª R« t PyMongoErrorR, R R R® R¯ R° R± R R t ERROR_NO_152( R] R RH R3 R² R³ R\ t recCntR` RP Ra R R¤ R¶ R· R6 ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\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 R8 R} R R R= R RV R RÕ t
|
dumpStringR R® t _UserCtrlDB__name_R° R± RW R© RS Rq RY RZ Ro t matht ceilt floatR< Rª R« R¬ R, R R R¯ ( R] RH R3 R² R³ R\ R, R` Ra RP R R¤ R¶ R t
|
docsStrLent insertTimest perTimeCountRL R R· ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\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ÿÿÿÿRP t FriendIDi s %s.%s:PlayerID = %si s5 delete failure!PlayerID = %s, error = %s, trycnt = %d( RÜ R} R R R= R R8 RV RE RS Rd RP R6 Rª R« R¬ R, R R R® R¯ R° R± R ( R] RH R3 t
|
packStructR² R\ R, R` RP R R¤ R¶ R· ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyt savePlayerDeleteFriendData 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= R8 RV R RÕ R} R t adoInsert( R] RH R² R³ R\ R6 R3 R, R` RP t datalenR R¤ ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyR < 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 tagBDStringTypeSendRE R R/ RÕ R R R R R t RegisterTimeR. R Rõ R} t dgInsertAccRZ Rä RS R R t ERROR_NO_83R0 RÚ RÛ R (
|
R] R\ R2 RH R3 R; t oTypeSendt AccR` R6 ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyR Y 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 R RP R s; OnPlayerIDMarkDeleted failed! Playerid = %d, exception = %s( Rê RÜ R t tagMarkPlayerDeletedRE R R R RP R R1 RZ R, R´ Rè R R R RS R R t ERROR_NO_84RÚ RÛ R ( R] R\ R2 RH R; R3 t oMarkPlayerDeletedRu t oPlayert SidErrorCntR6 ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyR p 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 tagDGetValueByAccRE Rê t UCN_AccCoinsR t tagAccCoinsRA R R R R8 RZ R} R t GoldCoinsR t tagDServerValueTypet dgCoinR: t ValueR? R@ RS R R t ERROR_NO_85RÚ RÛ ( R] R\ R2 t oDGetValueByAccRu t oAccCoinst oSvrValueR6 ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyR s(
|
# "c C sr y4t 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 t j } | j | _ | j | _ | j! t" t 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 tagMDCoinChangeReqRE Rê R R8 RA RP t CoinRH R RI R R RK R} t dgCoinChangeResultR: R R? R@ RZ R RJ t UseGoldCoinst adoUpdateR R t ERROR_NO_87RM RL R t tagDBPlayerLogInfoOnCoinChangeRÊ RÆ t" gstSavePlayerInfoLogOnOnCoinChanget ERROR_NO_88RÚ RÛ RS ( R] R\ R2 t oCoinChangeReqRu RP t retPackR6 t oDBPlayerLogInfoOnCoinChange( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyR ³ sN #
|
) . $" 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 tagBDCheckNameExistRE Rê R t tagDBPlayerNameIsExistR R R] RØ Rè R R} t dgCheckPlayerExistRG RÜ t NameLenR R RS RP R? R@ R R t ERROR_NO_89RÚ RÛ R RZ RS ( R] R\ R2 R R\ RE Ru R6 ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyR õ s&
|
/ " c C sh t j d t j rd y t j | Wn6 t j d t j d t j
|
} t j | n Xd Sd S( Ns process gstOnDay in the future!R s2 OnDay EventProcess.OnDayProcess catch exception
|
%s( R R0 R, t EventShellEnableR t OnDayProcessR R t ERROR_NO_161RÚ RÛ ( R] R\ R2 R6 ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\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= R R R¤ R R t ERROR_NO_90R RZ RS ( R] R\ R2 RH R3 t PlayerIdR6 ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyR s ( c C s t j } | j | j | t } | j i t | j d 6 j } t j
|
} t j | _ | | _ | j | | j t S( NR ( R RG RE Rê t UCN_ExpiationRH R RA RI R RK R} t dgGetExpiationCountR: RM R? R@ RS ( R] R\ R2 R Ru t recCountR\ ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyR # s
|
% c C s t j } | j | j | t } | j i t | j d 6 j } t j
|
} t j | _ | | _ | j | | j t S( NR ( R RG RE Rê t UCN_PetExpiationRH R RA RI R RK R} t dgGetPetExpiationCountR: RM R? R@ RS ( R] R\ R2 R Ru Rj R\ ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyR 1 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 xtF | j D]} | j@ | } tG jH } tI | _J | j | _ | j | _ | j$ | _$ | j/ | _/ | j | _ | j | _ | j | _ | j | _ | j | _ | j | _ | j | _ | j | _ | j | _ | j | _ | j | _ | j | _ | j | _ | j | _ | j | _ | j | _ | j! | _! | j" | _" | j# | _# | j% | _% | j& | _& | j' | _' | j( | _( | j) | _) | j* | _* | j+ | _+ | j, | _, | j- | _- | j. | _. | j0 | _0 | j1 | _1 | j2 | _2 | j3 | _3 | j4 | _4 | j5 | _5 | j6 | _6 | j7 | _7 | j8 | _8 | j9 | _9 | j: | _: | j; | _; | j< | _< | j= | _= | jK tL t jM | j q¶WtN S(4 Ni R t ExpiationIndext ExpiationTimeR» R¼ R½ R¾ t
|
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 (O R t tagMDGetExpiationExRE Rê R> R t tagDMGetExpiationExResultR} t dgGetExpiationR: Rh RH R RA t tagExpiationRm R R Rn R» R¼ R½ R¾ Ro Rp Rq Rr Rs Rt Ru Rv Rw Rx Ry 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" t DatasRW Rd RZ R? R@ RV R t tagExpiationLogRU t ReceiveDateRÊ RÆ t gstGetExpiationLogRS ( R] R\ R2 R t needCountRA R` t
|
expiationst colDelt curDatat expiationR t dbDatat saveLog( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyR ? sò
|
|
$c C s t j } | j | j | t } t j } | j | _ | j | } t j
|
} t j | _ | j | _ | j | _ | j | | j | s¦ t St j } t | _ | j | _ | j | _ | j | _ | j | _ | j | _ | j | _ | j | _ | j | _ | j | _ | j | _ | j! | _! | j" | _" | j# | _# | j$ | _$ | j% | _% | j& t' t j( | j | t) S( N(* R RG RE Rê Rk R t tagPetExpiationRA R R R< R} t dgGetPetExpiationR: R Ræ R R? R@ RZ R t tagPetExpiationLogRU R Rm Rn t NPCIDt Lvt Expt BindTypet UseCreatorDrugCntt Friendlinesst SkillIDListt HPTalentt PhysicAtkTalentt MagicAtkTalentt PhysicDefTalentt MagicDefTalentRÊ RÆ t gstGetPetExpiationLogRS ( R] R\ R2 R Ru R£ R) RA R¤ ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\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 RZ t UCN_ServerDataVersionNOR` R: t ERROR_NO_92RS ( R] R\ R2 t dbRecvR6 Ru ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyR¬ 9 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 LogIDR¡ s: OnMapServerInfo failed:LogID = %s, LogIndex = %s, Msg = %s( R R< RE Rê R Rº RÕ R R R t ERROR_NO_93R RZ RU R R R, t LOGINDEX_FEEDt LOGINDEX_STEPR» t UCN_DBMapServerInfot adoCheckUpdateExR¼ R R¡ t ERROR_NO_94RS ( R] R\ R2 RN R£ R6 Ru ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyR M s !
|
,. c C s yBt j d t j } | j | j t j } d | j | j k r t
|
j d t
|
j d t | j t | j f } t j
|
| t S| t } t j } | j | _ | j | } | rä | j | j 7_ n d | _ | j | sAt
|
j d t
|
j d t | j t | j f } t j
|
| t SWnW t
|
j d t
|
j d t | j t | j t j } t j
|
| t SXt j d t S( Ns% begin process gstUpdateTotalSavePointiÿÿÿÿR s? tagDBPlayerSaveCoinLog:lack of pack data:data = %s,datalen = %di s2 UpdateTotalSavePoint failed,data = %s,datalen = %dsM OnUpdateTotalSavePoint throw a exception, packdata = %s, packdata len = %d
|
%ss# end process gstUpdateTotalSavePoint( R R8 R R< RE Rê R t tagDBPlayerSaveCoinLogRÕ R R R t ERROR_NO_95RÝ RÜ RZ R. R R/ R R1 t TotalSavePointRS Râ t ERROR_NO_86t ERROR_NO_96RÚ RÛ RS ( R] R\ R2 RN R£ R6 Ru t dbDocRà ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyR c s4 4
|
4 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 tagDBGetMailListReqRE Rê t UCN_DBMailListRH RP R} t wmtSaveRI t MAX_PLAYER_MAIL_COUNTt pmiFullt wmtUnReadedt pmiNewLettert pmiNullR t tagPlayerMailInfot InfoTypeR Rþ R RZ t stRoutet RouteServerIndexRý R¥ t dgPlayerMailStateR@ R R t ERROR_NO_97RÚ RÛ R RZ RS ( R] R\ R2 RN Ru t docCountt stateRA R6 ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\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 tagDBGetMailDetailReqRE Rê t UCN_DBMailItemListR R t MailIDR± RÌ R R R R0 RZ R t tagDBMailDetailViewR} t dgMailDetailR: t MailDetailDataRÜ t MailDetailDataLent MailItemDatat MailItemDataLenR? R@ R R t ERROR_NO_98RÚ RÛ RS (
|
R] R\ R2 RN Ru t dbMailItemListRµ t
|
dbMailListRA R6 ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\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Ë RE Rê R t tagDBGetPlayerMailR} t
|
dgMailListR: RÌ RH RP t MailExistTimet tagDBMailInfoR RÝ RÊ Rè Ré Rê Rç Rë t MailRW RÜ t MailCountR? R@ R R t ERROR_NO_99RÚ RÛ R RZ RS (
|
R] R\ R2 RN RA Ru Ra Rx t mainInfoR6 ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\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 dataR i Rè s" not exist player role , accid = %sRÝ s+ OnAddPlayerMailByAccID: exist a same mailidRP s+ OnAddPlayerMailByAccID throw a exception
|
\s(/ RZ R R< RE Rê R R RS R t tagDBMailList_SaveSysMailRÕ R R t ERROR_NO_100R R RH R R RI R8 RÌ RÝ t ERROR_NO_101R t SenderIDRÉ RÊ Rè Ré R Rê Rç t ContentRÜ t
|
ContentLenRë t ContentUseSysMessageR: t ERROR_NO_102RÚ RÛ R} t dgAddPlayerMailByAccIDR: R? R@ ( R] R\ R2 R) RA RN t curMailR6 Ru Ra Rx ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyR å 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 tagDBDeleteMailRE Rê RÌ R R RÝ R) R R t ERROR_NO_103RÝ R RZ RÜ R t ERROR_NO_104t ERROR_NO_105RÚ RÛ RS ( R] R\ R2 RN Ru Rx R6 ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyR 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 tagDBUpdateMailRE Rê RÌ R R RÝ R R RU R RV R R R R t ERROR_NO_106R RZ t UpdateMailTypeRÊ t UpdateLetterTypeRê t GetAllMoneyR t
|
ReturnMailR÷ RÉ Rç RV RÝ t ERROR_NO_107t
|
GetAllItemRÜ R) t ERROR_NO_108t ERROR_NO_109RÚ RÛ RS ( R] R\ R2 RN Ru Rx R6 ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\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( NR i Rè RP RÉ s $neRÊ i R s' OnQueryCanSendMail throw a exception
|
%s( R R^ RE Rê R R_ R} t dgQueryCanSendMailRG R] RÜ Ra R RH R RI RP RS RÌ RÍ RÎ R? R@ R R t ERROR_NO_110RÚ RÛ R RZ RS ( R] R\ R2 RN RA Ru Ra RI R6 ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyR o 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 ExpiredTimeR t IsAccepti s $seti R s6 OnAccIDSendPrize!Update failed!AccID = %s, trycnt = %dt
|
CheckValuet PrizeIDt PrizeNumRs s% OnAccIDSendPrize throw a exception
|
%s(' R t tagDPlayerGetItemR} t dgAccIDSendPrizeR: RS R RG RE Rê t UCN_AccIDSendPrizeRb RU R RA RZ Rª R« R¬ R, R R R R t ERROR_NO_111R RH Rù RI t ItemIDR> Rs t ERROR_NO_112t RemainItemCountt ERROR_NO_113RÚ RÛ R? R@ ( R] R\ R2 RA Rà RN Ru R¶ R6 Ra Rx R ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\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ÿÿÿÿR i R g @@s4 OnCheckItemPrize db process time = %s, PrizeCnt = %ss sendString process time = %sR s% OnCheckItemPrize throw a exception
|
%s( R RG RE Rê t timeitt default_timerR RH R RA RI R, t ProfileThresholdR R0 R RK R} t dgCheckItemPrizeResultR: RM R? R@ R R t ERROR_NO_114RÚ RÛ RZ RS ( R] R\ R2 RN R t startTickRu t PrizeCntt processTimeRA R6 ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\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 RG RE Rê R. R R/ RA R0 R R R R1 Rà R= R Rõ R} R´ R R8 RZ Rá R3 Rä t dgPlayerAccLoadR R t ERROR_NO_115RÚ RÛ RS ( R] R\ R2 RN Ru Rx t strNowR6 ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\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& St' j( } | j | _) | j | _ d | _* t | _+ | j | _ | j
|
| _, | j- t" t# j. | j | j | _ | j j | _ | j | _ | j
|
| _ d
|
| _ | j! | t" t# j$ | j% Wn7 t/ j0 d t/ j1 d t2 j3 } t j/ | t& SXt4 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 Õ!(5 R R< RE Rê t tagIRAddItemR R R0 RA R t ItemCntR R t tagAccIDSendPrizeR t GetTransactionIDStrR R R R RU R t PrizeReasonR t SendPrizeTimeRs R t tagIAddItemResultR: t Lengtht AccLenR> RS R? RÆ R} t dgAddAccItemOKR@ RZ R t tagAccTransactionLogt TransactionIDt
|
OperReasont ProcessTimet ItemCountRÊ t gstItemTransactionLogR R t ERROR_NO_116RÚ RÛ RS (
|
R] R\ R2 RN t recvDataRu Rx RA t curLogR6 ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyR$ s\ #
|
) $" 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< RE Rê R t tagDSAccount_UpdateTelLockStateRÕ R R. R/ R R0 R1 t TelLockStateRâ R R t ERROR_NO_117R RZ t ERROR_NO_118RÚ RÛ RS ( R] R\ R2 RN R7 Ru Rx Rà R6 ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyR% Q 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< RE Rê R t tagDSAccount_UpdateAdultRÕ R R. R/ R R0 R1 Rº Râ R R t ERROR_NO_121R RZ t ERROR_NO_122RÚ RÛ RS ( R] R\ R2 RN R7 Ru Rx Rà R6 ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyR& w 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 Rm i i R s# OnAddExpiation throw a exception
|
%s( R R< RE Rê Rh R R RÕ R R R, t tagExpiation_ExpiationIndex_FEEDt tagExpiation_ExpiationIndex_STEPRm R: t ADOResultR} t dgAddExpiationOKR: RÜ R R? R@ R R t ERROR_NO_123RÚ RÛ R RZ RS ( R] R\ R2 RN Ru Rx RA R6 ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\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¥ Rm i i R s& OnAddPetExpiation throw a exception
|
%s( R R< RE Rê Rk R R¥ RÕ R R R, t# tagPetExpiation_ExpiationIndex_FEEDt# tagPetExpiation_ExpiationIndex_STEPRm R: RB R} t dgAddPetExpiationOKR: RÜ R R? R@ R R t ERROR_NO_124RÚ RÛ R RZ RS ( R] R\ R2 RN Ru Rx RA R6 ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\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< RE Rê R t tagDBPlayer_DeleteRoleUpdateRoleRÕ R Rõ R} t dgServerMergeDeleteRoleR R t ERROR_NO_125R RZ RS R R t DeletePlayerIDRP R1 Rè R3 t UpdatePlayerIDR» R¼ R½ R¾ RO RP Rª R« R¬ R, R t ERROR_NO_126Rä t ERROR_NO_127RÚ RÛ ( R] R\ R2 RN R7 R6 R¶ Ru Rx t Rett updatedoc( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\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< RE Rê R t tagDBPlayer_ChangeAccStateRÕ R RS R R RP R1 R¹ R3 Rª R« R¬ R, R R R t ERROR_NO_128R Rõ R} t dgServerMergeUpdateAccStateRZ Rä t ERROR_NO_129RÚ RÛ (
|
R] R\ R2 RN R7 R¶ Ru Rx RP R6 ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyR* 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< RE Rê R t tagDBPlayer_ChangeNameRÕ R R R8 RP RØ RS R RH R RI RB R} t dgServerMergeChangeNameR: RÜ R R? R@ Rª R« R¬ R, R R R t ERROR_NO_131RZ t ERROR_NO_132RÚ RÛ ( R] R\ R2 RN R7 R¶ Ru RA R6 ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyR+ A 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< RE Rê R RZ R R R, t tagDBImpeach_ImpeachIndex_FEEDt tagDBImpeach_ImpeachIndex_STEPR[ t UCN_DBImpeachR: R R t ERROR_NO_133R RZ t ERROR_NO_134RÚ RÛ RS ( R] R\ R2 RN Rx Ru R6 ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyR, s$
|
" c C sR y t j | | Wn7 t j d t j d t j } t j | t SXt S( NR sB OnGMToolCmdUserDBRequest Catch a unexpetcted exception, error = %s(
|
R R- R R t ERROR_NO_172RÚ RÛ R RZ RS ( R] R\ R2 R6 ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\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 | |
|
| j | | | t j t j t j |
|
j t j d | j t S( Ns OnMergerChildToCenter inRö i iÿÿÿÿs0 OnMergerChildToCenter sendString toGameServer %s( R RÛ R Rÿ R Rê R t tagLPStringDataRE R t tagDGMergerChildToGameStringDataR} t dgMergerChildToCenterR: R R t" _UserCtrlDB__processMergerChildMsgR R R RZ R[ R@ RS ( R] R\ R2 R R R R
|
RM RN R3 RA ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyR. ¯ s( c C s¨ | j s d St j | j } t | t s2 d S| j d d } | j d i } | s` d S| t j k rÐ | j d d } | j d d } t j d | | t
|
| f | rÌ | j | | n d S| t j k rN| j d g } g } x- | D]% }
|
| j |
|
rþ | j |
|
qþ qþ W| | d <t j d
|
| | | f n% | t j k rst j | | d <n | | d <t j | d | _ t
|
| j | _ d S( Nt MsgTypeR% R R i R s3 ¿ç·þdb¶îÍâ´¦ÀíÍÆË͵Ĵò°üÊý¾Ý: %s,playerID=%s,len=%st pullPlayerIDListt dbPackDataIDListsJ ¿ç·þdb¶îÍâ´¦ÀíÀÈ¡´ò°üÊý¾Ý±ê¼Ç: %s,pullPlayerIDList=%s,dbPackDataIDList=%sR i ( R Rh Ri Rm Rn R1 R} t ClientServerMsg_PlayerPackDataR RÛ RÜ R t' ClientServerMsg_PullOtherPlayerPackDataR~ RW t ClientServerMsg_GMCMDR t ClientGMCommandt dumpsR ( R] RN RA t msgDictt msgTypet msgDataR R Rg Rh t tagPlayerID( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyt __processMergerChildMsgÍ 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 tagLPPlayerDataRE R t tagDMMergePlayerDataR} R R: t gmMergePlayerDataR R R RP R R R RÕ R[ R@ RS ( R] R\ R2 R R R R
|
RM RN R3 RA ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\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 R Rè s= DumpSinglePlayerDataByAcc Exception accid = %s,playerID = %sRP s gmIP cnt = %st DumpPlayerDatas %s.pdsavet wbiÿÿÿÿ(= R R8 R R R Rè R R R R R RI RP R R R RS 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¯ Rp R° R± RÛ Rê RX RY RZ R RV R\ t mkdirRj t structt writet flushR< (* R] R\ R R² R` R& Rß R³ R´ Rµ Rs R¶ Ru R· Rv R¸ Rw R¹ Rx Rº Ry R» Rz R¼ R{ R½ R| R¾ R} R¿ R~ RÀ R RÁ R RÂ RÃ R R, t DumpDirRp Ry ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\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( NRv i s %s.pdsaveR% Rf iÿÿÿÿs$ Saving player data,playerID = %s....(8 RX RY RZ R RV R\ Rx RZ Rj R0 R< R R RÕ RÜ R R8 RP R Rp R Râ R R R RS R R R R R R R R R R R¡ R¢ R R£ R¤ R R= R¯ RV R¥ R¦ R§ R¨ R© Rª R« R¬ R R® R
( R] R\ R R| t FileDirR; Rp Rà R3 Rá R` R R R ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyt SaveSinglePlayerDataFromDumpFile sZ
|
|
|
|
|
,)))))) ) #)))))(v R¯ t
|
__module__R| RÔ Rà Rä Ræ R7 Rg Rí R^ Rï Rð R R Rñ Rò Rö Rå Rõ Rô R÷ R R/ RC R R
|
Râ Rs RW RS RR R RZ R R R RB RÓ RÑ R Rç R R Rÿ R Rþ R R R7 Ró Rñ R RE Rý Rþ Rk R Rj RY RT Rü Rä Rõ R? Rø Rû Rú Rù R R~ Rö Rã R Rï R- R R8 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. Re Ró R} R ( ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRz ì sô a ÿ ¶
|
' & @ " I # 8 0 : +
|
3 K 6 * o p ^ K
|
, 0
|
t D ' ÿ ; ÿ ÿ ÿ = ÿ Z ) 8 ÿ # + ; ! ' B
|
Ï + " ! " 8 5 ! @ % = & # C % R ) mc C s d d l } | j d d S( Niÿÿÿÿt pause( RX t system( RX ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyt testÍ s t __main__([ RX Rk RU Ré RÜ RÎ RÂ Rª R{ RÕ t DBCommon.CommonDefineR} t DBCommonR R R R R R t CommonR R R R
|
t ProtocolR R R R t CollectionsR R t MangoDBCommonR R R R R R t ServerClientShareDefineR R/ t
|
__import__R, t ctypesR RÚ t
|
EventShellR R R° t Collections.CollectionDefinet NetR t GMToolLogicProcessR t GMR R RÇ R: R` R RÄ RÏ Rh R0 t sysRÕ RË Rl Rq Rr Rp RÔ R< RÙ RØ RD t MergeRegPInfoIndex_GroupIDRL R t allocate_lockRQ Rd Ra Rj Ry Rz R R¯ ( ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyt <module> s¢
|
|
."".
|
|
, & . ÿ ÿ ÿ ÿ ÿ ÿ ÿ ÿ ÿ ÿ ÿ ÿ ÿ ÿ ÿ ÿ ÿ ÿ ÿ ÿ ÿ ÿ ÿ ÿ ù
|
