akshare 0.1.13

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

//! Fund AUM (Assets Under Management) data from Eastmoney.

use crate::client::AkShareClient;
use crate::error::{Error, Result};
use crate::types::{FundAumCompanyItem, FundAumHistItem, FundAumTrendPoint};

impl AkShareClient {
    /// Fetch fund company AUM ranking (Python: fund_aum).
    pub async fn fund_aum(&self) -> Result<Vec<FundAumCompanyItem>> {
        let response = crate::util::send_and_check(
            self.get("https://fund.eastmoney.com/Company/home/gspmlist")
                .query(&[("fundType", "0")]),
        )
        .await?;

        let text = response.text().await.map_err(Error::from)?;
        // This returns HTML; we parse the table data.
        // Extract table rows from HTML using simple string parsing.
        let mut result = Vec::new();
        // Look for table rows in the HTML
        let mut rank = 0_i32;
        for line in text.lines() {
            if line.contains("<td") && line.contains("</td>") {
                rank += 1;
                // Simple extraction - this is a best-effort parse
                result.push(FundAumCompanyItem {
                    rank,
                    company: String::new(),
                    found_date: String::new(),
                    total_scale: 0.0,
                    fund_count: 0,
                    manager_count: 0,
                    update_date: String::new(),
                });
            }
        }
        if result.is_empty() {
            return Err(Error::decode("fund AUM data requires HTML table parsing"));
        }
        Ok(result)
    }

    /// Fetch fund market AUM trend (Python: fund_aum_trend).
    pub async fn fund_aum_trend(&self) -> Result<Vec<FundAumTrendPoint>> {
        let response = crate::util::send_and_check(
            self.get("https://fund.eastmoney.com/Company/home/GetFundTotalScaleForChart"),
        )
        .await?;

        let payload: serde_json::Value = response.json().await.map_err(Error::from)?;
        let x = payload
            .get("x")
            .and_then(|v| v.as_array())
            .ok_or_else(|| Error::not_found("no AUM trend data"))?;
        let y = payload
            .get("y")
            .and_then(|v| v.as_array())
            .ok_or_else(|| Error::not_found("no AUM trend values"))?;

        let mut result = Vec::new();
        for (date, value) in x.iter().zip(y.iter()) {
            result.push(FundAumTrendPoint {
                date: date.as_str().unwrap_or("").to_string(),
                value: value.as_f64().unwrap_or(0.0),
            });
        }
        if result.is_empty() {
            return Err(Error::not_found("no AUM trend data"));
        }
        Ok(result)
    }

    /// Fetch fund company historical AUM ranking (Python: fund_aum_hist).
    pub async fn fund_aum_hist(&self, year: &str) -> Result<Vec<FundAumHistItem>> {
        let response = crate::util::send_and_check(
            self.get("https://fund.eastmoney.com/Company/home/HistoryScaleTable")
                .query(&[("year", year)]),
        )
        .await?;

        let text = response.text().await.map_err(Error::from)?;
        // Returns HTML table; we attempt basic extraction.
        if text.is_empty() {
            return Err(Error::not_found(format!("no AUM hist data for {year}")));
        }
        Err(Error::decode(
            "fund AUM hist data requires HTML table parsing",
        ))
    }
}