B
|
×ù=f¢ ã @ sÒ d Z ddlZddlZddlZddlZddlmZ ddlm Z m
|
Z
|
m Z m Z dZ dZdZdZd Zd
|
Zd Zd Zd ZdZG dd deZG dd deZG dd dZG dd dZe dkrÎedddZ e ¡ e dS )u
|
å½ä»¤ç®¡çå¨
|
é N)Úasync_log_util)Ú logger_local_huaxin_trade_debugÚ logger_tradeÚ!logger_local_huaxin_contact_debugÚ logger_infoZheartÚcmdÚtradeZ delegate_listZ deal_listZ position_listZmoneyZdealZl2_cmdé c @ s< e Zd Zdd Zdd Zdd Zdd Zd d
|
Zd d Zd S )ÚTradeActionCallbackc C s d S )N© )ÚselfÚ client_idÚ
|
request_idÚskÚtype_Údatar r ú8D:\workspace\trade_sell\huaxin_client\command_manager.pyÚOnTrade s zTradeActionCallback.OnTradec C s d S )Nr )r r r r Ú
|
can_cancelr r r ÚOnDelegateList$ s z"TradeActionCallback.OnDelegateListc C s d S )Nr )r r r r r r r Ú
|
OnDealList( s z TradeActionCallback.OnDealListc C s d S )Nr )r r r r r r r ÚOnPositionList, s z"TradeActionCallback.OnPositionListc C s d S )Nr )r r r r r r r ÚOnMoney0 s zTradeActionCallback.OnMoneyc C s d S )Nr )r r r r r r r r ÚOnTest4 s zTradeActionCallback.OnTestN) Ú__name__Ú
|
__module__Ú __qualname__r r r r r r r r r r r
|
s r
|
c @ s e Zd Zdd ZdS )ÚL2ActionCallbackc C s d S )Nr )r Z
|
codes_datar r r ÚOnSetL2Position: s z L2ActionCallback.OnSetL2PositionN)r r r r r r r r r 8 s r c st e Zd Zi ZdZejjddZ fddZ e
|
e e j dddZe
|
dd d
|
Ze
|
e j d d d ZdddZ ZS )ÚTradeCommandManagerNé )Ú max_workersc s" | j s t j| f||| _ | j S )N)Ú _instanceÚsuperÚ__new__)ÚclsÚargsÚkwargs)Ú __class__r r r$ D s zTradeCommandManager.__new__)Útrade_action_callbackÚ#queue_strategy_trade_read_for_tradec C s || _ || _d S )N)Úaction_callbackÚqueue_strategy_w_trade_r)r% r) r* r r r ÚinitI s zTradeCommandManager.initc
|
|
C s: t td| ¡ yì|d }| d¡}|tkrp|d }t td| ¡ | j |||||¡ t td| ¡ n|tkr| j |||¡ nr|t
|
kr¤| j |||¡ nX|t krÈ|d }| j ||||¡ n4|tkrâ| j |||¡ n|dkrü| j ||||¡ W n6 tk
|
r4 } zt td | ¡ W d d } ~ X Y nX d S )
|
Nu process_commandï¼ r r Z
|
trade_typeu 交æå¼å§:u 交æç»æ:r Útestu process_commandåºéï¼ )r Úinfor ÚgetÚCLIENT_TYPE_TRADEr r+ r ÚCLIENT_TYPE_MONEYr ÚCLIENT_TYPE_DEAL_LISTr ÚCLIENT_TYPE_DELEGATE_LISTr ÚCLIENT_TYPE_POSITION_LISTr r Ú ExceptionÚerror)
|
r% Ú_typer Ú result_jsonr r r Úctyper Úer r r Úprocess_commandO s,
|
z#TradeCommandManager.process_command)Úqueue_strategy_tradec
|
C sÔ |d kr d S yxyP| ¡ }|r^|d }|dkrPt td| ¡ t d| ¡ | |d |¡ W q tk
|
r } zt t|¡ t |¡ W d d }~X Y qX qW W n. tk
|
rÎ } zt t|¡ W d d }~X Y nX d S )NÚtyper. u æ¥åå°ä¿¡æ¯ï¼ )
|
r0 r r/ r r r< r6 Ú exceptionr Úlogging)r% r= Úvalr8 r; r r r Úrun_process_commandm s" $z'TradeCommandManager.run_process_commandTc s4 |r j¡ n tj fdddd}| ¡ d S )Nc s j¡S )N)rB r, r )r r r Ú<lambda> ó z)TradeCommandManager.run.<locals>.<lambda>T)ÚtargetÚdaemon)rB r, Ú threadingÚThreadÚstart)r ÚblockingÚt1r )r r Úrun s zTradeCommandManager.run)N)T)r r r Ztrade_client_dictr" Ú
|
concurrentÚfuturesÚThreadPoolExecutorZprocess_command_thread_poolr$ Ú classmethodr
|
ÚmultiprocessingÚQueuer- r< rB rL Ú __classcell__r r )r( r r ? s r c @ s( e Zd ZdZedd Zedd ZdS )ÚL2CommandManagerNc C s
|
|| _ d S )N)r+ )r% Zl2_action_callbackr r r r- s zL2CommandManager.initc C s( |d }|d }|t kr$| j |¡ d S )Nr r> )ÚCLIENT_TYPE_CMD_L2r+ r )r% r8 r r9 r r: r r r r< s z L2CommandManager.process_command)r r r r+ rP r- r< r r r r rT s rT Ú__main__z 127.0.0.1i' ) Ú__doc__Úconcurrent.futuresrM r@ rQ rG Ú
|
log_moduler Úlog_module.logr r r r ZMSG_TYPE_HEARTZ MSG_TYPE_CMDr1 r4 r3 r5 r2 ZCLIENT_TYPE_DEALrU ZHEART_SPACE_TIMEÚobjectr
|
r r rT r ÚmanagerrL Úinputr r r r Ú<module> s0 O
|
