B
|
Ûg`+ ã @ s d Z ddlZddlZddlZddlZddlZddlZddlZddlZddlm Z ddl
|
Z
|
ddl m Z dd Z dd Zd d
|
Zd d ZdeddZdfddZdd Zdd Zdd Zdd Zdd 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)dgd@dAZ*dhdCdDZ+didEdFZ,dGdH Z-e.dIkre e!dJdK G dLdM dMZ/dNdO Z0dPdQ Z1dRdS Z2dTdU Z3dVZ4dZ5dWZ6dXdY Z7dZd[ Z8d\d] Z9d^d_ Z:d`da Z;e.dIkre<e,dbdcdd dS )ju
|
常ç¨å·¥å
·
|
é N)ÚThread)Úprintlogc s fdd}|S )Nc s t | |d ¡ d S )N)ÚtargetÚargsÚkwargs)r Ústart)r r )Úfn© õ, D:\éåä½å¸\low_suction_hx\utils\tool.pyÚwrapper s zasync_call.<locals>.wrapperr )r r r )r r
|
Ú
|
async_call s r c s i fdd}|S )u6
|
åä¾è£
饰å¨
|
@param cls:
|
@return:
|
c s kr | | < S )Nr )r r )ÚclsÚ instancesr r
|
Ú get_instance! s z singleton.<locals>.get_instancer )r r r )r r r
|
Ú singleton 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ÚrandomZrandint)ÚnowÚendZ
|
local_timeZexpirer r r
|
Ú
|
get_expire) s r c C s t j ¡ } | S )N)Údatetimer )Údater r r
|
Ú get_now_date4 s
|
r ú%Y-%m-%dc C s t j ¡ | ¡}|S )N)r r r )Úformatr r r r
|
Úget_now_date_str9 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_strE 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_strJ s r( c C s t t ¡ d S )Niè )Úroundr r r r r
|
Úget_now_timestampO s r* c C s | t d¡tj¡S )Nz0.00)ZquantizeÚdecimalZDecimalZ ROUND_HALF_UP)Z_decimalr r r
|
Úto_priceT 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 i0 iô¡ iX¶ i,Ó F)ÚconstantÚTESTr r )Úrelative_timestampÚstart1Úend1Ústart2Úend2r r r
|
Ú is_trade_timeY s .r4 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 )r/ r0 r1 r2 r3 r r r
|
Ú is_alert_timej s .r5 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 )r/ r0 r1 r2 r3 r r r
|
Úis_repaire_timew s .r6 c C s< t ¡ d d } d}d}|| k r,|k r4n ndS dS d S )NiQ ip i
i,Ó FT)r r )r/ r0 r1 r r r
|
Ú is_init_time s r7 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- r. r r )r/ r0 r1 r2 r3 r r r
|
Úis_set_code_time s .r8 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
|
rC c C sP | d¡\}}| d¡}t|d d t|d d t|d d t| S ) NÚ.r> r i r? r# r@ iè )rA r )r& Ús_strÚms_strrB r r r
|
Úget_time_as_millionsecond° s
|
rG 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 rL 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ÚmsrH rI rJ rK r r r
|
Útime_millionseconds_format¾ s rN 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 )rC )Ú
|
time_str_1Ú
|
time_str_2Ú
|
split_timeÚtime_1Útime_2r r r
|
Útrade_time_subÉ s
|
rT 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 )rC rG )rO rP rQ rR rS r r r
|
Útrade_time_sub_with_msÕ s
|
rU )rR rS c C s t | dd¡t | dd¡ S )Nr> Ú )r Úreplace)rR rS r r r
|
Ú compare_timeá s rX c C s0 t | dd¡ dd¡t | dd¡ dd¡ S )Nr> rV rD )r rW )rR rS r r r
|
Úcompare_time_with_mså s rY c C sf | d¡}t|d d t|d d t|d }|| }|d krR|kr^n n|d7 }t|S ) Nr> r i r? r# r@ i¸¡ i )rA r rL )r& ÚsecondrB Ús_rK 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 ) NrD r> r i r? r# r@ iè iÀ¶wiÀeR )rA r rN )r& Z millionsecondrE rF rB r[ Zms_rM 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 )Nr> r i r? r# r@ é )rA r rL )Ztime_rB rK Zchar r r
|
Úcompute_buy1_real_time s
|
, r_ c C sX d}xN| D ]F}t |}|dkr$d}n d| kr8dkrDn n|d8 }|t|7 }q
|
W |S )NrV i 0 é iÿ i^ÿ iàþ )ÚordÚchr)ZustringZrstringZucharZ inside_coder r r
|
ÚstrQ2B s
|
rc ú%H:%M:%Sc C s t j | ¡ |¡S )N)r Ú fromtimestampr )Ztimestamp_secondZformat_r r r
|
Ú to_time_str s rf Fc C s` | d }|r t |d ¡d }nt |d ¡d }| d }|sRtt||d dS t||S d S )Ng\Âõ(\ï?iè éd g¹?g©?r@ )ÚmathÚceilr) Úmin)ÚpriceÚis_cbÚprice1Úprice2r r r
|
Úget_buy_min_price s ro c C sD | d }|r t |d ¡d }nt |d ¡d }| d }t||S )NgR¸
ëQð?iè rg g¹?)rh ri Úmax)rk rl rm rn r r r
|
Úget_buy_max_price( s rq c C s t t| d dS )Ng¸
ëQ¸?r@ )r) ro )rk r r r
|
Úget_shadow_price3 s rr Ú__main__z13:00:01z11:29:55c @ s0 e Zd Zedd Zedd Zedd ZdS )ÚCodeDataCacheUtilc C s ||kr| |¡ d S )N)Úpop)r Ú
|
cache_dictÚcoder r r
|
Ú clear_cacheB s z CodeDataCacheUtil.clear_cachec C s |||< d S )Nr )r rv rw Údatar r r
|
Ú set_cacheG s zCodeDataCacheUtil.set_cachec C s ||krd| |¡fS dS )NT)FN)Úget)r rv rw r r r
|
Ú get_cacheK s zCodeDataCacheUtil.get_cacheN)Ú__name__Ú
|
__module__Ú __qualname__Ú classmethodrx rz r| r r r r
|
rt @ s rt c C s2 | d¡dks*| d¡dks*| d¡dkr.dS dS )NÚ00r Ú60Ú30TF)Úfind)rw r r r
|
Úis_can_sell_codeS s *r
c C s( | d¡dks | d¡dkr dS dS d S )Nr r r gñ?g333333ó?)r )rw r r r
|
Úget_limit_up_rateY s r c C s( | d¡dks | d¡dkr dS dS d S )Nr r r gÍÌÌÌÌÌì?gé?)r )rw r r r
|
Úget_limit_down_ratea s r c C s< y*t ¡ rt ¡ jS t d¡ d¡} | S W n Y nX d S )Nz libc.so.6éº )r- Z
|
is_windowsÚ threadingÚcurrent_threadÚidentÚctypesZCDLLZsyscall)Z thread_idr r r
|
Ú get_thread_idi s
|
r r? éÿÿÿÿ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 r Ú12r Ú68Ú11N)r ÚMARKET_TYPE_SZSEÚMARKET_TYPE_SSEÚMARKET_TYPE_UNKNOWN)rw r r r
|
Úget_market_type} s
|
**r c C s t | tkS )u7
|
æ¯å¦æ¯ä¸è¯
|
@param code:
|
@return:
|
)r r )rw r r r
|
Ú
|
is_sh_code s r c C s t | tkS )u7
|
æ¯å¦æ¯æ·±è¯
|
@param code:
|
@return:
|
)r r )rw r r r
|
Ú
|
is_sz_code s r c C s | d¡dkp| d¡dkS )u:
|
æ¯å¦æ¯å¯è½¬åº
|
@param code:
|
@return:
|
r r r )r )rw r r r
|
Ú
|
is_cb_code s r c C s8 | d¡dkp6| d¡dkp6| d¡dkp6| d¡dkS )u=
|
æ¯å¦æ¯è¡ç¥¨ä»£ç
|
:param code:
|
:return:
|
r r r r r )r )rw r r r
|
Úis_stock¦ s r g Zd;ßY@T)rl )r )r )rd )F)F)=Ú__doc__r r+ rh r r r r r r r- Zlog_module.logr r r r r r! r% r' r( r* r, r4 r5 r6 r7 r8 r= rC rG rL rN rT rU ÚstrrX rY r\ r] r_ rc rf ro rq rr r} rt r
r r r r r r r r r r r Úprintr r r r
|
Ú<module> sz
|
|
|
|
|
|
|
|
|
|
