|
|
@@ -26,10 +26,6 @@ impl RankQuery {
|
|
|
if self.exchange.is_none() {
|
|
|
return false;
|
|
|
}
|
|
|
- if self.hour_num.is_none() {
|
|
|
- return false;
|
|
|
- }
|
|
|
-
|
|
|
true
|
|
|
}
|
|
|
}
|
|
|
@@ -53,7 +49,6 @@ async fn get_rank_list(query: web::Query<RankQuery>) -> impl Responder {
|
|
|
code: 500,
|
|
|
data: Value::Null,
|
|
|
};
|
|
|
-
|
|
|
let json_string = serde_json::to_string(&response).unwrap();
|
|
|
return HttpResponse::Ok().content_type("application/json").body(json_string);
|
|
|
}
|
|
|
@@ -95,6 +90,19 @@ async fn get_rank_list(query: web::Query<RankQuery>) -> impl Responder {
|
|
|
return HttpResponse::Ok().content_type("application/json").body(json_string);
|
|
|
}
|
|
|
};
|
|
|
+ // 提取时间窗口参数
|
|
|
+ let hour_num = match query.hour_num {
|
|
|
+ Some(i) => {
|
|
|
+ if i > 0{
|
|
|
+ i
|
|
|
+ } else {
|
|
|
+ 2
|
|
|
+ }
|
|
|
+ }
|
|
|
+ None => {
|
|
|
+ 2
|
|
|
+ }
|
|
|
+ };
|
|
|
|
|
|
// 逻辑执行部分
|
|
|
let rst = rank::generate_rank_by_indicator_map(&indicators, query.hour_num.unwrap());
|