akshare 0.1.2

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

//! CZCE yearly option history.

use crate::client::AkShareClient;
use crate::error::{Error, Result};

// ---------------------------------------------------------------------------
// CZCE option start year mapping
// ---------------------------------------------------------------------------

fn czce_symbol_start_year(symbol: &str) -> Option<&'static str> {
    match symbol {
        "SR" => Some("2017"),
        "CF" | "TA" | "MA" => Some("2019"),
        "RM" | "ZC" => Some("2020"),
        "OI" | "PK" => Some("2022"),
        "PX" | "SH" | "SA" | "PF" | "SM" | "SF" | "UR" | "AP" => Some("2023"),
        "CJ" | "FG" | "PR" => Some("2024"),
        _ => None,
    }
}

// ---------------------------------------------------------------------------
// Return types
// ---------------------------------------------------------------------------

/// CZCE yearly option history row (flexible - raw pipe-delimited data).
#[derive(Debug, Clone, serde::Serialize, serde::Deserialize)]
pub struct OptionHistYearlyCzceRow {
    /// Raw field values from the pipe-delimited text file.
    pub fields: Vec<String>,
}

// ---------------------------------------------------------------------------
// Implementation
// ---------------------------------------------------------------------------

impl AkShareClient {
    /// CZCE yearly option history download.
    ///
    /// `symbol` is the product code, e.g. "SR", "CF", "TA", "MA", "RM", etc.
    /// `year` is the year string, e.g. "2021".
    pub async fn option_hist_yearly_czce(
        &self,
        symbol: &str,
        year: &str,
    ) -> Result<Vec<OptionHistYearlyCzceRow>> {
        let start_year = czce_symbol_start_year(symbol)
            .ok_or_else(|| Error::invalid_input(format!("unsupported CZCE symbol: {symbol}")))?;

        if year < start_year {
            return Err(Error::invalid_input(format!(
                "{symbol} started trading in {start_year}, cannot get data for {year}"
            )));
        }

        let url = format!(
            "http://www.czce.com.cn/cn/DFSStaticFiles/Option/{year}/OptionDataAllHistory/{symbol}OPTIONS{year}.txt"
        );

        let body = self
            .get(&url)
            .send()
            .await
            .map_err(Error::from)?
            .text()
            .await
            .map_err(Error::from)?;

        let lines: Vec<&str> = body.lines().collect();
        if lines.len() < 2 {
            return Ok(vec![]);
        }

        // Skip header line (first line)
        let mut rows = Vec::new();
        for line in lines.iter().skip(1) {
            let trimmed = line.trim();
            if trimmed.is_empty() || trimmed.starts_with("----") {
                continue;
            }
            let fields: Vec<String> = trimmed.split('|').map(|s| s.trim().to_string()).collect();
            if fields.len() < 2 {
                continue;
            }
            rows.push(OptionHistYearlyCzceRow { fields });
        }

        Ok(rows)
    }
}