ó
|
@\c @ sâ d d l Z d d l Z d d l Td d l Z d d l Td d l Z d d l Z d d l Z d d l Z d d l m
|
Z
|
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- m. Z. m/ Z/ d d l0 Z0 d d l1 Td d l Z d d l2 m3 Z3 d d l4 m5 Z5 d d l m6 Z6 d d l7 Z7 d d l8 Z8 d d l9 Z9 d d l: Z: d d l; Z; d d d d d d g Z< d Z= d Z> d Z? e) j@ a@ i aA eB d \ ZC ZD ZE ZF d d lG ZG eG jH aI eG jH aJ d ZK d ZL d ZM d e j f d YZN d ZO eP d k rÞeO n d S( iÿÿÿÿN( t *( t CommonDefinet 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 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:%st resultt minIDt maxIDi t PlayerIDs5 IDDispatch CallDispatchPlayerID Connect Exception %ss: IDDispatch CallDispatchPlayerID Connect unknown Exception( t lockPlayerIDt acquiret Truet isDispatchingPlayerIDR
|
t infot sockett timet DBConfigt IDDispatchServerIPt IDDispatchServerPortt AF_INETt SOCK_STREAMt connectt sendt recvt evalt xranget appendt UCN_Dispatch_PlayerIDt insertt closet ExceptionR t Falset release( t dbt selfR/ R0 t hostt portt addrt BUF_SIZEt clientt datat dataRecvt
|
resultDictR' R( t recst idt
|
collectiont e( ( sT .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyt CallDispatchPlayerIDE 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& R' R( i t FamilyIDs5 IDDispatch CallDispatchFamilyID Connect Exception %ss: IDDispatch CallDispatchFamilyID Connect unknown Exception( t lockFamilyIDR+ R, t isDispatchingFamilyIDR
|
R. R/ R0 R1 R2 R3 R4 R5 R6 R7 R8 R9 R: R; t UCN_Dispatch_FamilyIDR= t CallBackToSendFamilyIDPackR> R? R R@ RA ( RB t fromPackt typeRC R/ R0 RD RE RF RG RH RI RJ RK R' R( RL RM RN RO ( ( sT .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyt CallDispatchFamilyIDk 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 hasattrR, t getattrRX t intt Def_Cmp_Greatert Def_Cmp_Lowert Def_Cmp_Equ( t curTimet timeInfot indext callObjt
|
curCallObjt wday( ( sT .\\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 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' Z* d( Z+ e d) Z, e d* Z- d+ Z. d, Z/ d- Z0 d. Z1 d/ Z2 d0 Z3 d1 Z4 d2 Z5 d3 Z6 d4 d5 Z7 d6 Z8 d7 Z9 d8 Z: d9 Z; d: Z< d; Z= d< Z> d= Z? d> Z@ d? ZA d@ ZB dA ZC dB ZD dC ZE dD ZF dE ZG dF ZH dG ZI dH ZJ dI ZK dJ ZL dK ZM dL ZN dM ZO dN ZP dO ZQ dP ZR dQ ZS dR ZT dS ZU 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 RS(f c @ 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 f@ | j d d <| jH tI jJ tI jK | jL tI jM tI jN tI jO tI jP r1tQ jR | _S n tQ jT tI jU | _S tV | _W tV | _X d | _Y tZ | _[ tZ | _\ d S( NRi i i i i (] t CtrlDBt __init__R t 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 setServerR1 t
|
USER_DB_IPt USER_DB_PORTt setDataBaset USER_DB_NAMEt userdb_usert
|
userdb_pwdt base64R t Base64StringManipulatort
|
translatort EncodeStringManipulatort encodingR@ R- RT t loginHeapR0 t loginStartTimet lastCleanMergePlayerTime( RC t ctrlDBMgr( ( sT .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRk ¸ s c C s t S( N( t IsMergeServer( RC ( ( sT .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRÁ s c C s² t s
|
d St } d } | | j | k r0 d S| | _ x[ t j D]M \ } } | t | t k rl qF n | | t | k r qF n t j | qF Wt j d t t d S( Niô s! PopOfflineMergePlayer hascnt = %s(
|
t g_mergeRegisterPlayerDictR0 R¿ t itemst MergeRegPInfoIndex_LogoutTimet MergeRegPInfoIndex_LoginTimet popR
|
t debugt len( RC Rb t Def_CleanTimet accIDt packInfo( ( sT .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyt PopOfflineMergePlayer 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 rt 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 r.| j d } | j
|
| j( | | | j t S| t j) k r| j d } | j
|
| j ru| j* | | n | 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 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¾t S| t j5 k r| j d } | j
|
| j6 | | | j t S| t j7 k rát8 j9 rOt: j; d t: j< d t j7 } t j= | t t> S| j d } | j
|
| j r¥| j? | | sÓt j: d | j@ jA qÓn. | jB | | sÓt j: d | j@ jA n | j t S| t jC k r'| j d } | j
|
| jD | | | 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 St j dB | j t S(C Ni s begin process request type = %dR« t gstMergeGeneralReturnR© R¨ R° R¥ R® R¯ R¦ s recv map server crash data!Rm Ro R R Rq Rr Rs R¤ R£ R¢ R t DeployErrorsN DbSaveServer is open, type = %d request should be send to PyMongoDBSaveServerRl s< onSaveMapServerPlayerDataMergeServer failed!sessionID = 0x%Xs1 onSaveMapServerPlayerData failed!sessionID = 0x%XR R R R} R~ Rt Rz Rp R R R R R R R R| Rw Rv R Ry Rx Ru 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 OnGeneralDBOperR, R© t OnMergeQueryRegisterResultR¨ t OnMergeRegisterPlayerByCacheR° t OnMergeChildToCenterPlayerDataR¥ t OnQueryNewGuyCardStateR® t OnQueryRechargeR¯ t OnFinishRechargeR¦ t onCheckUpdateNewGuyCardStateRm R. t onSaveMapServerCrashDataRo t onSaveGameServerDataR t onGetGameServerPlayerDataR t onGMCmdListReqRq t onAuthenticationRr t onGetMergePlayerDetailt onGetPlayerDetailRs t onCreatePlayerR¤ t! onCreateRoleServerCheckIsHaveRoleR£ t" onCreateRoleServerCheckPlayerExistR¢ t# onCreateRoleServerRequestCreateRoleR R t onSaveGameServerPlayerSaveDataRl R1 t IsOpenDbSaveServerR t formatMsgt ERROR_NO_56RÎ R@ t$ onSaveMapServerPlayerDataMergeServert getPackHeadt sessionIDt onSaveMapServerPlayerDataR t OnSavePlayerInfoR t OnInsertAccR t OnPlayerIDMarkDeletedR} t OnGetCoinR~ t OnCoinChangeRt t OnCheckPlayerExistRz t OnDayRp t OnSavePlayerGMOPerR t OnGetExpiationCountR t OnGetPetExpiationCountR t OnGetExpiationR t OnGetPetExpiationR t OnUpdateServerDataVersionNOR t OnMapServerInfoR t OnUpdateTotalSavePointR| t OnGetPlayerMailStateRw t OnGetMailDetailRv t OnGetPlayerMailR t OnAddPlayerMailByAccIDRy t OnDeleteMailRx t OnUpdateMailRu 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( RC RB t packt post requestTypet
|
oFuncGradet msg( ( sT .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyt requestLogicProcess5 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 FamilyIDListR; RÈ t Countt
|
sendStringt GetBuffer( RC RW R! R' R( t sendPackRM ( ( sT .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRV ã 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 dispatchRR s# CallType 0 sendPack.FamilyIDList %ss CallType 1 need dispatch( RÑ R t tagGDRequestCanUseFamilyIDListt ReadDataR
|
RÇ t OutputStringt CallTypeRU t findt countRT t threadingt ThreadRY t startR R R R R R! R# R; RÈ R$ R% R& ( RC RB R t buft recvPackR RN R& R0 t tR' t rec( ( sT .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRÔ í s>
|
'
|
'
|
c C s t j } t j | _ | | _ | | _ t | j | _ | | _ t | j | _
|
| j | d d t j t j t j | j d S( Ni ( R t tagDGGeneralDBOperResultR t dgDBOperResultR t Resultt ResultSetRÈ t ResultSetLent ErrMsgt ErrMsgLent packSendt atMergeLogicR t stGamet stDataR& ( RC Rï R& t resultSett errMsgR' ( ( sT .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyt sendGameServerDBOperResult s c C sÏ | j } t j } d } | j | | t j d | j d } y t | 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 } | sNt j d | j rJ| 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 s>t j d |
|
| j r:| j | j d d d n d S|
|
j }
|
|
|
d k rþd } 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
|
rm} 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
|
rB} 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
|
rI} 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 eval('%s') failed!t s OperDict parse failed!s %s is not a dict!RN 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!R= t docss# insert %s into %s failed!error = %ss+ insert %s into %s failed!unknown exception!t updatet specs0 update %s failed!spec = %s, doc = %s, error = %ss= update %s failed!spec = %s, doc = %s,unknown exception occur!t removes+ remove from %s failed!spec = %s, error = %ss3 remove from %s failed!spec = %s, unknown exception!R. t fieldss %s.find(%s) failed!s oper %s not support!( RÑ R t tagGDGameServerGeneralDBOperR+ R
|
RÇ R, t NoneR9 t OperDictR? R t
|
NeedReturnRD t getSessionIDt
|
isinstancet dictt gett
|
basestringt lowerRG t strR= R@ R, RI RK R. t list( RC RB R R3 R4 R t operDictRO t colNamet colRF R& t errorMsgt doc_or_docst docRJ t
|
spec_or_idRL RB ( ( sT .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRÖ s
|
|
|
|
|
|
c
|
C s | 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 | _ t j | g rd | _ | 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 RE (" RÑ R t tagLPQueryRegisterResultR+ t AccIDt stript chrR
|
RÇ RQ t MergeProxyClientMgrt getMergeProxyClientMgrt findClientBySessionIDR R t tagMPQueryRegisterResultR t dgMergeQueryNewAccountR RÂ RT R9 R> Rî Rï R? R t stNoSenseR& t AccountRÈ t
|
AccountLent Pwdt PwdLen(
|
RC RB R R3 R4 R RÊ t clientSessionIDRH R' ( ( sT .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyR× ± s4 * *c C s? y | j } t j } d } | j | | t j } t j | _ | j } t
|
j } d } | j | | t | } d | k rý d | _ d | _ t | j | _ | j | j | j j d t j t j t j | j t j d d S| j d k r~d | _ 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 t+ | <Wn t, k
|
rö} t- j. d t- j/ d | t0 j1 t2 j3 | f } t j- | nE t- j. d t- j4 d t0 j1 t2 j3 | 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 RE 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(5 RÑ R t tagLPRegisterPlayerR+ R t tagMPRegisterPlayerResultR t dgMergeRegisterResultR t DataR t tagDBPlayert readDataRÈ R9 t ErrorMsgt ErrorMsgLenR> RQ Rî Rï R? R Ri R& R
|
R R) Rd Re Rf t groupIDRa RV Rb Rc t
|
PlayerNameRj Rk Rl Rm R. R0 RÂ R? R Rë t ERROR_NO_175t tracebackt
|
format_exct binasciit b2a_hext ERROR_NO_176( RC RB R R3 R4 R t loginResultPackt
|
playerDatat playerRect dbPlayerReadLenRn RH Rw t playerIDRÊ t
|
playerNameRO R ( ( sT .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRØ Ó sh * * * 41c C s y| j } | j } t j } d } | j | | | j j t d } t j d | | t
|
} | j i | d 6 } | s | j d k r£ d St j j }
|
t |
|
} | j d d } | j i | d 6i i d d 6| d 6d 6 t j d | d SWn t k
|
r`} t j d
|
t j d | t j | f } t j | n9 t j d
|
t j d t j | } t j | n Xd S( Ni s OnFinishRecharge ...%st OrderIDs .i t IsProcesst EndOrderTimes $sets OnFinishRecharge OrderID = %sR s# OnFinishRecharge error %s!pack = %ss OnFinishRecharge error!pack = %s( RÑ t getLengthR t tagMDFinishRechargeR+ R
Rb Rc R
|
RÇ t UCN_PayInfoR. R/ t datetimet todayRW t splitRI R? R Rë t ERROR_NO_170R| R} ( RC RB R R3 t packLenR4 R t orderIDR[ R& Rb t
|
curTimeStrRO R ( ( sT .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRÜ s2
|
,+%c C s 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 | _ | 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 ...%sRa R R R
t OrderInfot OrderAmounti s $sets OnQueryRecharge OrderID = %sR s" OnQueryRecharge error %s!pack = %ss OnQueryRecharge error!pack = %s(% RÑ R R t tagMDQueryRechargeR+ Rj Rb Rc R
|
RÇ R R. R/ R t tagDMRechargePushR t dgDBToMapServerR t gmReChargePusht SubTypeR R
RÈ t
|
OrderIDLenR t OrderInfoLenR^ t MoneyRI R% R& R? R Rë R R| R} ( RC RB R R3 R R4 R t accountR[ R& t billInfoR' RO R ( ( sT .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRÛ @ s@
|
$
|
(+%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...RE s- OnQueryNewGuyCardState cardID = %s not found!i s. OnQueryNewGuyCardState query error!cardID = %ss+ OnQueryNewGuyCardState cardID = %s state:%sR s) OnQueryNewGuyCardState error %s!pack = %ss& OnQueryNewGuyCardState error!pack = %s($ RÑ R R t tagMDIsMediaCardUsedR+ R
|
RÇ t CardIDR t tagDMIsMediaCardUsedR R R t gmQueryNewGuyCardStateR t CardIDLenR t tagDBNewGuyCardStatet UCN_DBNewGuyCardStateR t adoLoadt IsUsedt UserDataLent UserDataR% R& R t CardTypet ValidTimeR R? R Rë R R| R} ( RC RB R R3 R R4 R R' t objR[ t lastExceptionCntRO R ( ( sT .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRÚ n sb
|
+% c C s yt| j } | j } t j } d } | j | | t j } t j | _ t j
|
| _ | j | _ | j | _ t j d | j t j } | j | _ | j | _ | j | _ | j | _ | j | _ | j | _ | j | _ | t } | j | s@d | _ | j | | j t j d | j d Sd | _ | j | | j t j d | j Wn t k
|
rÁ}
|
t j d t j d |
|
t! j" | f } t j | n9 t j d t j d t! j" | } t j | n Xd | _ | j | | j d S( Ni s onCheckUpdateNewGuyCardState %ss/ onCheckUpdateNewGuyCardState failed!cardID = %si s0 onCheckUpdateNewGuyCardState success!cardID = %sR s/ onCheckUpdateNewGuyCardState error %s!pack = %ss, onCheckUpdateNewGuyCardState error!pack = %s(# RÑ R R t tagMDCheckUpdateMediaCardStateR+ R t tagDMCheckUpdateMediaCardResultR R R t gmUpdateNewGuyCardStateR R¢ R R
|
RÇ R, R R£ R¦ R§ R¨ R© Rª R¤ t adoCheckUpdateR9 R% R& R? R Rë t ERROR_NO_171R| R} ( RC RB R R3 R R4 R R' R« R[ RO R ( ( sT .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRÝ ¨ sJ
|
+% c C sË | j r d Sd } t j } | j | j | } | j sG d S| t } t j } | j j
|
| _ | j | s® t j d t j d | j } t j | d S| j | _ | j | d S( s ±£´æÍæ¼ÒÐÅÏ¢Ni R s load account failed, accid = %s( RÁ R t tagGDSavePlayerInfoR+ RÑ t GeTuiClientIDt UCN_DSAccountR t tagDSAccountRa RV t ACCIDt adoLoadCR Rë t ERROR_NO_57R
|
t
|
adoUpdateC( RC RB R R t
|
PlayerInfoR[ t PlayerAccR ( ( sT .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRñ Ó s
|
c C sf d } t j } | j | j | } t j d d | j | j | d t j | j f d S( s ½øÈë´´½ÇÂñµãi i)# s, OperatorID=%s&Step=%s&AccountID=%s&Flag=1000i N(
|
R t tagLDPrepareCreateRoleR+ RÑ t PegasusCollectorProxyR t GetPlayerPlatformRa R t GetPlatformAccID( RC RB R R Rº ( ( sT .\\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ÿÿÿÿRE s __ReadPlayerID playerID = %s(
|
R Rs Rt RÈ R@ R) R
|
R. R, Ra ( RC RB t saveDataR R R R ( ( sT .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyt __ReadPlayerIDö s
|
c C s? d } | j } | j } t j | | \ } } | t j k r;t 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 S| j | | \ } } } | t k rÜt t | t <| t | t _ t | t | t _ t j d | | | j j f n | r1t 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 Rr t ReadDWORDR t stMint
|
ReadStringt ToDWORDt crc32Rc RA t onSavePlayerDataCRCErrorR@ t _UserCtrlDB__ReadPlayerIDRÂ R0 RÄ t MergeRegPInfoIndex_PackDataRr RÈ t DataLenR
|
R. Rî Rï R t tagDBUpdateReturnt dgUpDateR- R! R9 R) R% R& ( RC RB R R R3 t lengthRX t
|
needReturnt
|
packCrcPost packCrct serverTypePost
|
serverTypeRÀ t calcCrct serverTypeDataR& R RÊ t updateReturn( ( sT .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRí sH
|
|
c C s d } | j } | j } t j | | \ } } | t j k rt j | | \ } } | } t j | | \ } } | }
|
t j | | \ } } | t j k r5t j | | | | \ } } t j
|
t | } | | k sVt t j } | |
|
| | |
|
d } | j | | | | t d f Sn! | j | | | | t d f St } d } t j r| j | | \ } } } n | j | | \ } } } | s | j j } t j d t j d | } t j | t j t j d d | | | n | r^t j } t j | _! t j | _" | | _# | | _$ | j% | | j& n | j' | | t j( d | | | j j f | | 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%XN() RÑ R R RÐ R Rr R R Rà RÄ RÅ RÆ Rc RA RÇ R@ R1 t PackSavet SavePlayerMapServerDataExt SavePlayerMapServerDataRî Rï R Rë t ERROR_NO_59R
|
R t DumpDataR t
|
getAppPathR RË RÌ R- R! R9 R) R% R& t RevoverBillProcessR. ( RC RB R R R3 RÍ RX RÎ RÏ RÐ RÑ RÒ RÀ RÓ RÔ R& R RÊ Rï R RÕ ( ( sT .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRð 6 sR
|
|
' #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 Ra i R R R
s $sets RevoverBillProcess success...%ss RevoverBillProcess error %s(
|
Rb Rc R R. R/ RI R
|
RÇ t maylogR ( RC RB RÊ R R[ R& R R ( ( sT .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRÜ q 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ÿÿÿÿRE 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 Rs Rt RÈ R@ R
|
R. R) Ra RV t UCN_DBPlayerRÒ RÓ R¹ RÕ t recPlayerLogofft savePlayerDatat UCN_RoleItemt tagRoleItemR, t UCN_RoleMissiont tagRoleMissiont UCN_RoleMissionDictt tagRoleMissionDictt UCN_RoleSkillt tagRoleSkillt UCN_RoleBufft tagRoleBufft UCN_RoleRepeatTimet tagRoleRepeatTimet UCN_PlayerHorseTablet tagPlayerHorseTablet gmOperCheckt
|
UCN_GMOpert tagGMOperR RÂ t tagDBGMIPR: t UCN_RolePett
|
tagRolePett UCN_PetSkillt tagPetSkillt UCN_RoleNomalDictt tagRoleNomalDictt UCN_PlayerDienstgradt tagPlayerDienstgradt UCN_BattleFormationt tagBattleFormationt AssertionError( RC RB RÀ R R R RN R t gmIPCntt gmIPRect i( ( sT .\\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ÿÿÿÿRE 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 Rs Rt RÈ R@ R
|
R. R) Ra RV Rì RÒ RÓ R¹ RÕ t FacePicRí t savePlayerDataExRï Rð R, Rñ Rò Ró Rô Rõ Rö R÷ Rø Rù Rú Rû Rü Rý Rþ Rÿ R RÂ R R: R R R R R R R R R R
|
R ( RC RB RÀ R R R RN R R R R ( ( sT .\\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ÿ R: t clearRt t OperR t gmForbidAcct onForbiddenUpdateR, R t TDateTime_NowR^ t EndTimet GMAccIDt TDateTimeToStringt Msg(
|
RC RÊ R RI R RÍ t cntt gmOperRecR t readLen( ( sT .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRý e s
|
|
|
|
4c C s× | j d | } | j | | } | j d | } | j | j i | d 6 | 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| rÉd } x× t rÅy? | j d | } | j | j | t t | j PWqòt j j k
|
rÁ} t j | k rn| d 7} qòn t t j d | j j t j d d | f t j d | | | f PqòXqòWn | j |
|
S( s ±£´æÍæ¼ÒÎïÆ·µÈÊý¾Ý£¬ÓÅ»¯°æs savePlayerDataEx_%s_Alls savePlayerDataEx_%s_removeR) i s' saving %s data, playerID = %s, cnt = %sR$ i t
|
__PackSaves savePlayerDataEx_%s_clears savePlayerDataEx_%s_readDataiÿÿÿÿs %sNs savePlayerDataEx_%s_makeSIDs savePlayerDataEx_%s_inserts %s.%s:docs = %si s0 Insert failed!docs = %s, error = %s, trycnt = %d( RÒ RÓ RK RÕ R RÂ R
|
RÇ RÈ R: R Rt R. R} t makeSIDt getRecordR, R= R@ t pymongot errorst OperationFailureR1 t TryCntOnWriteFailR t __class__t __name__t inspectt stackR ( RC R RB t collectionNamet
|
structNameRI t checkSIDt oAllFuncGradeRN R R R( R6 RÍ R^ R R* t trycntt err( ( sT .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyR v sn
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
.
|
c C sá | 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 r_t j d t | d
|
S|
|
| 7}
|
| r£| j d | } | j | j | j n | j d | } | j | j } | j | j | qÅ Wt | rÓd } x× t rÏy? | j d | } | j | j | t t | j PWqüt j j k
|
rË} t j | k rx| d 7} qün t t j d | j j t j d d | f t j d | | | f PqüXqüWn | j |
|
S( s ±£´æÍæ¼ÒÎïÆ·Êý¾Ýs savePlayerData_%s_Alls savePlayerData_%s_removeR) 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Ó RK RÕ R R R
|
RÇ RÈ R: R Rt R. R} R, R- R; R, R= R@ R. R/ R0 R1 R1 R R2 R3 R4 R5 R ( RC R RB R6 R7 RI R8 R9 RN R R R( R6 RÍ RH R R* R^ R: R; ( ( sT .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRî º sn
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
.
|
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 RE ( R t tagDBPlayerLogInfoOnLogOffRa Rx t AccStatet LVt Goldt GoldPapert Silvert SilverPapert GMLevelt Jobt
|
HappyPointt TJGTimet Statet TJGStateR0 t LastLogoffTimeR) t IsOnlineR t WriteBYTER t gstSavePlayerInfoLogOnLogOfft WriteStringR RÑ t sendDBRequest( RC t dbPlayert reqt sendBuf( ( sT .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRí ÿ s( !c
|
C s t t j } t j d t j d | j j | f } t j | t j
|
t j d | | t j } d } t | } d | j | | | k r¢ n1 | j | | j t j rÓ | j | j d n t j } t j | _ t j | _ d | _ | j | | j d S( NR s sessionID = 0x%x dump to file %st UserLogsi iÿÿÿÿi i ( RW t uuidt uuid4R Rë t ERROR_NO_60Rî Rï R
|
R RÚ R RÛ R Rs RÈ Rt t updatePlayerAccStateR) R t pysForbiddent sendAccForbiddenLogReqRa R RË RÌ R- Rr R! R9 R% R& (
|
RC RB R t saveDataWithCRCt dumpFileNameR R R RÍ RÕ ( ( sT .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRÇ s + c C sw t j } | | _ | | _ t | _ d } t j | t j } t j
|
| | j | j } | j | d S( NRE ( R t tagDBPlayerInfoLogForbiddenRa t IsForbiddenR0 t ForbiddenTimeR RK R t gstSavePlayerInfoLogOnForbiddenRM R RÑ RN ( RC t accidt isForbiddent accForbiddenLogReqt accForbiddenLogReqPackBuf( ( sT .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRX / 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 Rs R) R R· R
|
R R2 R3 R4 R5 R@ RÇ R= R¹ R, ( RC RB R t newStateRN R^ t lastSIDErrorCntt ret( ( sT .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRV 9 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 RE N( R t* tagGameServerToBalanceServerPlayerSaveDataR+ RÑ R RP t setSrcSvrTypeR t stLogint sendOKStringR t dgPlayerSaveGameServerData( RC RB R t saveGameServerPlayerDataReq( ( sT .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRé N s c C s d S( N( ( RC RB R ( ( sT .\\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 Ra t IsDeleteds player of accid = %s exists!i s1 onCreateRoleServerCheckIsHaveRole ok, Accid = %s!R s) Catch a unexpetcted exception, error = %s(# R t tagCSIsHaveRoleR+ RÑ R t tagDRequestResultR R¤ R Ra R Rs RV Rm Rì R R t
|
adoLoadCExR R
|
R. R9 t ExAttrt disDataBaseErrorR1 R8 t disAccStateErrorR% R& RÇ R Rë t ERROR_NO_62Rz R{ (
|
RC RB R R4 R' t PlayerRN R¬ Rd R ( ( sT .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRæ w s@
|
, "c C sá y¤ t j } | j | j t j } t j | _ | j | _ d | _
|
| j | | j rp d | _ n d | _ | j | | j t j d | j Wn6 t j d t j d t j } t j | n Xd S( Ni i s2 onCreateRoleServerCheckPlayerExist ok, Accid = %s!R s) Catch a unexpetcted exception, error = %s( R t tagCSCheckPlayerNameExistR+ RÑ R Ro R R£ R Ra R9 t hasPlayerByPlayerNameRx Rq R% R& R
|
RÇ R Rë t ERROR_NO_63Rz R{ ( RC RB R R4 R' R ( ( sT .\\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(
|
Rg R Rh t
|
CreateRoleRi R t dgCreatePlayerR
|
RÇ t sendFailString( RC RB R t Suct disCodet AccIdRI ( ( sT .\\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( Ry R Ro R R¢ R R9 Ra Rq R
|
RÇ R% R& R Rë t ERROR_NO_64Rz R{ ( RC RB R R| R} R~ RI R' R ( ( sT .\\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Ç R< R. R- R, t sleepR@ RP R/ R1 t IDDispatchPlayeIDLimitR0 R1 R2 ( RC RB RN R& t try_countt emptyCntR0 R5 ( ( sT .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyt CheckEmptyPlayerIDCountÚ sF
|
|
|
|
c C s; | t } | j } | r7 | d } | j | | Sd S( NR) iÿÿÿÿ( R< t find_oneRK ( RC RB RN R6 t newID( ( sT .\\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( NR) iÿÿÿÿs CheckEmptyPlayerIDCount OK( R1 t UseIDDispatchServerR Rì t PLAYERID_FEEDt PLAYERID_STEPt threadR R ( RC RB R R ( ( sT .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyt DispatchNewPlayerID s c C s3 t j } | | _ | t } | j | | j S( N( R Rµ R¶ R´ R¥ t AppID( RC RÊ RB t accountDataRN ( ( sT .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyR¾ ! s
|
|
c C sÿ t j } | j | j d | j d d | _ | j j | _ | t } | j | i t
|
| j d 6| j d 6 r§ t j d | j d t | j d f S| j | | j rã t j d | j d t | j d f St j t j | _ | j | } | d k rUt j d t j d
|
| j } t j | d t | j d f S| | _ t j d | j | j f | j | sÉt j d t j d | j } t j | d t | j d f S| j | st 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 | j, | j- f | _. t/ | j. | _0 | j1 | j2 t3 j4 } | j | _ | j | _ | j, | _, | j5 | _5 t) | _6 | j | _ d } t j" | t% j7 } t j8 | | j | j } | j1 | | j9 | j | } t: j; d d | d t j< | j f t= j> i | d 6| j d 6t j< | j d 6| j- d 6 } t: j; d | | S( Ni i Ra Rm s player of accid = %s exists!RE s! player of playerName = %s exists!iÿÿÿÿR s# PlayerID Dispatch failed!accid = %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=1000i t
|
OperatorIDt RoleIDt AccountIDRD iO (? R Rs Rt RÑ R Rm Ra RV Rì Rp R R
|
R t disCreatePlayerError_PlayerExistRw Rx t' disCreatePlayerError_PlayerNameConflictR R& R# t CreateRoleTimeR R Rë t ERROR_NO_65Rr R) RÇ t
|
adoInsertCR¥ t ERROR_NO_66R t
|
WriteDWORDRÆ RK R t tagDBServerLogRecR t gstSavePlayerLogR R R0 t Timet MapIDt SexRD R' RÈ t MsgLenRN R& R t tagDBPlayerInfoLogCreateRolet Facet PlayerRegisterTimet gstSavePlayerInfoLogOnCreateRM R¾ R½ R R¿ t urllibt urlencode( RC RB R t createPlayerRN t newPlayerIDR t itemDatat missionDatat missionDictDatat skillDatat bufDatat repeatTimeDatat horseDatat
|
gmOperDatat gmPermitDatat petDatat petSkillDatat normalDictDatat dienstgradDatat battleFormationDatat allDatat crct dataCrct dataWithCrcR& t dbServerLogRect createRoleLogRQ t appIDt
|
playerInfo( ( sT .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRy ( s¦ #
|
, D
|
!
|
c C s= | t } | j i t | d 6d d 6 } | j d k S( NRx i Rm ( Rì R. R R/ ( RC RB R RN t resultCollection( ( sT .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRw 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( NRE i i R+ R$ s$ ####reading %s of player %s,cnt = %ss %s( R. t limitR/ R R RX t has_keyR
|
RÇ R: t
|
readRecordRÑ t adoQueryCustomCt adoQueryCustom( RC R[ t queryR7 R8 R3 RH R« R^ t docCntR& R ( ( sT .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyt readPlayerPackSaveData 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 = %sRE s! getMergePlayerDataBuffer_%s_clears$ getMergePlayerDataBuffer_%s_readDataiÿÿÿÿs %sR) t PetIDi t TruckIDt OwnerIDs# getMergePlayerDataBuffer_%s_makeSID( i s ( RÒ RÓ R R R
|
RÇ RÈ R R: R RÕ Rt R R} R t hasFieldR) RÆ R t makePetIDt makeTruckIDt TructIDRÈ R, RÑ ( RC R¦ R7 RI R8 R9 R R( R6 RÍ R& R R R* t orgPlayerIDt oldPetIDt petIndext
|
oldOwnerID( ( sT .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyt getMergePlayerDataBuffer¶ s`
|
|
|
|
|
|
|
|
|
|
c
|
C sþ t j } | j | j d | j t j d | j | j j j t
|
d } | t k ry | j | | St | } | 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 = %sRE s# onGetMergePlayerDetail OK! accID=%sN( R t tagPlayerDetailReqR+ RÑ R R
|
RÇ Ra RV Rb Rc RÂ Rä RÉ RÆ Rr R R RK Ri R t dgPlayerInit(
|
RC RB R t getPlayerDetailReqt
|
queryAccidt regPlayerInfoR4 R¶ R· R¸ ( ( sT .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRã ú s
|
|
c 4 C s
|
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 rst 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 | _- | j. j/ | Wq t0 k
|
rN} | j t j | t t j d t j1 d | | t f } t j | d SXq W| j2 t j3 | | j4 d St5 j6 } | j | _ d | _7 | t8 } t9 } t: } | j; | i t< | j d 6| j7 d 6 } | t9 k s| j t j | t d St j= d | | j f | t: k s²t j> | j? st@ jA rt jB | _? | jC | t j d | | jD | j d qn t@ jA r²| j t j | tE d Sn i | j d 6} | tF } | jG | | t5 jH tI } tJ jK | d } t j d | d | tL } | jG | | t5 jM } tJ jK | d } t j d | d | tN } | jG | | t5 jO } tJ jK | d } t j d | d | tP } | jG | | t5 jQ } tJ jK | d } t j d | d | tR } | jG | | t5 jS } tJ jK | d } t j d! | d | tT } | jG | | t5 jU } tJ jK | d } t j d" | d | tV } | jG | | t5 jW } tJ jK | d } t j d# | d | tX } | jG | | t5 jY } tJ jK | d }! t j d$ |! d | tZ } | jG | | t5 j[ }" tJ jK |" d }# t j d% |# d | t\ } | jG | | t5 j] }$ tJ jK |$ d }% t j d& |% d | t^ } | jG | | t5 j_ }& tJ jK |& d }' t j d' |' d | t` } | jG | | t5 ja }( tJ jK |( d }) t j d( |) d | tb } | jG | | t5 jc }* tJ jK |* d }+ t j d) |+ d | j? t jd k ra | je | t jf | }, |, r+ |, jg th ji k rÙ| j t j | tE d Sd* th jj |, jg |, jk f } | jl | | |, jm | t j= d+ | | f q d, } | jl | | d- | t j= d+ | | f n, | j? t jB k r | j t j | tE d St5 jn }- | j |- _ | to } |- jp | }. tJ jK |. d }/ t j d. |/ d | j | | | | | | | | |. |" |$ |& |( |* }0 tq |0 }1 d- }2 tJ jr |2 |1 }2 tJ js |2 d }2 |2 |0 }3 | j2 t j | |3 t j d/ | | j f d S(0 Ni s$ getting player detail for accid = %sR s( kick accid = %s reason = %s, error :
|
%sR) s kick accid = %s reason = %si t IDRx RD R R> t STRt PNEt PHYt CONR? R@ RA RB t WarehouseGoldt WarehouseSilvert
|
FightPowers* exception = %s:kick accid = %s reason = %sRa Rm s accid = %s,playerID = %ss AccID = %s check SID failed!s roleItem cnt = %ss roleMission cnt = %ss roleMissionDict cnt = %ss roleSkill cnt = %ss roleBuff cnt = %ss roleRepeatTime cnt = %ss roleHorse cnt = %ss gmOper cnt = %ss rolePet cnt = %ss petSkill cnt = %ss roleNormalDict cnt = %ss roleDienstgrad cnt = %ss battleFormationcnt = %ss" Time past.EndTime = %s.Reason = %ss$ auto unforbidden accid = %s msg = %ss No forbidden oper found!RE s gmIP cnt = %ss- gstPlayerDetail Send accid = %s playerID = %s(t R RÒ R+ RÑ R R
|
RÇ Ra RV Rb Rc t queryMergePlayerListR{ R RÓ Rr R Rë t ERROR_NO_67Rz R{ RÈ R t tagServerMergeInfot PlayerCountt tagServerMergePlayert getFamilyLeaderFamilyIDt ERROR_NO_68t ERROR_NO_69t LeaderFamilyIDR) t NameRD R R> t TotalSTRt TotalPNEt TotalPHYt TotalCONR? R@ RA RB RÜ RÝ RÞ t PlayersR; t KeyErrort ERROR_NO_70Ri t dgServerMergeR& R Rs Rm Rì R R Rp R R. t isAccStateForbiddenR= R1 R8 t pysSIDCheckErrorForbiddenR¹ RX Rs Rï RÅ Rð R, R RÂ Rñ Rò Ró Rô Rõ Rö R÷ Rø Rù Rú Rû Rü Rþ Rÿ R R R R R R R R R R
|
RW t extractGMOperR! R$ R R# R& R' t unFobbidenAccR% R t
|
UCN_DBGMIPt adoQueryIndexRÆ R RK (4 RC RB R RÔ RÕ t
|
playerListR R' t
|
playerDictt singlePlayert leaderFamilyInfot whyRO RN R¬ Rd t loadOKt queryDictR§ t itemCntR¨ t
|
missionCntt roleMissionDictDatat missonDictCntt roleSkillDatat skillCntt roleBuffDatat bufCntt roleRepeatTimeDatat repeatTimeCntt roleHorseDatat horseCntR® t gmOperCntt rolePetDatat petCntR± t petSkillCntt roleNormalDictDatat dictCntt roleDienstgradDatat roleDienstgradCntR´ t battleFormationCntR) t gmIPt gmIPDataR Rµ R¶ R· R¸ ( ( sT .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRä ! s@ + " " %
|
,
|
|
|
|
|
|
|
|
|
|
|
|
|
|
D
|
c C so t j | _ | t } | j | i t | j d 6| j d 6 | j | j | j t
|
t j d | | d S( NRa Rm i ( R t pysNormalR= Rì t adoUpdateExCR Ra Rm R" R) R@ R R# ( RC RB RO t gmAccidR RN ( ( sT .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRô )
|
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 = %sRE ( R
|
R. t ctimeRX RV R RK R t gstAccForbiddenLogR t tagAccForbiddenLogRa R) R t OperTimet TimeLimitR% R' RM R RÑ RN (
|
RC R_ R R` t operTimet timeLimitt operGMAccidR Ra t accForbiddenLog( ( sT .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyR" 2
|
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
|
R. R Rÿ R: Rt R RN ( RC R_ t gmOperR® R t operCntR) R ( ( sT .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRó M
|
s c C s0 | t } t | j i | d 6d g } | S( Nt LeaderIDR× ( t UCN_FamilyInfoRX R. ( RC RB t leaderIDRN t familyInfoSnap( ( sT .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRä [
|
s
|
"c C sb | t } t | j i t | d 6d d 6t j d 6 } | j r^ | j j | d } n | S( s ²éѯ´¦ÓںϷþ״̬µÄ½ÇÉ«ÁбíRa i Rm R= N( Rì RX R. R R t pysServerMergeRº t transform_outgoingRN ( RC RB R_ RN R÷ ( ( sT .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRß `
|
s
|
|
3 c C sN t j } | j | j d | j t j } | j j j t
|
d } | | _ t j d | j | j f | t } t | j } | t j k rz| 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 rkt j d q¡ | j d k r7i | j d 6t j | j d 6| j d 6} y t j! | } t" j# t$ j% | }
|
t" j& |
|
d d
|
} | j' } d | k r)t j d | j | j( t j) | t* t+ SWq7q7Xn t, } | | j- d k re| j d
|
7_ q¡ | | _- d | _ n' | t j. k r)| j | | j j t
|
d | _ | j | _ | j j t
|
d | _ | j | _ | j j t
|
d | _ | j | _ | j j t
|
d | _ nx| t j/ k rÜ| j | | j j t
|
d | _ | j | _ | j j t
|
d | _ | j | _ | j j t
|
d | _ | j | _ | j j t
|
d | _ | j0 j1 d d
|
d } | j d k r t j d q¡ t j | | k rI| j( t j) | t* t j d t+ St2 j2 | | j t j3 | | j j4 j | j j k r¡ | j( t j) | t* t j d | | j | g t j3 | | j f t+ SnÅ| t j5 k r6| j | | j j t
|
d | _ | j | _ | j j t
|
d | _ | j | _ d | _ | j | _ | j j t
|
d | _ | j0 j1 d } t6 | d k r´| j( t j) | t* t+ S| d
|
} | j d k rÝt j d q¡ | j d k rót t, } t2 j2 | t7 | t j3 | | j j4 } i | d 6| d 6| d 6} y t j! | } t" j# d | }
|
t" j& |
|
d d
|
} | j' } t8 j9 | } | j: d d d
|
k råt j d | | f | j( t j) | t* t+ SWqóqóXn t, } | | j- d k r!| j d
|
7_ q¡ | | _- d | _ nk| t j; k r | j | | j j t
|
d | _ | j | _ | j j t
|
d | _ | j | _ | j j t
|
d | _ | j | _ | j j t
|
d | _ | j0 j1 d } t6 | d k r | j( t j) | t* t+ S| j d k r?t j d q¡ i | d
|
d 6| d d 6| d d 6| j d 6} y t j! | } t" j# d | }
|
t" j& |
|
d d
|
} | j' } t j< | d
|
d k rþt j d | | f | j( t j) | t* t+ SWq¡ q¡ Xn| t j= k ro
|
| j | | j j t
|
d | _ | j | _ | j j t
|
d | _ | j | _ | j j t
|
d | _ | j | _ | j j t
|
d | _ | j d k r× t j d q¡ t2 j2 d | t j3 | | j | j f j4 j | j j k r¡ | j( t j) | t* t j d! | | j | g t j3 | | j f t+ Sn2t> } t? } | j | s= | t> k rÆ
|
t j@ d" | j( t j) | tA t+ S| t? k r t j@ d# | j | j( t j) | tB t+ St$ jC r= t j d$ | j | j( t j) | tD t+ Sn | j | j j t
|
d k s¡ t j d% | j j | j j f | j( t j) | t* t+ StE jF d& d' | j d
|
t j | f | jG d
|
7_G tH jI tH jJ | _K | jL | s. t j@ d( | j | j( t j) | tA t+ S| jM t j) | | j t+ S() s ÕʺÅÈÏÖ¤i s auth accid = %s-%s...s 127.0.0.1s iner no checki t tokenR t appidt timeouti s "0"s checktoken fail:%si
|
s |iÿÿÿÿs spgame session errors spgame token error--%s-%st 1i R0 t signs$ http://sdk.lingleigame.com/api/tokent codes checktoken fail:%s-%si t sdkt appi t uint sesss$ http://sync.1sdk.cn/login/check.htmls" username=%s&appkey=%s&logintime=%ss gitAoyouSDK token error--%s-%ss DB access excption!s accid = %s not found!s authPack.AccID = %s, sid errors$ input psw = %s while stored psw = %si)# s, OperatorID=%s&Step=%s&AccountID=%s&Flag=1000s %s update LogNum error(N R t tagDataServerPlayerLoginR+ RÑ R R Rµ Ra RV Rb Rc R¶ R
|
RÇ t IDTypeR´ R^ R t
|
gitFreeSDKR· R R t TokenExpiret Phonet Pswt Adultt IPt RegIPt IsDebugR½ R R¿ R£ R¤ t urllib2t RequestR1 t CheckTokenUrlt urlopent readR{ t dgPlayerLogint disPswCheckErrorR, R0 R¾ t gitMRGamet gitSPGamet ExtraR t md5t GetLoginKeyt hexdigestt gitJiSuGameRÈ RW t jsont loadsRT t gitYiJieSDKt ToIntDeft gitAoyouSDKR R R Rr t disUserNameNotExistR8 t disGMKickR½ R t LogNumR R& R# t LastLoginTimet adoCheckUpdateCRi ( RC RB R t authPackt
|
accountRect authAccIDRN t appTypet valuesRI RP t responset the_paget nowTimet opSessionIDt extraListR) t loginTimet signStrRK R& R¬ Rd ( ( sT .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRâ h
|
sl
|
D2
|
2
|
|
I2 !) c C sY d } t j | | } t j | d } t j | t | | } | j | | d S( NRE i ( R RK RM RÈ R% ( RC RX t
|
fromPacketR3 t packBuf( ( sT .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRi o s
|
i c C sP d } t j | | } t j | d } t j | | } | j | | d S( NRE i ( R RK R% ( RC RX Ra t disconnectReasonRb ( ( sT .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyR{ w s
|
c C sV | j | j | j j | j j | j j | j j | j j | d S( N( R> RQ Rî Rï t poolIndexRX t
|
srcSvrTypet
|
dstSvrType( RC Ra Rb ( ( sT .\\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 = %dt fatalsM 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È Rt t
|
SaveStreamt
|
StreamDataR$ R t getLoggerR. R
|
Rî Rd t VersionNOR t SERVER_DATA_VERSION_NOR Rë t ERROR_NO_71Rh R RÚ R RÛ R t CRCCheckErrorServerTypeR RÃ R t
|
DUMPPACKETRÇ R} t DATASAVE_MARKR RÅ RÆ t CRCt ERROR_NO_72t ERROR_NO_73R: t AllPlayerStreamt setBufferR Rr t LenRð R RË t dgUpdateMapServerCrashDataR- R9 R> RQ Rï RX Re Rf R& ( RC RB R t crashDataR3 R RÍ R t debugdatat CalcCRCR t
|
PlayerDataR& R R' ( ( sT .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRÞ s` #)4 # &'( #" # +, 3c C s d S( N( ( RC RB R ( ( sT .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRá À s c ; C sW | t } t j } | j | } 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@ } 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 d. | tb } t jc }4 | |4 j | 7} t j d/ | td } t je }5 | |5 j | 7} t j d0 | tf } t jg }6 | |6 j | 7} t j d1 | th } t ji }7 | |7 j | 7} t j d2 y tj jk | d3 }8 Wn7 tl jm d4 tl jn d5 to jp }9 t jq |9 d SXd6 }: tr js |: tt ju }: |: |8 7}: | jv | tw jx |: t jy d7 tz | d S(8 Ns tagDBCrossPKUnNotifyOverInfo oks tagDBCrossPKBillboard oks tagDBPyXMZZ oks tagDBPySealDemonRecord oks tagDBPyBossAttention oks tagDBPyBourseItemLastPrice oks tagDBPyBourseRecord oks tagDBPyFamilyStoreItem oks tagDBPyPlayerFriend oks tagPlayerEnemy oks tagDBPyPlayerContacts oks tagDBPyPlayerBlack oks tagPersonalSocial oks tagPlayerTeamTable oks tagTeamMemberTable oks tagFamilyInfo oks tagPlayerFamily oks tagDBFamilyVS oks tagGameWorldEvent oks tagDBMissionPub oks tagDBIPManage oks tagDBGameServerEventTrig oks tagDBCountryInfo oks tagDBCountryFamilyWarResult oks tagDBCountryFamilyWarRace oks tagDBCountryFamilyWarRequest oks tagDBBillboard oks tagDBGoldOrderForm oks tagDBOverdueGoldOrderForm oks tagDBFamilyTech oks tagDBPlayerLabel oks tagDBPlayerRecall oks tagDBVsReward oks tagDBFamilyReward oks tagDBFamilyRewardRec oks tagDBFamilyAction oks tagGameFBPassRec oks tagUniversalGameRec oks tagGameGroup oks tagGameGroupMember oks tagGameGroupMutualInfo oks tagGameBourseItem oks tagHighLadderPlayer oks tagDBHighLadderItem oks tagHighLadderVSRec oks tagDBCompensationItem oks tagDBPersonalCompensation oks! tagDBEntireCompensationRequire oks tagCompensationPlayerRec oks tagPlayerViewCache oki Rh s2 Compress game server player data failed!error =
|
%sRE s) Game server player data send ok! len = %d({ t UCN_DBCrossPKUnNotifyOverInfoR t tagDBCrossPKUnNotifyOverInfot adoQueryAllR
|
RÇ t UCN_DBCrossPKBillboardt tagDBCrossPKBillboardt UCN_DBPyXMZZt tagDBPyXMZZt UCN_DBPySealDemonRecordt tagDBPySealDemonRecordt UCN_DBPyBossAttentiont tagDBPyBossAttentiont UCN_DBPyBourseItemLastPricet tagDBPyBourseItemLastPricet UCN_DBPyBourseRecordt tagDBPyBourseRecordt UCN_DBPyFamilyStoreItemt tagDBPyFamilyStoreItemt UCN_DBPyPlayerFriendt tagDBPyPlayerFriendt UCN_PlayerEnemyt tagPlayerEnemyt UCN_DBPyPlayerContactst tagDBPyPlayerContactst UCN_DBPyPlayerBlackt tagDBPyPlayerBlackt UCN_PersonalSocialt tagPersonalSocialt UCN_PlayerTeamTablet tagPlayerTeamTablet UCN_TeamMemberTablet tagTeamMemberTableR$ t tagFamilyInfot UCN_PlayerFamilyt tagPlayerFamilyt UCN_DBFamilyVSt tagDBFamilyVSt UCN_GameWorldEventt tagGameWorldEventt UCN_DBMissionPubt tagDBMissionPubt UCN_DBIPManaget tagDBIPManaget UCN_DBGameServerEventTrigt tagDBGameServerEventTrigt UCN_DBCountryInfot tagDBCountryInfot UCN_DBCountryFamilyWarResultt tagDBCountryFamilyWarResultt UCN_DBCountryFamilyWarRacet tagDBCountryFamilyWarRacet UCN_DBCountryFamilyWarRequestt tagDBCountryFamilyWarRequestt UCN_DBBillboardt tagDBBillboardt UCN_DBGoldOrderFormt tagDBGoldOrderFormt UCN_DBOverdueGoldOrderFormt tagDBOverdueGoldOrderFormt UCN_DBUnclaimedGoldFormt tagDBUnclaimedGoldFormt UCN_DBFamilyTecht tagDBFamilyTecht UCN_DBPlayerLabelt tagDBPlayerLabelt UCN_DBPlayerRecallt tagDBPlayerRecallt UCN_DBVsRewardt tagDBVsRewardt UCN_DBFamilyRewardt tagDBFamilyRewardt UCN_DBFamilyRewardRect tagDBFamilyRewardRect UCN_DBFamilyActiont tagDBFamilyActiont UCN_GameFBPassRect tagGameFBPassRect UCN_UniversalGameRect tagUniversalGameRect UCN_GameGroupt tagGameGroupt UCN_GameGroupMembert tagGameGroupMembert UCN_GameGroupMutualInfot tagGameGroupMutualInfot UCN_GameBourseItemt tagGameBourseItemt UCN_HighLadderPlayert tagHighLadderPlayert UCN_DBHighLadderItemt tagDBHighLadderItemt UCN_HighLadderVSRect tagHighLadderVSRect UCN_DBCompensationItemt tagDBCompensationItemt UCN_DBPersonalCompensationt tagDBPersonalCompensationt UCN_DBEntireCompensationRequiret tagDBEntireCompensationRequiret UCN_CompensationPlayerRect tagCompensationPlayerRect UCN_PlayerViewCachet tagPlayerViewCachet zlibt compressR Rë t ERROR_NO_75Rz R{ Rh R R R t$ GAMESERVER_GAMEWORLD_DATA_VERSION_NOt sendGameServerStringR t dgGameServerDataR. RÈ (; RC RB R RN t crossPKOverInfoRI t crossPKt XMZZt sealDemonRecordt bossAttentiont bourseItemLastPricet bourseRecordt familyStoreItemt playerFriendt playerEnemyt playerContactst playerBlacklistt playerSocialt
|
playerTeamt
|
teamMembert
|
familyInfot playerFamilyt familyVSt gameWorldEventt
|
missionPubt ipManaget gameServerEventTrigt countryInfot countryFamilyWarResultt countryFamilyWarRacet countryFamilyWarReqt billboardt goldOrderFormt overdueGoldOrderFormt unclaimeGoldFormt
|
familyTecht
|
playrLabelt playerRecallt
|
dbVSRewardt dbFamilyRewardt dbFamilyRewardRect dbFamilyActiont dbGameFBPassRect dbUniversalGameRect dbGameGroupt dbGameGroupMembert dbGameGroupMutualInfot dbGameBourseItemt dbHighLadderPlayert dbDBHighLadderItemt dbHighLadderVSRect dbDBCompensationItemt dbDBPersonalCompensationt dbDBEntireCompensationRequiret dbCompensationPlayerRect dbPlayerViewCachet compressDataR t SendData( ( sT .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRà Ä s¬
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
"
|
c C sh d } t j | j | \ } } t j | j | \ } } | j | | | j | | | d S( Ni ( R RÐ RÑ t saveGameServerGameData( RC RB R R RÎ RX ( ( sT .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRß ¶ s # c C sî | t j k rW 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 Sy t j d t | 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$ | t j d t | d } y!| j% | | t& t' j( | } | j% | | t) t' j* | } | j% | | t+ t' j, | } | j% | | t- t' j. | } | j% | | t/ t' j0 | } | j% | | t1 t' j2 | } | j% | | t3 t' j4 | } | j% | | t5 t' j6 | } | j% | | t7 t' j8 | } | j% | | t9 t' j: | } | j% | | t; t' j< | } | j% | | t= t' j> | } | j% | | t? t' j@ | } | j% | | tA t' jB | } | j% | | tC t' jD | } | j% | | tE t' jF | } | j% | | tG t' jH | } | j% | | tI t' jJ | } | j% | | tK t' jL | } | j% | | tM t' jN | } | j% | | tO t' jP | } | j% | | tQ t' jR | } | j% | | tS t' jT | } | j% | | tU t' jV | } | j% | | tW t' jX | } | j% | | tY t' jZ | } | j% | | t[ t' j\ | } | j% | | t] t' j^ | } | j% | | t_ t' j` | } | j% | | ta t' jb | } | j% | | tc t' jd | } | j% | | te t' jf | } | j% | | tg t' jh | } | j% | | ti t' jj | } | j% | | tk t' jl | } | j% | | tm t' jn | } | j% | | to t' jp | } | j% | | tq t' jr | } | j% | | ts t' jt | } | j% | | tu t' jv | } | j% | | tw t' jx | } | j% | | ty t' jz | } | j% | | t{ t' j| | } | j% | | t} t' j~ | } | j% | | t t' j | } | j% | | t t' j | } | j% | | t t' j | } | j% | | t
t' j | } | j% | | t t' j | } | j% | | t t' j | } | j% | | t t' j | } t j# d t j d j# d WnO t j k
|
rt 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 } | rÆy t j d t$ | t | f t j | } | j d d \ } } t | } t j d
|
| | | f t j | | | | } Wn6 t j d t j d t! j" } t j | qÓXt$ | } t j# d | t j d t | d } y | j% | | t& t' j( | } | j% | | t) t' j* | } | j% | | t+ t' j, | } | j% | | t- t' j. | } | j% | | t/ t' j0 | } | j% | | t1 t' j2 | } | j% | | t3 t' j4 | } | j% | | t5 t' j6 | } | j% | | t7 t' j8 | } | j% | | t9 t' j: | } | j% | | t; t' j< | } | j% | | t= t' j> | } | j% | | t? t' j@ | } | j% | | tA t' jB | } | j% | | tC t' jD | } | j% | | tE t' jF | } | j% | | tG t' jH | } | j% | | tI t' jJ | } | j% | | tK t' jL | } | j% | | tM t' jN | } | j% | | tO t' jP | } | j% | | tQ t' jR | } | j% | | tS t' jT | } | j% | | tU t' jV | } | j% | | tW t' jX | } | j% | | tY t' jZ | } | j% | | t[ t' j\ | } | j% | | t] t' j^ | } | j% | | t_ t' j` | } | j% | | ta t' jb | } | j% | | tc t' jd | } | j% | | te t' jf | } | j% | | tg t' jh | } | j% | | ti t' jj | } | j% | | tk t' jl | } | j% | | tm t' jn | } | j% | | to t' jp | } | j% | | tq t' jr | } | j% | | ts t' jt | } | j% | | tu t' jv | } | j% | | tw t' jx | } | j% | | ty t' jz | } | j% | | t{ t' j| | } | j% | | t} t' j~ | } | j% | | t t' j | } | j% | | t t' j | } | j% | | t t' j | } | j% | | t
t' j | } | j% | | t t' j | } | j% | | t t' j | } | j% | | t t' j | } t j# d WqÓt j k
|
rÂt j d t j d } t j | qÓXn t j# d | d k rêt j } t j | _ t j¡ | _ d | _ | j | j | j j | j j | j j | j j | j j | j t j# d | qêno | t j¢ k rª| j£ | | d t' j¤ | n@ | t j¥ k rÙ| j£ | | d t' j¦ | n t j§ d | d S( NRh sW Save game server crash data error:data version conflict!versionNO = %s, db version = %st GameServerDataRestoreLogsJ ±ÀÀ£Êý¾Ý°æ±¾ºÅУÑéʧ°Ü(Èç¹ûÊǸüа汾£¬ÇëÆô¶¯¾É°æ±¾·þÎñÆ÷µ¼Èë±ÀÀ£Êý¾ÝÊÔÊÔ)t tagGDGameServerGameDatas 0.mdats Compress GameData = %ss |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...s GameData = %si s Save game server world data ok!s ϵͳ±ÀÀ£Êý¾Ý±£´æ³É¹¦!s Short data buf, ignore...s ±ÀÀ£Êý¾Ý¿ÉÄܲ»ÍêÕûs ±¾´ÎGameServer±ÀÀ£Êý¾Ý±£´æ³É¹¦£¡s Save game server player data ok!s ÎÞ±ÀÀ£Êý¾Ý...s Compress len %s, GameData = %ss5 Decompress game server world data failed! error =
|
%ss= Decompress game server world data success, len = %s!saving...s Empty crash data,ignore...sI saveGameServerGameData saveType = 0 decompressGameDataLen = %s responsed!t tagDBMailListt tagDBMailItemLists saveType = %s not processed!(¨ R t dgGameServerCrashDataR t ReadWORDRÂ RÄ R Rç R Rë t ERROR_NO_76R
|
Rh R Rl R RÚ t ost patht joinR RÛ t DUMP_PATHR, RÇ R} Rä t
|
decompressR R^ R| t a2b_hext ERROR_NO_77Rz R{ R. 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½ R¾ R¿ RÀ RÁ RÂ RÃ RÄ RÅ RÆ RÇ RÈ RÉ RÊ RË RÌ RÍ RÎ RÏ RÐ RÑ RÒ RÓ RÔ RÕ RÖ R× RØ RÙ RÚ RÛ RÜ RÝ RÞ Rß Rà Rá Râ Rã t ShortBuft ERROR_NO_78R RË RÌ R- R R! R9 R> RQ Rî Rï Rd RX Re Rf R& t ERROR_NO_80t ERROR_NO_81Ro t dgPlayerMailListt savePlayerMailDataR" t dgPlayerMailItemListR# R ( RC RB R RI R t saveTypeRÎ t markt versionNOR¶ t gameDataLent gameDataR t decompressGameDatat pyDataLent pyDataHext gameDataReadPosR' t decompressGameDataLen( ( sT .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyR ß st % . "
|
# " 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
|
R. R) t adoDeleteByIndexR: R Rt R; R- R, R= R@ R. R/ t PyMongoErrorR1 R1 R R2 R3 R4 R5 R Rë t ERROR_NO_152( RC R RI R R6 R7 RB t recCntRN R6 RH R R* R: R; R ( ( sT .\\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 } xÄ t ry | j | t t PWqUt j j k
|
r} t j | k rª| 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 s %s.%s save %s failed!s %s.%s, error = %s, trycnt = %s( RÈ R
|
R. R R/ R RÂ t drop_collectionR: R Rt t
|
dumpStringR R2 t _UserCtrlDB__name_R4 R5 R; R- R, R= R@ R. R/ R0 R1 R1 R R3 ( RC RI R R6 R7 RB RC RN RH R6 R R* R: R; ( ( sT .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyR. sD
|
|
|
.
|
|
.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ÿÿÿÿR) t FriendIDi s %s.%s:PlayerID = %si s5 delete failure!PlayerID = %s, error = %s, trycnt = %d( RÈ R R/ R RÂ R
|
R. R: R+ R, RK R) RH R. R/ R0 R1 R1 R R2 R3 R4 R5 R ( RC RI R t
|
packStructR6 RB RC RN R6 R R* R: R; ( ( sT .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyt savePlayerDeleteFriendData1 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Â R. R: R Rt R R/ t adoInsert( RC RI R6 R7 RB R R RC RN R6 t datalenR R* ( ( sT .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyR4 R 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 RE R s* Insert Acc failed, accid = %s, error =
|
%s( RÑ RÈ R t tagBDStringTypeSendR+ R Rµ Rt Rr RÊ R R& R# t RegisterTimeR´ R R{ R t dgInsertAccR@ Ri R, R Rë t ERROR_NO_83R¶ Rz R{ R
|
(
|
RC RB R RI R RM t oTypeSendt AccRN R ( ( sT .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRò o 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 Ra R) R s; OnPlayerIDMarkDeleted failed! Playerid = %d, exception = %s( RÑ RÈ R t tagMarkPlayerDeletedR+ Rì R Rs R) R R· R@ R1 R8 Rm R R Ra R, R Rë t ERROR_NO_84Rz R{ R
|
( RC RB R RI RM R t oMarkPlayerDeletedR[ t oPlayert SidErrorCntR ( ( sT .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRó s.
|
, +c C s yÓ t j } | j | j | t } t j } | j | _ | j | sd t
|
j d t St
|
j d t j | j | j f t j } t j | _ | j | _ | j | | j t
|
j d t SWn6 t j d t j d t j } t
|
j | n Xt S( Ns" gstGetCoin, not found match records% Type = %d, AccId = %s, GoldCoins = %ds process gstGetCoin okR s' OnGetCoin catch excepption, error =
|
%s( R t tagDGetValueByAccR+ RÑ t UCN_AccCoinsR t tagAccCoinsRS Ra R¥ R
|
R. R@ R R} t GoldCoinsR t tagDServerValueTypet dgCoinR t ValueR% R& R, R Rë t ERROR_NO_85Rz R{ ( RC RB R t oDGetValueByAccR[ t oAccCoinst oSvrValueR ( ( sT .\\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 tagMDCoinChangeReqR+ RÑ R
|
R. RS R) t CoinRZ R R[ Ra R R] R t dgCoinChangeResultR R¥ R% R& R@ R~ R\ t UseGoldCoinst adoUpdateR Rë t ERROR_NO_87R_ R^ R t tagDBPlayerLogInfoOnCoinChangeRN Rc t" gstSavePlayerInfoLogOnOnCoinChanget ERROR_NO_88Rz R{ R, ( RC RB R t oCoinChangeReqR[ Rb t retPackR t oDBPlayerLogInfoOnCoinChange( ( sT .\\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 Rx Rm R s% OnCheckPlayerExist catch exception
|
%s( R t tagBDCheckNameExistR+ RÑ R t tagDBPlayerNameIsExistR Rs Rè Rx Rm Rì R t dgCheckPlayerExistR- RÈ t NameLenRp R R9 R) R% R& R Rë t ERROR_NO_89Rz R{ R
|
R@ R, ( RC RB R t curPackRn RW R[ R ( ( sT .\\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 R1 t EventShellEnableR t OnDayProcessR Rë t ERROR_NO_161Rz R{ ( RC RB R R ( ( sT .\\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
|
R@ R, ( RC RB R RI R t PlayerIdR ( ( sT .\\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( NRa ( R RY R+ RÑ t UCN_ExpiationR. R RS R/ R R] R t dgGetExpiationCountR R_ R% R& R, ( RC RB R Ru R[ t recCountRn ( ( sT .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRù 9 s
|
% c C s t j } | j | j | t } | j i t | j d 6 j } t j
|
} t j | _ | | _ | j | | j t S( NRa ( R RY R+ RÑ t UCN_PetExpiationR. R RS R/ R R] R t dgGetPetExpiationCountR R_ R% R& R, ( RC RB R Ru R[ R} Rn ( ( sT .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRú G 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 Ra t ExpiationIndext ExpiationTimeR? R@ RA RB 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 tagMDGetExpiationExR+ RÑ R$ R t tagDMGetExpiationExResultR t dgGetExpiationR R{ R. R RS t tagExpiationR R Ra R R? R@ RA RB R R R R
R R R R R R R R R R R R R 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 DatasR; RK R@ R% R& R: R t tagExpiationLogR0 t ReceiveDateRN Rc t gstGetExpiationLogR, ( RC RB R Ru t needCountR' RN t
|
expiationst colDelt curDatat expiationR t dbDatat saveLog( ( sT .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRû U 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 RY R+ RÑ R~ R t tagPetExpiationRS Ra R¥ RN R t dgGetPetExpiationR Rr R RÊ R% R& R@ R t tagPetExpiationLogR0 R¯ R R t NPCIDt Lvt Expt BindTypet UseCreatorDrugCntt Friendlinesst SkillIDListt HPTalentt PhysicAtkTalentt MagicAtkTalentt PhysicDefTalentt MagicDefTalentRN Rc t gstGetPetExpiationLogR, ( RC RB R Ru R[ R¶ R& R' R· ( ( sT .\\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 tagServerDataVersionNORt RÑ R Rë t ERROR_NO_91R
|
R@ t UCN_ServerDataVersionNORG RL t ERROR_NO_92R, ( RC RB R t dbRecvR R[ ( ( sT .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyR O s
|
|
c C s t j } | j | j t j } d | j | j k rl t j d t j
|
d } t j | t St | _ t | d d t j t j | _ | t } | j | i | j d 6t | j d 6 st j d t j d | j | j | j f } t j | t St S( NiÿÿÿÿR s$ tagDBMapServerInfo:lack of pack datat tagDBMapServerInfot LogIndext LogIDR' s: OnMapServerInfo failed:LogID = %s, LogIndex = %s, Msg = %s( R RN R+ RÑ R RÍ Rt Rr R Rë t ERROR_NO_93R
|
R@ R0 R R R1 t LOGINDEX_FEEDt LOGINDEX_STEPRÎ t UCN_DBMapServerInfot adoCheckUpdateExRÏ R R' t ERROR_NO_94R, ( RC RB R R4 R¶ R R[ ( ( sT .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRþ c 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
|
R. R RN R+ RÑ R t tagDBPlayerSaveCoinLogRt Rr R Rë t ERROR_NO_95R} RÈ R@ R´ R Rµ Ra R· t TotalSavePointRe RT t ERROR_NO_86t ERROR_NO_96Rz R{ R, ( RC RB R R4 R¶ R R[ t dbDocRe ( ( sT .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRÿ y 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 tagDBGetMailListReqR+ RÑ t UCN_DBMailListR. R) R t wmtSaveR/ t MAX_PLAYER_MAIL_COUNTt pmiFullt wmtUnReadedt pmiNewLettert pmiNullR t tagPlayerMailInfot InfoTypeRî Re R R@ t stRoutet RouteServerIndexRd Rè t dgPlayerMailStateR& R Rë t ERROR_NO_97Rz R{ R
|
R@ R, ( RC RB R R4 R[ t docCountt stateR' R ( ( sT .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyR s,
|
0 ) " c
|
C sB yt j } | j | j | t } t j } | j | _ | j | } | t } t j
|
} | j | _ | j | s t j d | j t St j } t j | _ | j | _ t | j | _ | | _ t | | _ | j | | j Wn7 t j d t j d t j } t j | t SXt S( s È¡µÃÍæ¼ÒÓʼþÏêÇés mail list not exist! mailid = %sR s$ OnGetMailDetail throw a exception
|
%s(! R t tagDBGetMailDetailReqR+ RÑ t UCN_DBMailItemListR R# t MailIDRö Rß R" R¥ R
|
R R@ R t tagDBMailDetailViewR t dgMailDetailR t MailDetailDataRÈ t MailDetailDataLent MailItemDatat MailItemDataLenR% R& R Rë t ERROR_NO_98Rz R{ R, (
|
RC RB R R4 R[ t dbMailItemListR§ t
|
dbMailListR' R ( ( sT .\\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Þ R+ RÑ R t tagDBGetPlayerMailR t
|
dgMailListR Rß R. R) t MailExistTimet tagDBMailInfoR Rð RÝ Rû Rü Rý Rú Rþ t MailR; RÈ t MailCountR% R& R Rë t ERROR_NO_99Rz R{ R
|
R@ R, (
|
RC RB R R4 R' R[ RH R^ t mainInfoR ( ( sT .\\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 dataRa i Rm s" not exist player role , accid = %sRð s+ OnAddPlayerMailByAccID: exist a same mailidR) s+ OnAddPlayerMailByAccID throw a exception
|
\s(/ R@ R RN R+ RÑ Rr RÊ R, R t tagDBMailList_SaveSysMailRt R Rë t ERROR_NO_100R
|
Rì R. R Ra R/ R. Rß Rð t ERROR_NO_101R" t SenderIDRÜ RÝ Rû Rü R Rý Rú t ContentRÈ t
|
ContentLenRþ t ContentUseSysMessageRL t ERROR_NO_102Rz R{ R t dgAddPlayerMailByAccIDR R% R& ( RC RB R R& R' R4 t curMailR R[ RH R^ ( ( sT .\\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 tagDBDeleteMailR+ RÑ Rß R R" Rð R@ R Rë t ERROR_NO_103R} R
|
R@ Rï R# t ERROR_NO_104t ERROR_NO_105Rz R{ R, ( RC RB R R4 R[ R^ R ( ( sT .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyR 3 s,
|
(
|
( " c C sÄ yt j } | j | j | t } t j } | j | _ | j | sÊ t j
|
t j d d | j j | j f | j t j d t j d | j j | j f } t j | t S| j râ | j | _ n | j rú | j | _ n | j rd | _ n | j rK| j | _ d | _ d | _ d | _ d | _ n | j | s×t j
|
t j d d | j j | j f t | j t j d t j d | j | j j f } t j | t S| j! r
| t" } | j | _ | j# | s
t j
|
t j d d | j j | j f t | j t j d t j$ d | j | j j f } t j | t Sn Wn7 t j d t j% d t& j' } t j | t SXt( S( Ns UserLogs\UpdateMailFailDumps
|
%d_%s.mdatR sD update mail fail, load tagDBMailList fail, session = %d, mailid = %si s, update mail fail, maiid = %s, sessionid = %ds! OnUpdateMail throw a exception
|
%s() R t tagDBUpdateMailR+ RÑ Rß R R" Rð R¥ R RÚ R RÛ Rî Rï R Rë t ERROR_NO_106R
|
R@ t UpdateMailTypeRÝ t UpdateLetterTypeRý t GetAllMoneyR t
|
ReturnMailR
|
RÜ Rú Rh R} t ERROR_NO_107t
|
GetAllItemRï R@ t ERROR_NO_108t ERROR_NO_109Rz R{ R, ( RC RB R R4 R[ R^ R ( ( sT .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyR P 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( NRa i Rm R) RÜ s $neRÝ i R s' OnQueryCanSendMail throw a exception
|
%s( R Rp R+ RÑ R Rq R t dgQueryCanSendMailR- Rè RÈ Rs Rì R. R R/ R) R9 Rß Rà Rá R% R& R Rë t ERROR_NO_110Rz R{ R
|
R@ R, ( RC RB R R4 R' R[ RH R/ R ( ( sT .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyR
s0
|
&
|
0 " c C s t j } t j | _ t } xØt røyt j } | j | j | t
|
} d } xÚ t r5yW | j i i t d 6d 6t | j d 6d d 6i i d d 6d 6t t t t PWq\ t j j k
|
r1t j | k rî | d 7} q\ n t } t t j d t j d
|
| j | f } t j | Pq\ Xq\ W| s@Pn | j i t | j d 6d d 6 j d } | j r
| d }
|
|
|
d } |
|
d | _ |
|
d | _ |
|
d | _ d } x¹ t rwy6 | j i | d 6i i d d 6d 6t t t t PWq¿t j j k
|
rst j | k r0| d 7} q¿n t } t t j d t j d
|
| j | f } t j | Pq¿Xq¿W| s
Pq
n | j i t | j d 6d d 6 j | _! Wn< t j d t j" d t# j$ } t j | t } n XPq! W| j% | | j& | S( Ni s $ltt ExpiredTimeRa t IsAccepti s $seti R s6 OnAccIDSendPrize!Update failed!AccID = %s, trycnt = %dt
|
CheckValuet PrizeIDt PrizeNumR s% OnAccIDSendPrize throw a exception
|
%s(' R t tagDPlayerGetItemR t dgAccIDSendPrizeR R, R RY R+ RÑ t UCN_AccIDSendPrizeRI R0 R RS R@ R. R/ R0 R1 R1 R R Rë t ERROR_NO_111R
|
R. R¾ R/ t ItemIDR$ R t ERROR_NO_112t RemainItemCountt ERROR_NO_113Rz R{ R% R& ( RC RB R R' Re R4 R[ R: R RH R^ R# ( ( sT .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyR ¦ sn
|
R
|
% /
|
|
1
|
% 3"
|
c C sf y(t j } | j | j d d l } | j } | t } | j i t | j d 6d d 6 j
|
} | j | } | t j d k r t j d | | f n | j } t j } t j | _ | | _ | j | | j | j | } | t j d k r't j d | n Wn7 t j d t j d t j }
|
t j |
|
t SXt S(
|
NiÿÿÿÿRa i R" g @@s4 OnCheckItemPrize db process time = %s, PrizeCnt = %ss sendString process time = %sR s% OnCheckItemPrize throw a exception
|
%s( R RY R+ RÑ t timeitt default_timerR( R. R RS R/ R1 t ProfileThresholdR
|
R R R] R t dgCheckItemPrizeResultR R_ R% R& R Rë t ERROR_NO_114Rz R{ R@ R, ( RC RB R R4 R. t startTickR[ t PrizeCntt processTimeR' R ( ( sT .\\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 RY R+ RÑ R´ R Rµ RS R¶ R R& R# R· RR RO R R{ R RB R
|
R. R@ RS R¹ Ri t dgPlayerAccLoadR Rë t ERROR_NO_115Rz R{ R, ( RC RB R R4 R[ R^ t strNowR ( ( sT .\\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 RN R+ RÑ t tagIRAddItemRr R
|
R RS R* t ItemCntR( R t tagAccIDSendPrizeR t GetTransactionIDStrR# Ra R$ R% R0 R! t PrizeReasonR" t SendPrizeTimeR R t tagIAddItemResultRL t Lengtht AccLenR$ R9 R% Rc R t dgAddAccItemOKR& R@ R t tagAccTransactionLogt TransactionIDt
|
OperReasont ProcessTimet ItemCountRN t gstItemTransactionLogR Rë t ERROR_NO_116Rz R{ R, (
|
RC RB R R4 t recvDataR[ R^ R' t curLogR ( ( sT .\\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 RN R+ RÑ R t tagDSAccount_UpdateTelLockStateRt Rr R´ Rµ Ra R¶ R· t TelLockStateRT R Rë t ERROR_NO_117R
|
R@ t ERROR_NO_118Rz R{ R, ( RC RB R R4 RJ R[ R^ Re R ( ( sT .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyR g 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 RN R+ RÑ R t tagDSAccount_UpdateAdultRt Rr R´ Rµ Ra R¶ R· R9 RT R Rë t ERROR_NO_121R
|
R@ t ERROR_NO_122Rz R{ R, ( RC RB R R4 RJ R[ R^ Re R ( ( sT .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyR s&
|
( " c C s yÝ t j } | j | j | t } t j } | j | j t | d d t
|
j t
|
j | _ | j | r d | _ n d | _ t j } t j | _ | j | _ t | j | _ | j | | j Wn7 t j d t j d t j } t j | t SXt S( NR¬ R i i R s# OnAddExpiation throw a exception
|
%s( R RN R+ RÑ R{ R R¬ Rt Rr R R1 t tagExpiation_ExpiationIndex_FEEDt tagExpiation_ExpiationIndex_STEPR RL t ADOResultR t dgAddExpiationOKR RÈ RÊ R% R& R Rë t ERROR_NO_123Rz R{ R
|
R@ R, ( RC RB R R4 R[ R^ R' R ( ( sT .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyR ° s,
|
" c C s yÝ t j } | j | j | t } t j } | j | j t | d d t
|
j t
|
j | _ | j | r d | _ n d | _ t j } t j | _ | j | _ t | j | _ | j | | j Wn7 t j d t j d t j } t j | t SXt S( NR¸ R i i R s& OnAddPetExpiation throw a exception
|
%s( R RN R+ RÑ R~ R R¸ Rt Rr R R1 t# tagPetExpiation_ExpiationIndex_FEEDt# tagPetExpiation_ExpiationIndex_STEPR RL RU R t dgAddPetExpiationOKR RÈ RÊ R% R& R Rë t ERROR_NO_124Rz R{ R
|
R@ R, ( RC RB R R4 R[ R^ R' R ( ( sT .\\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 = %dRE s, OnServerMergeDeleteRole throw a exception
|
%s() R RN R+ RÑ R t tagDBPlayer_DeleteRoleUpdateRoleRt Rr R{ R t dgServerMergeDeleteRoleR Rë t ERROR_NO_125R
|
R@ R, Rì Rs t DeletePlayerIDR) R· Rm R¹ t UpdatePlayerIDR? R@ RA RB RÜ RÝ R. R/ R0 R1 R1 t ERROR_NO_126Ri t ERROR_NO_127Rz R{ ( RC RB R R4 RJ R R: R[ R^ t Rett updatedoc( ( sT .\\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 = %dRE s0 OnServerMergeUpdateAccState throw a exception
|
%s( R RN R+ RÑ R t tagDBPlayer_ChangeAccStateRt Rr R, Rì Rs R) R· R= R¹ R. R/ R0 R1 R1 R Rë t ERROR_NO_128R
|
R{ R t dgServerMergeUpdateAccStateR@ Ri t ERROR_NO_129Rz R{ (
|
RC RB R R4 RJ R: R[ R^ Rc R ( ( sT .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyR 2 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 Rx i R s@ OnServerMergeChangeName!Update failed!PlayerID = %s, trycnt = %ds, OnServerMergeChangeName throw a exception
|
%ss7 OnServerMergeChangeName playerID = %s, newName = %s ok!(% R RN R+ RÑ R t tagDBPlayer_ChangeNameRt Rr R
|
R. R) Rx R, Rì R. R R/ RU R t dgServerMergeChangeNameR RÈ RÊ R% R& R. R/ R0 R1 R1 R Rë t ERROR_NO_131R@ t ERROR_NO_132Rz R{ ( RC RB R R4 RJ R: R[ R' R ( ( sT .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyR W 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 RN R+ RÑ R Rm Rr R R1 t tagDBImpeach_ImpeachIndex_FEEDt tagDBImpeach_ImpeachIndex_STEPRn t UCN_DBImpeachRL R Rë t ERROR_NO_133R
|
R@ t ERROR_NO_134Rz R{ R, ( RC RB R R4 R^ R[ R ( ( sT .\\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_172Rz R{ R
|
R@ R, ( RC RB R R ( ( sT .\\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 tagLPStringDataR+ R t tagDGMergerChildToGameStringDataR t dgMergerChildToCenterR RÊ Rr t packSendBySessionIDt atInnerR R@ RA R& R, ( RC RB R t ServerMgrt sendViaSessionIDt SessionIDt PoolIndexR3 R4 R R' ( ( sT .\\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 inRu i iÿÿÿÿs8 OnMergeChildToCenterPlayerData sendString toMapServer %s( R
|
RÇ R Rv Rw RÑ R t tagLPPlayerDataR+ R t tagDMMergePlayerDataR R R t gmMergePlayerDataR RÊ Rr R) R{ R| R Rè RA R& R, ( RC RB R R} R~ R R R3 R4 R R' ( ( sT .\\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 Ra Rm s= DumpSinglePlayerDataByAcc Exception accid = %s,playerID = %sR) s gmIP cnt = %st DumpPlayerDatas %s.pdsavet wbiÿÿÿÿ(= R
|
R. R Rs Ra Rm Rì R R Rp R RÕ R) Rï RÅ Rð R, R RÂ Rñ Rò Ró Rô Rõ Rö R÷ Rø Rù Rú Rû Rü Rþ Rÿ R R R R R R R R R R
|
R RV Rõ Rö RÇ RÑ R' R( R) R RÛ t existst mkdirt opent structt writet flushR> (* RC RB R RO RN R¬ Rd Rü Rý R§ Rþ R¨ Rÿ R R 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 DumpDirt fileHandlerR ( ( sT .\\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( NR i s %s.pdsaveRE t rbiÿÿÿÿs$ Saving player data,playerID = %s....(8 R' R( R) R RÛ R R R@ R RA R> R Rs Rt RÈ R
|
R. R) Ra RV Rì RT R Rï Rð R, Rñ Rò Ró Rô Rõ Rö R÷ Rø Rù Rú Rû Rü Rý Rþ Rÿ R RÂ R R: R R R R R R R R R R
|
R ( RC RB R R t FileDirRÀ R R R R RN R R R ( ( sT .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyt SaveSinglePlayerDataFromDumpFileo sZ
|
|
|
|
|
,)))))) ) #)))))(h R3 t
|
__module__Rk RÁ RÌ R RV RÔ RD RÖ R× RØ RÜ RÛ RÚ RÝ Rñ R RÈ Rí Rð RÜ RØ R× Rý R@ R Rî Rí RÇ RX RV Ré Rl Ræ Rç Rå Rè R R R R¾ Ry Rw RÅ RÑ Rã Rä Rô R" Ró Rä Rß Râ Ri R{ R% RÞ Rá Rà Rß R RD R. RJ 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 ( ( ( sT .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyRi · sÐ _ ÿ ¯
|
' " I $ . : +
|
3 ; o p D E
|
, 0
|
n D ' ÿ ÿ = ò ) ú + - ! ' B
|
Ï + " ! " 8 5 ! @ % = & # C % R mc C s d d l } | j d d S( Niÿÿÿÿt pause( R' t system( R' ( ( sT .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyt testº s t __main__(Q R' Rä R0 R R| RS RG R. Rj t DBCommonR R 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 t ConfigParsert
|
__import__R1 t ctypesR Rz t
|
EventShellR R R4 t Collections.CollectionDefinet NetR t GMToolLogicProcessR R Rd R½ R£ R= RK R[ R` Ra R_ RÁ RÂ R" RÅ RÄ RÉ t MergeRegPInfoIndex_GroupIDR t allocate_lockR* RS RP RY Rh Ri R R3 ( ( ( sT .\\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\UserCtrlDB.pyt <module> s
|
|
4"".
|
|
& . ÿ ÿ ÿ ÿ ÿ ÿ ÿ ÿ ÿ ÿ ÿ ÿ ÿ ÿ ÿ ÿ ÿ ÿ ÿ ÿ
|
