B
|
èSg® ã @ sø d dl mZmZmZ d dlZd dlZd dlZd dlZd dlZd dl Z d dl
|
Z
|
d dl Z d dl mZ d dl mZ d dlmZ d dl mZmZ e Ze ¡ Zede dd Ze G d
|
d d Ze Zd d Zdd Zdd Z dd Z G dd dZ dS )é )Úprint_functionÚabsolute_importÚunicode_literalsN)Ú
|
data_cache)Ú basic_methods)Ú
|
get_logger)Úhx_qc_value_utilÚtoolu all_K_lineå¼å§è¿è¡--c C s d S )N© r
|
r
|
r
|
õ5 D:\éåä½å¸\low_suction_hx\strategy\all_K_line.pyÚ init_data s r c @ s4 e Zd Zi Zdd Zdd Zdd Zedd Zd S )
|
Ú KLineHistoryc C s d S )Nr
|
)Úselfr
|
r
|
r Ú__init__, s zKLineHistory.__init__c C s || _ || _|| _d S )N)Ú
|
today_dateÚNext_trading_dayÚsymbols)r r r r r
|
r
|
r Úinit/ s zKLineHistory.initc C sÀ t | jd¡}tt ¡ dd¡tdk r6t ¡ j }n
|
t ¡ j}i }xv| j
|
D ]l}|dd
}t ||¡}|s°t j|dd
d|d}|r°t |dd
|d d d ¡|¡ |||< qLW |S )
|
NéZ ú:Ú Z160000iúÿÿÿ)Úend_dater Úbobz%Y-%m-%d)r Úpre_num_trading_dayr Úintr Úget_now_time_strÚreplacer Ú DataCacheÚpre_trading_dayr ÚHistoryKDataManagerÚget_history_barsr Úget_history_k_barsÚsave_history_barsÚstrftime)r Zstart_time_datar Z$all_symbol_K_line_history_90day_dictÚsymbolÚcodeZk_barsr
|
r
|
r Úk_line_history_90day6 s
|
z!KLineHistory.k_line_history_90dayc sL d}d}d}d}d}g }d}d } g }
|
g } t ¡ j |¡} | d d< x>tdt d D ]&} | d d } | d d }t | d d}t | d d}t | d d}t | d d}t |¡}t |}t
|
|¡}t |} | d
|
} | d d
|
}t ||¡}| | d < t|| | d}| | d < tt d d D d}t tt fddd}tt dd D d}t tt fddd}t|| d d}|||||d} d |¡ d | d k rödk s
|
n | | d ¡ ||krtd d d< d| k r8dk rn nDt dkr|t d d d dk r||d krd d d< d| k rdk ràn nDt dkrà|t d d d d k rà||d kràd d d< d| k rødk r@n nDt dkr@|t d d d d!k r@||d kr@d" d d< |dk rt dkr||d krd# d d< nd$ d d< d| k rdk rÒn n6t dkrÒ|t d d d d%krÒd& d d< |dk rt dkr||d! krd' d d< d | d k r$d(k rn nê| d)k r||d! kr|dkrN| } |d7 }|d*kr|
|
rx|
|
d+ d | k rd, | d | d k r¤d-k rn nh|
|
| | f¡ t | d | d d d}| | d d.¡ | d d.¡|f¡ | d d/< nd}d } |dkrÌd}t|| dd%krz|dkrTd0 | d1< n$|dk rld2 | d1< n d3 | d1< nPt|| dd4k r|dkr¦d5 | d1< n$|dk r¾d6 | d1< n d7 | d1< n<|dkräd8 | d1< n$|dk rüd9 | d1< n d: | d1< || dkr@|| dkr2d; | d<< n d= | d<< n(|| dkr\d> | d<< n d? | d<< t|| d@k r t|| d@k r t|| d@k r¾t|| dk r¾dA | d<< n^t|| dk rÞdB | d<< n>t|| d@k rt|| dk rdC | d<< n dD | d<< t|| d@ k rDt|| krän nt|| d@krädE | d<< t|| d@krdF | d<< n^t|| dk r¦dG | d<< n>t|| dk rØt|| dk rØdH | d<< n dI | d<< t|| d@k rZt|| d@k rft|| d@k r&dJ | d<< n>t|| d@k rXt|| dk rXdK | d<< n dL | d<< qZt|| d@krZdM | d<< qZW t|dk rHdN d dO< || dPk rêdQ|t d d d k rØdRk rHn n dS d dO< n^||k r|dk rt dTk rdU d dO< n.||k rH|dk rHt dTk rHdV d dO< d S )WNg{®Gáz?r Úsec_nameé ÚcloseÚhighÚopené ÚlowÚvolumeÚ today_growthZtoday_amplitudec s s | ]}|d V qdS )r* Nr
|
)Ú.0Úir
|
r
|
r ú <genexpr>| s z7KLineHistory.get_property_limit_mark.<locals>.<genexpr>c s | d S )Nr* r
|
)Úii)Ú it_K_liner
|
r Ú<lambda>} ó z6KLineHistory.get_property_limit_mark.<locals>.<lambda>)Úkeyc s s | ]}|d V qdS )r- Nr
|
)r0 r1 r
|
r
|
r r2 ~ s c s | d S )Nr- r
|
)r3 )r4 r
|
r r5 r6 )Úhistorical_high_priceÚhistorical_high_price_indexÚhistorical_low_priceÚhistorical_low_price_indexÚhistorical_average_priceéüÿÿÿé r Zlow_price_aheadÚ risk_positioné r é Ú recent_monster_second_break_riskg¸
ëQ¸ò?gÍÌÌÌÌÌü?Úrecent_second_break_riskg ø?Ú+recent_second_break_near_high_position_riskÚrecent_high_position_riskZhigh_price_aheadgñ?Zrecent_second_crash_riskZrecent_low_position_riskg?é< é éÿÿÿÿg\Âõ(\ï?gR¸
ëQð?z%Y-%m-%d %H:%M:%SZ)rise_and_fall_is_small_start_and_end_dateZ increases_upÚtoday_volume_shapeÚincreases_downZincreases_balancegÍÌÌÌÌÌì?Z decreases_upZdecreases_downZdecreases_balanceZ remained_upZ remained_downZremained_balanceZup_upÚ attributeZup_downZdown_upÚ down_downgü©ñÒMbP?Úone_line_limit_upÚlimit_down_then_limit_upÚ&limit_up_then_limit_down_then_limit_upÚlimit_upÚ frying_plateÚfirst_frying_plateÚ#one_line_limit_up_then_frying_plateÚ3one_line_limit_up_then_frying_plate_then_limit_downÚnot_first_frying_plateÚlimit_up_then_limit_downÚone_line_limit_downÚ
|
limit_downÚtouch_limit_downZlow_amplitude_oscillationZlong_term_amplitudegffffffò?g®Gáz®ï?gq=
|
×£pñ?Z(low_amplitude_oscillation_remains_stableéX Z"low_amplitude_oscillation_and_riseZ%low_amplitude_oscillation_and_decline)r r Úcode_name_dictÚgetÚrangeÚlenÚroundr Úlimit_up_priceÚfloatÚlimit_down_priceÚintraday_growthÚmaxÚminÚupdateÚappendr# Úabs) r4 r$ r8 r: r; r9 r< Zlarge_amplitude_dayZ current_countÚstartÚresultsZ
|
dates_listr' r1 Zprevious_closeZ previous_highÚ current_openZ current_closeÚ current_highÚ current_lowr` rb Zcurrent_today_volumeZcurrent_yesterday_volumeZcurrent_today_growthZcurrent_today_amplitudeZnew_propertiesZaverage_consensus_pricer
|
)r4 r Úget_property_limit_markW s&
|
|
"
|
* * * * .
|
|
0"
|
|
|
|
|
|
|
$$$ . $ $ .
|
|
z$KLineHistory.get_property_limit_markN) Ú__name__Ú
|
__module__Ú __qualname__Úall_stocks_base_K_line_dictr r r& Ú staticmethodrn r
|
r
|
r
|
r r ( s
|
!r c
|
|
sî t ¡ } i }xPt ¡ jD ]B}| | }t |¡}t|}|s<qt ||¡ ||i}| |¡ qW fdd y<t
|
j |ddd}t dddd }| |¡ W d Q R X W n0 tk
|
rÖ } ztd
|
| W d d } ~ X Y nX td t ¡ d S ) Nc sZ t | tjr| d¡S t | tr6 fdd| ¡ D S t | trR fdd| D S | S d S )Nz%Y-%m-%d %H:%M:%Sc s i | ]\}} ||qS r
|
r
|
)r0 ÚkÚv)Úconvert_datetimer
|
r ú
|
<dictcomp>q s zNall_stocks_all_k_line_dict_write.<locals>.convert_datetime.<locals>.<dictcomp>c s g | ] } |qS r
|
r
|
)r0 Úelement)rv r
|
r ú
|
<listcomp>s s zNall_stocks_all_k_line_dict_write.<locals>.convert_datetime.<locals>.<listcomp>)Ú
|
isinstanceÚdatetimer# ÚdictÚitemsÚlist)Úobj)rv r
|
r rv m s
|
|
|
z:all_stocks_all_k_line_dict_write.<locals>.convert_datetimeFr> )Ú ensure_asciiÚindentz;local_storage_data/all_stocks_all_K_line_property_dict.jsonÚwzutf-8)Úencodingz5An error occurred while converting the data to JSON: u åå²k线åå®äºï¼)Úk_line_historyr& r r Úfiltered_stocksÚcopyÚdeepcopyr~ rn rf ÚjsonÚdumpsr+ ÚwriteÚ ExceptionÚprintr r )
|
rr Ú#all_stocks_all_K_line_property_dictr1 Zi_k_lineZ i_k_line_copyZit_K_line_reversedZsymbol_K_line_property_dictÚ json_dataÚfÚerrorr
|
)rv r Ú all_stocks_all_k_line_dict_write[ s&
|
r c C s xt j ¡ D ]\} }d|d krj| t jkr|d d t jkrt d| d|d d d¡ t j | ¡ q t d|d d d|d ¡ q W d S ) NrK r u= å¨K线ä¸æ¨æ¥æ¶¨åï¼ä½æ¯å¨å¼çå¦ä¸æ²¡æï¼key===u å
¬å¸å称===r' ú u! K线ä¸ç¼ºå¤±æ¨æ¥å±æ§é®å¼ z :values[0]===) r r r} Ú yesterday_limit_up_code_listÚ limit_up_typeÚloggerÚinfoÚ'yesterday_frying_plate_last_minute_listrg )r7 Úvaluesr
|
r
|
r Úcheck_limit_up_attribute
s r c
|
C sÞ xÖz®yjt j ¡ d¡} dd }tj| ks:| tjkrr| tjk râ|t ¡ j}|dkrn| tj kràt
|
d nrt
|
dtj d d d d d
|
d t ¡ j d t t d ddd&}t |¡t_ t
|
dttj W d Q R X n|tjj}|dkrt
|
d npt
|
dtj d d d d d
|
dtjj d t t d ddd&}t |¡t_ t
|
dttj W d Q R X W n< tk
|
r° } z t |¡ t
|
d| W d d }~X Y nX W d t j ¡ }| d¡}t d¡ X qW d S )Nz%H:%M:%Sc S s* t jd d d d d
| kr&d}|S d S )Nz SZSE.000034r r é
|
T)r r )Ú target_dateZdata_date_and_target_dater
|
r
|
r Úcheck_data_date§ s z1check_time_and_data_date.<locals>.check_data_dateTu æªå°ã18:31ã ä½ æ¢ææ°æ® ãæ¯ã ä¸ä¸ªäº¤ææ¥æ°æ® ãä¸æ§è¡æåK线ã ε=ε=ε=ε=ε=ε=ε=ε=ε=ε=ε=ε=ε(/â-â)/up æªå°ã18:31ã ä¸ æ¢ææ°æ® ãä¸æ¯ã ä¸ä¸ªäº¤ææ¥æ°æ® æ§è¡æåK线 ãæ¢ææ°æ®æ¥æï¼z SZSE.000034r r r u ä¸ä¸ªäº¤ææ¥ï¼u ãz;local_storage_data/all_stocks_all_K_line_property_dict.jsonÚrzutf-8)r u7 data_cache.all_stocks_all_K_line_property_dictç个æ°u å°äºã18:31ã ä½ æ¢ææ°æ® ãæ¯ã æ¬äº¤ææ¥æ°æ® ãä¸æ§è¡æåK线ã ε=ε=ε=ε=ε=ε=ε=ε=ε=ε=ε=ε=ε(/â-â)/um å°äºã18:31ã ä¸ æ¢ææ°æ® ãä¸æ¯ã æ¬äº¤ææ¥æ°æ® æ§è¡æåK线 ãæ¢ææ°æ®æ¥æï¼u æ¬äº¤ææ¥ï¼u; å®æ¶æ£æµæ¯å¦æåK线线ç¨æ¥éAn error occurred: r( )r{ Únowr# r Ú opening_timeÚ closing_timeÚupdate_data_timer r Úchecking_data_timer r r r+ r Úloadr^ r r ÚloggingÚ exceptionÚtimeÚsleep)Únow_timer Zcheck_pre_trading_dayr Zcheck_today_dater Ú current_timeZformatted_timer
|
r
|
r Úcheck_time_and_data_date sJ
|
|
0
|
|
.
|
|
$
|
|
rª c C sV d}xL| D ]D}d|kr
|
|d dksF|d dksF|d dksF|d dkr
|
|d7 }q
|
W |S )Nr rK rM rN rO rP r( r
|
)Ú k_line_dataÚ limit_up_dayr1 r
|
r
|
r Úcount_limit_up_dayé s
|
r c sf e Zd ZdZdZi Z fddZedd Zdd Z d d
|
Z
|
dd d Z dd Z dd Z dd Z ZS )r Nr c s. | j s(tt| j| f||| _ | ¡ | j S )N)Ú _HistoryKDataManager__instanceÚsuperr Ú__new__Ú _HistoryKDataManager__load_data)ÚclsÚargsÚkwargs)Ú __class__r
|
r r° s zHistoryKDataManager.__new__c C s d S )Nr
|
)r² r
|
r
|
r Z __load_data s z HistoryKDataManager.__load_datac C s( t ¡ d}tj |¡s$t |¡ |S )u5
|
è·åç¼åè·¯å¾
|
@return:
|
z /datas/k_bars)ÚconstantÚget_path_prefixÚosÚpathÚexistsÚmakedirs)r Údir_pathr
|
r
|
r Z__get_cache_dir
|
s
|
z#HistoryKDataManager.__get_cache_dirc C s° | ¡ }g }x`t |¡D ]R\}}}xF|D ]>}| |¡dk r<q(tj ||¡}| d¡d } | | |f¡ q(W qW |r¬|jdd dd |dd
}x|D ]}
|
t |
|
d ¡ qW d S )Nr Ú_c S s t | d dd¡S )Nr ú-r )r r )Úxr
|
r
|
r r5 ! r6 z9HistoryKDataManager.__del_outdate_datas.<locals>.<lambda>T)r7 Úreverser( )
|
Ú#_HistoryKDataManager__get_cache_dirr¸ ÚwalkÚfindr¹ ÚjoinÚsplitrg ÚsortÚremove) r r% r¼ ÚdatasÚrootÚdirsÚfilesÚfileÚpath_ÚdayÚdr
|
r
|
r Z__del_outdate_datas s
|
|
z'HistoryKDataManager.__del_outdate_datasFc C sì | ¡ }| d| d}| d| }tj |¡r:|s:dS || jkrNi | j|< |rÞ|| j| |< g }xR|D ]J} t | ¡}
|
x0|
|
D ](} t|
|
| tjkr~|
|
| d¡|
|
| < q~W |
|
|
|
¡ qjW t |ddd} | | ¡ W dQ R X | |¡ dS ) u½
|
ä¿ååå²K线
|
@param code: 代ç
|
@param day: K线ææ°çæ¥æï¼ådatasææ°ä¸æ¡æ°æ®çæ¥æï¼
|
@param datas: æ°æ®
|
@return:
|
r½ z.txtú/Nz%Y-%m-%d %H:%M:%Szutf-8r )r Úmode)rÁ r¸ r¹ rº Ú)_HistoryKDataManager__history_k_day_datasr r Útyper{ r# rg r+ r Ú'_HistoryKDataManager__del_outdate_datas) r r% rÎ rÈ ÚforceÚ cache_dirÚ file_nameÚpath_strÚfdatasrÏ Úddrt r r
|
r
|
r r" & s&
|
|
|
|
|
z%HistoryKDataManager.save_history_barsc C s
|
|| j kr&|| j | kr&| j | | S | ¡ }| d| d}| d| }tj |¡s\dS t|ddd}| ¡ }|rüt|}xv|D ]n} xh| D ]`}
|
t| |
|
t kr| |
|
|
d¡d kr| |
|
|
d
|
¡d kr| |
|
|
d ¡d krt j | |
|
d ¡| |
|
< qW qW |S W dQ R X dS ) u\
|
è·ååå²K线
|
@param code:
|
@param day:
|
@return:
|
r½ z.txtrÐ Nzutf-8r )r rÑ r¾ r r r z%Y-%m-%d %H:%M:%S) rÒ rÁ r¸ r¹ rº r+ ÚreadlineÚevalrÓ Ústrrà r{ Ústrptime) r r% rÎ rÖ r× rØ r ÚlinerÈ rÏ rt r
|
r
|
r r C s"
|
|
F z$HistoryKDataManager.get_history_barsc C s2 || j kr.|| j | kr.| j | | d d S dS )ud
|
è·åä¹åçæ¶çä»·
|
@param code:
|
@param day:
|
@return:
|
r r) N)rÒ )r r% rÎ r
|
r
|
r Ú get_pre_close] s z!HistoryKDataManager.get_pre_closec C sd | ¡ }t }xPt |¡D ]B\}}}x6|D ].}| |¡dkr*| | d¡d dd
¡ q*W qW |S )uo
|
è·åæä¸å¤©çåå²K线ç代ç æ°æ®
|
@param day:
|
@return: 代ç éå
|
r r½ r( Né )rÁ Úsetr¸ r rà ÚaddrÅ )r rÎ r¼ ÚcodesrÉ rÊ rË rÌ r
|
r
|
r Úget_history_bars_codesh s
|
$z*HistoryKDataManager.get_history_bars_codes)F)ro rp rq r® Z_HistoryKDataManager__dbrÒ r° Ú classmethodr± rÁ rÔ r" r rà rå Ú __classcell__r
|
r
|
)rµ r r û s
|
|
r ) Ú
|
__future__r r r r r¤ r¸ r¦ r{ r r¶ Úutils.juejin_apiÚutilsÚstrategyr r Ústrategy.logging_configr r r r Ú
|
start_timer r r r r r rª r r r
|
r
|
r
|
r Ú<module> s4 .*T
|
