B
|
¡ Kff$ ã @ sÈ d Z ddlZddlZddlZddlZddlZddlZddlZddlZddlm Z ddl
|
m Z ddl m Z dd Zdd Zd
|
d ZdSd dZdTddZdd Zdd Zdd ZdUddZdd Zd d Zd d Zd d! Zd"d# Zd$d% Z d&d' Z d(d) Z d*d+ Z d,d- Z d.d/ Z!d0d1 Z"e#e#d2d3d4Z$e#e#d2d5d6Z%d7d8 Z&d9d: Z'd;d< Z(d=d> Z)dVd@dAZ*dBdC Z+dDdE Z,e-dFkre e!dGdH G dIdJ dJZ.dKdL Z/dMdN Z0dOZ1dZ2dPZ3dQdR Z4e-dFkrÄdS )Wu
|
常ç¨å·¥å
·
|
é N)ÚThread)Úprintlog)Úconstantc s fdd}|S )Nc s t | |d ¡ d S )N)ÚtargetÚargsÚkwargs)r Ústart)r r )Úfn© ú#D:\workspace\trade_cb\utils\tool.pyÚwrapper s zasync_call.<locals>.wrapperr
|
)r r r
|
)r r Ú
|
async_call s r c C s` t t ¡ } t t ¡ d }t dt |¡¡}t t t |d¡¡}|| }|t dd¡7 }|S )NiQ z%Y-%m-%dr i ) ÚintÚtÚtimeÚstrftimeÚ localtimeÚmktimeÚstrptimeÚrandomÚrandint)ÚnowÚendZ
|
local_timeÚexpirer
|
r
|
r Ú
|
get_expire s r c C s t j ¡ } | S )N)Údatetimer )Údater
|
r
|
r Ú get_now_date$ s
|
r ú%Y-%m-%dc C s t j ¡ | ¡}|S )N)r r r )Úformatr r
|
r
|
r Úget_now_date_str) s r c C s8 t t | |¡¡}||d d d 8 }t |t |¡¡S )Né é< )r r r r r r )Zdate_strÚdayr Zt_r
|
r
|
r Údate_sub/ s r$ c C s t j ¡ d¡} | S )Nz%H:%M:%S)r r r )Útime_strr
|
r
|
r Úget_now_time_str5 s r& c C s t j ¡ d¡} | S )Nz%Y-%m-%d %H:%M:%S)r r r )r% r
|
r
|
r Úget_now_datetime_str: s r' c C s t t ¡ d S )Niè )Úroundr r
|
r
|
r
|
r Úget_now_timestamp? s r) ú0.00c C s | t |¡tj¡S )N)ÚquantizeÚdecimalÚDecimalÚ ROUND_HALF_UP)Ú_decimalr r
|
r
|
r Úto_priceD s r0 c C sd t jr
|
dS t ¡ d d } d}d}d}d}|| k r>|k sXn || k rT|k r\n ndS dS d S ) NTiQ ip i0 iô¡ iX¶ i,Ó F)r ÚTESTr r )Úrelative_timestampÚstart1Úend1Ústart2Úend2r
|
r
|
r Ú is_trade_timeI s .r7 c C sZ t ¡ d d } d}d}d}d}|| k r4|k sNn || k rJ|k rRn ndS dS d S ) NiQ ip i\
i|¡ iж iÑ TF)r r )r2 r3 r4 r5 r6 r
|
r
|
r Ú is_alert_timeZ s .r8 c C sZ t ¡ d d } d}d}d}d}|| k r4|k sNn || k rJ|k rRn ndS dS d S ) NiQ ip i\
i|¡ iж iðÒ TF)r r )r2 r3 r4 r5 r6 r
|
r
|
r Úis_repaire_timeg s .r9 c C s< t ¡ d d } d}d}|| k r,|k r4n ndS dS d S )NiQ ip i
i,Ó FT)r r )r2 r3 r4 r
|
r
|
r Ú is_init_timet s r: c C sd t jr
|
dS t ¡ d d } d}d}d}d}|| k r>|k sXn || k rT|k r\n ndS dS d S ) NTiQ ip iØ iä¢ ix´ i Ô F)r r1 r r )r2 r3 r4 r5 r6 r
|
r
|
r Úis_set_code_time~ s .r; c C s dd } | S )Nc s fdd}|S )Nc s: t t ¡ d } | f|}tdt t ¡ d | |S )Niè u æ§è¡æ¶é´)r( r r )r r r Úresult)Úfuncr
|
r Úinfunc s z+run_time.<locals>.decorator.<locals>.infuncr
|
)r= r> r
|
)r= r Ú decorator s zrun_time.<locals>.decoratorr
|
)r? r
|
r
|
r Úrun_time s r@ c C s6 | d¡}t|d d t|d d t|d S )Nú:r i é r" é )Úsplitr )r% Útsr
|
r
|
r Úget_time_as_second s
|
rF c C sP | d¡\}}| d¡}t|d d t|d d t|d d t| S ) NÚ.rA r i rB r" rC iè )rD r )r% Ús_strÚms_strrE r
|
r
|
r Úget_time_as_millionsecond s
|
rJ c C s* | d }| d d }| d }d |||¡S )Ni r" z{0:0>2}:{1:0>2}:{2:0>2})r )ÚsecondsÚhÚmÚsr
|
r
|
r Útime_seconds_format§ s rO c C s< | d }| d }|d }|d d }|d }d ||||¡S )Niè i r" z {0:0>2}:{1:0>2}:{2:0>2}.{3:0>3})r )ZmillionsecondsÚmsrK rL rM rN r
|
r
|
r Útime_millionseconds_format® s rQ c C sb t d}t | }t |}|| k r,|k r:n n
|
|d }n || k rN|k rZn n|d }|| S )Nz11:30:00i )rF )Ú
|
time_str_1Ú
|
time_str_2Ú
|
split_timeÚtime_1Útime_2r
|
r
|
r Útrade_time_sub¹ s
|
rW c C sf t dd }t| }t|}|| k r0|k r>n n
|
|d }n || k rR|k r^n n|d }|| S )Nz11:30:00iè iÀeR )rF rJ )rR rS rT rU rV r
|
r
|
r Útrade_time_sub_with_msÅ s
|
rX )rU rV c C s t | dd¡t | dd¡ S )NrA Ú )r Úreplace)rU rV r
|
r
|
r Ú compare_timeÑ s r[ c C s0 t | dd¡ dd¡t | dd¡ dd¡ S )NrA rY rG )r rZ )rU rV r
|
r
|
r Úcompare_time_with_msÕ s r\ c C sf | d¡}t|d d t|d d t|d }|| }|d krR|kr^n n|d7 }t|S ) NrA r i rB r" rC i¸¡ i )rD r rO )r% ÚsecondrE Ús_rN r
|
r
|
r Útrade_time_add_secondÚ s
|
,r_ c C s | d¡\}}| d¡}t|d d t|d d t|d }|d }|t|7 }|| }|d krt|krn n|d
|
7 }t|S ) NrG rA r i rB r" rC iè iÀ¶wiÀeR )rD r rQ )r% Z millionsecondrH rI rE r^ Zms_rP r
|
r
|
r Ú trade_time_add_millionsecondä s
|
, r` c C sR | d¡}t|d d t|d d t|d }|d d }t|d | S )NrA r i rB r" rC é )rD r rO )Ztime_rE rN Zchar
|
r
|
r Úcompute_buy1_real_timeñ s
|
, rb c C sX d}xN| D ]F}t |}|dkr$d}n d| kr8dkrDn n|d8 }|t|7 }q
|
W |S )NrY i 0 é iÿ i^ÿ iàþ )ÚordÚchr)ZustringZrstringZucharZ inside_coder
|
r
|
r ÚstrQ2Bù s
|
rf ú%H:%M:%Sc C s t j | ¡ |¡S )N)r Ú fromtimestampr )Ztimestamp_secondÚformat_r
|
r
|
r Ú to_time_str s rj c C s, | d }t |d ¡d }| d }t||S )Ng\Âõ(\ï?éd g¹?)ÚmathÚceilÚmax)ÚpriceZprice1Zprice2r
|
r
|
r Úget_buy_min_price s rp c C s t t| d dS )Ng¸
ëQ¸?rC )r( rp )ro r
|
r
|
r Úget_shadow_price s rq Ú__main__z13:00:01z11:29:55c @ s0 e Zd Zedd Zedd Zedd ZdS )ÚCodeDataCacheUtilc C s ||kr| |¡ d S )N)Úpop)ÚclsÚ
|
cache_dictÚcoder
|
r
|
r Ú clear_cache" s z CodeDataCacheUtil.clear_cachec C s |||< d S )Nr
|
)ru rv rw Údatar
|
r
|
r Ú set_cache' s zCodeDataCacheUtil.set_cachec C s ||krd| |¡fS dS )NT)FN)Úget)ru rv rw r
|
r
|
r Ú get_cache+ s zCodeDataCacheUtil.get_cacheN)Ú__name__Ú
|
__module__Ú __qualname__Ú classmethodrx rz r| r
|
r
|
r
|
r rs s rs c C s$ | d¡dks | d¡dkr dS dS )NÚ00r Ú60TF)Úfind)rw r
|
r
|
r Ú is_shsz_code3 s r c C s< y*t ¡ rt ¡ jS t d¡ d¡} | S W n Y nX d S )Nz libc.so.6éº )r Ú
|
is_windowsÚ threadingÚcurrent_threadÚidentÚctypesÚCDLLZsyscall)Ú thread_idr
|
r
|
r Ú get_thread_id9 s
|
r rB éÿÿÿÿc C sd | d¡dks*| d¡dks*| d¡dkr.tS | d¡dksX| d¡dksX| d¡dkr\tS tS dS ) u:
|
æ ¹æ®è¡ç¥¨ä»£ç
|
:param code:
|
:return:
|
r r Z30Z12r Z68Ú11N)r ÚMARKET_TYPE_SZSEÚMARKET_TYPE_SSEÚMARKET_TYPE_UNKNOWN)rw r
|
r
|
r Úget_market_typeM s
|
**r )r )r )r* )rg )5Ú__doc__r r, rl r r r r r r Úlog_module.logr Úutilsr r r r r r$ r& r' r) r0 r7 r8 r9 r: r; r@ rF rJ rO rQ rW rX Ústrr[ r\ r_ r` rb rf rj rp rq r} rs r r r r r r r
|
r
|
r
|
r Ú<module> sj
|
|
|
|
|
|
|
|
|
