B
|
Èd¦d+° ã @ s d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlm Z d dl
|
m Z dZ dZ dZdZdZdZdZd Zd Zd
|
Zd Zd Zd ZG dd dZG dd dejZi a G dd dej Z dd Z dd Z ej!ej" Z#Z$dddZ%e&dkr e% e' dS ) é N)ÚSendResponseSkManager)ÚloggerZ 388000013349Z110808Z0003Z
|
A641420991Z
|
0345104949é é é é é c @ sp e Zd ZdZe Ze Ze Ze Zdd Z dd Z
|
dd Z dd Z d
|
d Z d d Zdd Zdd Zdd ZdS )ÚTradeSimpleApir c C sü || j krtd| | j |¡ | jd7 _t ¡ }| d¡dkrXtj|_t |_
|
n | d¡dkrttj |_t |_
|
||_ tj|_||_||_||_tj|_tj|_tj|_t || j¡}|dkrÎtd| td k røt t d||dd ¡ d
|
¡¡ d S ) Nu ä¸å请æ±å·²ç»æ交ï¼r Ú00r Ú60z ReqOrderInsert fail, ret[%d]Ú listen_volume)ÚcodeÚvolume)ÚtypeÚdatazutf-8) Ú _TradeSimpleApi__buy_sinfo_setÚ ExceptionÚaddÚreq_idÚ traderapiÚCTORATstpInputOrderFieldÚfindÚTORA_TSTP_EXD_SZSEÚ
|
ExchangeIDÚSZSE_ShareHolderIDÚ ShareholderIDÚTORA_TSTP_EXD_SSEÚSSE_ShareHolderIDÚ
|
SecurityIDZTORA_TSTP_D_BuyÚ DirectionÚVolumeTotalOriginalÚSInfoÚ
|
LimitPriceÚTORA_TSTP_OPT_LimitPriceÚOrderPriceTypeÚTORA_TSTP_TC_GFDÚ TimeConditionÚTORA_TSTP_VC_AVÚVolumeConditionÚapiÚReqOrderInsertÚl2pipeÚsendÚjsonÚdumpsÚencode)Úselfr ÚcountÚpriceÚsinfoÚ req_fieldÚret© r6 ú,D:\workspace\GP\trade_huaxin\trade_client.pyÚbuyK s2
|
"zTradeSimpleApi.buyc C s¢ || j krtd| | j |¡ | jd7 _t ¡ }| d¡dkrRtj|_n| d¡dkrhtj |_tj
|
|_ ||_ ||_ t || j¡}|dkrtd| d S )Nu æ¤å请æ±å·²ç»æ交ï¼r r
|
r r z ReqOrderAction fail, ret[%d])Ú%_TradeSimpleApi__cancel_buy_sinfo_setr r r r Ú CTORATstpInputOrderActionFieldr r r r ÚTORA_TSTP_AF_DeleteÚ
|
ActionFlagÚ
|
OrderSysIDr! r) ÚReqOrderAction)r0 r Ú order_sys_idr3 r4 r5 r6 r6 r7 Ú
|
cancel_buy s
|
|
zTradeSimpleApi.cancel_buyc C sR || j krtd| | j |¡ | jd7 _t ¡ }| d¡dkrXtj|_t |_
|
n | d¡dkrttj |_t |_
|
||_ tj|_||_||_td|| |r¬|dkr¬||_|dkr¾tj|_n\|dkrÐtj|_nJ|dkrâtj|_n8|d krôtj|_n&|d
|
krtj|_n|d krtj|_tj|_ tj |_ t || j¡}|dkrNtd | d S ) Nu ä¸å请æ±å·²ç»æ交ï¼r r
|
r r u å pricer r r r é z ReqOrderInsert fail, ret[%d])!Ú _TradeSimpleApi__sell_sinfo_setr r r r r r r r r r r r r ZTORA_TSTP_D_Sellr r r! Úprintr" ZTORA_TSTP_OPT_AnyPricer$ r# ZTORA_TSTP_OPT_BestPriceZTORA_TSTP_OPT_FixPriceZ TORA_TSTP_OPT_FiveLevelPriceZTORA_TSTP_OPT_HomeBestPricer% r& r' r( r) r* )r0 r r1 r2 Ú
|
price_typer3 r4 r5 r6 r6 r7 Úsell² sH
|
|
|
|
|
|
|
|
|
zTradeSimpleApi.sellc C s¢ || j krtd| | j |¡ | jd7 _t ¡ }| d¡dkrRtj|_n| d¡dkrhtj |_tj
|
|_ ||_ ||_ t || j¡}|dkrtd| d S )Nu æ¤å请æ±å·²ç»æ交ï¼r r
|
r r z ReqOrderAction fail, ret[%d])Ú&_TradeSimpleApi__cancel_sell_sinfo_setr r r r r: r r r r r; r< r= r! r) r> )r0 r r? r3 r4 r5 r6 r6 r7 Ú cancel_sellý s
|
|
zTradeSimpleApi.cancel_sellc C sJ | j d7 _ | j }t ¡ }|r&d|_t ||¡}|dkrFtd| |S )Nr r zReqQryOrder fail, ret[%d])r r ZCTORATstpQryOrderFieldZIsCancelr) Z ReqQryOrderr )r0 Ú is_cancelr r4 r5 r6 r6 r7 Úlist_delegate_orders% s z#TradeSimpleApi.list_delegate_ordersc C s@ | j d7 _ | j }t ¡ }t ||¡}|dkr<td| |S )Nr r zReqQryTrade fail, ret[%d])r r ZCTORATstpQryTradeFieldr) Z ReqQryTrader )r0 r r4 r5 r6 r6 r7 Úlist_traded_orders7 s z!TradeSimpleApi.list_traded_ordersc C s@ | j d7 _ | j }t ¡ }t ||¡}|dkr<td| |S )Nr r z ReqQryPosition fail, ret[%d])r r ZCTORATstpQryPositionFieldr) ZReqQryPositionr )r0 r r4 r5 r6 r6 r7 Úlist_positionsA s z TradeSimpleApi.list_positionsc C sH | j d7 _ | j }t ¡ }tj|_t ||¡}|dkrDtd| |S )Nr r z"ReqQryTradingAccount fail, ret[%d])r r Z CTORATstpQryTradingAccountFieldZTORA_TSTP_CID_CNYÚ
|
CurrencyIDr) ZReqQryTradingAccountr )r0 r r4 r5 r6 r6 r7 Úget_money_accountK s z TradeSimpleApi.get_money_accountc C s\ t ¡ }t|_t j|_t|_d|_d|_t j
|
d7 _
|
t |t j
|
¡}|dkrXt d| d S )NÚjiabeizePC;IIP=123.112.154.118;IPORT=50361;LIP=192.168.118.107;MAC=54EE750B1713FCF8AE5CBD58;HD=TF655AY91GHRVLr r zReqUserLogin fail, ret[%d])r ÚCTORATstpReqUserLoginFieldÚUserIDÚ LogInAccountÚTORA_TSTP_LACT_UserIDÚLogInAccountTypeÚPasswordÚUserProductInfoÚ TerminalInfor r r) Ú ReqUserLoginr )r0 Ú login_reqr5 r6 r6 r7 ÚloginU s zTradeSimpleApi.loginN)Ú__name__Ú
|
__module__Ú __qualname__r Úsetr rB r9 rF r8 r@ rE rG rI rJ rK rM rY r6 r6 r6 r7 r C s ?(K(
|
|
|
r c @ s e Zd Zdd ZddddZdddd d
|
Zd d ddd ddZdd dddddZdd dddddZdd dddddZ d d ddd d d Z
|
d d ddd!d"d#Z d$d ddd%d&d'Z d(dd)d*d+Z d,dd-d.d/Zd0dd1d2d3Zd4d dd5dd6d7d8Zd9d dd5dd:d;d<Zd=d dd5dd>d?d@ZdAd dd5ddBdCdDZd(d dd5ddEdFdGZdHd dd5ddIdJdKZd,dd-dLd/Zd,d dd5ddMdNdOZdPS )QÚ TraderSpic C s4 t j | ¡ d| _d| _|| _i | _i | _i | _d S )Nr ) r ÚCTORATstpTraderSpiÚ__init__Ú_TraderSpi__front_idÚ_TraderSpi__session_idÚ_TraderSpi__data_callbackÚ _TraderSpi__temp_order_list_dictÚ#_TraderSpi__temp_position_list_dictÚ(_TraderSpi__temp_money_account_list_dict)r0 Úcallbackr6 r6 r7 r` s zTraderSpi.__init__Zvoid)Úreturnc C s> t d¡ t jd7 _t tj¡}|dkr:t d| ¡ d S )NÚOnFrontConnectedr r z"ReqGetConnectionInfo fail, ret[%d])r Úinfor r r) ZReqGetConnectionInfo)r0 r5 r6 r6 r7 ri s
|
|
zTraderSpi.OnFrontConnectedÚint)ÚnReasonrh c C s t d| ¡ d S )NzOnFrontDisconnected: [%d])r rj )r0 rl r6 r6 r7 ÚOnFrontDisconnected s z TraderSpi.OnFrontDisconnectedZ CTORATstpConnectionInfoFieldÚCTORATstpRspInfoField)ÚpConnectionInfoFieldÚ pRspInfoFieldÚ
|
nRequestIDrh c C sÒ |j dkr¶t d|j ¡ t d|j ¡ t d|j ¡ t d|j ¡ t d|j ¡ t ¡ }t
|
|_ tj |_ t|_d|_d|_t jd 7 _t |tj¡}|dkrÎt d
|
| ¡ nt d ||j |jf ¡ d S ) Nr zinner_ip_address[%s]zinner_port[%d]zouter_ip_address[%s]zouter_port[%d]zmac_address[%s]rN zaPC;IIP=NA;IPORT=NA;LIP=192.168.84.75;MAC=5C6F69CC2B40;HD=004bc76004aff0882b9052ba0eb00506;@jiabeir zReqUserLogin fail, ret[%d]z)GetConnectionInfo fail, [%d] [%d] [%s]!!!)ÚErrorIDr rj ÚInnerIPAddressZ InnerPortÚOuterIPAddressÚ OuterPortÚ
|
MacAddressr rO rP rQ rR rS rT rU rV r r r) rW ÚErrorMsg)r0 ro rp rq rX r5 r6 r6 r7 ÚOnRspGetConnectionInfo s$
|
z TraderSpi.OnRspGetConnectionInfoÚCTORATstpRspUserLoginField)ÚpRspUserLoginFieldrp rq rh c C sP |j dkr4t d| ¡ |j| _|j| _t ¡ nt d||j |j f ¡ d S )Nr zLogin success! [%d]z Login fail!!! [%d] [%d] [%s])
|
rr r rj ÚFrontIDra Ú SessionIDrb r rM rw )r0 rz rp rq r6 r6 r7 ÚOnRspUserLoginÒ s
|
zTraderSpi.OnRspUserLoginZ CTORATstpUserPasswordUpdateField)ÚpUserPasswordUpdateFieldrp rq rh c C s6 |j dkrt d| ¡ nt d||j |jf ¡ d S )Nr z!OnRspUserPasswordUpdate: OK! [%d]z.OnRspUserPasswordUpdate: Error! [%d] [%d] [%s])rr r rj rw )r0 r~ rp rq r6 r6 r7 ÚOnRspUserPasswordUpdateï s
|
z!TraderSpi.OnRspUserPasswordUpdater )ÚpInputOrderFieldrp rq rh c C s` |j dkr*t dtt ¡ d |f ¡ n2t d||j |jf ¡ | t||jd|jd¡ d S )Nr z [%d] OnRspOrderInsert: OK! [%d]iè z'OnRspOrderInsert: Error! [%d] [%d] [%s]éÿÿÿÿ)r3 Ú orderStatusZorderStatusMsg) rr r rj ÚroundÚtimerw rc Ú
|
TYPE_ORDERr! )r0 r rp rq r6 r6 r7 ÚOnRspOrderInsert÷ s
|
zTraderSpi.OnRspOrderInsertr: )ÚpInputOrderActionFieldrp rq rh c
|
C sr |j dkr4t d| ¡ | t||j|jdd¡ n:t d||j |jf ¡ | t||j|jd|j |jd¡ d S )Nr zOnRspOrderAction: OK! [%d]r )r3 Ú
|
orderSysIDÚcancelz'OnRspOrderAction: Error! [%d] [%d] [%s])r3 r r ZerrorIDZerrorMsg)rr r rj rc ÚTYPE_CANCEL_ORDERr! r= rw )r0 r rp rq r6 r6 r7 ÚOnRspOrderAction s
|
zTraderSpi.OnRspOrderActionZ CTORATstpRspInquiryJZFundField)ÚpRspInquiryJZFundFieldrp rq rh c C s@ |j dkr$t d||j|jf ¡ nt d||j |jf ¡ d S )Nr z*OnRspInquiryJZFund: OK! [%d] [%.2f] [%.2f]z)OnRspInquiryJZFund: Error! [%d] [%d] [%s])rr r rj Ú UsefulMoneyÚ
|
FetchLimitrw )r0 r rp rq r6 r6 r7 ÚOnRspInquiryJZFund s
|
|
z TraderSpi.OnRspInquiryJZFundZ CTORATstpInputTransferFundField)ÚpInputTransferFundFieldrp rq rh c C s6 |j dkrt d| ¡ nt d||j |jf ¡ d S )Nr zOnRspTransferFund: OK! [%d]z(OnRspTransferFund: Error! [%d] [%d] [%s])rr r rj rw )r0 r rp rq r6 r6 r7 ÚOnRspTransferFund s
|
zTraderSpi.OnRspTransferFundZCTORATstpOrderField)Ú pOrderFieldrh c C s| t dtt ¡ d |j|j|j|j|j|j |j
|
|j |j f
|
¡ |j t jkrx| td|j|j|j|j |j|j |jd¡ d S )Nz[%d] OnRtnOrder: SInfo[%s] InvestorID[%s] SecurityID[%s] OrderRef[%d] OrderLocalID[%s] LimitPrice[%.2f] VolumeTotalOriginal[%d] OrderSysID[%s] OrderStatus[%s]iè r )r3 Z
|
securityIdZ orderLocalIdr Ú statusMsgr Z accountId)r rj r r r! Ú
|
InvestorIDr ÚOrderRefÚ OrderLocalIDr" r r= Ú OrderStatusr ZTORA_TSTP_OST_Unknownrc r
Ú StatusMsgÚ AccountID)r0 r r6 r6 r7 Ú
|
OnRtnOrder" s zTraderSpi.OnRtnOrderZCTORATstpTradeField)Ú pTradeFieldrh c
|
C s. t d|j|j|j|j|j|j|jf ¡ d S )NzjOnRtnTrade: TradeID[%s] InvestorID[%s] SecurityID[%s] OrderRef[%d] OrderLocalID[%s] Price[%.2f] Volume[%d]) r rj ÚTradeIDr r r r ÚPriceÚVolume)r0 r r6 r6 r7 Ú
|
OnRtnTrade1 s zTraderSpi.OnRtnTradeZCTORATstpMarketStatusField)ÚpMarketStatusFieldrh c C s t d|j|jf ¡ d S )Nz0OnRtnMarketStatus: MarketID[%s] MarketStatus[%s])r rj ÚMarketIDZ MarketStatus)r0 r r6 r6 r7 ÚOnRtnMarketStatus7 s
|
zTraderSpi.OnRtnMarketStatusZCTORATstpSecurityFieldÚbool)ÚpSecurityFieldrp rq ÚbIsLastrh c C sR |dkr6t d||j|j|j|j|j|j|jf ¡ nt d||j |j
|
f ¡ d S )Nr zOnRspQrySecurity[%d]: SecurityID[%s] SecurityName[%s] MarketID[%s] OrderUnit[%s] OpenDate[%s] UpperLimitPrice[%.2f] LowerLimitPrice[%.2f]u/ æ¥è¯¢å约ç»æ[%d] ErrorID[%d] ErrorMsg[%s]) r rj r Ú SecurityNamer¡ Z OrderUnitZOpenDateÚUpperLimitPriceÚLowerLimitPricerr rw )r0 r¤ rp rq r¥ r6 r6 r7 ÚOnRspQrySecurityD s zTraderSpi.OnRspQrySecurityZCTORATstpInvestorField)ÚpInvestorFieldrp rq r¥ rh c C sB |dkr&t d||j|j|jf ¡ nt d||j|jf ¡ d S )Nr zBOnRspQryInvestor[%d]: InvestorID[%s] InvestorName[%s] Operways[%s]u2 æ¥è¯¢æèµè
ç»æ[%d] ErrorID[%d] ErrorMsg[%s])r rj r Z InvestorNameZOperwaysrr rw )r0 rª rp rq r¥ r6 r6 r7 ÚOnRspQryInvestorP s
|
zTraderSpi.OnRspQryInvestorZ CTORATstpShareholderAccountField)ÚpShareholderAccountFieldrp rq r¥ rh c C sB |dkr&t d||j|j|jf ¡ nt d||j|jf ¡ d S )Nr zOOnRspQryShareholderAccount[%d]: InvestorID[%s] ExchangeID[%s] ShareholderID[%s]u5 æ¥è¯¢è¡ä¸è´¦æ·ç»æ[%d] ErrorID[%d] ErrorMsg[%s])r rj r r r rr rw )r0 r¬ rp rq r¥ r6 r6 r7 ÚOnRspQryShareholderAccountZ s
|
z$TraderSpi.OnRspQryShareholderAccountZ CTORATstpTradingAccountField)ÚpTradingAccountFieldrp rq r¥ rh c
|
C s² || j krg | j |< |dkr|| j | |j|j|j|jt|jdt|jdd¡ t
|
d||j|j|j|j|j|jf ¡ n2| j |¡}| t ||¡ t
|
d||j|jf ¡ d S )Nr r )Z departmentIDÚ
|
investorIDÚ accountIDZ
|
currencyIDZ usefulMoneyZ
|
fetchLimitz{OnRspQryTradingAccount[%d]: DepartmentID[%s] InvestorID[%s] AccountID[%s] CurrencyID[%s] UsefulMoney[%.2f] FetchLimit[%.2f]u5 æ¥è¯¢èµéè´¦å·ç»æ[%d] ErrorID[%d] ErrorMsg[%s])rf ÚappendÚ DepartmentIDr r rL r r r r rj Úpoprc ÚTYPE_LIST_MONEYrr rw )r0 r® rp rq r¥ Úresultsr6 r6 r7 ÚOnRspQryTradingAccounte s"
|
|
|
|
|
z TraderSpi.OnRspQryTradingAccount)r rp rq r¥ rh c C sâ t d| || jkr g | j|< |s¦t d||j|j|j|j|j|j |j
|
|j |j f
|
¡ | j| |j|j|j|j|j|j|j|j|j|j|j|j |j
|
|j |j d¡ n8t d||j|jf ¡ | t|| j| ¡ | j |¡ d S )Nu æ¥è¯¢æ¥ååè°z¢OnRspQryOrder[%d]: SecurityID[%s] OrderLocalID[%s] Direction[%s] OrderRef[%d] OrderSysID[%s] VolumeTraded[%d] OrderStatus[%s] OrderSubmitStatus[%s], StatusMsg[%s])Ú
|
securityIDÚ orderLocalIDÚ directionr Z
|
insertTimeZ
|
insertDateZ
|
acceptTimeZ
|
cancelTimeZ
|
limitPriceZturnoverr Z volumeTradedr ZorderSubmitStatusr u/ æ¥è¯¢æ¥åç»æ[%d] ErrorID[%d] ErrorMsg[%s])rC rd r rj r r r r r= Z VolumeTradedr ZOrderSubmitStatusr r± Z
|
InsertTimeZ
|
InsertDateZ
|
AcceptTimeZ
|
CancelTimer" ÚTurnoverr rr rw rc ÚTYPE_LIST_DELEGATEr³ )r0 r rp rq r¥ r6 r6 r7 Ú OnRspQryOrderz s0
|
|
|
|
zTraderSpi.OnRspQryOrderZCTORATstpPositionField)ÚpPositionFieldrp rq r¥ rh c C s° || j krg | j |< |dkrt| j | |j|j|j|j|j|j|j|j |j
|
|j |j |j |j|j|j|j|jd¡ n8t d||j|jf ¡ | t|| j | ¡ | j |¡ d S )Nr )r¯ Ú
|
tradingDayZ securityNamer· Z
|
historyPosZhistoryPosFrozenZ
|
todayBSPosZtodayBSPosFrozenZhistoryPosPriceZ totalPosCostZ prePositionZavailablePositionZcurrentPositionZ openPosCostZtodayCommissionZtodayTotalBuyAmountZtodayTotalSellAmountu/ æ¥è¯¢æä»ç»æ[%d] ErrorID[%d] ErrorMsg[%s])re r± r Ú
|
TradingDayr¦ r Z
|
HistoryPosZHistoryPosFrozenZ
|
TodayBSPosZTodayBSPosFrozenZHistoryPosPriceZ TotalPosCostZ PrePositionZAvailablePositionZCurrentPositionZ OpenPosCostZTodayCommissionZTodayTotalBuyAmountZTodayTotalSellAmountr rj rr rw rc ÚTYPE_LIST_POSITIONr³ )r0 r½ rp rq r¥ r6 r6 r7 ÚOnRspQryPosition s&
|
|
|
zTraderSpi.OnRspQryPositionc C s t d¡ d S )Nr )r rj )r0 r r6 r6 r7 r ¯ s )r rp rq r¥ rh c C s t d¡ || jkr g | j|< |sf| j| |j|j|j|j|j|j |j
|
|j |j |j |j|jd ¡ n | t|| j| ¡ | j |¡ d S )Nu æ¥è¯¢æ交ååº) ZtradeIDr· r¸ r¹ r r2 Z tradeTimer Z tradeDater¾ ZpbuIDr° )r rj rd r± r r r r r= r Ú TradeTimer Z TradeDater¿ ZPbuIDr rc ÚTYPE_LIST_TRADEDr³ )r0 r rp rq r¥ r6 r6 r7 Ú OnRspQryTrade³ s
|
|
|
|
zTraderSpi.OnRspQryTradeN)rZ r[ r\ r` ri rm rx r} r r r r r r r r¢ r© r« r r¶ r¼ rÁ rÄ r6 r6 r6 r7 r^ sH
|
7 r^ c @ s: e Zd Ze Zdd Zdd Zdd Zdd Zd d
|
Z d S ) ÚMyTradeActionCallbackc
|
C sl t dt ¡ |dkrP|d }|d }|d }|d }|d } |dkr¶y"||ft| < | j |||| ¡ W nH tk
|
r² }
|
z*t t ¡
|
t dt |
|
d¡ d ¡¡ W d d }
|
~
|
X Y nX n|d
|
krhy6|d } ||ft| < | j |||| | ¡ t d t W nT tk
|
rJ }
|
z4t |
|
¡ t t ¡
|
t dt |
|
d¡ d ¡¡ W d d }
|
~
|
X Y nX n|d
|
krh|d }|d }|d } |d } |dkròy ||ft| < | j || | ¡ W nJ tk
|
rî }
|
z*t t¡
|
t dt |
|
d¡ d ¡¡ W d d }
|
~
|
X Y nX nv|d
|
krhy ||ft| < | j || | ¡ W nJ tk
|
rf }
|
z*t t¡
|
t dt |
|
d¡ d ¡¡ W d d }
|
~
|
X Y nX d S )Nu 请æ±è¿ç¨IDr r¹ r r r2 r3 )r Úmsgzutf-8r rD rE r )rC ÚosÚgetpidÚ req_rid_dictÚ&_MyTradeActionCallback__tradeSimpleApir8 r r Úget_send_response_skr
Úsendallr- r. Ústrr/ rE ÚloggingÚ exceptionr@ r rG ) r0 Ú client_idÚ
|
request_idÚtype_r r¹ r r r2 r3 ÚerD r r6 r6 r7 ÚOnTradeÏ sV
|
|
0
|
|
|
2
|
|
|
0
|
|
z MyTradeActionCallback.OnTradec
|
C sV y| j ¡ }||ft|< W n6 tk
|
rP } zt d||t|¡ W d d }~X Y nX d S )NÚcommon)rÊ rJ rÉ r r Úsend_error_responserÍ )r0 rÐ rÑ r rÓ r6 r6 r7 Ú
|
OnDealList s
|
|
z MyTradeActionCallback.OnDealListc
|
C sX y | j |¡}||ft|< W n6 tk
|
rR } zt d||t|¡ W d d }~X Y nX d S )NrÕ )rÊ rI rÉ r r rÖ rÍ )r0 rÐ rÑ rH r rÓ r6 r6 r7 ÚOnDelegateList s
|
z$MyTradeActionCallback.OnDelegateListc
|
C sV y| j ¡ }||ft|< W n6 tk
|
rP } zt d||t|¡ W d d }~X Y nX d S )NrÕ )rÊ rM rÉ r r rÖ rÍ )r0 rÐ rÑ r rÓ r6 r6 r7 ÚOnMoney s
|
|
z MyTradeActionCallback.OnMoneyc
|
C sV y| j ¡ }||ft|< W n6 tk
|
rP } zt d||t|¡ W d d }~X Y nX d S )NrÕ )rÊ rK rÉ r r rÖ rÍ )r0 rÐ rÑ r rÓ r6 r6 r7 ÚOnPositionList s
|
|
z$MyTradeActionCallback.OnPositionListN)
|
rZ r[ r\ r rÊ rÔ r× rØ rÙ rÚ r6 r6 r6 r7 rÅ Ì s 6rÅ c C sb t d¡ tj dd¡attat t¡ t
|
d¡ t
|
d¡ t tj ¡ t tj ¡ t ¡ d S )Nu åå§å交ææå¡å¨z./flowFztcp://192.168.84.31:6500ztcp://192.168.84.32:26500)r rj r ZCTORATstpTraderApiZCreateTstpTraderApir) r^ Útraderapi_callbackÚspiÚ RegisterSpiÚ RegisterFrontZSubscribePrivateTopicZTORA_TERT_QUICKZSubscribePublicTopicÚInitr6 r6 r6 r7 Ú__init_trade_data_server" s
|
|
|
|
rà c
|
sî fdd}t d || t dt ¡ |} tks< tkrD|d }yxt dt tr|tkrt |¡\}}|t dd|d ||d
|
¡ d ¡ t d n"|t d d| dd¡ d ¡ W n, t
|
k
|
rè } zt |¡ W d d }~X Y nX d S )Nc
|
s yt ¡ | ¡ W nv tk
|
rP } z t ¡ t ¡ | ¡ W d d }~X Y n< tk
|
r } z t ¡ t ¡ | ¡ W d d }~X Y nX d S )N)r rË rÌ ÚConnectionResetErrorÚdel_send_response_skÚBrokenPipeError)Zdata_strrÓ )r r6 r7 Ú send_responseY s
|
|
z)traderapi_callback.<locals>.send_responseu åè°u è¿ç¨IDr3 rÛ Úresponser )r r )r r rÐ rÑ zutf-8u ç»æåéå®æ¯Ztrade_callback)r r r )r r ) rC rÇ rÈ r
r rÉ r³ r- r. r/ r rÎ rÏ )r r r rä ÚkeyrÐ rÑ rÓ r6 )r r7 rÛ X s$
|
|
|
$rÛ c C s6 t | at ¡ at ttt ¡ t ¡ t
|
d d S )Nu trade_clientå¯å¨æå) rà r+ Úcommand_managerÚTradeCommandManagerZtradeCommandManagerÚinitÚaddrÚportrÅ ÚrunrC )Úpiper6 r6 r7 rì | s rì Ú__main__)N)(r- rÎ rÇ Úsocketr rç Úconstantr Úclient_networkr Úlogr rP rT r r² r r r r
r r» rà rÀ r´ r r_ r^ rÉ ÚTradeActionCallbackrÅ rà rÛ Ú SERVER_IPÚ SERVER_PORTrê rë rì rZ Úinputr6 r6 r6 r7 Ú<module> sJ ! B HV6!
|
|
|
