B
|
ªcÀ# ã @ 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 ¡ |¡ xz| D ]r}|d }|dkrVq@|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Útimez00:00:00Ú trade_numÚ_idÚdayiè Ú create_timezths-trade-success-recordé )ÚdatetimeÚnowÚstrftimer
|
r r r r r r% Útr) Ú
|
mongo_dataÚcountÚsave_one)Údatasr, r Útime_strÚdataÚ_timer4 r r r Úsave_trade_success_dataL s
|
r: 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 r) r+ r, iè r- zths-trade-delegate-recordr. ztrade-delegate-latestztrade-delegate-latest-time)r/ r0 r1 r r r% r2 r) 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/ r0 r1 r3 Úfindr )r r, r r r Úget_trade_success_datap 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_dataw s
|
|
rA 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
|
|
rG 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 rI c C s, d}t ¡ }| || ¡ | |t ¡ ¡ d S )Nzforbidden-trade-codes)r
|
r rE rF r r )r r r r r r Ú add_to_forbidden_trade_codes s rJ c C s& t | t | ¡ tj ¡ | ¡ d S )N)rJ Úl2_data_managerÚremove_from_l2_fixed_codesÚl2_code_operateÚ L2CodeOperateÚ get_instanceÚremove_l2_listen)r r r r Úforbidden_trade s
|
rQ c C s d}t ¡ }| || ¡S )Nzforbidden-trade-codes)r
|
r Ú sismember)r r r r r r Úis_in_forbidden_trade_codes£ s rS 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 {}ä¹°å
¥å¼å¸¸{})rS Ú Exceptionr r Ú TRADE_STATE_BUY_CANCEL_SUCCESSr( Úgpcode_managerÚget_limit_up_priceÚprintÚ logger_tradeÚinfor r ÚTRADE_STATE_BUY_PLACE_ORDERÚguiTradeZbuyrK Úadd_to_l2_fixed_codesÚerrorÚstr)r Ú trade_stater# ÚpriceÚer r r Ú start_buyª s4
|
|
|
|
rd 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_DELEGATEDrZ r[ r r ÚTRADE_STATE_BUY_CANCEL_INGr] Z
|
cancel_buyrK rL rU r_ r` )r Úforcera rc r r r Ústart_cancel_buyÌ s
|
|
|
|
ri c C sb | d kr d S xP| D ]H}|d }|d }|dkr0q|d k rt |d dkrt| t|t qW d S )Nr r) z00:00:00Útyper )r rQ r re )r6 r8 r r9 r r r Úprocess_trade_success_dataâ s
|
rk 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 rf r rg ri rV rK rL )r6 r r8 r ra Z ing_codesr r r Úprocess_trade_delegate_datað s"
|
|
|
|
rl 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 rD r r )r Zredis_l2r ÚkZ redis_trader r r Ú __clear_data s
|
rp Ú__main__Z000503)F)(r/ rM r3 r Ú trade_guir r) r2 rK Úlogrm rn r
|
r r\ rf rg rV re r] r r r r$ r( r: r= r? rA rG rI rJ rQ rS rd ri rk rl rp Ú__name__r r r r Ú<module> sL
|
"
|
|
|
