ó
|
}j\c @ sÎ 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 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 e d \ Z Z Z Z d Z d Z d Z d Z e d \ Z Z e d \ Z Z Z d Z d Z! d d d e j" d d
|
Z# d Z$ g d d d d d Z% d d d e j" d d Z& e j" d Z' d Z( d Z) d d d Z+ d Z, d Z- d d d d d d Z. d d d d Z/ d d d e j" d d Z0 d Z1 i d d d Z2 d Z3 d Z4 d Z5 d Z6 d Z7 d Z8 d Z9 e: d! Z; d" Z< d# Z= d$ Z> d% Z? d& Z@ d' ZA d( ZB d) ZC d S(* iÿÿÿÿNi i i i i t CompensationRequestStatec C sT t j } | d | _ | d | _ | j d d | _ | j d d | _ | S( Nt ItemIDt Countt IsBindi t UserDatat ( t IPY_GameServert IpyCompensationItemR R t getR R ( t curItemDictt curItemData( ( s .\\PlayerCompensation.pyt MakeCompensationItemJ s R c
|
C sP t t j | }
|
|
|
j d d }
|
t | | |
|
| | | | | | d | S( Ns .i t detail( t strt GameWorldt GetDatetimeByDiffDayst splitt SendPersonalItemMail( t titlet contentt getDayst playerIDListt addItemListt goldt goldPapert silvert
|
sourceTypeR t limitTime( ( s .\\PlayerCompensation.pyt SendPersonalItemMailExW s c C sª | \ } } } } } } } } t | } t | }
|
t | } t | } t | } t | } t | } d } d } t t j | } | j d d } xý t | D]ï \ } } |
|
| k rÕ | | n g } | | k rñ | | n g } | | k r | | n d } | | k r)| | n d } | | k rE| | n d } | | k ra| | n d } d | t | f } t | | | | | | | | d | q³ Wd S( NR i s .i s! <MailTemplate>%s</MailTemplate>%sR ( t lenR R R R t enumerateR ( t batchMailInfoListt mailTypeKeyt batchPlayerIDListt batchAddItemListt batchParamListt batchGoldt batchGoldPapert batchSilvert batchDetailt lenPlayerIDt lenItemt lenParamt lenGoldt lenGoldPapert lenSilvert lenDetailR R R t iR R t paramListR R R R R ( ( s .\\PlayerCompensation.pyt SendPersonalItemMailBatch^ s, )c
|
C s | s t j } n t j d | | | | | | | f d } d | t j | d t f } t | | d | | | | | d | S( Nsa SendMailByKey %s, playerIDList=%s, addItemList=%s, paramList=%s, gold=%s, goldPaper=%s, silver=%sR s! <MailTemplate>%s</MailTemplate>%st ensure_asciii R ( t ShareDefinet DefaultLackSpaceMailTypeR t DebugLogt jsont dumpst FalseR (
|
R R R R0 R R R R R R ( ( s .\\PlayerCompensation.pyt SendMailByKey{ s c
|
C s | s
|
d St j }
|
|
|
s) |
|
| k r> t j d | d Sg } x | D] } t | t rs | j | qK n t | d k rK | \ } } } n qK i } | | d <| | d <| | d <| j | qK Wt j d } t d t
|
t j t | t | } xp t | D]b } | | } t t j } t | | | | | !| | d t j | | f | | | | |
|
qW| S(
|
NR sC ¹¦ÄÜ·¢·ÅÎïÆ·²¹³¥/½±ÀøÓʼþ£¬Áìȡʱ¼äÒѳ¬Ê±£¬Ä¬Èϲ»Ìí¼Ó£¡LimitTime=%si R R R t MailMaxItemCnti s %s<$_$>%s<$_$>%s( R t GetCurrentDataTimeStrR5 t
|
isinstancet dictt appendR t IpyGameDataPYt
|
GetFuncCfgt maxt intt matht ceilt floatt xrangeR t uuidt uuid1t AddPersonalItemt ChConfigt Def_Mail_SenderSys( R R R R R R R R R R t curServerTimet addItemDictListt itemInfot itemIDt itemCntt isBindt addItemDictt perMailItemCntt mailCntR/ t
|
startIndext GUID( ( s .\\PlayerCompensation.pyR s8
|
|
|
.
|
c C sU t j r d St t j } t | | t j | d t j | | f | d S( Ns %s<$_$>%s<$_$>%s( R t IsCrossServerR RG RH t PyAddPersonalCompensationR; RJ RK ( t PlayerIDR R R R RV ( ( s .\\PlayerCompensation.pyt SendPersonalAsTextMail· s c C s | d | d | S( Ni@B i ( ( t
|
checkStatet limitLVTypet limitLV( ( s .\\PlayerCompensation.pyt GetEntireCompensationInfo¿ s c C s3 | d } | d } | | d d } | | | f S( Ni i@B ( ( t mailInfoR] R[ R\ ( ( s .\\PlayerCompensation.pyt ParseEntireCompensationInfoÁ s
|
|
i
|
c C s t j } g } | rY t | | j | d d | | | } | rU | j | n | S| rl d | } n | r d | } n | j }
|
xp t |
|
D]b } | j | } t | | | | | | | } | s× q n | j | t | | k r Pq q W| S( s ²¹³¥Óʼþ²éѯ
|
R s %s 00:00:00s %s 23:59:59( R t GetCompensationMgrt __GetQueryCompensationInfoDictt FindEntireCompensationR> t GetEntireCompensationCountRF t AtEntireCompensationR ( t fromDatet toDatet guidt searchTitlet searchContentt searchStatet maxCountt compensationMgrt retListt infoDictt entireCntR/ t compensation( ( s .\\PlayerCompensation.pyt QueryCompensationInfoÇ s* ' c C sà | s | j r d S| r. | j | k r. d S| rG | j | k rG d S| j j d } t | d k ro d S| \ } } }
|
| r | | k r d S| rª | |
|
k rª d St | j \ } } } | d k rÞ | | k rÞ d S| j } g } | j | } xc t | D]U } t
|
j j | | } | j } | s<q n | j | | j | j | j g q Wi | d 6| d 6| d 6| d 6| j d 6| j d 6| j d 6| j d
|
6| d 6| d 6|
|
d 6| j d 6| j d 6| d 6} | S( Ns <$_$>i RV t
|
CheckStatet LimitLVTypet LimitLVt Goldt GoldPapert Silvert PlayerJobt Sendert Titlet Contentt
|
CreateTimet LimitTimet ItemList( RV R} t TextR R R` t PlayerLVt Nonet FindItemCountRF R Ra t
|
FindItemAtR R> R R R Rv Rw Rx Ry R~ ( Rm Rq Rf Rg Ri Rj Rk t contentListt senderR R R[ R\ R] RV t itemListt curGUIDItemCountR/ t curItemRO t compensationDict( ( s .\\PlayerCompensation.pyRb æ s> & c C sf g } g } t j } x8| D]0} | j | } | s | j | k rP q n | d k r§ | j | | j | | j | t j d | t j | d n | d k r | j
|
} t | \ } } }
|
t t | |
|
} | j | | t j d | | | | f | t k rB| j | t j | d qBn q | j | q Wt j } x t | j D]ì } | j | } | d k sr| j srt j | rµqrn g } x | D] } t | | t \ } } | t k ròqÂn | j | j | j | j f \ } } } } | j } | j | | | | | | f qÂW| rrt | | qrqrW| S( sh È«·þÓʼþ²Ù×÷¹ÜÀí
|
@param operGUIDList: ´ý²Ù×÷µÄÓʼþGUIDÁбí
|
@param operation: 1-ͨ¹ý£»2-ɾ³ý
|
i s ɾ³ýÈ«·þÓʼþ: GUID=%st Deletei sB È«·þÓʼþÉóºËͨ¹ý: GUID=%s,mailInfo=%s,checkState=%s,updMailInfo=%st CheckOKN(! R Ra Rc RV t DeleteEntireCompensationt DeleteCompensationItemt DeleteRecByGUIDt Logt DataRecordPackt DR_EntireCompensationR R` R^ t CheckState_OKt SetEntireCompensationPlayerLVR> t GetPlayerManagerRF t GetActivePlayerCountt GetActivePlayerAtR t GetInitOKt PlayerControlt GetIsTJGt CheckRequestCompensationR8 t Unknow_CompensationTypeR Rv Rw Rx R} t SyncQueryCompensationResult( t operGUIDListt operationt
|
okGUIDListt successGUIDListRm RV Rq R_ R[ R\ R] t updMailInfot playerManagerR/ t playert
|
notifyListt compensationTypet curEntireRequireR R R R t
|
createTime( ( s .\\PlayerCompensation.pyt EntireCompensationOper sR ( * #c C sQ t j r d Sx0 | D]( } t | } t j j | | q Wt j } t j j | | | | | | | | | |
|
|
t | \ } } } i | d 6| d 6| d 6| d 6| d 6| d 6| d 6| d 6| d
|
6| d 6| d 6} | t k r÷ d n d } t j
|
| | | t | | | | d | | t j d } t j } xt | j D]ï } | j | } | d k sZ| j sZt j | rqZn | t k rÓt j | j } | | k rÓqZqÓn t | | t \ } } | t k rýqZn | j | j | j | j f \ } } } } t | | | | | | | f g qZWd S( sW
|
@param mailInfo: GetEntireCompensationInfo µÄ·µ»ØÖµ, Ä¿Ç°ÔÝ´æ×ֶΠPlayerLV ÖÐ
|
NR~ Ru Rt Rs Ry R Rv Rw Rx R t Detailt Addt
|
AddToCheckt TestAccID(! R RW R Ra t AddCompensationItemR; t AddEntireCompensationItemR` R R R t __WriteSendMailOKEventR t ReadChConfigt GetEvalChConfigR RF R R R R R t CheckState_Not GetPlatformAccIDt GetAccIDR R8 R R Rv Rw Rx R ( RV RM R~ R_ Ry R R R R R t serverIDRR R
|
R¨ R[ R\ R] t addDictt eventNamet testAccIDListR£ R/ R¤ t playerAccIDR¦ R§ ( ( s .\\PlayerCompensation.pyt AddEntireItemL s< -& ( *&c
|
C s1 t j j | } t j j | | }
|
i t j d t j 6t j d t j 6} |
|
| | d } | d k rg } xH t
|
| D]: } t j j | | | } | s· q n | j | q Wx7 | D], } t | | | rÏ t | | d qÏ qÏ Wn t j j | | | | | | | | | d S( Nt MailDefaultCountt MailMarketCounti i ( R R t FindPlayerByIDRa t" GetPersonalCompensationCountByTypeR? R@ RJ t Mail_Type_Defaultt Mail_Type_MarketRF t AtGUIDInPersonalTypesByTypeR> t ClearPersonalCompensationt NotifyCompensationResultt AddPersonalCompensation( RV RY R} R~ R R R R R t curPlayert cntt tmpDictt delcntt delGUIDsR/ t tmpGuidRh ( ( s .\\PlayerCompensation.pyRX } s& c
|
C sX t j r d St j d | | f x0 | D]( }
|
t |
|
} t j j | | q. Wi } t j } x | D] } t | | | | | | | | | t j j | } | rs t
|
| | | | | | | f g | j | j g | | j <qs qs Wi | d 6| d 6| d 6| d 6| d 6t | d 6| d 6} t j | | | | d S( Ns5 Compensation### AddPersonalItem GUID:%s ItemDict:
|
%s R~ R Rv Rw Rx t ItemListLenRª ( R RW R5 R Ra R® R; RX R R¾ R t GetNamet GetLVRµ R R t DR_AddPersonalCompensation( RV RM t PlayerIDListR~ R R R R R R RR R
|
t onlinePlayerInfoR¨ RY RÆ R· ( ( s .\\PlayerCompensation.pyRI ¤ s& ")&c C s | s
|
d Si } | \ } } } } t j d | t | f x* | D]" } | d | d g | | d <qF Wt | | | | | d S( Ns ÓʼþÀëÏßÍæ¼ÒDBÐÅÏ¢: GUID=%s, %st
|
PlayerNamet LVt AccID( R R R R° ( t resultSetListt extendValueListt playerInfoDictRV RM R~ R t
|
resultDict( ( s .\\PlayerCompensation.pyt FindDBResult_SendMailÍ s c C s d S( N( ( RV RM R~ R R× t playerLVt playerJob( ( s .\\PlayerCompensation.pyR° Û s 5c C s# t j j | } t | d S( N( R R t GetPlayerByIndext NotifyPlayerCompensation( t indext
|
clientDatat tickRÆ ( ( s .\\PlayerCompensation.pyt OnQueryPlayerCompensation s c C s t | } t | | d S( N( t SeekPlayerCompensationR ( RÆ R¥ ( ( s .\\PlayerCompensation.pyRÝ s c C sa t j j | | t j j | | t j j | d k r] t j j | n d S( Ni ( R Ra t DeletePersonalCompensationt DeletePlayerCompensationRect GetPersonalCountByGUIDR ( t curPlayerIDt curGUID( ( s .\\PlayerCompensation.pyRÃ " s
|
c C s+ | d | } t j j | | | d S( Ni
|
( R Ra t AddPlayerRec( Ræ RV t
|
prizeStatet readStatet state( ( s .\\PlayerCompensation.pyt SetPrizeState, s c C sÊ | j } t j j } g } t j j | } x] t | D]O } t j j | | } | j | j | j
|
| j | j | j | j f qC Wt j j } | j } | j } t j | j t j d k }
|
xßt | d d d D]Ç} t j j | } t | j \ } } } | t k rI|
|
sIqû qIn t j j | | j } | d } | d } | t t f k rqû n t j j | j t j } | | k rß| t! k rßt" | | j t | qû n | | k r| t# k rû t" | | j t | qû qû n | j$ d k rl| j } | j$ t% d | @d k rlt" | | j t | qû qln t& | k rt" | | j t& | n | j | j | j
|
| j | j | j | j f qû W| S( NR i iÿÿÿÿi
|
i i i ( iÿÿÿÿi (' t GetIDt datetimet todayR Ra t GetPersonalCompensationCountRF t PersonalCompensationAtR> RV R R} Rv Rw Rx Rd t GetJobRÎ R´ Rµ R± R² Re R` R R³ t FindPlayerRecStatet Disable_Statet Yet_Statet strptimeR~ RJ t TYPE_Time_Formatt Unknown_StateRì t LimitLVType_NotRy t powt Enable_State( RÆ Ræ t curTimet allListt curPersonalCountR/ t curIpyPersonalDatat curEntireCountt curJobt curLVt isTestAccIDt
|
curRequireR[ R\ R] t statesRê t curStateR ( ( s .\\PlayerCompensation.pyRâ 3 sR $
|
|
c C s t j } | j xZ| D]R\ } } } } } } t j j | } t j }
|
| |
|
_ | |
|
_ | |
|
_ t
|
| |
|
_ | |
|
_ | |
|
_ | |
|
_ t j j | j | d |
|
_ x t | D]| } t j j | | } t j } | j | _ | j | _ | j | _ | j | _ t
|
| j | _ |
|
j j | qÍ Wt
|
|
|
j |
|
_ | j j |
|
q Wt
|
| j | _ t j | | d S( Ni
|
( t ChPyNetSendPackt tagGCQueryCompensationResultt ClearR Ra R t tagGCCompensationPackRV R} R R t TextLenRv Rw Rx Ró t GetPlayerIDt IsReadRF R t tagGCCompensationItemR R R R t UserDataLent ItemsR> t PackListt NetPackCommont SendFakePack( RÆ R¥ t sendPackRV R R} R R R R t subPackRÞ R t subPackItem( ( s .\\PlayerCompensation.pyR u s6
|
% c
|
C s$ t j d | j } t j j | } | s5 d S| j t rU t j d d S| j t d | j } t j d | | f t | | \ } } | t
|
k rÇ | j t d t j d d S| j | j | j | j f \ } }
|
} } t | | | | | | |
|
| | t j d d S( Ns* Compensation### OnMGRequestCompensation ins Compensation### already requesti s= Compensation### OnMGRequestCompensation myPlayerID %s GUID %si s0 Compensation### OnMGRequestCompensation no founds+ Compensation### OnMGRequestCompensation out( R R5 RY R R¾ t GetDictByKeyt Def_RequestStatet SetDictRV R R R Rv Rw Rx t SendGMRequestCompensationResult( t
|
routeIndext mapIDt curPackDataRà t
|
myPlayerIDRÆ RV R¦ R§ R R R R ( ( s .\\PlayerCompensation.pyt OnMGRequestCompensation s& *
|
"c C s | j } | rF t j j | | } | j | k rF t | f Sn t j j | | } | d } | d } | t t f k r t d f St j j | } | j | k rÒ t j j | | t d f St | j \ } }
|
} | t k r-t j | j t j d k } | s-t d f Sn t j j | j t j } t j j } | | k rt | k rt | | t | t d f St | k r¢t | f S| j } | | k ræ|
|
t k rÜt | | t | n t d f S| j! } | j" d k r=| j" t# d | @d k r=t | | t | t d f Sn | j$ r{| j$ t j% | k r{t | | t | t d f St | | t | t | f S( Ni
|
R iÿÿÿÿi i i ( iÿÿÿÿi (& Rí R Ra t FindPersonalCompensationRY t Personal_CompensationTypeRó Rô Rõ R R Rc RV Rä R` R R³ R´ Rµ R± R² Rî Rö R~ RJ R÷ Rï Rø Rì Rû t Entire_CompensationTypeRÎ Rù Rò Ry Rú t ServerIDt GetPlayerServerID( RÆ RV t isPersonnalRæ t curPersonalCompensationR Rê R R§ R[ R\ R] R R Rü R R ( ( s .\\PlayerCompensation.pyR » sR
|
|
|
|
$
|
|
|
!
|
c C s+ t j } | j | _ | | _ | | _ | | _ t | | _ | | _ | | _
|
| | _ t j j | }
|
x t |
|
D]| } t j j | | } t j } | j | _ | j | _ | j | _ | j | _ t | j | _ | j j | q Wt | j | _ t j | | | d S( N( t ChGameToMapPyPackt tagGMRequestCompensationResultRí RY t CompensationTypeRV R R R Rv Rw Rx R Ra R RF R t tagGMCompensationItemR R R R R R R> R t SendPyPackToMapServer( R R RÆ RV R¦ R R R R R R R/ R R ( ( s .\\PlayerCompensation.pyR s, c C sj | j } t j j | } | s( d S| j } | j } | j t d | j rf t | | | n d S( Ni (
|
RY R R R¾ RV R) R R t Resultt GiveCompensationSuccess( R R R Rà R RÆ RV R) ( ( s .\\PlayerCompensation.pyt OnMGGiveCompensationResult s c C sz | j } t | | d t j | | | t k rY t j j | | d t d S| t k rv t
|
| | d Sd S( Ni i
|
( Rí RÄ R t DR_GiveCompensationSuccessR" R Ra Rè Rõ R! RÃ ( RÆ RV R) Ræ ( ( s .\\PlayerCompensation.pyR- 1 s c C së t j j } g } t j j } xs t | D]e } t j j | } t j j | j t j
|
t j d d } | | k r4 | j | j q4 q4 WxG | D]? } t j j | t j j | t j j | q¤ Wd S( Nt daysi ( Rî Rï R Ra Rd RF Re Rö R~ RJ R÷ t timedeltaR> RV R R R ( Rü t needClearGUIDListRp R/ R§ R RV ( ( s .\\PlayerCompensation.pyt ClearUpEntireCompensationE s + c C s t d S( N( R3 ( ( ( s .\\PlayerCompensation.pyt ClearUpTimeOutCompensation_ s c C s× t j j | } | j } | j } t j j | | } | j | k r| t j j | } | j | k r| d Sn t j j | | } | d t
|
k r¨ d St
|
d | d } t j j | | | d S( Ni
|
( R R RÜ RV Rí Ra R RY Rc Ró t Read_State_YesRè ( RÞ Rß Rà RÆ RV Ræ R& R§ R ( ( s .\\PlayerCompensation.pyt OnReadCompensationo s c C s t j j | } | j } | j } t j j | | } | j | k rr t | | t | | d d St j j
|
| } | j | k rª t | | d d St j j
|
| } | j | k r t | | t t j j | | d t | | d d St | | d d S( Ni i i
|
( R R RÜ RV Rí Ra R RY RÃ RÄ Rc Rì Rô Ró ( RÞ Rß Rà RÆ RV Ræ R& R§ ( ( s .\\PlayerCompensation.pyt OnDelCompensation s$ )c C s2 t j } | | _ | | _ t j | | d S( N( R t tagGCDelCompensationResultRV R, R R ( RÆ RV t resultt
|
sendMCPack( ( s .\\PlayerCompensation.pyRÄ ¯ s (D R RJ R3 R R' R t CommFuncR R R± t PlayerDBOpert EventReportR? R Rî RG RC R6 t rangeRø Rô Rû Rõ R R³ Rù t LimitLVType_Cant Read_State_NoR5 R" R! R R R RÀ R R1 R9 R RZ R^ R` R Rr Rb R© R» RX RI RÙ R° Rá RÝ RÃ Rì Râ R R t TrueR R R. R- R3 R4 R6 R7 RÄ ( ( ( s .\\PlayerCompensation.pyt <module> sr - ) >1'( ;
|
B & F !
|
