B
|
sNgº ã @ sº d dl Zd dlZd dlZd dlZd dlZd dlmZ d dlm Z
|
d dl m Z d dl mZmZ d dlmZmZmZmZ d dlmZmZ G dd deZG d d
|
d
|
ejejjZ dd dZ dS )é N)ÚBaseHTTPRequestHandler)Ú
|
data_cache)Úhuaxin_trade_apiÚhuaxin_trade_data_update)ÚDelegateRecordManagerÚDealRecordManagerÚ MoneyManagerÚPositionManager)ÚtoolÚ huaxin_utilc @ sJ e Zd ZejjddZdd Zdd Zdd Z d d
|
Z
|
d d Z d d Z dS )Ú
|
DataServeré
|
)Z max_workersc G s d S )N© )ÚselfÚformatÚargsr r õ- D:\éåä½å¸\low_suction_hx\data_server.pyÚ log_message s zDataServer.log_messagec C s dd }| j }t |¡}||}d}|j dkrJt ¡ }t d|d¡}n¤|j dkrpt ¡ }t d|d¡}n~|j dkrt t
|
d ¡¡}t d|d¡}nP|j d
|
kr| d ¡}g } |d krî|rÚt jt jt jt jg} nt jt jt jt jg} tj t
|
d ¡d | d }t d|d¡}nØ|j d kr| d¡}
|
|
|
dkr@t ¡ n<|
|
dkrVt d¡ n&|
|
dkrjt ¡ n|
|
dkr|t ¡ t di d¡}n`|j dkrî| d¡} t | ¡} g } x*| D ]"}t j |¡}|r¸| |¡ q¸W t d| d¡}| d¡ | !dd¡ | "¡ | j# $| %¡ ¡ d S )Nc S s t dd t | j¡ ¡ D S )Nc S s g | ]\}}||d fqS )r r )Ú.0ÚkÚvr r r ú
|
<listcomp> s z9DataServer.do_GET.<locals>.get_params.<locals>.<listcomp>)ÚdictÚurlparseÚparse_qsÚqueryÚitems)Úurlr r r Ú
|
get_params s z%DataServer.do_GET.<locals>.get_paramsÚ z/get_position_listr )ÚcodeÚdataz
|
/get_moneyz/get_deal_listz%Y%m%dz/get_delegate_listÚ
|
can_cancel)Z orderStatusz/refresh_trade_dataÚtypeZmoneyÚdelegateu æå¨å·æ°ZdealÚpositionz/get_market_infoÚcodeséÈ z Content-typezapplication/json)&Úpathr r Zget_position_cacheÚjsonÚdumpsr Úget_datar Z list_by_dayr
|
Úget_now_date_strÚgetr ZTORA_TSTP_OST_CachedZTORA_TSTP_OST_UnknownZTORA_TSTP_OST_AcceptedZTORA_TSTP_OST_PartTradedZTORA_TSTP_OST_AllTradedZ TORA_TSTP_OST_PartTradeCanceledZTORA_TSTP_OST_AllCanceledZTORA_TSTP_OST_Rejectedr r Zadd_money_listZadd_delegate_listZ add_deal_listZadd_position_listÚloadsr Ú latest_code_market_info_dictÚappendÚ send_responseÚ send_headerÚ end_headersÚwfileÚwriteÚencode)r r r( r Ú params_dictÚ response_dataÚresultsÚresultr" Z order_statusZ_typeZ codes_strr& Úfdatasr r! r r r Údo_GET sb
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
zDataServer.do_GETc C s g }x2| ¡ D ]&\}}|dkr q| | d| ¡ qW | ¡ d |¡d }t ¡ }| | d¡¡ | ¡ }|| d¡krdS dS )NÚsignú=ú&z!@#lowSU*^cTion8888zutf-8TF)
|
r r0 ÚsortÚjoinÚhashlibÚmd5Úupdater6 Ú hexdigestr- )r ÚparamsZpsr r Z
|
source_strZmd5_hashZ md5_hexdigestr r r Z__is_sign_rightW s zDataServer.__is_sign_rightc
|
C sº d}z¢yb| j }t |¡}|j dkrh| ¡ }t|tkrLt t |¡¡ n
|
t |¡ t ddi¡}n|j dkrè| ¡ }| |¡st ddd¡}d S t
|
d | | d¡}| d
|
¡}t | d ¡d }t d |||¡} t d| d¡}n|j dkrj| ¡ }| |¡s t ddd¡}d S t
|
d| | d¡}| d
|
¡}t | d ¡d }t d |||¡} t d| d¡}W n8 tk
|
r¤ }
|
zt d t|
|
d¡}W d d }
|
~
|
X Y nX W d | |¡ X d S )Nr z/trade_callbackr r z/buyié u ç¾åé误)r Úmsgu ä¹°å
¥ÚvolumeÚpriceé é )r r! z/sellu ååº)r( r Ú_DataServer__parse_requestr# Ústrr Zadd_trade_callback_datar) r* Ú_DataServer__is_sign_rightÚprintr- ÚroundÚorderÚ ExceptionÚ_DataServer__send_response) r Ú
|
result_strr( r ÚbodyrF r rH rI r: Úer r r Údo_POSTh sF
|
|
|
|
|
|
|
|
|
|
|
*zDataServer.do_POSTc C s2 | d¡ | dd¡ | ¡ | j | ¡ ¡ d S )Nr' z Content-typezapplication/json)r1 r2 r3 r4 r5 r6 )r r! r r r Z__send_response s
|
zDataServer.__send_responsec C sD i }| j t| jd ¡}t|dd}yt |¡}|S |S d S )Nzcontent-lengthÚgbk)Úencoding)ZrfileÚreadÚintÚheadersrM r) r. )r rF ÚdatasÚ_strr r r Z__parse_request s
|
zDataServer.__parse_requestN) Ú__name__Ú
|
__module__Ú __qualname__Ú
|
concurrentÚfuturesÚThreadPoolExecutorZ%_DataServer__data_process_thread_poolr r< rN rW rS rL r r r r r s A,r c @ s e Zd ZdS )ÚThreadedHTTPServerN)r_ r` ra r r r r re § s re ú0.0.0.0éQ2 c
|
C sV t }y*t| |f|}td| |f | ¡ W n" tk
|
rP } zW d d }~X Y nX d S )Nz HTTP server is at: http://%s:%d/)r re rO Ú serve_foreverrR )ÚaddrÚportÚhandlerZhttpdrV r r r Úrun« s rl )rf rg ) Úconcurrent.futuresrb rB Úhttpr) Ú socketserverZ http.serverr Ú urllib.parseÚparser Ústrategyr Útrader r Z!trade.huaxin_trade_record_managerr r r r Úutilsr
|
r r ZThreadingMixInÚserverZ
|
HTTPServerre rl r r r r Ú<module> s
|
