ó
|
¨[0hc @ så d d l Z d d l Z d d l Td d l Z d d l Td d l Z d d l Z d d l Z d d l Z d d l j
|
Z
|
d d l m Z m Z m Z m Z m Z m Z d d l Td d l Z d d l Z e d Z d d l m Z d d l Z d d l Z d d l Td d l Z d d l m Z m Z m Z d d l Z d d l! Z! d d l" Z" d d l# Z# d d l$ Z$ d d l% Z% d d l& Z& d d l' Z' d d l( Z( d d l) m* Z* m+ Z+ d d l, Z, d d l- m. Z. m/ Z/ m0 Z0 m1 Z1 d d l2 m3 Z3 m4 Z4 m5 Z5 m6 Z6 m7 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@ eA d \ ZB ZC ZD ZE d ZF d d lG ZG eG jH aI eG jH aJ d ZK d ZL d ZM d e: j: f d YZN d S( iÿÿÿÿN( t *( t getADOExceptionCountt getSIDErrorCntt addADOExceptionCountt seqt fix_outgoingTextt fix_incomingTexts Config.DBConfig( t string_at( t CommFunct mylogt
|
CommFuncEx( t DataServerGameDatat DataServerPlayerData( t GlobalFunctionst DBControllert errort
|
DataDumper( t
|
MMORPGPackt RecvPackProtocolt SendPackProtocolt MergeServerRecvProtocolt MergeServerSendProtocolt weekdayt yeart montht dayt hourt minutei i i c C s¶ d d l } t j } t j } | | f } d } d } d } y6t j } | j t j j t j
|
d | j d d } | j d d } t j } | j | j | j }
|
|
|
j | d | | | f } |
|
j | |
|
j | } t j d | t | } d } | r.| d
|
r.| d } n | | k rZt j d | | | | f n t j d |
|
j Wn7 t k
|
r} t j d | n t j d n X| | f S( Niÿÿÿÿi t s GameVersion.init configt GameIDt Versions GameVersion:%s|%s|%ss% IDDispatch CheckGameVersion recv:%st resultt versionsT CheckGameVersion,gameID=%s,groupID=%s,curVersion=%s is not equal to centerVersion=%ss! IDDispatch CheckGameVersion OK!s1 IDDispatch CheckGameVersion Connect Exception %ss6 IDDispatch CheckGameVersion Connect unknown Exception( t sockett DBConfigt IDDispatchServerIPt IDDispatchServerPortt ConfigParsert readt ost patht joinR t getServerConfigPatht gett GroupIDt AF_INETt SOCK_STREAMt connectt sendt recvR t infot evalt PegasusCollectorProxyt ErrorReportt closet ExceptionR ( R" t hostt portt addrt BUF_SIZEt
|
curVersiont centerVersiont cfGameVert gameIDt groupIDt clientt datat dataRecvt
|
resultDictt e( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyt CheckGameVersionK sB " c C s t j t | _ t j d d d l } d d l } t j } t j
|
} | | f } d } yë | j | j | j } | j | d } | j | | j | }
|
t j d |
|
t |
|
} | r<| d r<| d } | d } g } x/ t | | d D] } | j i | d
|
6 qW| t } | j | q<n | j Wn7 t k
|
rm} t j d | n t j d n Xt | _ t j d S( Ns IDDispatch CallDispatchPlayerIDiÿÿÿÿi t PIDs IDDispatch recv:%sR t minIDt maxIDi t PlayerIDs5 IDDispatch CallDispatchPlayerID Connect Exception %ss: IDDispatch CallDispatchPlayerID Connect unknown Exception( t lockPlayerIDt acquiret Truet isDispatchingPlayerIDR R3 R" t timeR# R$ R% R. R/ R0 R1 R2 R4 t xranget appendt UCN_Dispatch_PlayerIDt insertR7 R8 R t Falset release( t dbt selfR" RP R9 R: R; R< RB RC RD RE RI RJ t recst idt
|
collectionRF ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyt CallDispatchPlayerIDz sD
|
|
|
|
|
|
c C sò t j t | _ t j d d d l } d d l } t j } t j
|
} | | f } d } yE| 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 | x= t | | d D]( } | | j k rJ| j j | qJqJWt j d t | j qn | j Wn7 t k
|
rÇ} t j d | n t j d n Xt | _ t j d S( Ns IDDispatch CallDispatchFamilyIDiÿÿÿÿi t FIDs IDDispatch recv:%sR RI RJ i t FamilyIDs m_emptyFamilyIDList len=%ss5 IDDispatch CallDispatchFamilyID Connect Exception %ss: IDDispatch CallDispatchFamilyID Connect unknown Exception( t lockFamilyIDRM RN t isDispatchingFamilyIDR R3 R" RP R# R$ R% R. R/ R0 R1 R2 R4 RQ RR t UCN_Dispatch_FamilyIDRT t m_emptyFamilyIDListt lenR7 R8 R RU RV ( RW RX R" RP R9 R: R; R< RB RC RD RE RI RJ RY RZ R[ t newIDRF ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyt CallDispatchFamilyID sL
|
|
|
|
|
|
c C sà x¼ t t D]® \ } } | | d k r/ q n t | | t k rH d St | | } t | t k r | d } | | | k r d Sq n | | | k r¦ q n | | | k rº t St SWt S( Ns -i (
|
t enumeratet ATTR_CALL_TIMEt hasattrRN t getattrt typet intt Def_Cmp_Greatert Def_Cmp_Lowert Def_Cmp_Equ( t curTimet timeInfot indext callObjt
|
curCallObjt wday( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyt CompareActTimeÑ s" t
|
UserCtrlDBc B s e Z d Z d Z d Z d Z d Z d Z d Z d Z d Z
|
d Z d
|
Z d Z d Z d Z d Z d Z d Z d Z d Z d Z d Z d Z d Z d Z d Z d Z d Z d Z d Z d Z d Z 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- Z0 d. Z1 d/ Z2 d0 Z3 d1 Z4 d2 Z5 d3 Z6 d4 Z7 e% d5 Z8 e% d6 Z9 d7 Z: d8 Z; d9 Z< d: Z= d; Z> d< Z? d= Z@ d> ZA d? ZB eC d@ dA ZD dB ZE dC ZF dD ZG dE ZH dF ZI dG ZJ dH ZK dI ZL dJ ZM dK ZN dL ZO dM ZP dN ZQ dO ZR dP ZS dQ ZT dR ZU dS ZV dT ZW dU ZX dV ZY dW ZZ dX Z[ dY Z\ dZ Z] d[ Z^ d\ Z_ d] Z` d^ Za d_ Zb d` Zc da Zd db Ze dc Zf dd Zg de Zh df Zi dg Zj dh Zk di Zl dj Zm dk Zn dl Zo dm Zp dn Zq do Zr dp Zs dq Zt dr Zu RS(s c C s t j j | d t | _ d | _ t j r@ t j | _
|
n t j t j | _
|
t | _ t | _ g | _ d | _ t | _ t | _ | j d S( NRv i ( t CtrlDBt __init__RU t Connectedt NoneRW R# t base64R t Base64StringManipulatort
|
translatort EncodeStringManipulatort encodingRO R` Rb t loginHeapRP t loginStartTimet lastCleanMergePlayerTimet connectDB( RX ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyRx ð s Z
|
c C s t S( N( t IsMergeServer( RX ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyR ] s c C s» t j } | s d St } d } | | j | k r9 d S| | _ x[ | j D]M \ } } | t | t k ru qO n | | t | k r qO n | j | qO Wt j d t
|
| d S( Niô s! PopOfflineMergePlayer hascnt = %s( t
|
PyGameDatat g_mergeRegisterPlayerDictRP R t itemst MergeRegPInfoIndex_LogoutTimet MergeRegPInfoIndex_LoginTimet popR t debugRc ( RX R Ro t Def_CleanTimet accIDt packInfo( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyt PopOfflineMergePlayerc s c C sà | j s¿ t j d t j t j f t j t j t j d t | _ t
|
j t j t j d | j sl d S| j t j | _ t | _ t j d t j t j f t j d | j n d S( Ns !!!!!!!!!!!connect %s:%st auto_start_requestt
|
connections !!!!!!!!!!!connect %s:%s ok!s login on user db ok!( Ry R R3 R# t
|
USER_DB_IPt USER_DB_PORTt pymongot
|
ConnectionRU R R t LoginMongoDBt userdb_usert
|
userdb_pwdt USER_DB_NAMERW RN t onConnectedOK( RX ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyR { s !! c C s t | _ d S( N( RU Ry ( RX ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyt
|
disconnect s c C s4 t j s0 t t _ | j t | j n d S( N( R
t g_UserCtrlDBFirstInitRN t _UserCtrlDB__PlayerBackupSaveRG t loadDBPlayerIDMap( RX ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyR s
|
c C s | j t } | j i i d d 6d d 6d d 6 } | ro | j ro x& | D] } | d t j | d <qM Wn t j d t t j t j f d S( Ni RK t AccIDi t _ids0 Æô¶¯·þÎñÆ÷¼ÓÔØDBPlayerÍæ¼ÒÕ˺ÅID¶ÔÓ¦¹Øϵ! %s, %s( RW t UCN_DBPlayert findt countR
t g_dbPlayerIDMapt GameWorldt LogRc ( RX t colt resultSetRE ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyR s ' #c C sC | j t } t j } d | _ | j | i | d 6 s? d S| S( Ni RK ( RW R¡ R t tagDBPlayert IsDeletedt
|
adoLoadCEx( RX t playerIDR§ t dbPlayer( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyt findDBPlayer¡ s c C sP | j } | j r" | j n d } t j | j | \ } } t j d | | 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 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 j k rA| 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 rY| j
|
d } | j | j" | | | j t S| t j# k rlt S| t j$ k r²| j
|
d } | j | j% | | | j t S| t j& k r| j
|
d } | j | j rù| j' | | n | j( | | | j t S| t j) k r]| j
|
d } | j | j* | | | j t S| t 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 | j0 | | | j t S| t j1 k ru| j
|
d } | j | j2 | | | j t S| t j3 k r»| j
|
d } | j | j4 | | | j t S| t j5 k r| j
|
d } | j | j6 | | | j t S| t j7 k rG| j
|
d } | j | j8 | | | j t S| t j9 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 jA k r¥| j
|
d } | j | jB | | | j t S| t jC k rë| j
|
d } | j | jD | | | j t S| t jE k r1| j
|
d } | j | jF | | | j t S| t jG k rw| 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 rI | 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 r
|
| j
|
d% } | j | jT | | | j t S| t jU k ra
|
| 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 r3 | j
|
d) } | j | j\ | | | j t S| t j] k ry | j
|
d* } | j | j^ | | | j t S| t j_ k r¿ | j
|
d+ } | j | j` | | | j t S| t ja k r | j
|
d, } | j | jb | | | j t S| t jc k rK | 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 r | j
|
d0 } | j | jj | | | j t S| t jk k rc | 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 r5| j
|
d4 } | j | jr | | | j t St js d5 | jt t S(6 Ni s begin process request type = %dt gstGeneralDBOpert
|
gstDBLogict gstMergeQueryRegisterResultt gstMergeRegisterPlayert gstMergePlayerDatat gstQueryNewGuyCardStatet gstQueryRecharget gstFinishRecharget gstUpdateNewGuyCardStatet gstGMCommandListReqt gstPlayerLogint gstSaveGameServerPlayerSaveDatat gstUpdatet gstSavePlayerInfot gstInsertAcct gstPlayerIDMarkDeletedt
|
gstGetCoint gstCoinChanget gstCheckPlayerExistt gstOnDayt gstSavePlayerGMOPert gstGetExpiationCountt gstGetPetExpiationCountt gstGetExpiationt gstGetPetExpiationt gstUpdateServerDataVersionNOt gstMapServerInfot gstUpdateTotalSavePointt gstGetPlayerMailStatet gstGetMailDetailt gstGetPlayerMailt gstAddPlayerMailByAccIDt gstDeleteMailt gstUpdateMailt gstQueryCanSendMailt gstAccIDSendPrizet gstCheckItemPrizet gstCheckLoadAcct gstAddAccItemt gstUpdateTelLockStatet gstUpdateAccAdultt gstAddExpiationt gstAddPetExpiationt gstServerMergeDeleteRolet gstServerMergeUpdateAccStatet gstServerMergeChangeNamet gstInsertImpeacht gstGMToolCmdUserDBRequestt gstMergerChildToCentert gstPrepareCreateRoles %s not processed!(u RW R R R t ReadBYTEt getBufferR R t CommonDefineR¯ t GetFuncGradet Startt OnGeneralDBOpert EndRN R° t OnGameServerToDBLogicR± t OnMergeQueryRegisterResultR² t OnMergeRegisterPlayerByCacheR³ t OnMergeChildToCenterPlayerDataR´ t OnQueryNewGuyCardStateRµ t OnQueryRechargeR¶ t OnFinishRechargeR· t onCheckUpdateNewGuyCardStateR¸ t onGMCmdListReqR¹ t onAuthenticationt gstGetGameServerPlayerLoginDataRº t onSaveGameServerPlayerSaveDataR» t$ onSaveMapServerPlayerDataMergeServert onSaveMapServerPlayerDataR¼ t OnSavePlayerInfoR½ t OnInsertAccR¾ t OnPlayerIDMarkDeletedR¿ t OnGetCoinRÀ t OnCoinChangeRÁ t OnCheckPlayerExistRÂ t OnDayRÃ t OnSavePlayerGMOPerRÄ t OnGetExpiationCountRÅ t OnGetPetExpiationCountRÆ t OnGetExpiationRÇ t OnGetPetExpiationRÈ t OnUpdateServerDataVersionNORÉ t OnMapServerInfoRÊ t OnUpdateTotalSavePointRË t OnGetPlayerMailStateRÌ t OnGetMailDetailRÍ t OnGetPlayerMailRÎ t OnAddPlayerMailByAccIDRÏ t OnDeleteMailRÐ t OnUpdateMailRÑ t OnQueryCanSendMailRÒ t OnAccIDSendPrizeRÓ t OnCheckItemPrizeRÔ t OnCheckLoadAccRÕ t OnAddAccItemRÖ t OnUpdateTelLockStateR× t OnUpdateAccAdultRØ t OnAddExpiationRÙ t OnAddPetExpiationRÚ t OnServerMergeDeleteRoleRÛ t OnServerMergeUpdateAccStateRÜ t OnServerMergeChangeNameRÝ t OnInsertImpeachRÞ t OnGMToolCmdUserDBRequestRß t OnMergerChildToCenterRà t OnPrepareCreateRolet warningt outputString( RX t packRW t post requestTypet
|
oFuncGrade( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyt requestLogicProcess© sp
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
#
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
c C s¿ | j } | t } | j } | r | j } t j d | xR | D]G } | d } | | k rk qI n | | j k r qI n | j j | qI Wn t j d t | j | j d S( Ns2 OnFamilyIDInit db[UCN_Dispatch_FamilyID] idCnt=%sR^ s9 OnFamilyIDInit db[UCN_Dispatch_FamilyID] emptyIDCount=%s(
|
RW Ra R¢ R£ R R Rb RR Rc t" _UserCtrlDB__checkDiapatchFamilyID( RX t serverFamilyIDListRW R[ R t idCntt rect familyID( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyt OnFamilyIDInitI s
|
|
|
c C sa t | j d k r d S| j r& d Sd d l } | j d t d | j | f } | j d S( Ni
|
iÿÿÿÿt targett args( Rc Rb R` t threadingt ThreadRe RW t start( RX R* t t( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyt __checkDiapatchFamilyID^ s !
|
c C s- | j | j r) | j j d } | Sd S( Ni ( R" Rb R ( RX t newFamilyID( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyt GetNewFamilyIDh s
|
|
c C s) | | j k r% | j j d | n d S( Ni ( Rb RT ( RX R& ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyt FreeFamilyIDq 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 dgDBOperResultt Typet Resultt ResultSetRc t ResultSetLent ErrMsgt ErrMsgLent packSendt atMergeLogicR t stGamet stDatat GetBuffer( RX t sessionIDR R¨ t errMsgt sendPack( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyt sendGameServerDBOperResultx s c C sÒ | j } t j } d } | j | | t j d | j d } y t j | j
|
} WnP t k
|
r³ } t j d | j
|
| j r¯ | j | j d d d n d SXt | t s| j rÿ t j d | j
|
| j | j d d d n d S| j d } | sQt j d | j rM| j | j d d d n d St | t st j d | | j r| j | j d d d
|
n d S| | } | j d }
|
|
|
sõt j d | j rñ| j | j d d d n d St |
|
t sAt j d |
|
| j r=| j | j d d d n d S|
|
j }
|
|
|
d k rd } d } y | j Wn_ t k
|
r±} t j d | | f d } t | } n$ t j d | d } d } n X| j rý| j | j | d | n d S|
|
d k rÖ| j d } d } d } y | j | t t Wnh t k
|
r} t j d | | | f d } t | } n* t j d | | f d } d } n X| j rÒ| j | j | d | n d S|
|
d k rÉ| j d } | j d } d } d } y | j | | t t t t Wnn t k
|
rp} t j d | | | | f d } t | } n- t j d | | | f d } d } n X| j rÅ| j | j | d | n d S|
|
d k r| j d } d } d } y | j | t Wnh t k
|
rE} t j d | | | f d } t | } n* t j d | | f d } d } n X| j r| j | j | d | n d S|
|
d k r½| j d } | j d i } d } d } d } y4 | i k rû| j | } n | j | | } Wne t k
|
rL} t j d! | | f d } t | } n* t j d! | | f d } d } n X| j r¹| rt t | } n | j | j | | | n d St j d" |
|
d S(# Ni s pack = %ss cPickle.loads('%s') failed!R s OperDict parse failed!s %s is not a dict!R[ s collection not specified!s collection name:%s not valid!s collection name not valid!t opers oper not specified!s oper:%s not valid!s oper not valid!t dropi s drop %s failed!error = %ss drop %s failed!unknown error!s unknown exception!RT t docss# insert %s into %s failed!error = %ss+ insert %s into %s failed!unknown exception!t updatet specs0 update %s failed!spec = %s, doc = %s, error = %ss= update %s failed!spec = %s, doc = %s,unknown exception occur!t removes+ remove from %s failed!spec = %s, error = %ss3 remove from %s failed!spec = %s, unknown exception!R¢ t fieldss %s.find(%s) failed!s oper %s not support!( Râ R t tagGDGameServerGeneralDBOpert ReadDataR R t OutputStringRz t cPicklet loadst OperDictR8 R t
|
NeedReturnRB t getSessionIDt
|
isinstancet dictR, t
|
basestringt lowerRD t strRT RU RN RF RH R¢ t list( RX RW R t buft recvPackR t operDictRF t colNameR§ RC R t errorMsgt doc_or_docst docRG t
|
spec_or_idRI R¨ ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyRæ s
|
|
|
|
|
|
c C s | j } t j } d } | j | | | j } t j d | j | t j k r | j
|
} | j | } | r d } t j d | nW | j | | \ } }
|
t j d | | f | rì t j |
|
} | j | | n | j | j | | | d S| t j k rA| j
|
} | j } | j | | d S| t j k rt j | j } | j | j d | t | d Sd S( Ni s pack = %si s$ packData get from cache. playerID=%ss+ packData get from db. playerID=%s,result=%s( Râ R t tagGDGameServerToDBLogicRK t QueryTypeR R RL Rã t gstDBLogic_PlayerPackDataReqt IDt getPlayerPackDatat GetPlayerDataByPlayerIDR{ t b64encodet updPlayerPackDatat SendGameServerToDBLogicResultRQ t gstDBLogic_PlayerPackDataUpdt Datat gstDBLogic_GMCmdt GMShellt DBGMCommandRV ( RX RW R RX RY R t queryTypeR¬ t packDataR t
|
playerDatat dbAnswerList( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyRè s: "c C s± t j } t j | _ | | _ | j | _ | j | _ | j | _ t | j | _
|
| | _ t | j | _ | j | d d t j t j t j | j t j d d S( sñ »Ø¸´GameServer·¢Ë͵ÄSendDBLogic£¬¿ÉÒÔ²»»Ø¸´£¬ÓɾßÌåÀàÐ;ö¶¨
|
@param result: ½á¹û£º1³É¹¦£¬0ʧ°Ü
|
@param recvPack: GameServer·¢À´µÄÊý¾Ý°ü£¬Data¿ÉÔÖµ·µ»Ø£¬Ò²¿ÉÐ޸ĺ󷵻أ¬ÓɾßÌåÀàÐ;ö¶¨
|
@param resultSet: »Ø¸´Êý¾Ý
|
i s" »Ø¸´ SendGameServerToDBLogicResultN( R t tagDGGameServerToDBLogicResultRã t dgDBGameServerToDBLogicResultR4 R5 Rc Ra Rj Rc t DataLenR6 R7 R: t atInnerR R< R= R> R R ( RX R? R RY R¨ RA ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyRh ; s c C s¶ t j } | | _ | t } | j | i | d 6 } | sV t j d | j d St j d | j i | j d 6} | t } | j
|
| | t j t } | t } | j
|
| | t j } | t } | j
|
| | t j } | t } | j
|
| | t j }
|
| t } | j
|
| | t j } | t } | j
|
| | t j } | t } | j
|
| | t j } | t } | j
|
| | t j } | t } | j
|
| | t j } | t } | j
|
| | t j } | t } | j
|
| | t j } | t! } | j
|
| | t j" } | t# } | j
|
| | t j$ } t j% } | j j& | _ | t' } | j( | } d | j) | | | |
|
| | | | | | | | | | f S( NRK s0 GetPlayerDataByPlayerID Exception playerID = %si R s
|
accid = %si ( i s (* R R© RK R¡ R« R R R3 R t UCN_RoleItemt readPlayerPackSaveDatat tagRoleItemRN t UCN_RoleMissiont tagRoleMissiont UCN_RoleMissionDictt tagRoleMissionDictt UCN_RoleSkillt tagRoleSkillt UCN_RoleBufft tagRoleBufft UCN_RoleRepeatTimet tagRoleRepeatTimet UCN_PlayerHorseTablet tagPlayerHorseTablet
|
UCN_GMOpert tagGMOpert UCN_RolePett
|
tagRolePett UCN_PetSkillt tagPetSkillt UCN_RoleNomalDictt tagRoleNomalDictt UCN_PlayerDienstgradt tagPlayerDienstgradt UCN_BattleFormationt tagBattleFormationt tagDBGMIPRU t
|
UCN_DBGMIPt adoQueryIndexRâ ( RX RW R¬ R R[ t loadOKt queryDictt itemDatat missionDatat roleMissionDictDatat roleSkillDatat roleBuffDatat roleRepeatTimeDatat roleHorseDatat
|
gmOperDatat rolePetDatat petSkillDatat roleNormalDictDatat roleDienstgradDatat battleFormationDatat gmIPt gmIPData( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyRe P sR
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
c C s t j } | j } t j } d } | j | | | j j t d } t j
|
d | | j } t j j | } | s t j d | d St j }
|
t j |
|
_ | j | g r!d |
|
_ | j | j | j j d t j t j t j |
|
j t j d | d Sd |
|
_ | |
|
_ t | |
|
_ d |
|
_! d |
|
_" | j | j | j j d t j t j t j |
|
j d S( Ni s accID = %s.s client not found!sessionID = %ss query failed!spec = %si R (# R
R Râ R t tagLPQueryRegisterResultRK R t stript chrR R RQ t MergeProxyClientMgrt getMergeProxyClientMgrt findClientBySessionIDR R t tagMPQueryRegisterResultRã t dgMergeQueryNewAccountR4 R, R5 R: t getPackHeadR? R; R t stNoSenseR> t AccountRc t
|
AccountLent Pwdt PwdLen( RX RW R R RX RY R R t clientSessionIDRB RA ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyRé s6 * *c C sH t j } y | j } t j } d } | j | | t j } t j | _
|
| j } t j } d } | j | | t | }
|
d |
|
k rd | _ d | _ t | j | _ | j | j | j j d t j t j t j | j t j d d S| j d k rd | _ d | _ t | j | _ | j | j | j j d t j t j t j | j t j d d S| j } t j j | } | sÃt j d | d S| j! } | j } | j" j# j$ t% d } | j& j$ } d | _ | | _' t | | _( d
|
| _) d | _* | j | j | j j d t j t j t j | j t j+ d | | | | f t, d | | g | | <Wn t- k
|
rÿ} t. j/ d t. j0 d | t1 j2 t3 j4 | f } t j. | nE t. j/ d t. j5 d t1 j2 t3 j4 | f } t j. | n Xd S( sß »º´æ¿ç·þÍæ¼ÒÉÏ´«Êý¾ÝÐÅÏ¢
|
Ä¿Ç°Õ˺š¢Íæ¼ÒID¡¢½ÇÉ«Ãû¾ùÒÑÈ·±£Î¨Ò»£¬¹ÊÎÞÐèÔÙÖØÐÂÉú³ÉеÄÕ˺ż°½ÇÉ«ÐÅÏ¢
|
Ö±½Ó½ÓÊÕ¸üлº´æ¼´¿É£¬Íæ¼ÒµÇ½¿ç·þ·þÎñÆ÷ʱֱ½Ó´Ó»º´æÊý¾ÝÖнâÎö½ÇÉ«Êý¾Ý£¬´Ó¶ø½ÚÊ¡db´æÈ¡²½Öè
|
i iÿÿÿÿs Player data length not enough!s player data too short!Ns Player data error!s player data error!s client not found!sessionID = %si R s3 player %s accID=%s, playerID=%s, %s register PK ok!R s8 OnMergeRegisterPlayer error %s!traceback = %s, pack = %ss5 OnMergeRegisterPlayer error!traceback = %s, pack = %s(6 R
R Râ R t tagLPRegisterPlayerRK R t tagMPRegisterPlayerResultRã t dgMergeRegisterResultR4 Rj R R© t readDataRc R5 t ErrorMsgt ErrorMsgLenR: RQ R R? R; R R® R> R R RK R¨ R© Rª RA R RU R¦ R§ t
|
PlayerNameR¯ R° R± R² R3 RP R8 R t formatMsgt ERROR_NO_175t tracebackt
|
format_exct binasciit b2a_hext ERROR_NO_176( RX RW R R RX RY R t loginResultPackRp t playerRect dbPlayerReadLenR³ RB RA R¬ R t
|
playerNameRF t msg( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyRê ³ sj * * * 41c C s y| j } | j } t j } d } | j | | | j j t d } t j d | | t
|
} | j i | d 6 } | s | j d k r£ d St j j }
|
t |
|
} | j d d } | j i | d 6i i d d 6| d 6d 6 t j d | d SWn t k
|
r`} t j d
|
t j d | t j | f } t j | n9 t j d
|
t j d t j | } t j | n Xd S( Ni s OnFinishRecharge ...%st OrderIDs .i t IsProcesst EndOrderTimes $sets OnFinishRecharge OrderID = %sR s# OnFinishRecharge error %s!pack = %ss OnFinishRecharge error!pack = %s( Râ t getLengthR t tagMDFinishRechargeRK RÇ R¦ R§ R R t UCN_PayInfoR¢ R£ t datetimet todayRV t splitRF R8 R R» t ERROR_NO_170R¿ RÀ ( RX RW R RX t packLenRY R t orderIDR§ R Ro t
|
curTimeStrRF RÆ ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyRî ü s2
|
,+%c C sB y¸| j } | j } t j } d } | j | | | j j t d } t j d | | t
|
} | j i | d 6d d 6d d 6 } | s | j d k r± d S| d }
|
t j } t j | _ t j | _ t |
|
d | _ t | j | _ t |
|
d | _ t | j | _ t |
|
d | _ t |
|
d | _ t | j | _ | j i | j d 6i i d
|
d 6d 6 | j | | j t j d | j d SWn t! k
|
r} t" j# d t" j$ d | t% j& | f } t j" | n9 t" j# d t" j$ d t% j& | } t j" | n Xd S( Ni s OnQueryRecharge ...%sR RÈ RÉ RÇ t OrderInfot OrderAmountt Extrasi s $sets OnQueryRecharge OrderID = %sR s" OnQueryRecharge error %s!pack = %ss OnQueryRecharge error!pack = %s(' Râ RÊ R t tagMDQueryRechargeRK R¯ R¦ R§ R R RÌ R¢ R£ R t tagDMRechargePushRã t dgDBToMapServerR4 t gmReChargePusht SubTypeR RÇ Rc t
|
OrderIDLenRÔ t OrderInfoLenRk t MoneyRÖ t ExtrasLenRF t
|
sendStringR> R8 R R» RÐ R¿ RÀ ( RX RW R RX RÑ RY R t accountR§ R t billInfoRA RF RÆ ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyRí sD
|
$
|
(+%c C s¦ yë| j } | j } t j } d } | j | | t j d | j t j } t
|
j | _ t
|
j | _ | j | _ | j | _ t j } | j | _ | j | _ | t } t }
|
| j | st|
|
t k r+d | _ d | _ d | _ | j | | j t j d | j d Sd | _ d | _ d | _ | j | | j t j d | j d S| j | _ | j | _ | j | _ | j | _ | j | _ | j | | j t j d | j | j f d SWn t k
|
r8} t j d t j! d | t" j# | f } t j | n9 t j d t j! d
|
t" j# | } t j | n Xd | _ d | _ d | _ | j | | j d S( Ni s% OnQueryNewGuyCardState cardID = %s...R s- OnQueryNewGuyCardState cardID = %s not found!i s. OnQueryNewGuyCardState query error!cardID = %ss+ OnQueryNewGuyCardState cardID = %s state:%sR s) OnQueryNewGuyCardState error %s!pack = %ss& OnQueryNewGuyCardState error!pack = %s($ Râ RÊ R t tagMDIsMediaCardUsedRK R R t CardIDR t tagDMIsMediaCardUsedRã RÙ R4 t gmQueryNewGuyCardStateRÛ t CardIDLenR t tagDBNewGuyCardStatet UCN_DBNewGuyCardStateR t adoLoadt IsUsedt UserDataLent UserDataRà R> R t CardTypet ValidTimeR R8 R R» RÐ R¿ RÀ ( RX RW R RX RÑ RY R RA t objR§ t lastExceptionCntRF RÆ ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyRì P 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 tagMDCheckUpdateMediaCardStateRK R t tagDMCheckUpdateMediaCardResultRã RÙ R4 t gmUpdateNewGuyCardStateRÛ Rç Rä R R RL R Rè Rë Rì Rí Rî Rï Ré t adoCheckUpdateR5 Rà R> R8 R R» t ERROR_NO_171R¿ RÀ ( RX RW R RX RÑ RY R RA Rð R§ RF RÆ ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyRï sJ
|
+% c C së | j r d Sd } t j } | j | j | } | j sG d S| t } t j } | j j
|
| _ | j | sÎ | j r¶ t j d t j d | j } t j | n t j d | j d S| j | _ | j | d S( s ±£´æÍæ¼ÒÐÅÏ¢Ni R s load account failed, accid = %ss0 OnSavePlayerInfo load account failed, accid = %s( R R t tagGDSavePlayerInfoRK Râ t GeTuiClientIDt UCN_DSAccountR t tagDSAccountR RU t ACCIDt adoLoadCR R» t ERROR_NO_57R R t
|
adoUpdateC( RX RW R R t
|
PlayerInfoR§ t PlayerAccRÆ ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyRö µ s$
|
c C su d } t j } | j | j | } | j | j | } t j d d | j d t j
|
| j | j f d S( s ½øÈë´´½ÇÂñµãi i)# s: OperatorID=%s&Step=%s&AccountID=%s&Flag=1000&DeviceFlag=%si N( R t tagLDPrepareCreateRoleRK Râ t GetAccountFromTableR R5 t EventReportt AppIDR t GetPlatformAccIDt
|
DeviceFlag( RX RW R R Rÿ Rá ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyR Ñ s c C s t j } d } | j | | t | } d | k rF t d d f S| | 7} | j } | d k rr t d d f St j d | t | | j f S( Ni iÿÿÿÿR s __ReadPlayerID playerID = %s(
|
R R© R· Rc RU RK R R3 RN R ( RX RW t saveDataRÃ R RÄ R¬ ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyt __ReadPlayerIDÛ s
|
c C s¾ t j } d } t j | j | | j | \ } } | j | | \ } } } | | k r´ t | | t <| | | t _
|
t | | | t _ t j d | | f n | | f S( Ni s? onSaveMapServerPlayerDataMergeServer result = %s, playerID = %s( R
R R t
|
ReadStringRâ RÊ t _UserCtrlDB__ReadPlayerIDRP R t MergeRegPInfoIndex_PackDataRj Rc Rt R R3 ( RX RW R R R R R R¬ R ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyRô è s + c C sÒ d } t j | j | | j | \ } } t } d } t j rd | j | | \ } } } n | j | | \ } } } | sÑ t j
|
d t j d | } t j | t j t j d d | | n | j | | t j d | | f t j j t j t | } t j j | rÈt j j | d }
|
x t j | D]t } | j t j skqMn t j j | | } t j j t j j |
|
| s´t j | |
|
qMt j | qMWn | | f S( s# Íæ¼ÒÏÂÏߣ¬±£´æÍæ¼ÒÔÚMapServerµÄÊý¾Ýi i R s% Player save data failed!playerID = %ss UserLogs\SaveFailDumps %s.mdats4 onSaveMapServerPlayerData result = %s, playerID = %st Backup( R R Râ RÊ RU R# t PackSavet SavePlayerMapServerDataExt SavePlayerMapServerDataR R» t ERROR_NO_59R R t DumpDataR t
|
getAppPatht RevoverBillProcessR3 R( R) R* t PlayerBakRootRV t existst listdirt endswitht PlayerBakFileTypet shutilt moveRH ( RX RW R R R R R¬ R RÆ t PlayerBakDirt
|
BakCopyDirt filenamet fullPath( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyRõ ý s0 + # !c C s< | j } | j r d St j s9 t j j t j r= d St j d t j xät j t j D]Ð\ } } } | j
|
d r qd n x©| D]¡} | j
|
t j s q n t | d k rÔ t j d | d SyM t j j | | } t | d } | j } | j t j | } Wn t j d | d SXt j rd| j | | \ } }
|
} n | j | | \ } }
|
} | st j d | d St j j t j t |
|
d } t j j t j j | | s t j | | t j d |
|
| | f q t j | t j d |
|
| | f q Wqd Wd S(
|
Ns& Íæ¼Ò±¸µµÂ·¾¶ DBConfig.PlayerBakRoot=%sR i sN Íæ¼Ò±¸µµ¸öÊýÒì³£: The number of backup files is greater than one. filenames=%st rbs Íæ¼Ò±¸µµ´ò¿ªÊ§°Ü. %ss Íæ¼Ò±¸µµÈë¿âʧ°Ü fail. %ss/ Íæ¼Ò±¸µµÈë¿â³É¹¦: playerID=%s,accID=%s, move %ss1 Íæ¼Ò±¸µµÈë¿â³É¹¦: playerID=%s,accID=%s, remove %s( RW R R# R R( R) R R R3 t walkR R Rc t fatalR* t openR' R7 t zlibt
|
decompressR R R RV R R RH ( RX RW t parentt _t filenamesR R t fileHandlerR R R¬ R R ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyt __PlayerBackupSave% sJ "
|
!! "c
|
C s} t j d | y* t | | j d j d d } Wn d } n Xt j j t j t
|
| d | } t j j | s d | } t j | d Sy8 t | d } | j } | j t j | } Wn d | } t j | d SXt j r | j | | \ } } } n | j | | \ } } } | sYd | } t j | d Sd
|
| | | f } t j | d S( Ns ===Ö´ÐÐÍæ¼ÒÖ¸¶¨±¸µµÈë¿â: %ss .R& i R s ²»´æÔÚ¸ÃÍæ¼Ò±¸µµÎļþ: %sR s Íæ¼ÒÖ¸¶¨±¸µµ´ò¿ªÊ§°Ü: %ss Íæ¼ÒÖ¸¶¨±¸µµÈë¿âʧ°Ü: %ss. Íæ¼ÒÖ¸¶¨±¸µµÈë¿â³É¹¦: playerID=%s,accID=%s, %s( R R3 Rk Rq RÏ R( R) R* R# R RV R R" R' R7 R# R$ R R R (
|
RX RW t bakFileNameR¬ R RÆ R( R R R ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyt SavePlayerDataByBackupY s: *
|
$
|
|
|
|
c C sÝ y¸ | s d S| j t d } | t } | j i | d 6d d 6d d 6 } | si | j d k rm d S| d } | d } | j i | d 6i i d d 6d 6 t j d | Wn t j d t j
|
n Xd S(
|
Ni R i RÈ RÉ RÇ s $sets RevoverBillProcess success...%ss RevoverBillProcess error %s( R¦ R§ RÌ R¢ R£ RF R R R R½ R¾ ( RX RW R Rá R§ R Râ RÒ ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyR s
|
$
|
|
%c C sl t j } d } | j | | t | } d | k rF t d d f S| | 7} t j d | j | j d k r t d d f S| j j | _ | t
|
} | j d } | j | j | sÔ t | j d f S| j | j | | j d } | j | | j | j | t t j | | t 7} | j | j d } | j | | j | j | t t j | | 7} | j | j d } | j | | j | j | t t j | | 7} | j | j d } | j | | j | j | t t j | | 7} | j | j d
|
} | j | | j | j | t t j | | 7} | j | j d } | j | | j | j | t t j | | 7} | j | j d } | j | | j | j | t t j | | 7} | j | j d } | j | j | j | j | | | j | | j | j | t! t j" | | 7} t# j$ | | \ } } t j% } x3 t& | D]% }
|
| | j | | t | 7} qW| j d } | j | | j | j | t' t j( | | 7} | j | j d } | j | | j | j | t) t j* | | 7} | j | j d } | j | | j | j | t+ t j, | | 7} | j | j d } | j | | j | j | t- t j. | | 7} | j | j d } | j | | j | j | t/ t j0 | | 7} | j | t | k sYt1 t | j | j f S( Ni iÿÿÿÿR s$ Saving player data,playerID = %s....t' gstSaveMapServerCrashData_1_tagDBPlayert% SavePlayerMapServerData_1_tagRoleItemt( SavePlayerMapServerData_1_tagRoleMissiont, SavePlayerMapServerData_1_tagRoleMissionDictt& SavePlayerMapServerData_1_tagRoleSkillt% SavePlayerMapServerData_1_tagRoleBufft+ SavePlayerMapServerData_1_tagRoleRepeatTimet- SavePlayerMapServerData_1_tagPlayerHorseTablet% SavePlayerMapServerData_1_gmOperCheckt$ SavePlayerMapServerData_1_tagRolePett% SavePlayerMapServerData_1_tagPetSkillt* SavePlayerMapServerData_1_tagRoleNomalDictt- SavePlayerMapServerData_1_tagPlayerDienstgradt, SavePlayerMapServerData_1_tagBattleFormation(2 R R© R· Rc RU R R3 RK R RU R¡ Rä Rå Rþ Rç t recPlayerLogofft savePlayerDataRv Rx RN Ry Rz R{ R| R} R~ R R R R R R t gmOperCheckR
R R t ReadDWORDR RQ R R R R R R R R R R t AssertionError( RX RW R RÃ R RÄ R[ R t gmIPCntt gmIPRect i( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyR s
|
|
|
|
|
,
|
|
)
|
|
)
|
|
)
|
|
)
|
|
)
|
|
)
|
|
|
) #
|
)
|
|
)
|
|
)
|
|
)
|
|
)
|
c C s~ t j } d } | j | | t | } d | k rF t d d f S| | 7} t j d | j | j d k r t d d f S| j j | _ | t
|
} | j d } | j | j | sÔ t | j d f S| j | j d k rý | j | n | j d } | j | | j | j | t t j | | t 7} | j | j d } | j | | j | j | t t j | | 7} | j | j d } | j | | j | j | t t j | | 7} | j | j d } | j | | j | j | t t j | | 7} | j | j d
|
} | j | | j | j | t t j | | 7} | j | j d } | j | | j | j | t t j | | 7} | j | j d } | j | | j | j | t t j | | 7} | j | j d } | j | j! | j | j | | | j | | j | j | t" t j# | | 7} t$ j% | | \ } } t j& } x3 t' | D]% }
|
| | j | | t | 7} q®W| j d } | j | | j | j | t( t j) | | 7} | j | j d } | j | | j | j | t* t j+ | | 7} | j | j d } | j | | j | j | t, t j- | | 7} | j | j d } | j | | j | j | t. t j/ | | 7} | j | j d } | j | | j | j | t0 t j1 | | 7} | j | t | k skt2 t | j | j f S( Ni iÿÿÿÿR s$ Saving player data,playerID = %s....t' SavePlayerMapServerDataEx_1_tagDBPlayert' SavePlayerMapServerDataEx_1_tagRoleItemt* SavePlayerMapServerDataEx_1_tagRoleMissiont. SavePlayerMapServerDataEx_1_tagRoleMissionDictt( SavePlayerMapServerDataEx_1_tagRoleSkillt' SavePlayerMapServerDataEx_1_tagRoleBufft- SavePlayerMapServerDataEx_1_tagRoleRepeatTimet/ SavePlayerMapServerDataEx_1_tagPlayerHorseTablet' SavePlayerMapServerDataEx_1_gmOperCheckt& SavePlayerMapServerDataEx_1_tagRolePett' SavePlayerMapServerDataEx_1_tagPetSkillt, SavePlayerMapServerDataEx_1_tagRoleNomalDictt/ SavePlayerMapServerDataEx_1_tagPlayerDienstgradt. SavePlayerMapServerDataEx_1_tagBattleFormation(3 R R© R· Rc RU R R3 RK R RU R¡ Rä Rå Rþ Rç t CountryLastWeekHornorR: t savePlayerDataExRv Rx RN Ry Rz R{ R| R} R~ R R R R R R R< R
R R R= R RQ R R R R R R R R R R R> ( RX RW R RÃ R RÄ R[ R R? R@ RA ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\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( Rc R R= R R RQ t clearR· t OperRã t gmForbidAcct onForbiddenUpdateRN R
|
t TDateTime_NowRk t EndTimet GMAccIDt TDateTimeToStringt Msg(
|
RX R R¬ RC R t lengtht cntt gmOperRecRA t readLen( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyR< s s
|
|
|
|
4c C s t j } | | k r" i | | <n | j d | } | j | | } | j d | }
|
|
|
j |
|
j d } t j | | \ } } t j d | | | f | } t | } i } | rê | | d <| | d <d | d <n xt
|
| D]ö } | j d | }
|
|
|
j | j |
|
j | j d
|
| }
|
|
|
j | j | | | } |
|
j | d k rt j d t | d S| | 7} | rÕ| j d | }
|
|
|
j | j |
|
j n | j | d | d <q÷ W| rd } xòt r yx | j d | }
|
|
|
j | j i | d 6| d t |
|
j | | | | <t j d | | | | | f PWq t j j k
|
r} t j | k rµ| d 7} q n t t j d | j j t j d d | f t j d | | | f Pq Xq Wnâ d } xÙ t rñyo | j d | }
|
|
|
j | j i | d 6 |
|
j d | | | <t j d | | | | | f PWqt j j k
|
rí} t j | k rÅ| d 7} qn t t j d | | | | f PqXqW| j | S( s ±£´æÍæ¼ÒÎïÆ·µÈÊý¾Ý£¬ÓÅ»¯°æs savePlayerDataEx_%s_Alls savePlayerDataEx_%s_removei s' saving %s data, playerID = %s, cnt = %sRK t Counti t
|
__PackSaves savePlayerDataEx_%s_clears savePlayerDataEx_%s_readDataiÿÿÿÿs %sNs savePlayerDataEx_%s_makeSIDs savePlayerDataEx_%s_updatet upsertsA update end %s data, playerID = %s, cnt = %s, playerDataCntInfo=%ss %s.%s:docs = %si s0 update failed!docs = %s, error = %s, trycnt = %dsA remove end %s data, playerID = %s, cnt = %s, playerDataCntInfo=%ss7 remove failed!%s playerID = %s, error = %s, trycnt = %d( R
t g_playerDataCntInfoRä Rå Rç R R= R R3 Rc RQ RR R· RÀ t makeSIDt getRecordRN RF R t errorst OperationFailureR# t TryCntOnWriteFailR t __class__t __name__t inspectt stackR RH ( RX R¬ RW t collectionNamet
|
structNameRC t checkSIDRb t oAllFuncGradeR[ R R R\ R% R[ R^ RA R^ t trycntt err( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyRQ s
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
!
|
.
|
|
!
|
|
c C s t j } | | k r" i | | <n | j d | } | j | | } | j d | }
|
|
|
j | j i | d 6 |
|
j d } t j | | \ } } t j d | | | | f | } t
|
| } g } x,t | D] } | j d | }
|
|
|
j | j |
|
j | j d | }
|
|
|
j | j | | | } |
|
j | d k rt j d t | d
|
S| | 7} | rÅ| j d | }
|
|
|
j | j |
|
j n | j d | }
|
|
|
j | j } |
|
j | j | qç Wt
|
| rd } xó t rÿyM | j d | }
|
|
|
j | j | t t |
|
j | | | | <PWq t j j k
|
rû} t j | k r¨| d 7} q n t t j d | j j t j d d | f t j d | | | f Pq Xq Wn d | | | <| j | S( s ±£´æÍæ¼ÒÎïÆ·Êý¾Ýs savePlayerData_%s_Alls savePlayerData_%s_removeRK i s; saving %s data for player playerID = %s cnt = %s, data = %ss savePlayerData_%s_clears savePlayerData_%s_readDataiÿÿÿÿs %sNs savePlayerData_%s_makeSIDs savePlayerData_%s_getRecords savePlayerData_%s_inserti s %s.%s:docs = %si s0 Insert failed!docs = %s, error = %s, trycnt = %d(! R
Rb Rä Rå RH Rç R R= R R Rc RQ RR R· R3 RÀ Rc Rd RR RN RT RU R Re Rf R# Rg R Rh Ri Rj Rk R ( RX R¬ RW Rl Rm RC Rn Rb Ro R[ R R R\ R% R[ RE RA R^ R^ Rp Rq ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyR; â sx
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
.
|
c C s d S( N( ( RX R ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\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 d S( NR s sessionID = 0x%x dump to file %st UserLogsi iÿÿÿÿi ( RV t uuidt uuid4R R» t ERROR_NO_60R R? R R R R R R R© Rc R· t updatePlayerAccStateRK Rã t pysForbiddent sendAccForbiddenLogReqR ( RX RW R t saveDataWithCRCt dumpFileNameRÆ RÃ R R[ ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyt onSavePlayerDataCRCErrorE s + c C s d S( N( ( RX t accidt isForbidden( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\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 R© RK R Rü R R Rh Ri Rj Rk RU R t AccStateRþ RN ( RX RW R¬ t newStateR[ R^ t lastSIDErrorCntt ret( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyRv i s
|
.. c C sh t j } | j | j d | j | j d k rd | j t j | j t
|
j | d d Sd S( s$ Íæ¼ÒÏÂÏߣ¬±£´æÍæ¼ÒÔÚGameServerµÄÊý¾Ýi i R N( R t* tagGameServerToBalanceServerPlayerSaveDataRK Râ RÊ RP t setSrcSvrTypeR t stLogint sendOKStringRã t dgPlayerSaveGameServerData( RX RW R t saveGameServerPlayerDataReq( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyRó ~ s c C s d S( N( ( RX RW R ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyt onGetGameServerPlayerLoginData s c
|
C s¾ yt j } | j | j t j } t j | _ | j | _ t
|
j } | j j | _ d | _ | t } t } t } | j | i t | j d 6| j d 6 rÞ t j d | j d | _ d | _ nx | t k sd | _ t | _ nT | t k sDt j r/d | _ t | _ qVd | _ d | _ n d | _ d | _ | j | | j t j d | j Wn6 t j d t j d t! j" } t j | n Xd S( Ni R Rª s player of accid = %s exists!i s1 onCreateRoleServerCheckIsHaveRole ok, Accid = %s!R s) Catch a unexpetcted exception, error = %s(# R t tagCSIsHaveRoleRK Râ R t tagDRequestResultRã t" gstCreateRoleServerCheckIsHaveRoleR4 R R R© RU Rª R¡ R R R« R R R3 R5 t ExAttrt disDataBaseErrorR# Rn t disAccStateErrorRà R> R R R» t ERROR_NO_62R½ R¾ (
|
RX RW R RY RA t PlayerR[ Rñ R RÆ ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyt! onCreateRoleServerCheckIsHaveRole§ s@
|
, "c C sá y¤ t j } | j | j t j } t j | _ | j | _ d | _
|
| j | | j rp d | _ n d | _ | j | | j t j d | j Wn6 t j d t j d t j } t j | n Xd S( Ni i s2 onCreateRoleServerCheckPlayerExist ok, Accid = %s!R s) Catch a unexpetcted exception, error = %s( R t tagCSCheckPlayerNameExistRK Râ R R Rã t# gstCreateRoleServerCheckPlayerExistR4 R R5 t hasPlayerByPlayerNameRº R Rà R> R R R R» t ERROR_NO_63R½ R¾ ( RX RW R RY RA RÆ ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyt" onCreateRoleServerCheckPlayerExistÓ s "c C sx | j t j | j | | \ } } } } | r^ | j t j | | t j d | n | j t j | | d S( Ns' send created player info for accid = %s(
|
R R R t
|
CreateRoleR
Rã t dgCreatePlayerR R t sendFailString( RX RW R t Suct disCodet AccIdRC ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyt onCreatePlayeré s c C sË y | j | | \ } } } } t j } t j | _ | | _ | | _ | r] d | _ n | | _ t j
|
d | | j | | j Wn6 t j d t j d t j } t j | n Xd S( Ni s' send created player info for accid = %sR s) Catch a unexpetcted exception, error = %s( R R R Rã t$ gstCreateRoleServerRequestCreateRoleR4 R5 R R R R Rà R> R R» t ERROR_NO_64R½ R¾ ( RX RW R R R R RC RA RÆ ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyt# onCreateRoleServerRequestCreateRoleõ s "c C s[ t j d | t } | j } | s | j ry d } x: | d k rt | j rt | j s] t St d | d 7} q; Wt St | | t S| j } | t
|
j k r© t S| d k r| j rd } x: | d k r | j r | j sé t St d | d 7} qÇ Wt St | | t S| j r#t Sd d l } | j d t d | | f } | j t S( Ns CheckEmptyPlayerIDCount starti i i iÿÿÿÿR( R) ( R R RS R¢ RO RN t sleepRU R\ R£ R# t IDDispatchPlayeIDLimitR* R+ R, ( RX RW R[ R t try_countt emptyCntR* R- ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyt CheckEmptyPlayerIDCount
|
sD
|
|
|
|
c C s; | t } | j } | r7 | d } | j | | Sd S( NRK iÿÿÿÿ( RS t find_oneRH ( RX RW R[ R% Rd ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyt PopEmptyPlayerID9 s
|
|
c C sE t j } | s+ t | t d t j t j S| j | | j | S( NRK ( R# t UseIDDispatchServerR R¡ t PLAYERID_FEEDt PLAYERID_STEPR¥ R§ ( RX RW R¨ ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyt DispatchNewPlayerIDC s
|
c C s0 t j } | | _ | t } | j | | S( N( R Rú Rû Rù Rê ( RX R RW t accountDataR[ ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyR N s
|
|
c C s | t } | j | i t | j d 6| j d 6 r] t j d | j d t | j d f S| j | | j r t j d | j d t
|
| j d f St j t j | _ | j | } | d k r t j d t j d | j } t j | d t | j d f St j d
|
d } | | _ | | j d j t j | _ 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 | j t j | <t j d t! t j t j f d } t" j# | d } | } | } | }
|
| } | } | } | } | } | } | } | } | } | } | j$ | | | |
|
| | | | | | | | | | } t% | } d } t" j# | | } t" j& | d } | | } t j d | j d d | j | f } | j' | j | } t( j) d d | j* d t" j+ | j | j, f t- j. i | j* d 6| j d 6t" j+ | j d 6| j/ d 6| j, d 6 } t( j) d | t0 j1 | | S( NR Rª s player of accid = %s exists!i R s! player of playerName = %s exists!iÿÿÿÿR s# PlayerID Dispatch failed!accid = %sR i t gbks. Before insert role!accid = %s, PlayerName = %ss insert player failed!accid = %ss* insert role ok!accid = %s, PlayerName = %ss$ PyGameData.g_dbPlayerIDMap = %s£¬ %ss' send created player info for accid = %si)# s: OperatorID=%s&Step=%s&AccountID=%s&Flag=1000&DeviceFlag=%si t
|
OperatorIDt RoleIDt AccountIDt JobR iO (2 R¡ R« R R Rª R R t disCreatePlayerError_PlayerExistR Rº t' disCreatePlayerError_PlayerNameConflictR
|
RY RV t CreateRoleTimeR« R R» t ERROR_NO_65R t IpyGameDataPYt
|
GetFuncCfgRK t decodet encodeR# R R t
|
adoInsertCRê t ERROR_NO_66R
R¤ Rc R t
|
WriteDWORDRâ t crc32t WriteBYTER R5 R R R R t urllibt urlencodeR± t DataRecordPackt DR_CreateRole( RX RW t createPlayerR[ t newPlayerIDRÆ t
|
nameFormatR R t missionDictDatat skillDatat bufDatat repeatTimeDatat horseDataR t gmPermitDatat petDataR t normalDictDatat dienstgradDataR¢ t allDatat crct dataCrct dataWithCrcR Rá t
|
playerInfo( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyR U s|
|
, " #D
|
&
|
|
c C s= | t } | j i t | d 6d d 6 } | j d k S( NRº i Rª ( R¡ R¢ R R£ ( RX RW RÅ R[ t resultCollection( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyR ± s
|
#c C s d } | j | j d } | j sF t j | | j } | S| } t | d } | j d rî | d } d }
|
t j |
|
| }
|
t j d | | | f x= t | D]/ } | j
|
| d | d |
|
| j 7}
|
q· W|
|
S| r| j | | S| j | | Sd S( NR i i R` R_ s$ ####reading %s of player %s,cnt = %ss %s( R¢ t limitR£ R R¼ RW t has_keyR R RQ t
|
readRecordRâ t adoQueryCustomCt adoQueryCustom( RX R§ t queryRm Rn RX RE Rð R^ t docCntR RA ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyRw · s&
|
c C s | j d | } | j d } t j | | \ } } t j d | | | f | } t | } d }
|
t j |
|
| }
|
xt | D]÷} | j d | } | j | j | j
|
| j d | } | j | j | | | } | j
|
| d k r)t j d t | d S| | 7} d } t j | d r`| j } | | _ n t j | d
|
r| r| j } | j | d } t j | | | _ qn t j | d rÔt j | | _ n t j | d r<| r<| j } | | j k r-| j | d } t j | | | _ q9| | _ q<n | rv| j d | } | j | j | j
|
n |
|
| j 7}
|
q W| j
|
| |
|
f S( s »ñÈ¡¿ç·þÍæ¼Òͬ²½Êý¾Ý»º´æbuffer s getMergePlayerDataBuffer_%s_Alli s9 getMergePlayerDataBuffer %s data, playerID = %s, cnt = %sR s! getMergePlayerDataBuffer_%s_clears$ getMergePlayerDataBuffer_%s_readDataiÿÿÿÿs %sRK t PetIDi t TruckIDt OwnerIDs# getMergePlayerDataBuffer_%s_makeSID( i s ( Rä Rå R R= R R Rc R¼ RQ RR Rç R· R RÀ R
|
t hasFieldRK RÜ Rã t makePetIDt makeTruckIDt TructIDRÞ Rc Râ ( RX RÄ Rm RC Rn Ro R R\ R% R[ R RA R R^ t orgPlayerIDt oldPetIDt petIndext
|
oldOwnerID( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyt getMergePlayerDataBufferÑ s`
|
|
|
|
|
|
|
|
|
|
c C sW t j } | j } t j d | | | k r? | j | | S| | } | t } d S( s »ñÈ¡¿ç·þÍæ¼ÒÏêϸÐÅÏ¢ s) getting mergePlayer detail for accid = %sN( R
R R R R t onGetPlayerDetailR ( RX RW t authPackR t
|
queryAccidt regPlayerInfoRY ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyt onGetMergePlayerDetail
|
s
|
|
|
c 7 C sô t j } | j } t j d | t r- d St j } | | _ d | _ | t } t
|
} t } | j | i t | j d 6| j d 6 } | t
|
k s¼ | j t j t t d S| j | j i }
|
| t k sdt j | j s>t j r>t j | _ | j | t j d | | j | j d q>n t j rd| j t j t t d Sn t } i | j d 6} t } | | } | j | | t j t! } t" j# | d } |
|
j | } | på| d k oå| d | k } t j d | | d | f t% } | | } | j | | t j& } t" j# | d } |
|
j | } | pn| d k on| d | k } t j d | | d | f t' } | | } | j | | t j( } t" j# | d } |
|
j | } | p÷| d k o÷| d | k } t j d | | d | f t) } | | } | j | | t j* } t" j# | d } |
|
j | } | p| d k o| d | k } t j d | | d | f t+ } | | } | j | | t j, } t" j# | d } |
|
j | } | p | d k o | d | k } t j d | | d | f t- } | | } | j | | t j. } t" j# | d } |
|
j | } | p| d k o| d | k } t j d | | d | f t/ } | | } | j | | t j0 } t" j# | d } |
|
j | } | p| d k o| d | k } t j d | | d | f t1 } | | } | j | | t j2 } t" j# | d } |
|
j | } | p¤| d k o¤| d | k } t j d | | d | f t3 } | | } | j | | t j4 } t" j# | d } |
|
j | } | p-| d k o-| d | k } t j d | | d | f t5 } | | } | j | | t j6 }! t" j# |! d }" |
|
j | } | p¶| d k o¶|" d | k } t j d | |" d | f t7 } | | } | j | | t j8 }# t" j# |# d }$ |
|
j | } | p?| d k o?|$ d | k } t j d | |$ d | f t9 } | | } | j | | t j: }% t" j# |% d }& |
|
j | } | pÈ| d k oÈ|& d | k } t j d | |& d | f t; } | | } | j | | t j< }' t" j# |' d }( |
|
j | } | pQ| d k oQ|( d | k } t j d | |( d | f | r t j d | t= j> d
|
| t? j? }) |) j@ tA jB jC tD jE d |) jF d d oï|) jG d d d k }* |* r | j t j t t d Sn | j t jH k rü | jI | t jJ | }+ |+ rÆ |+ jK tL jM k rt | j t j t t d Sd tL jN |+ jK |+ jO f }, | jP | | |+ jQ |, t j d | |, f q(
|
d }, | jP | | d |, t j d | |, f n, | j t j k r(
|
| j t j t t d St jR }- | jS |- _ | tT } |- jU | }. t" j# |. d }/ t j d |/ d | jV | | | | | | | | |. | |! |# |% |' }0 tW |0 }1 d }2 t" jX |2 |1 }2 t" jY |2 d }2 |2 |0 }3 tZ j[ }4 t j |4 _\ | j] |4 _] | j^ |4 _^ | j_ |4 _` |3 |4 _a tb |3 |4 _c | td }5 t je }6 | |6 _ |6 jf |5 |6 jV |4 _g |6 jh |4 _i tj jk jl |4 _m tn jo |4 jp |4 jq t j d | | j f d S( Ns$ getting player detail for accid = %si R Rª s AccID = %s check SID failed!i RK s %s cnt = %s, lastCnt=%ss# ###dgPlayerInit cntError accid = %ss login data cntError accid=%ss PyMongoDataServer.init datasett DataCntErrorKicks" Time past.EndTime = %s.Reason = %ss$ auto unforbidden accid = %s msg = %ss No forbidden oper found!R s gmIP cnt = %ss- gstPlayerDetail Send accid = %s playerID = %s(r R
Rb R R R3 RU R R© Rª R¡ R R R« R R Rã t dgPlayerInitR R R, RK t isAccStateForbiddenR~ R# Rn t pysSIDCheckErrorForbiddenRþ R Rx R Rv Rw Rx RN R R= Rz Ry Rz R{ R| R} R~ R R R R R R R
R R R R R R R R R R R R5 R6 R& R' R( R) R* R R+ t
|
has_optiont getintRw t extractGMOperRT RW R
|
RV RY RZ t unFobbidenAccRX R RU R R Râ R½ R¼ R¾ R t tagMapServerPlayerLoginR4 t ServerRoleIndext SessionIDt IPt ClientIPt PlayerInfoPackRc t PlayerInfoPackLenRù Rú Rü t PlayerAccountInfoRÊ t PlayerAccountInfoLenR¥ t GetGameWorldt GetMapIDt MapIDt NetPackCommont SendPyPackToMapServerSelfR> t GetLength(7 RX RW Ré Rb Rê R R[ Rñ R R t playerDataCntInfot cntErrorR Rl R t itemCntt lastCntR t
|
missionCntR t missonDictCntR t skillCntR t bufCntR t repeatTimeCntR t horseCntR t gmOperCntR t petCntR t petSkillCntR t dictCntR¡ t roleDienstgradCntR¢ t battleFormationCntt dbIniRî R] RÆ R£ R¤ R? RÏ RÐ RÑ RÒ RA R§ t dbDoc( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyRè :
|
sV 4
|
,
|
"
|
"
|
"
|
"
|
"
|
"
|
"
|
"
|
"
|
"
|
"
|
"
|
" "*
|
D
|
|
c C so t j | _ | t } | j | i t | j d 6| j d 6 | j | j | j t
|
t j d | | d S( NR Rª i ( Rã t pysNormalR~ R¡ t adoUpdateExCR R Rª RU RK RU R
|
RV ( RX RW R t gmAccidRÆ R[ ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyRõ
s
|
*c C sF t j d | | | t | | | | f | j | j | d S( Ns` accid = %s playerID = %s isForbidden = %s operTime = %s timeLimit = %s operGMAccid = %s msg = %s( R R3 t ctimeRx RU ( RX R| R¬ R} t operTimet timeLimitt operGMAccidRÆ ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyRU s #
|
c C s
d } t j | | \ } } t j d | | f t j } x= t | D]/ } | | j | | 7} | j | k rN | SqN Wd S( Ni s accid = %s gmOperCnt = %s(
|
R R= R R3 R R RQ R· RS Rz ( RX R| t gmOperR R t operCntR] RA ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyRô ª s c C s0 | t } t | j i | d 6d g } | S( Nt LeaderIDRc ( t UCN_FamilyInfoRW R¢ ( RX RW t leaderIDR[ t familyInfoSnap( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyt getFamilyLeaderFamilyID¸ s
|
"c C sb | t } t | j i t | d 6d d 6t j d 6 } | j r^ | j j | d } n | S( s ²éѯ´¦ÓںϷþ״̬µÄ½ÇÉ«ÁбíR i Rª R~ N( R¡ RW R¢ R Rã t pysServerMergeR} t transform_outgoingRz ( RX RW R| R[ t
|
playerList( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyt queryMergePlayerList½ s
|
|
3 c C s± t j } | j | j d | j t j } | j j j t
|
d | _ | j } | | _ t j d | | j f | t } t | j } d } | t j k r¦| j | | j j t
|
d | _ | j | _ | j j t
|
d | _ | j | _ | j j t
|
d | _ | j | _ | j j t
|
d | _ t j sj| j d k rzt j d qm | j d k rm | j t j | t t SnÇ| t j! k rÅ| j | | j j t
|
d | _ | j | _ | j j t
|
d | _ | j | _ d | _ | j | _ | j j t
|
d | _ | j" j# d } t$ | | d k r| j t j | t t S| | }
|
| | d } | j d k r¹t j d qm | j% d
|
k ri |
|
d 6t& j' | | j d 6| d 6} y t( j) | } t* j+ d | } t* j, | d d } | j- } | d k rtt j d |
|
| f | j t j | t t SWqqXn t. } | | j/ d k r°| j% d 7_% qm | | _/ d | _% n¨| t j0 k rä| j | | j j t
|
d | _ | j | _ | j j t
|
d | _ | j | _ d | _ | j | _ | j j t
|
d | _ | j" j# d } t$ | | d k r¡| j t j | t t S| | }
|
| | d } | j d k rØt j d qm | j% d
|
k r¡i |
|
d 6t& j' | | j d 6| d 6} y t( j) | } t* j+ d | } t* j, | d d } | j- } | d k rt j d |
|
| f | j t j | t t SWq¡q¡Xn t. } | | j/ d k rÏ| j% d 7_% qm | | _/ d | _% n| t j1 k r;| j | | j j t
|
d | _ | j | _ | j j t
|
d | _ | j | _ d | _ | j | _ | j j t
|
d | _ | j" j# d } t$ | | d k rÀ| j t j | t t S| | }
|
| j d k rét j d qm | j% d
|
k røi |
|
d 6| j d 6t& j2 | d 6} yÌ t( j) | } t3 j4 j# d } d j5 | d d | } t j | t* j+ | } t* j, | d d } | j- } | j6 d d } | d k rêt j d |
|
| f | j t j | t t SWqøqøXn t. } | | j/ d k r&| j% d 7_% qm | | _/ d | _% n2t7 } t8 } | j | s | t7 k rt j9 d | j t j | t: t S| t8 k rÏt j9 d | j | j t j | t; t St3 j< r t j d | j | j t j | t= t Sn | j | j j t
|
d k sm t j d | j j | j j f | j t j | t t S| j" rÍ | j" j# d } t$ | d k rÍ t> j> | d j? | _@ | jA | d qÍ n tB jC d! d" | j d t& j2 | | j@ f | jD d 7_D tE jF tE jG | _H | jI | s`
|
t j9 d# | j | j t j | t: t St jJ } | j | _ d | _K | tL } t7 } t8 } | jM | i tN | j d$ 6| jK d% 6 r t jO d& | j | jP rü
|
| jQ | | q | jR | | n| t7 k s" t S| t8 k s5 t Sd | _S d | _T d' | _U d | _V d | _W d | _X d | _Y tZ j[ j\ | _] | j] | _^ | j] | __ d | _` d | _a d | _b d | _c d | _d | je | | \ } } } } | sö t Stf jg } t jh | _i | jj | _j | jk | _k | j | _l | | _m t$ | | _n | j | _o | j | _p tZ j[ j\ | _] t jO d( | j tq jr | js | jt t S() s ÕʺÅÈÏÖ¤i s auth accid = %s-%s...i s 127.0.0.1s iner no checkt 7758520t 1s |i i t tokent product_codet uids2 http://checkuser.sdk.quicksdk.net/v2/checkUserInfot timeouts checktoken fail:%s-%si
|
s1 http://checkuser.happilygame.com/v2/checkUserInfot tokenkeyt channelt guids /i s /centerapi/checkuser.php?s R t OKs DB access excption!s accid = %s not found!s authPack.AccID = %s, sid errors$ input psw = %s while stored psw = %siþÿÿÿi)# s: OperatorID=%s&Step=%s&AccountID=%s&Flag=1000&DeviceFlag=%ss %s update LogNum errorR Rª s player of accid = %s exists!i' s( gstPlayerDetail Send OnCreate accid = %s(u R t tagDataServerPlayerLoginRK Râ RÊ R Rú R RU R¦ R§ Rû R R t IDTypeRù Rk Rã t
|
gitFreeSDKRü R R° t TokenExpiret Phonet Pswt AdultRù t RegIPt IsDebugR t dgPlayerLogint disPswCheckErrorRN t gitQkGamet ExtraRÏ Rc R R t GetLoginKeyR¿ RÀ t urllib2t Requestt urlopenR' RP R t gitHYGamet gitX7R R# t ReportUrlR* t replaceR R R R t disUserNameNotExistRn t disGMKickt md5t hexdigestR t SetClientVersionR5 R t LogNumR
|
RY RV t LastLoginTimet adoCheckUpdateCR© Rª R¡ R« R R3 R Rì Rè t LVt Sext Hairt HairColort
|
PlayerTypeR± t CountryR¥ Rÿ R R t DataMapIDt CopyMapIDt PosXt PosYt HPt UseGoldTypet UseSilverTypeR R Rö Rï R4 R÷ Rø Rú Rû Rü Rý Rþ R R R> R ( RX RW R Ré t
|
accountRect authAccIDR[ t appTypet redefineIndext extraListR+ R- t valuesRC t reqt responset the_paget nowTimet urlListt tmpurlRñ R t infoListR R R R RA ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyRñ Æ s² !
|
|
|
|
|
|
|
|
|
|
|
!) #
|
, c C s d S( N( ( RX Rj t
|
fromPacketRX ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyR
s i c C s@ d } t j | | } t j | d } t j | | } d S( NR i ( R R¾ ( RX Rj Rj t disconnectReasont packBuf( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyR s c C s d S( N( ( RX Rj Rl ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyRà # s c C s d S( N( ( RX RW R ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyRð ) s c C s | j } d } 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 j d t | | S( sP ¶ÁÈ¡·þÎñÆ÷¹«¹²Êý¾Ý
|
¡¾×¢¡¿£ºÐ½¨µÄ±íÍùºóÌí¼Ó
|
R s readGameWorldData Start...s tagDBEventTrig oks tagDBPlayerViewCache oks tagDBBillboard oks tagDBMailServer oks tagDBMailPlayerRec oks tagDBMailPersonal oks tagDBMailItem oks tagDBFamily oks tagDBFamilyMem oks tagDBFamilyAction oks tagDBGameRec oks readGameWorldData len:%s( RW R R3 t UCN_DBEventTrigR t tagDBEventTrigt adoQueryAllt UCN_DBPlayerViewCachet tagDBPlayerViewCachet UCN_DBBillboardt tagDBBillboardt UCN_DBMailServert tagDBMailServert UCN_DBMailPlayerRect tagDBMailPlayerRect UCN_DBMailPersonalt tagDBMailPersonalt UCN_DBMailItemt tagDBMailItemt UCN_DBFamilyt tagDBFamilyt UCN_DBFamilyMemt tagDBFamilyMemt UCN_DBFamilyActiont tagDBFamilyActiont UCN_DBGameRect tagDBGameRecRc ( RX RW RC R[ t DBEventTrigt DBPlayerViewCachet DBBillboardt DBMailServert DBMailPlayerRect DBMailPersonalt
|
DBMailItemt DBFamilyt DBFamilyMemt DBFamilyActiont DBGameRec( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyt readGameWorldData- sb
|
|
|
|
|
|
|
|
|
|
|
c C sÙ | j } t | } t j d | d } yp| j | | t t j | } | j | | t t j | } | j | | t
|
t j | } | j | | t t j | } | j | | t t j | } | j | | t t j | } | j | | t t j | } | j | | t t j | } | j | | t t j | } | j | | t t j | } | j | | t t j | } t j d t j rt t _ n Wn6 t j! d t j" d t# j$ } t j | n Xd S( Ns% saveGameWorldData, len = %s!saving...i s saveGameWorldData ok!R s %s(% RW Rc R R3 t savegameServerWorldDataRm R Rn Rp Rq Rr Rs Rt Ru Rv Rw Rx Ry Rz R{ R| R} R~ R R R R R R
t g_serverClosingRN t g_closeSaveDataOKR R» t ERROR_NO_81R½ R¾ ( RX R RW t dataLent gameDataReadPosRÆ ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyt saveGameWorldDatap s. "c N C sc d } | t } t j } | | j | 7} t j d | t } t j } | | j | 7} t j d | t } t j } | | j | 7} t j d | t
|
} t j } | | j | 7} t j d | t } t j } | | j | 7} t j d | t } t j }
|
| |
|
j | 7} t j d | t } t j } | | j | 7} t j d | t } t j } | | j | 7} t j d | t } t j } | | j | 7} t j d
|
| t } t j } | | j | 7} t j d | t } t j } | | j | 7} t j d | t } t j } | | j | 7} t j d | t } t j } | | j | 7} t j d | t } t j } | | j | 7} t j d | t } t j! } | | j | 7} t j d | t" } t j# } | | j | 7} t j d | t$ } t j% } | | j | 7} t j d | t& } t j' } | | j | 7} t j d | t( } t j) } | | j | 7} t j d | t* } t j+ } | | j | 7} t j d | t, } t j- } | | j | 7} t j d | t. } t j/ } | | j | 7} t j d | t0 } t j1 } | | j | 7} t j d | t2 } t j3 } | | j | 7} t j d | t4 } t j5 } | | j | 7} t j d | t6 } t j7 } | | j | 7} t j d | t8 } t j9 } | | j | 7} t j d | t: } t j; } | | j | 7} t j d | t< } t j= }! | |! j | 7} t j d | t> } t j? }" | |" j | 7} t j d | t@ } t jA }# | |# j | 7} t j d | tB } t jC }$ | |$ j | 7} t j d! | tD } t jE }% | |% j | 7} t j d" | tF } t jG }& | |& j | 7} t j d# | tH } t jI }' | |' j | 7} t j d$ | tJ } t jK }( | |( j | 7} t j d% | tL } t jM }) | |) j | 7} t j d& | tN } t jO }* | |* j | 7} t j d' | tP } t jQ }+ | |+ j | 7} t j d( | tR } t jS }, | |, j | 7} t j d) | tT } t jU }- | |- j | 7} t j d* | tV } t jW }. | |. j | 7} t j d+ | tX } t jY }/ | |/ j | 7} t j d, | tZ } t j[ }0 | |0 j | 7} t j d- | t\ } t j] }1 | |1 j | 7} t j d. | t^ } t j_ }2 | |2 j | 7} t j d/ | t` } t ja }3 | |3 j | 7} t j d0 | tb } t jc }4 | |4 j | 7} t j d1 | td } t je }5 | |5 j | 7} | tf } t jg }6 | |6 j | 7} t j d2 | th } t ji }7 | |7 j | 7} t j d3 | tj } t jk }8 | |8 j | 7} t j d4 | tl } t jm }9 | |9 j | 7} t j d5 | tn } t jo }: | |: j | 7} t j d6 | tp } t jq }; | |; j | 7} t j d7 | tr } t js }< | |< j | 7} t j d8 | tt } t ju }= | |= j | 7} t j d9 | tv } t jw }> | |> j | 7} t j d: | tx } t jy }? | |? j | 7} t j d; | tz } t j{ }@ | |@ j | 7} t j d< | t| } t j} }A | |A j | 7} t j d= | t~ } t j }B | |B j | 7} t j d> | t } t j }C | |C j | 7} t j d? | t } t j }D | |D j | 7} t j d@ | t } t j
}E | |E j | 7} t j dA | t } t j }F | |F j | 7} t j dB | t } t j }G | |G j | 7} t j dC | t } t j }H | |H j | 7} t j dD | t } t j }I | |I j | 7} t j dE | t } t j }J | |J j | 7} t j dF y t j | dG }K Wn7 t j dH t j dI t j }L t j |L d SXd }M t j |M t j }M |M |K 7}M | j | t j |M t j dJ t | d S(K NR s tagDBGameRec oks tagDBPyFuncTeam oks tagDBPyFuncTeamMem oks tagDBPlayerRecData oks tagDBPyMineAreaAward oks tagDBPyMineAreaRecord oks tagDBPyMineAreaItem oks tagDBPyCouple oks tagDBPyUnNotifyLoveGiftRec oks tagDBPyCharmValueRec oks tagDBPyPlayerIntimacy oks! tagDBCrossPersonalCompensation oks tagDBCrossBillboard oks tagDBAssistThanks oks tagDBAssist oks tagPlayerViewCachePy oks tagDBAuctionAttention oks tagDBAuctionRecord oks tagDBAuctionItem oks tagDBCrossPKUnNotifyOverInfo oks tagDBCrossPKBillboard oks tagDBPyXMZZ oks tagDBPySealDemonRecord oks tagDBPyBossAttention oks tagDBPyBourseItemLastPrice oks tagDBPyBourseRecord oks tagDBPyFamilyStoreItem oks tagDBPyPlayerFriend oks tagPlayerEnemy oks tagDBPyPlayerContacts oks tagDBPyPlayerBlack oks tagPersonalSocial oks tagPlayerTeamTable oks tagTeamMemberTable oks tagFamilyInfo oks tagPlayerFamily oks tagDBFamilyVS oks tagGameWorldEvent oks tagDBMissionPub oks tagDBIPManage oks tagDBGameServerEventTrig oks tagDBCountryInfo oks tagDBCountryFamilyWarResult oks tagDBCountryFamilyWarRace oks tagDBCountryFamilyWarRequest oks tagDBBillboard oks tagDBGoldOrderForm oks tagDBOverdueGoldOrderForm oks tagDBFamilyTech oks tagDBPlayerLabel oks tagDBPlayerRecall oks tagDBVsReward oks tagDBFamilyReward oks tagDBFamilyRewardRec oks tagDBFamilyAction oks tagGameFBPassRec oks tagUniversalGameRec oks tagGameGroup oks tagGameGroupMember oks tagGameGroupMutualInfo oks tagGameBourseItem oks tagHighLadderPlayer oks tagDBHighLadderItem oks tagHighLadderVSRec oks tagDBCompensationItem oks tagDBPersonalCompensation oks! tagDBEntireCompensationRequire oks tagCompensationPlayerRec oks tagPlayerViewCache oki R! s2 Compress game server player data failed!error =
|
%ss) Game server player data send ok! len = %d(¡ R R R Ro R R t UCN_DBPyFuncTeamt tagDBPyFuncTeamt UCN_DBPyFuncTeamMemt tagDBPyFuncTeamMemt UCN_DBPlayerRecDatat tagDBPlayerRecDatat UCN_DBPyMineAreaAwardt tagDBPyMineAreaAwardt UCN_DBPyMineAreaRecordt tagDBPyMineAreaRecordt UCN_DBPyMineAreaItemt tagDBPyMineAreaItemt UCN_DBPyCouplet tagDBPyCouplet UCN_DBPyUnNotifyLoveGiftRect tagDBPyUnNotifyLoveGiftRect UCN_DBPyCharmValueRect tagDBPyCharmValueRect UCN_DBPyPlayerIntimacyt tagDBPyPlayerIntimacyt UCN_DBCrossPersonalCompensationt tagDBCrossPersonalCompensationt UCN_DBCrossBillboardt tagDBCrossBillboardt UCN_DBAssistThankst tagDBAssistThankst UCN_DBAssistt tagDBAssistt UCN_PlayerViewCachePyt tagPlayerViewCachePyt UCN_DBAuctionAttentiont tagDBAuctionAttentiont UCN_DBAuctionRecordt tagDBAuctionRecordt UCN_DBAuctionItemt tagDBAuctionItemt UCN_DBCrossPKUnNotifyOverInfot tagDBCrossPKUnNotifyOverInfot UCN_DBCrossPKBillboardt tagDBCrossPKBillboardt UCN_DBPyXMZZt tagDBPyXMZZt UCN_DBPySealDemonRecordt tagDBPySealDemonRecordt UCN_DBPyBossAttentiont tagDBPyBossAttentiont UCN_DBPyBourseItemLastPricet tagDBPyBourseItemLastPricet UCN_DBPyBourseRecordt tagDBPyBourseRecordt UCN_DBPyFamilyStoreItemt tagDBPyFamilyStoreItemt UCN_DBPyPlayerFriendt tagDBPyPlayerFriendt UCN_PlayerEnemyt tagPlayerEnemyt UCN_DBPyPlayerContactst tagDBPyPlayerContactst UCN_DBPyPlayerBlackt tagDBPyPlayerBlackt UCN_PersonalSocialt tagPersonalSocialt UCN_PlayerTeamTablet tagPlayerTeamTablet UCN_TeamMemberTablet tagTeamMemberTableR! t tagFamilyInfot UCN_PlayerFamilyt tagPlayerFamilyt UCN_DBFamilyVSt tagDBFamilyVSt UCN_GameWorldEventt tagGameWorldEventt UCN_DBMissionPubt tagDBMissionPubt UCN_DBIPManaget tagDBIPManaget UCN_DBGameServerEventTrigt tagDBGameServerEventTrigt UCN_DBCountryInfot tagDBCountryInfot UCN_DBCountryFamilyWarResultt tagDBCountryFamilyWarResultt UCN_DBCountryFamilyWarRacet tagDBCountryFamilyWarRacet UCN_DBCountryFamilyWarRequestt tagDBCountryFamilyWarRequestRr Rs t 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 tagDBFamilyRewardRecR R t 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 tagPlayerViewCacheR# t compressR R» t ERROR_NO_75R½ R¾ R! R R¼ t VersionNoDefinet$ GAMESERVER_GAMEWORLD_DATA_VERSION_NOt sendGameServerStringRã t dgGameServerDataR3 Rc (N RX RW R RC R[ R t DBPyFuncTeamt DBPyFuncTeamMemt DBPlayerRecDatat DBPyMineAreaAwardt DBPyMineAreaRecordt DBPyMineAreaItemt
|
DBPyCouplet DBPyUnNotifyLoveGiftRect DBPyCharmValueRect DBPyPlayerIntimacyt DBCrossPersonalCompensationt DBCrossBillboardt DBAssistThankst DBAssistt PlayerViewCachePyt AuctionAttentionInfot AuctionRecordInfot AuctionItemInfot crossPKOverInfot crossPKt XMZZt sealDemonRecordt bossAttentiont bourseItemLastPricet bourseRecordt familyStoreItemt playerFriendt playerEnemyt playerContactst playerBlacklistt playerSocialt
|
playerTeamt
|
teamMembert
|
familyInfot playerFamilyt familyVSt gameWorldEventt
|
missionPubt ipManaget gameServerEventTrigt countryInfot countryFamilyWarResultt countryFamilyWarRacet countryFamilyWarReqt billboardt goldOrderFormt overdueGoldOrderFormt unclaimeGoldFormt
|
familyTecht
|
playrLabelt playerRecallt
|
dbVSRewardt dbFamilyRewardt dbFamilyRewardRect dbFamilyActiont dbGameFBPassRect dbUniversalGameRect dbGameGroupt dbGameGroupMembert dbGameGroupMutualInfot dbGameBourseItemt dbHighLadderPlayert dbDBHighLadderItemt dbHighLadderVSRect dbDBCompensationItemt dbDBPersonalCompensationt dbDBEntireCompensationRequiret dbCompensationPlayerRect dbPlayerViewCachet compressDataRÆ t SendData( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyt onGetGameServerPlayerData sF
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
"
|
c C sh d } t j | j | \ } } t j | j | \ } } | j | | | j | | | d S( Ni ( R Rá Râ t saveGameServerGameData( RX RW R R t
|
needReturnRj ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyt onSaveGameServerDataé s # c C s | t j k rì
|
t j | | \ } } t j | | \ } } t j | | \ } } t j | | \ }
|
} t j | | |
|
\ } } |
|
rW
|
| t j k st j d t j
|
d | t j f } t j | t j t j j t j t j d d | t Sym t j | } | j d d \ } } t | } t j d | | | f t j | | | | } Wn6 t j d t j d t j } t j | qd
|
Xt j d
|
t! | d } yE| j" | | t# t$ j% | } | j" | | t& t$ j' | } | j" | | t( t$ j) | } | j" | | t* t$ j+ | } | j" | | t, t$ j- | } | j" | | t. t$ j/ | } | j" | | t0 t$ j1 | } | j" | | t2 t$ j3 | } | j" | | t4 t$ j5 | } | j" | | t6 t$ j7 | } | j" | | t8 t$ j9 | } | j" | | t: t$ j; | } | j" | | t< t$ j= | } | j" | | t> t$ j? | } | j" | | t@ t$ jA | } | j" | | tB t$ jC | } | j" | | tD t$ jE | } | j" | | tF t$ jG | } | j" | | tH t$ jI | } | j" | | tJ t$ jK | } | j" | | tL t$ jM | } | j" | | tN t$ jO | } | j" | | tP t$ jQ | } | j" | | tR t$ jS | } | j" | | tT t$ jU | } | j" | | tV t$ jW | } | j" | | tX t$ jY | } | j" | | tZ t$ j[ | } | j" | | t\ t$ j] | } | j" | | t^ t$ j_ | } | j" | | t` t$ ja | } | j" | | tb t$ jc | } | j" | | td t$ je | } | j" | | tf t$ jg | } | j" | | th t$ ji | } | j" | | tj t$ jk | } | j" | | tl t$ jm | } | j" | | tn t$ jo | } | j" | | tp t$ jq | } | j" | | tr t$ js | } | j" | | tt t$ ju | } | j" | | tv t$ jw | } | j" | | tx t$ jy | } | j" | | tz t$ j{ | } | j" | | t| t$ j} | } | j" | | t~ t$ j | } | j" | | t t$ j | } | j" | | t t$ j | } | j" | | t t$ j
| } | j" | | t t$ j | } | j" | | t t$ j | } | j" | | t t$ j | } | j" | | t t$ j | } | j" | | t t$ j | } | j" | | t t$ j | } | j" | | t t$ j | } | j" | | t t$ j | } | j" | | t t$ j | } | j" | | t t$ j | } | j" | | t t$ j | } | j" | | t t$ j | } | j" | | t t$ j | } | j" | | t t$ j¡ | } | j" | | t¢ t$ j£ | } | j" | | t¤ t$ j¥ | } | j" | | t¦ t$ j§ | } | j" | | t¨ t$ j© | } | j" | | tª t$ j« | } | j" | | t¬ t$ j | } | j" | | t® t$ j¯ | } t j d Wn9 t j° k
|
rF
|
t j d t j± d } t j | n Xt j d n t j d t² j³ } t j´ | _µ t j¶ | _· d | _¸ | j¹ | jº | j» j¼ | j» j½ | j» j¾ | j» j¿ | j» jÀ | jÁ n
|
| d k r| | } d } | r[ym t j | } | j d d \ } } t | } t j d | | | f t j | | | | } Wn6 t j d t j d t j } t j | qhXt! | } t j d | d } yE| j" | | t# t$ j% | } | j" | | t& t$ j' | } | j" | | t( t$ j) | } | j" | | t* t$ j+ | } | j" | | t, t$ j- | } | j" | | t. t$ j/ | } | j" | | t0 t$ j1 | } | j" | | t2 t$ j3 | } | j" | | t4 t$ j5 | } | j" | | t6 t$ j7 | } | j" | | t8 t$ j9 | } | j" | | t: t$ j; | } | j" | | t< t$ j= | } | j" | | t> t$ j? | } | j" | | t@ t$ jA | } | j" | | tB t$ jC | } | j" | | tD t$ jE | } | j" | | tF t$ jG | } | j" | | tH t$ jI | } | j" | | tJ t$ jK | } | j" | | tL t$ jM | } | j" | | tN t$ jO | } | j" | | tP t$ jQ | } | j" | | tR t$ jS | } | j" | | tT t$ jU | } | j" | | tV t$ jW | } | j" | | tX t$ jY | } | j" | | tZ t$ j[ | } | j" | | t\ t$ j] | } | j" | | t^ t$ j_ | } | j" | | t` t$ ja | } | j" | | tb t$ jc | } | j" | | td t$ je | } | j" | | tf t$ jg | } | j" | | th t$ ji | } | j" | | tj t$ jk | } | j" | | tl t$ jm | } | j" | | tn t$ jo | } | j" | | tp t$ jq | } | j" | | tr t$ js | } | j" | | tt t$ ju | } | j" | | tv t$ jw | } | j" | | tx t$ jy | } | j" | | tz t$ j{ | } | j" | | t| t$ j} | } | j" | | t~ t$ j | } | j" | | t t$ j | } | j" | | t t$ j | } | j" | | t t$ j
| } | j" | | t t$ j | } | j" | | t t$ j | } | j" | | t t$ j | } | j" | | t t$ j | } | j" | | t t$ j | } | j" | | t t$ j | } | j" | | t t$ j | } | j" | | t t$ j | } | j" | | t t$ j | } | j" | | t t$ j | } | j" | | t t$ j | } | j" | | t t$ j | } | j" | | t t$ j | } | j" | | t t$ j¡ | } | j" | | t¢ t$ j£ | } | j" | | t¤ t$ j¥ | } | j" | | t¦ t$ j§ | } | j" | | t¨ t$ j© | } | j" | | tª t$ j« | } | j" | | t¬ t$ j | } | j" | | t® t$ j¯ | } t j d Wqht j° k
|
rWt j d t jà d } t j | qhXn t j d | d k rt² j³ } t j´ | _µ t jÄ | _· d | _¸ | j¹ | jº | j» j¼ | j» j½ | j» j¾ | j» j¿ | j» jÀ | jÁ t j d | qno | t jÅ k r?| jÆ | | d t$ jÇ | n@ | t jÈ k rn| jÆ | | d t$ jÉ | n t jÊ d | d S( NR! sW Save game server crash data error:data version conflict!versionNO = %s, db version = %st tagGDGameServerGameDatas 0.mdats |i s' disCompresspydata len %s, GameData = %sR s4 Decompress game server world data failed!error =
|
%ss= Decompress game server world data success, len = %d!saving...i s Save game server world data ok!s Short data buf, ignore...s Save game server player data ok!s Empty crash data,ignore...s5 Decompress game server world data failed! error =
|
%ss= Decompress game server world data success, len = %s!saving...sI saveGameServerGameData saveType = 0 decompressGameDataLen = %s responsed!t tagDBMailListt tagDBMailItemLists saveType = %s not processed!(Ë Rã t dgGameServerCrashDataR t ReadWORDR= R R R R R» t ERROR_NO_76R R! R R R( R) R* R R t DUMP_PATHRN R# R$ RÏ Rk R R¿ t a2b_hext ERROR_NO_77R½ R¾ R3 Rc R R R R R R R R R R R R R R R¡ R¢ R£ R¤ R¥ R¦ R§ R¨ R© Rª R« R¬ R R® R¯ R° R± R² R³ R´ Rµ R¶ R· R¸ R¹ Rº R» R¼ R½ R¾ R¿ RÀ RÁ RÂ RÃ RÄ RÅ RÆ RÇ RÈ RÉ RÊ RË RÌ RÍ RÎ RÏ RÐ RÑ RÒ RÓ RÔ RÕ RÖ R× RØ R! RÙ RÚ RÛ RÜ RÝ RÞ Rß Rà Rá Râ Rã Rä Rå Ræ Rç Rè Ré Rê Rë Rì Rí Rr 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 R
|
R R R R R R R R R R R R R R R R R t ShortBuft ERROR_NO_78R t tagDBUpdateReturnt dgUpDatet CallTypet gstSaveGameServerCrashDatat
|
UpdateTypeR5 R: RQ R R? t poolIndexRj t
|
srcSvrTypet
|
dstSvrTypeR> t ERROR_NO_80R t gstSaveGameServerDatat dgPlayerMailListt savePlayerMailDataRn t dgPlayerMailItemListRo R ( RX RW R RC R t saveTypeRk t markt versionNORÐ t gameDataLent gameDataRÆ t decompressGameDatat pyDataLent pyDataHexR RA t decompressGameDataLen( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyRj s® % . "
|
" c C sÛ | t | k r$ t j | n t j | | \ } } t j d | | | f | | } | } | | _ | j | g }
|
xw t d | D]f } | j
|
| j | | t | } | d k rÞ t j | n | | 7} |
|
j | j q W|
|
s | Sd } xÅ t rÖy | j |
|
t t PWqt j j k
|
rÒ} t j | k rg| d 7} qn t t j d | j j t j d d | f t j d t j d | | | f } t j | | SXqW| S( Ns Saving %s cnt = %s playerID = %si iÿÿÿÿi s %s.%s:rec = %si R s4 Insert failed!PlayerID = %s, error = %s, trycnt = %d( Rc Rã Rv R R= R R3 RK t adoDeleteByIndexRQ RR R· RR Rd RN RT RU R Re t PyMongoErrorR# Rg R Rh Ri Rj Rk R R» t ERROR_NO_152( RX R¬ RC R Rl Rm RW t recCntR[ R% RE RA R^ Rp Rq RÆ ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyt saveGameServerPlayerData5 sB
|
|
|
|
.% c C sì | t | k r; t j d | | f t j | n t j | | \ } } t j d | | f | | } | j | g } | } x¯ t d | D] }
|
| j | j
|
| | t | } | j d | k r!t j d | j j t j d d |
|
f t j | n | | 7} | j | j q W| sL| Sd } xt rçyç d } t t | } | | k r| j | t t n¨ t t j | t | } t | | } t j d | | f x_ t | D]Q }
|
|
|
| } |
|
| d
|
k r| | } n | | | | !} | j | t t qëWPWqUt j j k
|
rã} t j | k ry| d
|
7} qUn t! t j d | j j" t j d d | f t j d | j j" t j d d | | f | SXqUW| S( Ns !!!Saving Error %s cnt = %ss Saving %s cnt = %si iÿÿÿÿs! %s.%s readData failed, index = %si i i s" insertTimes=%s,perTimeCount=%si s %s.%s save %s failed!s %s.%s, error = %s, trycnt = %si i (# Rc R R3 Rã Rv R R= t drop_collectionRQ RR R· t
|
dumpStringR Rh t _UserCtrlDB__name_Rj Rk RR Rd RN RV RT RU Rk t matht ceilt floatt rangeR Re Rf R# Rg R Ri ( RX RC R Rl Rm RW R R[ RE R% RA R^ Rp t max_sizet
|
docsStrLent insertTimest perTimeCountR, t insDocsRq ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyR ` s\
|
|
|
.
|
|
|
.1 c C s¬ | t | k r$ t j | n t j | | \ } } t j d | | | } | } xEt d | D]4} | j | | t | }
|
d |
|
k r¯ t j | n | |
|
7} d } xâ t r£yG | j
|
i | j d 6| j d 6 | j
|
i | j d 6| j d 6 PWq t j j k
|
r} t j | k r | d 7} q q t t j d | j j t j d d | j f t j d | j | | f | SXq Wqp W| S(
|
Ns' Saving PlayerDeleteFriend data Cnt = %si iÿÿÿÿRK t FriendIDi s %s.%s:PlayerID = %si s5 delete failure!PlayerID = %s, error = %s, trycnt = %d( Rc Rã Rv R R= R R3 RQ RK RN RH RK R R Re Rf R# Rg R Rh Ri Rj Rk R ( RX RC R t
|
packStructRl RW R R[ R% RA R^ Rp Rq ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyt savePlayerDeleteFriendData s4
|
|
!! 1 c C s | rt | d k rD t j d t j d | } t j | d Sd } t j | | \ } } t j d | | f | | } | } t | }
|
x{ t | D]Z } | j | j
|
| | |
|
} d | k rè t j | n | | 7} | j | q¥ Wn t j d | d S( Ni R s- invalid player mail data, collectionName = %si s Saving %s cnt = %siÿÿÿÿs0 empty player mail list data, collectionName = %s( Rc R R» t ERROR_NO_82R R R= R3 RQ RR R· Rã Rv t adoInsert( RX RC Rl Rm RW RÆ R R R[ R% t datalenRA R^ ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyR ¼ s&
|
|
|
c
|
C s | j } d } t | } y¯ t j } | j | | | } t j } | j | j d | j t
|
j t
|
j | _ | t } | j | s² | j t j | d t S| j t j | d t SWn? t j d t j d | j t j f } t j | n Xt S( Ni R R s* Insert Acc failed, accid = %s, error =
|
%s( Râ Rc R t tagBDStringTypeSendRK R Rú R· Rj Rt R
|
RY RV t RegisterTimeRù Rº R Rã t dgInsertAccRU R
RN R R» t ERROR_NO_83Rû R½ R¾ R (
|
RX RW R RC R R¤ t oTypeSendt AccR[ RÆ ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyR÷ Ù s&
|
+c C s# | j } t | } d } y¿ t j } | j | | | } | t } t j } | j | _ t } | j
|
| s | t k r t St j r t Sn d | _ | j | i t | j d 6| j d 6 sØ t St SWn? t j d t j d | j t j f }
|
t j |
|
n Xt S( Ni i R RK R s; OnPlayerIDMarkDeleted failed! Playerid = %d, exception = %s( Râ Rc R t tagMarkPlayerDeletedRK R¡ R R© RK R Rü RU R# Rn Rª R R R RN R R» t ERROR_NO_84R½ R¾ R ( RX RW R RC R¤ R t oMarkPlayerDeletedR§ t oPlayert SidErrorCntRÆ ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\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 tagDGetValueByAccRK Râ t UCN_AccCoinsR t tagAccCoinsRª R Rê R R3 RU Rã R¿ t GoldCoinsR t tagDServerValueTypet dgCoinR4 t ValueRà R> RN R R» t ERROR_NO_85R½ R¾ ( RX RW R t oDGetValueByAccR§ t oAccCoinst oSvrValueRÆ ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyRù s(
|
# "c C s. yðt j } | j | j t j d | j | j | j f | t } t
|
j } | j | _ t j } t j | _ | j | sµ t j d | j | | j t St j d t j | j | j | j f | j | j k rt j d | j | | j t S| j | j 8_ | j | j 7_ | j | s| j | | j t j d t j d t j | j | j f } t j | t S| j | _ | j | | j t j | _ | j | _ | j | | j Wn7 t j d t j d t j! } t j | t SXt" S( Ns3 gstCoinChange, AccId = %s, PlayerID = %d, coin = %ds" gstGetCoin, not found match recordsE Type = %d, AccId = %s, PlayerID = %d, Before exchange GoldCoins = %ds not enough coin to exchangeR sE Type = %d, AccId = %s, PlayerID = %d, update exchange GoldCoins fails OnCoinChange throw exception
|
%s(# R t tagMDCoinChangeReqRK Râ R R3 Rª RK t CoinR± R R² R R R´ Rã t dgCoinChangeResultR4 Rê Rà R> RU RÀ R³ t UseGoldCoinst adoUpdateR R» t ERROR_NO_87R¶ Rµ t ERROR_NO_88R½ R¾ RN ( RX RW R t oCoinChangeReqR§ R¹ t retPackRÆ ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyRú 3 sF #
|
) . " c C s yÕ t j } | j | j t j } t j } | j | _ d | _
|
| t } t j | _ | j | _ t | j | _ | j | i t | j d 6| j
|
d 6 | _ | j | _ | j | | j Wn7 t j d t j d t j } t j | t SXt S( Ni Rº Rª R s% OnCheckPlayerExist catch exception
|
%s( R t tagBDCheckNameExistRK Râ R t tagDBPlayerNameIsExistR R© t NameRº Rª R¡ Rã t dgCheckPlayerExistRz Rc t NameLenR« R R5 RK Rà R> R R» t ERROR_NO_89R½ R¾ R RU RN ( RX RW R t curPackRÃ R® R§ RÆ ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyRû u s&
|
/ " c C s t j d d S( Ns process gstOnDay in the future!( R R ( RX RW R ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\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 RU RN ( RX RW R RC R t PlayerIdRÆ ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyRý s ( c C s t j } | j | j | t } | j i t | j d 6 j } t j
|
} t j | _ | | _ | j | | j t S( NR ( R R° RK Râ t UCN_ExpiationR¢ R Rª R£ R R´ Rã t dgGetExpiationCountR4 R¶ Rà R> RN ( RX RW R RÊ R§ t recCountRÃ ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyRþ £ s
|
% c C s t j } | j | j | t } | j i t | j d 6 j } t j
|
} t j | _ | | _ | j | | j t S( NR ( R R° RK Râ t UCN_PetExpiationR¢ R Rª R£ R R´ Rã t dgGetPetExpiationCountR4 R¶ Rà R> RN ( RX RW R RÊ R§ RÏ RÃ ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyRÿ ± s
|
% c C sª t j } | j | j | j } t j } t j | _ d | _ | t
|
} | j i t | j d 6 } | t
|
} xþ| D]ö} | j | k r Pn t j }
|
| d |
|
_ t | d |
|
_ | d |
|
_ | d |
|
_ | d |
|
_ | d |
|
_ | d |
|
_ | d |
|
_ | d
|
|
|
_ | d |
|
_ | d |
|
_ | d |
|
_ | d |
|
_ | d |
|
_ | d |
|
_ | d |
|
_ | d |
|
_ | d |
|
_ | d |
|
_! | d |
|
_" | d |
|
_# t | d |
|
_$ | d |
|
_% | d |
|
_& | d |
|
_' | d |
|
_( | d |
|
_) | d |
|
_* | d |
|
_+ | d |
|
_, | d |
|
_- | d! |
|
_. t | d" |
|
_/ | d# |
|
_0 | d$ |
|
_1 | d% |
|
_2 | d& |
|
_3 | d' |
|
_4 | d( |
|
_5 | d) |
|
_6 t | d* |
|
_7 | d+ |
|
_8 | d, |
|
_9 | d- |
|
_: | d. |
|
_; | d/ |
|
_< | d0 |
|
_= | d1 |
|
_> t | d2 |
|
_? | j@ jA |
|
| jB i |
|
j d 6 | j d3 7_ q W| j d k rtC S| jD | | jE tF S(4 Ni R t ExpiationIndext ExpiationTimet Goldt GoldPapert Silvert SilverPapert
|
ItemTypeIDR_ t IsLockedt ItemPlaceTypet ItemPlaceIndext IsBindt
|
ItemStarLVt IdentifyPart CurDurgt MaxDurgt CanPlaceStoneCountt ItemPropertyt SoulPropertyt Makert MakerNamet Stone1t Stone2t Stone3t Stone4t Stone5t Stone6t Stone7t Stone8t Stone9t
|
RemainHourt
|
CreateTimet ElementEffectt IsSuitet FitLVt EquipAddSkillCntt
|
ExpireTimet BaseAtkPlust BaseDefPlust AddSkillDatat BaseHPt BaseMagicDeft EquipMinAtkValuet Proficiencyt RelMaxAddSkillCntt FamilyActiveValueRì Rí i (G R t tagMDGetExpiationExRK Râ R_ R t tagDMGetExpiationExResultRã t dgGetExpiationR4 RÍ R¢ R Rª t tagExpiationRÒ R R RÓ RÔ RÕ RÖ R× RØ RÙ RÚ RÛ RÜ RÝ RÞ Rß Rà Rá Râ Rã Rä Rå Ræ Rç Rè Ré Rê Rë Rì Rí Rî Rï Rð Rñ Rò Ró Rô Rõ Rö R÷ Rø Rù Rú Rû Rü Rý Rþ Rì Rí t DatasRR RH RU Rà R> RN ( RX RW R RÊ t needCountRA R[ t
|
expiationst colDelt curDatat expiation( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyR ¿ s
|
|
7c C sª t j } | j | j | t } t j } | j | _ | j | } t j
|
} t j | _ | j | _ | j | _ | j | | j | s¦ t St S( N( R R° RK Râ RÐ R t tagPetExpiationRª R Rê R¥ Rã t dgGetPetExpiationR4 Rj RÊ Rt Rà R> RU RN ( RX RW R RÊ R§ t dbDataR RA ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyR s
|
c C s¤ t j } d | j | j k rT t j d t j d d } t j | t S| t } | j
|
| j | s t j d t j d } t j | t St S( s ·þÎñÆ÷Êý¾Ý¿â°æ±¾Ë¢ÐÂiÿÿÿÿR s tagServerDataVersionNO:%Ss lack of pack datas* insert tagServerDataVersionNO data failed!( R t tagServerDataVersionNOR· Râ R R» t ERROR_NO_91R RU t UCN_ServerDataVersionNORD R£ t ERROR_NO_92RN ( RX RW R t dbRecvRÆ R§ ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyRÈ ¹ s
|
|
c C s t j } | j | j t j } d | j | j k rl t j d t j
|
d } t j | t St | _ t | d d t j t j | _ | t } | j | i | j d 6t | j d 6 st j d t j d | j | j | j f } t j | t St S( NiÿÿÿÿR s$ tagDBMapServerInfo:lack of pack datat tagDBMapServerInfot LogIndext LogIDRZ s: OnMapServerInfo failed:LogID = %s, LogIndex = %s, Msg = %s( R R¥ RK Râ R R R· Rj R R» t ERROR_NO_93R RU RP t TimeR R# t LOGINDEX_FEEDt LOGINDEX_STEPR t UCN_DBMapServerInfot adoCheckUpdateExR R RZ t ERROR_NO_94RN ( RX RW R RY R RÆ R§ ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyR Í s !
|
,. c C s| y t j d WnW t j d t j d t | j t | j t j } t j | t
|
SXt j d t S( Ns% begin process gstUpdateTotalSavePointR sM OnUpdateTotalSavePoint throw a exception, packdata = %s, packdata len = %d
|
%ss# end process gstUpdateTotalSavePoint( R R3 R R» t ERROR_NO_96RÀ Râ Rc R½ R¾ RU RN ( RX RW R RÆ ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyR ã s B c C sp y2t j } | j | j | t } | j i | j d 6i t j d 6d 6 j } | t j
|
k rw t j } nJ | j i | j d 6t j d 6 j } | d k r¸ t j } n t j } t j } | | _ | j j t j k rt j | j _ | j | j _ n | j | t j | j Wn7 t j d t j d t j } t! j | t" SXt# S( Nt ReceverIDt MailTypes $nei R s) OnGetPlayerMailState throw a exception
|
%s($ R t tagDBGetMailListReqRK Râ t UCN_DBMailListR¢ RK Rã t wmtSaveR£ t MAX_PLAYER_MAIL_COUNTt pmiFullt wmtUnReadedt pmiNewLettert pmiNullR t tagPlayerMailInfot InfoTypeR R~ R R< t stRoutet RouteServerIndexR} R t dgPlayerMailStateR> R R» t ERROR_NO_97R½ R¾ R RU RN ( RX RW R RY R§ t docCountt stateRA RÆ ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\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 tagDBGetMailDetailReqRK Râ t UCN_DBMailItemListR Ro t MailIDR R Rn Rê R R RU R t tagDBMailDetailViewRã t dgMailDetailR4 t MailDetailDataRc t MailDetailDataLent MailItemDatat MailItemDataLenRà R> R R» t ERROR_NO_98R½ R¾ RN (
|
RX RW R RY R§ t dbMailItemListR t
|
dbMailListRA RÆ ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\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 ExistTimeR0 R t
|
SenderNamet Titlet
|
LetterTypet TitleUseSysMessageR s$ OnGetPlayerMail throw a exception
|
%s($ R R RK Râ R t tagDBGetPlayerMailRã t
|
dgMailListR4 R R¢ RK t MailExistTimet tagDBMailInfoR R0 R R; R< R= R: R> t MailRR Rc t MailCountRà R> R R» t ERROR_NO_99R½ R¾ R RU RN (
|
RX RW R RY RA R§ RE R^ t mainInfoRÆ ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyR H s0
|
* " c C s t } t j } yt j } | j | j | j | _ | j | _ xÕt r#t j } d | j
|
| j k r¢ t j d t j d } t j | Pn | t } | j i t | j d 6d d 6 } | j d k rü t j d | j Pn | t } | j i | j d 6 j d k rTt j d t j d } t j | Pn t j }
|
| j |
|
_ | d d
|
|
|
_ | j |
|
_ | j |
|
_ | j |
|
_ | j |
|
_ | j |
|
_ | j |
|
_ | j |
|
_ | j! |
|
_! t" |
|
j! |
|
_# | j$ |
|
_$ | j% |
|
_% |
|
j& | r t } n PqO WWn6 t j d t j' d t( j) } t j | n Xt* j+ | _, | j- | | j. | S( NiÿÿÿÿR s+ tagDBMailList_SaveSysMail lack of pack dataR i Rª s" not exist player role , accid = %sR0 s+ OnAddPlayerMailByAccID: exist a same mailidRK s+ OnAddPlayerMailByAccID throw a exception
|
\s(/ RU R R¥ RK Râ Rj Rt RN R t tagDBMailList_SaveSysMailR· R R» t ERROR_NO_100R R¡ R¢ R R R£ R3 R R0 t ERROR_NO_101Rn t SenderIDR R R; R< RÞ R= R: t ContentRc t
|
ContentLenR> t ContentUseSysMessageR£ t ERROR_NO_102R½ R¾ Rã t dgAddPlayerMailByAccIDR4 Rà R> ( RX RW R R RA RY t curMailRÆ R§ RE R^ ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyR e 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 tagDBDeleteMailRK Râ R R Rn R0 R R R» t ERROR_NO_103RÀ R RU R/ Ro t ERROR_NO_104t ERROR_NO_105R½ R¾ RN ( RX RW R RY R§ R^ RÆ ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyR s,
|
(
|
( " c C sÄ yt j } | j | j | t } t j } | j | _ | j | sÊ t j
|
t j d d | j j | j f | j t j d t j d | j j | j f } t j | t S| j râ | j | _ n | j rú | j | _ n | j rd | _ n | j rK| j | _ d | _ d | _ d | _ d | _ n | j | s×t j
|
t j d d | j j | j f t | j t j d t j d | j | j j f } t j | t S| j! r
| t" } | j | _ | j# | s
t j
|
t j d d | j j | j f t | j t j d t j$ d | j | j j f } t j | t Sn Wn7 t j d t j% d t& j' } t j | t SXt( S( Ns UserLogs\UpdateMailFailDumps
|
%d_%s.mdatR sD update mail fail, load tagDBMailList fail, session = %d, mailid = %si s, update mail fail, maiid = %s, sessionid = %ds! OnUpdateMail throw a exception
|
%s() R t tagDBUpdateMailRK Râ R R Rn R0 Rê R R R R R R? R R» t ERROR_NO_106R RU t UpdateMailTypeR t UpdateLetterTypeR= t GetAllMoneyRÞ t
|
ReturnMailRJ R R: R¿ RÀ t ERROR_NO_107t
|
GetAllItemR/ R t ERROR_NO_108t ERROR_NO_109R½ R¾ RN ( RX RW R RY R§ R^ RÆ ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyR
|
º sR
|
8. >.
|
>. " c C sm y/t j } | j | j t j } t j | _ | j | _ t
|
| j | _ | t } | j i t | j d 6d d 6 } | j s© d | _ d | _ no | d d | _ | t } | j i | j d 6i t j d 6d 6 j } | t j k rd | _ n d | _ | j | | j Wn7 t j d t j d
|
t j } t j | t SXt S( NR i Rª RK R s $neR i R s' OnQueryCanSendMail throw a exception
|
%s( R RÄ RK Râ R RÅ Rã t dgQueryCanSendMailRz RÆ Rc RÈ R¡ R¢ R R£ RK R5 R R R! Rà R> R R» t ERROR_NO_110R½ R¾ R RU RN ( RX RW R RY RA R§ RE R£ RÆ ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\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 ExpiredTimeR 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 dgAccIDSendPrizeR4 RN R R° RK Râ t UCN_AccIDSendPrizeRF RP R Rª RU R Re Rf R# Rg R R R» t ERROR_NO_111R R¢ RÕ R£ t ItemIDR_ RÜ t ERROR_NO_112t RemainItemCountt ERROR_NO_113R½ R¾ Rà R> ( RX RW R RA R RY R§ Rp RÆ RE R^ Rc ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyR sn
|
R
|
% /
|
|
1
|
% 3"
|
c C sf y(t j } | j | j d d l } | j } | t } | j i t | j d 6d d 6 j
|
} | j | } | t j d k r t j d | | f n | j } t j } t j | _ | | _ | j | | j | j | } | t j d k r't j d | n Wn7 t j d t j d t j }
|
t j |
|
t SXt S(
|
NiÿÿÿÿR i Rb g @@s4 OnCheckItemPrize db process time = %s, PrizeCnt = %ss sendString process time = %sR s% OnCheckItemPrize throw a exception
|
%s( R R° RK Râ t timeitt default_timerRh R¢ R Rª R£ R# t ProfileThresholdR R R R´ Rã t dgCheckItemPrizeResultR4 R¶ Rà R> R R» t ERROR_NO_114R½ R¾ RU RN ( RX RW R RY Rn t startTickR§ t PrizeCntt processTimeRA RÆ ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyR P s.
|
, " c C sv y8t j } | j | j | t } t j } | j | _ t j
|
t j } | j | sÀ d | _ | | _ | j | sÀ | j t j | t j d | j | j f t Sn | j d 7_ | | _ | j | s| j t j | t j d | j | j f t S| j t j | | j Wn7 t j d t j d t j } t j | t SXt S( Ni s %s Update Error !doc.LogNum = %di R s# OnCheckLoadAcc throw a exception
|
%s( R R° RK Râ Rù R Rú Rª Rû R
|
RY RV Rü RM R¦ Rº R Rã R< R R3 RU RN Rþ R
t dgPlayerAccLoadR R» t ERROR_NO_115R½ R¾ RN ( RX RW R RY R§ R^ t strNowRÆ ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyR o s4
|
" c C s, yît j } | j | j t j } | j | j t j d | j | j | j
|
f | t } t j } t j d | _ | j | _ | j | _ | j
|
| _ t d | _ d | _ d | _ t | _ | j | _ t j } | j | st j d | j | j | j | j
|
f | j | _ | j j | _ | j | _ | j
|
| _ d | _ | j! | t" t# j$ | j% t& S| j | _ | j j | _ | j | _ | j
|
| _ d
|
| _ | j! | t" t# j$ | j% Wn7 t' j( d t' j) d t* j+ } t j' | t& SXt, S( Ns< Type == gstAddAccItem, accid = %s, itemID = %d, itemCnt = %di im i i i< RÕ i sb Type == gstAddAccItem, transactionIDStr = %s, accid = %s, itemID = %d, itemCnt = %d, Insert Error!i R s! OnAddAccItem throw a exception
|
%siª iðg i@\ i Õ!(- R R¥ RK Râ t tagIRAddItemRj R R Rª Rj t ItemCntRh R t tagAccIDSendPrizeR t GetTransactionIDStrRc R Rd Re RP Ra t PrizeReasonRb t SendPrizeTimeRÜ R t tagIAddItemResultR£ t Lengtht AccLenR_ R5 Rà R§ Rã t dgAddAccItemOKR> RU R R» t ERROR_NO_116R½ R¾ RN ( RX RW R RY t recvDataR§ R^ RA RÆ ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyR sL #
|
) $" c C s yÄ t j } | j | j t j } | j | j | t } t j } | j
|
| _ | j | } | j | _ | j | sà t j d t j d | j
|
| j f } t j | t SWnF t j d t j d | j
|
| j t j f } t j | t SXt S( NR s? OnUpdateTelLockState!Update failed!ACCID = %s,TelLockState = %ssH OnUpdateTelLockState ACCID = %s, TelLockState = %s, throw a exception
|
%s( R R¥ RK Râ R t tagDSAccount_UpdateTelLockStateR· Rj Rù Rú R Rû Rü t TelLockStateRO R R» t ERROR_NO_117R RU t ERROR_NO_118R½ R¾ RN ( RX RW R RY R R§ R^ R RÆ ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyR Ñ s&
|
( 1 c C s yÄ t j } | j | j t j } | j | j | t } t j } | j
|
| _ | j | } | j | _ | j | sà t j d t j d | j
|
| j f } t j | t SWn7 t j d t j d t j } t j | t SXt S( NR s4 OnUpdateAccAdult!Update failed!ACCID = %s,Adult = %ss% OnUpdateAccAdult throw a exception
|
%s( R R¥ RK Râ R t tagDSAccount_UpdateAdultR· Rj Rù Rú R Rû Rü R9 RO R R» t ERROR_NO_121R RU t ERROR_NO_122R½ R¾ RN ( RX RW R RY R R§ R^ R RÆ ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\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 R¥ RK Râ RÍ R R R· Rj R R# t tagExpiation_ExpiationIndex_FEEDt tagExpiation_ExpiationIndex_STEPRÒ R£ t ADOResultRã t dgAddExpiationOKR4 Rc Rt Rà R> R R» t ERROR_NO_123R½ R¾ R RU RN ( RX RW R RY R§ R^ RA RÆ ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\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 R¥ RK Râ RÐ R R R· Rj R R# t# tagPetExpiation_ExpiationIndex_FEEDt# tagPetExpiation_ExpiationIndex_STEPRÒ R£ R Rã t dgAddPetExpiationOKR4 Rc Rt Rà R> R R» t ERROR_NO_124R½ R¾ R RU RN ( RX RW R RY R§ R^ RA RÆ ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyR : s,
|
" c C s7 yùt j } | j | j t j } d | j | j k r | j t j
|
| t j d t j d } t j | t Sd } xWt ráyÈ | t } t j } | j | _ | j | } d | _ | j | t j }
|
| j |
|
_ |
|
j | } | j |
|
_ | j |
|
_ | j |
|
_ | j |
|
_ | j |
|
_ | j |
|
_ |
|
j | PWq t j j! k
|
rÝt" j# | k r| d 7} q n t j d t j$ d | j | j | f } t j | | j t j
|
| t SXq W| j% t j
|
| d Wn7 t j d t j& d t' j( } t j | t SXt S( NiÿÿÿÿR s2 tagDBPlayer_DeleteRoleUpdateRole:lack of pack datai i s[ OnServerMergeDeleteRole!Update failed!DeletePlayerID = %s, UpdatePlayerID = %s, trycnt = %dR s, OnServerMergeDeleteRole throw a exception
|
%s() R R¥ RK Râ R t tagDBPlayer_DeleteRoleUpdateRoleR· Rj R Rã t dgServerMergeDeleteRoleR R» t ERROR_NO_125R RU RN R¡ R© t DeletePlayerIDRK Rü Rª Rþ t UpdatePlayerIDRÔ RÕ RÖ R× t WarehouseGoldt WarehouseSilverR Re Rf R# Rg t ERROR_NO_126R
t ERROR_NO_127R½ R¾ ( RX RW R RY R RÆ Rp R§ R^ t Rett updatedoc( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyR Y sV
|
|
+ " c
|
C st y6t j } | j | j t j } | j | j d } xØ t r yO | t } t j
|
} | j | _ | j | } | j | _ | j | PWqG t j j k
|
rt j | k rÑ | d 7} qG n t j d t j d | j | f } t j | | j t j | t SXqG W| j t j | d Wn7 t j d t j d t j } t j | t SXt S( Ni i R sD OnServerMergeUpdateAccState!Update failed!PlayerID = %s, trycnt = %dR s0 OnServerMergeUpdateAccState throw a exception
|
%s( R R¥ RK Râ R t tagDBPlayer_ChangeAccStateR· Rj RN R¡ R© RK Rü R~ Rþ R Re Rf R# Rg R R» t ERROR_NO_128R R Rã t dgServerMergeUpdateAccStateRU R
t ERROR_NO_129R½ R¾ (
|
RX RW R RY R Rp R§ R^ R RÆ ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyR s:
|
|
% " c C sÎ yst j } | j | j t j } | j | j t j d | j
|
| j f d } xt rqy | t } | j i t | j d 6 j r¨ d | _ n d | _ t j } t j | _ | j | _ t | j | _ | j | | j PWqd t j j k
|
rmt j | k r7| d 7} qd n t j d t j d | j
|
| f } t j | t! SXqd WWn7 t j d t j" d t# j$ } t j | t! SXt j d | j
|
| j f t S( Ns6 OnServerMergeChangeName playerID = %s, newName = %s...i Rº i R s@ OnServerMergeChangeName!Update failed!PlayerID = %s, trycnt = %ds, OnServerMergeChangeName throw a exception
|
%ss7 OnServerMergeChangeName playerID = %s, newName = %s ok!(% R R¥ RK Râ R t tagDBPlayer_ChangeNameR· Rj R R3 RK Rº RN R¡ R¢ R R£ R Rã t dgServerMergeChangeNameR4 Rc Rt Rà R> R Re Rf R# Rg R R» t ERROR_NO_131RU t ERROR_NO_132R½ R¾ ( RX RW R RY R Rp R§ RA RÆ ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyR Á s@
|
% -
|
% " c C sà y¢ t j } | j | j t j } | j | j t | d d t j t j
|
| _ | t } | j | s¡ t j d t j d } t j | t SWn7 t j d t j d t j } t j | t SXt S( Nt tagDBImpeacht ImpeachIndexR s+ OnInsertImpeach!insert tagDBImpeach failed!s, OnServerMergeChangeName throw a exception
|
%s( R R¥ RK Râ R R¨ Rj R R# t tagDBImpeach_ImpeachIndex_FEEDt tagDBImpeach_ImpeachIndex_STEPR© t UCN_DBImpeachR£ R R» t ERROR_NO_133R RU t ERROR_NO_134R½ R¾ RN ( RX RW R RY R^ R§ RÆ ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyR s$
|
" c C s t S( N( RN ( RX RW R ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\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 t MongoDBServert getServerMgrt getClientSessionIDByNameRâ R t tagLPStringDataRK R t tagDGMergerChildToGameStringDataRã t dgMergerChildToCenterR4 Rt Rj t packSendBySessionIDRu R R< R= R> RN ( RX RW R t ServerMgrt sendViaSessionIDRø t PoolIndexRX RY R RA ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyR / s& c C sü t j d t j } | j d d } d } d } | j } t j } d } | j | | t j
|
}
|
t j |
|
_ t j |
|
_ | j |
|
_ | j |
|
_ | j |
|
_ | j | | | t j t j t j |
|
j t j d | j |
|
j g t S( Ns! OnMergeChildToCenterPlayerData inR¯ i iÿÿÿÿs8 OnMergeChildToCenterPlayerData sendString toMapServer %s( R R R° R± R² Râ R t tagLPPlayerDataRK R t tagDMMergePlayerDataRã RÙ R4 t gmMergePlayerDataRÛ Rt Rj RK R¶ Ru R R( R= R> RN ( RX RW R R· R¸ Rø R¹ RX RY R RA ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyRë M s* c * C s t j d | t j } | | _ d | _ | t } t } t } | j | i t
|
| j d 6| j d 6 } | t k s¤ t j d t | j f d Si | j d 6} | t } | j | | t j t } t j | d }
|
| t } | j | | t j } t j | d } | t } | j | | t j } t j | d } | t } | j | | t j } t j | d } | t } | j | | t j } t j | d } | t } | j | | t j } t j | d } | t } | j | | t j } t j | d } | t } | j | | t j } t j | d } | t! } | j | | t j" } t j | d } | t# } | j | | t j$ } t j | d } | t% } | j | | t j& } t j | d } | t' } | j | | t j( } t j | d } | t) } | j | | t j* }! t j |! d }" t j+ }# | j, |# _ | t- } |# j. | }$ t j |$ d }% t j/ d |% d | j0 | | | | | | | | |$ | | | | |! }& t1 j2 j3 t4 j5 d }' t1 j2 j6 |' s7t1 j7 |' n t8 t1 j2 j3 |' d | d
|
}( d d l9 }) |( j: |& |( j; |( j< d S( Ns$ DumpSinglePlayerDataByAcc accid = %si R Rª s= DumpSinglePlayerDataByAcc Exception accid = %s,playerID = %sRK s gmIP cnt = %st DumpPlayerDatas %s.pdsavet wbiÿÿÿÿ(= R R3 R R© R Rª R¡ R R R« R Rê RK Rv Rw Rx RN R R= Ry Rz R{ R| R} R~ R R R R R R R
R R R R R R R R R R R R RU R R R Râ R( R) R* R R R t mkdirR" t structt writet flushR7 (* RX RW Rá R R[ Rñ R R R R R R R R R
|
R R R R R R R R R R R R R R R R R¡ R R¢ R R£ R¤ R? RÏ t DumpDirR( RÀ ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyt DumpSinglePlayerDataByAccl s
|
,
|
|
|
|
|
|
|
|
|
|
|
|
|
|
D"
|
c C s t j j t j d } t j j | sD t j | t d f St j j | d | } d } y) t | d } | j } | j
|
Wn t d f SXt j } d } | j | | t | } d | k rà t d f S| | 7} t j d | j | j d k rt d f S| j j | _ | t }
|
| j |
|
sOt | j f S| | j | j | t t j | | t 7} | | j | j | t t j | | 7} | | j | j | t t j | | 7} | | j | j | t t j | | 7} | | j | j | t t j! | | 7} | | j | j | t" t j# | | 7} | | j | j | t$ t j% | | 7} | j& | j | j | | | | j | j | t' t j( | | 7} t) j* | | \ } } t j+ } x3 t, | D]% } | | j | | t | 7} qèW| | j | j | t- t j. | | 7} | | j | j | t/ t j0 | | 7} | | j | j | t1 t j2 | | 7} | | j | j | t3 t j4 | | 7} | | j | j | t5 t j6 | | 7} | t | k söt7 t | j f S( NR½ i s %s.pdsaveR R iÿÿÿÿs$ Saving player data,playerID = %s....(8 R( R) R* R R R R¿ RU R" R' R7 R R© R· Rc R R3 RK R RU R¡ RO RQ Rv Rx RN Ry Rz R{ R| R} R~ R R R R R R R< R
R R R= R RQ R R R R R R R R R R R> ( RX RW Rá RÃ t FileDirR R( RÃ R RÄ R[ R? R@ RA ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyt SaveSinglePlayerDataFromDumpFileÙ sZ
|
|
|
|
|
,)))))) ) #)))))(v Ri t
|
__module__Rx R R R R R R R® R! R' R" R0 R1 RB Ræ Rè Rh Re Ré Rê Rî Rí Rì Rï Rö R R
|
Rô Rõ R R+ R R R R< RU RQ R; R: R{ Rx Rv Ró R R R R R R¥ R§ R« R R R Rw Rç Rì Rè Rõ RU Rô R$ R( Rñ R
Rz R Rà Rð R R Ri Rl Rj R R R¡ R R÷ Rø Rù Rú Rû Rü Rý Rþ Rÿ R R RÈ R R R R R R R R
|
R R R R R R R R R R R R R R R Rë RÄ RÆ ( ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyRv ï sî m
|
ÿ ¡
|
& A " I $ 0 : +
|
( 4 & o p ^ K , /
|
\ D % ÿ L ÿ N C ÿ [ ) ÿ $ + ; ! ' B
|
Ï + " ! " 8 5 ! @ % = & # C % R m(O R( R# RP RÍ R¿ Rs RJ R R
t DBCommon.CommonDefineRã t MangoDBCommonR R R R R R t ServerClientShareDefineR& R¶ t
|
__import__R# t ctypesR R½ Rj t Collections.CollectionDefinet CommonR R R
|
R5 R R¿ RA t jsonRM R t syst hashlibt CollectionsR R R t DBCommonR R R R t ProtocolR R R R R RÁ R¥ Rw R{ Rg Rm Rn Rl R R R R R t MergeRegPInfoIndex_GroupIDRG t threadt allocate_lockRL R_ R\ Re Ru Rv ( ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyt <module> sf
|
|
.
|
|
"( , & 1
|
