B
|
ø©c¥& ã @ s\ d dl mZmZ d dlZd dlZd dlZd dlZd dlm Z
|
d dl Z d dl Z d dl Z d dlZd dlZd dlZd dlZd dlZd dlmZ d dlmZmZ e ¡ Zdd Zdd Zd d
|
Z d d Z d d Z dd Z dd Z dd Z!dd Z"i Z#dd Z$dd Z%dd Z&d d Z'd d Z(d!d" Z)G d#d$ d$Z*d%d& Z+d'd( Z,e-d)krXe,d*d+gZ.e/e. dS ),é )Úprint_functionÚabsolute_importN)Ú L2CodeOperate)Úlogger_juejin_tickÚ logger_systemc C s0 t ¡ }| d| ¡ | d|¡ | d|¡ d S )Nzjuejin-account-idzjuejin-strategy-idz juejin-token)Ú redisManagerÚgetRedisÚset)Ú accountIdÚ
|
strategyIdÚtokenÚredis© r ú D:\workspace\trade\juejin.pyÚsetAccountInfo s r c C s0 t ¡ } | d¡}| d¡}| d¡}|||fS )Nzjuejin-account-idzjuejin-strategy-idz juejin-token)r r Úget)r Ú
|
account_idÚ strategy_idr r r r ÚgetAccountInfo" s
|
|
|
|
r c C s2 t d¡ t ¡ t ¡ t g d¡ td d S )Nu æ¯æ¥åå§åT)r ÚinfoÚ global_utilÚ load_industryÚ load_zyltgbÚadd_limit_up_codesÚget_latest_infor r r r Ú everyday_init+ s
|
|
r c C s x t ¡ qW d S )N)ÚscheduleÚ run_pendingr r r r Ú__run_schedule7 s r c C sÒ t d¡ t ¡ j d¡ t¡ tj dd d}|
|
d¡ | ¡ t jt ddd t jt dd
|
d t jt dd d t jtdd d t jtdd d t t ¡ }x,|D ]$}x tddD ]}t ||¡ q¶W q¦W d S )Nu æéåå§åz09:00:00c S s t S )N)r r r r r Ú<lambda>D ó zinit.<locals>.<lambda>)ÚtargetTÚ1dz08:30:00)Ú schedule_funcÚ date_ruleÚ time_rulez08:50:00z09:28:00z09:25:00z09:29:00r é )r r r ÚeveryÚdayÚatÚdor Ú threadingÚThreadÚ setDaemonÚstartÚgmapir Úget_current_infoÚre_subscribe_tickÚ authorityÚget_l2_clientsÚrangeÚgpcode_managerÚinit_listen_code_by_pos)ÚcontextÚt1ÚclientsÚclientÚir r r Úinit< s
|
|
|
r< c
|
C s¼ t ¡ }x0|D ](}x"tddD ]}t t||¡ q W qW t ¡ }t |¡}xj|D ]b}|d }|d }| d¡d }t
|
t t|d ¡¡} |dkrª||kr´t || ¡ qRt |¡ qRW d S )Nr r& Ú sec_levelÚsymbolÚ.é Ú pre_close)r2 r3 r4 r5 r6 ÚintÚ get_gp_listÚ JueJinManagerÚget_gp_latest_infoÚsplitÚtoolÚto_priceÚdecimalÚDecimalÚstrÚ set_price_preÚrm_gp)
|
r7 r9 Úcr; ÚcodesÚresultÚitemr= r> rA r r r r Y s
|
|
|
r c C sX t ¡ } t | ¡}t d|¡ x4|D ],}|d }|d }| d¡d }t|| q$W d S )Nu å®æ¶è·åï¼{}Úpricer> r? r@ )r5 rC rD Úget_gp_current_infor ÚdebugrF Ú accpt_price)ÚdataÚresultsrP rR r> r r r r0 n s
|
|
r0 c C s | g}t | d S )N)Úre_set_price_pres)ÚcoderO r r r Úre_set_price_pre{ s rZ c C sV t | ¡}xF|D ]>}|d }| d¡d }t t t|d ¡¡}t ||¡ qW d S )Nr> r? r@ rA )
|
rD rE rF rG rH rI rJ rK r5 rL )rO rP rQ r> rA r r r rX s
|
|
rX c
|
C s t ¡ d d }d}d}d}d}d}|| k r8|k sTn || k rN|k sTn |r|d }|d } | d
|
¡d }t d || |d ¡¡ t|| | t|< d S )NiQ ip i0 iä¢ ix´ i Ô Fr> rR r? r@ z {} {} {}Ú
|
created_at)ÚtÚtimerF r r ÚformatrU Ú __prices_now)
|
r7 ÚtickÚrelative_timestampÚstart1Úend1Ústart2Úend2Útestr> rR r r r Úon_tick s 0
|
rg c C s¦ t | |¡ t | ¡}|d k r¢t|| d | d}|dkrvt| || t | ¡s¢t | ¡s¢t ¡ s¢t ¡
|
d| ¡ n,|dk r¢t | ¡r¢t | ¡s¢t ¡
|
d| ¡ d S )Néd r@ é é r ) r5 Ú set_priceÚ get_price_preÚroundÚprintÚ is_listenÚ
|
is_operateÚis_listen_fullr Ú get_instanceÚ add_operate)rY rR ÚpricePreÚrater r r rU ¦ s
|
rU c C s t d| d S )NÚon_bar)rn )r7 Úbarsr r r rv ¸ s rv c C s6 t ¡ } d | ¡}td| tj|dddddd d S ) Nú,u 订é
ï¼r` é FÚ10sT)ÚsymbolsÚ frequencyÚcountÚ
|
wait_groupÚwait_group_timeoutÚunsubscribe_previous)r5 Úget_gp_list_with_prefixÚjoinrn r/ Ú subscribe)Ú gpcode_listÚ codes_strr r r r1 ¼ s
|
|
|
r1 c C s2 t ¡ } d | ¡}td| tj|dddd d S )Nrx u 订é
ï¼Ú60sr@ T)r{ r| r} r )r5 r r rn r/ r )r r
r r r Úre_subscribe_barÅ s
|
|
|
|
r c
|
C s¦ x | ¡ }td| t |¡}|d }|dkr6t q|dkry0|d }x"|D ]}t|d t|d qNW W q tk
|
r } ztt| W d d }~X Y qX qW d S )Nu è·¨è¿ç¨éä¿¡ï¼ÚtypeÚresubrU rV rY rR ) Úrecvrn ÚjsonÚloadsr1 rU ÚfloatÚ ExceptionrK )ÚpipeÚvalueÚ jsonValueÚactionÚdatasrV Úer r r Ú recieve_msgÍ s
|
|
|
r c @ s< e Zd Zdd Zedd Zedd Zdd Zd d
|
Zd S ) rD c s0 | _ tj fddd}| d¡ | ¡ d S )Nc s t S )N)r r )r r r r â r z(JueJinManager.__init__.<locals>.<lambda>)r! T)r r+ r, r- r. )Úselfr r8 r )r r Ú__init__ß s
|
zJueJinManager.__init__c C s> t \}}}t | ¡}t |¡ tjd |¡d}t| |S )Nrx )r{ )r r5 r r/ Ú set_tokenÚget_instrumentsr rn )rO r Ús_idr r{ rV r r r rE æ s
|
|
z JueJinManager.get_gp_latest_infoc C s> t \}}}t | ¡}t |¡ tjd |¡d}t| |S )Nrx )r{ )r r5 r r/ r Úcurrentr rn )rO r r r r{ rV r r r rS ï s
|
|
z!JueJinManager.get_gp_current_infoc C s( t \}}}tj|dtjdd|d d S )Nz juejin.pyz2022-08-18 09:25:00z2022-08-18 10:30:00)r ÚfilenameÚmodeÚbacktest_start_timeÚbacktest_end_timer )r r/ ÚrunÚ MODE_LIVE)r r r r r r r r. ø s zJueJinManager.startc C s t ¡ d S )N)r/ Ústop)r r r r r¢ s zJueJinManager.stopN) Ú__name__Ú
|
__module__Ú __qualname__r Ú staticmethodrE rS r. r¢ r r r r rD Þ s
|
|
rD c C sF t \}}}t |¡ t |¡ tj| |tjtjtjd}t| d S )N)r> ÚvolumeÚsideÚ
|
order_typeÚposition_effect) r r/ r Úset_account_idÚ order_volumeÚOrderSide_SellÚOrderType_MarketÚPositionEffect_Closern )rY r§ r r r rP r r r Útrade s
|
|
r° c C sö t j ¡ }t jdd}|| }t \}}}t |¡ t |¡ tjt | ¡dd
|
|¡dd
|
|¡d}t t | i }x||D ]t} | d d¡d }
|
t| d
|
} d
|
| d ¡} | |
|
¡d krÆ| | d ||
|
< | ||
|
d krâ| ||
|
d < | ||
|
d< qzW |S )NéZ )Údaysr" z {:%Y-%m-%d}zsymbol,volume,eob)r> r| Ú
|
start_timeÚfieldsÚend_timer> r? r@ r§ Úeob)Ú
|
max_volumnÚ latest_volumnr· r¸ )ÚdatetimeÚnowÚ timedeltar r/ r r« Úhistoryr5 r r^ rn ÚlenrF rB r ) rO ÚendÚchar. r r r rW Ú_fresultrP rY Úvolumnr( r r r Ú get_volumns s,
|
|
|
|
r Ú__main__Ú000333Ú002531)0Ú
|
__future__r r r¹ r r] r\ r Úgm.apiÚapir/ r r5 r+ ÚserverrG Ú redis_managerr2 rI Úl2_code_operater Úlogr r Ú RedisManagerr r r r r r< r r0 rZ rX r_ rg rU rv r1 r r rD r° r r£ rÀ rn r r r r Ú<module> sL (
|
|
|
