B
|
ìðüe!R ã @ sZ d Z ddlZddlZddlZddlmZ ddlZG dd dZe Ze d¡Z
|
e d¡Z e d¡Z e d ¡Z e d
|
¡Ze d ¡Ze d ¡Ze d ¡Ze d¡Ze d¡Ze d¡Ze d¡Ze d¡Ze d¡Ze d¡Ze d¡Ze d¡Ze d¡Ze d¡Z e d¡Z e d¡Z e d¡Z e d ¡Z e d ¡Z!e d ¡Z"e d ¡Z#e d ¡Z$e d!¡Z%e d"¡Z&e d#¡Z'e d$¡Z(e d%¡Z)e d&¡Z*e d'¡Z+e d(¡Z,e d)¡Z-e d*¡Z.e d+¡Z/e d,¡Z0e d-¡Z1e d.¡Z2e d/¡Z3e d0¡Z4e d1¡Z5e d2¡Z6e d3¡Z7e d4¡Z8e d5¡Z9e d6¡Z:e d7¡Z;e d8¡Z<e d9¡Z=e d:¡Z>e d;¡Z?e d<¡Z@e d=¡ZAe d>¡ZBe d?¡ZCe d@¡ZDe dA¡ZEe dB¡ZFe dC¡ZGe dD¡ZHe dE¡ZIe dF¡ZJe dG¡ZKe dH¡ZLe dI¡ZMe dJ¡ZNe dK¡ZOe dL¡ZPe dM¡ZQe dN¡ZRe dO¡ZSdPdQ ZTeUdRkrVeVdSdThZWe8 XdUeW ¡ dS )Vu
|
æ¥å¿
|
é N)Úloggerc @ s, e Zd Zdd Zdd Zdd Zdd Zd S )
|
ÚMyLoggerc C s t ¡ t j| dd¡dd dddd t j| dd¡d d dddd t j| dd
|
¡d d dddd t j| d d ¡dd dddd t j| d d¡dd dddd t j| d d¡dd dddd t j| d d¡dd dddd t j| d d¡dd dddd t j| d d¡dd dddd t j| dd¡dd dddd t j| d d ¡d d dddd t j| d d ¡d d dddd t j| d d ¡d!d dddd t j| d d"¡d#d dddd t j| d d$¡d%d dddd t j| d d&¡d'd dddd t j| d d(¡d)d dddd t j| d d*¡d+d dddd t j| d d,¡d-d dddd t j| d d.¡d/d dddd t j| d d0¡d1d dddd t j| d d2¡d3d dddd t j| d d4¡d5d dddd t j| d d6¡d7d dddd t j| d d8¡d9d dddd t j| d d:¡d;d dddd t j| d<d=¡d>d dddd t j| d<d?¡d@d dddd t j| d<dA¡dBd dddd t j| dCdD¡dEd dddd t j| dFdF¡dGd dddd t j| dHdH¡dId dddd t j| dCdJ¡dKd dddd t j| dCdL¡dMd dddd t j| dCdN¡dOd dddd t j| dCdP¡dQd dddd t j| dCdR¡dSd dddd t j| dTdU¡dVd dddd t j| dWdW¡dXd dddd t j| dWdY¡dZd dddd t j| dd[¡d\d dddd t j| dd]¡d^d dddd t j| d_d`¡dad dddd t j| dbdc¡ddd dddd t j| dbde¡dfd dddd t j| dbdg¡dhd dddd t j| dbdi¡djd dddd t j| dbdk¡dld dddd t j| dmdn¡dod dddd t j| dpdq¡drd dddd t j| dsds¡dtd dddd t j| d du¡dvd dddd t j| d dw¡dxd dddd t j| d dy¡dzd dddd t j| d d{¡d|d dddd t j| d d}¡d~d dddd t j| ddW¡dd dddd t j| dd¡dd dddd t jtjdd d t j| d
d¡dd dddd t j| d
d¡dd dddd t j| d d¡dd dddd t j| d d¡dd dddd t j| d d¡dd dddd d S )NÚtradeÚ trade_guic S s | d d¡dkS )NÚextraÚnamer )Úget)Úrecord© r
|
ú)D:\workspace\trade_sell\log_module\log.pyÚ<lambda> ó z#MyLogger.__init__.<locals>.<lambda>z00:00ÚzipT)ÚfilterZrotationÚ compressionZenqueuec S s | d d¡dkS )Nr r r )r )r r
|
r
|
r r r Údelegatec S s | d d¡dkS )Nr r r )r )r r
|
r
|
r r r Úl2Úl2_errorc S s | d d¡dkS )Nr r r )r )r r
|
r
|
r r r Ú
|
l2_processc S s | d d¡dkS )Nr r r )r )r r
|
r
|
r r r Úl2_process_timec S s | d d¡dkS )Nr r r )r )r r
|
r
|
r r r Úl2_tradec S s | d d¡dkS )Nr r r )r )r r
|
r
|
r r ! r Úl2_datac S s | d d¡dkS )Nr r r )r )r r
|
r
|
r r $ r Úl2_latest_datac S s | d d¡dkS )Nr r r )r )r r
|
r
|
r r ( r ZmysqlÚ mysql_debugc S s | d d¡dkS )Nr r r )r )r r
|
r
|
r r , r Úl2_trade_cancelc S s | d d¡dkS )Nr r r )r )r r
|
r
|
r r 4 r zcancel/s_cancelc S s | d d¡dkS )Nr r Ús_cancel)r )r r
|
r
|
r r 8 r zcancel/h_cancelc S s | d d¡dkS )Nr r Úh_cancel)r )r r
|
r
|
r r < r zcancel/l_cancelc S s | d d¡dkS )Nr r Úl_cancel)r )r r
|
r
|
r r @ r zcancel/g_cancelc S s | d d¡dkS )Nr r Úg_cancel)r )r r
|
r
|
r r D r zcancel/d_cancelc S s | d d¡dkS )Nr r Úd_cancel)r )r r
|
r
|
r r H r zcancel/f_cancelc S s | d d¡dkS )Nr r Úf_cancel)r )r r
|
r
|
r r L r Ú l2_trade_buyc S s | d d¡dkS )Nr r r! )r )r r
|
r
|
r r P r Ú l2_big_datac S s | d d¡dkS )Nr r r" )r )r r
|
r
|
r r T r Úl2_trade_queuec S s | d d¡dkS )Nr r r# )r )r r
|
r
|
r r X r Úl2_trade_buy_queuec S s | d d¡dkS )Nr r r$ )r )r r
|
r
|
r r \ r Úl2_trade_buy_progressc S s | d d¡dkS )Nr r r% )r )r r
|
r
|
r r ` r Ú l2_real_place_order_positionc S s | d d¡dkS )Nr r r& )r )r r
|
r
|
r r d r Z l2_subscriptc S s | d d¡dkS )Nr r Úl2_codes_subscript)r )r r
|
r
|
r r h r Úl2_market_sellc S s | d d¡dkS )Nr r r( )r )r r
|
r
|
r r l r Úl2_not_buy_reasonsc S s | d d¡dkS )Nr r r) )r )r r
|
r
|
r r p r ZjuejinÚ juejin_tickc S s | d d¡dkS )Nr r r* )r )r r
|
r
|
r r t r Ú juejin_tradec S s | d d¡dkS )Nr r r+ )r )r r
|
r
|
r r x r Ú huaxin_tradec S s | d d¡dkS )Nr r r, )r )r r
|
r
|
r r | r ZthsÚ code_operatec S s | d d¡dkS )Nr r r- )r )r r
|
r
|
r r r Údevicec S s | d d¡dkS )Nr r r. )r )r r
|
r
|
r r r Úsystemc S s | d d¡dkS )Nr r r/ )r )r r
|
r
|
r r r Ú buy_1_volumnc S s | d d¡dkS )Nr r r0 )r )r r
|
r
|
r r r Úbuy_1_volumn_recordc S s | d d¡dkS )Nr r r1 )r )r r
|
r
|
r r r Útrade_queue_price_infoc S s | d d¡dkS )Nr r r2 )r )r r
|
r
|
r r r Ú
|
day_volumnc S s | d d¡dkS )Nr r r3 )r )r r
|
r
|
r r r Úbuy_win_distibutec S s | d d¡dkS )Nr r r4 )r )r r
|
r
|
r r r Z
|
first_codeÚfirst_code_recordc S s | d d¡dkS )Nr r r5 )r )r r
|
r
|
r r ¡ r Údebugc S s | d d¡dkS )Nr r r6 )r )r r
|
r
|
r r ¥ r Ú request_apic S s | d d¡dkS )Nr r r7 )r )r r
|
r
|
r r © r Ú trade_recordc S s | d d¡dkS )Nr r r8 )r )r r
|
r
|
r r r Úposition_api_requestc S s | d d¡dkS )Nr r r9 )r )r r
|
r
|
r r ± r ZscoreÚplace_order_scorec S s | d d¡dkS )Nr r r: )r )r r
|
r
|
r r µ r ZkplÚkpl_limit_up_reason_changec S s | d d¡dkS )Nr r r; )r )r r
|
r
|
r r ¹ r Ú kpl_limit_upc S s | d d¡dkS )Nr r r< )r )r r
|
r
|
r r ½ r Ú kpl_debugc S s | d d¡dkS )Nr r r= )r )r r
|
r
|
r r Á r Úkpl_block_can_buyc S s | d d¡dkS )Nr r r> )r )r r
|
r
|
r r Å r Úkpl_open_limit_upc S s | d d¡dkS )Nr r r? )r )r r
|
r
|
r r É r ZkpÚkp_msgc S s | d d¡dkS )Nr r r@ )r )r r
|
r
|
r r Î r ZredisÚ redis_debugc S s | d d¡dkS )Nr r rA )r )r r
|
r
|
r r Ò r Úprofilec S s | d d¡dkS )Nr r rB )r )r r
|
r
|
r r Ö r Z transactionc S s | d d¡dkS )Nr r Úlocal_huaxin_transaction)r )r r
|
r
|
r r Ú r Z orderdetailc S s | d d¡dkS )Nr r Úlocal_huaxin_orderdetail)r )r r
|
r
|
r r Ý r Zuploadc S s | d d¡dkS )Nr r Úlocal_huaxin_upload)r )r r
|
r
|
r r à r Úerrorc S s | d d¡dkS )Nr r Úlocal_huaxin_error)r )r r
|
r
|
r r ä r Z subscriptc S s | d d¡dkS )Nr r Úlocal_huaxin_subscript)r )r r
|
r
|
r r è r Zcontactc S s | d d¡dkS )Nr r Úlocal_huaxin_debug)r )r r
|
r
|
r r ë r Z trade_debugc S s | d d¡dkS )Nr r Úlocal_huaxin_trade_debug)r )r r
|
r
|
r r ï r c S s | d d¡dkS )Nr r Úlocal_huaxin_l1_show_info)r )r r
|
r
|
r r ò r )r Úl1Z show_infoc S s | d d¡dkS )Nr r rK )r )r r
|
r
|
r r ô r Z l1_for_tradec S s | d d¡dkS )Nr r Úlocal_huaxin_l1_trade_info)r )r r
|
r
|
r r ø r r c S s | d d¡dkS )Nr r Úlocal_huaxin_g_cancel)r )r r
|
r
|
r r ü r Zspecial_volumec S s | d d¡dkS )Nr r Ú local_huaxin_l2_special_volume)r )r r
|
r
|
r r r Z l2_buy_noc S s | d d¡dkS )Nr r Úlocal_huaxin_l2_buy_no)r )r r
|
r
|
r r r )r ÚremoveÚaddÚget_pathÚget_local_huaxin_pathÚsysÚstdout)Úselfr
|
r
|
r Ú__init__ st
|
|
zMyLogger.__init__c C s d t ¡ ||¡d }|S )Nz{}/sell_logs/gp/{}/{}z.{time:YYYY-MM-DD}.log)ÚformatÚconstantÚget_path_prefix)rW Údir_nameÚlog_nameÚpath_strr
|
r
|
r rS s
|
zMyLogger.get_pathc C s d t ¡ ||¡d }|S )Nz {}/sell_logs/huaxin_local/{}/{}z.{time:YYYY-MM-DD}.log)rY rZ r[ )rW r\ r] r^ r
|
r
|
r rT s
|
z MyLogger.get_local_huaxin_pathc C s t j|dS )N)r )r Úbind)rW r] r
|
r
|
r Ú
|
get_logger s zMyLogger.get_loggerN)Ú__name__Ú
|
__module__Ú __qualname__rX rS rT r` r
|
r
|
r
|
r r s
|
|r r r r r r r r r r( r) r r r r r r r r r! r# r$ r% r& r' r" r* r+ r, r- r. r/ r0 r1 r2 r3 r4 r5 r6 r7 r8 r9 r: r; r< r= r> r? r@ rA rB r Zhx_l2_orderdetailZhx_l2_transactionZ hx_l2_transaction_sell_orderZhx_l2_transaction_descZhx_l2_market_dataZ hx_l2_uploadZ hx_l2_debugZhx_contact_debugZhx_trade_callbackZhx_trade_debugZ hx_trade_looprC rD rE rG rH rI rJ rK rN rP rM rO c C s2 t jt jd t ¡ s.t d¡ t dtj¡ d S )N)Úlevelé z /dev/null) ÚloggingÚ basicConfigÚERRORrZ Ú
|
is_windowsÚosÚcloseÚopenÚO_WRONLYr
|
r
|
r
|
r Ú close_print~ s
|
rn Ú__main__Z000333Z000222u ç¸æ¿ä»£ç ï¼)YÚ__doc__rf rj rU Zlogurur rZ r Z
|
__myloggerr` Zlogger_trade_guiZ logger_tradeZlogger_trade_delegateZlogger_l2_errorZlogger_l2_processZlogger_l2_process_timeZlogger_l2_dataZlogger_l2_latest_dataZlogger_l2_market_sellZlogger_l2_not_buy_reasonsZlogger_l2_tradeZlogger_l2_trade_cancelZlogger_l2_s_cancelZlogger_l2_h_cancelZlogger_l2_d_cancelZlogger_l2_f_cancelZlogger_l2_l_cancelZlogger_l2_g_cancelZlogger_l2_trade_buyZlogger_l2_trade_queueZlogger_l2_trade_buy_queueZ logger_l2_trade_buy_progressZ logger_real_place_order_positionZlogger_l2_codes_subscriptZlogger_l2_big_dataZlogger_juejin_tickZlogger_juejin_tradeZlogger_huaxin_tradeZlogger_code_operateZ logger_deviceZ logger_systemZlogger_buy_1_volumnZlogger_buy_1_volumn_recordZ logger_trade_queue_price_infoZlogger_day_volumnZlogger_buy_win_distibuteZlogger_first_code_recordZ logger_debugZlogger_request_apiZlogger_trade_recordZ!logger_trade_position_api_requestZlogger_place_order_scoreZ!logger_kpl_limit_up_reason_changeZlogger_kpl_limit_upZlogger_kpl_debugZlogger_kpl_block_can_buyZlogger_kpl_open_limit_upZ logger_kp_msgZlogger_redis_debugZlogger_profileÚlogger_mysql_debugZhx_logger_l2_orderdetailZhx_logger_l2_transactionZ#hx_logger_l2_transaction_sell_orderZ hx_logger_l2_transaction_descZhx_logger_l2_market_dataZhx_logger_l2_uploadZhx_logger_l2_debugZhx_logger_contact_debugZhx_logger_trade_callbackZhx_logger_trade_debugZhx_logger_trade_loopZ"logger_local_huaxin_l2_transactionZ"logger_local_huaxin_l2_orderdetailZ logger_local_huaxin_l2_uploadZ logger_local_huaxin_l2_errorZ logger_local_huaxin_l2_subscriptZ!logger_local_huaxin_contact_debugZ logger_local_huaxin_trade_debugZlogger_local_huaxin_l1Z logger_local_huaxin_g_cancelZ logger_local_huaxin_l2_buy_noZ!logger_local_huaxin_l1_trade_infoZ%logger_local_huaxin_l2_special_volumern ra ÚsetZopen_limit_up_codesÚinfor
|
r
|
r
|
r Ú<module> s®
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
