ó
|
|
jc @ 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 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 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 l0 m1 Z1 m2 Z2 m3 Z3 m4 Z4 d d
|
l5 m6 Z6 m7 Z7 m8 Z8 m9 Z9 m: Z: d d l; Z; d d l< Z< d d l= Z= d d l> Z> d d d d d d g Z? d Z@ d ZA d ZB eC d \ ZD ZE ZF ZG d ZH d d lI ZI eI jJ aK eI jJ aL d ZM d ZN d ZO d e= j= f d YZP d S( iÿÿÿÿN( t *( t getADOExceptionCountt getSIDErrorCntt addADOExceptionCountt seqt fix_outgoingTextt fix_incomingTexts Config.DBConfig( t string_at( t ProjSpecialProcess( 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 CheckGameVersionJ sB " c C s t j t | _ t j d d d l } d d l } t j } t j
|
} | | f } d } yë | j | j | j } | j | d } | j | | j | }
|
t j d |
|
t |
|
} | r<| d r<| d } | d } g } x/ t | | d D] } | j i | d
|
6 qW| t } | j | q<n | j Wn7 t k
|
rm} t j d | n t j d n Xt | _ t j d S( Ns IDDispatch CallDispatchPlayerIDiÿÿÿÿi t PIDs IDDispatch recv:%sR! t minIDt maxIDi t PlayerIDs5 IDDispatch CallDispatchPlayerID Connect Exception %ss: IDDispatch CallDispatchPlayerID Connect unknown Exception( t lockPlayerIDt acquiret Truet isDispatchingPlayerIDR
|
R4 R# t timeR$ R% R& R/ R0 R1 R2 R3 R5 t xranget appendt UCN_Dispatch_PlayerIDt insertR8 R9 R t Falset release( t dbt selfR# RQ R: R; R< R= RC RD RE RF RJ RK t recst idt
|
collectionRG ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyt CallDispatchPlayerIDy sD
|
|
|
|
|
|
c C s t j t | _ t j d d d l } d d l } t j } t j
|
} | | f } d } yë | j | j | j } | j | d } | j | | j | }
|
t j d |
|
t |
|
} | 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 CallDispatchFamilyIDiÿÿÿÿi t FIDs IDDispatch recv:%sR! RJ RK i t FamilyIDs5 IDDispatch CallDispatchFamilyID Connect Exception %ss: IDDispatch CallDispatchFamilyID Connect unknown Exception( t lockFamilyIDRN RO t isDispatchingFamilyIDR
|
R4 R# RQ R$ R% R& R/ R0 R1 R2 R3 R5 RR RS t UCN_Dispatch_FamilyIDRU R8 R9 R RV RW ( RX RY R# RQ R: R; R< R= RC RD RE RF RJ RK RZ R[ R\ RG ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyt CallDispatchFamilyID sD
|
|
|
|
|
|
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 hasattrRO 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
|
e d Z e d
|
Z e d Z d Z d Z d Z d Z d Z d Z d Z d Z d Z d Z d Z d Z d Z d Z d Z d Z 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- Z0 d. Z1 d/ Z2 d0 Z3 d1 Z4 d2 Z5 d3 Z6 d4 Z7 d5 Z8 d6 Z9 d7 Z: d8 Z; e d9 Z< e d: Z= d; Z> d< Z? d= Z@ d> ZA d? ZB d@ ZC dA ZD dB ZE dC ZF eG dD dE ZH dF ZI eG dD 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 ds Zv dt Zw RS(u c C s t j j | d t | _ d | _ t j r@ t j | _
|
n t j t j | _
|
t | _ t | _ d | _ t | _ t | _ | j d S( NRt i ( t CtrlDBt __init__RV t Connectedt NoneRX R$ t base64R t Base64StringManipulatort
|
translatort EncodeStringManipulatort encodingRP Ra t loginHeapRQ t loginStartTimet lastCleanMergePlayerTimet connectDB( RY ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyRv ê s Z
|
c C s
|
t j S( N( t GameWorldt IsCrossServer( RY ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyt IsMergeServerV 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_mergeRegisterPlayerDictRQ R t itemst MergeRegPInfoIndex_LogoutTimet MergeRegPInfoIndex_LoginTimet popR
|
t debugt len( RY R Rm t Def_CleanTimet accIDt packInfo( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyt PopOfflineMergePlayerY 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!( Rw R
|
R4 R$ t
|
USER_DB_IPt USER_DB_PORTt pymongot
|
ConnectionRV R R t LoginMongoDBt userdb_usert
|
userdb_pwdt USER_DB_NAMERX RO t onConnectedOK( RY ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyR q s !! c C s t | _ d S( N( RV Rw ( RY ( ( 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_UserCtrlDBFirstInitRO t _UserCtrlDB__PlayerBackupSaveRH t loadDBPlayerIDMap( RY ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyR s
|
c C s* | j s d S| j r n
|
| j d S( s ×ÓÀàʵÏÖ - ÿÃë´¦ÀíN( Rw R t OnQueryRechargeByLoop( RY ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyt onSecondProcess 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 d S( Ni RL t AccIDi t _ids, Æô¶¯·þÎñÆ÷¼ÓÔØDBPlayerÍæ¼ÒÕ˺ÅID¶ÔÓ¦¹Øϵ! %s( RX t UCN_DBPlayert findt countR
t g_dbPlayerIDMapR t LogR ( RY t colt resultSetRF ( ( 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( sD ¸ù¾ÝÍæ¼ÒID²éÕÒdbPlayer
|
@return: None or tagDBPlayer
|
i RL N( RX R¤ R t tagDBPlayert IsDeletedt
|
adoLoadCEx( RY t playerIDR© t dbPlayer( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyt findDBPlayer¡ s c C sw t j | d } | s d S| j t } | j i | d 6d d 6 } | sP d S| rs t j } | j | | S| S( s´ ¸ù¾ÝÍæ¼ÒÃû²éÕÒdbPlayer
|
@param backDBPlayer: ¿ÉÖ¸¶¨·µ»Ø tagDBPlayer ʵÀý£¬Ä¬ÈÏfalse£¬Ö±½Ó·µ»ØdbÊý¾Ý×Öµä
|
@return: None or dbÊý¾Ý×Öµä{k:v, ...} or tagDBPlayer
|
i NRL R¬ ( R t ToIntDefRX R¤ t find_oneR R« t
|
readRecord( RY R® t backDBPlayerR\ t recR¯ ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyt findDBPlayerByID¬ s c C sa | j t } | j i t | d 6d d 6 } | s: d S| r] t j } | j | | S| S( s´ ¸ù¾ÝÍæ¼ÒÃû²éÕÒdbPlayer
|
@param backDBPlayer: ¿ÉÖ¸¶¨·µ»Ø tagDBPlayer ʵÀý£¬Ä¬ÈÏfalse£¬Ö±½Ó·µ»ØdbÊý¾Ý×Öµä
|
@return: None or dbÊý¾Ý×Öµä{k:v, ...} or tagDBPlayer
|
t
|
PlayerNamei R¬ N( RX R¤ R² R R R« R³ ( RY t
|
playerNameR´ R\ Rµ R¯ ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyt findDBPlayerByName¾ s # c C sa | j t } | j i t | d 6d d 6 } | s: d S| r] t j } | j | | S| S( s¶ ¸ù¾ÝÍæ¼ÒÕ˺ŲéÕÒdbPlayer
|
@param backDBPlayer: ¿ÉÖ¸¶¨·µ»Ø tagDBPlayer ʵÀý£¬Ä¬ÈÏfalse£¬Ö±½Ó·µ»ØdbÊý¾Ý×Öµä
|
@return: None or dbÊý¾Ý×Öµä{k:v, ...} or tagDBPlayer
|
R¢ i R¬ N( RX R¤ R² R R R« R³ ( RY R R´ R\ Rµ R¯ ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyt findDBPlayerByAccIDÍ s # c C sL | j t } t j } | j | i | d 6 s6 d S| | _ | j | S( NRL ( RX R¤ R R« R R· t
|
adoUpdateC( RY R® t newNameR© R¯ ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyt updateDBPlayerNameÜ s c C s t j j d | j } | j r5 | j n d } t j | j | \ } } | 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 rq| 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 rC| j d } | j | j | | | j t S| t j k r| j d } | j | j | | | j t S| t j k rÏ| j d
|
} | j | j | | | j t S| t j k r| j d } | j | j! | | | j t S| t j" k r(t S| t j# k rn| 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 | j/ | | | j t S| t j0 k r1| j d } | j | j1 | | | j t S| t j2 k rw| j d } | j | j3 | | | j t S| t j4 k r½| j d } | j | j5 | | | j t S| t j6 k r| j d } | j | j7 | | | j t S| t j8 k rI| j d } | j | j9 | | | 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 ra| j d } | j | jA | | | j t S| t jB k r§| j d } | j | jC | | | j t S| t jD k rí| j d } | j | jE | | | j t S| t jF k r3| j d } | j | jG | | | j t S| t jH k ry| j d } | j | jI | | | j t S| t jJ k r¿| j d } | j | jK | | | j t S| t jL k r | j d } | j | jM | | | j t S| t jN k rK | j d! } | j | jO | | | j t S| t jP k r | j d" } | j | jQ | | | j t S| t jR k r× | j d# } | j | jS | | | j t S| t jT k r
|
| j d$ } | j | jU | | | j t S| t jV k rc
|
| j d% } | j | jW | | | j t S| t jX k r©
|
| j d& } | j | jY | | | j t S| t jZ k rï
|
| j d' } | j | j[ | | | j t S| t j\ k r5 | j d( } | j | j] | | | j t S| t j^ k r{ | j d) } | j | j_ | | | j t S| t j` k rÁ | j d* } | j | ja | | | j t S| t jb k r | j d+ } | j | jc | | | j t S| t jd k rM | j d, } | j | je | | | j t S| t jf k r | j d- } | j | jg | | | j t S| t jh k rÙ | j d. } | j | ji | | | j t S| t jj k r | j d/ } | j | jk | | | j t S| t jl k re | j d0 } | j | jm | | | j t Stn jo d1 | jp t S(2 Ni t gstCrossServerToServerPackt gstGMToolCommandt gstGeneralDBOpert
|
gstDBLogict 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 gstPrepareCreateRoles %s not processed!(q R t GetGameWorldt SetCurGameWorldIndexRX R R R t ReadBYTEt getBuffert CommonDefineR¾ t GetFuncGradet Startt OnCrossServerToServerPackt EndRO R¿ t OnGMToolCommandRÀ t OnGeneralDBOperRÁ t OnGameServerToDBLogicRÂ 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 OnPrepareCreateRoleR
|
t warningt outputString( RY t packRX t post requestTypet
|
oFuncGrade( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyt requestLogicProcesså sL
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
#
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
c C su 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 j d | t
|
j f t S| d k r0| j r d } x: | d k r| j r| j st St d | d 7} qá Wt St | | t S| j r=t Sd d l } | j d t d | | f } | j t S( Ns CheckEmptyFamilyIDCount starti i i s EmptyFamilyIDCount=%s > %siÿÿÿÿt targett args( R
|
R Rb R¥ Ra RO t sleepRV Rc R¦ R$ t IDDispatchFamilyIDLimitt threadingt Threadt start( RY RX R\ R! t try_countt emptyCntR1 t t( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyt CheckEmptyFamilyIDCountv sF
|
|
|
|
c C sd | j } t j } | s d S| j | | t } | j } | r` | d } | j | | Sd S( Ni R_ iÿÿÿÿ( RX R$ t UseIDDispatchServerR7 Rb R² t remove( RY RX R8 R\ Rµ t newID( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyt GetNewFamilyID¥ s
|
|
c C s t j d t | | f | s' d S| j } | t } t j d | j j | j i i | d 6d 6 t j d | j j | j | d S( sv ÒƳýÒÑʹÓõĹ«»áID
|
ÔÒò£º¹«»áIDÐÞ¸ÄΪ²»¸´Óã¬Ð޸ĺó·þÎñÆ÷Æô¶¯ÐèÒª´¦ÀíÒ»´Îɾ³ý±¾Êý¾Ý¿âÖÐÒÑʹÓõĹ«»áID
|
s RemoveFamilyIDUsed: cnt=%s,%sNs idCnt before =%ss $inR_ s idCnt after =%s( R
|
R4 R RX Rb R¥ R¦ R9 R7 ( RY t familyIDListRX R\ ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyt RemoveFamilyIDUsed¸ s
|
c C s[ t j } t j | _ | | _ | | _ t | j | _ | | _ t | j | _
|
d S( N( R t tagDGGeneralDBOperResultRñ t dgDBOperResultt Typet Resultt ResultSetR t ResultSetLent ErrMsgt ErrMsgLen( RY t sessionIDR! Rª t errMsgt sendPack( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyt sendGameServerDBOperResultÇ s c C s t j | d S( N( R t GMCmdPlayerLogin( RY t curPlayer( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyt OnPlayerLoginÒ s c C s y3 t j } | j | j t j | j WnW t j d t j d t
|
j } t j j r| t | q t j | n Xd S( NR sW LogicProcessThread::OnCrossServerToServerPack Catch a unexpetcted exception, error = %s( R t tagLPStringDatat ReadDataRð t NetPackCommont RecCrossServerNetPackt DataR t formatMsgt ERROR_NO_172t tracebackt
|
format_excR Rí t GetDebugLevelR9 R
|
( RY RX R( t recvPackt msg( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyRô Ö s "c C sN y t j | Wn6 t j d t j d t j } t j | n Xd S( NR sM LogicProcessThread::OnGMToolCommand Catch a unexpetcted exception, error = %s( R Rö R RR RS RT RU R
|
( RY RX R( RX ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyRö ê 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!RU 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!R9 s+ 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 tagGDGameServerGeneralDBOperRN R
|
R t OutputStringRx t cPicklet loadst OperDictR9 R& t
|
NeedReturnRI t getSessionIDt
|
isinstancet dictR- t
|
basestringt lowerRZ t strRU RV RO R\ R9 R¥ t list( RY RX R( t bufRW R) t operDictRG t colNameR© RY R! t errorMsgt doc_or_docst docR] t
|
spec_or_idR^ 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 tagGDGameServerToDBLogicRN t QueryTypeR
|
R R` Rñ t gstDBLogic_PlayerPackDataReqt IDt getPlayerPackDatat GetPlayerDataByPlayerIDRy t b64encodet updPlayerPackDatat SendGameServerToDBLogicResultRe t gstDBLogic_PlayerPackDataUpdRQ t gstDBLogic_GMCmdt GMShellt DBGMCommandRj ( RY RX R( Rl RW 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 | _ t j d d S( sñ »Ø¸´GameServer·¢Ë͵ÄSendDBLogic£¬¿ÉÒÔ²»»Ø¸´£¬ÓɾßÌåÀàÐ;ö¶¨
|
@param result: ½á¹û£º1³É¹¦£¬0ʧ°Ü
|
@param recvPack: GameServer·¢À´µÄÊý¾Ý°ü£¬Data¿ÉÔÖµ·µ»Ø£¬Ò²¿ÉÐ޸ĺ󷵻أ¬ÓɾßÌåÀàÐ;ö¶¨
|
@param resultSet: »Ø¸´Êý¾Ý
|
s" »Ø¸´ SendGameServerToDBLogicResultN( R t tagDGGameServerToDBLogicResultRñ t dgDBGameServerToDBLogicResultR@ RA Rv Rt RQ R t DataLenRB RC R
|
R ( RY RF R! RW Rª RH ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyR{ ¯ s c C s¶ t j } | | _ | t } | j | i | d 6 } | sV t j d | j d St j d | j i | j d 6} | t } | j
|
| | t j t } | t } | j
|
| | t j } | t } | j
|
| | t j } | t } | j
|
| | t j }
|
| t } | j
|
| | t j } | t } | j
|
| | t j } | t } | j
|
| | t j } | t } | j
|
| | t j } | t } | j
|
| | t j } | t } | j
|
| | t j } | t } | j
|
| | t j } | t! } | j
|
| | t j" } | t# } | j
|
| | t j$ } t j% } | j j& | _ | t' } | j( | } d | j) | | | |
|
| | | | | | | | | | f S( NRL s0 GetPlayerDataByPlayerID Exception playerID = %si R s
|
accid = %si ( i s (* R R« RL R¤ R R
|
R& R4 R¢ t UCN_RoleItemt readPlayerPackSaveDatat tagRoleItemRO 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 tagDBGMIPRi t
|
UCN_DBGMIPt adoQueryIndexRð ( RY RX 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.pyRx Ä sR
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
c C s d S( N( ( RY RX R( ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyRû s c C s@ d } | d k r d St j s# d St j rD t j d t j d Sy¶| j t } i i t j d 6d 6d d 6} i d d 6d d 6d d
|
6d d 6d d 6} | j | | j | } | sÊ | j rÎ d St
|
j
|
j } t | } | j d d } xú | D]ò } t | d } t | d
|
}
|
t | d } | d } t j j | } | sk| j rt j d | | | |
|
f qn |
|
t j k r£qn t j j |
|
| j i |
|
d
|
6i i d d 6| d 6d 6 t j | |
|
| | qWWn6 t j d t j d t j } t j | n Xg t _ d S( s ¶¨Ê±´¦Àí³äÖµ¶©µ¥¶Ò»»' ÿÃë´¦ÀíÒ»´Î
|
³äÖµÁ÷³Ì
|
¿Í»§¶ËÖ§¸¶ÉÌÆ· -> ƽ̨»Øµ÷ÓÎÏ·ÖÐÐÄ·þÎñÆ÷ -> ÓÎÏ··þÎñÆ÷²åÈ붩µ¥tagPayInfo
|
ÉÌÆ·¶Ò»»¾ÉÁ÷³Ì£º
|
curPlayer.SendDBQueryRecharge() -> gstQueryRecharge -> OnQueryRecharge -> ¡¾GameServerRefresh.PushRecharge¡¿ -> PlayerCoin.PlayerCoinToGold ->
|
-> curPlayer.SendDBFinishRecharge(orderID) -> gstFinishRecharge -> OnFinishRecharge
|
·¢Æð·½Ê½£º
|
1. ÓÎÏ··þÎñÆ÷ÿÃëÂÖѯδ´¦ÀíµÄ¶©µ¥½øÐжһ»ÉÌÆ· -> MT_GetCoinReqs -> curPlayer.SendDBQueryRecharge()
|
2. A8 06 ²éѯ³äÖµ½á¹û #tagCMQueryRecharge -> curPlayer.SendDBQueryRecharge()
|
|
ÉÌÆ·¶Ò»»ÐÂÁ÷³Ì:
|
1. ÓÎÏ··þÎñÆ÷ÿÃëÂÖѯδ´¦ÀíµÄ¶©µ¥½øÐжһ»ÉÌÆ· -> Ö±½Óµ÷Óà PlayerCoin.OnDBPushRecharge -> Ö±½Ó¸üж©µ¥ IsProcess
|
2. ·ÏÆú£¬ A8 06 ²éѯ³äÖµ½á¹û #tagCMQueryRecharge£¬Ö»Ê¹Óúó¶ËÂÖѯ¼´¿É£¬ºóÐøÓÐÎÊÌâÔÙ²¹³äÓÅ»¯
|
i i Ns" »¹ÓÐÕýÔÚ´¦Àí¶Ò»»ÉÌÆ·µÄ³äÖµ¶©µ¥! %ss $inR¢ t IsProcessR£ i t OrderIDt OrderInfot OrderAmounts .sI ³äÖµ¶Ò»»ÉÌƷʱÍæ¼Ò²»ÔÚÏß! accID=%s,orderAmount=%s,orderInfo=%s,orderID=%st EndOrderTimes $setR s traceback = %s( R
t g_onlineAccIDListt g_ctgOrderIDListR t DebugLogRX t UCN_PayInfoR¥ t limitR¦ t datetimet todayRj t splitR t GetPlayerManagert FindPlayerByAccIDt IsEmptyR¨ RS R\ t
|
PlayerCoint OnDBPushRechargeR RR t ERROR_NO_170RT RU R
|
( RY t PayRechargeCountR© R] R^ R! Rm t
|
curTimeStrt billInfoR t orderIDt orderInfot orderAmountRK RX ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyR ( sJ )
|
, " c C s d S( N( ( RY RX R( ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyRú c s c C s¦ yë| j } | j } t j } d } | j | | t j d | j t j } t
|
j | _ t
|
j | _ | j | _ | j | _ t j } | j | _ | j | _ | t } t }
|
| j | st|
|
t k r+d | _ d | _ d | _ | j | | j t j d | j d Sd | _ d | _ d | _ | j | | j t j d | j d S| j | _ | j | _ | j | _ | j | _ | j | _ | j | | j t j d | j | j f d SWn t k
|
r8} t j d t j! d | t" j# | f } t j | n9 t j d t j! d
|
t" j# | } t j | n Xd | _ d | _ d | _ | j | | j d S( Ni s% OnQueryNewGuyCardState cardID = %s...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ð t getLengthR t tagMDIsMediaCardUsedRN R
|
R t CardIDR t tagDMIsMediaCardUsedRñ t dgDBToMapServerR@ t gmQueryNewGuyCardStatet SubTypet CardIDLenR t tagDBNewGuyCardStatet UCN_DBNewGuyCardStateR t adoLoadt IsUsedt UserDataLent UserDatat
|
sendStringt GetBufferR& t CardTypet ValidTimeR' R9 R RR RÈ t binasciit b2a_hex( RY RX R( Rl t packLenRW R) RH t objR© t lastExceptionCntRG RX ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyRù sb
|
+% c C s yt| j } | j } t j } d } | j | | t j } t j | _ t j
|
| _ | j | _ | j | _ t j d | j t j } | j | _ | j | _ | j | _ | j | _ | j | _ | j | _ | j | _ | t } | j | s@d | _ | j | | j t j d | j d Sd | _ | j | | j t j d | j Wn t k
|
rÁ}
|
t j d t j d |
|
t! j" | f } t j | n9 t j d t j d t! j" | } t j | n Xd | _ | j | | j d S( Ni s onCheckUpdateNewGuyCardState %ss/ onCheckUpdateNewGuyCardState failed!cardID = %si s0 onCheckUpdateNewGuyCardState success!cardID = %sR s/ onCheckUpdateNewGuyCardState error %s!pack = %ss, onCheckUpdateNewGuyCardState error!pack = %s(# Rð RÏ R t tagMDCheckUpdateMediaCardStateRN R t tagDMCheckUpdateMediaCardResultRñ RÓ R@ t gmUpdateNewGuyCardStateRÕ RÖ RÑ R
|
R R` R R× RÚ RÛ RÜ Rß Rà RØ t adoCheckUpdateRA RÝ RÞ R9 R RR t ERROR_NO_171Rá Râ ( RY RX R( Rl Rã RW R) RH Rä R© RG RX ( ( 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 tagGDSavePlayerInfoRN Rð t GeTuiClientIDt UCN_DSAccountR t tagDSAccountR¢ Ri t ACCIDt adoLoadCR RR t ERROR_NO_57R
|
R& R» ( RY RX R( R) t
|
PlayerInfoR© t PlayerAccRX ( ( 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 tagLDPrepareCreateRoleRN Rð t GetAccountFromTableR¢ R6 t EventReportt AppIDR t GetPlatformAccIDt
|
DeviceFlag( RY RX R( R) Rò t account( ( 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« t readDataR RV RL R
|
R4 RO R¢ ( RY RX t saveDatat playerRecR) t dbPlayerReadLenR® ( ( 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__ReadPlayerIDRQ R t MergeRegPInfoIndex_PackDataRQ R R R
|
R4 ( RY RX 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 | t j k rt j j | t j j | d
|
n t j d | | f t j j } t j j t j d | t | }
|
t j j |
|
rt j j |
|
d } x t j! |
|
D]t } | j" t j# s©qn t j j |
|
| } t j j t j j | | sòt$ j% | | qt j | qWn | | f S( s# Íæ¼ÒÏÂÏߣ¬±£´æÍæ¼ÒÔÚMapServerµÄÊý¾Ýi i R s% Player save data failed!playerID = %ss UserLogs\SaveFailDumps %s.mdats4 onSaveMapServerPlayerData result = %s, playerID = %ss S%st BackupN(& R R Rð RÏ RV R$ t PackSavet SavePlayerMapServerDataExt SavePlayerMapServerDataR RR t ERROR_NO_59R
|
R t DumpDataR t
|
getAppPathR
R» R9 t g_onlineAccIDDictR Rx R4 R Rí t GetServerIDR) R* R+ t PlayerBakRootRj t existst listdirt endswitht PlayerBakFileTypet shutilt move( RY RX R( R) Rü R! R® R RX t serverIDt PlayerBakDirt
|
BakCopyDirt filenamet fullPath( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyR B s6 + #%!c C sw | j } | j r d St j s9 t j j t j r= d St j j } t j j
|
t j d | } t j d | t j j | s d SxÞt j | D]Í\ } } } | j d rÆ q¢ n x¦| D]} | j t j së qÍ n t | d k rt j d | d SyM t j j
|
| | } t | d } | j }
|
| j t j |
|
}
|
Wn t j d | d SXt j r¢| j | |
|
\ } } } n | j | |
|
\ } } } | sØt j d | d St j j
|
| t | d } t j j t j j
|
| | sDt j | | t j d | | | f qÍ t j | t j d
|
| | | f qÍ Wq¢ Wd S( Ns S%ss" Íæ¼Ò±¸µµÂ·¾¶ ServerPlayerBakDir=%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( RX R R$ R R) R* R R Rí R R+ R
|
R4 t walkR R R t fatalt openR( R8 t zlibt
|
decompressR R R Rj R R R9 ( RY RX R t ServerPlayerBakDirt 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 __PlayerBackupSaveo sR
|
! "c C sl t j } d } | j | | t | } d | k rF t d d f S| | 7} t j d | j | j d k r t d d f S| j j | _ | t
|
} | j d } | j | j | sÔ t | j d f S| j | j | | j d } | j | | j | j | t t j | | t 7} | j | j d } | j | | j | j | t t j | | 7} | j | j d } | j | | j | j | t t j | | 7} | j | j d } | j | | j | j | t t j | | 7} | j | j d
|
} | j | | j | j | t t j | | 7} | j | j d } | j | | j | j | t t j | | 7} | j | j d } | j | | j | j | t t j | | 7} | j | j d } | j | j | j | j | | | j | | j | j | t! t j" | | 7} t# j$ | | \ } } t j% } x3 t& | D]% }
|
| | j | | t | 7} qW| j d } | j | | j | j | t' t j( | | 7} | j | j d } | j | | j | j | t) t j* | | 7} | j | j d } | j | | j | j | t+ t j, | | 7} | j | j d } | j | | j | j | t- t j. | | 7} | j | j d } | j | | j | j | t/ t j0 | | 7} | j | t | k sYt1 t | j | j f S( Ni iÿÿÿÿR s$ Saving player data,playerID = %s....t' gstSaveMapServerCrashData_1_tagDBPlayert% SavePlayerMapServerData_1_tagRoleItemt( SavePlayerMapServerData_1_tagRoleMissiont, SavePlayerMapServerData_1_tagRoleMissionDictt& SavePlayerMapServerData_1_tagRoleSkillt% SavePlayerMapServerData_1_tagRoleBufft+ SavePlayerMapServerData_1_tagRoleRepeatTimet- SavePlayerMapServerData_1_tagPlayerHorseTablet% SavePlayerMapServerData_1_gmOperCheckt$ SavePlayerMapServerData_1_tagRolePett% SavePlayerMapServerData_1_tagPetSkillt* SavePlayerMapServerData_1_tagRoleNomalDictt- SavePlayerMapServerData_1_tagPlayerDienstgradt, SavePlayerMapServerData_1_tagBattleFormation(2 R R« Rû R RV R
|
R4 RL R¢ Ri R¤ Rò Ró R» Rõ t recPlayerLogofft savePlayerDataR R RO R R R R R R R R R R R R t gmOperCheckR R R t ReadDWORDR¢ RR R R R R R R R R R R¡ t AssertionError( RY RX 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û R RV R
|
R4 RL R¢ Ri R¤ Rò Ró R» Rõ t CountryLastWeekHornorR2 t savePlayerDataExR R RO R R R R R R R R R R R R R4 R R R R5 R¢ RR R R R R R R R R R R¡ R6 ( RY RX Rü Rý R) Rþ R\ R+ R7 R8 R9 ( ( 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( R R R5 R R RR t clearRû t OperRñ t gmForbidAcct onForbiddenUpdateRO R t TDateTime_NowRi t EndTimet GMAccIDt TDateTimeToStringt Msg(
|
RY R R® RD R) t lengtht cntt gmOperRecR9 t readLen( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyR4 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 = %sRL 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 R5 R
|
R4 R RR RJ Rû Râ t makeSIDt getRecordRO R\ R t errorst OperationFailureR$ t TryCntOnWriteFailR t __class__t __name__t inspectt stackR R9 ( RY R® RX t collectionNamet
|
structNameRD t checkSIDRZ t oAllFuncGradeR\ R+ R) RT Rµ RS Rq R9 RV t trycntt err( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyRI « 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_removeRL 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
RZ Rò Ró R9 Rõ R R5 R
|
R R RR RJ Rû R4 Râ R[ R\ RS RO RU RV R R] R^ R$ R_ R R` Ra Rb Rc R ( RY R® RX Rd Re RD Rf RZ Rg R\ R+ R) RT Rµ RS R[ R9 RV Rq Rh Ri ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyR3 sx
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
.
|
c C s d S( N( ( RY R¯ ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyR2 T 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 ( Rj t uuidt uuid4R RR t ERROR_NO_60t getPackHeadRF R
|
R R R R R R« R Rû t updatePlayerAccStateRL Rñ t pysForbiddent sendAccForbiddenLogReqR¢ ( RY RX R( t saveDataWithCRCt dumpFileNameRX Rý R) RS ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyt onSavePlayerDataCRCErrorl s + c C s d S( N( ( RY t accidt isForbidden( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyRq
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« RL R Rð R
|
R& R` Ra Rb Rc RV R t AccStateR» RO ( RY RX R® t newStateR\ Rq t lastSIDErrorCntt ret( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyRo 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* tagGameServerToBalanceServerPlayerSaveDataRN Rð RÏ Rd t setSrcSvrTypeR t stLogint sendOKStringRñ t dgPlayerSaveGameServerData( RY RX 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( ( RY RX 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 tagCSIsHaveRoleRN Rð R t tagDRequestResultRñ t" gstCreateRoleServerCheckIsHaveRoleR@ R¢ R R« Ri R¬ R¤ R R R R R
|
R4 RA t ExAttrt disDataBaseErrorR$ Rf t disAccStateErrorRÝ RÞ R R RR t ERROR_NO_62RT RU (
|
RY RX R( RW RH t PlayerR\ Rå Ry RX ( ( 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 tagCSCheckPlayerNameExistRN Rð R R Rñ t# gstCreateRoleServerCheckPlayerExistR@ R¢ RA t hasPlayerByPlayerNameR· R
RÝ RÞ R
|
R R RR t ERROR_NO_63RT RU ( RY RX R( RW RH RX ( ( 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( RY RX R( t Suct disCodet AccIdRD ( ( 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$ gstCreateRoleServerRequestCreateRoleR@ RA R¢ R
R
|
R RÝ RÞ R RR t ERROR_NO_64RT RU ( RY RX R( R R R RD RH RX ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyt# onCreateRoleServerRequestCreateRole s "c C su 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 j d | t
|
j f t S| d k r0| j r d } x: | d k r| j r| j st 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 s EmptyPlayerIDCount=%s > %siÿÿÿÿR- R. ( R
|
R RT R¥ RP RO R/ RV R] R¦ R$ t IDDispatchPlayeIDLimitR1 R2 R3 ( RY RX R\ R! R4 R5 R1 R6 ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyt CheckEmptyPlayerIDCount1 sF
|
|
|
|
c C s; | t } | j } | r7 | d } | j | | Sd S( NRL iÿÿÿÿ( RT R² R9 ( RY RX R\ Rµ R: ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyt PopEmptyPlayerIDa s
|
|
c C sE t j } | s+ t | t d t j t j S| j | | j | S( NRL ( R$ R8 R R¤ t PLAYERID_FEEDt PLAYERID_STEPR R ( RY RX R8 ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyt DispatchNewPlayerIDk s
|
c C s0 t j } | | _ | t } | j | | S( N( R Rî Rï Rí RÙ ( RY R RX t accountDataR\ ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyRõ v 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 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 = %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 RQ RN t CreateRoleTimeR R RR t ERROR_NO_65R t IpyGameDataPYt
|
GetFuncCfgRL t decodet encodeR$ R} R t
|
adoInsertCRÙ t ERROR_NO_66R
R§ R R t
|
WriteDWORDRð t crc32t WriteBYTERõ R6 Rö R÷ Rø Rù t urllibt urlencodeR¥ t DataRecordPackt DR_CreateRole( RY RX t createPlayerR\ t newPlayerIDRX 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 } s|
|
, " D
|
&
|
|
c C s= | t } | j i t | d 6d d 6 } | j d k S( NR· i R¬ ( R¤ R¥ R R¦ ( RY RX 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 RX RW s$ ####reading %s of player %s,cnt = %ss %s( R¥ R¿ R¦ R R° Rk t has_keyR
|
R RR R³ Rð t adoQueryCustomCt adoQueryCustom( RY R© t queryRe Rf Rl R[ Rä Rq t docCntR! R9 ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyR ß s&
|
c C s | j d | } | j d } t j | | \ } } t j d | | | f | } t | } d }
|
t j |
|
| }
|
xt | D]÷} | j d | } | j | j | j
|
| j d | } | j | j | | | } | j
|
| d k r)t j d t | d S| | 7} d } t j | d r`| j } | | _ n t j | d
|
r| r| j } | j | d } t j | | | _ qn t j | d rÔt j | | _ n t j | d r<| r<| j } | | j k r-| j | d } t j | | | _ q9| | _ q<n | rv| j d | } | j | j | j
|
n |
|
| j 7}
|
q W| j
|
| |
|
f S( s »ñÈ¡¿ç·þÍæ¼Òͬ²½Êý¾Ý»º´æbuffer s getMergePlayerDataBuffer_%s_Alli s9 getMergePlayerDataBuffer %s data, playerID = %s, cnt = %sR s! getMergePlayerDataBuffer_%s_clears$ getMergePlayerDataBuffer_%s_readDataiÿÿÿÿs %sRL t PetIDi t TruckIDt OwnerIDs# getMergePlayerDataBuffer_%s_makeSID( i s ( Rò Ró R R5 R
|
R R R° RR RJ Rõ Rû R& Râ R t hasFieldRL RÎ Rñ t makePetIDt makeTruckIDt TructIDRÐ R[ Rð ( RY R¸ Re RD Rf Rg R) RT Rµ RS R! R9 R+ RV 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 ( RY RX t authPackR t
|
queryAccidt regPlayerInfoRW ( ( 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 RL 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
RZ R¢ R
|
R4 RV R R« R¬ R¤ R R R R R Rñ t dgPlayerInitR( R R- RL t isAccStateForbiddenRw R$ Rf t pysSIDCheckErrorForbiddenR» R Rq R R R R RO R R5 Rx R R R R R R R R R R R R R R R R R R R R R R R R¡ R6 R7 R' R( R) R* R+ R R, t
|
has_optiont getintRp t extractGMOperRL RO R RN RQ RR t unFobbidenAccRP R¢ Ri R£ R¤ Rð R± R° R² R t tagMapServerPlayerLoginR@ t ServerRoleIndext SessionIDt IPt ClientIPt PlayerInfoPackR t PlayerInfoPackLenRí Rî Rð t PlayerAccountInfoRÏ t PlayerAccountInfoLenR Rí t GetMapIDt MapIDRO t SendPyPackToMapServerSelfRÞ t GetLength(7 RY RX RÛ RZ RÜ R¯ R\ Rå Ry R¥ t playerDataCntInfot cntErrorR¦ Rd 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à RU RX R´ Rµ R7 RÃ RÄ RÅ RÆ RH R© t dbDoc( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyRÚ b
|
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 pysNormalRw R¤ t adoUpdateExCR R¢ R¬ RM RL RV R RN ( RY RX R¯ t gmAccidRX 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
|
R4 t ctimeRq Ri ( RY Ru R® Rv t operTimet timeLimitt operGMAccidRX ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyRM ¶ 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 R5 R
|
R4 R R RR Rû RK Rx ( RY Ru t gmOperR® R) t operCntRU R9 ( ( 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 LeaderIDRv ( t UCN_FamilyInfoRk R¥ ( RY RX 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¬ Rw N( R¤ Rk R¥ R Rñ t pysServerMergeR{ t transform_outgoingRx ( RY RX Ru 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 j | } | rå d d l m } t j d | | j f | j | t j j | j t j | t t St j d | | j f | t } t | j } d }
|
| t j k r-| j | | j! j t
|
d | _! | j" | _" | j# j t
|
d | _# | j$ | _$ | j% j t
|
d | _% | j& | _& | j' j t
|
d | _( t j) sñ| j( d k sñt j* rt j d q| j% d k r| j t j | t+ t Sna | t j, k rL| j | | j! j t
|
d | _! | j" | _" | j# j t
|
d | _# | j$ | _$ d
|
| _% | j& | _& | j' j t
|
d | _( | j- j. d } t/ | |
|
d k r | j t j | t+ t S| |
|
} | |
|
d } | j( d k r@t j d q| j0 d k r i | d 6t1 j2 | | j! d 6| d 6} y t3 j4 | } t5 j6 d | } t5 j7 | d d } | j8 } | d
|
k rût j d | | f | j t j | t+ t SWq q Xn t9 } | | j: d k r7| j0 d 7_0 q| | _: d | _0 nB
|
| t j; k rê| j | | j! j t
|
d | _! | j" | _" | j# j t
|
d | _# | j$ | _$ d
|
| _% | j& | _& | j' j t
|
d | _( | j- j. d } t/ | |
|
d k r(| j t j | t+ t S| |
|
} | |
|
d } | j( d k r_t j d q| j0 d k r§t1 j2 | | j! } | } d } d } t t9 } t< j< d | | | | | | f j= } i | d 6| d 6| d 6| d 6| d 6| d 6} y t3 j4 | } t5 j6 d | } t5 j7 | d d } | j8 } t> | } | j? d d k rt j d | | | f | j t j | t+ t SWq§q§Xn t9 } | | j: d k rÕ| j0 d 7_0 q| | _: d | _0 n¤| t j@ k ræ| j | | j! j t
|
d | _! | j" | _" | j# j t
|
d | _# | j$ | _$ d
|
| _% | j& | _& | j' j t
|
d | _( | j- j. d } t/ | |
|
d k rÆ| j t j | t+ t S| |
|
} | |
|
d } | j( d k rýt j d q| j0 d k r£y t5 j6 d | } t5 j7 | d d } | j8 } t> | } | j? d! d k rt j d | | f | j t j | t+ t SWq£q£Xn t9 } | | j: d k rÑ| j0 d 7_0 q| | _: d | _0 n¨| t jA k r | j | | j! j t
|
d | _! | j" | _" | j# j t
|
d | _# | j$ | _$ d
|
| _% | j& | _& | j' j t
|
d | _( | j- j. d } t/ | |
|
d k r | j t j | t+ t S| |
|
} | |
|
d } | j( d k rù t j d q| j0 d k rÂ
|
i | d 6t1 j2 | | j! d 6| d 6} y t3 j4 | } t5 j6 d" | } t5 j7 | d d } | j8 } | d
|
k r´
|
t jB d | | f | j t j | t+ t SWqÂ
|
qÂ
|
Xn t9 } | | j: d k rð
|
| j0 d 7_0 q| | _: d | _0 n| t jC k r\ | j | | j! j t
|
d | _! | j" | _" | j# j t
|
d | _# | j$ | _$ d
|
| _% | j& | _& | j' j t
|
d | _( | j- j. d } t/ | |
|
d k rá | j t j | t+ t S| |
|
} | j( d k r
|
t j d q| j0 d k r i | d# 6| j! d$ 6t1 jD | d% 6} yÌ t3 j4 | } tE jF j. d& } d& jG | d' d( | } t j | t5 j6 | } t5 j7 | d d } | j8 } | jH d) d* } | d+ k r t j d | | f | j t j | t+ t SWq q Xn t9 } | | j: d k rG | j0 d 7_0 q| | _: d | _0 n2tI } tJ } | j | s*| tI k r³ t j d, | j t j | tK t S| tJ k rð t j d- | j | j t j | tL t StE jM r*t j d. | j | j t j | tN t Sn | j% | j% j t
|
d k st j d/ | j% j | j% j f | j t j | t+ t Si } | j- r
|
d0 } | j- j. d }! t/ |! d' k rðt< j< |! d j= | _O |! d1 } n | jP | | | d2 <n tQ jR d3 d4 | j! d t1 jD | | jO f | jS d 7_S tT jU tT jV | _W | jX | st j d5 | j | j t j | tK t St jY }" | j |" _ d |" _Z | t[ } tI } tJ } |" j\ | i t] |" j d6 6|" jZ d7 6 rLt jB d8 |" j | j^ r9| j_ | | qê| j` | | n| tI k s_t S| tJ k srt Sd |" _a d |" _b d9 |" _c d |" _d d |" _e d |" _f d |" _g t j jh |" _i |" ji |" _j |" ji |" _k d |" _l d |" _m d |" _n d |" _o d' |" _p | jq | |" \ }# }$ }% } |# s3t Str js }& t jt |& _u | jv |& _v | jw |& _w | j' |& _x | |& _y t/ | |& _z | j |& _{ | j |& _| t j jh |& _i t jB d: | j t} j~ |& j |& j | t j k r t j j | n | t j | <t S(; s ÕʺÅÈÏÖ¤i iÿÿÿÿ( t ChPlayers Íæ¼ÒÒ쳣δµÇ³ö accid = %s-%s...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
|
t ryzji®# s %s%s%s%s%s%st userIDt game_signt game_idRQ t signs5 https://apisdk.gaore.com/user/verifyAccount/state.phpt states, checktoken fail: loginkey=%s, req:%s, ret:%ss4 https://api.funshine-game.com/v3/auth/token?token=%st statuss1 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 = %ss Unity 2022.3.62f3c1iþÿÿÿt ClientVersioni)# 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(
R t tagDataServerPlayerLoginRN Rð RÏ R Rî R¢ Ri t stript chrRï R RÃ RÄ R R R
|
R& t IDTypet PlayerDisconnectExRí t GetTickt sendLoginFailRñ t dgPlayerLogint disKickRepeatPlayerRO R Rí Ri t
|
gitFreeSDKRð R÷ R¤ t TokenExpiret Phonet Pswt AdultRë t RegIPt IsDebugt IsInsideLogint disPswCheckErrort gitQkGamet ExtraRÂ R R~ R t GetLoginKeyR³ R´ t urllib2t Requestt urlopenR( RQ R t gitGaoret md5t hexdigestR5 R- t gitFunshinet gitHYGameR4 t gitX7Rø R$ t ReportUrlR+ t replaceR R R t disUserNameNotExistRf t disGMKickRù t SetClientVersionR6 Rö t LogNumR RQ RN t LastLoginTimet adoCheckUpdateCR« R¬ R¤ R R R RÞ RÚ t LVt Sext Hairt HairColort
|
PlayerTypeR¥ t CountryRñ Rò t DataMapIDt CopyMapIDt PosXt PosYt HPt UseGoldTypet UseSilverTypeR R Rè Rá R@ Ré Rê Rì Rí Rî Rï Rð RO Ró RÞ Rô R
R» RS R
|
(' RY RX R( RÛ t
|
accountRect authAccIDRK R R\ t appTypet redefineIndext extraListR R t valuesRD t reqt responset the_paget nowTimet loginkeyR! R" R# Rm R$ t retDictt urlListt tmpurlRå Ry t accountInfot clientVersiont infoListR R R R RH ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyRþ î sp !
|
'
|
|
|
|
+
|
|
|
|
|
|
|
|
|
!) #
|
, c C s d S( N( ( RY Rh t
|
fromPacketRl ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyR~ ¹ s i c C s
|
d } d S( NR ( ( RY Rh RÛ 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( ( RY Rp Rr ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyRÝ Æ s c C sV t j } | | _ | j | _ | j | _ | | _ t j | j | j d S( N(
|
R Rè R@ Ré Rê Rò RO Ró RÞ Rô ( RY Rh RÛ Rq RH ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyR2 Ë s c C s d S( N( ( RY RX 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 } 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 tagDBFuncTeam oks tagDBFuncTeamMem oks readGameWorldData len:%s( RX R
|
R4 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 tagDBGameRect UCN_DBFuncTeamt tagDBFuncTeamt UCN_DBFuncTeamMemt tagDBFuncTeamMemR ( RY RX RD R\ t DBEventTrigt DBPlayerViewCachet DBBillboardt DBMailServert DBMailPlayerRect DBMailPersonalt
|
DBMailItemt DBFamilyt DBFamilyMemt DBFamilyActiont DBGameRect
|
DBFuncTeamt DBFuncTeamMem( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyt readGameWorldDataÛ sr
|
|
|
|
|
|
|
|
|
|
|
|
|
c C s | j } t | } t j d | d } y¬| j | | t t j | } | j | | t t j | } | j | | t
|
t j | } | j | | t t j | } | j | | t t j | } | j | | t t 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! r×t" 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() RX R R
|
R4 t savegameServerWorldDataRs R Rt Rv Rw Rx Ry Rz R{ R| R} R~ R R R R R R R
R R R R R R R R R
t g_serverClosingRO t g_closeSaveDataOKR RR t ERROR_NO_81RT RU ( RY Rü RX t dataLent gameDataReadPosRX ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyt saveGameWorldData( s2 "c K C sÁ d } | t } t j } | | j | 7} t j d | t } t j } | | j | 7} t j d | t } t j } | | j | 7} t j d | t
|
} t j } | | j | 7} t j d | t } t j } | | j | 7} t j d | t } t j }
|
| |
|
j | 7} t j d | t } t j } | | j | 7} t j d | t } t j } | | j | 7} t j d | t } t j } | | j | 7} t j d
|
| t } t j } | | j | 7} t j d | t } t j } | | j | 7} t j d | t } t j } | | j | 7} t j d | t } t j } | | j | 7} t j d | t } t j } | | j | 7} t j d | t } t j! } | | j | 7} t j d | t" } t j# } | | j | 7} t j d | t$ } t j% } | | j | 7} t j d | t& } t j' } | | j | 7} t j d | t( } t j) } | | j | 7} t j d | t* } t j+ } | | j | 7} t j d | t, } t j- } | | j | 7} t j d | t. } t j/ } | | j | 7} t j d | t0 } t j1 } | | j | 7} t j d | t2 } t j3 } | | j | 7} t j d | t4 } t j5 } | | j | 7} t j d | t6 } t j7 } | | j | 7} t j d | t8 } t j9 } | | j | 7} t j d | t: } t j; } | | j | 7} t j d | t< } t j= }! | |! j | 7} t j d | t> } t j? }" | |" j | 7} t j d | t@ } t jA }# | |# j | 7} t j d | tB } t jC }$ | |$ j | 7} t j d! | tD } t jE }% | |% j | 7} t j d" | tF } t jG }& | |& j | 7} t j d# | tH } t jI }' | |' j | 7} t j d$ | tJ } t jK }( | |( j | 7} t j d% | tL } t jM }) | |) j | 7} t j d& | tN } t jO }* | |* j | 7} t j d' | tP } t jQ }+ | |+ j | 7} t j d( | tR } t jS }, | |, j | 7} t j d) | tT } t jU }- | |- j | 7} t j d* | tV } t jW }. | |. j | 7} t j d+ | tX } t jY }/ | |/ j | 7} t j d, | tZ } t j[ }0 | |0 j | 7} t j d- | t\ } t j] }1 | |1 j | 7} t j d. | t^ } t j_ }2 | |2 j | 7} | t` } t ja }3 | |3 j | 7} t j d/ | tb } t jc }4 | |4 j | 7} t j d0 | td } t je }5 | |5 j | 7} t j d1 | 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 y t j | dD }H Wn7 t j dE t j dF t j }I t j |I d SXd }J t j |J t j }J |J |H 7}J | j | t j |J t j dG t | d S(H NR s tagDBGameRec oks tagDBPyFuncTeam oks tagDBPyFuncTeamMem oks tagDBPlayerRecData 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 Ru R
|
R t UCN_DBPyFuncTeamt tagDBPyFuncTeamt UCN_DBPyFuncTeamMemt tagDBPyFuncTeamMemt UCN_DBPlayerRecDatat tagDBPlayerRecDatat 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 tagDBCountryFamilyWarRequestRx Ry 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 RR t ERROR_NO_75RT RU R R R° t VersionNoDefinet$ GAMESERVER_GAMEWORLD_DATA_VERSION_NOt sendGameServerStringRñ t dgGameServerDataR4 R (K RY RX R( RD R\ R t DBPyFuncTeamt DBPyFuncTeamMemt DBPlayerRecDatat
|
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 compressDataRX t SendData( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyt onGetGameServerPlayerDataI s.
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
"
|
c C sh d } t j | j | \ } } t j | j | \ } } | j | | | j | | | d S( Ni ( R Rï Rð t saveGameServerGameData( RY RX R( R) t
|
needReturnRh ( ( 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 | | |
|
\ } } |
|
rý | 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 | q
|
|
Xt j d
|
t! | d } yë| j" | | t# t$ j% | } | j" | | t& t$ j' | } | j" | | t( t$ j) | } | j" | | t* t$ j+ | } | j" | | t, t$ j- | } | j" | | t. t$ 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© | } t j d Wn9 t jª k
|
rì t j d t j« d } t j | n Xt j d n t j d t¬ j } t j® | _¯ t j° | _± d | _² ná | d k r¬| | } d } | rOym t j | } | j d d \ } } t | } t j d | | | f t j | | | | } Wn6 t j d t j³ d t j } t j | q\Xt! | } t j d | d } yë| j" | | t# t$ j% | } | j" | | t& t$ j' | } | j" | | t( t$ j) | } | j" | | t* t$ j+ | } | j" | | t, t$ j- | } | j" | | t. t$ 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© | } t j d Wq\t jª k
|
rKt j d t j´ d } t j | q\Xn t j d | d k rt¬ j } t j® | _¯ t jµ | _± d | _² t j d | qno | t j¶ k rÛ| j· | | d t$ j¸ | n@ | t j¹ k r
|
| 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 ReadWORDR5 R R$ R% R RR t ERROR_NO_76R
|
R R R R) R* R+ R R t DUMP_PATHRO R R RÂ Ri R Rá t a2b_hext ERROR_NO_77RT RU R4 R R R R R R£ R¤ R¥ R¦ R§ R¨ R© Rª R« R¬ R R® R¯ R° R± R² R³ R´ Rµ R¶ R· R¸ R¹ Rº R» R¼ R½ R¾ R¿ RÀ RÁ RÂ RÃ RÄ RÅ RÆ RÇ RÈ RÉ RÊ RË RÌ RÍ RÎ RÏ RÐ RÑ RÒ RÓ RÔ RÕ RÖ R× RØ RÙ RÚ RÛ RÜ RÝ RÞ R Rß Rà Rá Râ Rã Rä Rå Ræ Rç Rè Ré Rê Rë Rì Rí Rî Rï Rð Rñ Rò Ró Rx Ry Rô Rõ Rö R÷ Rø Rù Rú Rû Rü Rý Rþ Rÿ R R R R R R R R R R R R R
|
R R R R R R R R R R R R R R R R R R R R R R R! t ShortBuft ERROR_NO_78R t tagDBUpdateReturnt dgUpDatet CallTypet gstSaveGameServerCrashDatat
|
UpdateTypeRA t ERROR_NO_80R t gstSaveGameServerDatat dgPlayerMailListt savePlayerMailDataRq t dgPlayerMailItemListRr R& ( RY RX R( RD R) t saveTypeRn t markt versionNORÄ t gameDataLent gameDataRX t decompressGameDatat pyDataLent pyDataHexR¡ RH t decompressGameDataLen( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyRm ½ s % . "
|
" c C sÛ | t | k r$ t j | n t j | | \ } } t j d | | | f | | } | } | | _ | j | g }
|
xw t d | D]f } | j
|
| j | | t | } | d k rÞ t j | n | | 7} |
|
j | j q W|
|
s | Sd } xÅ t rÖy | j |
|
t t PWqt j j k
|
rÒ} t j | k rg| d 7} qn t t j d | j j t j d d | f t j d t j d | | | f } t j | | SXqW| S( Ns Saving %s cnt = %s playerID = %si iÿÿÿÿi s %s.%s:rec = %si R s4 Insert failed!PlayerID = %s, error = %s, trycnt = %d( R Rñ Ry R R5 R
|
R4 RL t adoDeleteByIndexRR RJ Rû RS R\ RO RU RV R R] t PyMongoErrorR$ R_ R R` Ra Rb Rc R RR t ERROR_NO_152( RY R® RD R) Rd Re RX t recCntR\ Rµ R[ R9 RV Rh Ri RX ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyt saveGameServerPlayerDataÚ sB
|
|
|
|
.% c C sâ | t | k r; t j d | | f t j | n t j | | \ } } t j d | | f | | } | j | g } | } x¥ t d | D] }
|
| j | j
|
| | t | } d | k rt j d | j j t j d d |
|
f t j | n | | 7} | j | j q W| sB| 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áWPWqKt j j k
|
rÙ} t j | k ro| d
|
7} qKn t t j d | j j! t j d d | f t j d | j j! t j d d | | f | SXqKW| S( Ns !!!Saving Error %s cnt = %ss Saving %s cnt = %si iÿÿÿÿs! %s.%s readData failed, index = %si i i s" insertTimes=%s,perTimeCount=%si s %s.%s save %s failed!s %s.%s, error = %s, trycnt = %si i (" R R
|
R4 Rñ Ry R R5 t drop_collectionRR RJ Rû R R` t _UserCtrlDB__name_Rb Rc RS R\ RO Rj RU RV Ri t matht ceilt floatt rangeR R] R^ R$ R_ R Ra ( RY RD R) Rd Re RX R R\ R[ Rµ R9 RV Rh t max_sizet
|
docsStrLent insertTimest perTimeCountR3 t insDocsRi ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyR sZ
|
|
.
|
|
|
.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ÿÿÿÿRL t FriendIDi s %s.%s:PlayerID = %si s5 delete failure!PlayerID = %s, error = %s, trycnt = %d( R Rñ Ry R R5 R
|
R4 RR RN RO R9 RL R R R] R^ R$ R_ R R` Ra Rb Rc R ( RY RD R) t
|
packStructRd RX R R\ Rµ R9 RV Rh Ri ( ( 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( R R RR t ERROR_NO_82R
|
R R5 R4 RR RJ Rû Rñ Ry t adoInsert( RY RD Rd Re RX RX R) R R\ Rµ t datalenR9 RV ( ( 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ð R R t tagBDStringTypeSendRN R Rî Rû RQ R R RQ RN t RegisterTimeRí R® R Rñ t dgInsertAccRV R~ RO R RR t ERROR_NO_83Rï RT RU R
|
(
|
RY RX R( RD R) R£ t oTypeSendt AccR\ RX ( ( 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¢ RL R s; OnPlayerIDMarkDeleted failed! Playerid = %d, exception = %s( Rð R R t tagMarkPlayerDeletedRN R¤ R R« RL R Rð RV R$ Rf R¬ R R R¢ RO R RR t ERROR_NO_84RT RU R
|
( RY RX R( RD R£ R) t oMarkPlayerDeletedR© t oPlayert SidErrorCntRX ( ( 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 tagDGetValueByAccRN Rð t UCN_AccCoinsR t tagAccCoinsR© R¢ RÙ R
|
R4 RV Rñ RÍ t GoldCoinsR t tagDServerValueTypet dgCoinR@ t ValueRÝ RÞ RO R RR t ERROR_NO_85RT RU ( RY RX R( t oDGetValueByAccR© t oAccCoinst oSvrValueRX ( ( 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 tagMDCoinChangeReqRN Rð R
|
R4 R© RL t CoinR° R R± R¢ R R³ Rñ t dgCoinChangeResultR@ RÙ RÝ RÞ RV RÎ R² t UseGoldCoinst adoUpdateR RR t ERROR_NO_87Rµ R´ t ERROR_NO_88RT RU RO ( RY RX R( t oCoinChangeReqR© R¸ t retPackRX ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyR × sF #
|
) . " c C s yÕ t j } | j | j t j } t j } | j | _ d | _
|
| t } t j | _ | j | _ t | j | _ | j | i t | j d 6| j
|
d 6 | _ | j | _ | j | | j Wn7 t j d t j d t j } t j | t SXt S( Ni R· R¬ R s% OnCheckPlayerExist catch exception
|
%s( R t tagBDCheckNameExistRN Rð R t tagDBPlayerNameIsExistR R« t NameR· R¬ R¤ Rñ t dgCheckPlayerExistR} R t NameLenR R RA RL RÝ RÞ R RR t ERROR_NO_89RT RU R
|
RV RO ( RY RX R( t curPackRÂ R R© RX ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyR s&
|
/ " c C s t j d d S( Ns process gstOnDay in the future!( R
|
R& ( RY RX R( ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyR 1 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 R5 R3 R R R RR t ERROR_NO_90R
|
RV RO ( RY RX R( RD R) t PlayerIdRX ( ( 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¯ RN Rð t UCN_ExpiationR¥ R R© R¦ R R³ Rñ t dgGetExpiationCountR@ Rµ RÝ RÞ RO ( RY RX R( RÉ R© t recCountRÂ ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyR G 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¯ RN Rð t UCN_PetExpiationR¥ R R© R¦ R R³ Rñ t dgGetPetExpiationCountR@ Rµ RÝ RÞ RO ( RY RX R( RÉ 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 } | 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
|
ItemTypeIDRW 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 tagMDGetExpiationExRN Rð RW R t tagDMGetExpiationExResultRñ t dgGetExpiationR@ 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 DatasRS R9 RV RÝ RÞ RO ( RY RX R( RÉ t needCountRH R\ t
|
expiationst colDelt curDatat expiation( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyR c 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¯ RN Rð RÏ R t tagPetExpiationR© R¢ RÙ R¤ Rñ t dgGetPetExpiationR@ RQ RÏ R RÝ RÞ RV RO ( RY RX R( RÉ R© t dbDataR! RH ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyR 2 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 RR t ERROR_NO_91R
|
RV t UCN_ServerDataVersionNORZ R¢ t ERROR_NO_92RO ( RY RX R( t dbRecvRX 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 LogIDRR s: OnMapServerInfo failed:LogID = %s, LogIndex = %s, Msg = %s( R R¤ RN Rð R R Rû RQ R RR t ERROR_NO_93R
|
RV RQ t TimeR R$ t LOGINDEX_FEEDt LOGINDEX_STEPR t UCN_DBMapServerInfot adoCheckUpdateExR R RR t ERROR_NO_94RO ( RY RX R( RW R
|
RX R© ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyR q 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
|
R4 R RR t ERROR_NO_96Râ Rð R RT RU RV RO ( RY RX R( RX ( ( 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 tagDBGetMailListReqRN Rð t UCN_DBMailListR¥ RL Rñ t wmtSaveR¦ t MAX_PLAYER_MAIL_COUNTt pmiFullt wmtUnReadedt pmiNewLettert pmiNullR t tagPlayerMailInfot InfoTypeRn t
|
srcSvrTypeR t stGamet stRoutet RouteServerIndext poolIndexR& t dgPlayerMailStateRÞ R RR t ERROR_NO_97RT RU R
|
RV RO ( RY RX R( RW R© t docCountR% RH RX ( ( 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 tagDBGetMailDetailReqRN Rð t UCN_DBMailItemListR Rr t MailIDR¤ R Rq RÙ R
|
R& RV R t tagDBMailDetailViewRñ t dgMailDetailR@ t MailDetailDataR t MailDetailDataLent MailItemDatat MailItemDataLenRÝ RÞ R RR t ERROR_NO_98RT RU RO (
|
RY RX R( RW R© t dbMailItemListR§ t
|
dbMailListRH RX ( ( 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 ExistTimeR1 R t
|
SenderNamet Titlet
|
LetterTypet TitleUseSysMessageR s$ OnGetPlayerMail throw a exception
|
%s($ R R RN Rð R t tagDBGetPlayerMailRñ t
|
dgMailListR@ R R¥ RL t MailExistTimet tagDBMailInfoR R1 R R< R= R> R; R? t MailRS R t MailCountRÝ RÞ R RR t ERROR_NO_99RT RU R
|
RV RO (
|
RY RX R( RW RH R© R[ Rq t mainInfoRX ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyR ì s0
|
* " c C s t } t j } yt j } | j | j | j | _ | j | _ xÕt r#t j } d | j
|
| j k r¢ t j d t j d } t j | Pn | t } | j i t | j d 6d d 6 } | j d k rü t j d | j Pn | t } | j i | j d 6 j d k rTt j d t j d } t j | Pn t j }
|
| j |
|
_ | d d
|
|
|
_ | j |
|
_ | j |
|
_ | j |
|
_ | j |
|
_ | j |
|
_ | j |
|
_ | j |
|
_ | j! |
|
_! t" |
|
j! |
|
_# | j$ |
|
_$ | j% |
|
_% |
|
j& | r t } n PqO WWn6 t j d t j' d t( j) } t j | n Xt* j+ | _, | j- | | j. | S( NiÿÿÿÿR s+ tagDBMailList_SaveSysMail lack of pack dataR¢ i R¬ s" not exist player role , accid = %sR1 s+ OnAddPlayerMailByAccID: exist a same mailidRL s+ OnAddPlayerMailByAccID throw a exception
|
\s(/ RV R R¤ RN Rð RQ R RO R t tagDBMailList_SaveSysMailRû R RR t ERROR_NO_100R
|
R¤ R¥ R R¢ R¦ R4 R R1 t ERROR_NO_101Rq t SenderIDR R R< R= t MoneyR> R; t ContentR t
|
ContentLenR? t ContentUseSysMessageR¢ t ERROR_NO_102RT RU Rñ t dgAddPlayerMailByAccIDR@ RÝ RÞ ( RY RX R( R! RH RW t curMailRX R© R[ Rq ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyR s\
|
&
|
% " c C s5 y÷ t j } | j | j | t } t j } | j | _ | j | s t j
|
d t j d t | j } t j | t S| t } t j } | j | _ | j | sö t j
|
d t j d t | j } t j | t SWn7 t j
|
d t j d t j } t j | t SXt S( NR s DeleteMail fail:data = %ss! OnDeleteMail throw a exception
|
%s( R t tagDBDeleteMailRN Rð R R Rq R1 R R RR t ERROR_NO_103Râ R
|
RV R0 Rr t ERROR_NO_104t ERROR_NO_105RT RU RO ( RY RX R( RW R© Rq RX ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyR A 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 tagDBUpdateMailRN Rð R R Rq R1 RÙ R R R R Rn RF R RR t ERROR_NO_106R
|
RV t UpdateMailTypeR t UpdateLetterTypeR> t GetAllMoneyRL t
|
ReturnMailRK R R; R¾ Râ t ERROR_NO_107t
|
GetAllItemR0 R t ERROR_NO_108t ERROR_NO_109RT RU RO ( RY RX R( RW R© Rq RX ( ( 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¬ RL R s $neR i R s' OnQueryCanSendMail throw a exception
|
%s( R RÃ RN Rð R RÄ Rñ t dgQueryCanSendMailR} RÅ R RÇ R¤ R¥ R R¦ RL RA R R R RÝ RÞ R RR t ERROR_NO_110RT RU R
|
RV RO ( RY RX R( RW RH R© R[ R¦ RX ( ( 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 dgAccIDSendPrizeR@ RO R R¯ RN Rð t UCN_AccIDSendPrizeR\ RQ R R© RV R R] R^ R$ R_ R R RR t ERROR_NO_111R
|
R¥ R¿ R¦ t ItemIDRW RÛ t ERROR_NO_112t RemainItemCountt ERROR_NO_113RT RU RÝ RÞ ( RY RX R( RH Rz RW R© Rh RX R[ Rq Re ( ( 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 Rd g @@s4 OnCheckItemPrize db process time = %s, PrizeCnt = %ss sendString process time = %sR s% OnCheckItemPrize throw a exception
|
%s( R R¯ RN Rð t timeitt default_timerRj R¥ R R© R¦ R$ t ProfileThresholdR
|
R& R R³ Rñ t dgCheckItemPrizeResultR@ Rµ RÝ RÞ R RR t ERROR_NO_114RT RU RV RO ( RY RX R( RW Rp t startTickR© t PrizeCntt processTimeRH RX ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyR ô s.
|
, " c C sv y8t j } | j | j | t } t j } | j | _ t j
|
t j } | j | sÀ d | _ | | _ | j | sÀ | j t j | t j d | j | j f t Sn | j d 7_ | | _ | j | s| j t j | t j d | j | j f t S| j t j | | j Wn7 t j d t j d t j } t j | t SXt S( Ni s %s Update Error !doc.LogNum = %di R s# OnCheckLoadAcc throw a exception
|
%s( R R¯ RN Rð Rí R Rî R© Rï R RQ RN Rð RO R¥ R® R Rñ R3 R
|
R4 RV RP R» R~ t dgPlayerAccLoadR RR t ERROR_NO_115RT RU RO ( RY RX R( RW R© Rq t strNowRX ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyR s4
|
" c C s, yît j } | j | j t j } | j | j t j d | j | j | j
|
f | t } t j } t j d | _ | j | _ | j | _ | j
|
| _ t d | _ d | _ d | _ t | _ | j | _ t j } | j | st j d | j | j | j | j
|
f | j | _ | j j | _ | j | _ | j
|
| _ d | _ | j! | t" t# j$ | j% t& 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¤ RN Rð t tagIRAddItemRQ R
|
R& R© Rl t ItemCntRj R t tagAccIDSendPrizeR t GetTransactionIDStrRe R¢ Rf Rg RQ Rc t PrizeReasonRd t SendPrizeTimeRÛ R t tagIAddItemResultR¢ t Lengtht AccLenRW RA RÝ R. Rñ t dgAddAccItemOKRÞ RV R RR t ERROR_NO_116RT RU RO ( RY RX R( RW t recvDataR© Rq RH RX ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyR 8 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¤ RN Rð R t tagDSAccount_UpdateTelLockStateRû RQ Rí Rî R¢ Rï Rð t TelLockStateRQ R RR t ERROR_NO_117R
|
RV t ERROR_NO_118RT RU RO ( RY RX R( RW R R© Rq Rz RX ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyR u 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¤ RN Rð R t tagDSAccount_UpdateAdultRû RQ Rí Rî R¢ Rï Rð R9 RQ R RR t ERROR_NO_121R
|
RV t ERROR_NO_122RT RU RO ( RY RX R( RW R R© Rq Rz RX ( ( 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¤ RN Rð RÌ R R Rû RQ R R$ t tagExpiation_ExpiationIndex_FEEDt tagExpiation_ExpiationIndex_STEPRÑ R¢ t ADOResultRñ t dgAddExpiationOKR@ R R RÝ RÞ R RR t ERROR_NO_123RT RU R
|
RV RO ( RY RX R( RW R© Rq RH RX ( ( 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¤ RN Rð RÏ R R Rû RQ R R$ t# tagPetExpiation_ExpiationIndex_FEEDt# tagPetExpiation_ExpiationIndex_STEPRÑ R¢ R Rñ t dgAddPetExpiationOKR@ R R RÝ RÞ R RR t ERROR_NO_124RT RU R
|
RV RO ( RY RX R( RW R© Rq RH RX ( ( 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¤ RN Rð R t tagDBPlayer_DeleteRoleUpdateRoleRû RQ R Rñ t dgServerMergeDeleteRoleR RR t ERROR_NO_125R
|
RV RO R¤ R« t DeletePlayerIDRL Rð R¬ R» t UpdatePlayerIDRÓ RÔ RÕ RÖ t WarehouseGoldt WarehouseSilverR R] R^ R$ R_ t ERROR_NO_126R~ t ERROR_NO_127RT RU ( RY RX R( RW R RX Rh R© Rq t Rett updatedoc( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyR! ý sV
|
|
+ " c
|
C st y6t j } | j | j t j } | j | j d } xØ t r yO | t } t j
|
} | j | _ | j | } | j | _ | j | PWqG t j j k
|
rt j | k rÑ | d 7} qG n t j d t j d | j | f } t j | | j t j | t SXqG W| j t j | d Wn7 t j d t j d t j } t j | t SXt S( Ni i R sD OnServerMergeUpdateAccState!Update failed!PlayerID = %s, trycnt = %dR s0 OnServerMergeUpdateAccState throw a exception
|
%s( R R¤ RN Rð R t tagDBPlayer_ChangeAccStateRû RQ RO R¤ R« RL Rð Rw R» R R] R^ R$ R_ R RR t ERROR_NO_128R
|
R Rñ t dgServerMergeUpdateAccStateRV R~ t ERROR_NO_129RT RU (
|
RY RX R( RW R Rh R© Rq R RX ( ( 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¤ RN Rð R t tagDBPlayer_ChangeNameRû RQ R
|
R4 RL R· RO R¤ R¥ R R¦ R Rñ t dgServerMergeChangeNameR@ R R RÝ RÞ R R] R^ R$ R_ R RR t ERROR_NO_131RV t ERROR_NO_132RT RU ( RY RX R( RW R Rh R© RH RX ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyR# e 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¤ RN Rð R Rª RQ R R$ t tagDBImpeach_ImpeachIndex_FEEDt tagDBImpeach_ImpeachIndex_STEPR« t UCN_DBImpeachR¢ R RR t ERROR_NO_133R
|
RV t ERROR_NO_134RT RU RO ( RY RX R( RW Rq R© RX ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyR$ · s$
|
" c * C s t j d | t j } | | _ d | _ | t } t } t } | j | i t
|
| j d 6| j d 6 } | t k s¤ t j d t | j f d Si | j d 6} | t } | j | | t j t } t j | d }
|
| t } | j | | t j } t j | d } | t } | j | | t j } t j | d } | t } | j | | t j } t j | d } | t } | j | | t j } t j | d } | t } | j | | t j } t j | d } | t } | j | | t j } t j | d } | t } | j | | t j } t j | d } | t! } | j | | t j" } t j | d } | t# } | j | | t j$ } t j | d } | t% } | j | | t j& } t j | d } | t' } | j | | t j( } t j | d } | t) } | j | | t j* }! t j |! d }" t j+ }# | j, |# _ | t- } |# j. | }$ t j |$ d }% t j/ d |% d | j0 | | | | | | | | |$ | | | | |! }& t1 j2 j3 t4 j5 d }' t1 j2 j6 |' s7t1 j7 |' n t8 t1 j2 j3 |' d | d
|
}( d d l9 }) |( j: |& |( j; |( j< d S( Ns$ DumpSinglePlayerDataByAcc accid = %si R¢ R¬ s= DumpSinglePlayerDataByAcc Exception accid = %s,playerID = %sRL s gmIP cnt = %st DumpPlayerDatas %s.pdsavet wbiÿÿÿÿ(= R
|
R4 R R« R¢ R¬ R¤ R R R R RÜ RL R R R RO R R5 R R R R R R R R R R R R R R R R R R R R R R R R¡ R¢ Ri R£ R¤ R Rð R) R* R+ R R R t mkdirR t structt writet flushR8 (* RY RX Rú R¯ R\ Rå Ry R¥ R¦ R§ R÷ R¨ Rù R© Rú Rª Rû R« Rü R¬ Rý R Rþ R® Rÿ R¯ R R° R R± R R² R R³ R R´ Rµ R7 RÃ t DumpDirR" R´ ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyt DumpSinglePlayerDataByAccÒ s
|
,
|
|
|
|
|
|
|
|
|
|
|
|
|
|
D"
|
c C s t j j t j d } t j j | sD t j | t d f St j j | d | } d } y) t | d } | j } | j
|
Wn t d f SXt j } d } | j | | t | } d | k rà t d f S| | 7} t j d | j | j d k rt d f S| j j | _ | t }
|
| j |
|
sOt | j f S| | j | j | t t j | | t 7} | | j | j | t t j | | 7} | | j | j | t t j | | 7} | | j | j | t t j | | 7} | | j | j | t t j! | | 7} | | j | j | t" t j# | | 7} | | j | j | t$ t j% | | 7} | j& | j | j | | | | j | j | t' t j( | | 7} t) j* | | \ } } t j+ } x3 t, | D]% } | | j | | t | 7} qèW| | j | j | t- t j. | | 7} | | j | j | t/ t j0 | | 7} | | j | j | t1 t j2 | | 7} | | j | j | t3 t j4 | | 7} | | j | j | t5 t j6 | | 7} | t | k söt7 t | j f S( NR± i s %s.pdsaveR R iÿÿÿÿs$ Saving player data,playerID = %s....(8 R) R* R+ R R R R³ RV R R( R8 R R« Rû R R
|
R4 RL R¢ Ri R¤ RQ RI R R RO R R R R R R R R R R R R R4 R R R R5 R¢ RR R R R R R R R R R R¡ R6 ( RY RX Rú R· t FileDirRü R" Rý R) Rþ R\ R7 R8 R9 ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyt SaveSinglePlayerDataFromDumpFile? sZ
|
|
|
|
|
,)))))) ) #)))))(x Ra t
|
__module__Rv R R R R R R¡ R R° RV R¶ R¹ Rº R½ R, R7 R; R= RI RL Rô Rö R÷ Rø R{ Rx Rû R Rú Rù Rü R R% R R R R R R R4 RI R3 R2 Rt Rq Ro R R R R R R R R R Rõ R R R RÙ RÞ RÚ Rç RM Ræ R R Rþ R~ Rx R RÝ R2 Rý R R¢ Rl Ro Rm R R R R R R R R R R R
|
R R R R 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.pyRt é sò l
|
|
ÿ / & @ $ ; 2 : +
|
- L o p ^ K , 0
|
\ D % ÿ L ÿ Ì M ! ÿ L ) ÿ + : ! ' B
|
Ï + " ! " 8 5 ! @ % = & # C % R m(Q R) R RQ RÀ Rá Rk RE R R
t DBCommon.CommonDefineRñ t MangoDBCommonR R R R R R t ServerClientShareDefineR' Rª RÆ t
|
__import__R$ t ctypesR RT Rb t Collections.CollectionDefinet GMToolLogicProcessR t CommonR R
|
R R6 R R³ RA t jsonRa R t syst hashlibt CollectionsR R RO t DBCommonR R R R t ProtocolR R R R R Rµ R Ru Ry Re Rk Rl Rj R R R R t MergeRegPInfoIndex_GroupIDRH t threadt allocate_lockRM R` R] Rc Rs Rt ( ( ( sy D:\SG_ServerCode\ServerPython\ZoneServerGroup\map1_8G\MapServer\MapServerData\Script\PyMongoDB\LogicProcess\UserCtrlDB.pyt <module> sh
|
|
.
|
|
"( , & ,
|
