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
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
//! 校园卡余额、账单查询接口
use reqwest::header::CONTENT_LENGTH;
use serde::{Deserialize, Serialize};
use serde_json::{Map, Value, from_str};
use serde_with::serde_as;
use snafu::ensure;
use crate::{
card::utils::card_request_handler,
errors,
errors::{ApiError, card::CardResult},
session::{Client, Session},
utils::{
ApiModel,
consts::{CARD_GET_BILL_URL, CARD_GET_CARD_URL},
response_json_map,
},
};
/// 校园卡相关信息
#[serde_as]
#[derive(Debug, PartialEq, Clone, Serialize, Deserialize)]
pub struct Card {
/// 一卡通账户号
#[serde(alias = "acctNo")]
#[serde_as(deserialize_as = "serde_with::PickFirst<(_, serde_with::DisplayFromStr)>")]
pub id: u64,
/// 账户余额，单位为分
#[serde(alias = "acctAmt")]
pub amount: u64,
/// 账户状态
#[serde(alias = "acctStatus")]
pub account_status: Option<String>,
}
impl ApiModel for Card {}
/// 校园卡账单相关信息
#[serde_as]
#[derive(Debug, PartialEq, Clone, Serialize, Deserialize)]
pub struct Bill {
/// 交易名称
#[serde(rename = "tranName")]
pub name: String,
/// 交易时间
#[serde(alias = "tranDt")]
pub date: String,
/// 交易地点
#[serde(alias = "mchAcctName")]
pub place: String,
/// 交易金额，单位为分
#[serde(alias = "tranAmt")]
pub tran_amount: i64,
/// 卡类型名称
#[serde(alias = "cardTypeName")]
pub card_type_name: Option<String>,
/// 账户余额，单位为分
#[serde(alias = "acctAmt")]
#[serde_as(deserialize_as = "serde_with::DisplayFromStr")]
pub acc_amount: i64,
}
impl ApiModel for Bill {}
impl Card {
/// 通过具有校园卡查询网址权限的会话([`Session`])，获取卡类型为“正式卡”的校园卡信息([`Card`])
///
/// # Examples
/// ```rust, no_run
/// # use serde::de::Unexpected::Option;
/// # use rsmycqu::card::{access_card, Card};
/// # use rsmycqu::session::{Client, Session};
/// # use rsmycqu::sso::login;
/// #
/// # async fn fetch_card() {
/// # let client = Client::default();
/// # let mut session = Session::new();
/// login(&client, &mut session, "your_auth", "your_password", false).await.unwrap();
/// access_card(&client, &mut session).await.unwrap();
/// let card = Card::fetch_self(&client, &mut session).await.unwrap();
/// # }
/// ```
pub async fn fetch_self(client: &Client, session: &Session) -> CardResult<Card> {
let res = card_request_handler(client, session, |client| {
client.post(CARD_GET_CARD_URL).header(CONTENT_LENGTH, 0)
})
.await?;
let text = res.json::<String>().await?;
let raw_response = text.clone();
let mut json = from_str::<Map<String, Value>>(&text).map_err(|_| ApiError::Website {
msg: "Website response format incorrect".to_string(),
})?;
ensure!(
json.get("respCode").and_then(Value::as_str) == Some("0000"),
errors::WebsiteSnafu {
msg: json
.get("respInfo")
.and_then(Value::as_str)
.unwrap_or("No Website Error")
.to_string(),
}
);
if let Some(Value::Array(mut data)) = json.get_mut("objs").map(Value::take) {
fn card_type_name(value: &Value) -> Option<&str> {
value.get("cardTypeName").and_then(Value::as_str)
}
let card_index = data
.iter()
.position(|value| card_type_name(value) == Some("正式卡"))
.ok_or_else(|| {
let available_card_types: Vec<_> =
data.iter().filter_map(card_type_name).collect();
let available_card_types_text = if available_card_types.is_empty() {
"none".to_string()
} else {
available_card_types.join(", ")
};
ApiError::Website {
msg: format!(
"No formal card ('正式卡') found. Available cardTypeName values: {}",
available_card_types_text,
),
}
})?;
let card = data.remove(card_index);
serde_json::from_value(card).map_err(|err| ApiError::ModelParse {
msg: format!("Deserialize error: {}", err),
raw_response,
})
} else {
Err(ApiError::Website {
msg: "Website response format incorrect".to_string(),
})
}
}
}
impl Card {
/// 通过具有校园卡查询网址权限的会话([`Session`])，获取校园卡账单信息([`Bill`])
///
/// *`start_date`, `end_date`日期格式应当符合`%Y-%m-%d`*
///
/// # Examples
/// ```rust, no_run
/// # use serde::de::Unexpected::Option;
/// # use rsmycqu::card::{access_card, Card};
/// # use rsmycqu::session::{Client, Session};
/// # use rsmycqu::sso::login;
/// #
/// # async fn fetch_bill() {
/// # let client = Client::default();
/// # let mut session = Session::new();
/// login(&client, &mut session, "your_auth", "your_password", false).await.unwrap();
/// access_card(&client, &mut session).await.unwrap();
/// let card = Card::fetch_self(&client, &mut session).await.unwrap();
/// let bills = card.fetch_bill(&client, &session, "2023-11-10", "2023-12-12", 1, 100).await.unwrap();
/// # }
/// ```
pub async fn fetch_bill(
&self,
client: &Client,
session: &Session,
start_date: impl AsRef<str>,
end_date: impl AsRef<str>,
page: u16,
row: u16,
) -> CardResult<Vec<Bill>> {
let res = card_request_handler(client, session, |client| {
client.post(CARD_GET_BILL_URL).form(&[
("sdate", start_date.as_ref()),
("edate", end_date.as_ref()),
("account", self.id.to_string().as_ref()),
("page", &page.to_string()),
("row", &row.to_string()),
])
})
.await?;
let (mut json, raw_response) = response_json_map(res).await?;
if let Some(Value::Array(data)) = json.get_mut("rows").map(Value::take) {
data.into_iter()
.map(serde_json::from_value)
.collect::<Result<_, serde_json::Error>>()
.map_err(|err| ApiError::ModelParse {
msg: format!("Deserialize error: {}", err),
raw_response,
})
} else {
Err(ApiError::Website {
msg: "Website response format incorrect".to_string(),
})
}
}
}