B
|
`,gI ã @ sÒ d Z ddlZddlZddlZddlZddlZddlmZ ddl m
|
Z
|
ddl m Z m Z ddlmZmZ ddlmZmZ ddlZe ¡ Zejjdd Zd
|
d Zd d Z dddZ dd Z dddZ dd Z dd Z!dS )u
|
åé«äº¤ææ°æ®æ´æ°
|
é N)Úconstant)Úasync_log_util)Úhx_logger_trade_debugÚ logger_system)Úhuaxin_trade_apiÚhuaxin_trade_record_manager)Ú huaxin_utilÚtoolé
|
)Ú max_workersc
|
C sÎ t d¡ x¼z¨yrt ¡ } | r| d }| d¡}|rL|dkrLt |¡ t td| ¡ yü|dkrtj ddd }|d
|
dkr|d } t
|
j | ¡ n®|d krÊt ¡ }|d
|
dkrÈ|d } t
|
j | ¡ n||d krtjdd}td| |d
|
dkrF|d }t
|
j |¡ n8|dkrFt ¡ }|d
|
dkrF|d }t t
|
jj |¡ t td| ¡ W n( tk
|
r } z|W d d }~X Y nX W n. tk
|
r´ } zt |¡ W d d }~X Y nX W d t d¡ X qW d S )Nu$ å¯å¨è¯»å交ææ°æ®æ´æ°éåÚtypeÚdelayr u è·å交ææ°æ®å¼å§ï¼Ú delegate_listFr
|
)Ú
|
can_cancelÚtimeoutÚcodeÚdataÚmoneyÚ deal_list)r u æ交ååºï¼Ú position_listu è·å交ææ°æ®æåï¼g{®Gáz?)r ÚinfoÚtrade_data_request_queueÚgetÚtimeÚsleepr r r Úget_delegate_listr ÚDelegateRecordManagerÚaddÚ get_moneyÚ MoneyManagerZ save_dataÚ get_deal_listÚprintÚDealRecordManagerÚget_position_listÚ__process_thread_poolÚsubmitÚPositionManagerÚ ExceptionÚ exception)r Útype_r ZdataJSONÚdatasÚe1Úe© r- õ@ D:\éåä½å¸\low_suction_hx\trade\huaxin_trade_data_update.pyÚ__read_update_task_queue sL
|
|
|
|
|
|
r/ c C s t | ¡ d S )N)r Ú
|
put_nowait)r r- r- r. Ú
|
__add_dataP s r1 c C s$ t d|d t td| ¡ d S )Nr )r r u 请æ±å§æå表ï¼æ¥æºï¼)r1 r r r )Úsourcer r- r- r. Úadd_delegate_listT s r3 c C s t ddi d S )Nr r )r1 r- r- r- r. Ú add_deal_listY s r4 c C s t d| d d S )Nr )r r )r1 )r r- r- r. Úadd_money_list] s r5 c C s t ddi d S )Nr r )r1 r- r- r- r. Úadd_position_lista s r6 c C s t jdd dd} | ¡ dS )u8
|
è¿è¡è¯»åæ¥æ¶å½ä»¤çéå
|
:return:
|
c S s t S )N)r/ r- r- r- r. Ú<lambda>k ó zrun.<locals>.<lambda>T)ÚtargetÚdaemonN)Ú threadingÚThreadÚstart)Út1r- r- r. Úrunf s r? )r )r )"Ú__doc__ÚjsonÚloggingÚqueuer; r Ú huaxin_clientr Zhuaxin_client_constantÚ
|
log_moduler Úlog_module.logr r Útrader r Úutilsr r Úconcurrent.futuresÚ
|
concurrentÚQueuer ÚfuturesÚThreadPoolExecutorr$ r/ r1 r3 r4 r5 r6 r? r- r- r- r. Ú<module> s( 9
|
|
|
