B
|
6Sg ã @ sP d Z ddlZddlZddlZddlZddlmZ ddlmZ ddlm Z ddl
|
m Z e Z e ¡ Z ede dZd Zd
|
Zd Zd Zd d Zdd Zd>ddZdd Zdd Zdd Zdd Zd d Zd d Z d d! Z d"d# Z d$d% Z d&d' Z d(d) Z!d*d+ Z"d,d- Z#d.d/ Z$G d0d1 d1Z%d2d3 Z&d4d5 Z'd6d7 Z(d8d9 Z)d:d; Z*d<d= Z+dS )?u
|
kpl APIæ°æ®è·åä¸å¤ç
|
é N)Ú
|
data_cache)Ú basic_methods)Ú
|
get_logger)Úhx_qc_value_utilu kpl_apiå¼å§è¿è¡--é é é é é c C s: ddd}t j| ||d d dd}|jdkr4td|jS )Nz0application/x-www-form-urlencoded; charset=UTF-8z7Dalvik / 2.1.0(Linux;U;Android 6.0.1;MuMu Build/V417IR))z Content-Typez
|
User-Agent)ZhttpZhttps)ÚdataÚheadersZproxieséÈ u 请æ±åºé)ÚrequestsZpostZ status_codeÚ ExceptionÚtext)Úurlr r Úresponse© r õ2 D:\éåä½å¸\low_suction_hx\strategy\kpl_api.pyÚ__base_request# s
|
r c C s d| d}t d|d}|S )NzOrder=1&a=DaBanList&st=100&c=HomeDingPan&PhoneOSNew=1&DeviceID=a38adabd-99ef-3116-8bb9-6d893c846e23&VerSion=5.8.0.2&Index=0&Is_st=1&PidType=zF&apiv=w32&Type=4&FilterMotherboard=0&Filter=0&FilterTIB=0&FilterGem=0 z,https://apphq.longhuvip.com/w1/api/index.php)r )r )ÚpidTyper Úresultr r r Ú daBanList0 s r Tc C s$ d| r
|
dnd d}t d|d}|S )NzOrder=r r z&a=RealRankingInfo&st=20&apiv=w32&Type=5&c=ZhiShuRanking&PhoneOSNew=1&DeviceID=a38adabd-99ef-3116-8bb9-6d893c846e23&VerSion=5.8.0.2&Index=0&ZSType=4&z,https://apphq.longhuvip.com/w1/api/index.php)r )r )ZorderJingE_DESCr r r r r Ú getMarketIndustryRealRankingInfo9 s r c C s d} t d| d}|S )Nz·Order=1&a=RealRankingInfo&st=20&a=RealRankingInfo&apiv=w35&Type=1&Index=0&c=ZhiShuRanking&VerSion=5.13.0.0&Order=1&PhoneOSNew=1&ZSType=7&DeviceID=d6f20ce9-fa08-31c9-a493-536ebb8e9773&z,https://apphq.longhuvip.com/w1/api/index.php)r )r )r r r r r Ú getMarketJingXuanRealRankingInfoM s r c C sN d| d}t d|d}t |¡}t|d dkr6d S |d rF|d S |d S ) Nz5a=GetStockIDPlate_New&apiv=w32&c=StockL2Data&StockID=z]&PhoneOSNew=1&UserID=0&DeviceID=a38adabd-99ef-3116-8bb9-6d893c846e23&VerSion=5.8.0.2&Token=0&z,https://apphq.longhuvip.com/w1/api/index.php)r Úerrcoder ÚListJXÚList)r ÚjsonÚloadsÚint)Úcoder r r r r ÚgetStockIDPlateU s
|
r" c C s, d| d}t d|d}t |¡}| d¡S )Nz8a=GetStockIDPlate&apiv=w32&Type=2&c=StockL2Data&StockID=z]&PhoneOSNew=1&UserID=0&DeviceID=a38adabd-99ef-3116-8bb9-6d893c846e23&VerSion=5.8.0.2&Token=0&z,https://apphq.longhuvip.com/w1/api/index.php)r r )r r r Úget)r! r r r r r ÚgetCodeJingXuanBlocksc s
|
r$ c C s d| d}t d|dS )NzÈOrder=1&a=ZhiShuStockList_W8&st=30&c=ZhiShuRanking&PhoneOSNew=1&old=1&DeviceID=a38adabd-99ef-3116-8bb9-6d893c846e23&VerSion=5.8.0.2&IsZZ=0&Token=0&Index=0&apiv=w32&Type=6&IsKZZType=0&UserID=0&PlateID=ú&z,https://apphq.longhuvip.com/w1/api/index.php)r )r )Ú
|
plate_coder r r r ÚgetCodesByPlatek s r' c C s d| d}t d|dS )Nz|a=SonPlate_Info&apiv=w32&c=ZhiShuRanking&PhoneOSNew=1&DeviceID=a38adabd-99ef-3116-8bb9-6d893c846e23&VerSion=5.8.0.2&PlateID=r% z,https://apphq.longhuvip.com/w1/api/index.php)r )r )r& r r r r Ú getSonPlater s r( c C s< d| d}t d|d}t |¡}d|kr8|d d¡S d S )Nza=GetStockPanKou_Narrow&apiv=w32&c=StockL2Data&VerSion=5.8.0.2&State=1&PhoneOSNew=1&DeviceID=a38adabd-99ef-3116-8bb9-6d893c846e23&StockID=r% z,https://apphq.longhuvip.com/w1/api/index.php)r ÚrealZactualcirculation_value)r r r r# )r! r r r r r Ú getZYLTAmount
s
|
r* c C s0 d| d|d | d| d}t d|d}|S )Nz#Order=0&a=DailyLimitPerformance&st=zq&apiv=w35&Type=4&c=HomeDingPan&PhoneOSNew=1&DeviceID=a38adabb-99ef-3116-8bb9-6d893c846e24&VerSion=5.13.0.0&Index=r z &PidType=r% z,https://apphq.longhuvip.com/w1/api/index.php)r )r )r ZpageZpageSizer r r r r Ú__getLimitUpInfo s r+ c C s¼ dddddg} g }x| D ]}g }xRt dD ]F}t|d |d d }t |¡}|d
|
d }| |¡ t|d k r*P q*W x(|D ] }|d sz|d rz|d |d < qzW | |¡ qW t d|d ¡S ) N)r u é¦æ¿)r u 2è¿æ¿)r u 3è¿æ¿)é u 4è¿æ¿)r
|
Ú é
|
r r é Úinfoé )r Úlist)Úranger+ r r ÚextendÚlenÚdumps)ZpidsÚfresultsZpid_infoÚresultsÚir ÚdatasÚrr r r ÚgetLimitUpInfoNew s
|
|
|
|
r< c
|
|
C s t } t | ¡}t d|d ¡ t d|d d ¡ i }d|krx.|d D ] }|d }|dkstd|krVt|d }t |¡}g }xÆ|d D ]º}|d dkr|d d ¡dk r|d d
|
¡dk r|d d ¡dk r|d d ¡dk r|d d¡s|d d¡r|d dkr|d |d |d |d |d |d |d g}| |¡ qW t |dkrV|d |i} |
|
| ¡ qVW t d| ¡ |S )Nz market_sift_plate['list']======r2 z$market_sift_plate['list'][0] ======r r ) u ç§åæ¿u å交æu 次æ°è¡u æ u STæ¿åu STæ帽u 并è´éç»u å½ä¼æ¹é©u è¶
è·u 壳èµæºu è¡æ转让u é转填æu å¢é¿é ÚSTZXDé u æ¿é Ú60Ú00é r, r é( u( ç²¾éæ¿åè¡ç¥¨å¼ºåº¦æ°æ®æ´æ° == ) r r r Úloggerr0 r' ÚfindÚ
|
startswithÚappendr5 Úupdate)
|
r Zmarket_sift_plateÚ market_sift_plate_stock_dictr9 Z
|
plate_nameZ its_stockZstock_power_listÚsÚits_stock_powerZstock_power_itemr r r Ú%get_market_sift_plate_its_stock_powerÒ s.
|
|
|
J4. rM c
|
C sb x\zJyt }| | W n2 tk
|
rH } zt d| ¡ W d d }~X Y nX W d t d¡ X qW d S )Nu4 å¼çå¦æ¿å强度线ç¨æ¥éAn error occurred: r )rM r rE ÚerrorÚtimeÚsleep)ÚcallbackrL Úer r r Ú-get_market_sift_plate_its_stock_power_process s &rS c C s t t ¡d } | S )Nr2 )r r r< )Ú limit_up_infor r r Úget_limit_up_info s rU c C s$ t dd} t | ¡}t|d d S )u)
|
è·åå¸åºå¼ºåº¦
|
:return:
|
z.https://apphwhq.longhuvip.com/w1/api/index.phpzpa=DiskReview&apiv=w35&c=HomeDingPan&VerSion=5.13.0.0&PhoneOSNew=1&DeviceID=d6f20ce9-fa08-31c9-a493-536ebb8e9773&r0 Zstrong)r r r r )r r r r r Úget_market_strong s
|
rV c C s t } t t_g }tj ¡ d¡}x| D ]}| |d ¡ q(W |tjkrt |¡}t
|
|dkrt dddd}| |¡ W d Q R X |S )Nz%H:%M:%Sr
|
r z,local_storage_data/limit_up_block_names.jsonÚwzutf-8)Úencoding) rU r rT ÚdatetimeÚnowÚstrftimerH Úafter_closing_timer r6 r5 ÚopenÚwrite)rT Úlimit_up_block_namesÚnow_timer9 Ú json_dataÚfr r r Úget_limit_up_block_names- s
|
|
|
rc c
|
C sb x\zJyt }| | W n2 tk
|
rH } zt d| ¡ W d d }~X Y nX W d t d¡ X qW d S )Nu: å¼çå¦æ¶¨åæ¿åæ¦å¿µçº¿ç¨æ¥éAn error occurred: g ø?)rc r rE rN rO rP )rQ r_ rR r r r Úkpl_limit_up_processO s &rd c @ s. e Zd Zd ddZdd Zdd Zdd Zd
|
S ) Ú DailyLimitUpInfoStorageManagerú1local_storage_data/limit_up_block_date_data.jsonlc C s
|
|| _ d S )N)Ú file_path)Úselfrg r r r Ú__init__e s z'DailyLimitUpInfoStorageManager.__init__c
|
C sØ t | jddd¾}tj ¡ d¡}dd |D }|r|d |¡d krtj||idd d
|
}t | jd dd}| |¡ W d Q R X qÊt d n<tj||idd d
|
}t | jd dd}| |¡ W d Q R X W d Q R X d S ) Nr; zutf-8)rX z%Y-%m-%dc S s" g | ]}| ¡ rt | ¡ ¡qS r )Ústripr r )Ú.0Úliner r r ú
|
<listcomp>o s zFDailyLimitUpInfoStorageManager.append_data_to_file.<locals>.<listcomp>éÿÿÿÿF)Ú ensure_asciiÚ
|
ÚauQ ï¼å½æ¥æ¥æå·²åå¨äºæ件çæåä¸è¡äºï¼ä¸åéå¤è¿½å åå
¥ï¼)
|
r] rg rY rZ r[ r# r r6 r^ Úprint)rh Zdata_to_appendÚfileÚ current_dateÚlinesZ json_liner r r Úappend_data_to_filei s
|
z2DailyLimitUpInfoStorageManager.append_data_to_filec C s t | jddd}dd |D }W d Q R X t||kr|| d
}t | jddd,}x$|D ] }| tj|ddd ¡ q\W W d Q R X d S )
|
Nr; zutf-8)rX c S s" g | ]}| ¡ rt | ¡ ¡qS r )rj r r )rk rl r r r rm
s zPDailyLimitUpInfoStorageManager.check_and_remove_oldest_entry.<locals>.<listcomp>rW F)ro rp )r] rg r5 r^ r r6 )rh Ú max_entriesrs ru Úobjr r r Ú check_and_remove_oldest_entry s
|
z<DailyLimitUpInfoStorageManager.check_and_remove_oldest_entryc C sx i }t | jdddZ}xR|D ]J}| d¡}t |¡}t|tr t|dkr t| ¡ d \}}|||< q W W d Q R X |S )Nr; zutf-8)rX rp r r )
|
r] rg Úrstripr r Ú
|
isinstanceÚdictr5 r2 Úitems)rh Z
|
limit_infors rl r0 Údater r r r Úarrange_limit_up_info s
|
|
|
z4DailyLimitUpInfoStorageManager.arrange_limit_up_infoN)rf )Ú__name__Ú
|
__module__Ú __qualname__ri rv ry r r r r r re c s
|
re c C s" t } | t ¡ | jdd d S )Niè )rw )re rv rU ry )Úmanagerr r r Úget_arrange_limit_up_info£ s r c C sp t } | ¡ t_ttj}g }t ¡ j}x@t|D ]4}t |¡}d}t
|
j
|
||¡ d¡}| |¡ |}q2W g }x|tj ¡ D ]n\} }
|
xd|D ]\}| |krg } x.|
|
D ]&} | d | d i} | | kr| | ¡ qW t| dd dd}| |¡ qW qzW dd }tj t ¡ j¡}|d k rlg }x*|D ]"}t |d
|
¡}|}| |¡ qW |t_t d ttj ¡ t d | ¡ d S ) Nz%Y-%m-%dr
|
r/ c S s t | ¡ d S )Nr )r2 Úvalues)Úxr r r Ú<lambda>Ú ó z,get_handling_limit_up_info.<locals>.<lambda>T)ÚkeyÚreversec S s i }xH| D ]@}x:|D ]2}x,|D ]$}||kr2d||< || d7 < q W qW q
|
W x4| ¡ D ](\}}|dkrXt d| d| d¡ qXW d S )Nr r ú'u ' è¿ç»åºç° u 次)r} rE r0 )Zlist_of_dicts_listsZ
|
key_countsZsublistZ dict_itemr Úcountr r r Úcount_key_occurrencesä s
|
|
|
z9get_handling_limit_up_info.<locals>.count_key_occurrencesr u æ¨æ¥æ¶¨åè¡ç¥¨æ°é==u æ¨æ¥æ¶¨å代ç å表==)re r r Údaily_limit_up_infor5 Ú DataCacheÚ
|
today_dater3 r Úget_previous_trading_daterY Ústrptimer[ rH r} Úsortedr# Úpre_trading_dayr Úformat_stock_symbolÚ yesterday_limit_up_code_listrE r0 )Zhistory_limit_up_infoZdaily_limit_up_info_lenZ historical_transaction_date_listZdate_of_the_dayr9 Zpre_dateZ date_formatZ target_dateZ!history_sorted_plate_ranking_listr ÚvalueZplate_ranking_listÚvZplate_limit_up_num_dictZsorted_plate_ranking_listr Z pre_trading_day_limit_up_infor Z symbol_codeZ limit_up_coder r r Úget_handling_limit_up_info« sB
|
|
|
|
|
|
|
|
|
r c C sÚ i }x| D ]}zxyB| d¡d }t|}t|}dd |D }||d}|||< W n0 tk
|
r } ztd| W d d }~X Y nX W d X q
|
W t |¡} tddd d
|
}
|
|
|
| ¡ W d Q R X t j
|
¡ } t d | ¡ d S ) NÚ.r c S s g | ] }|d qS )r r )rk Úblockr r r rm U s z-get_all_stocks_plate_dict.<locals>.<listcomp>)Úfree_market_valueÚplateuA è·åå
¨é¨ä¸ªè¡çæ¿å并åå¨çå½æ° An error occurred: z-local_storage_data/all_stocks_plate_dict.jsonrW zutf-8)rX u) åå
¥ææ个è¡æ¿åæ件å®æï¼::) Úsplitr* r" r rr r r6 r] r^ rY rZ rE r0 ) Z stocks_listÚall_stocks_plate_dictr9 r! r Úselected_blocksZselected_plate_listZ
|
block_datarR ra rb r` r r r Úget_all_stocks_plate_dictI s$
|
$
|
|
r¡ c C s d} g }xVt j ¡ D ]H\}}t|d dkr| d7 } t |¡}t j |¡}|d k r| |¡ qW t
|
d| d¡ t
|
d| ¡ d S )Nr r r u æu åªè¡ç¥¨æ¦å¿µä¸ºç©ºu+ 个è¡æåå²K线ä½æ¦å¿µä¸ºç©ºçæï¼) r r r} r5 r r Ú#all_stocks_all_K_line_property_dictr# rH rE r0 )Zhave_no_plate_numZplate_are_null_listÚkr ÚsymbolÚsec_namer r r Úget_have_no_plate_numq s
|
r¦ c C sÖ g }x| D ]~}yF| d¡d }t|}t|}dd |D }|||d}| |¡ W q
|
tk
|
r } zt d| ¡ W d d }~X Y q
|
X q
|
W t |¡} t ddd d
|
}
|
|
|
|
| ¡ W d Q R X t j ¡ } t d | d S ) Nr r c S s g | ] }|d qS )r r )rk r r r r rm s z/stocks_list_selected_blocks.<locals>.<listcomp>)r! r Zselected_blockuG è·åå
¨é¨ä¸ªè¡çç²¾éæ¿å并åå¨çå½æ° An error occurred: z2local_storage_data/stocks_selected_block_data.jsonrW zutf-8)rX u# åå
¥ç²¾éæ¿åæ件å®æï¼::)r r* r$ rH r rE rN r r6 r] r^ rY rZ rr ) Ú
|
min_stocksZstocks_selected_block_datar9 r! r r Zselected_block_listZstocks_selected_block_dictrR ra rb r` r r r Ústocks_list_selected_blocks s$
|
&
|
|
r¨ c
|
C s4 x,zyÞt jdkräi } tj ¡ }t t _t dt j d¡ t jdkrVdt _dt _ ndt j krldk r~n ndt _dt _ nfdt j krdk r¦n nd t _d t _ n>d
|
t j kr¼dk rÎn nd t _d t _ nt jd
|
k räd t _d t _ W n4 t
|
k
|
r } zt d | ¡ W d d }~X Y nX W d t d¡ X qW d S )NTu* 大çè¡æ
æ
绪综å强度 [åæ°]===u åéF i0u é< i N é2 i' é i¸ iè uA è·åå®æ¶å¤§çè¡æ
æ
绪综å强度[åæ°] å½æ°æ¥é: r )r Ú$position_automatic_management_switchrY rZ rV Úreal_time_market_strongrE r0 Úhave_plate_buy_moneyÚhave_strength_buy_moneyr rN rO rP )Ú time_sharing_market_strong_dirtrZ rN r r r Úget_real_time_market_strong° s2
|
|
|
|
|
&r² )T),Ú__doc__r rO rY r Ústrategyr r Ústrategy.logging_configr Úutilsr rE rZ rr ZDABAN_TYPE_BIDDINGZDABAN_TYPE_LIMIT_UPZDABAN_TYPE_OPEN_LIMIT_UPZDABAN_TYPE_LIMIT_DOWNZDABAN_TYPE_EVER_LIMIT_DOWNr r r r r" r$ r' r( r* r+ r< rM rS rU rV rc rd re r r r¡ r¦ r¨ r² r r r r Ú<module> sR
|
|
<7"@ ('
|
