B
|
²×dJJ ã @ sØ d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlm Z m
|
Z
|
d dl m Z d dl mZmZmZmZmZmZ d dlmZmZ G dd dejZG dd d ejeZG d
|
d d ejZ d d Z e dkrÔdS )é N)Ú
|
mysql_dataÚ redis_manager)Ú
|
RedisUtils)Ú socket_utilÚhosting_api_utilÚhuaxin_trade_record_managerÚ huaxin_utilÚtoolÚglobal_data_cache_util)ÚHistoryKDatasUtilsÚ JueJinApic @ s e Zd Zdd ZdS )Ú MyTCPServerc C s t jj| ||dd d S )NT)Zbind_and_activate)Ú socketserverÚ TCPServerÚ__init__)ÚselfZserver_addressZRequestHandlerClass© r ú5D:\workspace\GP\gp_middle_server\middle_api_server.pyr s zMyTCPServer.__init__N)Ú__name__Ú
|
__module__Ú __qualname__r r r r r r s r c @ s e Zd ZdS )ÚMyThreadingTCPServerN)r r r r r r r r s r c sT e Zd ZdZdd Zedd Zdd Z fdd Zed
|
d Z fd d Z
|
Z S )ÚMyBaseRequestHandleFc C s | ¡ d S )N)Ú_MyBaseRequestHandle__init)r r r r Úsetup s zMyBaseRequestHandle.setupc C s | j r
|
dS d| _ i | _d S )NT)Ú _MyBaseRequestHandle__initedZ%_MyBaseRequestHandle__req_socket_dict)Úclsr r r Z__init s zMyBaseRequestHandle.__initc C s| g }|d }| d¡ x$|D ] }| | d|| ¡ q W | ¡ d |¡d }t |jdd¡ ¡ }||krxtdd S )NÚsignú=ú&z
|
JiaBei@!*.zutf-8)Úencodingu ç¾ååºé) ÚpopÚappendÚsortÚjoinÚhashlibÚmd5ÚencodeZ hexdigestÚ Exception)r Ú data_jsonZlist_strr ÚkZ_MyBaseRequestHandle__strr& r r r Z__is_sign_right& s
|
|
z#MyBaseRequestHandle.__is_sign_rightc " sÊ | j d }t ¡ | j}x¨d}zy6t |¡\}}|rZ|}t |¡}|d }t|t krp|
|
|||¡}P t |¡} |dkr| st d|d }
|
|
|
d } |
|
d } |
|
d } y°| s¾t d
|
| sÊt d t t| d dkrt | g¡}|söt d |d d } t tj| | t t| d ¡}|r\|}td| |d dkrPt ddi¡}n t |d P W n( t k
|
r } z|W d d }~X Y nX nÌ|dkr4| s¦t d|d }
|
|
|
d } |
|
d¡}|
|
d¡}| r t tj| |d¡}td t| |d dkrt ddi¡}n t |d nt ddd¡}P n&|dkrø| sLt d|d }
|
|
|
d } |
|
d } |
|
d } |
|
d }| s¤t | g¡}|st d |d d d } t tj| | | ¡}|d dkrÖt ddd¡}n t |d td t| P nb|d kr|d d }|d d }d \}}|rLtj t d ¡d t j t j g¡\}}ntj t d ¡|¡\}}t d||d!dd"¡}P nØ|d#kr¸tj! t d ¡¡}t dd$|idd"¡}n¢|d%kròtj" t d ¡¡\}}t dd$|idd"¡}nh|d&kr tj# $¡ }t d|dd"¡}n>|d'krR|d d }t %|¡ t di dd"¡}n|d(krt&j'}t dt(||d)dd"¡}nØ|d*kr¸|d d } t )| ¡ t di dd"¡}n¢|d+kràt *¡ t di dd"¡}nz|d,krg }i } t d| dd"¡}nR|d-krvy(t+ ,t ¡ ¡} | r8t ddd¡}W n8 t k
|
rr } zt dt-|d¡}W d d }~X Y nX nä|d.krt .¡ }t |¡}nÆ|d/krZt/ 0d0¡ 1¡ } z¢t2 2¡ } g } x,t3dd1D ] }!t4j5| d2d3|! d4d5 qÆW | 6t2 2¡ | ¡ t2 2¡ } x$t3dd6D ]}!t4j7| d2d4d5 qW | 6t2 2¡ | ¡ t d| dd"¡}W d | 8¡ X P W nD t k
|
r¢ } z$t9 :|¡ t d7t-|d¡}P W d d }~X Y nX W d | ;t <|j=d8d9¡¡ X q W d S ):Nr Ú ÚtypeZbuyu ç¾åé误ÚdataÚcodeÚvolumeÚpriceu 请ä¸ä¼ codeu 请ä¸ä¼ volumeé u ç°ä»·è·å失败é u ä¸åç»æï¼ÚmsgZ cancel_orderÚ
|
orderSysIDÚ accountIdTu ---æ¤åç»æ----u 请ä¸ä¼ 代ç )r. r3 ZsellZforceg{®Gáz¤?u ---ååºç»æ----Z delegate_listÚ update_timeÚ
|
can_cancel)NNz%Y%m%d)ÚlistZ
|
updateTime)r. r- r3 Z deal_listr8 Z position_listZ
|
money_listZsync_trade_dataZget_huaxin_subscript_codes)Úcountr8 Úexport_l2_dataÚ everyday_initZhuaxin_channel_stateZjuejin_is_validÚ get_env_infoZ
|
test_redisé éd Ztest_setz000000:F)Z auto_freeé i zutf-8)r )>Zclient_addressÚsuperÚhandleZrequestr Z recv_dataÚjsonÚloadsr, ÚintÚprocess_num_typeZis_client_params_sign_rightr( ÚroundÚfloatr Z get_now_pricer Z trade_orderZTRADE_DIRECTION_BUYÚprintÚdumpsÚgetZtrade_cancel_orderZTRADE_DIRECTION_SELLr ZDelegateRecordManagerZ list_by_dayr Zget_now_date_strr ZTORA_TSTP_OST_AcceptedZTORA_TSTP_OST_PartTradedZDealRecordManagerZPositionManagerZ MoneyManagerÚget_dataZrefresh_trade_datar
|
Zhuaxin_subscript_codesÚlenr: r; r Zget_previous_trading_dateÚstrr< r Z RedisManagerZgetRedisNoPoolÚtimeÚranger Zsaddr" ZsmembersÚcloseÚloggingZ exceptionZsendallZ load_headerr' )"r ZhostÚskÚ
|
return_strr- ÚheaderZdata_strr) Ztype_Z is_sign_rightZ
|
codes_datar. r/ r0 ZpricesÚresultZ
|
resultJSONÚer4 r5 Z
|
force_sellr6 r7 ZresultsZ
|
money_dataZ sync_typeZfresultsÚtypesZfdataZdateZredisZ _start_timeÚtimesÚi)Ú __class__r r rA 2 sH
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
$
|
|
|
|
zMyBaseRequestHandle.handlec
|
C sN d}y
|
|dkrTt |¡}|d d }x|D ]}t |tj¡ q,W t ddi¡}nº|dkr t |¡}|d d }x|D ]}t |tj¡ qxW t ddi¡}nn|dkrÂt tj¡}t |¡}nL|d krNt |¡}|d d }y.x|D ]}t |tj¡ qêW t ddi¡}W n8 t k
|
rH } zt d
|
t
|
| d ¡}W d d } ~ X Y nX nÀ|d krt |¡}|d d }x |D ]}t |tj¡ qtW t ddi¡}np|d krÂt tj¡}t |¡}nL|dkrt |¡}|d d }x |D ]}t |tj ¡ qèW t ddi¡}nü|dkrbt |¡}|d d }x |D ]}t |tj ¡ q8W t ddi¡}n¬|dkrt tj ¡}t |¡}n|dkrÖt |¡}|d d }x |D ]}t |tj ¡ q¬W t ddi¡}n8|dkr&t |¡}|d d }x |D ]}t |tj ¡ qüW t ddi¡}nè|dkrJt tj ¡}t |¡}nÄ|dkrÆt |¡}|d d }|d }t |¡}|d d }
|
|
|
tjkr²|
|
tjkr²t ddd ¡}nt d
|
dd ¡}nH|dkrþt |¡}|d d }t |¡}t |¡}n|dkrVt |¡}|d d } | r0t d¡ n
|
t d ¡ t d| rJd nd d ¡}n¸|d krtt ¡ }t |¡}n|d kròt |¡}|d d! } y"t | ¡ t dd!| id"¡}W n8 t k
|
rî } zt d
|
t
|
| d ¡}W d d } ~ X Y nX n |d#krt ¡ }t |¡}W n8 t k
|
rH } zt d
|
t
|
| d ¡}W d d } ~ X Y nX |S )$Nr+ éÉ r- Úcodesr. r éË i- éÊ r2 )r. r3 éÌ i. i i i i i i i¤ Ústateu å¯ä»¥åæ¶u ä¸å¯ä»¥åæ¶i® iõ ÚopenTFu å¼å¯æåu å
³éæåiö i÷ Úmode)r. r- iø )rB rC r Z add_code_listZCODE_LIST_BLACKrI Zremove_code_listZ get_code_listZCODE_LIST_WHITEr( rM ZCODE_LIST_WANTZCODE_LIST_PAUSE_BUYZget_code_trade_stateÚ trade_managerZ TRADE_STATE_BUY_CANCEL_SUCCESSZTRADE_STATE_BUY_SUCCESSZget_code_attributeZset_trade_stateZget_trade_stateZset_trade_modeZget_trade_mode) r rR r, Ú_strrS r- r\ r. rU rV r` Zis_openrb r r r rE û sÎ
|
|
|
|
|
|
|
*
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
(
|
&z$MyBaseRequestHandle.process_num_typec s t ¡ d S )N)r@ Úfinish)r )rZ r r re s zMyBaseRequestHandle.finish) r r r r r Ú classmethodr Z#_MyBaseRequestHandle__is_sign_rightrA rE re Ú __classcell__r r )rZ r r s J r c C s" t d d} t| t}| ¡ d S )Nzcreate middle_api_server)z0.0.0.0i' )rH r r Z serve_forever)ZladdrZ tcpserverr r r Úrun s
|
rh Ú__main__) r% rB rQ Zsocketr Ú threadingrN rc Zdbr r Zdb.redis_managerr Zutilsr r r r r r
|
Zutils.history_k_data_utilr r r r ZThreadingMixInr ZBaseRequestHandlerr rh r r r r r Ú<module> s& t
|
