
    fiX              	          d Z ddlZddlZdej        fdZ	 ddeded	edej        fd
Z	 dded	edej        fdZddedej        fdZ	ddedej        fdZ
ddedej        fdZedk    r e            Z ee            eddd          Z ee            edd          Z ee            e	d          Z ee            e
d          Z ee            ed          Z ee           dS dS )uu   
Date: 2025/1/13 22:30
Desc: 东方财富网-数据中心-大宗交易-市场统计
https://data.eastmoney.com/dzjy/
    Nreturnc            	      L   d} ddddddddd	}t          j        | |
          }|                                }t          |d         d                   }t	          j                    }t          d|dz             D ]{}|                    d|i           t          j        | |
          }|                                }t	          j        |d         d                   }t	          j        ||gd          }||	                    d           |d         dz   |d<   g d|_
        t	          j        |d         d          j        j        |d<   t	          j        |d         d          |d<   t	          j        |d         d          |d<   t	          j        |d         d          |d<   t	          j        |d         d          |d<   t	          j        |d         d          |d<   t	          j        |d         d          |d<   t	          j        |d         d          |d<   |S )u   
    东方财富网-数据中心-大宗交易-市场统计
    https://data.eastmoney.com/dzjy/dzjy_sctj.html
    :return: 市场统计表
    :rtype: pandas.DataFrame
    4https://datacenter-web.eastmoney.com/api/data/v1/get
TRADE_DATE-15001PRT_BLOCKTRADE_MARKET_STAzvTRADE_DATE,SZ_INDEX,SZ_CHANGE_RATE,BLOCKTRADE_DEAL_AMT,PREMIUM_DEAL_AMT,PREMIUM_RATIO,DISCOUNT_DEAL_AMT,DISCOUNT_RATIOWEB)sortColumns	sortTypespageSize
pageNumber
reportNamecolumnssourceclientparamsresultpages   r   dataTobjsignore_indexinplaceindex)	   序号   交易日期   上证指数   上证指数涨跌幅   大宗交易成交总额   溢价成交总额   溢价成交总额占比   折价成交总额   折价成交总额占比r!   coerceerrorsr"   r#   r$   r%   r&   r'   r(   )requestsgetjsonintpd	DataFramerangeupdateconcatreset_indexr   to_datetimedtdate
to_numeric)urlr   r	data_json
total_pagebig_dfpagetemp_dfs           F/usr/local/lib/python3.11/dist-packages/akshare/stock/stock_dzjy_em.pystock_dzjy_sctjrB      sc    AC#19
 
