akshare 0.1.0

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

//! Datacenter financial reports (三大报表-数据中心) from Eastmoney.

use super::helpers::*;
use super::types::*;
use crate::client::AkShareClient;
use crate::error::Result;

impl AkShareClient {
    /// 资产负债表(数据中心)
    pub async fn stock_zcfz_em(&self, date: &str) -> Result<Vec<BalanceSheet>> {
        let date_fmt = fmt_date(date);
        let filter = format!(
            "(SECURITY_TYPE_CODE in (\"058001001\",\"058001008\"))(TRADE_MARKET_CODE!=\"069001017\")(REPORT_DATE='{}')",
            date_fmt
        );
        let data = self
            .dc_fetch_all(
                "RPT_DMSK_FN_BALANCE",
                "ALL",
                &filter,
                "NOTICE_DATE,SECURITY_CODE",
                "-1",
                500,
                10,
                &[],
            )
            .await?;
        Ok(data
            .iter()
            .map(|v| BalanceSheet {
                code: json_str(v, "SECURITY_CODE"),
                name: json_str(v, "SECURITY_NAME_ABBR"),
                notice_date: json_str_opt(v, "NOTICE_DATE"),
                total_assets: json_f64_opt(v, "TOTAL_ASSETS"),
                total_liabilities: json_f64_opt(v, "TOTAL_LIABILITIES"),
                equity: json_f64_opt(v, "TOTAL_EQUITY"),
                cash: json_f64_opt(v, "MONETARYFUNDS"),
                accounts_receivable: json_f64_opt(v, "ACCOUNTS_RECE"),
                inventory: json_f64_opt(v, "INVENTORY"),
                accounts_payable: json_f64_opt(v, "ACCOUNTS_PAYABLE"),
                advance_receipts: json_f64_opt(v, "ADVANCE_RECEIVABLES"),
                total_assets_yoy: json_f64_opt(v, "TOTAL_ASSETS_YOY"),
                total_liabilities_yoy: json_f64_opt(v, "TOTAL_LIABILITIES_YOY"),
                debt_ratio: json_f64_opt(v, "DEBT_ASSET_RATIO"),
            })
            .collect())
    }

    /// 利润表(数据中心)
    pub async fn stock_lrb_em(&self, date: &str) -> Result<Vec<ProfitSheet>> {
        let date_fmt = fmt_date(date);
        let filter = format!(
            "(SECURITY_TYPE_CODE in (\"058001001\",\"058001008\"))(TRADE_MARKET_CODE!=\"069001017\")(REPORT_DATE='{}')",
            date_fmt
        );
        let data = self
            .dc_fetch_all(
                "RPT_DMSK_FN_INCOME",
                "ALL",
                &filter,
                "NOTICE_DATE,SECURITY_CODE",
                "-1",
                500,
                10,
                &[],
            )
            .await?;
        Ok(data
            .iter()
            .map(|v| ProfitSheet {
                code: json_str(v, "SECURITY_CODE"),
                name: json_str(v, "SECURITY_NAME_ABBR"),
                notice_date: json_str_opt(v, "NOTICE_DATE"),
                total_revenue: json_f64_opt(v, "TOTAL_OPERATE_INCOME"),
                operating_cost: json_f64_opt(v, "OPERATE_COST"),
                operating_profit: json_f64_opt(v, "OPERATE_PROFIT"),
                total_profit: json_f64_opt(v, "TOTAL_PROFIT"),
                net_profit: json_f64_opt(v, "NETPROFIT"),
                net_profit_deducted: json_f64_opt(v, "DEDUCT_PARENT_NETPROFIT"),
                total_revenue_yoy: json_f64_opt(v, "TOTAL_OPERATE_INCOME_YOY"),
                net_profit_yoy: json_f64_opt(v, "PARENT_NETPROFIT_YOY"),
                gross_margin: json_f64_opt(v, "GROSS_PROFIT_RATIO"),
                net_margin: json_f64_opt(v, "NET_PROFIT_RATIO"),
                roe: json_f64_opt(v, "ROE"),
                eps: json_f64_opt(v, "BASIC_EPS"),
            })
            .collect())
    }

    /// 现金流量表(数据中心)
    pub async fn stock_xjll_em(&self, date: &str) -> Result<Vec<CashFlowSheet>> {
        let date_fmt = fmt_date(date);
        let filter = format!(
            "(SECURITY_TYPE_CODE in (\"058001001\",\"058001008\"))(TRADE_MARKET_CODE!=\"069001017\")(REPORT_DATE='{}')",
            date_fmt
        );
        let data = self
            .dc_fetch_all(
                "RPT_DMSK_FN_CASHFLOW",
                "ALL",
                &filter,
                "NOTICE_DATE,SECURITY_CODE",
                "-1",
                500,
                10,
                &[],
            )
            .await?;
        Ok(data
            .iter()
            .map(|v| CashFlowSheet {
                code: json_str(v, "SECURITY_CODE"),
                name: json_str(v, "SECURITY_NAME_ABBR"),
                notice_date: json_str_opt(v, "NOTICE_DATE"),
                operating_cash_flow: json_f64_opt(v, "NETCASH_OPERATE"),
                investing_cash_flow: json_f64_opt(v, "NETCASH_INVEST"),
                financing_cash_flow: json_f64_opt(v, "NETCASH_FINANCE"),
                cash_increase: json_f64_opt(v, "CCE_ADD"),
                operating_cash_flow_yoy: json_f64_opt(v, "NETCASH_OPERATE_YOY"),
            })
            .collect())
    }
}