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

//! SEO (增发) and rights issue (配股) from Eastmoney.

use super::helpers::{json_f64, json_f64_opt, json_str, json_str_opt};
use super::types::{Pg, Qbzf};
use crate::client::AkShareClient;
use crate::error::Result;

impl AkShareClient {
    /// 全部增发
    pub async fn stock_qbzf_em(&self) -> Result<Vec<Qbzf>> {
        let data = self
            .dc_fetch_all(
                "RPT_SEO_DETAIL",
                "ALL",
                "",
                "ISSUE_DATE",
                "-1",
                500,
                10,
                &[],
            )
            .await?;
        Ok(data
            .iter()
            .map(|v| Qbzf {
                code: json_str(v, "SECURITY_CODE"),
                name: json_str(v, "SECURITY_NAME_ABBR"),
                seo_code: json_str(v, "SEO_CODE"),
                issue_type: json_str(v, "SEO_TYPE"),
                issue_count: json_f64(v, "ISSUE_NUM"),
                online_issue: json_f64_opt(v, "ONLINE_ISSUE_NUM"),
                issue_price: json_f64(v, "ISSUE_PRICE"),
                latest_price: json_f64_opt(v, "NEW_PRICE"),
                issue_date: json_str(v, "ISSUE_DATE"),
                listing_date: json_str_opt(v, "LISTING_DATE"),
                lock_period: json_str_opt(v, "LOCK_PERIOD"),
            })
            .collect())
    }

    /// 配股
    pub async fn stock_pg_em(&self) -> Result<Vec<Pg>> {
        let data = self
            .dc_fetch_all(
                "RPT_RIGHTS_ISSUE",
                "ALL",
                "",
                "PLAN_NOTICE_DATE",
                "-1",
                500,
                10,
                &[],
            )
            .await?;
        Ok(data
            .iter()
            .map(|v| Pg {
                code: json_str(v, "SECURITY_CODE"),
                name: json_str(v, "SECURITY_NAME_ABBR"),
                pg_code: json_str(v, "RIGHTS_ISSUE_CODE"),
                issue_price: json_f64(v, "ISSUE_PRICE"),
                latest_price: json_f64_opt(v, "NEW_PRICE"),
                issue_count: json_f64(v, "ISSUE_NUM"),
                plan_notice_date: json_str_opt(v, "PLAN_NOTICE_DATE"),
                record_date: json_str_opt(v, "RECORD_DATE"),
                pay_date: json_str_opt(v, "PAY_DATE"),
                listing_date: json_str_opt(v, "LISTING_DATE"),
                issue_type: json_str_opt(v, "ISSUE_TYPE"),
            })
            .collect())
    }
}