|
|
@@ -18,6 +18,7 @@ use crate::msv::{generate_msv_by_trades, Indicators, parse_json_to_trades};
|
|
|
pub struct RankQuery {
|
|
|
exchange: Option<String>,
|
|
|
time: Option<String>,
|
|
|
+ hour_num: Option<i64>
|
|
|
}
|
|
|
|
|
|
impl RankQuery {
|
|
|
@@ -25,8 +26,11 @@ impl RankQuery {
|
|
|
if self.exchange.is_none() {
|
|
|
return false;
|
|
|
}
|
|
|
+ if self.hour_num.is_none() {
|
|
|
+ return false;
|
|
|
+ }
|
|
|
|
|
|
- return true;
|
|
|
+ true
|
|
|
}
|
|
|
}
|
|
|
|
|
|
@@ -149,7 +153,7 @@ async fn get_rank_list(query: web::Query<RankQuery>) -> impl Responder {
|
|
|
};
|
|
|
|
|
|
// 逻辑执行部分
|
|
|
- let rst = rank::generate_rank_by_indicator_map(&indicators, 2);
|
|
|
+ let rst = rank::generate_rank_by_indicator_map(&indicators, query.hour_num.unwrap());
|
|
|
|
|
|
let response = Response {
|
|
|
query: serde_json::to_value(&query.into_inner()).unwrap(),
|