B
|
ɨgÕ ã @ sò d Z ddlZddlZddlZddlZddlmZ ddlmZ ddl m
|
Z
|
i Z dZ dd Z d e fd
|
d Zejd d dZdd Zdd Ze
|
¡ fddZdd Zg Zi Zdd Zdd Zdd Zd d Zd d Z e d!krîej e d d" ¡ e dS )#u
|
åé«å¢å¼æå¡API
|
é N)Ú l1_api_client)Ú logger_debug)Útoolé c C s |t | < d S )N)Ú__response_data)Ú
|
request_idÚ response_data© r õ8 D:\éåä½å¸\low_suction_hx\utils\hx_qc_value_util.pyÚ__set_response_data s r Tc C s\ |rXt ¡ }zHxBt d¡ | tkr0t | ¡}|S t ¡ | |krtd| qW W d X d S )Ng{®Gázt?u 读åå
容è¶
æ¶: request_id=)ÚtimeÚsleepr ÚpopÚ Exception)r ÚblockingÚtimeoutÚ
|
start_timeÚresultr r r
|
Ú__read_response s
|
|
r )Úresponse_queuec C s< x6y$| ¡ }|d }|d }|t|< W q Y qX qW dS )uD
|
读åç»æéå
|
@param response_queue:
|
@return:
|
r ÚdataN)Úgetr )r Úvalr r r r r
|
Ú__set_response' s r c C s* d| dt t ¡ d dt dd¡ S )NZr_Ú_i' r i )Úroundr ÚrandomÚrandint)Útyper r r
|
Ú__get_request_id7 s r c C s t | }t | ||d¡ |S )N)r r r )r Ú request_queueÚ
|
put_nowait)r r r r r r
|
Ú__base_request; s r" c C s t d}d}xptttd ddD ]X}|dkrbt| dd¡tt| dd¡krrd}t| }n|d7 }t| }||kr$P q$W td||| d}t|S )u_
|
è·ååå²K线
|
@param code:
|
@param count:
|
@param end_date:
|
@return:
|
éÿÿÿÿNé ú-Ú Úget_history_k_bars)Ú
|
start_dateÚend_dateÚcode)Úload_latest_trade_calendarÚrangeÚlenÚ__trade_calendar_listÚintÚreplacer" r )r* Úcountr) Ú_countr( Úir r r r
|
r' A s $
|
r' c C s& t d| |d}t|}dd |D S )NÚget_trade_calendar)r( r) c S s8 g | ]0}|d d
d|dd
d|dd
qS )Né r% é é r )Ú.0Úxr r r
|
ú
|
<listcomp>^ s z&get_trade_calendar.<locals>.<listcomp>)r" r )r( r) r Úresultsr r r
|
r4 [ s r4 c C sÜ t str dS t ¡ } t | d¡} tt | d¡| }xtdt|D ]}d| k rbt|d k rn n"||d ||d ft|| < qB|dkrªd||d ft|| < qB||d dft|| < qBW t ¡ t |¡ dS )u2
|
å è½½æè¿ç交ææ¥å
|
@return:
|
Niâÿÿÿim r r$ )
|
r. Ú__trade_calendar_dictr Úget_now_date_strÚdate_subr4 r, r- ÚclearÚextend)r) Údaysr3 r r r
|
r+ f s " r+ c C s t | tkr t | ¡d S dS )u?
|
è·åä¸ä¸ä¸ªäº¤ææ¥
|
@param day:
|
@return:
|
r N)r+ r< r )Údayr r r
|
Úget_previous_trading_date{ s rC c C s t | tkr t | ¡d S dS )u?
|
è·åä¸ä¸ä¸ªäº¤ææ¥
|
@param day:
|
@return:
|
r$ N)r+ r< r )rB r r r
|
Úget_next_trading_date s rD c C s< t ¡ t ¡ a} t jtjt| fdd}| ¡ t| d S )NT)ÚtargetÚargsÚdaemon)ÚmultiprocessingÚQueuer ÚProcessr ÚrunÚstartr )r Úprocessr r r
|
rK s rK c C s6 t d¡ ttddd ttd ttd d S )Né Ú000333é )r1 z
|
2024-12-31z
|
2024-12-30)r r Úprintr' rC rD r r r r
|
Ú__test s
|
rR Ú__main__)rE rG ) Ú__doc__rH r Ú threadingr Ú huaxin_clientr Úlog_module.logr Úutilsr r ZTIMEOUTr r rI r r r" r= r' r4 r. r< r+ rC rD rK rR Ú__name__ÚThreadrL r r r r
|
Ú<module> s4
|
