B
|
9ëEfr* ã @ s d dl Z d dlZd dlZd dlZd dlZd dlZd dlmZ d dlm Z G dd dZ
|
dd Z dd Z d
|
d Z d d Zdd Zdd Zd'ddZdd Zdd Zd(ddZd)ddZi Zd*d d Ze ¡ fd d Zde ¡ fd!d"Zd#d$ Ze ¡ fd%d&Z dS )+é N)Úprintlog)Útoolc @ s e Zd Zedd ZdS )ÚLogUtilc C sp t |ddd}zRt |ddd:}| ¡ }x*|D ]"}| d |¡¡dkr.| |¡ q.W W d Q R X W d | ¡ X d S )NÚwzutf-8)ÚmodeÚencodingÚr)r z{}r )ÚopenÚ readlinesÚfindÚformatÚwriteÚclose)ÚclsÚkeyÚpathZ target_pathÚfwÚfÚlinesÚline© r ú0D:\workspace\trade_sell\log_module\log_export.pyÚextract_log_from_key s
|
z LogUtil.extract_log_from_keyN)Ú__name__Ú
|
__module__Ú __qualname__Ú classmethodr r r r r r s r c C s, t d | ¡d t ¡ |¡d ||¡¡ d S )Nu {} å¤çæ°æ®èå´z${}/sell_logs/gp/l2/l2_process.{}.logz{}/l2_process_{}.log)r r r ÚconstantÚget_path_prefix)ÚcodeÚdateÚdirr r r Ú__export_l2_pos_range s r" c C s& t | d t ¡ |¡d ||¡¡ d S )Nz"{}/sell_logs/gp/l2/l2_trade.{}.logz{}/l2_trade_{}.log)r r r r r )r r r! r r r Ú__export_l2_trade_log" s r# c C s& t | d t ¡ |¡d ||¡¡ d S )Nz){}/sell_logs/gp/l2/l2_trade_cancel.{}.logz{}/l2_trade_cancel_{}.log)r r r r r )r r r! r r r Ú __export_l2_trade_cancel_log( s r$ c C s| t j ¡ d¡} t ¡ d| d}t|ddB}| ¡ }x2|rl| d¡d }t|dkrbt | | ¡ }q<W W d Q R X d S ) Nz%Y-%m-%dz /sell_logs/gp/l2/l2_process.z.logzutf-8)r ú:éÿÿÿÿé )
|
ÚdatetimeÚnowÚstrftimer r r ÚreadlineÚsplitÚintr )r Ú file_pathr r Útime_r r r Ú__analyse_pricess_time- s r0 c C sn t | dk rd S tj ¡ d¡}d t ¡ | ¡}tj |¡sFt
|
|¡ t | || t | || t | || d S )Né z%Y-%m-%dz{}/sell_logs/gp/l2/{})Úlenr( r) r* r r r Úosr ÚexistsÚmkdirr" r$ r# )r r Zdir_r r r Ú export_l2_log9 s
|
r6 c C sT | d¡}t|d d t|d d t|d }|d d }t |d | ¡S )Nr% r i é é< é é )r, r- r Útime_seconds_format)r/ ÚtsÚsÚchar r r Úcompute_buy1_real_timeE s
|
, r? c C s i }| d krt ¡ } yîtd t ¡ | ¡dd}x| ¡ }|s@P | d¡d }| d¡dkrl| d|¡d }||d d
¡ }|dd
|
}|d d
}t |}||kr²|||< q2||
|
|¡ q2W W d Q R X x0|D ](}t |t || d || d d qÔW W n Y nX |S )Nz!{}/sell_logs/gp/l2/l2_data.{}.logr )r z - r9 Úasync_log_utilr ú]r7 r1 é r& Úindex) r Úget_now_date_strr r r r r+ r ÚstripÚevalÚextendr r2 )r Z
|
today_datar ÚdatarC r Zdict_r r r r Úload_l2_from_logL s0
|
|
,rI c C s& | d¡d d¡d d¡d }|S )Nú|r ú r7 Ú.)r, )r r/ r r r Ú__get_log_timek s "rM c C s2 | d¡d } | | d¡d | d¡d
}|S )Nz - r7 ú[é )r, r )r Útime_strr r r Ú__get_async_log_timep s rQ c C sT |st j ¡ d¡}g }td t ¡ |¡ddd}x | ¡ }|sHP | d | ¡¡dk r^q:t |}|| d¡t
|
d d | d
|
¡
¡ }t
|
|dks¸|d d t | d ¡d k r:t d t | dd¡ kràt dkr:n q:y.| t | d ¡d t | d ¡d f¡ W q: tk
|
r@ } zt |¡ W d d }~X Y q:X q:W W d Q R X |S )Nz%Y-%m-%dz${}/sell_logs/gp/l2/l2_process.{}.logr zutf-8)r r zcode:{}r u å¤çæ°æ®èå´r7 u å¤çæ¶é´r& ú-Ú093000r% Ú Ú150000)r( r) r* r r r r r+ r rM r2 rE r- r, ÚreplaceÚappendÚ ExceptionÚloggingÚ exception)r r Úpos_listr r r/ Úer r r Úget_l2_process_positionw s( (*,.*r] c C s |st j ¡ d¡}g }td t ¡ |¡ddd^}xT| ¡ }|sHP | d | ¡¡dk r^q:t |}t
|
dt
|
| d d
|
¡ks:t
|
| d d
|
¡t
|
d krq:| d ¡dkrä| d ¡d ¡ }|d| d¡
¡ }| dt
|
|d
|
f¡ q:| d¡dkr2| d¡d ¡ }|d| d¡
¡ }| dt
|
|d
|
f¡ q:| d¡dkr:| d¡d ¡ }|d| d¡
¡ }| dt
|
|| d¡d f¡ q:q:q:W W d Q R X |S )Nz%Y-%m-%dz"{}/sell_logs/gp/l2/l2_trade.{}.logr zutf-8)r r zcode={}r rS r% rT rU u è·åå°ä¹°å
¥ä¿¡å·èµ·å§ç¹u! è·åå°ä¹°å
¥ä¿¡å·èµ·å§ç¹ï¼r7 rK u è·åå°ä¹°å
¥æ§è¡ä½ç½®u è·åå°ä¹°å
¥æ§è¡ä½ç½®ï¼u 触åæ¤åï¼æ¤åä½ç½®ï¼r9 u æ¤ååå ï¼)r( r) r* r r r r r+ r rM r- rV r, rE rW )r r r[ r r r/ Ústr_rC r r r Úget_l2_trade_position s: 0 r_ é c C s t | jdd¡ ¡ }|tkrBt ¡ t| d |k rBt| d S g }tj | ¡rt | ddd&}|
|
¡ }x|D ]}| |¡ qpW W d Q R X t ¡ |ft|< |S )Nzutf-8)r r r7 r ) ÚhashlibÚmd5ÚencodeÚ hexdigestÚ__log_file_contentsÚtimer3 r r4 r r
|
rW )Úpath_strZexpire_timespacerb Úcontentsr r r r r r Ú__load_file_content» s
|
ri c C sÀ t ¡ d| d}g }t|}x|D ]}| | d¡}|dkr&| d¡d }|| d¡d | d¡d
}|| d ¡d d
¡ }| d¡d } | d¡d }t|}| |¡ q&W |S )
|
Nz&/sell_logs/huaxin/l2/transaction_desc.z.logú#r z - r7 rN rO rA )r r ri r r, rE rF rW ) r r r Úfdatasr r Z
|
data_indexrP rH r r r Úload_huaxin_deal_recordË s
|
rl c C sì t ¡ d| d}i }tj |¡rèt|ddd°}| ¡ }x |D ]}|rB| d¡d ¡ }| d¡r||
|
d ¡d d
¡ }| d
|
¡d }|d d
}| r¨| |kr¨qB|d d
¡ }||krÈg ||< || t |¡ qBW W d Q R X |S ) Nz,/sell_logs/huaxin/l2/transaction_sell_order.z.logr zutf-8)r z - r7 rN rA zcode=r1 ) r r r3 r r4 r r
|
r, rE Ú
|
startswithr rW rF ) r r r rk r r r rH Úcode_r r r Ú load_huaxin_transaction_sell_noß s&
|
|
ro c C sÔ t ¡ dt ¡ d} g }tj | ¡rÐt| ddd}| ¡ }x|D ]|}|rFyf| d¡d
|
¡ }| d¡d
|
¡ }|d kr|d
|
krwF| d¡d d ¡d
|
¡ }| |||f¡ W qF Y qFX qFW W d Q R X |S ) Nz /sell_logs/gp/system/system.z.logr zutf-8)r rJ r r7 ÚINFOÚERRORr9 z - ) r r r rD r3 r r4 r r
|
r, rE rW )r rk r r r rP ÚlevelrH r r r Úload_system_logø s"
|
rs c C sâ t ¡ d| d}i }tj |¡rÞt|ddd¦}| ¡ }x|D ]}|rByx| d¡d ¡ }| d¡r||
|
d ¡d d
¡ }| d
|
¡d }t | d
|
¡d }||kr²g ||< || |¡ W qB Y qBX qBW W d Q R X |S ) Nz!/sell_logs/huaxin/l2/transaction.z.logr zutf-8)r z - r7 rN rA rj r ) r r r3 r r4 r r
|
r, rE rm r rF rW ) r r rk r r r rH r Úl2_datar r r Úload_huaxin_transaction_map s&
|
|
ru )N)N)N)r` ) r( ra rY r3 rf r Úlog_module.logr Úutilsr r r" r# r$ r0 r6 r? rI rM rQ r] r_ re ri rD rl ro rs ru r r r r Ú<module> s2
|
|
|
(
|
|
