ó
|
æígc @ sB 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 l m8 Z8 d d l9 Z9 d d l: Z: d d l; Z; d d l< Z< d d l= Z= d d l> Z> d d l? Z? d d l@ Z@ d d lA ZA d d lB ZB d d lC ZC d d d d d d g ZD d ZE d ZF d ZG e+ jH aH eI d \ ZJ ZK ZL ZM d ZN d d lO ZO eO jP aQ eO jP aR d ZS d ZT d ZU d e j f d YZV d ZW eX d k r>eW 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 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 CheckGameVersionJ sB c C s t j t | _ t j d d d l } d d l } t j } t j
|
} | | f } d } yë | j | j | j } | j | d } | j | | j | }
|
t j d |
|
t |
|
} | r<| d r<| d } | d } g } x/ t | | d D] } | j i | d
|
6 qW| t } | j | q<n | j Wn7 t k
|
rm} t j d | n t j d n Xt | _ t j d S( Ns IDDispatch CallDispatchPlayerIDiÿÿÿÿi t PIDs IDDispatch recv:%sR( t minIDt maxIDi t PlayerIDs5 IDDispatch CallDispatchPlayerID Connect Exception %ss: IDDispatch CallDispatchPlayerID Connect unknown Exception( t lockPlayerIDt acquiret Truet isDispatchingPlayerIDR R7 R* t timeR+ R, R- R2 R3 R4 R5 R6 R8 t xranget appendt UCN_Dispatch_PlayerIDt insertR; R< R t Falset release( t dbt selfR* RT R= R> R? R@ RF RG RH RI RM RN t recst idt
|
collectionRJ ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyt CallDispatchPlayerIDy sD
|
|
|
|
|
|
c C s® t j t | _ t j d d d l } d d l } t j } t j
|
} | | f } d } y| j | j | j }
|
|
|
j | d } |
|
j | |
|
j | } t j d | t | } | rR| d rR| d } | d } g } x/ t | | d D] } | j i | d
|
6 qW| t } | j | | j | | | | qRn |
|
j Wn7 t k
|
r} t j d | n t j d n Xt | _ t j d S( Ns IDDispatch CallDispatchFamilyIDiÿÿÿÿi t FIDs IDDispatch recv:%sR( RM RN i t FamilyIDs5 IDDispatch CallDispatchFamilyID Connect Exception %ss: IDDispatch CallDispatchFamilyID Connect unknown Exception( t lockFamilyIDRQ RR t isDispatchingFamilyIDR R7 R* RT R+ R, R- R2 R3 R4 R5 R6 R8 RU RV t UCN_Dispatch_FamilyIDRX t CallBackToSendFamilyIDPackR; R< R RY RZ ( R[ t fromPackt typeR\ R* RT R= R> R? R@ RF RG RH RI RM RN R] R^ R_ RJ ( ( 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 hasattrRR t getattrRh 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 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+ Z. d, Z/ d- Z0 d. Z1 e d/ Z2 e d0 Z3 d1 Z4 d2 Z5 d3 Z6 d4 Z7 d5 Z8 d6 Z9 d7 Z: d8 Z; d9 Z< d: 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 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 RS(l 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( NRy 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 encodingRY RS Rd t loginHeapRT 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Ó M 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_mergeRegisterPlayerDictRT RÑ t itemst MergeRegPInfoIndex_LogoutTimet MergeRegPInfoIndex_LoginTimet popR t debugt len( R\ RÕ Rr t Def_CleanTimet accIDt packInfo( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyt PopOfflineMergePlayerS s c C s- t j s) t t _ t | j | n d S( N( RÔ t g_UserCtrlDBFirstInitRR RK t _UserCtrlDB__PlayerBackupSave( R\ R[ ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyt onConnectedOKk 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 OnGeneralDBOperRR RÂ t OnGameServerToDBLogicRº t OnMergeQueryRegisterResultR¹ t OnMergeRegisterPlayerByCacheRÁ t OnMergeChildToCenterPlayerDataR¶ t OnQueryNewGuyCardStateR¿ t OnQueryRechargeRÀ t OnFinishRechargeR· t onCheckUpdateNewGuyCardStateR~ R7 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ã RY 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 requestLogicProcessr 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 FamilyIDListRV RÛ t Countt
|
sendStringt GetBuffer( R\ Rg R7 RM RN t sendPackR^ ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRf ' 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 dispatchRb s# CallType 0 sendPack.FamilyIDList %ss CallType 1 need dispatch( Ræ R t tagGDRequestCanUseFamilyIDListt ReadDataR RÚ t OutputStringt CallTypeRe t findt countRd t threadingt ThreadRi t startR R4 R| R5 R6 R7 R9 RV RÛ R: R; R< ( R\ R[ R. t buft recvPackR/ R_ R( RF t tR= t rec( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRé 1 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 dgDBOperResultR6 t Resultt ResultSetRÛ t ResultSetLent ErrMsgt ErrMsgLent packSendt atMergeLogicR t stGamet stDataR< ( R\ R R( t resultSett errMsgR= ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyt sendGameServerDBOperResultX 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!RX 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!RD t fieldss %s.find(%s) failed!s oper %s not support!( Ræ R t tagGDGameServerGeneralDBOperRA R RÚ RB t Nonet cPicklet loadst OperDictR< R, t
|
NeedReturnRZ t getSessionIDt
|
isinstancet dictR0 t
|
basestringt lowerR\ t strRX RY RR R^ R` RD t list( R\ R[ R. RI RJ R/ t operDictRJ t colNamet colR[ R( t errorMsgt doc_or_docst docR_ t
|
spec_or_idRa RX ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRë c s
|
|
|
|
|
|
c C s | j } t j } d } | j | | t j d | j | j d k r | j | | j \ } } | j
|
| j | | t j | d Sd S( Ni s pack = %s( Ræ R t tagGDGameServerToDBLogicRA R RÚ RB t QueryTypet GetPlayerDataByPlayerIDt IDt SendGameServerToDBLogicResultRh RÊ t b64encode( R\ R[ R. RI RJ R/ R( t
|
playerData( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRì ô s %c C s« t j } t j | _ | | _ | j | _ | j | _ | j | _ | j | _ | | _
|
t | j
|
| _ | j | d d t j t j t j | j t j d d S( Ni s" »Ø¸´ SendGameServerToDBLogicResult( R t tagDGGameServerToDBLogicResultR| t dgDBGameServerToDBLogicResultR6 RO Ry Rw t DataLent DataRP RÛ RQ RT t atInnerR RV RW R< R RÚ ( R\ R R( RJ RG R= ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRz 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( NRO s0 GetPlayerDataByPlayerID Exception playerID = %si R$ s
|
accid = %si ( i s (* R t tagDBPlayerRO t UCN_DBPlayert
|
adoLoadCExR R, R7 t AccIDt UCN_RoleItemt readPlayerPackSaveDatat tagRoleItemRR 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 tagDBGMIPRl t
|
UCN_DBGMIPt adoQueryIndexRæ ( R\ R[ t playerIDt 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.pyRx 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 tagLPQueryRegisterResultRA R
t stript chrR RÚ Rh t MergeProxyClientMgrt getMergeProxyClientMgrt findClientBySessionIDR, R t tagMPQueryRegisterResultR| t dgMergeQueryNewAccountR6 R0 RO RT R R RU R t stNoSenseR< t AccountRÛ t
|
AccountLent Pwdt PwdLen( R\ R[ R. RÕ RI RJ R/ RÝ t clientSessionIDRF R= ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRí Q 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 tagLPRegisterPlayerRA R t tagMPRegisterPlayerResultR| t dgMergeRegisterResultR6 R R R t readDataRÛ RO t ErrorMsgt ErrorMsgLenRT Rh R R RU R R¿ R< R R, RO Rº R» R¼ RE R
Rl R¸ R¹ t
|
PlayerNameRÀ RÁ RÂ RÃ R7 RT R< R R t ERROR_NO_175t tracebackt
|
format_exct binasciit b2a_hext ERROR_NO_176( R\ R[ R. RÕ RI RJ R/ t loginResultPackR| t playerRect dbPlayerReadLenRÄ RF RE R¤ RÝ t
|
playerNameRJ R2 ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRî s 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 tagMDFinishRechargeRA RÖ R¸ R¹ R RÚ t UCN_PayInfoRD RE t datetimet todayRm t splitR^ R< R R t ERROR_NO_170RÏ RÐ ( R\ R[ R. RI t packLenRJ R/ t orderIDRq R( Rr t
|
curTimeStrRJ R2 ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRò ¼ s2
|
,+%c C sB y¸| j } | j } t j } d } | j | | | j j t d } t j d | | t
|
} | j i | d 6d d 6d d 6 } | s | j d k r± d S| d }
|
t j } t j | _ t j | _ t |
|
d | _ t | j | _ t |
|
d | _ t | j | _ t |
|
d | _ t |
|
d | _ t | j | _ | j i | j d 6i i d
|
d 6d 6 | j | | j t j d | j d SWn t! k
|
r} t" j# d t" j$ d | t% j& | f } t j" | n9 t" j# d t" j$ d t% j& | } t j" | n Xd S( Ni s OnQueryRecharge ...%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 tagMDQueryRechargeRA RÀ R¸ R¹ R RÚ RÛ RD RE R t tagDMRechargePushR| t dgDBToMapServerR6 t gmReChargePusht SubTypeR RÖ RÛ t
|
OrderIDLenRã t OrderInfoLenRn t MoneyRå t ExtrasLenR^ R; R< R< R R Rß RÏ RÐ ( R\ R[ R. RI Rà RJ R/ t accountRq R( t billInfoR= RJ R2 ( ( 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 tagMDIsMediaCardUsedRA R RÚ t CardIDR t tagDMIsMediaCardUsedR| Rè R6 t gmQueryNewGuyCardStateRê t CardIDLenR t tagDBNewGuyCardStatet UCN_DBNewGuyCardStateR t adoLoadt IsUsedt UserDataLent UserDataR; R< R, t CardTypet ValidTimeR- R< R R Rß RÏ RÐ ( R\ R[ R. RI Rà RJ R/ R= t objRq t lastExceptionCntRJ R2 ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRð 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 tagMDCheckUpdateMediaCardStateRA R t tagDMCheckUpdateMediaCardResultR| Rè R6 t gmUpdateNewGuyCardStateRê Rõ Rò R RÚ RB R Rö Rù Rú Rû Rü Rý R÷ t adoCheckUpdateRO R; R< R< R R t ERROR_NO_171RÏ RÐ ( R\ R[ R. RI Rà RJ R/ R= Rþ Rq RJ R2 ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRó J 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 tagGDSavePlayerInfoRA Ræ t GeTuiClientIDt UCN_DSAccountR t tagDSAccountR
Rl t ACCIDt adoLoadCR R t ERROR_NO_57R R, t
|
adoUpdateC( R\ R[ R. R/ t
|
PlayerInfoRq t PlayerAccR2 ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyR u 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 tagLDPrepareCreateRoleRA Ræ t GetAccountFromTableR
R9 R t AppIDR t GetPlatformAccIDt
|
DeviceFlag( R\ R[ R. R/ R 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Û RY RO R R7 RR R
( R\ R[ t saveDataRÓ R/ 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¹ RW t onSavePlayerDataCRCErrorRY t _UserCtrlDB__ReadPlayerIDRT R× t MergeRegPInfoIndex_PackDataR RÛ R R R7 R R R t tagDBUpdateReturnt dgUpDateRC R7 RO RO R; R< ( R\ R[ R. RÕ R/ RI t lengthRh 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 so d } | j } | j } t j | | \ } } | t j k rkt j | | \ } } | } t j | | \ } } | }
|
t j | | \ } } | t j k r5t j | | | | \ } } t j
|
t | } | | k sVt t j } | |
|
| | |
|
d } | j | | | | t d f Sn! | j | | | | t d f St } d } t j r| j | | \ } } } n | j | | \ } } } | s | j j } t j d t j d | } t j | t j t j d d | | | n | r^t j } t j | _! t j | _" | | _# | | _$ | j% | | j& n | j' | | t j( d | | | j j f t) j* j+ t j, t- | } t) j* j. | rat) j* j+ | d } x t) j/ | D]t } | j0 t j1 sqæn t) j* j+ | | } t) j* j. t) j* j+ | | sMt2 j3 | | qæt) j4 | qæWn | | f Sd S(
|
s# Íæ¼ÒÏÂÏߣ¬±£´æÍæ¼ÒÔÚMapServerµÄÊý¾Ýi i R s& Player save data failed!sessionID = %ss UserLogs\SaveFailDumps %s.mdatsF onSaveMapServerPlayerData result = %s, playerID = %s, sessionID = 0x%Xt BackupN(5 Ræ RÙ R Rå R| R R R R R R R R¹ RW R RY R+ t PackSavet SavePlayerMapServerDataExt SavePlayerMapServerDataR R R R t ERROR_NO_59R R t DumpDataR t
|
getAppPathR R R RC R7 RO RO R; R< t RevoverBillProcessR7 t ost patht joint PlayerBakRootRm t existst listdirt endswitht PlayerBakFileTypet shutilt moveR` ( R\ R[ R. R/ RI R Rh R! R" R# R$ R% R R& R' R( R¤ RÝ R R2 R( t PlayerBakDirt
|
BakCopyDirt filenamet fullPath( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyR Û sf
|
|
' # !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=%sR) 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+ R4 R1 R2 R5 R R7 t walkR7 R8 RÛ t fatalt exitR3 t openR/ R; t zlibt
|
decompressR* R+ R, Rm R9 R: R` ( R\ R[ t parentt _t filenamesR= R> t fileHandlerR R( R¤ RÝ R< ( ( 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 .RG i R) s ²»´æÔÚ¸ÃÍæ¼Ò±¸µµÎļþ: %sR? s Íæ¼ÒÖ¸¶¨±¸µµ´ò¿ªÊ§°Ü: %ss Íæ¼ÒÖ¸¶¨±¸µµÈë¿âʧ°Ü: %ss. Íæ¼ÒÖ¸¶¨±¸µµÈë¿â³É¹¦: playerID=%s,accID=%s, %s( R R7 Rn Rt RÞ R1 R2 R3 R+ R4 Rm R5 RC R/ R; RD RE R* R+ R, (
|
R\ R[ t bakFileNameR¤ R> R2 RI R R( RÝ ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyt SavePlayerDataByBackupY 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Û RD RE R^ R RÚ R ( R\ R[ RÝ Rï Rq R( Rð Rá ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyR0 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Û RY R R7 RO R
Rl R Rç Rè R Rê t recPlayerLogofft savePlayerDataR R RR R R R R R R R R R R R R t gmOperCheckR R R R R¡ RU R R R R R R R R R R t AssertionError( R\ R[ R RÓ R/ RÔ R_ R1 t gmIPCntt gmIPRect i( ( 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} 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Û RY R R7 RO R
Rl R Rç Rè R Rê t CountryLastWeekHornorR[ t savePlayerDataExR R RR R R R R R R R R R R R R R] R R R R R¡ RU R R R R R R R R R R R^ ( R\ R[ R RÓ R/ RÔ R_ R1 R_ R` Ra ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyR+ s
|
|
|
|
|
,
|
|
)
|
|
)
|
|
)
|
|
)
|
|
)
|
|
)
|
|
|
) #
|
)
|
|
)
|
|
)
|
|
)
|
|
)
|
c
|
C s÷ d } t | } t j | | \ } } | | 8} t j } x° t | D]¢ } | j | j | | | } | | 7} | | 8} | j t j
|
k rM | j | | t t j t | j t j | j d t j | j | j f qM qM Wd S( Ni s EndTime = %s.Reason = %s( RÛ R R R R RU t clearRÈ t OperR| t gmForbidAcct onForbiddenUpdateRR R t TDateTime_NowRn t EndTimet GMAccIDt TDateTimeToStringt Msg(
|
R\ RÝ R¤ RG R/ R t cntt gmOperRecRa t readLen( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyR] w 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 = %sRO 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 R7 RÛ RU Rr RÈ RÐ t makeSIDt getRecordRR R^ t pymongot errorst OperationFailureR+ t TryCntOnWriteFailR t __class__t __name__t inspectt stackR R` ( R\ R¤ R[ t collectionNamet
|
structNameRG t checkSIDR t oAllFuncGradeR_ R1 R/ R{ RL R Rt Ra R} t trycntt err( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRq 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_removeRO 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è R` Rê R R R RÚ RÛ RU Rr RÈ R7 RÐ R R RV RR RX RY R R R
R+ R R R R R R R ( R\ R¤ R[ R R RG R R R R_ R1 R/ R{ RL R R] Ra R} Rt R R ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyR\ æ 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 TJGStateRT t LastLogoffTimeRO 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[ 1 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 ( Rm t uuidt uuid4R R t ERROR_NO_60R R R R R. R R/ R R RÛ RÈ t updatePlayerAccStateRO R| t pysForbiddent sendAccForbiddenLogReqR
R R R RC R R7 RO R; R< (
|
R\ R[ R. t saveDataWithCRCt dumpFileNameR2 RÓ R/ R R( ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyR H s + c C sw t j } | | _ | | _ t | _ d } t j | t j } t j
|
| | j | j } | j | d S( NR$ ( R t tagDBPlayerInfoLogForbiddenR
t IsForbiddenRT 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¬ a 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 RO R R
|
R R, R R R R RY RÚ R R RR ( R\ R[ R¤ t newStateR_ Rt t lastSIDErrorCntt ret( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRª k 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* tagGameServerToBalanceServerPlayerSaveDataRA Ræ RÙ Rg t setSrcSvrTypeR t stLogint sendOKStringR| t dgPlayerSaveGameServerData( R\ R[ R. t saveGameServerPlayerDataReq( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRÿ s c C s d S( N( ( R\ R[ R. ( ( 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 tagCSIsHaveRoleRA Ræ R t tagDRequestResultR| Rµ R6 R
R R Rl RÁ R R R R R R R7 RO t ExAttrt disDataBaseErrorR+ R t disAccStateErrorR; R< RÚ R R t ERROR_NO_62RÍ RÎ (
|
R\ R[ R. RJ R= t PlayerR_ Rÿ R¸ R2 ( ( 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 tagCSCheckPlayerNameExistRA Ræ R RÃ R| R´ R6 R
RO t hasPlayerByPlayerNameRË RÄ R; R< R RÚ R R t ERROR_NO_63RÍ RÎ ( R\ R[ R. RJ R= R2 ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRý Õ 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[ R. t Suct disCodet AccIdRG ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRû ë 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³ R6 RO R
RÄ R RÚ R; R< R R t ERROR_NO_64RÍ RÎ ( R\ R[ R. RÏ RÐ RÑ RG R= R2 ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRþ ÷ 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ÿÿÿÿR> R? ( R RÚ RW RD RS RR t sleepRY R` RE R+ t IDDispatchPlayeIDLimitRF RG RH ( R\ R[ R_ R( t try_countt emptyCntRF RK ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyt CheckEmptyPlayerIDCount sF
|
|
|
|
c C s; | t } | j } | r7 | d } | j | | Sd S( NRO iÿÿÿÿ( RW t find_oneR` ( R\ R[ R_ RL 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( NRO 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 DispatchNewPlayerIDF s c C s0 t j } | | _ | t } | j | | S( N( R R R R Rø ( R\ RÝ R[ t accountDataR_ ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyR S 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 = %st gbksF 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
Rl RË R R R R R, t disCreatePlayerError_PlayerExistRÊ t' disCreatePlayerError_PlayerNameConflictR Ry Rv t CreateRoleTimeRß R R t ERROR_NO_65RÅ RO t decodet encodeR+ RÎ RÚ t
|
adoInsertCRø t ERROR_NO_66R t
|
WriteDWORDR R R t tagDBServerLogRecR| t gstSavePlayerLogR6 Rs RT t Timet MapIDt SexR Rz RÛ t MsgLenR£ R< R t tagDBPlayerInfoLogCreateRolet Facet PlayerRegisterTimet gstSavePlayerInfoLogOnCreateR¢ R R9 R R R R t urllibt urlencode( R\ R[ R. t createPlayert createNameByFormatPlayerIDR_ t newPlayerIDR2 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Ì Z s° #
|
, %# D
|
! &
|
|
c C s= | t } | j i t | d 6d d 6 } | j d k S( NRË i RÁ ( R RD R RE ( R\ R[ RÕ R_ t resultCollection( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRÊ Î s
|
#c C s d } | j | j d } | j sF t j | | j } | S| } t | d } | j d rî | d } d }
|
t j |
|
| }
|
t j d | | | f x= t | D]/ } | j
|
| d | d |
|
| j 7}
|
q· W|
|
S| r| j | | S| j | | Sd S( NR$ i i R~ R: s$ ####reading %s of player %s,cnt = %ss %s( RD t limitRE R Rí Rn t has_keyR RÚ RU t
|
readRecordRæ t adoQueryCustomCt adoQueryCustom( R\ Rq t queryR R RI R] Rþ Rt t docCntR( Ra ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyR Ô s&
|
c C s | j d | } | j d } t j | | \ } } t j d | | | f | } t | } d }
|
t j |
|
| }
|
xt | D]÷} | j d | } | j | j | j
|
| j d | } | j | j | | | } | j
|
| d k r)t j d t | d S| | 7} d } t j | d r`| j } | | _ n t j | d
|
r| r| j } | j | d } t j | | | _ qn t j | d rÔt j | | _ n t j | d r<| r<| j } | | j k r-| j | d } t j | | | _ q9| | _ q<n | rv| j d | } | j | j | j
|
n |
|
| j 7}
|
q W| j
|
| |
|
f S( s »ñÈ¡¿ç·þÍæ¼Òͬ²½Êý¾Ý»º´æbuffer s getMergePlayerDataBuffer_%s_Alli s9 getMergePlayerDataBuffer %s data, playerID = %s, cnt = %sR$ s! getMergePlayerDataBuffer_%s_clears$ getMergePlayerDataBuffer_%s_readDataiÿÿÿÿs %sRO t PetIDi t TruckIDt OwnerIDs# getMergePlayerDataBuffer_%s_makeSID( i s ( Rç Rè R R R RÚ RÛ Rí RU Rr Rê RÈ R, RÐ R t hasFieldRO R R| t makePetIDt makeTruckIDt TructIDR R Ræ ( R\ Rü R RG R R R/ R{ RL R R( Ra R1 R} t orgPlayerIDt oldPetIDt petIndext
|
oldOwnerID( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyt getMergePlayerDataBufferî 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 tagPlayerDetailReqRA Ræ RÙ R RÚ R
Rl R¸ R¹ Rú R R R R Rí R R½ R| t dgPlayerInit( R\ R[ R. RÕ t getPlayerDetailReqt
|
queryAccidt regPlayerInfoRJ R R R ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRù 2
|
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 :
|
%sRO s kick accid = %s reason = %si Ry 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 R! RA Ræ RÙ R R7 R
Rl R¸ R¹ t queryMergePlayerListRÎ R| R" RÅ R R t ERROR_NO_67RÍ RÎ RÛ R t tagServerMergeInfot PlayerCountt tagServerMergePlayert getFamilyLeaderFamilyIDt ERROR_NO_68t ERROR_NO_69t LeaderFamilyIDRO t NameR Rò R t TotalSTRt TotalPNEt TotalPHYt TotalCONR R R R R* R+ R, t PlayersRV t KeyErrort ERROR_NO_70R½ t dgServerMergeR< R R RÁ R R R R R R0 t isAccStateForbiddenR R+ R t pysSIDCheckErrorForbiddenR RÚ R¬ RÆ RY R R R RR R R Rc R R R R R R R R R R R R R R R R R R R R R R R R R9 R: R. R/ R1 R2 R3 R R/ t
|
has_optiont getintR« t extractGMOperRt Rw R Rv Ry Rz t unFobbidenAccRx R¡ R¢ R£ R Rí R (; R\ R[ R. R R# R$ t
|
playerListR2 R= 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 dbIniR. R| Rµ R¶ R_ R R R R ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRú Y
|
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Á Ru RO RY R Rv ( R\ R[ R¥ t gmAccidR2 R_ ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRF 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 R7 t ctimeR¬ Rl R R R| t gstAccForbiddenLogR t tagAccForbiddenLogR
RO Rs t OperTimet TimeLimitRx Rz R¢ RÙ Ræ R£ (
|
R\ R³ R¤ R´ t operTimet timeLimitt operGMAccidR2 Rµ t accForbiddenLog( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRu 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 R7 R R RU RÈ Rs Rc ( R\ R³ t gmOperR¯ R/ t operCntR| Ra ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRE · s c C s0 | t } t | j i | d 6d g } | S( Nt LeaderIDRy ( t UCN_FamilyInfoRn RD ( R\ R[ t leaderIDR_ t familyInfoSnap( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyR4 Å 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 Rn RD R R| t pysServerMergeRÌ t transform_outgoingRc ( R\ R[ R³ R_ RG ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyR/ Ê s
|
|
3 c ( C s9 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 q&| j d k r&| j$ t j | t% t Sn:| t j& k rÉ| j | | j j t
|
d | _ | j | _ | j j t
|
d | _ | j | _ d | _ | j | _ | j! j t
|
d | _" | j' j( d }
|
t) |
|
| d k rÈ| j$ t j | t% t S|
|
| } t |
|
| d
|
} t t* } |
|
d } | j" d k r t j d q&| 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_+ q&| | _: 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 q&| 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_+ q&| | _: 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 q&| 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_+ q&| | _: 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 q&| 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_+ q&| | _: 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 r÷ t j d q&| j+ d k r i | d 6| d 6} y t1 j2 | } t3 j4 d | } t3 j5 | d d
|
} | j6 } t? j@ | } | jA d! t k r´ t j d | | f | j$ t j | t% t SWq q Xn t* } | | j: d k rð | j+ d
|
7_+ q&| | _: d | _+ n! | t jB 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 jC 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 q&| j+ d k rYi d" d# 6| d$ 6| d% 6} | jD } | jE d& } x& | D] } | d' | | | f 7} q\W| d( 7} t/ j/ | j0 } | jF i | d 6 y t1 j2 | } t3 j4 d) | } t3 j5 | d d
|
} | j6 } t? j@ | } | jA d! d k rKt j d | | f | j$ t j | t% t SWqYqYXn t* } | | j: d k r| j+ d
|
7_+ q&| | _: d | _+ n | t jG k r5| j | | j j t
|
d | _ | j | _ | j j t
|
d | _ | j | _ d | _ | j | _ | j! j t
|
d | _" | j' j( d }
|
t) |
|
| d k rx| j$ t j | t% t S|
|
| } |
|
| d
|
} | j } | } | j" d k r¾t j d q&d* } tH jI t/ j/ d+ | | | f j0 j0 } | | k r&t j d, | | f | j$ t j | t% t Snñ| t jJ 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 } | } | j" d k rWt j d q&d- } tH jI t/ j/ d+ | | | f j0 j0 } | | k r&t j d, | | f | j$ t j | t% t SnX| t jK 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 q&| j+ d k rZi | d. 6t, jL | d/ 6| d0 6d1 d2 6d3 d4 6} t jM } | tN }! | jO |! i | d5 6 srd& | d6 <d& | d7 <d& | d8 <n6 | jP | d6 <| jQ j t
|
d | d7 <| jR | d8 <y¥ t1 j2 | } d9 | }" t3 j4 |" } t3 j5 | d d
|
} | j6 } t? j@ | } | jA d! d
|
k rLt j d: |" | | f | j$ t j | t% t SWqZqZXn t* } | | j: d k r| j+ d
|
7_+ q&| | _: d | _+ n| t jS 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 ry| j$ t j | t% t S|
|
| } | j" d k r¢t j d q&| j+ d k r±i | d; 6| j d< 6t, j- | d= 6} yÌ t1 j2 | } tT jU j( d> }# d> jV |# d? d@ | }$ t j |$ t3 j4 |$ } t3 j5 | d d
|
} | j6 } | jW 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_+ q&| | _: d | _+ n2tX }% tY }& | j | sÂ|% tX k rKt jZ dC | j$ t j | t[ t S|& tY k rt jZ dD | j | j$ t j | t\ t StT j] rÂt j dE | j | j$ t j | t^ t Sn | j | j j t
|
d k s&t j dF | j j | j j f | j$ t j | t% t S| j' r| j' j( d }' t) |' d? k rt/ j/ |' d
|
j0 | __ | j` |' dG qn ta jb dH dI | j d
|
t, j- | | j_ f | jc d
|
7_c td je td jf | _g | jh | s t jZ dJ | j | j$ t j | t[ t S| j t j | | j 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 gameIdRT 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(i R t tagDataServerPlayerLoginRA Ræ RÙ R R R
Rl R¸ R¹ R RÔ RÕ RÓ R R7 R½ R| t dgPlayerLoginRR RÚ t IDTypeR Rn t
|
gitFreeSDKR
|
R Rä t TokenExpiret Phonet Pswt Adultt IPt RegIPt IsDebugRÎ t disPswCheckErrort gitGTGamet ExtraRÞ RÛ RT RÏ R R t GetLoginKeyt md5t hexdigestRø Rù t urllib2t Requestt urlopenR/ t HTTPErrort disTimeErrorR< RÐ t gitGTGameIOSt gitQkGamet gitHYGamet gitHYGTGamet jsonRe R0 t gitMLGTGamet gitMLGTGameJFt keyst sortR^ t gitHYYNGamet hashlibt sha1t gitHYEnglisht gitVNGamet GetPlayerServerIDR R R RO RË R t gitX7R+ t ReportUrlR3 t replaceR R R, RÅ t disUserNameNotExistR t disGMKickR t SetClientVersionR9 R t LogNumR Ry Rv t LastLoginTimet adoCheckUpdateC(( R\ R[ R. t authPackt
|
accountRect authAccIDRÕ R_ t appTypet redefineIndext extraListRy RD t timeIntt opuidRt t signStrRu t valuesRG R¤ t responset the_pageRJ t nowTimeRI 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ø Ò 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\ Rh t
|
fromPacketRI 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\ Rh RÓ t disconnectReasonRÔ ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRÎ ¯ s
|
c C sV | j | j | j j | j j | j j | j j | j j | d S( N( RT Rh R R t poolIndexRh t
|
srcSvrTypet
|
dstSvrType( R\ RÓ RÔ ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyR; · 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 = %dRA 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 getLoggerR7 R R RÖ t VersionNOR t SERVER_DATA_VERSION_NOR R t ERROR_NO_71RA R R. R R/ Rñ t CRCCheckErrorServerTypeR R R| t
|
DUMPPACKETRÚ RÐ t DATASAVE_MARKR R R t CRCt ERROR_NO_72t ERROR_NO_73RU t AllPlayerStreamt setBufferR R t LenR R R t dgUpdateMapServerCrashDataRC RO RT Rh R Rh R× RØ R< ( R\ R[ R. t crashDataRI R/ R R2 t debugdatat CalcCRCRa t
|
PlayerDataR( R¤ R= ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRô » s` #)4 # &'( #" # +, 3c C s d S( N( ( R\ R[ R. ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyR÷ ø s c O C s 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} t j d2 | tf } t jg }6 | |6 j | 7} | 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 | t } t j }K | |K j | 7} t j dG y t j | dH }L Wn7 t j dI t j dJ t j }M t j |M d SXd }N t j |N t j }N |N |L 7}N | j | t j |N t j¡ dK t¢ | d S(L NR$ s tagDBPlayerPackData oks 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 RA s2 Compress game server player data failed!error =
|
%ss) Game server player data send ok! len = %d(£ t UCN_DBPlayerPackDataR t tagDBPlayerPackDatat adoQueryAllR RÚ t UCN_DBGameRect tagDBGameRect 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 tagTeamMemberTableRl 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 tagPlayerViewCacheRD t compressR R t ERROR_NO_75RÍ RÎ RA R Rí R t$ GAMESERVER_GAMEWORLD_DATA_VERSION_NOt sendGameServerStringR| t dgGameServerDataR7 RÛ (O R\ R[ R. RG R_ t DBPlayerPackDatat 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 compressDataR2 t SendData( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRö ü sN
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
"
|
c C sh d } t j | j | \ } } t j | j | \ } } | j | | | j | | | d S( Ni ( R Rå Ræ t saveGameServerGameData( R\ R[ R. R/ R! Rh ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRõ T s # c C s6 | t j k r 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 Sym t j | } | j d d \ } } t | } t j d | | | f t j | | | | } WnL t j d
|
t j d t j! } t j | t j d j d qù
|
Xt j" d t# | d } yy| j$ | | t% t& j' | } | j$ | | t( t& j) | } | j$ | | t* t& j+ | } | j$ | | t, t& j- | } | j$ | | t. t& j/ | } | j$ | | t0 t& j1 | } | j$ | | t2 t& j3 | } | j$ | | t4 t& j5 | } | j$ | | t6 t& j7 | } | j$ | | t8 t& j9 | } | j$ | | t: t& j; | } | j$ | | t< t& j= | } | j$ | | t> t& j? | } | j$ | | t@ t& jA | } | j$ | | tB t& jC | } | j$ | | tD t& jE | } | j$ | | tF t& jG | } | j$ | | tH t& jI | } | j$ | | tJ t& jK | } | j$ | | tL t& jM | } | j$ | | tN t& jO | } | j$ | | tP t& jQ | } | j$ | | tR t& jS | } | j$ | | tT t& jU | } | j$ | | tV t& jW | } | j$ | | tX t& jY | } | j$ | | tZ t& j[ | } | j$ | | t\ t& j] | } | j$ | | t^ t& j_ | } | j$ | | t` t& ja | } | j$ | | tb t& jc | } | j$ | | td t& je | } | j$ | | tf t& jg | } | j$ | | th t& ji | } | j$ | | tj t& jk | } | j$ | | tl t& jm | } | j$ | | tn t& jo | } | j$ | | tp t& jq | } | j$ | | tr t& js | } | j$ | | tt t& ju | } | j$ | | tv t& jw | } | j$ | | tx t& jy | } | j$ | | tz t& j{ | } | j$ | | t| t& j} | } | j$ | | t~ t& j | } | j$ | | t t& j | } | j$ | | t t& j | } | j$ | | t t& j
| } | j$ | | t t& j | } | j$ | | t t& j | } | j$ | | t t& j | } | j$ | | t t& j | } | j$ | | t t& j | } | j$ | | t t& j | } | j$ | | t t& j | } | j$ | | t t& j | } | j$ | | t t& j | } | j$ | | t t& j | } | j$ | | t t& j | } | j$ | | t t& j | } | j$ | | t t& j | } | j$ | | t t& j¡ | } | j$ | | t¢ t& j£ | } | j$ | | t¤ t& j¥ | } | j$ | | t¦ t& j§ | } | j$ | | t¨ t& j© | } | j$ | | tª t& j« | } | j$ | | t¬ t& j | } | j$ | | t® t& j¯ | } | 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 } | rym t j | } | j d d \ } } t | } t j d | | | f t j | | | | } Wn6 t j d
|
t jÆ d t j! } t j | qXt# | } t j" d | d } yc| j$ | | t% t& j' | } | j$ | | t( t& j) | } | j$ | | t* t& j+ | } | j$ | | t, t& j- | } | j$ | | t. t& j/ | } | j$ | | t0 t& j1 | } | j$ | | t2 t& j3 | } | j$ | | t4 t& j5 | } | j$ | | t6 t& j7 | } | j$ | | t8 t& j9 | } | j$ | | t: t& j; | } | j$ | | t< t& j= | } | j$ | | t> t& j? | } | j$ | | t@ t& jA | } | j$ | | tB t& jC | } | j$ | | tD t& jE | } | j$ | | tF t& jG | } | j$ | | tH t& jI | } | j$ | | tJ t& jK | } | j$ | | tL t& jM | } | j$ | | tN t& jO | } | j$ | | tP t& jQ | } | j$ | | tR t& jS | } | j$ | | tT t& jU | } | j$ | | tV t& jW | } | j$ | | tX t& jY | } | j$ | | tZ t& j[ | } | j$ | | t\ t& j] | } | j$ | | t^ t& j_ | } | j$ | | t` t& ja | } | j$ | | tb t& jc | } | j$ | | td t& je | } | j$ | | tf t& jg | } | j$ | | th t& ji | } | j$ | | tj t& jk | } | j$ | | tl t& jm | } | j$ | | tn t& jo | } | j$ | | tp t& jq | } | j$ | | tr t& js | } | j$ | | tt t& ju | } | j$ | | tv t& jw | } | j$ | | tx t& jy | } | j$ | | tz t& j{ | } | j$ | | t| t& j} | } | j$ | | t~ t& j | } | j$ | | t t& j | } | j$ | | t t& j | } | j$ | | t t& j
| } | j$ | | t t& j | } | j$ | | t t& j | } | j$ | | t t& j | } | j$ | | t t& j | } | j$ | | t t& j | } | j$ | | t t& j | } | j$ | | t t& j | } | j$ | | t t& j | } | j$ | | t t& j | } | j$ | | t t& j | } | j$ | | t t& j | } | j$ | | t t& j | } | j$ | | t t& j | } | j$ | | t t& j¡ | } | j$ | | t¢ t& j£ | } | j$ | | t¤ t& j¥ | } | j$ | | t¦ t& j§ | } | j$ | | t¨ t& j© | } | j$ | | tª t& j« | } | j$ | | t¬ t& j | } | j$ | | t® t& j¯ | } | j$ | | t° t& j± | } | j$ | | t² t& j³ | } t j" d Wqt j´ k
|
r
|
t j d
|
t jÇ d } t j | qXn t j" d | d k r2t¶ j· } t j¸ | _¹ t jÈ | _» d | _¼ | j½ | j¾ | j¿ jÀ | j¿ jÁ | j¿ j | j¿ jà | j¿ jÄ | jÅ t j" d | q2no | t jÉ k rò| jÊ | | d t& jË | n@ | t jÌ k r!| jÊ | | d t& jÍ | n t jÎ d | d S( NRA sW Save game server crash data error:data version conflict!versionNO = %s, db version = %st GameServerDataRestoreLogsJ ±ÀÀ£Êý¾Ý°æ±¾ºÅУÑéʧ°Ü(Èç¹ûÊǸüа汾£¬ÇëÆô¶¯¾É°æ±¾·þÎñÆ÷µ¼Èë±ÀÀ£Êý¾ÝÊÔÊÔ)t tagGDGameServerGameDatas 0.mdats |i s' disCompresspydata len %s, GameData = %sR 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 RA R RÝ R R. R1 R2 R3 R R/ t DUMP_PATHRR RD RE RÞ Rn RÚ RÏ t a2b_hext ERROR_NO_77RÍ RÎ R7 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 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/ R0 R1 R2 R3 R4 R5 Rl 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` 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| t ShortBuft ERROR_NO_78R R R RC R¨ R7 RO RT Rh R R RÖ Rh R× RØ R< t ERROR_NO_80t ERROR_NO_81R t dgPlayerMailListt savePlayerMailDataRÎ t dgPlayerMailItemListRÏ R, ( R\ R[ R. RG R/ t saveTypeR! t markt versionNOR t gameDataLent gameDataR2 t decompressGameDatat pyDataLent pyDataHext gameDataReadPosR= 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 R7 RO t adoDeleteByIndexRU Rr RÈ RV R RR RX RY R R t PyMongoErrorR+ R R R R R R R R t ERROR_NO_152( R\ R¤ RG R/ R R R[ t recCntR_ RL R] Ra R} R R R2 ( ( 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 R7 R| R× R R t drop_collectionRU Rr RÈ t
|
dumpStringR R t _UserCtrlDB__name_R R RV R RR Rm RX RY Rn t matht ceilt floatR8 R R R
R+ R R R ( R\ RG R/ R R R[ Rë R_ R] RL Ra R} R t max_sizet
|
docsStrLent insertTimest perTimeCountRH t insDocsR ( ( 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ÿÿÿÿRO t FriendIDi s %s.%s:PlayerID = %si s5 delete failure!PlayerID = %s, error = %s, trycnt = %d( RÛ R| R× R R R R7 RU RA RR R` RO Rø R R R
R+ R R R R R R R ( R\ RG R/ t
|
packStructR R[ Rë R_ RL Ra 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 R7 RU Rr RÈ R| R× t adoInsert( R\ RG R R R[ R2 R/ Rë R_ RL t datalenRa 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 tagBDStringTypeSendRA R R RÈ R R R Ry Rv t RegisterTimeR Rë RÎ R| t dgInsertAccRY R½ RR R R t ERROR_NO_83R RÍ RÎ R (
|
R\ R[ R. RG R/ Rý t oTypeSendt AccR_ R2 ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyR C 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
RO R s; OnPlayerIDMarkDeleted failed! Playerid = %d, exception = %s( Ræ RÛ R t tagMarkPlayerDeletedRA R R R RO R R
|
RY R+ R RÁ R^ R R
RR R R t ERROR_NO_84RÍ RÎ R ( R\ R[ R. RG Rý R/ t oMarkPlayerDeletedRq t oPlayert SidErrorCntR2 ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyR Z 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 tagDGetValueByAccRA Ræ t UCN_AccCoinsR t tagAccCoinsR R
Rø R R7 RY R| R t GoldCoinsR t tagDServerValueTypet dgCoinR6 t ValueR; R< RR R R t ERROR_NO_85RÍ RÎ ( R\ R[ R. t oDGetValueByAccRq t oAccCoinst oSvrValueR2 ( ( 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 tagMDCoinChangeReqRA Ræ R R7 R RO t CoinR
|
R R R
R R R| t dgCoinChangeResultR6 Rø R; R< RY R R t UseGoldCoinst adoUpdateR R t ERROR_NO_87R R R t tagDBPlayerLogInfoOnCoinChangeR£ R¹ t" gstSavePlayerInfoLogOnOnCoinChanget ERROR_NO_88RÍ RÎ RR ( R\ R[ R. t oCoinChangeReqRq R t retPackR2 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 tagBDCheckNameExistRA Ræ R t tagDBPlayerNameIsExistR R R8 RË RÁ R R| t dgCheckPlayerExistRC RÛ t NameLenR R RO RO R; R< R R t ERROR_NO_89RÍ RÎ R RY RR ( R\ R[ R. t curPackR R Rq R2 ( ( 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 R, R+ t EventShellEnableR t OnDayProcessR R t ERROR_NO_161RÍ RÎ ( R\ R[ R. R2 ( ( 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 RY RR ( R\ R[ R. RG R/ t PlayerIdR2 ( ( 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 R RA Ræ t UCN_ExpiationRD R R RE R R R| t dgGetExpiationCountR6 R R; R< RR ( R\ R[ R. R% Rq 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 R RA Ræ t UCN_PetExpiationRD R R RE R R R| t dgGetPetExpiationCountR6 R R; R< RR ( R\ R[ R. R% Rq R- R ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyR s
|
% c C s= t j } | j | j | j } t j } t j | _ d | _ | t
|
} | j i t | j d 6 } | t
|
} xþ| D]ö} | j | k r Pn t j }
|
| d |
|
_ t | d |
|
_ | d |
|
_ | d |
|
_ | d |
|
_ | d |
|
_ | d |
|
_ | d |
|
_ | d
|
|
|
_ | d |
|
_ | d |
|
_ | d |
|
_ | d |
|
_ | d |
|
_ | d |
|
_ | d |
|
_ | d |
|
_ | d |
|
_ | d |
|
_! | d |
|
_" | d |
|
_# t | d |
|
_$ | d |
|
_% | d |
|
_& | d |
|
_' | d |
|
_( | d |
|
_) | d |
|
_* | d |
|
_+ | d |
|
_, | d |
|
_- | d! |
|
_. t | d" |
|
_/ | d# |
|
_0 | d$ |
|
_1 | d% |
|
_2 | d& |
|
_3 | d' |
|
_4 | d( |
|
_5 | d) |
|
_6 t | d* |
|
_7 | d+ |
|
_8 | d, |
|
_9 | d- |
|
_: | d. |
|
_; | d/ |
|
_< | d0 |
|
_= | d1 |
|
_> t | d2 |
|
_? | j@ jA |
|
| jB i |
|
j d 6 | j d3 7_ q W| j d k rtC S| jD | | jE 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 tagMDGetExpiationExRA Ræ R: R t tagDMGetExpiationExResultR| t dgGetExpiationR6 R+ RD R R t tagExpiationR0 R R
R1 R R R R 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 Rú Rû t DatasRV R` RY R; R< RU R t tagExpiationLogRT t ReceiveDateR£ R¹ t gstGetExpiationLogRR ( R\ R[ R. R% t needCountR= R_ t
|
expiationst colDelt curDatat expiationRa 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 R RA Ræ R. R t tagPetExpiationR R
Rø Rþ R| t dgGetPetExpiationR6 R RÙ R R; R< RY R t tagPetExpiationLogRT R_ R0 R1 t NPCIDt Lvt Expt BindTypet UseCreatorDrugCntt Friendlinesst SkillIDListt HPTalentt PhysicAtkTalentt MagicAtkTalentt PhysicDefTalentt MagicDefTalentR£ R¹ t gstGetPetExpiationLogRR ( R\ R[ R. R% Rq Rf R( R= Rg ( ( 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 RY t UCN_ServerDataVersionNOR\ Rü t ERROR_NO_92RR ( R\ R[ R. t dbRecvR2 Rq ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyR« # s
|
|
c C s t j } | j | j t j } d | j | j k rl t j d t j
|
d } t j | t St | _ t | d d t j t j | _ | t } | j | i | j d 6t | j d 6 st j d t j d | j | j | j f } t j | t St S( NiÿÿÿÿR s$ tagDBMapServerInfo:lack of pack datat tagDBMapServerInfot LogIndext LogIDRz s: OnMapServerInfo failed:LogID = %s, LogIndex = %s, Msg = %s( R Rþ RA Ræ R R} RÈ R R R t ERROR_NO_93R RY RT Rð R R+ t LOGINDEX_FEEDt LOGINDEX_STEPR~ t UCN_DBMapServerInfot adoCheckUpdateExR R Rz t ERROR_NO_94RR ( R\ R[ R. RJ Rf R2 Rq ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyR 7 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 R7 R Rþ RA Ræ R t tagDBPlayerSaveCoinLogRÈ R R R t ERROR_NO_95RÐ RÛ RY R R R R
R
|
t TotalSavePointR R» t ERROR_NO_86t ERROR_NO_96RÍ RÎ RR ( R\ R[ R. RJ Rf R2 Rq t dbDocR¹ ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyR M 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 tagDBGetMailListReqRA Ræ t UCN_DBMailListRD RO R| t wmtSaveRE t MAX_PLAYER_MAIL_COUNTt pmiFullt wmtUnReadedt pmiNewLettert pmiNullR t tagPlayerMailInfot InfoTypeR R× R RV t stRoutet RouteServerIndexRÖ R t dgPlayerMailStateR< R R t ERROR_NO_97RÍ RÎ R RY RR ( R\ R[ R. RJ Rq t docCountt stateR= R2 ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyR o 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 tagDBGetMailDetailReqRA Ræ t UCN_DBMailItemListR RÏ t MailIDR£ R RÎ Rø R R, RY R t tagDBMailDetailViewR| t dgMailDetailR6 t MailDetailDataRÛ t MailDetailDataLent MailItemDatat MailItemDataLenR; R< R R t ERROR_NO_98RÍ RÎ RR (
|
R\ R[ R. RJ Rq t dbMailItemListR¨ t
|
dbMailListR= R2 ( ( 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 RA Ræ R t tagDBGetPlayerMailR| t
|
dgMailListR6 R RD RO t MailExistTimet tagDBMailInfoR R R R« R¬ R Rª R® t MailRV RÛ t MailCountR; R< R R t ERROR_NO_99RÍ RÎ R RY RR (
|
R\ R[ R. RJ R= Rq R] Rt t mainInfoR2 ( ( 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 mailidRO s+ OnAddPlayerMailByAccID throw a exception
|
\s(/ RY R Rþ RA Ræ R R RR R t tagDBMailList_SaveSysMailRÈ R R t ERROR_NO_100R R RD R R
RE R7 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 dgAddPlayerMailByAccIDR6 R; R< ( R\ R[ R. R( R= RJ t curMailR2 Rq R] Rt ( ( 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 tagDBDeleteMailRA Ræ R R RÎ R Rè R R t ERROR_NO_103RÐ R RY R RÏ t ERROR_NO_104t ERROR_NO_105RÍ RÎ RR ( R\ R[ R. RJ Rq Rt R2 ( ( 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 tagDBUpdateMailRA Ræ R R RÎ R Rø R R. R R/ R R R R t ERROR_NO_106R RY t UpdateMailTypeR t UpdateLetterTypeR t GetAllMoneyRí t
|
ReturnMailRº R Rª R RÐ t ERROR_NO_107t
|
GetAllItemR Rè t ERROR_NO_108t ERROR_NO_109RÍ RÎ RR ( R\ R[ R. RJ Rq Rt R2 ( ( 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Á RO R s $neR i R s' OnQueryCanSendMail throw a exception
|
%s( R R RA Ræ R R! R| t dgQueryCanSendMailRC R8 RÛ R# R RD R RE RO RO R R R R; R< R R t ERROR_NO_110RÍ RÎ R RY RR ( R\ R[ R. RJ R= Rq R] RE R2 ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyR Y 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 PrizeNumR6 s% OnAccIDSendPrize throw a exception
|
%s(' R t tagDPlayerGetItemR| t dgAccIDSendPrizeR6 RR R R RA Ræ t UCN_AccIDSendPrizeR^ RT R R RY R R R
R+ R R R R t ERROR_NO_111R RD R RE t ItemIDR: R6 t ERROR_NO_112t RemainItemCountt ERROR_NO_113RÍ RÎ R; R< ( R\ R[ R. R= R¹ RJ Rq R R2 R] Rt RÓ ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyR z 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 R RA Ræ t timeitt default_timerRØ RD R R RE R+ t ProfileThresholdR R, R R R| t dgCheckItemPrizeResultR6 R R; R< R R t ERROR_NO_114RÍ RÎ RY RR ( R\ R[ R. RJ RÞ t startTickRq t PrizeCntt processTimeR= R2 ( ( 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 R RA Ræ R R R R R R Ry Rv R
|
R¹ Rÿ Rë RÎ R| R R R7 RY Rº R R½ t dgPlayerAccLoadR R t ERROR_NO_115RÍ RÎ RR ( R\ R[ R. RJ Rq Rt t strNowR2 ( ( 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þ RA Ræ t tagIRAddItemR R R, R RÚ t ItemCntRØ R t tagAccIDSendPrizeR t GetTransactionIDStrRÓ R
RÔ RÕ RT RÑ t PrizeReasonRÒ t SendPrizeTimeR6 R t tagIAddItemResultRü t Lengtht AccLenR: RO R; R¹ R| t dgAddAccItemOKR< RY R t tagAccTransactionLogt TransactionIDt
|
OperReasont ProcessTimet ItemCountR£ t gstItemTransactionLogR R t ERROR_NO_116RÍ RÎ RR (
|
R\ R[ R. RJ t recvDataRq Rt R= t curLogR2 ( ( 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þ RA Ræ R t tagDSAccount_UpdateTelLockStateRÈ R R R R
R R
|
t TelLockStateR» R R t ERROR_NO_117R RY t ERROR_NO_118RÍ RÎ RR ( R\ R[ R. RJ Rú Rq Rt R¹ R2 ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyR! ; s&
|
( 1 c C s yÄ t j } | j | j t j } | j | j | t } t j } | j
|
| _ | j | } | j | _ | j | sà t j d t j d | j
|
| j f } t j | t SWn7 t j d t j d t j } t j | t SXt S( NR s4 OnUpdateAccAdult!Update failed!ACCID = %s,Adult = %ss% OnUpdateAccAdult throw a exception
|
%s( R Rþ RA Ræ R t tagDSAccount_UpdateAdultRÈ R R R R
R R
|
R R» R R t ERROR_NO_121R RY t ERROR_NO_122RÍ RÎ RR ( R\ R[ R. RJ Rú Rq Rt R¹ R2 ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyR" a 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\ R0 i i R s# OnAddExpiation throw a exception
|
%s( R Rþ RA Ræ R+ R R\ RÈ R R R+ t tagExpiation_ExpiationIndex_FEEDt tagExpiation_ExpiationIndex_STEPR0 Rü t ADOResultR| t dgAddExpiationOKR6 RÛ R R; R< R R t ERROR_NO_123RÍ RÎ R RY RR ( R\ R[ R. RJ Rq Rt R= R2 ( ( 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( NRh R0 i i R s& OnAddPetExpiation throw a exception
|
%s( R Rþ RA Ræ R. R Rh RÈ R R R+ t# tagPetExpiation_ExpiationIndex_FEEDt# tagPetExpiation_ExpiationIndex_STEPR0 Rü R R| t dgAddPetExpiationOKR6 RÛ R R; R< R R t ERROR_NO_124RÍ RÎ R RY RR ( R\ R[ R. RJ Rq Rt R= R2 ( ( 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þ RA Ræ R t tagDBPlayer_DeleteRoleUpdateRoleRÈ R RÎ R| t dgServerMergeDeleteRoleR R t ERROR_NO_125R RY RR R R t DeletePlayerIDRO R
|
RÁ R t UpdatePlayerIDR R R R R* R+ R R R
R+ R t ERROR_NO_126R½ t ERROR_NO_127RÍ RÎ ( R\ R[ R. RJ Rú R2 R Rq Rt 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þ RA Ræ R t tagDBPlayer_ChangeAccStateRÈ R RR R R RO R
|
R R R R R
R+ R R R t ERROR_NO_128R RÎ R| t dgServerMergeUpdateAccStateRY R½ t ERROR_NO_129RÍ RÎ (
|
R\ R[ R. RJ Rú R Rq Rt R R2 ( ( 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þ RA Ræ R t tagDBPlayer_ChangeNameRÈ R R R7 RO RË RR R RD R RE R R| t dgServerMergeChangeNameR6 RÛ R R; R< R R R
R+ R R R t ERROR_NO_131RY t ERROR_NO_132RÍ RÎ ( R\ R[ R. RJ Rú R Rq R= R2 ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyR' + s@
|
% -
|
% " c C sà y¢ t j } | j | j t j } | j | j t | d d t j t j
|
| _ | t } | j | s¡ t j d t j d } t j | t SWn7 t j d t j d t j } t j | t SXt S( Nt tagDBImpeacht ImpeachIndexR s+ OnInsertImpeach!insert tagDBImpeach failed!s, OnServerMergeChangeName throw a exception
|
%s( R Rþ RA Ræ R R R R R+ t tagDBImpeach_ImpeachIndex_FEEDt tagDBImpeach_ImpeachIndex_STEPR t UCN_DBImpeachRü R R t ERROR_NO_133R RY t ERROR_NO_134RÍ RÎ RR ( R\ R[ R. RJ Rt Rq R2 ( ( 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 RY RR ( R\ R[ R. R2 ( ( 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 | | | t j t j t j |
|
j t j d | j t S( Ns OnMergerChildToCenter int
|
CenterGatei iÿÿÿÿs0 OnMergerChildToCenter sendString toGameServer %s( R RÚ R t getServerMgrt getClientSessionIDByNameRæ R t tagLPStringDataRA R t tagDGMergerChildToGameStringDataR| t dgMergerChildToCenterR6 R R t packSendBySessionIDR R RV RW R< RR ( R\ R[ R. t ServerMgrt sendViaSessionIDt SessionIDt PoolIndexRI RJ R/ R= ( ( 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 |
|
_ 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 tagLPPlayerDataRA R t tagDMMergePlayerDataR| Rè R6 t gmMergePlayerDataRê R R RO R+ R R R RW R< RR ( R\ R[ R. R, R- R. R/ RI RJ R/ R= ( ( 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 = %sRO s gmIP cnt = %st DumpPlayerDatas %s.pdsavet wbiÿÿÿÿ(= R R7 R R R
RÁ R R R R R R$ RO R R R RR 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¡ Rl R¢ R£ RÚ Ræ R1 R2 R3 R R/ R5 t mkdirRC t structt writet flushR; (* R\ R[ Rï R¥ R_ Rÿ R¸ R¦ R§ R¨ RN R© RP Rª RQ R« RR R¬ RS R RT R® RU R¯ RV R° RW R± RX R² RY R³ RZ R´ R[ Rµ R¶ R_ R t DumpDirRI R6 ( ( 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( NR3 i s %s.pdsaveR$ R? iÿÿÿÿs$ Saving player data,playerID = %s....(8 R1 R2 R3 R R/ R5 R5 RY RC R/ R; R R RÈ RÛ R R7 RO R
Rl R R» Rq R R RR R R R R R R R R R R R R R] R R R R R¡ RU R R R R R R R R R R R^ ( R\ R[ Rï R9 t FileDirR RI RÓ R/ RÔ R_ R_ R` Ra ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyt SaveSinglePlayerDataFromDumpFileC sZ
|
|
|
|
|
,)))))) ) #)))))(n R t
|
__module__R{ RÓ Rß Râ R3 Rf Ré RZ Rë Rì Rz Rx Rí Rî Rò Rñ Rð Ró R R+ R R R Rá RL R0 R, R+ R] RY Rq R\ R[ R R¬ Rª Rÿ RÀ Rü Rý Rû Rþ R× RÚ Rß R RÌ RÊ R R Rù Rú RF Ru RE R4 R/ Rø R½ RÎ R; Rô R÷ Rö Rõ RË Rì RÖ Rú RÜ R R R
|
R R R R R R R R R« R R R R R R R R R R R R R R! R" R# R$ R% R& R' R( R) R* Rï R: R< ( ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRy ë sâ a ÿ ¶
|
' @ " I $ 0 : +
|
3 H 6 * o p ^ K
|
, 0
|
t D ' ÿ ; ÿ ÿ × = ÿ Y ) ÿ # + ; ! ' B
|
Ï + " ! " 8 5 ! @ % = & # C % R mc C s d d l } | j d d S( Niÿÿÿÿt pause( R1 t system( R1 ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyt test s t __main__(Y R1 RD RT RÜ RÏ R§ R R Rz 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 R Rº R9 R9 Rø R R¨ Rd Rð t sysR® RÊ Rk Rp Rq Ro RÓ R8 RØ R× R t MergeRegPInfoIndex_GroupIDRK RÞ t allocate_lockRP Rc R` Ri Rx Ry R@ R ( ( ( sS .\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyt <module> s
|
|
."".
|
|
, & . ÿ ÿ ÿ ÿ ÿ ÿ ÿ ÿ ÿ ÿ ÿ ÿ ÿ ÿ ÿ ÿ ÿ ÿ ÿ ÿ ÿ ÿ ÿ º
|
