akshare 0.1.3

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

//! Stock comments (千股千评) from Eastmoney.

use super::helpers::{json_f64, json_str};
use super::types::{
    CommentDesireIndex, CommentFocusIndex, CommentHistScore, CommentOrgParticipation, StockComment,
};
use crate::client::AkShareClient;
use crate::error::Result;

impl AkShareClient {
    /// 千股千评
    pub async fn stock_comment_em(&self) -> Result<Vec<StockComment>> {
        let data = self
            .dc_fetch_all(
                "RPT_DMSK_TS_STOCKNEW",
                "ALL",
                "",
                "SECURITY_CODE",
                "1",
                500,
                10,
                &[],
            )
            .await?;
        Ok(data
            .iter()
            .map(|v| StockComment {
                code: json_str(v, "SECURITY_CODE"),
                name: json_str(v, "SECURITY_NAME_ABBR"),
                latest_price: json_f64(v, "CLOSE_PRICE"),
                change_pct: json_f64(v, "CHANGE_RATE"),
                turnover_rate: json_f64(v, "TURNOVERRATE"),
                pe: json_f64(v, "PE_DYNAMIC"),
                main_cost: json_f64(v, "MAIN_COST"),
                org_participation: json_f64(v, "ORG_PARTICIPATE"),
                total_score: json_f64(v, "TOTAL_SCORE"),
                rise: json_f64(v, "RISE"),
                current_rank: json_f64(v, "CURRENT_RANK"),
                focus_index: json_f64(v, "FOCUS_INDEX"),
                trade_date: json_str(v, "TRADE_DATE"),
            })
            .collect())
    }

    /// 千股千评-主力控盘-机构参与度
    pub async fn stock_comment_detail_zlkp_jgcyd_em(
        &self,
        symbol: &str,
    ) -> Result<Vec<CommentOrgParticipation>> {
        let filter = format!("(SECURITY_CODE=\"{symbol}\")");
        let data = self
            .dc_fetch_all(
                "RPT_DMSK_TS_STOCKEVALUATE",
                "ALL",
                &filter,
                "TRADE_DATE",
                "-1",
                500,
                1,
                &[],
            )
            .await?;
        Ok(data
            .iter()
            .map(|v| CommentOrgParticipation {
                trade_date: json_str(v, "TRADE_DATE"),
                org_participation: json_f64(v, "ORG_PARTICIPATE") * 100.0,
            })
            .collect())
    }

    /// 千股千评-综合评价-历史评分
    pub async fn stock_comment_detail_zhpj_lspf_em(
        &self,
        symbol: &str,
    ) -> Result<Vec<CommentHistScore>> {
        let filter = format!("(SECURITY_CODE=\"{symbol}\")");
        let data = self
            .dc_fetch_all(
                "RPT_STOCK_HISTORYMARK",
                "ALL",
                &filter,
                "DIAGNOSE_DATE",
                "1",
                500,
                1,
                &[],
            )
            .await?;
        Ok(data
            .iter()
            .map(|v| CommentHistScore {
                trade_date: json_str(v, "DIAGNOSE_DATE"),
                score: json_f64(v, "TOTAL_SCORE"),
            })
            .collect())
    }

    /// 千股千评-市场热度-用户关注指数
    pub async fn stock_comment_detail_scrd_focus_em(
        &self,
        symbol: &str,
    ) -> Result<Vec<CommentFocusIndex>> {
        let filter = format!("(SECURITY_CODE=\"{symbol}\")");
        let data = self
            .dc_fetch_all(
                "RPT_STOCK_FOCUSSCORE",
                "ALL",
                &filter,
                "TRADE_DATE",
                "1",
                500,
                1,
                &[],
            )
            .await?;
        Ok(data
            .iter()
            .map(|v| CommentFocusIndex {
                trade_date: json_str(v, "TRADE_DATE"),
                focus_index: json_f64(v, "FOCUS_INDEX"),
            })
            .collect())
    }

    /// 千股千评-市场热度-市场渴望指数
    pub async fn stock_comment_detail_scrd_desire_em(
        &self,
        symbol: &str,
    ) -> Result<Vec<CommentDesireIndex>> {
        let filter = format!("(SECURITY_CODE=\"{symbol}\")");
        let data = self
            .dc_fetch_all(
                "RPT_STOCK_DESIRESCORE",
                "ALL",
                &filter,
                "TRADE_DATE",
                "1",
                500,
                1,
                &[],
            )
            .await?;
        Ok(data
            .iter()
            .map(|v| CommentDesireIndex {
                trade_date: json_str(v, "TRADE_DATE"),
                desire_index: json_f64(v, "DESIRE_INDEX"),
            })
            .collect())
    }
}