B
|
?þb-# ã @ s" d dl mZmZ d dlZd dlZd dlZd dlmZ d dl
|
Z
|
d dl Z d dl Z d dl Z d dlZd dlZd dlmZ d dlmZ e ¡ Zdd Zdd Zd d
|
Zd d Zd d Zdd Zdd Z i Z dd Z dd Z dd Z dd Z!dd Z"d d Z#G d d d Z$d!d" Z%d#d$ Z&e'd%kr e dS )&é )Úprint_functionÚabsolute_importN)Ú L2CodeOperate)Úlogger_juejin_tickc C s0 t ¡ }| d| ¡ | d|¡ | d|¡ d S )Nzjuejin-account-idzjuejin-strategy-idz juejin-token)Ú redisManagerÚgetRedisÚset)Z accountIdZ
|
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 s t d tjtddd tjtddd tjtddd tjtddd tjtddd t t ¡ }x,|D ]$}x td d
|
D ]}t
|
||¡ q|W qlW d S ) Nu æéåå§åÚ1dz08:30:00)Z schedule_funcZ date_ruleZ time_rulez08:50:00z09:15:00z09:29:00z09:29:35r é ) ÚprintÚgmapiÚscheduleÚget_latest_infoÚget_current_infoÚre_subscribe_tickÚ authorityÚget_l2_clientsÚrangeÚgpcode_managerÚinit_listen_code_by_pos)ÚcontextÚclientsÚclientÚir r r Úinit% s
|
r# c
|
C s´ t ¡ }x0|D ](}x"tddD ]}t t||¡ q W qW t ¡ }t |¡}xb|D ]Z}|d }|d }| d¡d }t
|
t t|d ¡¡} |dkr¢t || ¡ qRt |¡ qRW d S )Nr r Ú sec_levelÚsymbolÚ.é Ú pre_close)r r r r r ÚintÚ get_gp_listÚ JueJinManagerÚget_gp_latest_infoÚsplitÚtoolÚto_priceÚdecimalÚDecimalÚstrÚ set_price_preÚrm_gp)
|
r r Úcr" ÚdataÚresultÚitemr$ r% r( r r r r < s
|
|
|
r c C sX t ¡ } t | ¡}t d|¡ x4|D ],}|d }|d }| d¡d }t|| q$W d S )Nu å®æ¶è·åï¼{}Úpricer% r& r' )r r* r+ Úget_gp_current_infor Údebugr- Ú accpt_price)r6 Úresultsr7 r9 r% r r r r P s
|
|
r c C s | g}t | d S )N)Úset_price_pres)ÚcodeÚcodesr r r r3 ] s r3 c C sV t | ¡}xF|D ]>}|d }| d¡d }t t t|d ¡¡}t ||¡ qW d S )Nr% r& r' r( )
|
r+ r, r- r. r/ r0 r1 r2 r r3 )r@ r7 r8 r% r( r r r r> b s
|
|
r> 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% r9 r& r' z {} {} {}Z
|
created_at)ÚtÚtimer- r ÚinfoÚformatr< Ú __prices_now)
|
r ÚtickZrelative_timestampZstart1Zend1Zstart2Zend2Útestr% r9 r r r Úon_tickn s 0
|
rH 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 ) r Ú set_priceÚ get_price_preÚroundr Ú is_listenÚ
|
is_operateÚis_listen_fullr Ú get_instanceZ add_operate)r? r9 ZpricePreZrater r r r< s
|
r< c C s t d| d S )NÚon_bar)r )r Zbarsr r r rS s rS c C s6 t ¡ } d | ¡}td| tj|dddddd d S ) Nú,u 订é
ï¼rF é FZ10sT)ÚsymbolsÚ frequencyÚcountZ
|
wait_groupZwait_group_timeoutÚunsubscribe_previous)r Úget_gp_list_with_prefixÚjoinr r Ú subscribe)Ú gpcode_listÚ codes_strr r r r s
|
|
|
r c C s2 t ¡ } d | ¡}td| tj|dddd d S )NrT u 订é
ï¼Z60sr' T)rV rW rX rY )r rZ r[ r r r\ )r] r^ r r r Úre_subscribe_bar§ s
|
|
|
|
r_ c C s( x"| ¡ }t| |dkrt qW d S )NÚresub)Úrecvr r )ÚpipeÚvaluer r r Ú recieve_msg¯ s
|
rd c @ s< e Zd Zdd Zedd Zedd Zdd Zd d
|
Zd S ) r+ c s0 | _ tj fddd}| d¡ | ¡ d S )Nc s t S )N)rd r )rb r r Ú<lambda>» ó z(JueJinManager.__init__.<locals>.<lambda>)ÚtargetT)rb Ú threadingÚThreadÚ setDaemonÚstart)Úselfrb Út1r )rb r Ú__init__¸ s
|
zJueJinManager.__init__c C s> t \}}}t | ¡}t |¡ tjd |¡d}t| |S )NrT )rV )r r rZ r Ú set_tokenZget_instrumentsr[ r )r@ r Ús_idr rV r6 r r r r, ¿ s
|
|
z JueJinManager.get_gp_latest_infoc C s> t \}}}t | ¡}t |¡ tjd |¡d}t| |S )NrT )rV )r r rZ r ro Úcurrentr[ r )r@ r rp r rV r6 r r r r: È 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ÚmodeZbacktest_start_timeZbacktest_end_timer )r r ÚrunZ MODE_LIVE)rl r rp r r r r rk Ñ s zJueJinManager.startc C s t ¡ d S )N)r Ústop)rl r r r ru Û s zJueJinManager.stopN) Ú__name__Ú
|
__module__Ú __qualname__rn Ú staticmethodr, r: rk ru r r r r r+ · s
|
|
r+ c C sF t \}}}t |¡ t |¡ tj| |tjtjtjd}t| d S )N)r% ÚvolumeÚsideZ
|
order_typeZposition_effect) r r ro Úset_account_idZ order_volumeZOrderSide_SellZOrderType_MarketZPositionEffect_Closer )r? rz r rp r r7 r r r Útradeß s
|
|
r} c C sê t j ¡ }t jdd}|| }t \}}}t |¡ t |¡ tjt | ¡dd
|
|¡dd
|
|¡d}i }x||D ]t} | d d¡d }
|
t | d
|
} d
|
| d ¡} | |
|
¡d krº| | d ||
|
< | ||
|
d krÖ| ||
|
d < | ||
|
d< qnW |S )NéZ )Údaysr z {:%Y-%m-%d}zsymbol,volume,eob)r% rW Ú
|
start_timeÚfieldsÚend_timer% r& r' rz Zeob)Ú
|
max_volumnÚ latest_volumnr r )ÚdatetimeÚnowÚ timedeltar r ro r| Úhistoryr rZ rD r- r) r ) r@ ÚendZchark r rp r r= Z_fresultr7 r? ZvolumnÚdayr r r Ú get_volumnsè s*
|
|
|
|
r Ú__main__)(Ú
|
__future__r r r
ÚjsonrB rA Zgm.apiZapir r rh r. Ú redis_managerr r0 Úl2_code_operater Úlogr Ú RedisManagerr r r r# r r r3 r> rE rH r< rS r r_ rd r+ r} r rv r r r r Ú<module> s@ (
|
|
