|
@@ -5,7 +5,7 @@ use serde::{Deserialize, Serialize};
|
|
|
use serde_json::{json, Value};
|
|
use serde_json::{json, Value};
|
|
|
use tracing::{info};
|
|
use tracing::{info};
|
|
|
use actix_cors::Cors;
|
|
use actix_cors::Cors;
|
|
|
-use crate::{coinex_usdt_swap_data_listener, gate_usdt_swap_data_listener, rank};
|
|
|
|
|
|
|
+use crate::{binance_usdt_swap_data_listener, coinex_usdt_swap_data_listener, gate_usdt_swap_data_listener, rank};
|
|
|
|
|
|
|
|
// 定义用于反序列化查询参数的结构体
|
|
// 定义用于反序列化查询参数的结构体
|
|
|
#[derive(Serialize, Deserialize, Clone)]
|
|
#[derive(Serialize, Deserialize, Clone)]
|
|
@@ -53,10 +53,13 @@ async fn get_rank_list(query: web::Query<RankQuery>) -> impl Responder {
|
|
|
"coinex_usdt_swap" => {
|
|
"coinex_usdt_swap" => {
|
|
|
coinex_usdt_swap_data_listener::INDICATOR_MAP.lock().await
|
|
coinex_usdt_swap_data_listener::INDICATOR_MAP.lock().await
|
|
|
},
|
|
},
|
|
|
|
|
+ "binance_usdt_swap" => {
|
|
|
|
|
+ binance_usdt_swap_data_listener::INDICATOR_MAP.lock().await
|
|
|
|
|
+ },
|
|
|
_ => {
|
|
_ => {
|
|
|
let response = Response {
|
|
let response = Response {
|
|
|
query: serde_json::to_value(&query.into_inner()).unwrap(),
|
|
query: serde_json::to_value(&query.into_inner()).unwrap(),
|
|
|
- msg: Some("查询内容有误,exchange当前仅支持:[gate_usdt_swap]".to_string()),
|
|
|
|
|
|
|
+ msg: Some("查询内容有误,exchange当前仅支持:[gate_usdt_swap, coinex_usdt_swap, binance_usdt_swap]".to_string()),
|
|
|
code: 500,
|
|
code: 500,
|
|
|
data: Value::Null,
|
|
data: Value::Null,
|
|
|
};
|
|
};
|