B
|
*c¾" ã @ s¦ 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 mZ G dd deZdd Zdd Zed kr¢e dS )
|
é N)Úlogger_code_operatec @ s e Zd ZdZe ¡ Ze ¡ Z e
|
dd Z e
|
dd Z e dd Ze
|
dd Ze d
|
d Zdd d Zdd Zdd Zdd Ze
|
dd 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ÚkwargsÚ insObjectr r r Ú get_instance s
|
|
zL2CodeOperate.get_instancec
|
C sÔ dt ||dd}t d | ||¡¡ t |¡ zyXt | |¡}t d || ||¡¡ t |¡}|d dkrt
|
| ||¡ t | |d¡ W n2 t k
|
r¾ } zt d t|¡ 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-{}r r é u setGPCodeåºéï¼{})Úintr ÚinfoÚformatÚgpcode_managerÚ set_operateÚserverÚsend_msgÚjsonÚloadsÚset_listen_code_by_posr Úset_operate_code_stateÚ ExceptionÚerrorÚstrÚ
|
rm_operate)Ú client_idÚpositionÚgpcoder ÚresultÚjsonDataÚ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>; ó z#L2CodeOperate.run.<locals>.<lambda>)ÚtargetT)Ú_L2CodeOperate__lockÚacquireÚ threadingÚThreadÚ setDaemonÚstartÚrelease)r Út1r r r Úrun7 s
|
|
zL2CodeOperate.runc
|
C sL 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 |||¡ nn|d krÐt ¡ rÆ|d }|d }t ||¡} td| ntd n(|dkr|d }|d
|
}t ||d¡ n
|
t d¡ W q t k
|
rB }
|
z t |
|
¡ tdt |
|
W d d }
|
~
|
X Y q X q W d S )NÚcode_operate_queueu 读åæä½éåÚtyper r Ú r é ÚclientÚposu ä¿®å¤ä»£ç ä¸è´ï¼{}-{}-{}é r u L2æ¸æ修復çµæï¼u é交ææ¶é´ï¼æ¾å¼ä¿®å¤L2é u åéæä½å¼å¸¸:)!r r ÚlpopÚprintÚllenr r Úl2_data_managerÚis_in_l2_fixed_codesr Ú is_listenÚ
|
is_operateÚget_listen_code_posr Ú trade_managerÚis_in_forbidden_trade_codesÚis_listen_fullÚget_can_listen_posr Úget_operate_code_stateÚget_listen_code_by_posr r ÚtoolÚ is_trade_timer r ÚtimeÚsleepr" ÚloggingÚ exceptionr$ ) Úredisr r: r r& r> ÚstateÚcode_r= r) r+ r r r r, B sb
|
|
|
|
|
|
|
|
|
|
|
|
|
zL2CodeOperate.send_operatec
|
C s6 | j ¡ }td|| | dt ||||d¡¡ d S )NÚ add_operater9 )r: r r= r> )r r rB Úrpushr Údumps)Úselfr: r r= r> rU r r r rX s
|
zL2CodeOperate.add_operatec
|
C sZ t ||¡}|dks |d kr d S t d|||¡ | j ¡ }| dt d|||d¡¡ d S )Nr; u8 客æ·ç«¯ä½ç½®ä»£ç ä¿®å¤ï¼client-{}ï¼pos-{},code-{}r9 r< )r: r= r> r ) r rN r r r r rY r rZ )r[ r= r> r rW rU r r r Úrepaire_operate s
|
z L2CodeOperate.repaire_operatec
|
C s t d| ¡ t |¡\}}|d k r|d k rt |¡}t |¡}dt||t|t|dd}| j ¡ }|
|
dt d|||d¡¡ d S )Nu ä¿®å¤å票çL2æ°æ®ï¼Ú repairL2Data)r r Ú min_priceÚ max_price)r r r9 r? )r: r r= r ) r r r rH Úget_limit_up_priceÚget_limit_down_pricer Úfloatr r rY r rZ )r[ r r& r> r_ r^ r rU r r r Úrepaire_l2_data s
|
|
|
z L2CodeOperate.repaire_l2_datac C s t |¡r| d|¡ d S )Nr )r rF rX )r[ r r r r Úremove_l2_listen s
|
z L2CodeOperate.remove_l2_listenc C s" | ¡ d ||¡t ¡ |¡ d S )Nzcode-operate_state-{}-{})r Úsetexr rO Ú
|
get_expire)r r& ÚchannelrV r r r r! ¥ s z$L2CodeOperate.set_operate_code_statec C s* | ¡ d ||¡¡}|d k r&t|S |S )Nzcode-operate_state-{}-{})r Úgetr r )r[ r& rg Úvaluer r r rM © s z$L2CodeOperate.get_operate_code_state)NN)Ú__name__Ú
|
__module__Ú __qualname__Ú_L2CodeOperate__instancer2 ÚRLockr0 Ú redis_managerÚ RedisManagerr Ú classmethodr r Ú staticmethodr r8 r, rX r\ rc rd r! rM r r r r r s ?
|
r c C sr ddi}t | |¡}t |¡}|d dkrft |d ¡}|d }i }x |D ]}|d ||d < qJW |S tdd S )Nr Ú
|
getL2Codesr r r r u! è·å客æ·ç«¯çå¬ä»£ç åºé)r r r r r" )r& r r) ÚcodesÚ result_listÚdr r r Ú get_listen_codes_from_client± s
|
|
rw c C sè t ¡ } xÚ| D ]Ò}yt|}xtddD ]x}t ||¡}|d k rlt|dkrl| |¡|krlt |||¡ q(|d kst|dkr(| |¡d k r(t
|
dd||¡ q(W W q t k
|
rÞ } zt d |t|¡¡ W d d }~X Y qX qW d S )Nr é r@ r; zclient:{} msg:{})Ú data_processÚgetValidL2Clientsrw Úranger rN Úlenrh r r\ rX r" r r# r r$ )Ú
|
client_idsr& Ú index_codesr r r+ r r r Úcorrect_client_codesÁ s
|
""r Ú__main__)r rS ÚosÚqueuer2 ry r rD r rO rI rQ ro Úlogr Úobjectr rw r rj r r r r Ú<module> s&
|
