ó
|
¡®~[c @ sk d d l Td d l m Z d d l m Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l m
|
Z
|
d d l m Z d d l Td d l m Z m Z d d l m Z d Z e d
|
d a d Z d Z d Z d Z d Z d Z d Z d d d YZ d d d YZ d Z d Z d Z! d d d Z" d Z# d S( iÿÿÿÿ( t *( t GlobalFunctions( t GMCommonN( t fix_incomingText( t DataServerPlayerData( t
|
CommFuncExt mylog( t
|
MMORPGPackc C sô t j } xá t j d | | f D]Æ \ } } } x´ | D]¬ } t j j | | } | j | d } | d t | !} | j d d k r q< n | j d } | d } | d } | d
|
k rÌ q< n | j d d } t
|
| q< Wq& Wd S( Ns %s\%st i t __init__i s .t pyct pys \( R
|
R ( R t
|
getAppPatht ost walkt patht joint replacet lent findt splitt
|
__import__( t importDirt curPatht roott dirst filest filet fileNamet curFileListt ext( ( sL .\ServerPython\db\PyMongoDataServer\GMToolLogicProcess\ProjSpecialProcess.pyt ImportCommandAll3 s )
|
|
s GMToolLogicProcess\Commandsc C s» t j d t j } | j | j | j } | j } | j } | j } | j
|
} | j } t j d | | f d } yÜ t | } | j t j d } | d k rÆ t | | t j d St | }
|
|
|
i k rõ t | | t j d St } |
|
| _ | | _ | | _ | | _ t j | | _ | | _ t j | | | j WnL t! k
|
r©t j d t" j# t j$ | t | | t j% d SXt j d d S( Ns% ProjSpecialProcess OnGMToolCommand INs GM Tool Cmd->%s,orderId->%sR s GM cmd error - > %ss' ProjSpecialProcess OnGMToolCommand Done(& R t infot RecvPackProtocolt tagGMCommandt ReadDatat getBuffert OrderLent OrderIdt CmdLent Cmdt UserDataLent UserDatat evalt getR t Def_GMKey_Typet Nonet GMCommandResultt Def_GMCmdNonet ChangeEncodIngt Def_EncodeFailt GMCmdMangert gmCmdDictt funcNamet orderIdt userDatat copyt deepcopyt packt gmCmdDictUnEncodet GetGMOrderMgrt AddCmdt GMToolCommandt BaseExceptiont tracebackt
|
format_exct PopCmdt Def_GMDBEntranceFail( R: t recvPackt orderLenR6 t cmdLent cmdt
|
uerDataLenR7 R5 R4 t cmdDictt gmCmdManger( ( sL .\ServerPython\db\PyMongoDataServer\GMToolLogicProcess\ProjSpecialProcess.pyt OnGMToolCommandP sJ c C s# t j } | j | j | S( N( t SendPackProtocolt tagGMCommandResultR# t GetBuffer( R: t sendpack( ( sL .\ServerPython\db\PyMongoDataServer\GMToolLogicProcess\ProjSpecialProcess.pyt OnGMToolCommandResult s c C sa t j d t j } | j | j | j } | j } | j } | j } t j d d S( Ns- ProjSpecialProcess OnGMToolCmdSysDBRequest INs/ ProjSpecialProcess OnGMToolCmdSysDBRequest Done(
|
R R R! t tagGMCommandDBRequestR# R$ R% R& t DataLent Data( t sysdbR: RD R% R& RR RS ( ( sL .\ServerPython\db\PyMongoDataServer\GMToolLogicProcess\ProjSpecialProcess.pyt OnGMToolCmdSysDBRequest§ s c C s t j d t j } | j | j | j } | j } | j } | j } t
|
} | j | } | j | | t j d d S( Ns- ProjSpecialProcess OnGMToolCmdLogDBRequest INs/ ProjSpecialProcess OnGMToolCmdLogDBRequest Done( R R R! RQ R# R$ R% R& RR RS R< t GetCmdt LogDBRequestResponse( t logdbR: RD R% R& RR RS t gmCmdOrderMgrt cmdManger( ( sL .\ServerPython\db\PyMongoDataServer\GMToolLogicProcess\ProjSpecialProcess.pyt OnGMToolCmdLogDBRequestÁ s c C sÁ t j d t j } | j | j | j } | j } | j } | j } t
|
} | j | } t | | \ } }
|
| t j k r | j | |
|
d S| j | | t j d d S( Ns. ProjSpecialProcess OnGMToolCmdUserDBRequest INs0 ProjSpecialProcess OnGMToolCmdUserDBRequest Done( R R R! RQ R# R$ R% R& RR RS R< RV t UpdatePackDataR t Def_ResultTypeMaxt GMCmdExecuteResultt UserDBRequestResponse( t userdbR: RD R% R& RR RS RY RZ t execTypet execInfo( ( sL .\ServerPython\db\PyMongoDataServer\GMToolLogicProcess\ProjSpecialProcess.pyt OnGMToolCmdUserDBRequestÜ s c C s^ | j d k rQ| j } | j d d } | j d } | sL t j d f Sg } | j t j d } | j t j d } x | D]} d } | t j k rÇ t j | i t
|
| d 6d d 6 } n8 | t j k rÿ t j | i t
|
| d 6d d 6 } n | d k r"t j d t | f S| t } t j } d | _ | j | i t
|
| d 6| j d 6 }
|
|
|
st j d t | f S| j | j q Wt | | j d
|
<t j } t | j | _ t | j | _ t | j | _ t | j | _ t | j | _ t | j | _ t! j" } | j# | j$ | | _% n t j& d f S( Nt GMT_AddPersonalCompensationt
|
playerListR s ,t
|
PlayerNamei t IsDeletedt AccIDs %s can not found!t PlayerIDList(' R5 R4 R, R R t Def_ParamErrt Def_GMKey_QueryTypet Def_GMKey_PlayerFindt Def_GMKey_PlayerNamet GetPlayerAccIDR t Def_GMKey_PlayerAccIDt Def_NoTagt strt UCN_DBPlayerR t tagDBPlayerRg t
|
adoLoadCExt appendt PlayerIDR; R! R" R6 R& R R% R( R' R7 R* R) R t MMORPGPackett setBufferRN R: t Def_SendToGameServer( R` RJ R4 Re t playerIDListt queryTypet
|
playerFindt playerAccIDt
|
collectiont dbPlayert loadOKt
|
updatePackt
|
mmoRPGPack( ( sL .\ServerPython\db\PyMongoDataServer\GMToolLogicProcess\ProjSpecialProcess.pyR\ ù sJ ))
|
c C sa t j d t j } | j | j | j } | j } | j } | j } t j d d S( Ns4 ProjSpecialProcess OnGMToolCmdLogicProcessRequest INs6 ProjSpecialProcess OnGMToolCmdLogicProcessRequest Done(
|
R R R! RQ R# R$ R% R& RR RS ( R: RD R% R& RR RS ( ( sL .\ServerPython\db\PyMongoDataServer\GMToolLogicProcess\ProjSpecialProcess.pyt OnGMToolCmdLogicProcessRequest9 s R3 c B s> e Z d Z d Z d Z d Z d Z d Z RS( c C s | j d S( N( t Clear( t self( ( sL .\ServerPython\db\PyMongoDataServer\GMToolLogicProcess\ProjSpecialProcess.pyR U s
|
c C s: i | _ d | _ d | _ d | _ d | _ i | _ d S( NR i ( R4 R5 R6 R. R7 R: R; ( R
( ( sL .\ServerPython\db\PyMongoDataServer\GMToolLogicProcess\ProjSpecialProcess.pyR ] s c C sc t t d | j d f } t j } d } | d k rO | | j \ } } n | j | | d S( Ns %s.%st OnExecR ( t GetExecFunct CommandsR5 R Ry R. R4 R^ ( R
t callFuncRa Rb ( ( sL .\ServerPython\db\PyMongoDataServer\GMToolLogicProcess\ProjSpecialProcess.pyR> i s c C si t t d | j d f } t j } d } | d k rU | | | | j \ } } n | j | | d S( Ns %s.%st LogDBResponseR ( R R R5 R R0 R. R4 R^ ( R
RX t dataR Ra Rb ( ( sL .\ServerPython\db\PyMongoDataServer\GMToolLogicProcess\ProjSpecialProcess.pyRW y s c C si t t d | j d f } t j } d } | d k rU | | | | j \ } } n | j | | d S( Ns %s.%st UserDBResponseR ( R R R5 R R0 R. R4 R^ ( R
R` R R Ra Rb ( ( sL .\ServerPython\db\PyMongoDataServer\GMToolLogicProcess\ProjSpecialProcess.pyR_ s c C sÜ | t j k r= t t j t | j | j t | | n | t j k rz t t j t | j | j t | | n^ | t j k r¬ t
|
| j t j | j n, t j | j t | j | j | | d S( N( R t Def_DoQueryLogDBt SendDBRequestt CommonDefinet gstGMToolCmdLogDBRequestR R6 t Def_DoQueryUserDBt gstGMToolCmdUserDBRequestRy t SendGMToolCommandToGameServerR: R< RB R/ R5 ( R
Ra Rb ( ( sL .\ServerPython\db\PyMongoDataServer\GMToolLogicProcess\ProjSpecialProcess.pyR^ s % % ( t __name__t
|
__module__R R R> RW R_ R^ ( ( ( sL .\ServerPython\db\PyMongoDataServer\GMToolLogicProcess\ProjSpecialProcess.pyR3 P s t GMCmdOrderMgrc B s, e Z d Z d Z d Z d Z RS( c C s i | _ d S( N( t _GMCmdOrderMgr__CmdOrderdict( R
( ( sL .\ServerPython\db\PyMongoDataServer\GMToolLogicProcess\ProjSpecialProcess.pyR ¶ s c C sD | | j j k r3 t j d | | j f t S| | j | <t S( Ns( orderId = %s already exists,New cmd = %d( R t keysR t warningR5 t Falset True( R
R6 RZ ( ( sL .\ServerPython\db\PyMongoDataServer\GMToolLogicProcess\ProjSpecialProcess.pyR= ¿ s
|
c C s | j j | d S( N( R t popR. ( R
R6 ( ( sL .\ServerPython\db\PyMongoDataServer\GMToolLogicProcess\ProjSpecialProcess.pyRB Ì s c C s | j j | d S( N( R R, R. ( R
R6 ( ( sL .\ServerPython\db\PyMongoDataServer\GMToolLogicProcess\ProjSpecialProcess.pyRV Ó s ( R R R R= RB RV ( ( ( sL .\ServerPython\db\PyMongoDataServer\GMToolLogicProcess\ProjSpecialProcess.pyR ± s c C s t d k r t St a t S( N( t _GMCmdOrderMgrR. R ( ( ( sL .\ServerPython\db\PyMongoDataServer\GMToolLogicProcess\ProjSpecialProcess.pyR< Ù s c C sb | j d } t | d k r% d Sx6 | D]. } t | | t k rK d St | | } q, W| S( Ns .i ( R R R. t hasattrR t getattr( t
|
curCallObjt callNamet callListt curCallName( ( sL .\ServerPython\db\PyMongoDataServer\GMToolLogicProcess\ProjSpecialProcess.pyt ParseNameGetObjç s c C s9 t | | } | d k r d St | t k r5 d S| S( N( R¤ R. t callableR ( R R¡ ( ( sL .\ServerPython\db\PyMongoDataServer\GMToolLogicProcess\ProjSpecialProcess.pyR ú s R c C sy i | t j 6| t j 6| t j 6} t j | d t } t j d | t t
|
| | t
|
| | t
|
| | d S( Nt ensure_asciis gm result:%s( R R- t Def_GMKey_ResultTypet Def_GMKey_ResultMsgt jsont dumpsR R R t SendToGMToolCommandResultR ( R6 t gmCmdt
|
resultTypet strMsgt useDatat
|
resultDcitt resultMsg( ( sL .\ServerPython\db\PyMongoDataServer\GMToolLogicProcess\ProjSpecialProcess.pyR/ s
|
+c C sÑ i } | j d d } | d k r( | Sx¢ | j D] \ } } t | t sV q5 n yG | j d d } | j d d } t d | } | j | } Wn t j d t | | SX| | | <q5 W| S( Nt codingR s
|
s `rs 's \'s u'%s's translateStr error! srcStr = %s (
|
R, t itemst
|
isinstanceRq R R+ t encodeR R t repr( R4 RI R² t keyt valuet translateStr( ( sL .\ServerPython\db\PyMongoDataServer\GMToolLogicProcess\ProjSpecialProcess.pyR1 s" ( ( ($ t GMToolPyInterfacet DBCommonR R R R8 R R@ R© t MangoDBCommonR t CollectionsR t Collections.CollectionDefinet CommonR R t ProtocolR R R. R RK RP RU R[ Rc R\ R R3 R R< R¤ R R/ R1 ( ( ( sL .\ServerPython\db\PyMongoDataServer\GMToolLogicProcess\ProjSpecialProcess.pyt <module> s:
|
|
|
F @ a(
|
