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

//! Analyst rankings from Eastmoney.

use super::helpers::{json_f64, json_f64_opt, json_i64, json_str, json_str_opt};
use super::types::{AnalystDetail, AnalystRank};
use crate::client::AkShareClient;
use crate::error::Result;

impl AkShareClient {
    /// 东方财富分析师指数
    pub async fn stock_analyst_rank_em(&self, year: &str) -> Result<Vec<AnalystRank>> {
        let filter = format!("(YEAR=\"{year}\")");
        let data = self
            .dc_fetch_all(
                "RPT_ANALYST_INDEX_RANK",
                "ALL",
                &filter,
                "YEAR_YIELD",
                "-1",
                500,
                1,
                &[("distinct", "ANALYST_CODE"), ("limit", "top100")],
            )
            .await?;
        Ok(data
            .iter()
            .map(|v| AnalystRank {
                analyst_name: json_str(v, "ANALYST_NAME"),
                analyst_org: json_str(v, "ORG_NAME"),
                annual_index: json_f64(v, "YEAR_INDEX"),
                annual_return: json_f64(v, "YEAR_YIELD"),
                return_3m: json_f64(v, "THREE_MONTH_YIELD"),
                return_6m: json_f64(v, "SIX_MONTH_YIELD"),
                return_12m: json_f64(v, "TWELVE_MONTH_YIELD"),
                constituent_count: json_i64(v, "CONSTITUTE_NUM"),
                latest_stock_name: json_str_opt(v, "RATING_NAME"),
                latest_stock_code: json_str_opt(v, "RATING_CODE"),
                analyst_id: json_str(v, "ANALYST_CODE"),
                industry_code: json_str_opt(v, "INDUSTRY_CODE"),
                industry: json_str_opt(v, "INDUSTRY_NAME"),
                update_date: json_str(v, "UPDATE_DATE"),
                year: json_str(v, "YEAR"),
            })
            .collect())
    }

    /// 东方财富分析师详情
    pub async fn stock_analyst_detail_em(
        &self,
        analyst_id: &str,
        indicator: &str,
    ) -> Result<Vec<AnalystDetail>> {
        let (report, cols) = match indicator {
            "历史跟踪成分股" => ("RPT_ANALYST_INDEX_HISTORY", "ALL"),
            "历史指数" => ("RPT_ANALYST_INDEX_HIST", "ALL"),
            _ => ("RPT_ANALYST_INDEX_LATEST", "ALL"),
        };
        let filter = format!("(ANALYST_CODE=\"{analyst_id}\")");
        let data = self
            .dc_fetch_all(report, cols, &filter, "TRADE_DATE", "-1", 500, 1, &[])
            .await?;
        Ok(data
            .iter()
            .map(|v| AnalystDetail {
                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"),
                target_price: json_f64_opt(v, "TARGET_PRICE"),
                rating: json_str_opt(v, "RATING_NAME"),
                report_title: json_str_opt(v, "REPORT_TITLE"),
                publish_date: json_str_opt(v, "PUBLISH_DATE"),
            })
            .collect())
    }
}