akshare 0.1.2

100% pure Rust implementation of akshare — unified access to Chinese and global financial market data APIs
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155

//! Shareholder count (股东户数) from Eastmoney.

use super::helpers::{fmt_date, json_f64, json_f64_opt, json_str};
use super::types::{Gdhs, GdhsDetail};
use crate::client::AkShareClient;
use crate::error::Result;

impl AkShareClient {
    /// 股东户数
    pub async fn stock_gdhs_em(&self, date: &str) -> Result<Vec<Gdhs>> {
        let date_fmt = fmt_date(date);
        let filter = format!("(END_DATE='{date_fmt}')");
        let data = self
            .dc_fetch_all(
                "RPT_F10_EH_HOLDERSNUM",
                "ALL",
                &filter,
                "SECURITY_CODE",
                "1",
                500,
                10,
                &[],
            )
            .await?;
        Ok(data
            .iter()
            .map(|v| Gdhs {
                code: json_str(v, "SECURITY_CODE"),
                name: json_str(v, "SECURITY_NAME_ABBR"),
                latest_price: json_f64_opt(v, "CLOSE_PRICE"),
                change_pct: json_f64_opt(v, "CHANGE_RATE"),
                holder_count: json_f64(v, "HOLDER_NUM"),
                prev_holder_count: json_f64(v, "HOLDER_NUM_CHANGE"),
                holder_change: json_f64(v, "HOLDER_NUM_RATIO"),
                holder_change_ratio: json_f64(v, "HOLDER_NUM_RATIO"),
                interval_change_pct: json_f64_opt(v, "INTERVAL_CHANGE_PCT"),
                current_end_date: json_str(v, "END_DATE"),
                prev_end_date: json_str(v, "PREV_END_DATE"),
                avg_market_cap: json_f64_opt(v, "AVG_MARKET_CAP"),
                avg_shares: json_f64_opt(v, "AVG_SHARES"),
                total_market_cap: json_f64_opt(v, "TOTAL_MARKET_CAP"),
                total_shares: json_f64_opt(v, "TOTAL_SHARES"),
                notice_date: json_str(v, "NOTICE_DATE"),
            })
            .collect())
    }

    /// 股东户数详情
    pub async fn stock_gdhs_detail_em(&self, symbol: &str) -> Result<Vec<GdhsDetail>> {
        let filter = format!("(SECURITY_CODE=\"{symbol}\")");
        let data = self
            .dc_fetch_all(
                "RPT_F10_EH_HOLDERSNUM",
                "ALL",
                &filter,
                "END_DATE",
                "-1",
                500,
                2,
                &[],
            )
            .await?;
        Ok(data
            .iter()
            .map(|v| GdhsDetail {
                end_date: json_str(v, "END_DATE"),
                holder_count: json_f64(v, "HOLDER_NUM"),
                prev_holder_count: json_f64(v, "HOLDER_NUM_CHANGE"),
                holder_change: json_f64(v, "HOLDER_NUM_RATIO"),
                holder_change_ratio: json_f64(v, "HOLDER_NUM_RATIO"),
                avg_market_cap: json_f64_opt(v, "AVG_MARKET_CAP"),
                avg_shares: json_f64_opt(v, "AVG_SHARES"),
                total_market_cap: json_f64_opt(v, "TOTAL_MARKET_CAP"),
                total_shares: json_f64_opt(v, "TOTAL_SHARES"),
                notice_date: json_str(v, "NOTICE_DATE"),
                interval_change_pct: json_f64_opt(v, "INTERVAL_CHANGE_PCT"),
            })
            .collect())
    }

    /// 东方财富-股东户数 (Python: stock_zh_a_gdhs)
    pub async fn stock_zh_a_gdhs(&self, symbol: &str) -> Result<Vec<Gdhs>> {
        let (report, filter) = if symbol == "最新" {
            ("RPT_HOLDERNUMLATEST", String::new())
        } else {
            ("RPT_HOLDERNUMLATEST", format!("(END_DATE='{symbol}')"))
        };
        let data = self
            .dc_fetch_all(
                report,
                "ALL",
                &filter,
                "HOLD_NOTICE_DATE,SECURITY_CODE",
                "-1",
                500,
                10,
                &[],
            )
            .await?;
        Ok(data
            .iter()
            .map(|v| Gdhs {
                code: json_str(v, "SECURITY_CODE"),
                name: json_str(v, "SECURITY_NAME_ABBR"),
                latest_price: json_f64_opt(v, "CLOSE_PRICE"),
                change_pct: json_f64_opt(v, "CHANGE_RATE"),
                holder_count: json_f64(v, "HOLDER_NUM"),
                prev_holder_count: json_f64(v, "PRE_HOLDER_NUM"),
                holder_change: json_f64(v, "HOLDER_NUM_CHANGE"),
                holder_change_ratio: json_f64(v, "HOLDER_NUM_RATIO"),
                interval_change_pct: json_f64_opt(v, "INTERVAL_CHRATE"),
                current_end_date: json_str(v, "END_DATE"),
                prev_end_date: json_str(v, "PRE_END_DATE"),
                avg_market_cap: json_f64_opt(v, "AVG_MARKET_CAP"),
                avg_shares: json_f64_opt(v, "AVG_HOLD_NUM"),
                total_market_cap: json_f64_opt(v, "TOTAL_MARKET_CAP"),
                total_shares: json_f64_opt(v, "TOTAL_A_SHARES"),
                notice_date: json_str(v, "HOLD_NOTICE_DATE"),
            })
            .collect())
    }

    /// 东方财富-股东户数详情 (Python: stock_zh_a_gdhs_detail_em)
    pub async fn stock_zh_a_gdhs_detail_em(&self, symbol: &str) -> Result<Vec<GdhsDetail>> {
        let filter = format!("(SECURITY_CODE=\"{symbol}\")");
        let data = self
            .dc_fetch_all(
                "RPT_HOLDERNUM_DET",
                "ALL",
                &filter,
                "END_DATE",
                "-1",
                500,
                10,
                &[],
            )
            .await?;
        Ok(data
            .iter()
            .map(|v| GdhsDetail {
                end_date: json_str(v, "END_DATE"),
                holder_count: json_f64(v, "HOLDER_NUM"),
                prev_holder_count: json_f64(v, "PRE_HOLDER_NUM"),
                holder_change: json_f64(v, "HOLDER_NUM_CHANGE"),
                holder_change_ratio: json_f64(v, "HOLDER_NUM_RATIO"),
                avg_market_cap: json_f64_opt(v, "AVG_MARKET_CAP"),
                avg_shares: json_f64_opt(v, "AVG_HOLD_NUM"),
                total_market_cap: json_f64_opt(v, "TOTAL_MARKET_CAP"),
                total_shares: json_f64_opt(v, "TOTAL_A_SHARES"),
                notice_date: json_str(v, "HOLD_NOTICE_DATE"),
                interval_change_pct: json_f64_opt(v, "INTERVAL_CHRATE"),
            })
            .collect())
    }
}