F 	S(((AIYx(122J\^^Faa(( F F|T*+++LV,,,FFHH	,y26:;; 1EEE
t$$$Wo)F7O
 
 
FN  ^F>,B8TTTW\F>]6.+A(SSSF>&(mF;R4S\d&e&e&eF"#)+)*8* * *F%& $&=8L1MV^#_#_#_F )+)*8* * *F%& $&=8L1MV^#_#_#_F )+)*8* * *F%& M       基金20220104symbol
start_dateend_datec                    ddddd}d}ddddd	d
ddd||           dd                     |dd         |dd         |dd         g           dd                     |dd         |dd         |dd         g           dd	}t          j        ||          }|                                }|d         d         st	          j                    S t	          j        |d         d                   }|                    d           |j        dz   |d<   | dv rg d|_        t	          j	        |d         d           j
        j        |d<   |g d!         }t	          j        |d"         d           |d"<   t	          j        |d#         d           |d#<   t	          j        |d$         d           |d$<   t	          j        |d%         d           |d%<   t	          j        |d&         d           |d&<   t	          j        |d'         d           |d'<   t	          j        |d(         d           |d(<   | d)v rg d*|_        t	          j	        |d         d           j
        j        |d<   |g d+         }t	          j        |d$         d           |d$<   t	          j        |d&         d           |d&<   t	          j        |d'         d           |d'<   |S ),uz  
    东方财富网-数据中心-大宗交易-每日明细
    https://data.eastmoney.com/dzjy/dzjy_mrmx.html
    :param symbol: choice of {'A股', 'B股', '基金', '债券'}
    :type symbol: str
    :param start_date: 开始日期
    :type start_date: str
    :param end_date: 结束日期
    :type end_date: str
    :return: 每日明细
    :rtype: pandas.DataFrame
    r	   234)   A股   B股rD      债券r   SECURITY_CODE5000RPT_DATA_BLOCKTRADEa   TRADE_DATE,SECURITY_CODE,SECUCODE,SECURITY_NAME_ABBR,CHANGE_RATE,CLOSE_PRICE,DEAL_PRICE,PREMIUM_RATIO,DEAL_VOLUME,DEAL_AMT,TURNOVER_RATE,BUYER_NAME,SELLER_NAME,CHANGE_RATE_1DAYS,CHANGE_RATE_5DAYS,CHANGE_RATE_10DAYS,CHANGE_RATE_20DAYS,BUYER_CODE,SELLER_CODEr   z(SECURITY_TYPE_WEB=z)(TRADE_DATE>=
        '-N      z')(TRADE_DATE<=
        '')	r   r   r   r   r   r   r   r   filterr   r   r   Tr   r   r   >   rM   )r    r!      证券代码rS      证券简称	   涨跌幅	   收盘价	   成交价	   折溢率	   成交量	   成交额   成交额/流通市值   买方营业部   卖方营业部_rd   rd   rd   rd   rd   r!   r)   r*   )r    r!   rY   rZ   r[   r\   r]   r^   r_   r`   ra   rb   rc   r[   r\   r]   r^   r_   r`   ra   >   rN   rO   rD   )r    r!   rY   rS   rZ   rS   rS   r]   rS   r_   r`   rS   rb   rc   rd   rd   rd   rd   rd   rd   )	r    r!   rY   rZ   r]   r_   r`   rb   rc   joinr,   r-   r.   r0   r1   r5   r   r   r6   r7   r8   r9   )	rF   rG   rH   
