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

//! Goodwill (商誉) from Eastmoney.

use super::helpers::{json_f64, json_str, json_str_opt};
use super::types::{SyDetail, SyJzDetail, SyProfile, SyYqDetail};
use crate::client::AkShareClient;
use crate::error::Result;

impl AkShareClient {
    /// A股商誉市场概况
    pub async fn stock_sy_profile_em(&self) -> Result<Vec<SyProfile>> {
        let data = self
            .dc_fetch_all(
                "RPT_GOODWILL_MARKET",
                "ALL",
                "",
                "REPORT_DATE",
                "-1",
                500,
                2,
                &[],
            )
            .await?;
        Ok(data
            .iter()
            .map(|v| SyProfile {
                report_date: json_str(v, "REPORT_DATE"),
                goodwill: json_f64(v, "GOODWILL"),
                goodwill_impairment: json_f64(v, "GOODWILL_IMPAIRMENT"),
                net_assets: json_f64(v, "NET_ASSETS"),
                goodwill_to_net_assets_ratio: json_f64(v, "GOODWILL_TO_NET_ASSETS_RATIO"),
                impairment_to_net_assets_ratio: json_f64(v, "IMPAIRMENT_TO_NET_ASSETS_RATIO"),
                net_profit: json_f64(v, "NET_PROFIT"),
                impairment_to_net_profit_ratio: json_f64(v, "IMPAIRMENT_TO_NET_PROFIT_RATIO"),
            })
            .collect())
    }

    /// 商誉减值预期明细
    pub async fn stock_sy_yq_em(&self, indicator: &str) -> Result<Vec<SyYqDetail>> {
        let report_name = match indicator {
            "沪市主板" => "RPT_GOODWILL_EXPECT_SH",
            "深市主板" => "RPT_GOODWILL_EXPECT_SZ",
            "创业板" => "RPT_GOODWILL_EXPECT_CYB",
            _ => "RPT_GOODWILL_EXPECT",
        };
        let data = self
            .dc_fetch_all(report_name, "ALL", "", "GOODWILL", "-1", 500, 5, &[])
            .await?;
        Ok(data
            .iter()
            .map(|v| SyYqDetail {
                code: json_str(v, "SECURITY_CODE"),
                name: json_str(v, "SECURITY_NAME_ABBR"),
                report_date: json_str(v, "REPORT_DATE"),
                notice_date: json_str(v, "NOTICE_DATE"),
                goodwill: json_f64(v, "GOODWILL"),
                predicted_impairment: json_f64(v, "PREDICTED_IMPAIRMENT"),
                net_profit: json_f64(v, "NET_PROFIT"),
                impairment_reason: json_str_opt(v, "IMPAIRMENT_REASON"),
            })
            .collect())
    }

    /// 个股商誉减值明细
    pub async fn stock_sy_jz_em(&self, symbol: &str) -> Result<Vec<SyJzDetail>> {
        let filter = format!("(SECURITY_CODE=\"{symbol}\")");
        let data = self
            .dc_fetch_all(
                "RPT_GOODWILL_IMPAIRMENT",
                "ALL",
                &filter,
                "REPORT_DATE",
                "-1",
                500,
                2,
                &[],
            )
            .await?;
        Ok(data
            .iter()
            .map(|v| SyJzDetail {
                code: json_str(v, "SECURITY_CODE"),
                name: json_str(v, "SECURITY_NAME_ABBR"),
                report_date: json_str(v, "REPORT_DATE"),
                notice_date: json_str(v, "NOTICE_DATE"),
                goodwill: json_f64(v, "GOODWILL"),
                impairment_amount: json_f64(v, "IMPAIRMENT_AMOUNT"),
                net_profit: json_f64(v, "NET_PROFIT"),
            })
            .collect())
    }

    /// 个股商誉明细
    pub async fn stock_sy_em(&self, symbol: &str) -> Result<Vec<SyDetail>> {
        let filter = format!("(SECURITY_CODE=\"{symbol}\")");
        let data = self
            .dc_fetch_all(
                "RPT_GOODWILL_DETAIL",
                "ALL",
                &filter,
                "REPORT_DATE",
                "-1",
                500,
                2,
                &[],
            )
            .await?;
        Ok(data
            .iter()
            .map(|v| SyDetail {
                code: json_str(v, "SECURITY_CODE"),
                name: json_str(v, "SECURITY_NAME_ABBR"),
                report_date: json_str(v, "REPORT_DATE"),
                notice_date: json_str(v, "NOTICE_DATE"),
                goodwill: json_f64(v, "GOODWILL"),
                goodwill_change: json_f64(v, "GOODWILL_CHANGE"),
                net_profit: json_f64(v, "NET_PROFIT"),
                goodwill_to_net_assets_ratio: json_f64(v, "GOODWILL_TO_NET_ASSETS_RATIO"),
            })
            .collect())
    }
}