B
|
ySg; ã @ sÐ d dl Z d dlZd dlZd dlmZ d dlmZ d dlmZ d dlmZ d dlmZ d dl m
|
Z
|
e
|
Z dd Z d
|
d Z d d Zdd Zdd ZG dd dZdd Zi Zi Zdd Zdd Zdd Zd d ZdS ) é N)Ú l1_data_api)Ú
|
data_cache)Ú basic_methods)Úbuying_strategy)Úselling_strategy)Ú
|
get_loggerc C s$ t | | td td| d S )Nu å¯å¨on_tickz tick-====)Ú __processÚprint)ÚcontextZtick© r õ> D:\éåä½å¸\low_suction_hx\strategy\instant_time_market.pyÚon_tick s
|
r c C s d S )Nr )r
|
Ú current_datar r r r s r c C sì t d¡ xÜzÊyt ¡ } ttjjdd}t ¡ }|| }xT|D ]L}yttj| W q> t k
|
r } zt
|
|¡ t d| W d d }~X Y q>X q>W t dt |d d W n, t k
|
rÒ } zt
|
|¡ W d d }~X Y nX W d t d¡ X q W d S ) Nu get_current_dataè¿å
¥zNopen,high,low,symbol,price,created_at,cum_volume,cum_amount,last_volume,quotes)ÚsymbolsÚfieldsu å¼å¸¸ï¼u è¿è¡ä¸==é u ç§é )ÚloggingÚinfoÚtimeÚcurrentr Ú DataCacheÚ
|
min_stocksr r
|
Ú ExceptionÚ exceptionr ÚroundÚsleep)Ú now_startÚ current_datasÚnow_endZnow_start_to_endr Úerrorr r r Úget_current_data( s$
|
|
|
r! c C s$ |d k r t | |¡ t | |¡ d S )N)r Zgrowth_view_strategyr Z instantaneous_change_strategy)r
|
Ú current_infor r r Ústrategic_thread_managerM s r# c C s¾ t j ¡ d¡}tj|k rº|tjk rntjdkrnt d¡ dt_xz| D ]$}t
|
|d ¡}d|d itj |< qDW nLtjdkrºt d dt_t tjjd d
|
}x"|D ]}d|d itj |d < qW d S ) Nz%H:%M:%SFu= å¨å¼çåå¯å¨ï¼éç¨ãåé«æ°æ®ãè®°å½ å¼çä»·Tr Ú current_openr uL ã没æãå¨å¼çåå
å¯å¨ï¼éç¨ãæéæ°æ®ãè®°å½ å¼çä»·z symbol,open)r r ÚopenÚsymbol)ÚdatetimeÚnowÚstrftimer Úlater_open_bidding_timeÚ opening_timeÚ record_current_open_executionÚloggerr r Úformat_stock_symbolÚall_stocks_current_openr r r Úfiltered_stocks)Ú current_infosÚnow_timer" r& r r r r r Úget_all_stocks_current_openV s
|
|
|
|
|
|
r3 c @ s4 e Zd Zdd Zdd Zdd Zdd Zd d
|
Zd S ) Ú PriceTrackerc C s || _ || _d S )N)Ú current_highÚ current_low)ÚselfZ initial_pricer r r Ú__init__
s zPriceTracker.__init__c C s || _ || _d S )N)r5 r6 )r7 ÚhighÚlowr r r Úset_high_and_low_price s z#PriceTracker.set_high_and_low_pricec C s | |¡ | |¡ d S )N)Úupdate_and_get_highÚupdate_and_get_low)r7 Ú new_pricer r r Úset_current_price s
|
z PriceTracker.set_current_pricec C s || j kr|| _ | j S )N)r5 )r7 r> r r r r< s
|
z PriceTracker.update_and_get_highc C s || j k r|| _ | j S )N)r6 )r7 r> r r r r= s
|
z PriceTracker.update_and_get_lowN)Ú__name__Ú
|
__module__Ú __qualname__r8 r; r? r< r= r r r r r4 s
|
r4 c C s& t j | ¡d k r t j| d S d S d S )Nr$ )r r/ Úget)r& r r r Úget_symbol_current_open¢ s rD c C s| t j ¡ d¡}tj|k rxtjtjk rNt d¡ x@| D ]}t
|
|d ¡}|d }|d }|d d d }t |¡}|st |}|t |< |}|d k r<|dksª|dkrÊ| |¡ |j|jdtj|< q<|dksÚ|dkrú| |¡ |j|jdtj|< q<|dks |dkr<t d | d
|
| d | ¡ | |¡ |j|jdtj|< q<W n*t d ¡ t s¶ttjjd d} xF| D ]>}
|
|
|
d |
|
d |
|
d }} } t dt |< t | | | ¡ qtW xÀ| D ]¸}t
|
|d ¡}|tjjkràq¼|d }t |¡} | sJt|gd d} | d }
|
|
|
d |
|
d |
|
d }} } t d} | t |< t | | | ¡ |d k r¼| |¡ | j| jdtj|< q¼W d S )Nz%H:%M:%SuI ãå¨ãå¼çåå¯å¨ï¼éç¨ãåé«æ°æ®ãè®°å½ æé«æä½ä»·r r r é g )r5 r6 uQ ææ°ä»·åä¹°ä¸ä»·è·å失败ææ误ï¼è·åå°çå½æ¥å½æ¶ææ°ä»·ï¼u ï¼ä¹°ä¸ä»·ï¼u< ãï¼ä¸´æ¶æ§éç¨æ¨æ¶ä»·ä½ä¸ºææ°ä»·ï¼æ¨æ¶ä»·ï¼u ã没æãå¼çåå¯å¨ï¼éç¨ãæéæ°æ®ãåå§å æé«ä»·æä½ä»·ï¼éç¨ãåé«æ°æ®ãæ´æ° æé«æä½ä»·zsymbol,high,low)r r r& r9 r: )r' r( r) r r* ÚLocal_startup_timer+ r- r r r. Ú__current_high_or_low_dictrC r4 r? r5 r6 Ú all_stocks_current_high_and_lowr r r0 r; )r1 r2 r" r& Ú pre_closeZ current_priceZcurrent_quotes_buy_1_priceZ price_trackerZget_current_high_or_lowr r r9 r: Zprice_track_manager r r Ú#get_all_stocks_current_high_and_low° sj
|
|
|
|
|
|
|
|
|
|
|
rJ c C s& t j | ¡d k r t j| d S d S d S )Nr5 )r rH rC )r& r r r Úget_symbol_current_high s rK c C s& t j | ¡d k r t j| d S d S d S )Nr6 )r rH rC )r& r r r Úget_symbol_current_low s rL c C s t ¡ }t| t| xZ| D ]R}y|dk r6td| W q tk
|
rn } zt |¡ td| W dd}~X Y q X q W t ¡ }|| }tdt|d d dS )u=
|
å¤çç°ä»·
|
:param current_infos:
|
:return:
|
Nu å¼å¸¸ï¼u è¿è¡ä¸==r u ç§) r r3 rJ r# r r r r r )r1 r r" r r Z start_to_endr r r Úprocess_current_infos s
|
|
rM )r r r' Ústrategyr r r r r Ústrategy.logging_configr r- r r r! r# r3 r4 rD rG Z__current_high_and_low_dictrJ rK rL rM r r r r Ú<module> s, % - Y
|
