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

//! Per-stock financial reports (个股三大报表) from Eastmoney emweb.

use super::types::ThreeReportEntry;
use crate::client::AkShareClient;
use crate::error::Result;

impl AkShareClient {
    /// Per-stock financial report fetch helper using emweb API.
    async fn emweb_three_report(
        &self,
        symbol: &str,
        report_type: &str,
        report_date_type: &str,
        report_type_num: &str,
    ) -> Result<Vec<ThreeReportEntry>> {
        let code = symbol.to_lowercase();
        let url = format!(
            "https://emweb.securities.eastmoney.com/PC_HSF10/NewFinanceAnalysis/{report_type}"
        );
        let resp = self
            .get(&url)
            .query(&[
                ("companyType", "4"),
                ("reportDateType", report_date_type),
                ("reportType", report_type_num),
                ("code", &code),
            ])
            .send()
            .await?
            .error_for_status()?
            .json::<serde_json::Value>()
            .await?;

        let data = resp
            .get("data")
            .and_then(|d| d.as_array())
            .cloned()
            .unwrap_or_default();
        Ok(data
            .iter()
            .map(|v| ThreeReportEntry {
                report_date: v
                    .get("REPORT_DATE")
                    .and_then(|d| d.as_str())
                    .unwrap_or("")
                    .to_string(),
                data: v.clone(),
            })
            .collect())
    }

    /// 资产负债表-按报告期
    pub async fn stock_balance_sheet_by_report_em(
        &self,
        symbol: &str,
    ) -> Result<Vec<ThreeReportEntry>> {
        self.emweb_three_report(symbol, "zcfzbDateAjaxNew", "0", "1")
            .await
    }

    /// 资产负债表-按年度
    pub async fn stock_balance_sheet_by_yearly_em(
        &self,
        symbol: &str,
    ) -> Result<Vec<ThreeReportEntry>> {
        self.emweb_three_report(symbol, "zcfzbDateAjaxNew", "1", "1")
            .await
    }

    /// 利润表-按报告期
    pub async fn stock_profit_sheet_by_report_em(
        &self,
        symbol: &str,
    ) -> Result<Vec<ThreeReportEntry>> {
        self.emweb_three_report(symbol, "lrbDateAjaxNew", "0", "1")
            .await
    }

    /// 利润表-按年度
    pub async fn stock_profit_sheet_by_yearly_em(
        &self,
        symbol: &str,
    ) -> Result<Vec<ThreeReportEntry>> {
        self.emweb_three_report(symbol, "lrbDateAjaxNew", "1", "1")
            .await
    }

    /// 利润表-按单季度
    pub async fn stock_profit_sheet_by_quarterly_em(
        &self,
        symbol: &str,
    ) -> Result<Vec<ThreeReportEntry>> {
        self.emweb_three_report(symbol, "lrbDateAjaxNew", "0", "2")
            .await
    }

    /// 现金流量表-按报告期
    pub async fn stock_cash_flow_sheet_by_report_em(
        &self,
        symbol: &str,
    ) -> Result<Vec<ThreeReportEntry>> {
        self.emweb_three_report(symbol, "xjllDateAjaxNew", "0", "1")
            .await
    }

    /// 现金流量表-按年度
    pub async fn stock_cash_flow_sheet_by_yearly_em(
        &self,
        symbol: &str,
    ) -> Result<Vec<ThreeReportEntry>> {
        self.emweb_three_report(symbol, "xjllDateAjaxNew", "1", "1")
            .await
    }

    /// 现金流量表-按单季度
    pub async fn stock_cash_flow_sheet_by_quarterly_em(
        &self,
        symbol: &str,
    ) -> Result<Vec<ThreeReportEntry>> {
        self.emweb_three_report(symbol, "xjllDateAjaxNew", "0", "2")
            .await
    }
}