|
|
@@ -1,17 +1,11 @@
|
|
|
-use std::collections::HashMap;
|
|
|
use std::sync::Arc;
|
|
|
use std::sync::atomic::{AtomicBool, Ordering};
|
|
|
-use tokio::sync::{Mutex};
|
|
|
use actix_web::{web, App, HttpResponse, HttpServer, Responder, get};
|
|
|
use serde::{Deserialize, Serialize};
|
|
|
use serde_json::{json, Value};
|
|
|
use tracing::{info};
|
|
|
use actix_cors::Cors;
|
|
|
-use chrono::Utc;
|
|
|
-use rust_decimal_macros::dec;
|
|
|
use crate::{binance_usdt_swap_data_listener, gate_usdt_swap_data_listener, bybit_usdt_swap_data_listener, coinex_usdt_swap_data_listener, phemex_usdt_swap_data_listener, rank};
|
|
|
-use crate::json_db_utils::{collect_special_trades_json, get_symbols_by_exchange};
|
|
|
-use crate::msv::{generate_msv_by_trades, Indicators, parse_json_to_trades};
|
|
|
|
|
|
// 定义用于反序列化查询参数的结构体
|
|
|
#[derive(Serialize, Deserialize, Clone)]
|
|
|
@@ -93,7 +87,7 @@ async fn get_rank_list(query: web::Query<RankQuery>) -> impl Responder {
|
|
|
// 提取时间窗口参数(默认值 2)
|
|
|
let hour_num = match query.hour_num {
|
|
|
Some(i) => {
|
|
|
- return if i > 0{
|
|
|
+ if i > 0{
|
|
|
i
|
|
|
} else {
|
|
|
2
|
JiahengHe