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
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
142
143
144
145

#![allow(dead_code)]
//! Convertible bond data from JSL (集思录).

use serde::Deserialize;

use crate::client::AkShareClient;
use crate::error::Result;
use crate::types::Row;

#[derive(Debug, Deserialize)]
struct JslCbResponse {
    #[serde(default)]
    data: Vec<serde_json::Value>,
}

impl AkShareClient {
    /// JSL convertible bond list with pricing and premium data.
    ///
    /// Fetches all listed convertible bonds from jisilu.cn with current price,
    /// conversion value, premium ratio, remaining years, etc.
    pub async fn bond_cb_jsl(&self) -> Result<Vec<Row>> {
        let url = "https://www.jisilu.cn/data/cbnew/cb_list/?___jsl=LST___t=1630000000000";
        let body = self
            .get(url)
            .header("User-Agent", "Mozilla/5.0")
            .header("Referer", "https://www.jisilu.cn/data/cbnew/")
            .send()
            .await?
            .text()
            .await?;

        let resp: serde_json::Value = serde_json::from_str(&body)?;
        let rows = resp["rows"].as_array().cloned().unwrap_or_default();

        let mut items = Vec::new();
        for row in &rows {
            let cell = row.get("cell").cloned().unwrap_or_else(|| row.clone());
            let mut r = Row::new();
            let empty = serde_json::Map::new();
            for (key, val) in cell.as_object().unwrap_or(&empty) {
                r.insert(key.clone(), val.clone());
            }
            if !r.is_empty() {
                items.push(r);
            }
        }
        Ok(items)
    }

    /// JSL convertible bond index data.
    ///
    /// Returns the convertible bond market index from JSL.
    pub async fn bond_cb_index_jsl(&self) -> Result<Vec<Row>> {
        let url = "https://www.jisilu.cn/data/cbnew/cb_index/?___jsl=LST___t=1630000000000";
        let body = self
            .get(url)
            .header("User-Agent", "Mozilla/5.0")
            .header("Referer", "https://www.jisilu.cn/data/cbnew/")
            .send()
            .await?
            .text()
            .await?;

        let resp: serde_json::Value = serde_json::from_str(&body)?;
        let rows = resp["rows"].as_array().cloned().unwrap_or_default();

        let mut items = Vec::new();
        for row in &rows {
            let cell = row.get("cell").cloned().unwrap_or_else(|| row.clone());
            let mut r = Row::new();
            let empty = serde_json::Map::new();
            for (key, val) in cell.as_object().unwrap_or(&empty) {
                r.insert(key.clone(), val.clone());
            }
            if !r.is_empty() {
                items.push(r);
            }
        }
        Ok(items)
    }

    /// JSL convertible bond adjustment logs (下修记录).
    ///
    /// Returns the history of conversion price downward adjustments.
    pub async fn bond_cb_adj_logs_jsl(&self) -> Result<Vec<Row>> {
        let url = "https://www.jisilu.cn/data/cbnew/cb_adj/?___jsl=LST___t=1630000000000";
        let body = self
            .get(url)
            .header("User-Agent", "Mozilla/5.0")
            .header("Referer", "https://www.jisilu.cn/data/cbnew/")
            .send()
            .await?
            .text()
            .await?;

        let resp: serde_json::Value = serde_json::from_str(&body)?;
        let rows = resp["rows"].as_array().cloned().unwrap_or_default();

        let mut items = Vec::new();
        for row in &rows {
            let cell = row.get("cell").cloned().unwrap_or_else(|| row.clone());
            let mut r = Row::new();
            let empty = serde_json::Map::new();
            for (key, val) in cell.as_object().unwrap_or(&empty) {
                r.insert(key.clone(), val.clone());
            }
            if !r.is_empty() {
                items.push(r);
            }
        }
        Ok(items)
    }

    /// JSL convertible bond redemption data (强赎数据).
    ///
    /// Returns information about forced redemption of convertible bonds.
    pub async fn bond_cb_redeem_jsl(&self) -> Result<Vec<Row>> {
        let url = "https://www.jisilu.cn/data/cbnew/cb_redeem/?___jsl=LST___t=1630000000000";
        let body = self
            .get(url)
            .header("User-Agent", "Mozilla/5.0")
            .header("Referer", "https://www.jisilu.cn/data/cbnew/")
            .send()
            .await?
            .text()
            .await?;

        let resp: serde_json::Value = serde_json::from_str(&body)?;
        let rows = resp["rows"].as_array().cloned().unwrap_or_default();

        let mut items = Vec::new();
        for row in &rows {
            let cell = row.get("cell").cloned().unwrap_or_else(|| row.clone());
            let mut r = Row::new();
            let empty = serde_json::Map::new();
            for (key, val) in cell.as_object().unwrap_or(&empty) {
                r.insert(key.clone(), val.clone());
            }
            if !r.is_empty() {
                items.push(r);
            }
        }
        Ok(items)
    }
}