B
|
áý£d8= ã @ sâ d Z ddlZddlZddlZddlZddlZddlZddlZddlZddl m
|
Z
|
dZ dZ dZ dZdZd Zd
|
Zd Zd Zd Zdd aG dd deZG dd deZG dd dZG dd dZedkrÞedddZ e ¡ e dS )u
|
å½ä»¤ç®¡çå¨
|
é N)ÚSendResponseSkManagerÚheartÚcmdZtradeZ delegate_listZ deal_listZ position_listZmoneyZdealÚl2_cmdé c C s° | d¡}d| kr | d¡ g }xX| D ]P}t| | tkr^| | dtj| | dd ¡ q&| | d| | ¡ q&W | ¡ | d¡ t d
|
|¡¡}||kr¨dS dS d S ) NZsignú=)ú,ú:)Ú
|
separatorsz %Yeshi2014@#.ú&TF) ÚgetÚpopÚtypeÚdictÚappendÚjsonÚdumpsÚsortÚcryptZ md5_encryptÚjoin)ÚdataZold_signZstr_listÚkZnew_sign© r ú/D:\workspace\GP\trade_huaxin\command_manager.pyÚ is_sign_right# s
|
|
|
$
|
r c @ s4 e Zd Zdd Zdd Zdd Zdd Zd d
|
Zd S ) ÚTradeActionCallbackc C s d S )Nr )ÚselfÚ client_idÚ
|
request_idZtype_r r r r ÚOnTrade8 s zTradeActionCallback.OnTradec C s d S )Nr )r r r r r r ÚOnDelegateList< s z"TradeActionCallback.OnDelegateListc C s d S )Nr )r r r r r r Ú
|
OnDealList@ s z TradeActionCallback.OnDealListc C s d S )Nr )r r r r r r ÚOnPositionListD s z"TradeActionCallback.OnPositionListc C s d S )Nr )r r r r r r ÚOnMoneyH s zTradeActionCallback.OnMoneyN)Ú__name__Ú
|
__module__Ú __qualname__r r r! r" r# r r r r r 6 s
|
r c @ s e Zd Zdd ZdS )ÚL2ActionCallbackc C s d S )Nr )r r r Ú
|
codes_datar r r ÚOnSetL2PositionN s z L2ActionCallback.OnSetL2PositionN)r$ r% r& r) r r r r r' L s r' c s e Zd Zi ZdZ fddZedd ZedddZedd d
|
Z ed d Z
|
ed d Z edd Z edd Z edd ZdddZ ZS )ÚTradeCommandManagerNc s" | j s t j| f||| _ | j S )N)Ú _instanceÚsuperÚ__new__)ÚclsÚargsÚkwargs)Ú __class__r r r- W s zTradeCommandManager.__new__c
|
C sd t t jt j¡}| t jt jd¡ | | j¡ | t
|
t dd|i|d¡ d¡¡¡ | d¡ |S )NTÚregisterÚ client_type)r r Úridzutf-8i )ÚsocketÚAF_INETÚ SOCK_STREAMÚ
|
setsockoptÚ
|
SOL_SOCKETÚ SO_KEEPALIVEÚconnectÚip_portÚsendr Úformat_responser r ÚencodeÚrecv)r. r3 r4 Úclientr r r Ú__create_client\ s
|
z#TradeCommandManager.__create_clientc C sn | dt t ¡ d dt dd¡ }|d k r>|d| 7 }| ||¡}| |||¡ | |||¡ ||fS )NÚ_iè r )ÚroundÚtimeÚrandomÚrandintÚ#_TradeCommandManager__create_clientÚ'_TradeCommandManager__heartbeats_threadÚ+_TradeCommandManager__listen_command_thread)r. r ÚindexÚkeyÚskr r r Z__create_and_run_clientg s ( z+TradeCommandManager.__create_and_run_clienté
|
c C s i | _ || _|| _||f| _x.t|D ]"}| t|¡}|d | j |d < q&W | t¡| _| t ¡| _
|
| t ¡| _ | t ¡| _d S )Né r )Útrade_client_dictÚtrade_client_countÚaction_callbackr< ÚrangeÚ+_TradeCommandManager__create_and_run_clientÚCLIENT_TYPE_TRADEÚCLIENT_TYPE_DELEGATE_LISTÚdelegate_clientÚCLIENT_TYPE_DEAL_LISTÚdeal_list_clientÚCLIENT_TYPE_POSITION_LISTÚposition_list_clientÚCLIENT_TYPE_MONEYÚ money_client)r. ÚaddrÚportZtrade_action_callbackrQ ÚiÚresultr r r Úinitr s
|
zTradeCommandManager.initc C sB x:y~t |¡d }|rzz<ytd|| t |¡}|d tkrd| t d|d¡ d¡¡ w|d }| d¡}t
|
|st |||d d
|
d ¡ w|t krº|d }| j ||||¡ nl|tkrÒ| j ||¡ nT|tkrê| j ||¡ n<|tkr|d } | j ||| ¡ n|tkr&| j ||¡ W n. tk
|
rV }
|
zt |
|
¡ W d d }
|
~
|
X Y nX W d | t ddi¡ d¡¡ X ntdW q tk
|
r8 }
|
zt |
|
¡ |t krÆ|| jkr | j |¡ nF|tkrØd | _ n4|tkrêd | _ n"|tkrüd | _ n|tkr d | _ y | !¡ W n Y nX P W d d }
|
~
|
X Y qX qW d S )Nr u æ¥æ¶æ°æ®r r )r r zutf-8r r éÿÿÿÿu ç¾åé误)ÚcodeÚmsgZ
|
trade_typeÚ
|
can_cancelÚ cmd_recieveu æ¥æ¶çå
容为空)"Ú socket_utilÚ recv_dataÚprintr ÚloadsÚMSG_TYPE_HEARTr= r r? r r r Úsend_error_responserU rR r r\ r# rX r! rV r rZ r" Ú ExceptionÚloggingÚ exceptionrP r r] rY rW r[ Úclose) r. Ú_typer rM ra Ú result_jsonr r Zctyperf Úer r r Ú__listen_command sf
|
|
|
|
|
|
|
|
|
|
|
|
z$TradeCommandManager.__listen_commandc
|
C sô xîy0| t t d|d¡ d¡¡¡ td| W n® tk
|
rà } ztd t |¡ |t
|
krv|| j kr´| j |¡ n>|t krd | _n.|tkrd | _n |tkr¦d | _n|tkr´d | _y | ¡ W n Y nX P W d d }~X Y nX t t¡ qW d S )Nr )r r zutf-8u å¿è·³ä¿¡æ¯åéæåu å¿è·³ä¿¡æ¯åé失败)r= r r> r r r? rj rn ro rp rU rP r r\ r] rX rY rV rW rZ r[ rq rE ÚsleepÚHEART_SPACE_TIME)r. rr r rM rt r r r Ú __heart_beatsÆ s2
|
|
z!TradeCommandManager.__heart_beatsc s0 t j fddd}| d¡ | ¡ d S )Nc s ¡S )N)Ú$_TradeCommandManager__listen_commandr )rr r. r4 rM r r Ú<lambda>å ó z=TradeCommandManager.__listen_command_thread.<locals>.<lambda>)ÚtargetT)Ú threadingÚThreadÚ setDaemonÚstart)r. rr r4 rM Út1r )rr r. r4 rM r Ú__listen_command_threadã s
|
z+TradeCommandManager.__listen_command_threadc s0 t j fddd}| d¡ | ¡ d S )Nc s ¡S )N)Ú!_TradeCommandManager__heart_beatsr )rr r. r4 rM r r rz ë r{ z9TradeCommandManager.__heartbeats_thread.<locals>.<lambda>)r| T)r} r~ r r )r. rr r4 rM r r )rr r. r4 rM r Ú__heartbeats_threadé s
|
z'TradeCommandManager.__heartbeats_threadc C sú xôyØt | j| jk rXtdt x8t| jt | j D ] }| t¡}|d | j|d < q4W | jd krxtdt | t¡| _| j d krtdt
|
| t
|
¡| _ | j d kr¸tdt | t ¡| _ | j d krØtdt | t¡| _ W n Y nX t d¡ qW d S )NÚ__maintain_clientrO r )ÚlenrP rQ rj rU rS rT rW rV rY rX r[ rZ r] r\ rE rv )r. r` ra r r r r
ï s,
|
|
|
|
|
|
|
|
|
|
z%TradeCommandManager.__maintain_clientTc s8 |r ¡ n&tj fddd}| d¡ | ¡ d S )Nc s ¡ S )N)Ú%_TradeCommandManager__maintain_clientr )r r r rz r{ z)TradeCommandManager.run.<locals>.<lambda>)r| T)r r} r~ r r )r Úblockingr r )r r Úrun s
|
|
|
zTradeCommandManager.run)N)rN )T)r$ r% r& rP r+ r- Ú classmethodrH rT rb ry r rJ rI r r Ú __classcell__r r )r1 r r* S s
|
@ !r* c @ sj e Zd Zedd Zedd Zedd Zedd Zed d
|
Zed d Z ed d Z
|
dddZ dS )ÚL2CommandManagerc
|
C sJ t ¡ }| | j¡ | t t dd|i|d¡ d¡¡¡ | d¡ |S )Nr2 r3 )r r r4 zutf-8i ( )
|
r5 r; r< r= r r> r r r? r@ )r. r3 r4 rA r r r rB s
|
z L2CommandManager.__create_clientc C sj || _ ||f| _t dtt ¡ d dt dd¡ }| t|¡| _| t|| j¡ |
|
t|| j¡ d S )NrC iè r ) rR r< ÚCLIENT_TYPE_CMD_L2rD rE rF rG Ú _L2CommandManager__create_clientÚ l2_cmd_clientÚ$_L2CommandManager__heartbeats_threadÚ(_L2CommandManager__listen_command_thread)r. r^ r_ Zl2_action_callbackrL r r r rb ' s
|
(zL2CommandManager.initc C sF x>yèt |¡d }td |râz¢yt |¡}|d tkrX| t d|d¡ d¡¡ w|d }|d }|d }t |st
|
|||d d
|
d ¡ w|d } |t kr°| j ||| ¡ W n Y nX W d | t dd i¡ d¡¡ X ntd W q tk
|
r< }
|
z0t |
|
¡ d | _y | ¡ W n Y nX P W d d }
|
~
|
X Y qX qW d S )Nr u æ¥æ¶L2_CMDæ°æ®r r )r r4 zutf-8r r rc u ç¾åé误)rd re rg u æ¥æ¶L2_CMDæ°æ®ä¸ºç©º)rh ri rj r rk rl r= r r? r r rm r rR r) rn ro rp r rq ) r. rr r rM ra rs r r r r( rt r r r ru 2 s@
|
|
|
|
z!L2CommandManager.__listen_commandc
|
C s xy0| t t d|d¡ d¡¡¡ td| W nV tk
|
r } z8td t |¡ d | _
|
y | ¡ W n Y nX P W d d }~X Y nX t t¡ qW d S )Nr )r r zutf-8u å¿è·³ä¿¡æ¯åéæåu å¿è·³ä¿¡æ¯åé失败)r= r r> r r r? rj rn ro rp r rq rE rv rw )r. rr r rM rt r r r rx [ s
|
z L2CommandManager.__heart_beatsc s0 t j fddd}| d¡ | ¡ d S )Nc s ¡S )N)Ú _L2CommandManager__heart_beatsr )rr r. r4 rM r r rz o r{ z6L2CommandManager.__heartbeats_thread.<locals>.<lambda>)r| T)r} r~ r r )r. rr r4 rM r r )rr r. r4 rM r r m s
|
z$L2CommandManager.__heartbeats_threadc s0 t j fddd}| d¡ | ¡ d S )Nc s ¡S )N)Ú!_L2CommandManager__listen_commandr )rr r. r4 rM r r rz u r{ z:L2CommandManager.__listen_command_thread.<locals>.<lambda>)r| T)r} r~ r r )r. rr r4 rM r r )rr r. r4 rM r r s s
|
z(L2CommandManager.__listen_command_threadc
|
C s® x¨yl| j d krltd t dtt ¡ d dt dd¡ }| t|¡| _ | t|| j ¡ | t|| j ¡ W n, t
|
k
|
r } zt |¡ W d d }~X Y nX t d¡ qW d S )Nr
rC iè r rO )r rj r rD rE rF rG r r r rn ro rp rv )r. rL rt r r r r
y s
|
( z"L2CommandManager.__maintain_clientTc s8 |r ¡ n&tj fddd}| d¡ | ¡ d S )Nc s ¡ S )N)Ú"_L2CommandManager__maintain_clientr )r r r rz r{ z&L2CommandManager.run.<locals>.<lambda>)r| T)r r} r~ r r )r r r r )r r r s
|
|
|
zL2CommandManager.runN)T) r$ r% r& r r rb r r r r r r r r r r r s
|
) r Ú__main__z 127.0.0.1i' ) Ú__doc__r ro rF r5 r} rE r rh Zclient_networkr rl Z MSG_TYPE_CMDrU rV rX rZ r\ ZCLIENT_TYPE_DEALr rw r Úobjectr r' r* r r$ Zmanagerr Úinputr r r r Ú<module> s: Iw
|
