B
|
[ýe+! ã @ sì d Z ddlZddlZddlZddlZddlZddlZddlmZ ddl m
|
Z
|
m Z ddl m Z mZmZ dZdZdZd Zd
|
Zd Zd
|
Zd Zd
|
Zd Zd Zd Zd Z dZ dZ dZ G dd de Z!G dd dZ"e#dkrèe"e j$e j%dZ&e& '¡ e( dS )u
|
å¤é¨æ¥å£ç®¡ç
|
é N)ÚSendResponseSkManager)Ú logger_systemÚlogger_request_api)Úmiddle_api_protocolÚtoolÚ socket_utilÚheartÚcmdZ
|
trade_sellé é é é ÚtradeZ sell_ruleZrefresh_trade_dataZget_code_position_infoc @ s, e Zd Zdd Zdd Zdd Zdd Zd S )
|
ÚActionCallbackc C s d S )N© )ÚselfÚ client_idÚ
|
request_idÚdatar r ú<D:\workspace\trade_sell\utils\outside_api_command_manager.pyÚOnTrade. s zActionCallback.OnTradec C s d S )Nr )r r r r r r r Ú
|
OnSellRule2 s zActionCallback.OnSellRulec C s d S )Nr )r r r r r r r ÚOnRefreshTradeData5 s z!ActionCallback.OnRefreshTradeDatac C s d S )Nr )r r r r r r r ÚOnGetCodePositionInfo8 s z$ActionCallback.OnGetCodePositionInfoN)Ú__name__Ú
|
__module__Ú __qualname__r r r r r r r r r , s r c s¢ e Zd Zi Zi ZdZdZdZdZ fddZ e
|
dd Z e
|
dddZ e
|
dd
|
d Z e
|
d d Ze
|
dd Ze
|
dd Ze
|
dd Ze
|
dd ZdddZ ZS ) ÚApiCommandManagerr Nc s" | j s t j| f||| _ | j S )N)Ú _instanceÚsuperÚ__new__)ÚclsÚargsÚkwargs)Ú __class__r r r G s zApiCommandManager.__new__c
|
C sR t t jt j¡}| | j¡ | t t dd|i|d¡
|
d¡¡¡ | d¡ |S )NÚregisterÚ client_type)Útyper Úridzutf-8i ) ÚsocketÚAF_INETÚ SOCK_STREAMÚconnectÚip_portÚsendr Úformat_responseÚjsonÚdumpsÚencodeÚrecv)r! r& r( Úclientr r r Z__create_clientL s
|
z!ApiCommandManager.__create_clientc C sz | dt t ¡ d dt dd¡ }|d k r>|d| 7 }| ||¡}| |||¡ | |||¡ td|| ||fS )NÚ_iè r z create_and_run_client success)ÚroundÚtimeÚrandomÚrandintÚ!_ApiCommandManager__create_clientÚ%_ApiCommandManager__heartbeats_threadÚ)_ApiCommandManager__listen_command_threadÚprint)r! r' ÚindexÚkeyÚskr r r Z__create_and_run_clientW s ( z)ApiCommandManager.__create_and_run_clienté c C sT | j ¡ || _|| _||f| _x.t|D ]"}| t|¡}|d | j |d < q*W d S )Nr r )Útrade_client_dictÚclearÚtrade_client_countÚaction_callbackr- ÚrangeÚ)_ApiCommandManager__create_and_run_clientÚCLIENT_TYPE_TRADE_SELL)r! ÚaddrÚportZtrade_action_callbackrD ÚiÚresultr r r Úinitc s
|
|
zApiCommandManager.initc C s2 x*y¶t |¡d }|r²t ¡ }z0yütd|| t |¡}|d tkrj| t d|d¡ d¡¡ w|d }|d }td| |
|
d ¡} t |¡s¸td
|
t || |d d
|
d ¡ w|tkrÒ| j || |¡ nP|tkrì| j || |¡ n6|tkr| j || |¡ n|tkr"| j || |¡ W n. tk
|
rR }
|
zt |
|
¡ W d d }
|
~
|
X Y nX W d tt ¡ | } | d krt |¡}t d|d d ¡ | t ddi¡ d¡¡ X ntdW q tk
|
r( }
|
zLt |
|
¡ |t krü|| j krü| j |¡ y | ¡ W n Y nX P W d d }
|
~
|
X Y qX qW d S )Nr u æ¥æ¶æ°æ®r' r )r' r zutf-8r u æ¥æ¶å
容r u ç¾åé误éÿÿÿÿ)ÚcodeÚmsgé u è¶
æ¶5s以ä¸ï¼Z cmd_recieveu æ¥æ¶çå
容为空)!r Ú recv_datar7 r= r0 ÚloadsÚMSG_TYPE_HEARTr. r1 r2 ÚgetÚis_client_params_sign_rightr Úsend_error_responseÚAPI_TYPE_TRADErE r ÚAPI_TYPE_SELL_RULEr ÚAPI_TYPE_REFRESH_TRADE_DATAr Ú API_TYPE_GET_CODE_POSITION_INFOr Ú ExceptionÚloggingÚ exceptionÚintr ÚinforH rB ÚpopÚclose) r! Ú_typer r@ rL Ú
|
start_timeÚ result_jsonr Ú content_typer ÚeÚuse_timer r r Z__listen_commandn s\
|
|
|
|
|
|
|
|
|
|
|
z"ApiCommandManager.__listen_commandc
|
C s xy&| t t d|d¡ d¡¡¡ W n\ tk
|
r } z>|tkrX|| jkrX| j |¡ y |
|
¡ W n Y nX P W d d }~X Y nX t t ¡ qW d S )Nr )r' r zutf-8)r. r Ú load_headerr0 r1 r2 r\ rH rB ra rb r7 ÚsleepÚHEART_SPACE_TIME)r! rc r r@ rg r r r Z __heart_beats¨ s &
|
z ApiCommandManager.__heart_beatsc s0 t j fddd}| d¡ | ¡ d S )Nc s ¡S )N)Ú"_ApiCommandManager__listen_commandr )rc r! r( r@ r r Ú<lambda>¼ ó z;ApiCommandManager.__listen_command_thread.<locals>.<lambda>)ÚtargetT)Ú threadingÚThreadÚ setDaemonÚstart)r! rc r( r@ Út1r )rc r! r( r@ r Z__listen_command_threadº s
|
z)ApiCommandManager.__listen_command_threadc s0 t j fddd}| d¡ | ¡ d S )Nc s ¡S )N)Ú _ApiCommandManager__heart_beatsr )rc r! r( r@ r r rm  rn z7ApiCommandManager.__heartbeats_thread.<locals>.<lambda>)ro T)rp rq rr rs )r! rc r( r@ rt r )rc r! r( r@ r Z__heartbeats_threadÀ s
|
z%ApiCommandManager.__heartbeats_threadc C s t dt ¡ ¡ xjyNt| j| jk rbx8t| jt| j D ] }| t ¡}|d | j|d < q>W W n Y nX t
|
d¡ qW d S )Nu' outside_api __maintain_client 线ç¨ID:r r ) r r` r Ú get_thread_idÚlenrB rD rF rG rH r7 rj )r! rK rL r r r Z__maintain_clientÆ s
|
z#ApiCommandManager.__maintain_clientTc s8 |r ¡ n&tj fddd}| d¡ | ¡ d S )Nc s ¡ S )N)Ú#_ApiCommandManager__maintain_clientr )r r r rm Ù rn z'ApiCommandManager.run.<locals>.<lambda>)ro T)rx rp rq rr rs )r Úblockingrt r )r r ÚrunÔ s
|
|
|
zApiCommandManager.run)N)rA )T)r r r Zcommon_client_dictrB rD Zcommon_client_countrE r r Ú classmethodr: rG rM rl ru r< r; rx rz Ú __classcell__r r )r$ r r > s$
|
: r Ú__main__))Ú__doc__r0 r] r8 r) rp r7 Ú huaxin_client.client_networkr Úlog_module.logr r Úutilsr r r rT Z MSG_TYPE_CMDrH rk ÚTRADE_DIRECTION_BUYÚTRADE_DIRECTION_SELLÚTRADE_TYPE_ORDERZTRADE_TYPE_CANCEL_ORDERÚ OPERRATE_SETÚOPERRATE_DELETEÚ OPERRATE_GETÚ OPERRATE_ADDrX rY rZ r[ Úobjectr r r Ú SERVER_HOSTÚ SERVER_PORTÚmanagerrz Úinputr r r r Ú<module> s@ !
|
