B
|
c31 ã
|
@ s4 d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZd dl Z d dl
|
Z
|
d dl Z d dl Z d dl mZmZmZmZ G dd dejZG dd dejeZG dd dejZd d
|
Zd d Zd d Zdd Zdd Z e dkr0yedZ e e W n0 e k
|
r. Z! ze e"e! W ddZ![!X Y nX dS )é N)Úlogger_l2_errorÚlogger_l2_processÚ logger_deviceÚlogger_trade_delegatec @ 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 sD e Zd Zi Zi Zi ZdZ fddZ fddZ fddZ Z
|
S )ÚMyBaseRequestHandleNc 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}|dkrFyÐt t
|
|
¡ d }t |¡\}} }
|
} } t | ¡\} }| d k r2|d k r2| t| kr2|
|
t|kr2z0y$t | |
|
¡}|| krxd | |
|
| ¡}|| jks t t
|
|
¡ d | j| dkrÖ| j | |
|
d¡ t t
|
|
¡ d | j|< |d krTd}t ¡ rÖ| j t| t|
|
|¡ n^d | |
|
¡}|| jks°t t
|
|
¡ d | j| dkrÖt t
|
|
¡ d | j|< | j | |
|
d ¡ t | ¡rît | | ¡ W n t jk
|
r } z| ¡ t jj krd | |
|
| ¡}|| j ksTt t
|
|
¡ d | j | d
|
krt d | |j!¡ t" #¡ $| ¡ 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 }|| dkr0t+ ,d | || ¡¡ X W n Y nX nB|dkry,t -|¡\} }t | ¡rzt .|| |¡ W n t&d Y nX nò|d krt /|¡}t 0|¡ g }x |D ]}| 1|d ¡ q¾W t 2|¡ | j3j4 5t6 7ddi¡¡ t8 n|dkr$t /|¡}t 9|¡ nd|dkrt :|¡}yt; <|¡ W n. t%k
|
rt } zt( )|¡ W d d }~X Y nX t; =|¡ n|dkr t :|¡}| j>|kr´|| _>t? ,|¡ yt; @|¡ W n. t%k
|
rð } zt( )|¡ W d d }~X Y nX t; A|¡ n|dkr"t :|¡}t B|¡ nf|dkrVt C|¡} | d } | d }t; D| |¡ n2|d kræt E|¡d }y<tF G|d |d ¡\}}t Hdt|t6 I|¡d d!¡}W n8 t%k
|
râ } zt Hd t'|d"¡}W d d }~X Y nX n¢|dkr@t E|¡d }|d k rt&d#t| xp|D ] } tJ K| d tL| d$ ¡ q W nH|d%krt E|¡d }|d }tM ,d& |t6 7|¡¡¡ t Nt||¡ | 5| O¡ ¡ q W d S )'Nr i ÚOKiè z{}-{}-{}iÐ Ú z{}-{}é i' u code-{} l2åä»·é误:{}u å¼å¸¸u åºéï¼{}u å
容ï¼{}é( u l2å¤çæ¶é´ï¼{}-{}é
|
ÚcodeÚtypeÚresubé é é é é ÚclientÚmoneyé ÚdataÚaccountÚpwd)r) Z
|
authoritys)r! r, )r! Úmsgu ç°ä»·æ°éÚpriceé u ï¼{}ï¼å®¢æ·ç«¯ä¿¡æ¯ï¼{})PÚclient_addressr ÚhandleÚrequestÚrecvÚlenÚdecodeÚ data_processÚ parseTypeÚroundÚtimeÚl2_data_managerZ parseL2DataÚgpcode_managerÚget_listen_code_posÚintÚget_listen_code_by_posÚformatÚreset_code_dictr Zset_operate_code_stateÚtoolÚ is_trade_timeZrepaire_operateÚset_operate_code_state_dictÚ is_listenZ process_dataZL2DataExceptionÚget_codeZCODE_PRICE_ERRORÚl2_data_error_dictr Úwarningr/ r r Zremove_l2_listenÚ ExceptionÚprintÚstrÚloggingÚ exceptionÚerrorr ÚinfoÚparseL2TradeQueueDataZ
|
saveL2DataÚ parseGPCodeÚ
|
saveZYLTSZÚappendÚ set_gp_listÚserverr ÚsendÚjsonÚdumpsÚsync_target_codes_to_thsÚset_limit_up_listÚ parseListÚ trade_managerZprocess_trade_success_dataZsave_trade_success_dataÚlast_trade_delegate_datar Zprocess_trade_delegate_dataZsave_trade_delegate_dataÚsaveIndustryCodeÚ parseDataZset_available_moneyÚparseÚ authorityÚloginÚtoJsonÚloadsÚjuejinÚ accpt_priceÚfloatr ÚsaveClientActiveÚencode) r ÚhostÚskr, Ú_strr" Z
|
return_strZ _MyBaseRequestHandle__start_timeÚdayr) Úchannelr! ÚdatasZcidÚpidÚcode_ÚkeyÚlÚeZ _MyBaseRequestHandle__end_timeZsetDataÚ data_listÚ code_listZcodeListZdataListr* Ú client_idZ _authoritysÚitem)r r r r3 ) sì
|
|
|
|
|
0
|
|
|
&
|
&
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
(
|
|
|
|
zMyBaseRequestHandle.handlec s t ¡ d S )N)r Úfinish)r )r r r rz Ð s zMyBaseRequestHandle.finish) r r r rB rE rH r^ r r3 rz Ú __classcell__r r )r r r s (r c C s t | ¡}td| | |d ks*t|dkr2tdt tjtj¡}| |df¡ z.| t
|
|¡ ¡ ¡ | d¡}| ¡ ¡ }|S | ¡ X d S )NÚipr u 客æ·ç«¯IP为空i.# i )r8 ÚgetActiveClientIPrK r6 rJ ÚsocketÚAF_INETÚ SOCK_STREAMÚconnectrW rX rY rj r5 r7 ÚlstripÚclose)rx r, Ú_ipZ socketClientr5 Úresultr r r Úsend_msgÕ s
|
|
r c C s\ xVt ¡ } x6| D ].}td| yt|ddi W q Y qX qW t ¡ t d¡ qW d S )Nu å¿è·³ÚactionÚtestr& )rb Úget_l2_clientsrK r r Zcorrect_client_codesr; Úsleep)Úclientsr) r r r Útest_client_serverç s
|
|
|
r c C sB t | ddi}t |¡}|d dkr2t |d ¡S t|d d S )Nr Z getEnvStater! r r, r/ )r rX re rJ )r) r
r r r Úget_client_env_stateö s
|
|
r c C s4 t | ddi}t |¡}|d dkr0t|d d S )Nr Z repairEnvr! r r/ )r rX re rJ )r) r
r r r Úrepair_client_env s
|
r c C sF t ¡ } g }x| D ]}| |¡ qW t d¡}t|d d|d}|S )Nzclient-industryr ZsyncTargetCodes)r r, )r= Ú get_gp_listrT rb Ú_get_client_ids_by_ruler )Úcodesrw r! r) r
r r r rZ s
|
|
rZ Ú__main__r% )#rX rM r r~ r; r8 r= rb rf r< rC r] r Úlogr r r r r
|
r ZThreadingMixInr ZBaseRequestHandlerr r r r r rZ r r
rK rJ ru rL r r r r Ú<module> s8 9
|
|
|
|
