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
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141

//! Spot market data from Eastmoney (stock_zh_a_spot_em, stock_sh_a_spot_em, etc.)

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

const SPOT_FIELDS: &str =
    "f2,f3,f4,f5,f6,f7,f8,f9,f10,f12,f13,f14,f15,f16,f17,f18,f20,f21,f23,f24,f25,f22,f11,f62";

fn parse_spot_quote(v: &serde_json::Value) -> Option<SpotQuote> {
    let code = v.get("f12")?.as_str()?.to_string();
    let name = v.get("f14")?.as_str()?.to_string();
    Some(SpotQuote {
        code,
        name,
        latest_price: json_f64(v, "f2"),
        change_pct: json_f64(v, "f3"),
        change_amount: json_f64(v, "f4"),
        volume: json_f64(v, "f5"),
        amount: json_f64(v, "f6"),
        amplitude_pct: json_f64(v, "f7"),
        turnover_rate: json_f64(v, "f8"),
        pe_dynamic: json_f64(v, "f9"),
        volume_ratio: json_f64(v, "f10"),
        high: json_f64(v, "f15"),
        low: json_f64(v, "f16"),
        open: json_f64(v, "f17"),
        prev_close: json_f64(v, "f18"),
        total_market_cap: json_f64(v, "f20"),
        circulating_market_cap: json_f64(v, "f21"),
        speed: json_f64(v, "f22"),
        pb: json_f64(v, "f23"),
        change_60d: json_f64(v, "f24"),
        change_ytd: json_f64(v, "f25"),
        change_5min: json_f64(v, "f62"),
    })
}

impl AkShareClient {
    /// 东方财富网-沪深京 A 股-实时行情
    pub async fn stock_zh_a_spot_em(&self) -> Result<Vec<SpotQuote>> {
        let items = self
            .clist_spot_fetch(
                "m:0 t:6,m:0 t:80,m:1 t:2,m:1 t:23,m:0 t:81 s:2048",
                SPOT_FIELDS,
                "5000",
                "f12",
            )
            .await?;
        Ok(items.iter().filter_map(parse_spot_quote).collect())
    }

    /// 东方财富网-沪 A 股-实时行情
    pub async fn stock_sh_a_spot_em(&self) -> Result<Vec<SpotQuote>> {
        let items = self
            .clist_spot_fetch("m:1 t:2,m:1 t:23", SPOT_FIELDS, "5000", "f12")
            .await?;
        Ok(items.iter().filter_map(parse_spot_quote).collect())
    }

    /// 东方财富网-深 A 股-实时行情
    pub async fn stock_sz_a_spot_em(&self) -> Result<Vec<SpotQuote>> {
        let items = self
            .clist_spot_fetch("m:0 t:6,m:0 t:80", SPOT_FIELDS, "5000", "f12")
            .await?;
        Ok(items.iter().filter_map(parse_spot_quote).collect())
    }

    /// 东方财富网-京 A 股-实时行情
    pub async fn stock_bj_a_spot_em(&self) -> Result<Vec<SpotQuote>> {
        let items = self
            .clist_spot_fetch("m:0 t:81 s:2048", SPOT_FIELDS, "5000", "f12")
            .await?;
        Ok(items.iter().filter_map(parse_spot_quote).collect())
    }

    /// 东方财富网-新股-实时行情
    pub async fn stock_new_a_spot_em(&self) -> Result<Vec<SpotQuote>> {
        let items = self
            .clist_spot_fetch("m:0 f:8,m:1 f:8", SPOT_FIELDS, "5000", "f26")
            .await?;
        Ok(items.iter().filter_map(parse_spot_quote).collect())
    }

    /// 东方财富网-创业板-实时行情
    pub async fn stock_cy_a_spot_em(&self) -> Result<Vec<SpotQuote>> {
        let items = self
            .clist_spot_fetch("m:0 t:80", SPOT_FIELDS, "5000", "f12")
            .await?;
        Ok(items.iter().filter_map(parse_spot_quote).collect())
    }

    /// 东方财富网-科创板-实时行情
    pub async fn stock_kc_a_spot_em(&self) -> Result<Vec<SpotQuote>> {
        let items = self
            .clist_spot_fetch("m:1 t:23", SPOT_FIELDS, "5000", "f12")
            .await?;
        Ok(items.iter().filter_map(parse_spot_quote).collect())
    }

    /// 东方财富网-AB 股比价
    pub async fn stock_zh_ab_comparison_em(&self) -> Result<Vec<SpotQuote>> {
        let items = self
            .clist_spot_fetch("m:0 t:6,m:0 t:80,m:1 t:2", SPOT_FIELDS, "5000", "f12")
            .await?;
        Ok(items.iter().filter_map(parse_spot_quote).collect())
    }

    /// 东方财富网-B 股-实时行情
    pub async fn stock_zh_b_spot_em(&self) -> Result<Vec<SpotQuote>> {
        let items = self
            .clist_spot_fetch("m:0 t:7,m:1 t:3", SPOT_FIELDS, "5000", "f12")
            .await?;
        Ok(items.iter().filter_map(parse_spot_quote).collect())
    }

    /// 东方财富网-港股-实时行情
    pub async fn stock_hk_spot_em(&self) -> Result<Vec<SpotQuote>> {
        let items = self
            .clist_spot_fetch("m:128 t:3,m:128 t:4", SPOT_FIELDS, "5000", "f12")
            .await?;
        Ok(items.iter().filter_map(parse_spot_quote).collect())
    }

    /// 东方财富网-港股主板-实时行情
    pub async fn stock_hk_main_board_spot_em(&self) -> Result<Vec<SpotQuote>> {
        let items = self
            .clist_spot_fetch("m:128 t:3", SPOT_FIELDS, "5000", "f12")
            .await?;
        Ok(items.iter().filter_map(parse_spot_quote).collect())
    }

    /// 东方财富网-美股-实时行情
    pub async fn stock_us_spot_em(&self) -> Result<Vec<SpotQuote>> {
        let items = self
            .clist_spot_fetch("m:105,m:106", SPOT_FIELDS, "5000", "f12")
            .await?;
        Ok(items.iter().filter_map(parse_spot_quote).collect())
    }
}