B
|
|d» ã @ s d dl Z d dlZd dlZd dlZd dlZd dlZd dlmZ d dlm Z m
|
Z
|
i Z i Z i Z i Ze Zd#ddZdd Zd d
|
Zd d Zd d Zdd Zdd Zdd ZedkrdZe e¡ ee xBx2e d dD ]$Z eeddddd d d d d d!
|
d qÒW e d"¡ qÆW dS )$é N)ÚSendResponseSkManager)Úlogger_l2_errorÚlogger_l2_uploadFc C sp | d }|t kr t ¡ t |< |r"n t | | d | d | d | d | d | d | d | d | d | d
|
f
|
¡ d S ) NÚ
|
SecurityIDÚPriceÚVolumeÚSideÚ OrderTypeÚ OrderTimeÚMainSeqÚSubSeqÚOrderNOÚ OrderStatus)Ú tmep_order_detail_queue_dictÚqueueÚQueueÚput)ÚdataZ istransactionÚcode© r ú/D:\workspace\GP\trade_huaxin\l2_data_manager.pyÚadd_l2_order_detail s $r c C sd | d }|t kr t ¡ t |< t | | d | d | d | d | d | d | d | d | d f ¡ d S )
|
Nr Ú
|
TradePriceÚ TradeVolumer
|
r r ÚBuyNoÚSellNoÚExecType)Útmep_transaction_queue_dictr r r )r r r r r Úadd_transaction_detail+ s r c C sT t |¡}| |¡ x:| d¡}|r| d¡}t |¡}| d¡dkrJdS P qW dS )Ni zutf-8r r TF)r Úformat_responseÚsendallÚrecvÚdecodeÚjsonÚloadsÚget)ÚskÚmsgÚresultÚ result_jsonr r r Ú__send_response< s
|
|
|
|
|
r* c
|
C sª y.t | ¡}t||rdS td t||S W nv tk
|
rj } z t | ¡ t | ¡}t||S d }~X Y n< tk
|
r¤ } z t | ¡ t | ¡}t||S d }~X Y nX d S )NTu å次åé)r Úget_send_response_skr* ÚprintÚConnectionResetErrorÚdel_send_response_skÚBrokenPipeError)Útyper' r& Úer r r Ú send_responseK s
|
|
|
|
|
|
r2 c C sÊ t t ¡ d t dd¡}| d| }t || |dd¡}d }t ¡ }zFyt|| d¡}W n, tk
|
r } zt
|
|¡ W d d }~X Y nX W d t | dt t ¡ | d d d
|
t| ¡ X d S ) Niè r i Ú_)r r )r0 r zutf-8u ä¸ä¼ æ°æ®èæ¶ï¼ é u æ°æ®é:)r, ÚtimeÚrandomÚrandintr# Údumpsr2 ÚencodeÚ ExceptionÚloggingÚ exceptionr ÚinfoÚroundÚlen) r Ú_typeZdatasZuidÚkeyZfdatar( Z
|
start_timer1 r r r Ú upload_data_ s rB c
|
C s¶ | t krt ¡ t | < xy`| tkr"P t ¡ t| < g }x&t | ¡ sXt | ¡ }| |¡ q4W |rjt | d| t
|
d¡ W q t k
|
r¬ } zt dt| ¡ W d d }~X Y qX qW d S )NZl2_orderg{®Gáz¤?u ä¸ä¼ 订åæ°æ®åºéï¼)r r r Ú target_codesr5 Ú$order_detail_upload_active_time_dictÚemptyr% ÚappendrB Úsleepr: r ÚerrorÚstr)r ÚudatasÚtempr1 r r r Ú__run_upload_ordert s" rL c
|
C s¶ | t krt ¡ t | < xy`| tkr"P t ¡ t| < g }x&t | ¡ sXt | ¡ }| |¡ q4W |rjt | d| t
|
d¡ W q t k
|
r¬ } zt dt| ¡ W d d }~X Y qX qW d S )NZl2_transg¹?u ä¸ä¼ æ交æ°æ®åºéï¼)r r r rC r5 Ú#transaction_upload_active_time_dictrE r% rF rB rG r: r rH rI )r rJ rK r1 r r r Ú__run_upload_trans s rN c s t kr d S tks(t ¡ t dkrNtj fddd}| d¡ | ¡ tksjt ¡ t dkrtj fddd}| d¡ | ¡ d S )Né c s t S )N)rL r )r r r Ú<lambda>¦ ó z!run_upload_task.<locals>.<lambda>)ÚtargetTc s t S )N)rN r )r r r rP « rQ )rC r r5 Ú threadingÚThreadÚ setDaemonÚstartrM )r Útr )r r Úrun_upload_task s
|
|
rX Ú__main__Z603809é gÂõ(\&@iô Ú2ú iC¦Þ r4 i¾¨ i)£ ÚA)
|
r r r r r r
|
r r r r gü©ñÒMbP?)F) r# r; r r6 rS r5 Úclient_networkr Úmylogr r rD rM r r ÚsetrC r r r* r2 rB rL rN rX Ú__name__r ÚaddÚrangeÚirG r r r r Ú<module> s<
|
|
|
|
