B
|
r«g 0 ã @ s´ d dl Z d dlZd dlZd dlZd dlZd dlZd dlmZ d dlm Z da
|
d dl m Z dd Z G dd d ej Zejejd
|
d d Zejejd
|
d dZdd Zedkr°e dS )é N)Ú logger_system)Útooli )Údatetimec C s t d a t S )Né )Úg_seqnum© r r õ= D:\éåä½å¸\low_suction_hx\huaxin_client\l1_api_client.pyÚ
|
new_seqnum s r c @ s e Zd Zi Zi Zdd Zdd Zd ddZd d
|
Zd d d Z d d Z
|
dd Z dd Z dd Z dd Zdd Zdd Zdd Zd S ) Ú sampleSpic C s t j | ¡ || _d S )N)ÚqcvalueaddproapiÚCQCValueAddProSpiÚ__init__Úm_api)ÚselfZt_tapir r r r s zsampleSpi.__init__c C s t S )N)r )r r r r Z__create_request_id s z sampleSpi.__create_request_idr éÈ c
|
|
C s¦ ytt ¡ }||_||_||_||_t j|_| ¡ }| j
|
||¡}x0t ddD ]"}|| j krd| j | S t d¡ qLW W n, tk
|
r } zt | ¡ W dd} ~ X Y nX g S )uÙ
|
æ¥è¯¢äº¤ææ¥å
|
@param start_date: æ ¼å¼ï¼20241201
|
@param end_date: æ ¼å¼ï¼20241201
|
@param page_locate:
|
@param page_count:
|
@return: è¿åæ¥æ[顺åº]
|
r iè gü©ñÒMb`?N)r Z CQCVDReqQryShareCalendarFieldÚBegDateÚEndDateÚ PageCountÚ
|
PageLocateZQCVD_ORDST_ASCÚ OrderTypeÚ _sampleSpi__create_request_idr ZReqReqQryShareCalendarÚrangeÚ_sampleSpi__result_cacheÚtimeÚsleepÚ ExceptionÚloggingÚ exception)
|
r Ú
|
start_dateÚend_dateÚ page_locateÚ
|
page_countÚ
|
queryFieldÚ
|
request_idÚresultsÚiÚer r r Z__query_trade_calendar! s
|
|
z sampleSpi.__query_trade_calendarc
|
C s¢ g }yld}xTt dD ]H}| j| dd¡| dd¡|d}|rF| |¡ t|dkrTP |d7 }qW tdt| W n, tk
|
r } zt |¡ W dd}~X Y nX |S ) u5
|
æ¥è¯¢äº¤ææ¥å
|
@return:
|
r é ú-Ú )r r zqueryTradeCalendar:N) r Ú _sampleSpi__query_trade_calendarÚreplaceÚextendÚlenÚprintr r r )r r r Úfresultsr r% r$ r& r r r ÚqueryTradeCalendar; s
|
z sampleSpi.queryTradeCalendarc
|
C sª t ¡ }| dd¡|_| dd¡|_t |¡r8t j|_nt j |_||_
|
||_ ||_ t j |_| ¡ }| j ||¡}x4tddD ]&} || jkr| j| }|S t d¡ q|W g S )Nr( r) r iè gü©ñÒMb`?)r Z!CQCVDReqQryStockDayQuotationFieldr+ r r r Ú
|
is_sh_codeZ QCVD_EXD_SSEZ
|
ExchangeIDZ QCVD_EXD_SZSEÚ
|
SecurityIDr r ZQCVD_ORDST_DESCr r r ZReqReqQryStockDayQuotationr r r r )
|
r ÚcodeÚ
|
begin_dater r r! r" r# r$ r% r r r Z __query_barsP s$
|
|
|
|
zsampleSpi.__query_barsc C sÈ yd}g }xFt dD ]:}| ||||¡}|r8| |¡ t|dkrHP q|d7 }qW d}xÌt dt|D ]º}|| } |s| d }|| d krht| d | d | d| d< t| d | d | d| d < t| d | d
|
| d| d
|
< t| d | d | d| d < t| d | d | d| d < qhW g }
|
xX|D ]P} |
|
| d | d | d
|
| d | d | d | d t | d d¡| d d ¡ q0W tdt|
|
|
|
S t k
|
r } zt
|
| ¡ W dd} ~ X Y nX dS )uû
|
è·ååå²K线ï¼å
å«èµ·æ¢æ¥æï¼
|
@param code:
|
@param begin_date: ä¾å¦ï¼2024-10-31
|
@param end_date: ä¾å¦ï¼2024-11-30
|
@param page_locate: 第å 页ï¼ä»ç¬¬ä¸é¡µå¼å§ï¼
|
@return:
|
r r' r Nr Ú AdjustFactorÚ PreClosePriceé Ú OpenPriceÚ HighPriceÚLowPriceÚ
|
ClosePricer2 ÚVolumeÚ
|
TradingDayz%Y%m%dÚTurnover) Zsec_idÚopenÚhighÚlowÚcloseÚvolumeÚ pre_closeZbobÚamountzReqReqQryStockDayQuotation:) r Ú_sampleSpi__query_barsr, r- ÚroundÚappendr Ústrptimer. r r r ) r r3 r4 r r Z final_resultsr% r$ Zstart_adjust_factorÚdr/ Úrr& r r r Ú queryBarsi sH
|
"
|
|
zsampleSpi.queryBarsc C s8 t d t ¡ }t|_tj|_t|_| j
|
|t ¡ d S )NÚOnFrontConnected) r. r ZCQCVDReqUserLoginFieldÚg_useridÚ LogInAccountZQCVD_AM_PasswordZAuthModeÚg_passwdZPasswordr Z ReqUserLoginr )r Z
|
loginfieldr r r rM s zsampleSpi.OnFrontConnectedc C s t d| d S )Nz OnFrontDisconnected Reason[%d])r. )r ZnReasonr r r ÚOnFrontDisconnected© s z sampleSpi.OnFrontDisconnectedc C s2 t d|j||j|jf |jdkr.t d¡ d S )NzGOnRspUserLogin LogInAccount[%s] RequestID[%d] ErrorID[%d] ErrorMsg[%s] r u! åé«å¢å¼æå¡APIç»å½æå)r. rO ZErrorIDZErrorMsgr Úinfo)r ZpRspUserLoginFieldÚpRspInfoÚ
|
nRequestIDZbIsLastr r r ÚOnRspUserLogin® s
|
zsampleSpi.OnRspUserLoginc C s t ¡ }| j |t ¡ d S )N)r ZCQCVDQryGGTEODPricesFieldr ÚReqQryGGTEODPricesr )r ÚQryFieldr r r rV ¼ s z sampleSpi.ReqQryGGTEODPricesc C s t ¡ }| j |t ¡ d S )N)r ZCQCVDQryInvestorFieldr ÚReqQryInvestorr )r rW r r r rX À s zsampleSpi.ReqQryInvestorc C s\ || j krg | j |< |r,| j | |j¡ n,| j | | j|< | j |¡ td| j| dS )uÁ
|
交ææ¥åååº
|
@param pShareCalendar:
|
@param pRspInfo:
|
@param nRequestID:
|
@param bIsPageLast:
|
@param bIsTotalLast:
|
@return:
|
zOnRspInquiryShareCalendar:N)Ú_sampleSpi__temp_cacherH r= r Úpopr. )r ZpShareCalendarrS rT Ú bIsPageLastÚ bIsTotalLastr r r ÚOnRspInquiryShareCalendarÄ s
|
|
|
z#sampleSpi.OnRspInquiryShareCalendarc C s || j krg | j |< |sd| j | |j|j|j|j|j|j|j|j t
|
|j d t
|
|j d d
|
¡ n0| j | | j |< | j |¡ tdt| j | dS )uµ
|
æ¥Kååº
|
@param pStockDayQuotation:
|
@param pRspInfo:
|
@param nRequestID:
|
@param bIsPageLast:
|
@param bIsTotalLast:
|
@return:
|
éd iè )
|
r2 r= r5 r6 r8 r9 r: r; r< r> z OnRspInquiryStockDayQuotation:N)rY rH r2 r= r5 r6 r8 r9 r: r; Úintr< r> r rZ r. r- )r ZpStockDayQuotationrS rT r[ r\ r r r Ú OnRspInquiryStockDayQuotationØ s
|
|
|
|
z'sampleSpi.OnRspInquiryStockDayQuotationN)r r )r r )Ú__name__Ú
|
__module__Ú __qualname__r rY r r r* r0 rF rL rM rQ rU rV rX r] r` r r r r r
|
s
|
|
7 r
|
)Ú request_queueÚresponse_queuec
|
sÈ fdd}x¶y| ¡ }|d }|d }| d¡}|dkrb|d }|d }t ||¡} ||| n8|d kr|d }|d }|d
|
}
|
t |
|
||¡} ||| W q tk
|
r¾ } zW d d } ~ X Y qX qW d S ) Nc s | |d¡ d S )N)r# Údata)Ú
|
put_nowait)r# Ú response_data)re r r Ú__set_response_dataø s z+__read_request.<locals>.__set_response_dataÚtyper# rf Úget_trade_calendarr r Úget_history_k_barsr3 )ÚgetÚthespir0 rL r ) rd re ri ÚvalÚtype_r# rf r r r$ r3 r& r )re r Ú__read_requestö s(
|
rq c C sx da dadadat ¡ s da datdt ¡ t ¡ }t
|
|a | t ¡ | t t¡ tjt| |fdd ¡ | ¡ d
|
S ) ul
|
è¿è¡
|
@param request_queue: 请æ±éå
|
@param response_queue: ååºéå
|
@return:
|
z 101.230.90.99iÔc Z 388000013942Z110808z 192.168.84.61iÕc zGetApiVersion():T)ÚtargetÚargsÚdaemonN)Z g_addressZg_portrN rP ÚconstantÚ
|
is_windowsr. r Z CQCValueAddProApi_GetApiVersionZ"CQCValueAddProApi_CreateInfoQryApir
|
rn Z RegisterSpiZ RegisterFrontÚ threadingÚThreadrq ÚstartZRun)rd re Ztheapir r r Úrun s
|
rz c C s t ¡ t ¡ } }t| | d S )N)ÚmultiprocessingÚQueuerz )rd re r r r Úmain4 s r} Ú__main__)r r{ rw r ru r Úlog_module.logr Úutilsr r r r r r
|
r| rq rz r} ra r r r r Ú<module> s" a "
|
