B
|
ãíýbÛ ã @ sx d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZd dl Z d dl
|
Z
|
d dl m Z G dd de ZdS )é N)Úlogger_code_operatec @ s e Zd ZdZe ¡ Ze ¡ Z e
|
dd Z e
|
dd Z e dd Ze
|
dd Ze d
|
d Zd d Zdd Zdd Zdd Zdd Zdd ZdS )Ú L2CodeOperateNc C s
|
| j ¡ S )N)Úredis_manager_ÚgetRedis)Úcls© r ú%D:\workspace\trade\l2_code_operate.pyr s zL2CodeOperate.getRedisc O s* t | ds | ||}t| d| t| dS )NÚins)ÚhasattrÚsetattrÚgetattr)r ÚargsÚkwargsZ insObjectr r r Ú get_instance s
|
|
zL2CodeOperate.get_instancec
|
C sº dt ||dd}t d | ||¡¡ t |¡ zvy>t | |¡}t d || ||¡¡ | d¡rpt | ||¡ W n2 t
|
k
|
r¤ } zt dt |¡ W d d }~X Y nX W d t |¡ X d S )NÚ setGPCode)ÚindexÚcode)ÚactionÚdatau, setGPCodeï¼clientid-{} position-{} code-{}u: setGPCodeç»æï¼{}ï¼ï¼clientid-{} position-{} code-{}ÚOKu setGPCodeåºéï¼{})Úintr ÚinfoÚformatÚgpcode_managerÚ set_operateÚserverÚsend_msgÚ __contains__Úset_listen_code_by_posÚ ExceptionÚerrorÚstrÚ
|
rm_operate)Ú client_idÚpositionÚgpcoder ÚresultÚer r r r " s
|
|
&zL2CodeOperate.setGPCodec C sB | j ¡ z&tjdd d}| d¡ | ¡ W d | j ¡ X d S )Nc S s t ¡ S )N)r Ú send_operater r r r Ú<lambda>7 ó z#L2CodeOperate.run.<locals>.<lambda>)ÚtargetT)Ú_L2CodeOperate__lockÚacquireÚ threadingÚThreadÚ setDaemonÚstartÚrelease)r Út1r r r Úrun3 s
|
|
zL2CodeOperate.runc C sâ t ¡ } xÒy¶| d¡}td|| d¡ |d k r¸t |¡}|d |d }}|dkrªt |¡rfw t
|
|¡r¦t |¡s¦t |¡\}}|d k r¦|d k r¦t ||d¡ qÂ|dkrt |¡rÀw t
|
|¡s¶t |¡s¶t ¡ s¶t ¡ \}}|d k r¶|d k r¶t |||¡ n¤|dkr|d }|d
|
}t ¡ ||¡}|dkrHw t ||¡}|dksh|d krjw t d |||¡ t |||¡ n,|d krÂ|d }|d }t |t |¡¡ n
|
t d¡ W q td Y q X q W d S )NÚcode_operate_queueu 读åæä½éåÚtyper r Ú é é ÚclientÚposu ä¿®å¤ä»£ç ä¸è´ï¼{}-{}-{}é r u åéæä½å¼å¸¸) r r ÚlpopÚprintÚllenÚjsonÚloadsÚl2_data_managerZis_in_l2_fixed_codesr Ú is_listenÚ
|
is_operateÚget_listen_code_posr Ú trade_managerZis_in_forbidden_trade_codesÚis_listen_fullÚget_can_listen_posr Úget_operate_code_stateÚget_listen_code_by_posr r r r ÚdumpsÚtimeÚsleep) Úredisr r6 r r# r; ÚstateÚcode_r: r r r r( > sR
|
|
|
|
|
|
|
|
|
zL2CodeOperate.send_operatec C s2 | j ¡ }td|| | dt ||d¡¡ d S )NÚ add_operater5 )r6 r )r r r> Úrpushr@ rK )Úselfr6 r rN r r r rQ r s
|
zL2CodeOperate.add_operatec
|
C s* | j ¡ }| dt d|||d¡¡ d S )Nr5 r9 )r6 r: r; r )r r rR r@ rK )rS r: r; r rN r r r Úrepaire_operatew s
|
z L2CodeOperate.repaire_operatec C s t d| ¡ t |¡\}}|d k r`|d k r`t |¡}t |¡}dt||t|t|dd}| j ¡ }|
|
dt d||d¡¡ d S )Nu ä¿®å¤å票çL2æ°æ®ï¼Z repairL2Data)r r Ú min_priceÚ max_price)r r r5 r< )r6 r: r ) r r r rE Úget_limit_up_priceÚget_limit_down_pricer Úfloatr r rR r@ rK )rS r r# r; rV rU r rN r r r Úrepaire_l2_data} s
|
|
|
z L2CodeOperate.repaire_l2_datac C s t |¡r| d|¡ d S )Nr )r rC rQ )rS r r r r Úremove_l2_listen s
|
z L2CodeOperate.remove_l2_listenc C s" | ¡ d ||¡t ¡ |¡ d S )Nzcode-operate_state-{}-{})r Úsetexr ÚtoolÚ
|
get_expire)rS r# ÚchannelrO r r r Úset_operate_code_state s z$L2CodeOperate.set_operate_code_statec C s* | ¡ d ||¡¡}|d k r&t|S |S )Nzcode-operate_state-{}-{})r Úgetr r )rS r# r_ Úvaluer r r rI s z$L2CodeOperate.get_operate_code_state)Ú__name__Ú
|
__module__Ú __qualname__Z_L2CodeOperate__instancer. ÚRLockr, Ú redis_managerÚ RedisManagerr Ú classmethodr r Ú staticmethodr r4 r( rQ rT rZ r[ r` rI r r r r r s 4r )r@ ÚosÚqueuer. r rB r r] rF rL rg Úlogr Úobjectr r r r r Ú<module> s
|
