B
|
f¥dW ã @ sJ d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlmZ d dlm Z m
|
Z
|
d dl m Z dZ dZdZdZd Zd
|
Zd
|
Zd
|
Zd
|
Zd
|
Zd
|
Zd
|
Zd
|
Zd
|
Zd d d ddddddddddddddd gZd d gZ d dd d!d"d#d$d%d&d'd(d)d*d+d,gZ d-d.d/gZ G d0d1 d1ej Z G d2d3 d3eZ!d4d5 Z"d6d7 Z#d;d8d9Z$e%d:krFe$ e& dS )<é N)ÚL2ActionCallback)Úlogger_l2_orderdetailÚlogger_l2_transaction)ÚSendResponseSkManagerztcp://10.0.1.101:6900zudp://224.224.2.19:7889zudp://224.224.224.234:7890z 192.168.84.75z
|
10.0.1.101Fs 603000s 600225s 600469s 600616s 600059s 002849s 605188s 603630s 600105s 603773s 603915s 603569s 603322s 603798s 605198s 603079s 600415s 600601s 018003s 113565s 002456s 002281s 002336s 000936s 000920s 000757s 002896s 002725s 000952s 000526s 000753s 000681s 002088s 002436s 100303s 109559s 112617c @ sâ e Zd Ze Zi Zi Zdd Zdd Zdd Z dd Z
|
d d
|
Z d d Z d d Z dd Zdd Zdd Zdd Zdd Zdd Zdd Zd d Zd d Zd!d" Zd#d$ Zd%d& Zd'd( Zd)d* Zd+d, Z d-d. Z d/d0 Z d1d2 Z d3S )4Ú Lev2MdSpic C s t j | ¡ || _d| _d S )NF)Ú lev2mdapiÚCTORATstpLev2MdSpiÚ__init__Ú_Lev2MdSpi__apiÚis_login)ÚselfÚapi© r ú)D:\workspace\GP\trade_huaxin\l2_client.pyr - s zLev2MdSpi.__init__c
|
s t d| dd fdd} fdd} jsBtjsBtdt }x4|D ],}|d }| |¡ |d
|
|d f j|< qNW | j } j| }t d || x|D ]} t j
|
| ¡ q¤W x|D ]} t j
|
| ¡ q¾W x|D ]} t | ¡ qØW || || | _d S ) NÚset_codes_datac S sX g }g }xF| D ]>}| d¡dkr0| | ¡ ¡ q| d¡dkr| | ¡ ¡ qW ||fS )NZ00r Z60)ÚfindÚappendÚencode)ÚcodesZ
|
szse_codesZ sse_codesÚcoder r r Ú split_codes6 s
|
z-Lev2MdSpi.set_codes_data.<locals>.split_codesc sX | \}}|r0 j |tj¡ j |tj¡ |rT j |tj¡ j |tj¡ d S )N)r
|
ÚSubscribeOrderDetailr ÚTORA_TSTP_EXD_SSEÚSubscribeTransactionÚTORA_TSTP_EXD_SZSE)Ú_codesÚshÚsz)r r r r Ú subscribeA s z+Lev2MdSpi.set_codes_data.<locals>.subscribec sX | \}}|r0 j |tj¡ j |tj¡ |rT j |tj¡ j |tj¡ d S )N)r
|
ZUnSubscribeOrderDetailr r ZUnSubscribeTransactionr )r r r )r r r r Ú unsubscribeP s z-Lev2MdSpi.set_codes_data.<locals>.unsubscribeu L2å°æªç»å½r é é z add del codes) Úprintr ÚconstantZTESTÚ ExceptionÚsetÚaddÚcodes_volume_and_price_dictÚlatest_codes_setÚl2_data_managerZ target_codesÚdiscardZrun_upload_task)
|
r Ú
|
codes_datar r r Údr Z add_codesZ del_codesÚcr )r r r r 3 s.
|
|
|
|
|
|
|
|
zLev2MdSpi.set_codes_datac C s |t ¡ d f| j|< d S )Né )ÚtimeÚ"special_code_volume_for_order_dict)r r Úvolumer r r Ú set_code_special_watch_volumet s z'Lev2MdSpi.set_code_special_watch_volumec C s" t d t ¡ }| j |d¡ d S )NÚOnFrontConnectedr )r" r ZCTORATstpReqUserLoginFieldr
|
Z ReqUserLogin)r Z login_reqr r r r3 x s zLev2MdSpi.OnFrontConnectedc C s t d|d |d ||f |d dkrd| _trT| j ttj¡ | j ttj ¡ t
|
rx| j ttj¡ | j ttj ¡ t r| j ttj¡ | j ttj ¡ tr°| j ttj¡ trÄ| j ttj¡ trØ| j ttj ¡ trì| j ttj ¡ tr| j ttj ¡ tr| j ttj¡ d S )NzAOnRspUserLogin: ErrorID[%d] ErrorMsg[%s] RequestID[%d] IsLast[%d]ZErrorIDZErrorMsgr T) r" r Úg_SubMarketDatar
|
ZSubscribeMarketDataÚ SH_Securitiesr r Ú SZ_Securitiesr Úg_SubTransactionr Úg_SubOrderDetailr Ú g_SubXTSTickZSubscribeXTSTickÚSH_XTS_SecuritiesÚg_SubXTSMarketDataZSubscribeXTSMarketDataÚg_SubBondMarketDataZSubscribeBondMarketDataÚSZ_Bond_SecuritiesÚg_SubBondTransactionZSubscribeBondTransactionÚg_SubBondOrderDetailZSubscribeBondOrderDetailÚ g_SubNGTSTickZSubscribeNGTSTick)r Z pRspUserLoginÚpRspInfoÚ
|
nRequestIDÚbIsLastr r r ÚOnRspUserLogin~ s2 zLev2MdSpi.OnRspUserLoginc C s t d d S )NÚOnRspSubMarketData)r" )r ÚpSpecificSecurityrA rB rC r r r rE ¡ s z Lev2MdSpi.OnRspSubMarketDatac C s t d d S )NÚ OnRspSubIndex)r" )r rF rA rB rC r r r rG ¤ s zLev2MdSpi.OnRspSubIndexc C s t d d S )NÚOnRspSubTransaction)r" )r rF rA rB rC r r r rH § s z Lev2MdSpi.OnRspSubTransactionc C s t d d S )NÚOnRspSubOrderDetail)r" )r rF rA rB rC r r r rI ª s z Lev2MdSpi.OnRspSubOrderDetailc C s t d d S )NÚOnRspSubBondMarketData)r" )r rF rA rB rC r r r rJ s z Lev2MdSpi.OnRspSubBondMarketDatac C s t d d S )NÚOnRspSubBondTransaction)r" )r rF rA rB rC r r r rK ° s z!Lev2MdSpi.OnRspSubBondTransactionc C s t d d S )NÚOnRspSubBondOrderDetail)r" )r rF rA rB rC r r r rL ³ s z!Lev2MdSpi.OnRspSubBondOrderDetailc C s t d d S )NÚOnRspSubXTSMarketData)r" )r rF rA rB rC r r r rM ¶ s z Lev2MdSpi.OnRspSubXTSMarketDatac C s t d d S )NÚOnRspSubXTSTick)r" )r rF rA rB rC r r r rN ¹ s zLev2MdSpi.OnRspSubXTSTickc C s t d d S )NÚOnRspSubNGTSTick)r" )r rF rA rB rC r r r rO ½ s zLev2MdSpi.OnRspSubNGTSTickc C s t d|d |d |d |d |d |d |d |d f x&td |D ]}t d
|
||| f qHW x&td |D ]}t d ||| f qpW d S ) NzOnRtnMarketData SecurityID[%s] LastPrice[%.2f] TotalVolumeTrade[%d] TotalValueTrade[%.2f] BidPrice1[%.2f] BidVolume1[%d] AskPrice1[%.2f] AskVolume1[%d]Ú
|
SecurityIDÚ LastPriceÚTotalValueTradeÚ BidPrice1Ú
|
BidVolume1Ú AskPrice1Ú
|
AskVolume1r z first level buy [%d] : [%d]z first level sell [%d] : [%d])r" Úrange)r ÚpDepthMarketDataÚFirstLevelBuyNumÚFirstLevelBuyOrderVolumesÚFirstLevelSellNumÚFirstLevelSellOrderVolumesÚ buy_indexÚ
|
sell_indexr r r ÚOnRtnMarketDataÀ s zLev2MdSpi.OnRtnMarketDatac C s4 t d|d |d |d |d |d |d f d S )NzmOnRtnIndex SecurityID[%s] LastIndex[%.2f] LowIndex[%.2f] HighIndex[%.2f] TotalVolumeTraded[%d] Turnover[%.2f]rP Z LastIndexZLowIndexZ HighIndexZTotalVolumeTradedZTurnover)r" )r ZpIndexr r r Ú
|
OnRtnIndexÕ s zLev2MdSpi.OnRtnIndexc C s t |d }| j |¡\}}|d kr>|d |d dk rNd S n|d |k rNd S |d dkrâ|d |d |d d|d |d
|
|d d d }|d }|d }|dkr²||d< d|d< n|dkrÊ||d< d|d< td| t |d¡ njt|d | dk rL|d |d |d |d |d
|
|d |d |d |d ¡ d }td| t |¡ t
|
d|d |d |d |d |d
|
|d |d |d |d f ¡ d S )NrP Ú
|
TradePriceÚVolumei ¡ Ú TradeVolumeÚExecTypeó 2Ú2Ú TradeTimeÚMainSeqÚSubSeqÚD)rP ÚPricerb Ú OrderTypeÚ OrderTimerh ri Ú OrderStatusÚBuyNoÚSellNor ÚOrderNOÚ1ÚSideu éç¬å§æTgü©ñÒMbP?) rP ra rc rm rh ri ro rp rd u éç¬æ交zOnRtnTransaction SecurityID[%s] TradePrice[%.2f] TradeVolume[%d] TradeTime[%d] MainSeq[%d] SubSeq[%d] BuyNo[%d] SellNo[%d] ExecType[%s]) Ústrr' Úgetr" r) Úadd_l2_order_detailÚabsÚdecodeZadd_transaction_detailr Úinfo)r Ú pTransactionr Ú
|
min_volumeÚlimit_up_priceÚitemZbuyNoZsellNor r r ÚOnRtnTransactionà sX
|
|
|
|
zLev2MdSpi.OnRtnTransactionc C s` d}t |d }|| jkrX| j| d |d krX| j| d t ¡ krLd}n | j |¡ |s| j |¡\}}|d kr|d |d dk rd S n|d |k rd S |d |d |d |d ¡ |d
|
¡ |d |d |d |d |d ¡ d
|
}td| t |¡ t
|
d|d |d |d |d |d
|
|d |d |d |d |d |d |d |d f ¡ d S )NFrP r rb r Trk i ¡ rs rl rm rh ri rq rn )
|
rP rk rb rs rl rm rh ri rq rn u éç¬å§æz¬OnRtnOrderDetail SecurityID[%s] Price[%.2f] Volume[%d] Side[%s] OrderType[%s] OrderTime[%d] MainSeq[%d] SubSeq[%d] OrderNO[%s] OrderStatus[%s] Info1[%d] Info2[%d] Info3[%d]ZInfo1ZInfo2ZInfo3) rt r0 r/ Úpopr' ru rx r" r) rv r ry )r Ú pOrderDetailZ
|
can_listenr r{ r| r} r r r ÚOnRtnOrderDetail sJ
|
|
|
zLev2MdSpi.OnRtnOrderDetailc C s t d|d |d |d |d |d |d |d |d f x&td |D ]}t d
|
||| f qHW x&td |D ]}t d ||| f qpW d S ) NzOnRtnBondMarketData SecurityID[%s] LastPrice[%.2f] TotalVolumeTrade[%d] TotalValueTrade[%.2f] BidPrice1[%.2f] BidVolume1[%d] AskPrice1[%.2f] AskVolume1[%d]rP rQ rR rS rT rU rV r z first level buy [%d] : [%d]z first level sell [%d] : [%d])r" rW )r rX rY rZ r[ r\ r] r^ r r r ÚOnRtnBondMarketDataG s z Lev2MdSpi.OnRtnBondMarketDatac C sF t d|d |d |d |d |d |d |d |d |d
|
f d S ) NzOnRtnBondTransaction SecurityID[%s] TradePrice[%.2f] TradeVolume[%d] TradeTime[%d] MainSeq[%d] SubSeq[%d] BuyNo[%d] SellNo[%d] ExecType[%d]rP ra rc rg rh ri ro rp rd )r" )r rz r r r ÚOnRtnBondTransaction] s z Lev2MdSpi.OnRtnBondTransactionc C s@ t d|d |d |d |d |d |d |d |d f d S )
|
NzvOnRtnBondOrderDetail SecurityID[%s] Price[%.2f] Volume[%d] Side[%s] OrderType[%s] OrderTime[%d] MainSeq[%d] SubSeq[%d]rP rk rb rs rl rm rh ri )r" )r r r r r ÚOnRtnBondOrderDetaill s z Lev2MdSpi.OnRtnBondOrderDetailc C s t d|d |d |d |d |d |d |d |d f x&td |D ]}t d
|
||| f qHW x&td |D ]}t d ||| f qpW d S ) NzOnRtnXTSMarketData SecurityID[%s] LastPrice[%.2f] TotalVolumeTrade[%d] TotalValueTrade[%.2f] BidPrice1[%.2f] BidVolume1[%d] AskPrice1[%.2f] AskVolume1[%d]rP rQ rR rS rT rU rV r z first level buy [%d] : [%d]z first level sell [%d] : [%d])r" rW )r rX rY rZ r[ r\ r] r^ r r r ÚOnRtnXTSMarketDatay s z Lev2MdSpi.OnRtnXTSMarketDatac C sF t d|d |d |d |d |d |d |d |d |d
|
f d S ) NzuOnXTSTick TickType[%s] SecurityID[%s] Price[%.2f] Volume[%d] TickTime[%d] MainSeq[%d] SubSeq[%d] BuyNo[%d] SellNo[%d]ÚTickTyperP rk rb ÚTickTimerh ri ro rp )r" )r ÚpTickr r r Ú OnRtnXTSTick s zLev2MdSpi.OnRtnXTSTickc C sF t d|d |d |d |d |d |d |d |d |d
|
f d S ) NzyOnRtnNGTSTick TickType[%s] SecurityID[%s] Price[%.2f] Volume[%d] TickTime[%d] MainSeq[%d] SubSeq[%d] BuyNo[%d] SellNo[%d]r rP rk rb r rh ri ro rp )r" )r r r r r Ú OnRtnNGTSTick s zLev2MdSpi.OnRtnNGTSTickN) Ú__name__Ú
|
__module__Ú __qualname__r% r( r' r0 r r r2 r3 rD rE rG rH rI rJ rK rL rM rN rO r_ r` r~ r r r r r
r r r r r r r ( s8 A# 9. r c @ s e Zd Zdd ZdS )ÚMyL2ActionCallbackc
|
C st t d||| y*t |¡ t dt ||ddd¡¡ W n6 tk
|
rn } zt d||t|¡ W d d }~X Y nX d S )Nu æ¥åå°å½ä»¤Zl2_cmdr u 设置æå)r ÚmsgÚcommon) r" Úspir r Zsend_normal_responseZ load_responser$ Zsend_error_responsert )r Z client_idZ
|
request_idr+ Úer r r ÚOnSetL2Position® s
|
z"MyL2ActionCallback.OnSetL2PositionN)r r r r r r r r r ¬ s r c C s` t t ¡ tj} t | d¡}t|a| t¡ | tjkrF| t ¡ n|
|
t t d¡ | ¡ d S )NTÚ )r" r Z CTORATstpLev2MdApi_GetApiVersionZTORA_TSTP_MST_MCASTZ&CTORATstpLev2MdApi_CreateTstpLev2MdApir r Z RegisterSpiZ RegisterFrontÚ Front_AddressZRegisterMulticastÚMulticast_AddressÚLocal_Interface_AddressZInit)Z g_SubModer r r r Ú __init_l2¹ s
|
|
|
r c C sl xfyT| ¡ }|rT| d¡}t |¡}|d dkrT|d d }|d d }t ||¡ W q Y qX qW d S )Nzutf-8ÚtypeZ listen_volumeÚdatar1 r )Úrecvrx ÚjsonÚloadsr r2 )ÚpipeÚvaluer r1 r r r r Ú__receive_from_pipeÙ s
|
|
r c sd t d k r4tj fddd}| d¡ | ¡ t ¡ at t j
|
t j t ¡ t ¡ td d S )Nc s t S )N)r r )r r r Ú<lambda>ë ó zrun.<locals>.<lambda>)ÚtargetTu l2_clientå¯å¨æå)r Ú threadingÚThreadÚ setDaemonÚstartÚcommand_managerZL2CommandManagerZl2CommandManagerZinitr# Z SERVER_IPZ SERVER_PORTr Úrunr" )r Zt1r )r r r© è s
|
r© Ú__main__)N)'r r¤ r/ r¨ r# r) r r Zmylogr r Ú trade_clientr r r ZMulticast_Address2r ZSender_Interface_Addressr4 r7 r8 r9 r; r@ r< r> r? r5 r: r6 r= r r r r r r© r Úinputr r r r Ú<module> sP
|
|
|
|