symbol_mapr:   r   r;   r<   r@   s	            rA   stock_dzjy_mrmxrh   H   ss     	 J AC&+k F*V*< F F
((JrrNJqsOZ^D
E
EF F
((HRaRL(1Q3-!"">
?
?F F F F 	S(((AIXv& |~~l9X.v677G%%%}q(GG
 
 
, #%.N#H#
 #
 #

T 	   
"  "}W[-A(SSS!}W[-A(SSS!}W[-A(SSS!}W[-A(SSS!}W[-A(SSS!}W[-A(SSS,.M,-h-
 -
 -
() ---
 
 
, #%.N#H#
 #
 #

T 	 
 
 

  "}W[-A(SSS!}W[-A(SSS!}W[-A(SSSNrC   20220105c                 *   d}ddddddddd	d
                     | dd         | dd         | dd         g           dd
                     |dd         |dd         |dd         g           dd	}t          j        ||          }|                                }t	          j        |d         d                   }|                    d           |j        dz   |d<   g d|_        t	          j	        |d         d          j
        j        |d<   |g d         }t	          j        |d         d          |d<   t	          j        |d         d          |d<   t	          j        |d         d          |d<   t	          j        |d          d          |d <   t	          j        |d!         d          |d!<   t	          j        |d"         d          |d"<   t	          j        |d#         d          |d#<   t	          j        |d$         d          |d$<   |S )%u"  
    东方财富网-数据中心-大宗交易-每日统计
    https://data.eastmoney.com/dzjy/dzjy_mrtj.html
    :param start_date: 开始日期
    :type start_date: str
    :param end_date: 结束日期
    :type end_date: str
    :return: 每日统计
    :rtype: pandas.DataFrame
    r   TURNOVERRATEr   rQ   r	   RPT_BLOCKTRADE_STAzTRADE_DATE,SECURITY_CODE,SECUCODE,SECURITY_NAME_ABBR,CHANGE_RATE,CLOSE_PRICE,AVERAGE_PRICE,PREMIUM_RATIO,DEAL_NUM,VOLUME,DEAL_AMT,TURNOVERRATE,D1_CLOSE_ADJCHRATE,D5_CLOSE_ADJCHRATE,D10_CLOSE_ADJCHRATE,D20_CLOSE_ADJCHRATEr   z(TRADE_DATE>='rS   NrT   rU   z')(TRADE_DATE<='rV   rW   r   r   r   Tr   r   r   )r    r!   rY   rS   rZ   r[   r\   r]   r^      成交笔数   成交总量   成交总额   成交总额/流通市值rd   rd   rd   rd   r!   r)   r*   )r    r!   rY   rZ   r[   r\   r]   r^   rm   rn   ro   rp   r[   r\   r]   r^   rm   rn   ro   rp   re   )rG   rH   r:   r   r;   r<   r@   s          rA   stock_dzjy_mrtjrq      sm    AC%*e F388Z^Z!_jYZY[Y[n,]#^#^ F FHHhrrlHQqSM8ABB<@AAF F F F 	S(((AIl9X.v677G%%%}q(GG  GO& !nW^-DXVVVY^GN	
 	
 	
G  =)=hOOOGK=)=hOOOGK=)=hOOOGK=)=hOOOGK mGN,CHUUUGN mGN,CHUUUGN mGN,CHUUUGN+-=+,X, , ,G'( NrC   	   近三月c                    ddddd}d}ddd	dd
dddd||           dd	}t          j        ||          }|                                }|d         d         }t          j                    }t          dt          |          dz             D ]{}|                    d|i           t          j        ||          }|                                }t          j        |d         d                   }	t          j        ||	gd          }||	                    d           |j
        dz   |d<   g d|_        |g d         }t          j        |d         d          j        j        |d<   t          j        |d         d          |d<   t          j        |d          d          |d <   t          j        |d!         d          |d!<   t          j        |d"         d          |d"<   t          j        |d#         d          |d#<   t          j        |d$         d          |d$<   t          j        |d%         d          |d%<   t          j        |d&         d          |d&<   t          j        |d'         d          |d'<   t          j        |d(         d          |d(<   t          j        |d)         d          |d)<   t          j        |d*         d          |d*<   |S )+u  
    东方财富网-数据中心-大宗交易-活跃 A 股统计
    https://data.eastmoney.com/dzjy/dzjy_hygtj.html
    :param symbol: choice of {'近一月', '近三月', '近六月', '近一年'}
    :type symbol: str
    :return: 活跃 A 股统计
    :rtype: pandas.DataFrame
    r	   rK   612u	   近一月rr   u	   近六月u	   近一年r   zDEAL_NUM,SECURITY_CODE-1,-1rQ   RPT_BLOCKTRADE_ACSTAzSECURITY_CODE,SECUCODE,SECURITY_NAME_ABBR,CLOSE_PRICE,CHANGE_RATE,TRADE_DATE,DEAL_AMT,PREMIUM_RATIO,SUM_TURNOVERRATE,DEAL_NUM,PREMIUM_TIMES,DISCOUNT_TIMES,D1_AVG_ADJCHRATE,D5_AVG_ADJCHRATE,D10_AVG_ADJCHRATE,D20_AVG_ADJCHRATE,DATE_TYPE_CODEr   z(DATE_TYPE_CODE=)rW   r   r   r   r   r   r   Tr   r   r   )r    rY   rd   rZ   	   最新价r[      最近上榜日   总成交额r^   rp      上榜次数-总计   上榜次数-溢价   上榜次数-折价    上榜日后平均涨跌幅-1日    上榜日后平均涨跌幅-5日!   上榜日后平均涨跌幅-10日!   上榜日后平均涨跌幅-20日rd   )r    rY   rZ   rz   r[   r{   r}   r~   r   r|   r^   rp   r   r   r   r   r{   r)   r*   rz   r[   r}   r~   r   r|   r^   rp   r   r   r   r   r,   r-   r.   r0   r1   r2   r/   r3   r4   r5   r   r   r6   r7   r8   r9   
rF   
period_mapr:   r   r;   r<   r=   r>   r?   r@   s
             rA   stock_dzjy_hygtjr   '  sZ    	 J AC/,_ :Z%7::: F 	S(((AI8$W-J\^^FaZ1,-- F F|T*+++LV,,,FFHH	,y26:;; 1EEE
t$$$lQ&F7O  FN( 	
 	
 	
F( !#v6G/HQY Z Z Z ] bF-{(;HMMMF;-{(;HMMMF;$&M&9N2OX`$a$a$aF !$&M&9N2OX`$a$a$aF !$&M&9N2OX`$a$a$aF !]6.+A(SSSF>-{(;HMMMF;*,-*+H+ + +F&' 241282 2 2F-. 241282 2 2F-. 35-23H3 3 3F./ 35-23H3 3 3F./ MrC      近3日c                    dddddd}d}dd	d
dddddd||           dd	}t          j        ||          }|                                }|d         d         }t          j                    }t          dt          |          dz             D ]{}|                    d|i           t          j        ||          }|                                }t          j        |d         d                   }	t          j        ||	gd          }||	                    d           |j
        dz   |d<   g d|_        |g d         }t          j        |d         d          j        j        |d<   t          j        |d          d          |d <   t          j        |d!         d          |d!<   t          j        |d"         d          |d"<   t          j        |d#         d          |d#<   t          j        |d$         d          |d$<   |S )%u4  
    东方财富网-数据中心-大宗交易-活跃营业部统计
    https://data.eastmoney.com/dzjy/dzjy_hyyybtj.html
    :param symbol: choice of {'当前交易日', '近3日', '近5日', '近10日', '近30日'}
    :type symbol: str
    :return: 活跃营业部统计
    :rtype: pandas.DataFrame
    r	   rK   51030)u   当前交易日r   u   近5日u   近10日u   近30日r   zBUYER_NUM,TOTAL_BUYAMTrw   rQ   $RPT_BLOCKTRADE_OPERATEDEPTSTATISTICSzOPERATEDEPT_CODE,OPERATEDEPT_NAME,ONLIST_DATE,STOCK_DETAILS,BUYER_NUM,SELLER_NUM,TOTAL_BUYAMT,TOTAL_SELLAMT,TOTAL_NETAMT,N_DATEr   	(N_DATE=-ry   rW   r   r   r   r   r   r   Tr   r   r   )r    rd      营业部名称r{      买入的股票   次数总计-买入   次数总计-卖出   成交金额统计-买入   成交金额统计-卖出   成交金额统计-净买入额rd   )	r    r{   r   r   r   r   r   r   r   r{   r)   r*   r   r   r   r   r   r   r   s
             rA   stock_dzjy_hyyybtjr     sp     J AC/<N3j0333 F 	S(((AI8$W-J\^^FaZ1,-- F F|T*+++LV,,,FFHH	,y26:;; 1EEE
t$$$lQ&F7O  FN 
	
 
	
 
	
F !#v6G/HQY Z Z Z ] bF$&M&9N2OX`$a$a$aF !$&M&9N2OX`$a$a$aF !*,-*+H+ + +F&' +--*+H+ + +F&' 1301(1 1 1F,- MrC   c                 f   ddddd}d}ddd	d
ddddd||           dd	}t          j        ||          }|                                }|d         d         }t          j                    }t          dt          |          dz             D ]{}|                    d|i           t          j        ||          }|                                }t          j        |d         d                   }	t          j        ||	gd          }||	                    d           |j
        dz   |d<   g d|_        |g d         }t          j        |d         d          |d<   t          j        |d          d          |d <   t          j        |d!         d          |d!<   t          j        |d"         d          |d"<   t          j        |d#         d          |d#<   t          j        |d$         d          |d$<   t          j        |d%         d          |d%<   t          j        |d&         d          |d&<   t          j        |d'         d          |d'<   t          j        |d(         d          |d(<   t          j        |d)         d          |d)<   t          j        |d*         d          |d*<   |S )+u  
    东方财富网-数据中心-大宗交易-营业部排行
    https://data.eastmoney.com/dzjy/dzjy_yybph.html
    :param symbol: choice of {'近一月', '近三月', '近六月', '近一年'}
    :type symbol: str
    :return: 营业部排行
    :rtype: pandas.DataFrame
    r   90180360rv   r   z D5_BUYER_NUM,D1_AVERAGE_INCREASErw   rQ   r	   RPT_BLOCKTRADE_OPERATEDEPT_RANKa  OPERATEDEPT_CODE,OPERATEDEPT_NAME,D1_BUYER_NUM,D1_AVERAGE_INCREASE,D1_RISE_PROBABILITY,D5_BUYER_NUM,D5_AVERAGE_INCREASE,D5_RISE_PROBABILITY,D10_BUYER_NUM,D10_AVERAGE_INCREASE,D10_RISE_PROBABILITY,D20_BUYER_NUM,D20_AVERAGE_INCREASE,D20_RISE_PROBABILITY,N_DATE,RELATED_ORG_CODEr   r   ry   rW   r   r   r   r   r   r   Tr   r   r   )r    rd   r      上榜后1天-买入次数   上榜后1天-平均涨幅   上榜后1天-上涨概率   上榜后5天-买入次数   上榜后5天-平均涨幅   上榜后5天-上涨概率   上榜后10天-买入次数   上榜后10天-平均涨幅   上榜后10天-上涨概率   上榜后20天-买入次数   上榜后20天-平均涨幅   上榜后20天-上涨概率rd   rd   )r    r   r   r   r   r   r   r   r   r   r   r   r   r   r   r)   r*   r   r   r   r   r   r   r   r   r   r   r   )r,   r-   r.   r0   r1   r2   r/   r3   r4   r5   r   r   r9   r   s
             rA   stock_dzjy_yybphr     sw    	 J AC97L 3j0333 F 	S(((AI8$W-J\^^FaZ1,-- F F|T*+++LV,,,FFHH	,y26:;; 1EEE
t$$$lQ&F7O  FN& 	
 	
 	
F$ ,.=+,X, , ,F'( ,.=+,X, , ,F'( ,.=+,X, , ,F'( ,.=+,X, , ,F'( ,.=+,X, , ,F'( ,.=+,X, , ,F'( -/M,-h- - -F() -/M,-h- - -F() -/M,-h- - -F() -/M,-h- - -F() -/M,-h- - -F() -/M,-h- - -F() MrC   __main__rO   )rF   rG   rH   )rG   rH   )rF   )rD   rE   rE   )ri   ri   )rr   )r   )__doc__pandasr0   r,   r1   rB   strrh   rq   r   r   r   __name__stock_dzjy_sctj_dfprintstock_dzjy_mrmx_dfstock_dzjy_mrtj_dfstock_dzjy_hygtj_dfstock_dzjy_hyyybtj_dfstock_dzjy_yybph_df rC   rA   <module>r      sd        8 8 8 8 8x KUJ JJ(+JDGJ\J J J J\ 3=O OO,/O\O O O Odh hS h2< h h h hVO Os O2< O O O Odt tS t2< t t t tn z(**	E
(J   
E
(JTTT	E
**+>>>	E
..i@@@	E
   **+>>>	E
' rC   