gp-server.git - Gitblit

B  
)
Öd¨(ã@svdZddlZddlZddlZddlZddlmZddlmZdZ    dZ
dZdZdZ dZd    Zd
ZdZdZd ZdZdZdZdZdZdZdZdZdZiZddZddZefddZ ddZ!dd Z"dBd"d#Z#dCd$d%Z$dDd&d'Z%dEd(d)Z&dFd*d+Z'dGd,d-Z(dHd.d/Z)dId0d1Z*dJd2d3Z+dKd4d5Z,dLd6d7Z-dMd8dZ.dNd9d:Z/dOd;d<Z0dPd=d>Z1e2d?krrd@dAiZ3e4e3 5d@¡dS)Qu
äº¤æAPI
éN)ÚClientSocketManager)Úsocket_utiléééÚwhiteÚblackZwantZ    pause_buyZtradeZtrade_stateZ
trade_modeZ    code_listZ    export_l2ÚinitÚrefresh_trade_dataZcode_attributeZcode_trade_stateZget_envg@c    Cs*d|dtt ¡ddt dd¡S)NZr_Ú_i'ri )ÚroundÚtimeÚrandomÚrandint)Útype©rú:D:\workspace\GP\gp_middle_server\utils\hosting_api_util.pyÚ__get_request_id,src
CsØt |¡}|stdt|d}yJd||d}t |¡}|d t t     |¡j
dd¡¡|d d¡}Wnbtk
r }zt  |d    ¡|Wdd}~XYn0tk
rÎ}zt |¡|Wdd}~XYnX||fS)
Nuæ å¯ç¨çäº¤æclientrÚcmd)rÚdataÚ
request_idrzutf-8)Úencodingir)rZacquire_clientÚ    ExceptionrrÚencryp_client_params_signÚsendallÚload_headerÚjsonÚdumpsÚencodeÚrecvÚBrokenPipeErrorZ
del_clientÚloggingÚ    exception)Úclient_typerÚclientrZ    root_dataÚresultÚerrrÚ    __request1s$
 
"
r'cCsj|rft ¡}zVxPt d¡|tkr0t |¡}|St ¡||krt |d¡td|qWWdXdS)Ng{®Gázt?ruè¯»ååå®¹è¶æ¶: request_id=)r ÚsleepÚ__request_response_dictÚpoprÚrelease_clientr)r$rÚblockingÚtimeoutÚ
start_timer%rrrÚ__read_responseJs
 
r/cCs |r|r|t|<t |¡ndS)N)r)rr+)Ú    client_idrÚresponserrrÚset_response^sr2cCsN|std|}t|tkr&t |¡}|d}|ddkrFt|d|dS)Nuåé¦åå®¹ä¸ºç©ºrÚcoderÚmsg)rrÚstrrÚloads)Údata_strÚresrrrÚ parseResponsehs
r9TcCsRtdtjttjtd|||||d|dtt ¡dd\}}t|||S)Nu    å®¢æ·ç«¯rZorder_riè)rÚ
trade_typeÚ    directionr3ÚvolumeÚ
price_typeÚpriceÚsinfo)    ÚprintrZsocket_client_dictr'ÚCLIENT_TYPE_TRADEÚAPI_TYPE_TRADErr r/)r;r3r<r>r=r,rr$rrrÚtrade_orderzs(rCcCsDttjtd||||d|dtt ¡dd\}}t|||S)NrZ cancel_order_riè)rr:r;r3Ú    accountIDÚ
orderSysIDr?)r'rrArBrr r/)r;r3rDrEr,rr$rrrÚtrade_cancel_orders&rFcCs>ttjtt|dtdtt ¡dd\}}t|||S)NÚcb_riè)rÚoperateÚstater?)r'rrAÚAPI_TYPE_TRADE_STATEÚOPERRATE_SETrr r/)rIr,rr$rrrÚset_trade_states
&rLc
Cs<ttjttdtdtt ¡dd\}}t|||S)NrGriè)rrHr?)r'rrArJÚOPERRATE_GETrr r/)r,rr$rrrÚget_trade_states&rNcCs>ttjtt|dtdtt ¡dd\}}t|||S)NrGriè)rrHÚmoder?)r'rrAÚAPI_TYPE_TRADE_MODErKrr r/)rOr,rr$rrrÚset_trade_mode¥s&rQc
Cs<ttjttdtdtt ¡dd\}}t|||S)NrGriè)rrHr?)r'rrArPrMrr r/)r,rr$rrrÚget_trade_modes&rRcCs@ttjt||tdtdtt ¡dd\}}t|||S)NrGriè)rÚcode_list_typer3rHr?)r'rrAÚAPI_TYPE_CODE_LISTrKrr r/)r3rSr,rr$rrrÚ add_code_listµs
&rUcCs@ttjt||tdtdtt ¡dd\}}t|||S)NrGriè)rrSr3rHr?)r'rrArTÚOPERRATE_DELETErr r/)r3rSr,rr$rrrÚremove_code_list½s
&rWcCs>ttjt|tdtdtt ¡dd\}}t|||S)NrGriè)rrSrHr?)r'rrArTrMrr r/)rSr,rr$rrrÚ get_code_listÅs
&rXc
Cs<ttjt|dtdtt ¡dd\}}t|||S)NrGriè)rr3r?)r'rrAÚAPI_TYPE_EXPORT_L2rTrr r/)r3r,rr$rrrÚexport_l2_dataÎs&rZc    Cs:ttjtdtdtt ¡dd\}}t|||S)NrGriè)rr?)r'rrAÚ API_TYPE_INITrTrr r/)r,rr$rrrÚ everyday_initÖs&r\cCs6ttjt|dtt ¡dd\}}t|||S)NÚupdate_trade_data_iè)rÚctyper?)r'rrAÚAPI_TYPE_REFRESH_TRADE_DATArr r/)rr,rr$rrrr
Þs cCs6ttjt|dtt ¡dd\}}t|||S)Nr]iè)rr3r?)r'rrAÚAPI_TYPE_CODE_ATRRIBUTErr r/)r3r,rr$rrrÚget_code_attributeæs racCs6ttjt|dtt ¡dd\}}t|||S)Nr]iè)rr3r?)r'rrAÚAPI_TYPE_CODE_TRADE_STATErr r/)r3r,rr$rrrÚget_code_trade_stateîs rccCs4ttjtdtt ¡dd\}}t|||S)Nr]iè)rr?)r'rrAÚAPI_TYPE_GET_ENVrr r/)r,rr$rrrÚget_env_infoös reÚ__main__ÚidZ123123)rT)T)T)T)T)T)T)T)T)T)T)T)T)T)T)6Ú__doc__rr!rr Zsocket_managerrÚutilsrÚTRADE_DIRECTION_BUYÚTRADE_DIRECTION_SELLrKrVrMÚCODE_LIST_WHITEÚCODE_LIST_BLACKÚCODE_LIST_WANTÚCODE_LIST_PAUSE_BUYrBrJrPrTrYr[r_r`rbrdZTIMEOUTr)rr'r/r2r9rCrFrLrNrQrRrUrWrXrZr\r
rarcreÚ__name__Údr@r*rrrrÚ<module>sd