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

//! Institutional research (机构调研) from Eastmoney.

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

impl AkShareClient {
    /// 机构调研统计
    pub async fn stock_jgdy_tj_em(&self, date: &str) -> Result<Vec<JgdyTj>> {
        let date_fmt = fmt_date(date);
        let filter = format!(
            "(NUMBERNEW=\"1\")(IS_SOURCE=\"1\")(NOTICE_DATE>'{}')",
            date_fmt
        );
        let data = self
            .dc_fetch_all(
                "RPT_ORG_SURVEYNEW",
                "ALL",
                &filter,
                "NOTICE_DATE,SUM,RECEIVE_START_DATE,SECURITY_CODE",
                "-1",
                500,
                10,
                &[],
            )
            .await?;
        Ok(data
            .iter()
            .map(|v| JgdyTj {
                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"),
                org_count: json_i64(v, "SUM"),
                receive_method: json_str_opt(v, "RECEIVE_WAY"),
                receive_personnel: json_str_opt(v, "RECEIVE_TARGET"),
                receive_location: json_str_opt(v, "RECEIVE_PLACE"),
                receive_date: json_str(v, "RECEIVE_START_DATE"),
                notice_date: json_str(v, "NOTICE_DATE"),
            })
            .collect())
    }

    /// 机构调研详细
    pub async fn stock_jgdy_detail_em(&self, date: &str) -> Result<Vec<JgdyDetail>> {
        let date_fmt = fmt_date(date);
        let filter = format!("(NOTICE_DATE>'{}')", date_fmt);
        let data = self
            .dc_fetch_all(
                "RPT_ORG_SURVEY",
                "ALL",
                &filter,
                "NOTICE_DATE,SECURITY_CODE",
                "-1",
                500,
                10,
                &[],
            )
            .await?;
        Ok(data
            .iter()
            .map(|v| JgdyDetail {
                code: json_str(v, "SECURITY_CODE"),
                name: json_str(v, "SECURITY_NAME_ABBR"),
                notice_date: json_str(v, "NOTICE_DATE"),
                receive_date: json_str(v, "RECEIVE_START_DATE"),
                receive_location: json_str_opt(v, "RECEIVE_PLACE"),
                receive_method: json_str_opt(v, "RECEIVE_WAY"),
                receive_personnel: json_str_opt(v, "RECEIVE_TARGET"),
                org_count: json_i64(v, "ORG_NUM"),
                content: json_str_opt(v, "ORG_SURVEY_CONTENT"),
            })
            .collect())
    }
}