B
|
ÙÕd9 ã @ s d Z ddlZddlZddlmZ ddlmZ ddlmZm Z ddl
|
m Z G dd dZ G d d
|
d
|
Z G d d d ZG d d dZedkre dd¡Zee dS )u
|
åå
´äº¤æè®°å½
|
é N)Ú
|
RedisUtils)Útool)Ú
|
mysql_dataÚ redis_manager)ÚHistoryKDatasUtilsc @ s( e Zd Zedd Zeg fddZdS )ÚDelegateRecordManagerc
|
C sn t ¡ }z\|rdxN|D ]D}| d|d d¡}|sÖt |d g¡}| |d ¡}| d|d |d ||d |d |d |d |d
|
|d |d |d |d |d |d |d |d t ¡ t ¡ |d f ¡ qi }|d |d krö|d |d< |d |d
|
kr|d
|
|d
|
< |d |d kr2|d |d < |d t |d krT|d |d < |d |d krr|d |d< |d t
|
|d kr|d |d< |d t
|
|d kr¶|d |d< |d |d krÔ|d |d< |rt ¡ |d < g }xT|D ]L} t || t kr | | d || d¡ n| | d || ¡ qîW | d d |¡ d!|d" d¡ qW W d X d S )#Nz;select * from hx_trade_delegate_record where orderLocalID='Ú orderLocalIDú'Ú
|
securityIDzinsert into hx_trade_delegate_record values('%s','%s','%s','%s','%s','%s','%s','%s','%s','%s','%s','%s','%s','%s','%s','%s','%s','%s','%s')Ú directionÚ
|
orderSysIDÚ
|
insertTimeÚ
|
insertDateÚ
|
acceptTimeÚ
|
cancelTimeÚ
|
limitPriceÚturnoverÚvolumeÚ volumeTradedÚ orderStatusÚorderSubmitStatusÚ statusMsgÚ accountIDé é é é
|
é é é é Ú
|
updateTimez='ú=z$update hx_trade_delegate_record set ú,z where orderLocalID='r )r ÚMysqldbÚ
|
select_oner Zget_gp_codes_namesÚgetÚexecuter Úget_now_datetime_strÚstrÚintÚtypeÚappendÚjoin)
|
ÚclsÚdatasÚmysqldbÚdÚresultZnameDictÚnameÚ
|
updateDictÚ
|
where_listÚk© r7 úED:\workspace\GP\gp_middle_server\utils\huaxin_trade_record_manager.pyÚadd sV
|
&zDelegateRecordManager.addc C sV t ¡ }zDd| dg}|r0| d| d¡ |rZd dd |D ¡}| d| d¡ | d d
|
|¡ d ¡}d d ddddddddddddddd d d g}g } d }
|
|r8x|D ]} |
|
sÀ| d }
|
| d |
|
krÔ| d }
|
i } xPtt| D ]@} t| | tjkr| | d ¡| || < qæ| | | || < qæW | | ¡ q°W | |
|
rJ|
|
d ¡nd fS X d S )!Nzr.insertDate='r zupdateTime > 'z or c S s g | ]}d | qS )zorderStatus = r7 )Ú.0r6 r7 r7 r8 ú
|
<listcomp>P s z5DelegateRecordManager.list_by_day.<locals>.<listcomp>ú(ú)z/select * from hx_trade_delegate_record r where z and z order by createTimer r
|
Ú securityNamer r r r r r r r r r r r r Ú
|
createTimer! r é z%Y-%m-%d %H:%M:%S)
|
r r$ r, r- Ú
|
select_allÚrangeÚlenr+ ÚdatetimeÚstrftime)r. ÚdayZmin_update_timer r0 r5 ÚssÚresultsÚkey_listÚfresultsZmax_update_timeÚrÚtempÚir7 r7 r8 Ú list_by_dayH s:
|
z!DelegateRecordManager.list_by_dayN)Ú__name__Ú
|
__module__Ú __qualname__Ú classmethodr9 rN r7 r7 r7 r8 r s 5r c @ s^ e Zd Ze d¡Zedd Zedd Zedd Z edd Z
|
ed
|
d Z ed d Z dS )ÚPositionManageré c C s
|
| j ¡ S )N)Ú _PositionManager__redisManagerÚgetRedis)r. r7 r7 r8 Z __get_redisq s zPositionManager.__get_redisc C s$ t | ¡ d| t ¡ | ¡ d S )NÚavailable_position_)r ÚsetexÚ_PositionManager__get_redisr Ú
|
get_expire)r. Úcoder r7 r7 r8 Z__save_code_volumev s z"PositionManager.__save_code_volumec C s& t | ¡ d| ¡}|s dS t|S )NrW r )r r& rY r* )r. r[ Úvalr7 r7 r8 Úget_code_volumez s z PositionManager.get_code_volumec
|
C sp t ¡ }z^|rfi }x@|D ]8}|d |kr8d||d < ||d |d ||d < q W x |D ]}| ||| ¡ q^W xì|D ]â}|d d|d d|d }| d| d¡}|s@| d ||d |d |d
|
|d |d |d |d |d |d |d |d |d |d |d |d |d |d t ¡ t ¡ f ¡ q~i }|d |d krb|d |d < |d |d kr|d |d < |d |d kr|d |d < |d |d kr¼|d |d< |d |d krÜ|d |d< |d |d krü|d |d< |d |d kr|d |d< |d |d kr8|d |d< |d |d krV|d |d< |d |d krv|d |d< |d! |d kr|d |d< |d" |d kr¶|d |d< |d# |d krÖ|d |d< |r~t ¡ |d$< g } xT|D ]L}t|| tkr"| | d%|| d¡ n| | d&|| ¡ qðW | d'd(
|
| ¡ d)|d d¡ q~W W d X d S )*Nr
|
r ÚavailablePositionÚ
|
investorIDú-Ú
|
tradingDayz*select * from hx_trade_position where id='r zinsert into hx_trade_position values('%s','%s','%s','%s','%s','%s','%s','%s','%s','%s','%s','%s','%s','%s','%s','%s','%s','%s','%s','%s')r> Ú
|
historyPosÚhistoryPosFrozenÚ
|
todayBSPosÚtodayBSPosFrozenÚhistoryPosPriceÚ totalPosCostÚ prePositionÚcurrentPositionÚ openPosCostÚtodayCommissionÚtodayTotalBuyAmountÚtodayTotalSellAmounté é r r é r é r r r r é r@ r! z='r" z update hx_trade_position set r# z where id=') r r$ Ú"_PositionManager__save_code_volumer% r' r r( r+ r) r, r- )
|
r. r/ r0 Z volume_dictr1 r6 Ú_idr2 r4 r5 r7 r7 r8 r9 s|
|
|
|
&zPositionManager.addc C sÄ t ¡ }z´| d| d¡}ddddddd d
|
d d d ddddddddg}g }|rºxj|D ]b}i }xNtt|D ]>}t|| tjkr|| d¡||| < qj|| ||| < qjW | |¡ qTW |S X d S )Nz6select * from hx_trade_position r where r.tradingDay='z' order by createTimeÚidr_ r> r
|
rb rc rd re rf rg rh r^ ri rj rk rl rm r? r! z%Y-%m-%d %H:%M:%S) r r$ rA rB rC r+ rD rE r, ) r. rF r0 rH rI rJ rK rL rM r7 r7 r8 rN Ë s(
|
|
|
zPositionManager.list_by_dayc C s t ¡ }| d| d¡ d S )Nz@select currentPosition from hx_trade_position where securityID='r )r r$ r% )r. r[ r0 r7 r7 r8 Úget_volume_by_codeæ s z"PositionManager.get_volume_by_codeN) rO rP rQ r Ú RedisManagerrU rR rY rs r] r9 rN rv r7 r7 r7 r8 rS n s
|
J rS c @ s$ e Zd Zedd Zedd ZdS )ÚDealRecordManagerc C s¨ t ¡ }z|rx|D ]}| d|d d¡}|s| d|d |d |d |d |d t|d d
|
|d |d |d |d |d |d t ¡ t ¡ f ¡ qW W d X d S )Nz2select * from hx_trade_deal_record where tradeID='ÚtradeIDr zninsert into hx_trade_deal_record values('%s','%s','%s','%s','%s','%s','%s','%s','%s','%s','%s','%s','%s','%s')r
|
r r r ÚpricerT Ú tradeTimer Ú tradeDatera ÚpbuIDr )r r$ r% r' Úroundr r( )r. r/ r0 r1 r2 r7 r7 r8 r9 î s
|
zDealRecordManager.addc C sº t ¡ }zª| d| d¡}ddddddd d
|
d d d dddg}g }|r°xj|D ]b}i }xNtt|D ]>}t|| tjkr|| d¡||| < q`|| ||| < q`W | |¡ qJW |S X g S )Nz8select * from hx_trade_deal_record r where r.tradeDate='z' order by createTimery r
|
r r r rz r{ r r| ra r} r r? r! z%Y-%m-%d %H:%M:%S) r r$ rA rB rC r+ rD rE r, ) r. rF r0 rH rI rJ rK rL rM r7 r7 r8 rN s(
|
|
z DealRecordManager.list_by_dayN)rO rP rQ rR r9 rN r7 r7 r7 r8 rx í s rx c @ s: e Zd Ze d¡Zedd Zedd Zedd Z dS ) Ú MoneyManagerrT c C s
|
| j ¡ S )N)Ú _MoneyManager__redisManangerrV )r. r7 r7 r8 Ú get_redis# s zMoneyManager.get_redisc C s" t | ¡ dt ¡ t |¡¡ d S )NÚ huaxin_money)r rX r r rZ ÚjsonÚdumps)r. Údatar7 r7 r8 Ú save_data' s zMoneyManager.save_datac C s" t | ¡ d¡}|sd S t |¡S )Nr )r r& r r Úloads)r. r\ r7 r7 r8 Úget_data+ s zMoneyManager.get_dataN)
|
rO rP rQ r rw r rR r r r r7 r7 r7 r8 r s
|
r Ú__main__Z20230704z
|
1970-01-01)Ú__doc__rD r Údb.redis_managerr Úutilsr Údbr r Úutils.history_k_data_utilr r rS rx r rO rN rH Úprintr7 r7 r7 r8 Ú<module> s \3
|
