B
|
3 þbÝ" ã @ s, d dl Z d dlZd dlZd dlZd dlmZ d dlZd dlT d dlZd dl T d dl
|
Z
|
e
|
d¡Z d Z dZdZdZdZd Ze Zd
|
d Zd d Zdd Zdd Zdd Zdd Zdd Zdd Zdd Z d d Z d d Z d d! Z d"d# Z d$d% Z!d&d' Z"d3d)d*Z#d+d, Z$d-d. Z%d/d0 Z&e'd1kr(e&d2 dS )4é N)Ú THSGuiTrade)Ú*é é
|
é é é é c C s, t ¡ }| d | ¡¡}|d kr$tS t|S )Nztrade-state-{})Ú__redis_managerÚgetRedisÚgetÚformatÚTRADE_STATE_NOT_TRADEÚint)ÚcodeÚredisÚstate© r ú#D:\workspace\trade\trade_manager.pyÚget_trade_state# s
|
r c C s$ t ¡ }| d | ¡t ¡ |¡ d S )Nztrade-state-{})r
|
r Úsetexr ÚtoolÚ
|
get_expire)r r r r r r Úset_trade_state, s r c C sT t ¡ }| d¡}g }|d k rPx0|D ](}t| |¡| kr$| | dd¡¡ q$W |S )Nz trade-state-*z trade-state-Ú )r
|
r Úkeysr r ÚappendÚreplace)r r r ÚcodesÚkeyr r r Úget_codes_by_trade_state1 s
|
|
r c C s t ¡ }| d|¡ d S )Nztrade-account-canuse-money)r
|
r Úset)Ú client_idÚmoneyr r r r Úset_available_money= s r$ c C s, t ¡ } | d¡}|d kr d S tt|dS )Nztrade-account-canuse-moneyr )r
|
r r ÚroundÚfloat)r Úresultr r r Úget_available_moneyC s
|
|
r( c C s¨ t j ¡ d¡}t ¡ }t j ¡ d¡}| dt ¡ |¡ xh| D ]`}|d |d< ||d< tt t
|
¡ d |d< t d d|d i¡}|d ks|d
|
k r@t d |¡ q@W d S ) Nz%Y%m%dz%H:%M:%Sztrade-success-latest-timeÚ trade_numÚ_idÚdayiè Ú create_timezths-trade-success-recordé )ÚdatetimeÚnowÚstrftimer
|
r r r r r r% ÚtÚtimeÚ
|
mongo_dataÚcountÚsave_one)Údatasr+ r Útime_strÚdatar4 r r r Úsave_trade_success_dataL s
|
r9 c C sÆ t j ¡ d¡}t j ¡ d¡}xn| D ]f}d ||d |d ¡|d< ||d< ttt ¡ d |d < t d
|
d|d i¡}|d k r&t
|
d
|
|¡ q&W t ¡ }| d t ¡ t | ¡¡ | d t ¡ |¡ d S )Nz%Y%m%dz%H:%M:%Sz{}-{}-{}r r2 r* r+ iè r, zths-trade-delegate-recordr- ztrade-delegate-latestztrade-delegate-latest-time)r. r/ r0 r r r% r1 r2 r3 r4 r5 r
|
r r r r ÚjsonÚdumps)r6 r+ r7 r8 r4 r r r r Úsave_trade_delegate_data[ s
|
r< c C s2 t ¡ } tj ¡ d¡}t dd|i¡| d¡fS )Nz%Y%m%dzths-trade-success-recordr+ ztrade-success-latest-time)r
|
r r. r/ r0 r3 Úfindr )r r+ r r r Úget_trade_success_datal s r> c C s> t ¡ } | d¡}| d¡}|d kr,g |fS t |¡|fS d S )Nztrade-delegate-latestztrade-delegate-latest-time)r
|
r r r: Úloads)r r' r7 r r r Úget_trade_delegate_datas s
|
|
r@ c C sH d} t ¡ }| | ¡}|dkr(| | ¡ | | d¡ | | t ¡ ¡ d S )Nzforbidden-trade-codesr Ú000000)r
|
r ÚscardÚdeleteÚsaddÚexpirer r )r r r4 r r r Úinit_forbidden_trade_codes~ s
|
|
rF c C s d}t ¡ }| || ¡ d S )Nzforbidden-trade-codes)r
|
r Úsrem)r r r r r r Ú!remove_from_forbidden_trade_codes s rH c C s, d}t ¡ }| || ¡ | |t ¡ ¡ d S )Nzforbidden-trade-codes)r
|
r rD rE r r )r r r r r r Ú add_to_forbidden_trade_codes s rI c C s& t | t | ¡ tj ¡ | ¡ d S )N)rI Úl2_data_managerÚremove_from_l2_fixed_codesÚl2_code_operateÚ L2CodeOperateÚ get_instanceÚremove_l2_listen)r r r r Úforbidden_trade s
|
rP c C s d}t ¡ }| || ¡S )Nzforbidden-trade-codes)r
|
r Ú sismember)r r r r r r Úis_in_forbidden_trade_codes s rR c
|
C s t | rtdt| }|tkr0|tkr0tdt }|d krFtdt | ¡}|d kr`td|d |krttdyTtd t
|
d | ¡¡ t | t t | |¡ t | ¡ td t
|
d
|
| ¡¡ W nP tk
|
r } z0td t d | t|¡¡ t | | |W d d }~X Y nX d S ) Nu ç¦æ¢äº¤æu 代ç å¤äºä¸å¯äº¤æç¶æu æªè·åå°è´¦æ·å¯ç¨èµéu å°æªè·åå°æ¶¨åä»·éd u è´¦æ·å¯ç¨èµéä¸è¶³u å¼å§ä¹°å
¥u {}å¼å§ä¹°å
¥u ä¹°å
¥ç»æu {}ä¹°å
¥æåu ä¹°å
¥å¼å¸¸u {}ä¹°å
¥å¼å¸¸{})rR Ú Exceptionr r Ú TRADE_STATE_BUY_CANCEL_SUCCESSr( Úgpcode_managerÚget_limit_up_priceÚprintÚ logger_tradeÚinfor r ÚTRADE_STATE_BUY_PLACE_ORDERÚguiTradeZbuyrJ Úadd_to_l2_fixed_codesÚerrorÚstr)r Ú trade_stater# ÚpriceÚer r r Ú start_buy¦ s4
|
|
|
|
rc Fc
|
C sº t | }|tkrd S |s,|tkr,|tkr,d S yBt d | ¡¡ t| t t
|
| ¡ t | ¡ t d | ¡¡ W nF t k
|
r´ } z(t| | t d | t|¡¡ |W d d }~X Y nX d S )Nu {}å¼å§æ¤åu {}æ¤åæåu {}æ¤åå¼å¸¸ï¼{})r ÚTRADE_STATE_BUY_SUCCESSr[ ÚTRADE_STATE_BUY_DELEGATEDrY rZ r r ÚTRADE_STATE_BUY_CANCEL_INGr\ Z
|
cancel_buyrJ rK rT r^ r_ )r Úforcer` rb r r r Ústart_cancel_buyÈ s
|
|
|
|
rh c C s@ | d kr d S x.| D ]&}|d }|d k rt |t t| qW d S )Nr )r rd rP )r6 r8 r r r r Úprocess_trade_success_dataÞ s
|
|
ri c C s | d kr d S g }x@| D ]8}|d }|d k r| |¡ t|}|tkrt|t qW tt}|d k rx4|D ],}||krt|d qht|t t
|
|¡ qhW d S )Nr T) r r r[ r re r rf rh rU rJ rK )r6 r r8 r r` Z ing_codesr r r Úprocess_trade_delegate_dataé s"
|
|
|
|
rj c C s¨ t d¡ ¡ }| d | ¡¡ | d | ¡¡ | d | ¡¡}x|D ]}| |¡ qDW | d | ¡¡ | d | ¡¡ | d | ¡¡ t d¡ ¡ }| d | ¡¡ d S )
|
Nr- zbuy_compute_index-{}zbuy_compute_num-{}zl2-{}-*zl2-data-latest-{}zl2-maxindex-{}zlatest-l2-count-{}r ztrade-state-{})Ú redis_managerÚ RedisManagerr rC r r )r Zredis_l2r ÚkZ redis_trader r r Ú __clear_data s
|
rn Ú__main__Z000503)F)(r. rL r3 r Ú trade_guir r2 r1 rJ Úlogrk rl r
|
r r[ re rf rU rd r\ r r r r$ r( r9 r< r> r@ rF rH rI rP rR rc rh ri rj rn Ú__name__r r r r Ú<module> sL
|
"
|
|
|
