ó
|
I ec @ 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 Z
|
d Z d Z d Z d Z d d Z d Z d d
|
Z d Z d d Z d d Z d Z d Z d Z d d Z d Z d d Z i i d Z e d Z d Z i d Z d Z! d Z" d Z# d Z$ d Z% d Z& d! i e' d" Z( d# Z) d d$ Z* d% Z+ d d& Z, d' Z- d( Z. d S() iÿÿÿÿNs utf-8t
|
_FinalDatac C s[ t | t r | j t St | t s: t | t r> | St | t sW t | S| S( N( t
|
isinstancet unicodet encodet Encodingt intt longt str( t s( ( s# E:\www\Server\eventdata\CommFunc.pyR s
|
c C s | j t j d S( Nt gbk( t decodeR R ( R ( ( s# E:\www\Server\eventdata\CommFunc.pyt toGBK s c C s t | t j t S( N( R R R ( t pyChStr( ( s# E:\www\Server\eventdata\CommFunc.pyt
|
encodePych! s c C s' t t t j | r | n t d S( N( t reloadt syst setdefaultencodingR ( t encoding( ( s# E:\www\Server\eventdata\CommFunc.pyR % s
|
c C s i } x t j d D] } | j d } | s5 q n t | d k rQ | d n d } | j d r
| j d r
| d d !} n | | | d <q W| S( Ni t =t t [t ]iÿÿÿÿi ( R t argvt splitt lent
|
startswitht endswith( t argvDictt argvInfot kvListt value( ( s# E:\www\Server\eventdata\CommFunc.pyt
|
parse_args* s " i c C s# y t | } | SWn | SXd S( N( R ( t
|
inputValuet defValuet result( ( s# E:\www\Server\eventdata\CommFunc.pyt toInt: s
|
c C s: | s
|
t S| r | | k r t S| r6 | | k r6 t St S( N( t Falset True( t startDatet endDatet checkDate( ( s# E:\www\Server\eventdata\CommFunc.pyR( A s s %Y-%m-%dc C s& y t j j | | SWn d SXd S( N( t datetimet strptime( t timeStrt strFormat( ( s# E:\www\Server\eventdata\CommFunc.pyt strToDatetimeO s c C s2 | d k r t j j } n | t j d | S( Nt days( t NoneR) t todayt timedelta( t diffDayst dateObj( ( s# E:\www\Server\eventdata\CommFunc.pyt getDiffDaysDateU s c C s t j j S( N( R) R0 ( ( ( s# E:\www\Server\eventdata\CommFunc.pyt getCurrentTime[ s c C s) t j j } d | j | j | j f S( Ns %d-%02d-%02d( R) R0 t yeart montht day( t curTime( ( s# E:\www\Server\eventdata\CommFunc.pyt getCurrentDateStr^ s c C s7 | j d } t | d k r% d St | d d S( Nt @i i iÿÿÿÿi ( R R R ( t accIDt infoList( ( s# E:\www\Server\eventdata\CommFunc.pyt getServerIDb s id c C s8 | t | } t | j d r4 t | } n | S( Ns .0( t floatR R R ( t coinValuet ratet toValue( ( s# E:\www\Server\eventdata\CommFunc.pyt coinToYf s c C s\ | j d d | r0 t | j d d | S| j d d rX t | j d d Sd S( Nt ExChanges ExChangeScale_%st ExChangeScaleid ( t
|
has_optionR t get( t cfgt spid( ( s# E:\www\Server\eventdata\CommFunc.pyt getCoinRatem s
|
i c C s7 t | | } t | j d r3 t | } n | S( Ns .0( t roundR R R ( R t ndigits( ( s# E:\www\Server\eventdata\CommFunc.pyt roundIntu s c C s x@ | j D]2 \ } } | | k r+ q n | | | k r t Sq Wx> | j D]0 \ } } | | k rl t S| | | k rP t SqP Wt S( se æ£æ¥æµåæ°æ®æ¯å¦æ¯éè¦æ»¡è¶³å¹é
æ¡ä»¶çæ°æ®
|
@param matchSet: å¹é
è®¾å® {å¹é
key:[å¹é
å¼å表], ...}, å³åªä¼å¹é
对åºkey为æå®å¼å表çå
容
|
@param filterSet: è¿æ»¤è®¾å®, {è¿æ»¤key:[è¿æ»¤å¼å表], ...}, å³ä¼è¿æ»¤æ对åºkey为æäºå¼çå
容
|
@return: æ¯å¦æ¯éè¦ç»è®¡çæµåæ°æ®
|
( t itemsR$ R% ( t drDictt matchSett filterSett filterKeyt
|
filterListt matchKeyt matchList( ( s# E:\www\Server\eventdata\CommFunc.pyt matchDr| s c C sÞ g } | s | S| j d d j d } x¬ | D]¤ } | j rZ | j t | q2 d | k r2 | j d } | r¬ | j t t | d t | d d qÖ | j t | d t | d g q2 q2 W| S( s- 解æåææå¡å¨IDç»åä¿¡æ¯
|
æ¯ææ ¼å¼ï¼
|
èå´: æå¡å¨ID~æå¡å¨ID
|
åæï¼æå¡å¨ID
|
|
ç»åæ ¼å¼ï¼ææ¯æçæ ¼å¼ä½¿ç¨è±æéå·åå²ï¼å¦ 1~10,20,30 代表 1è³10æ å 20æ å 30æ
|
t R t ,t ~i i ( t replaceR t isdigitt appendR t extendt range( t mixServerIDInfot useAllIDListt serverIDListt splitListt idInfot rangeIDList( ( s# E:\www\Server\eventdata\CommFunc.pyt parseMixServerIDInfo s 1.c
|
C st t | } | s t SxW| D]O} t | t r | } | | k rH t Sx!| D]G } t | t rj qO n | \ } } | | k o | k n rO t SqO Wq | \ } } xÀ | D]¸ } t | t rè | | k oÜ | k n rht Sq° | \ } } | | k o | k n sd| | k o'| k n sd| | k oC| k n sd| | k o_| k n r° t Sq° Wq Wt S( s; æ£æ¥æ¯å¦æ»¡è¶³éè¦æ¥è¯¢çåºæå¤ä»½
|
@param queryServerIDList: éè¦æ¥è¯¢çç®æ æå¡å¨ç»åå表ï¼ç± parseMixServerIDInfo 解æå¾å°
|
@param checkServerInfo: éè¦æ£æ¥æ¯å¦æ»¡è¶³æ¡ä»¶çåºåIDä¿¡æ¯ä¸²ï¼å¯ç± parseMixServerIDInfo 解æçæ ¼å¼
|
@return: æ¯å¦æ»¡è¶³
|
( Re R$ R R R% (
|
t queryServerIDListt checkServerInfot checkServerIDListt checkServerIDInfot checkIDt queryServerIDInfot
|
queryIDMint
|
queryIDMaxt
|
checkIDMint
|
checkIDMax( ( s# E:\www\Server\eventdata\CommFunc.pyt checkIsBackupServerFolderª s0 88 c C s | j d d } d | d <t j d | d t j | } t j | d d } | j } | sm d GHd S| j d
|
s d | k r | GHd St j | S( Nt
|
ServerInfot EventDataBackupToolUrli t queryCenterbakt urlt datat timeoutix s> error: query backup center's eventdata no message return!<br/>s error:t Traceback(
|
RG t urllib2t Requestt urllibt urlencodet urlopent readR t jsont loads( RH t postDataRt t reqt res_datat resMsg( ( s# E:\www\Server\eventdata\CommFunc.pyt queryBackupCenterDRÍ s
|
! c C s d | GHd S( Ns error: %s( ( t errorMsg( ( s# E:\www\Server\eventdata\CommFunc.pyt queryBackupCenterErrorß s c C s! t j | d t d d GHd S( Nt ensure_asciit defaultc S s | j S( N( t __dict__( t obj( ( s# E:\www\Server\eventdata\CommFunc.pyt <lambda>æ s ( R~ t dumpsR$ ( t retData( ( s# E:\www\Server\eventdata\CommFunc.pyt queryBackupCenterOKã s c C sO t j } | j d d j d d j d d j d d } d G| GHd S( Nt <s <t >s >s s <br/>s
|
s error:<br/>:( t tracebackt
|
format_excRZ ( t error( ( s# E:\www\Server\eventdata\CommFunc.pyt printExceptionErroré s 6c O s+ t | } t | } d }
|
t j d t | t j j | j d d d } x
t j | D]t\ } } } | j
|
d } | d } t | } | r¼ |
|
s³ | |
|
k r¼ | }
|
n t | | | sÔ qf n d | k r
|
g | d D] } d | | f ^ që } n | } xÇ | D]¿ } t j j | | } t j j | sJqn | } | | | | \ } } | stqn | | j d } t | d
|
} | j } | j x' | D] } | | | | | | | q³WqWqf W| j d o| p|
|
p| |
|
k } | rd | d <n t j d | S( s 循ç¯éå游æ主ææµåä¿¡æ¯ï¼å¹¶è§£æ满足æ¶é´èå´æµå
|
@param cfg: InterfaceConfig.php é
置对象
|
@param startDate: èµ·å§æ¥æ
|
@param endDate: ç»ææ¥æ
|
@param argvDict: postå°ä¸å¿çåæ°
|
@param checkDrFileNeedParseFunc: é¢å¤æ£æ¥æµåæ件æ¯å¦éè¦è§£æçå½æ°ï¼ä¼ å
¥åæ°(æµåæ件å drFileName, *parseArgs, **kv)ï¼è¿åèªå®ä¹ä¿¡æ¯æä¾ parseLineFunc ç¨
|
@param parseLineFunc: 解ææµåæ¯è¡å
容çé»è¾å½æ°ï¼ä¼ å
¥åæ°(æµåådrName, æå±dateStr, checkDrFileNeedParseFunc è¿åçç»æä¿¡æ¯ checkNeedParseRetInfo, æµåè¡å
容line, *parseArgs, **kv)
|
@param *parseArgs: èªå®ä¹åæ°
|
|
@return: needQueryCenterbak æ¯å¦éè¦æ¥è¯¢ä¸å¿å¤ä»½æµåæ°æ®
|
s loopMainServerDR %sRq t
|
ServerPaths EventServer\EventDatas \iÿÿÿÿt
|
drNameLists %s_%s.txtt _t rt queryAllDatai Rs t EndN( R- R/ t loggingt infoR t ost patht joinRG t walkR R( t isfilet rindext opent readlinest close( RH R& R' R t checkDrFileNeedParseFunct parseLineFunct parseArgst kvt startDatetimet endDatetimet minDatetimet
|
FolderPatht parentR t fileListt
|
parentListt lastStrt fileDatetimet drNamet loopFileListt
|
drFileNamet fullPatht dateStrt isNeedt checkNeedParseRetInfot ft linest linet needQueryCenterbak( ( s# E:\www\Server\eventdata\CommFunc.pyt loopMainServerDRï sF !
|
*
|
%) c C s | j d d k S( NRs ( RG R/ ( R ( ( s# E:\www\Server\eventdata\CommFunc.pyt isQueryCenterbak. s c 0 O sÎ t j d t | | j d d } | s= t d d S| j d d } t j j | j d d | d }
|
| j d d
|
d k } t j d | | |
|
f t j j |
|
sÉ t d |
|
d St
|
| } t
|
| } t | j d d } | r| g n t | } d | } t j d | | f x
t j |
|
D]t} | t d } t
|
| } t | d | sqEn | s¶x1t j t j j |
|
| D] } | j d r¿q¤n | j | sÔq¤n | t | } t | | sùq¤n t j d t j j |
|
| | xt j t j j |
|
| | D]m\ } } } | sYq>n | j d } | d } t
|
| } t | | | sq>n d | k rÌg | d D] } d | | f ^ q} n | } xÖ | D]Î } t j j | | } t j j | s qÙn | } g }! | rE| | | | \ }" }! |" sEqÙqEn | | j d } t | d }# |# j }$ |# j x' |$ D] }% | | | |! |% | | qWqÙWq>Wq¤WqEd d l m }& xðt j t j j |
|
| D]Ð} | j d s qån | j | sqån | t | d !} t | | s=qån |& j t j j |
|
| | }' |' j }( g } d | k r¨i }) x |( d d d
D]q }* d |* k r®qn |* j d }+ |+ d } t
|
| } | sßqn t | | | s÷qn |* }, |, |) | <qW|) j }- |- j x |- D]y } |) | }, xf | d D]Z } t j j |, d | | f }. |. |( k rC| j t j j |, d | | f qCqCWq(Wn |( } x| D]ü }* d |* k rÍqµn |* j d }+ t |+ d k rôqµn |+ d } t
|
| } t | | | s"qµn |+ d } g }! | r_| | | | \ }" }! |" s_qµq_n | | j d } |' j |* }/ x- |/ j D] }% | | | |! |% | | qWqµWqåWqEWt j d t! S(! sÒ å¾ªç¯éåä¸å¿æå¡å¨å¤ä»½æµåä¿¡æ¯ï¼å¹¶è§£æ满足æ¶é´èå´ååºææ¡ä»¶çæµå
|
@note: Rarä¸ç¨
|
@param cfg: InterfaceConfig.php é
置对象
|
@param argvDict: postå°ä¸å¿çåæ°
|
@param checkDrFileNeedParseFunc: é¢å¤æ£æ¥æµåæ件æ¯å¦éè¦è§£æçå½æ°ï¼ä¼ å
¥åæ°(æµåæ件å drFileName, *parseArgs, **kv)ï¼è¿åèªå®ä¹ä¿¡æ¯æä¾ parseLineFunc ç¨
|
@param parseLineFunc: 解ææµåæ¯è¡å
容çé»è¾å½æ°ï¼ä¼ å
¥åæ°(æµåådrName, æå±dateStr, checkDrFileNeedParseFunc è¿åçç»æä¿¡æ¯ checkNeedParseRetInfo, æµåè¡å
容line, *parseArgs, **kv)
|
@param *parseArgs: 解æå½æ°æéçåæ°
|
|
@return: æ¯å¦æå
|
s loopCenterbakRarDR %sR_ R s can not found mixServerIDInfo!Nt spIDRq t EventDataBackupPatht EventDatat EventDataBackupUseRari s! isUseRar=%s,spID=%s,backupPath=%ss can not found backup path: %st OnlyServerIDi s
|
Event_%s-ss serverIDList=%s,spfileFormat=%st Event_s .rars loop %ss \iÿÿÿÿR s %s_%s.txtR R ( t rarfileiüÿÿÿt .i iþÿÿÿt loopEnd(" R R R RG R R R R t getintt existsR- R Re t listdirR R( R R Rp R R R¡ R¢ R£ R¤ R¥ t unrarRÆ t RarFilet namelistt keyst sortR\ R% (0 RH R& R' R R¦ R§ R¨ R© R_ RÀ t
|
backupPatht isUseRarRª R« RÄ Ra t spfileFormatt backupDateFilet backupDateStrt backupDatetimet backupServert
|
serverInfoR® R R¯ R° R± R² R³ R´ Rµ R¶ R· R¹ R¸ Rº R» R¼ RÆ t drRarFilet drFileNameListt loopDateInfot drPatht rspListt
|
drDatePatht loopDateListt
|
loopDrPatht
|
rarOpenObj( ( s# E:\www\Server\eventdata\CommFunc.pyt loopCenterbakRarDR2 sê
|
$
|
%#1
|
*
|
,%!
|
|
|
4
|
|
) R c C sÆ d } | r- | t d d t | 7} n | d 7} | d 7} | rX | d | 7} n x: | D]2 } | j | i } | d | j d | 7} q_ W| d 7} xt | D]\ } } | d 7} | rÝ | d | d 7} n xÊ | D]Â } d }
|
t | t r| j | d }
|
n! t | | r5t | | }
|
n t |
|
t rV|
|
j t
|
}
|
n t |
|
t stt |
|
}
|
n | j | i } | d
|
| j d d |
|
f 7} qä W| d 7} q¬ W| d 7} | S( sO ç¼è¾è¡¨æ ¼html
|
@param dataList: æ°æ®å表ï¼å
ç´ æ¯æ ç±»å®ä¾ æ åå
¸
|
@param tdList: è¡¨æ ¼å±æ§å段key顺åºå表
|
@param rowNumTitle: è¡ç¼å·æ é¢ï¼å¦æ空表示ä¸æ¾ç¤ºè¡ç¼å·ï¼é空åä¼ å
¥è¡ç¼å·æ é¢åï¼è¡ç¼å·é»è®¤ä¸º index + 1
|
@param styleInfo: å±æ§åæ®µæ ·å¼ä¿¡æ¯
|
R u æ°æ®æ¡æ°s : %s<br/>s$ <table id="tt" class="border-table">s <tr>s <td align='center'>%s</td>t titles </tr>i s <td align='%s'>%s</td>t alignt centers </table>( R R RG t enumerateR t dictt hasattrt getattrR R R R ( t dataListt tdListt rowNumTitlet styleInfot
|
printCountt tablHtmlt tdKeyt stylet it dataObjt tdValue( ( s# E:\www\Server\eventdata\CommFunc.pyt editTableHtmlÚ s< !
|
|
|
|
$
|
c C s d | j d d | j d d | f } t j j | sr d | j d d | f } t j j | sr i Sn i } t | d } | j } xk | D]c } | s¬ q n | j d } t | d k rÓ q n | d j d
|
d j d d | | d <q W| S( Ns ../../Common/config/%s/%s/%s.txtRÀ R t langs ../../Common/config/%s/%s.txtR s i i s s
|
i ( RG R R RÊ R£ R¤ R R RZ ( t cfgNameR t
|
txtFileDirt kvDictRº R» R¼ t spList( ( s# E:\www\Server\eventdata\CommFunc.pyt getCfgKeyNameDict s + .c C sk d | j d d } t j j | s, | St j } | j | | j | | s[ | S| j | | S( sg è·åspè¿è¥é¡¹ç®å¯¹åºä¸å±é
ç½®
|
@param section é
ç½®èç¹
|
@param option é
置项
|
s! ../../Common/config/%s/config.iniRÀ R ( RG R R RÊ t ConfigParserR} RF ( R t sectiont optiont defaultValuet
|
iniFileDirRH ( ( s# E:\www\Server\eventdata\CommFunc.pyt getSPConfig s c C s | d k r t | } nl | d k rD d | d t d f } nC | d k rm d | d t d f } n d | d t d
|
f } | S( Ni' i@B s %.2f%sg Ã@u ä¸i áõs %.1f%ss %.3f%sg ×Au 亿( R R ( t numt fpStr( ( s# E:\www\Server\eventdata\CommFunc.pyt transformNum* s c C sP | s d } n t | t k r- | g } n t j d d | } | j d S( Nt zh_CNt eventDataPys ../../language( t typeR t gettextt translationt install( t languagest gt( ( s# E:\www\Server\eventdata\CommFunc.pyt gettextInstall5 s
|
c C st i t d d 6t d d 6t d d 6t d d 6t d d
|
6t d d 6} | j | d t d | f S( Nu 人æ°å¸i u ç¾å
i u è¶åç¾i u sohaå¸i u é票ç¹å¸i u 代å¸i s %s[%s]u æªç¥è®¢åç±»å( R RG ( t payOrderTypet PayOrderTypeName( ( s# E:\www\Server\eventdata\CommFunc.pyt getPayOrderTypeName? s Tc C s$ i d d 6d d 6} | j | d S( Ni i i id ( RG ( R t rateDict( ( s# E:\www\Server\eventdata\CommFunc.pyt getPayOrderCoinRateC s (/ R R) R Rx Rz R~ R R R Rü R t FinalDataSignR R R R/ R R R# R( R- R4 R5 R: R> RC RJ RM RV R$ Re Rp R R R R R¾ R¿ Râ R% Rõ Rû R R R R R ( ( ( s# E:\www\Server\eventdata\CommFunc.pyt <module> sX # ? ¨/
|
|
