B
|
ìèEfI_ ã @ s 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¡ZSe dP¡ZTe dQ¡ZUe dR¡ZVdSdT ZWdUdV ZXeYdWkr|eZdXdYhZ[e: \dZe[ ¡ dS )[u
|
æ¥å¿
|
é N)Úloggerc @ s4 e Zd Zdd Zdd Zdd Zdd Zd d
|
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 jtjd d dd 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| d>dC¡dDd dddd t j| dEdF¡dGd dddd t jtjdHd dd t j| dIdI¡dJd dddd t j| dKdK¡dLd dddd t j| dEdM¡dNd dddd t j| dEdO¡dPd dddd t j| dEdQ¡dRd dddd t j| dEdS¡dTd dddd t j| dEdU¡dVd dddd t j| dWdX¡dYd dddd t j| dZdZ¡d[d dddd t j| dZd\¡d]d dddd t j| dd^¡d_d dddd t j| dd`¡dad dddd t j| dbdc¡ddd dddd t j| dedf¡dgd dddd t j| dedh¡did dddd t j| dedj¡dkd dddd t j| dedl¡dmd dddd t j| dedn¡dod dddd t j| dpdq¡drd dddd t j| dsdt¡dud dddd t j| dvdv¡dwd dddd t j| d dx¡dyd dddd t j| d dz¡d{d dddd t j| d d|¡d}d dddd t j| d d~¡dd dddd t j| d d¡dd dddd t j| d d¡dd dddd t j| d dZ¡dd dddd t j| d
dZ¡dd dddd t j| dd¡dd dddd t j| ddZ¡dd dddd t j| dd¡dd dddd t j| d dx¡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| d
dZ¡dd dddd t j| dd¡dd dddd t jtjdd d t j| dd¡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 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Ú compressionÚenqueuec 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 c S s | d d¡dkS )Nr r Úinfo)r )r r
|
r
|
r r 1 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 c S s | d d¡dkS )Nr r Úprint)r )r r
|
r
|
r r r Údevicec S s | d d¡dkS )Nr r r1 )r )r r
|
r
|
r r r Úsystemc S s | d d¡dkS )Nr r r2 )r )r r
|
r
|
r r r Ú buy_1_volumnc S s | d d¡dkS )Nr r r3 )r )r r
|
r
|
r r r Úbuy_1_volumn_recordc S s | d d¡dkS )Nr r r4 )r )r r
|
r
|
r r r Útrade_queue_price_infoc S s | d d¡dkS )Nr r r5 )r )r r
|
r
|
r r r Ú
|
day_volumnc S s | d d¡dkS )Nr r r6 )r )r r
|
r
|
r r r Úbuy_win_distibutec S s | d d¡dkS )Nr r r7 )r )r r
|
r
|
r r r Z
|
first_codeÚfirst_code_recordc S s | d d¡dkS )Nr r r8 )r )r r
|
r
|
r r ¡ r Údebugc S s | d d¡dkS )Nr r r9 )r )r r
|
r
|
r r ¥ r Ú request_apic S s | d d¡dkS )Nr r r: )r )r r
|
r
|
r r © r Ú trade_recordc S s | d d¡dkS )Nr r r; )r )r r
|
r
|
r r r Úposition_api_requestc S s | d d¡dkS )Nr r r< )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 rA )r )r r
|
r
|
r r Å r Úkpl_open_limit_upc S s | d d¡dkS )Nr r rB )r )r r
|
r
|
r r É r ZkpÚkp_msgc S s | d d¡dkS )Nr r rC )r )r r
|
r
|
r r Î r ZredisÚ redis_debugc S s | d d¡dkS )Nr r rD )r )r r
|
r
|
r r Ò r Úprofilec S s | d d¡dkS )Nr r rE )r )r r
|
r
|
r r Ö r Z transactionc S s | d d¡dkS )Nr r Úhx_l2_transaction)r )r r
|
r
|
r r Û r Ztransaction_sell_orderc S s | d d¡dkS )Nr r Ú hx_l2_transaction_sell_order)r )r r
|
r
|
r r ß r Ztransaction_descc S s | d d¡dkS )Nr r Úhx_l2_transaction_desc)r )r r
|
r
|
r r ã r Z orderdetailc S s | d d¡dkS )Nr r Úhx_l2_orderdetail)r )r r
|
r
|
r r æ r Z
|
marketdatac S s | d d¡dkS )Nr r Úhx_l2_market_data)r )r r
|
r
|
r r é r Zuploadc S s | d d¡dkS )Nr r Ú hx_l2_upload)r )r r
|
r
|
r r ì r c S s | d d¡dkS )Nr r Ú hx_l2_debug)r )r r
|
r
|
r r ï r Zcontactc S s | d d¡dkS )Nr r Úhx_contact_debug)r )r r
|
r
|
r r ó r Ztrade_callbackc S s | d d¡dkS )Nr r Úhx_trade_callback)r )r r
|
r
|
r r ö r c S s | d d¡dkS )Nr r Úhx_trade_debug)r )r r
|
r
|
r r ù r Z
|
trade_loopc S s | d d¡dkS )Nr r Ú hx_trade_loop)r )r r
|
r
|
r r ü r c S s | d d¡dkS )Nr r Úlocal_huaxin_transaction)r )r r
|
r
|
r r r c S s | d d¡dkS )Nr r Úlocal_huaxin_orderdetail)r )r r
|
r
|
r r r c 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 Zmarketc S s | d d¡dkS )Nr r Úlocal_huaxin_l2_market)r )r r
|
r
|
r r r c 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 rZ )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ÚsysÚstdoutÚ get_hx_pathÚget_local_huaxin_path)Úselfr
|
r
|
r Ú__init__ sÄ
|
|
zMyLogger.__init__c C s d t ¡ tj||¡d }|S )Nz{}/{}/gp/{}/{}z.{time:YYYY-MM-DD}.log)ÚformatÚconstantÚget_path_prefixÚLOG_DIR)rg Údir_nameÚlog_nameÚpath_strr
|
r
|
r rb 2 s
|
zMyLogger.get_pathc C s d t ¡ tj||¡d }|S )Nz{}/{}/huaxin/{}/{}z.{time:YYYY-MM-DD}.log)ri rj rk rl )rg rm rn ro r
|
r
|
r re 8 s
|
zMyLogger.get_hx_pathc C s d t ¡ tj||¡d }|S )Nz{}/{}/huaxin_local/{}/{}z.{time:YYYY-MM-DD}.log)ri rj rk rl )rg rm rn ro r
|
r
|
r rf > s
|
z MyLogger.get_local_huaxin_pathc C s t j|dS )N)r )r Úbind)rg rn r
|
r
|
r Ú
|
get_loggerD s zMyLogger.get_loggerN)Ú__name__Ú
|
__module__Ú __qualname__rh rb re rf rq r
|
r
|
r
|
r r s (r r0 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/ r1 r2 r3 r4 r5 r6 r7 r8 r9 r: r; r< r= r> r? r@ rA rB rC rD rE r rI rF rG rH rJ rK rL rM rN rO rP rQ rR rS rU rV rW rX rY rZ r] r_ r\ r^ c C s2 t jt jd t ¡ s.t d¡ t dtj¡ d S )N)Úlevelé z /dev/null) ÚloggingÚ basicConfigÚERRORrj Ú
|
is_windowsÚosÚcloseÚopenÚO_WRONLYr
|
r
|
r
|
r Ú close_print¶ s
|
r c G s t | ¡ d S )N)Ú logger_printr )Úargsr
|
r
|
r Úprintlog½ s r Ú__main__Z000333Z000222u ç¸æ¿ä»£ç ï¼)]Ú__doc__rw r{ rc Zlogurur rj r Z
|
__myloggerrq r Z logger_infoZlogger_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_recordÚ 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_profileZlogger_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_l2_marketZ!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_volumer r rr ÚsetZopen_limit_up_codesr r
|
r
|
r
|
r Ú<module> s¶ ?
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
