B
|
Aêýb) ã @ s& d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZd dl Z d dl
|
Z
|
d dl m Z m Z mZ G dd dejZG dd dejeZG dd dejZd d
|
Zd d Zed kr"dZe e¡\ZZedk r"edk r"e e¡Z e e¡Z de eee!e e!e ddZ"eee" dS )é N)Úlogger_l2_errorÚlogger_l2_processÚ logger_devicec @ s e Zd ZdddZdS )Ú MyTCPServerTNc C s || _ tjj| |||d d S )N)Úbind_and_activate)ÚpipeÚ socketserverÚ TCPServerÚ__init__)ÚselfÚserver_addressZRequestHandlerClassr r © r ú D:\workspace\trade\server.pyr
|
s zMyTCPServer.__init__)TN)Ú__name__Ú
|
__module__Ú __qualname__r
|
r r r r r s r c @ s e Zd ZdS )ÚMyThreadingTCPServerN)r r r r r r r r s r c s@ e Zd Zi Zi Zi Z fddZ fddZ fddZ Z S )ÚMyBaseRequestHandlec s t ¡ tj ¡ | _d S )N)ÚsuperÚsetupÚl2_code_operateÚ L2CodeOperateÚ get_instanceÚ l2CodeOperate)r )Ú __class__r r r s
|
zMyBaseRequestHandle.setupc sÄ | j d }t ¡ | j}x¢| d¡}t|dkr6P | ¡ }t|dkr t |¡}d}|dkrèyrt t
|
|
¡ d }t |¡\}} }
|
} } zyt | |
|
¡} | | kr.d | |
|
| ¡}|| jksàt t
|
|
¡ d | j| dkr| j | |
|
d¡ t t
|
|
¡ d | j|< | d krd} | j t| t|
|
| ¡ n^d | |
|
¡}|| jksft t
|
|
¡ d | j| dkrt t
|
|
¡ d | j|< | j | |
|
d ¡ t | ¡r¤t | | ¡ W nò t jk
|
r: } zr| ¡ t jjkr*d | |
|
| ¡}|| jkst t
|
|
¡ d | j| dkr*| j | ¡ t t
|
|
¡ d | j|< W d d }~X Y n` t k
|
r } z@t d
|
t | t !|¡ t" #d t |¡¡ t" #d |¡¡ W d d }~X Y nX W d t t
|
|
¡ d }|| d krÒt$ %d | || ¡¡ X W n Y nX nÆ|dkr8y,t &|¡\} }t | ¡r t '|| |¡ W n t d
|
Y nX nv|d krt (|¡}t )|¡ g }x |D ]}| *|d ¡ q`W t +|¡ | j,j- .d¡ n|dkr¶t (|¡}t /|¡ nø|dkrt 0|¡}yt1 2|¡ W n. t k
|
r } zt !|¡ W d d }~X Y nX t1 3|¡ n|dkrvt 0|¡}yt1 4|¡ W n. t k
|
rf } zt !|¡ W d d }~X Y nX t1 5|¡ n8|dkrt 0|¡}t 6|¡ n|dkrÊt 7|¡} | d } | d }t1 8| |¡ nä|dkrZt 9|¡d }y<t: ;|d |d ¡\}}t <dt|t= >|¡d d ¡}W n8 t k
|
rV } zt <d t |d ¡}W d d }~X Y nX nT|d kr®t 9|¡d }|d }d!|kr|d! }t? %d" ||¡¡ t @t||¡ | .| A¡ ¡ q W d S )#Nr i ÚOKiè z{}-{}-{}iÐ Ú z{}-{}é u å¼å¸¸u åºéï¼{}u å
容ï¼{}é( u l2å¤çæ¶é´ï¼{}-{}é
|
ÚcodeÚresubé é é é é ÚclientÚmoneyé ÚdataÚaccountÚpwd)r' Z
|
authoritys)r r* )r Úmsgé Zmemeryu ï¼{}ï¼å
å使ç¨çï¼{})BÚclient_addressr ÚhandleÚrequestÚrecvÚlenÚdecodeÚ data_processÚ parseTypeÚroundÚtimeÚl2_data_managerÚ parseL2DataÚgpcode_managerÚget_listen_code_by_posÚformatÚreset_code_dictr Úset_operate_code_stateÚrepaire_operateÚintÚset_operate_code_state_dictÚ is_listenÚ process_dataÚL2DataExceptionÚget_codeÚCODE_PRICE_ERRORÚl2_data_error_dictÚrepaire_l2_dataÚ ExceptionÚprintÚstrÚloggingÚ exceptionr Úerrorr ÚinfoÚparseL2TradeQueueDataÚ
|
saveL2DataÚ parseGPCodeÚ
|
saveZYLTSZÚappendÚ set_gp_listÚserverr ÚsendÚset_limit_up_listÚ parseListÚ trade_managerÚprocess_trade_success_dataÚsave_trade_success_dataÚprocess_trade_delegate_dataÚsave_trade_delegate_dataÚsaveIndustryCodeÚ parseDataÚset_available_moneyÚparseÚ authorityÚloginÚtoJsonÚjsonÚloadsr ÚsaveClientActiveÚencode)r ÚhostÚskr* Ú_strÚtypeZ
|
return_strZ _MyBaseRequestHandle__start_timeÚdayr' Úchannelr ÚdatasÚcode_ÚkeyÚlÚeZ _MyBaseRequestHandle__end_timeZsetDataÚ data_listZ code_listZcodeListZdataListr( Ú client_idZ _authoritysÚmem)r r r r0 & sÔ
|
|
|
|
|
|
|
&
|
&
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
(
|
|
zMyBaseRequestHandle.handlec s t ¡ d S )N)r Úfinish)r )r r r ry ¿ s zMyBaseRequestHandle.finish)
|
r r r r> rB rH r r0 ry Ú __classcell__r r )r r r s r c C s t | ¡}|d ks t|dkr&tdt tjtj¡}| |df¡ z.| t
|
|¡ ¡ ¡ | d¡}| ¡ ¡ }|S | ¡ X d S )Nr u 客æ·ç«¯IP为空i.# i )r5 ÚgetActiveClientIPr3 rJ ÚsocketÚAF_INETÚ SOCK_STREAMÚconnectrX rg Údumpsrj r2 r4 ÚlstripÚclose)rw r* Ú_ipZ socketClientr2 Úresultr r r Úsend_msgÄ s
|
|
r
c C sT xNt ¡ } x6| D ].}td| yt|ddi W q Y qX qW t d¡ qW d S )Nu å¿è·³ÚactionÚtestr$ )rd Úget_l2_clientsrK r
r8 Úsleep)Úclientsr' r r r Útest_client_serverÕ s
|
|
|
r Ú__main__Z000503Ú repairL2Data)Úindexr Ú min_priceÚ max_price)r r* )#rg rM r r| r8 r5 r; rd r9 r[ r Úlogr r r r r ZThreadingMixInr ZBaseRequestHandlerr r
r r r Úget_listen_code_posrw ÚposÚget_limit_up_pricer Úget_limit_down_pricer rA Úfloatr* r r r r Ú<module> s8 *
|
|
|
|
|
