ó
|
¯6hc @ sY 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 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( ( s8 .\\ServersRoute\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( ( s8 .\\ServersRoute\GMToolLogicProcess\ProjSpecialProcess.pyt OnGMToolCommandP sJ c C s# t j } | j | j | S( N( t SendPackProtocolt tagGMCommandResultR# t GetBuffer( R: t sendpack( ( s8 .\\ServersRoute\GMToolLogicProcess\ProjSpecialProcess.pyt OnGMToolCommandResult 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! t tagGMCommandDBRequestR# R$ R% R& t DataLent DataR< t GetCmdt UpdatePackDataR t Def_ResultTypeMaxt GMCmdExecuteResultt UserDBRequestResponse( t userdbR: RD R% R& RR RS t gmCmdOrderMgrt cmdMangert execTypet execInfo( ( s8 .\\ServersRoute\GMToolLogicProcess\ProjSpecialProcess.pyt OnGMToolCmdUserDBRequest§ s c C sz | j d k rm| j } | j d d } | j d } | sL t j d f Sg } | j t j d } | t j k r t j d f S| j t j d } x | D]} d } | t j
|
k rã t j | i t | d 6d d 6 } n8 | t j k rt 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 }
|
|
|
s£t 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 GMT_CompensationQueryPersonalt
|
playerListR s ,t
|
PlayerNamei t IsDeletedt AccIDs %s can not found!t PlayerIDList( R_ R` (( R5 R4 R, R R t Def_ParamErrt Def_GMKey_QueryTypet Def_GMKey_FamilyIDt Def_SendToGameServert Def_GMKey_PlayerFindt Def_GMKey_PlayerNamet GetPlayerAccIDR t Def_GMKey_PlayerAccIDt Def_NoTagt strt UCN_DBPlayerR t tagDBPlayerRc t
|
adoLoadCExt appendt PlayerIDR; R! R" R6 R& R R% R( R' R7 R* R) R t MMORPGPackett setBufferRN R: ( RY RJ R4 Ra t playerIDListt queryTypet
|
playerFindt playerAccIDt
|
collectiont dbPlayert loadOKt
|
updatePackt
|
mmoRPGPack( ( s8 .\\ServersRoute\GMToolLogicProcess\ProjSpecialProcess.pyRU Ä sN ))
|
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 ( ( s8 .\\ServersRoute\GMToolLogicProcess\ProjSpecialProcess.pyt OnGMToolCmdLogicProcessRequest 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( ( s8 .\\ServersRoute\GMToolLogicProcess\ProjSpecialProcess.pyR $ s
|
c C s: i | _ d | _ d | _ d | _ d | _ i | _ d S( NR i ( R4 R5 R6 R. R7 R: R; ( R ( ( s8 .\\ServersRoute\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 Ri R. R4 RW ( R t callFuncR\ R] ( ( s8 .\\ServersRoute\GMToolLogicProcess\ProjSpecialProcess.pyR> 8 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 RW ( R t logdbt dataR R\ R] ( ( s8 .\\ServersRoute\GMToolLogicProcess\ProjSpecialProcess.pyt LogDBRequestResponseH 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 RW ( R RY R R R\ R] ( ( s8 .\\ServersRoute\GMToolLogicProcess\ProjSpecialProcess.pyRX X s c C s | t j k r= t t j t | j | j t | | n^ | t j k ro t | j t
|
j | j n, t
|
j | j t | j | j | | d S( N( R t Def_DoQueryUserDBt SendDBRequestt CommonDefinet gstGMToolCmdUserDBRequestR R6 Ri t SendGMToolCommandToGameServerR: R< RB R/ R5 ( R R\ R] ( ( s8 .\\ServersRoute\GMToolLogicProcess\ProjSpecialProcess.pyRW h s % ( t __name__t
|
__module__R R R> R RX RW ( ( ( s8 .\\ServersRoute\GMToolLogicProcess\ProjSpecialProcess.pyR3 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 ( ( s8 .\\ServersRoute\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 R[ ( ( s8 .\\ServersRoute\GMToolLogicProcess\ProjSpecialProcess.pyR= s
|
c C s | j j | d S( N( R t popR. ( R R6 ( ( s8 .\\ServersRoute\GMToolLogicProcess\ProjSpecialProcess.pyRB s c C s | j j | d S( N( R R, R. ( R R6 ( ( s8 .\\ServersRoute\GMToolLogicProcess\ProjSpecialProcess.pyRT s ( R R R R= RB RT ( ( ( s8 .\\ServersRoute\GMToolLogicProcess\ProjSpecialProcess.pyR { s c C s t d k r t St a t S( N( t _GMCmdOrderMgrR. R ( ( ( s8 .\\ServersRoute\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( ( s8 .\\ServersRoute\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 ( ( s8 .\\ServersRoute\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( ( s8 .\\ServersRoute\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
|
isinstanceRo R R+ t encodeR R t repr( R4 RI R¯ t keyt valuet translateStr( ( s8 .\\ServersRoute\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 R^ RU R R3 R R< R¡ R R/ R1 ( ( ( s8 .\\ServersRoute\GMToolLogicProcess\ProjSpecialProcess.pyt <module> s6
|
|
|
D D \(
|
