关闭没用到的交易所

src/bitget_usdt_swap_data_listener.rs

@@ -17,7 +17,7 @@ use crate::json_db_utils::{collect_special_trades_json, delete_db_by_exchange};
 use crate::listener_tools::{TradeMap, update_trade};
 use crate::msv::{generate_msv_by_trades, Indicators, parse_json_to_trades, delete_expire_data};
 
-const EXCHANGE_NAME: &str = "bitget_usdt_swap";
+const _EXCHANGE_NAME: &str = "bitget_usdt_swap";
 
 lazy_static! {
     // 给其他模块使用
@@ -27,7 +27,7 @@ lazy_static! {
     static ref MUL_MAP: Mutex<HashMap<String, Decimal>> = Mutex::new(HashMap::new());
 }
 
-pub async fn run_listener(is_shutdown_arc: Arc<AtomicBool>) {
+pub async fn _run_listener(is_shutdown_arc: Arc<AtomicBool>) {
     let name = "bitget_usdt_swap_listener";
     // 订阅所有币种
     let login = BTreeMap::new();
@@ -60,7 +60,7 @@ pub async fn run_listener(is_shutdown_arc: Arc<AtomicBool>) {
 
             // 建立链接
             ws.set_symbols(symbols_chunk);
-            ws.ws_connect_async(is_shutdown_clone, data_listener, &write_tx_am, write_rx).await.expect("链接失败(内部一个心跳线程应该已经关闭了)");
+            ws.ws_connect_async(is_shutdown_clone, _data_listener, &write_tx_am, write_rx).await.expect("链接失败(内部一个心跳线程应该已经关闭了)");
         });
     }
     // 每分钟计算msv
@@ -75,7 +75,7 @@ pub async fn run_listener(is_shutdown_arc: Arc<AtomicBool>) {
                 start_timestamp = end_timestamp - 60 * 1000 * 60 * 2;
             }
             for symbol in symbols.clone() {
-                let trades_value = collect_special_trades_json(start_timestamp, end_timestamp, EXCHANGE_NAME, &symbol).await;
+                let trades_value = collect_special_trades_json(start_timestamp, end_timestamp, _EXCHANGE_NAME, &symbol).await;
                 let trades = parse_json_to_trades(trades_value);
                 let msv = generate_msv_by_trades(trades, dec!(50), vec![], start_timestamp, end_timestamp);
                 let mut indicator_map = INDICATOR_MAP.lock().await;
@@ -105,13 +105,13 @@ pub async fn run_listener(is_shutdown_arc: Arc<AtomicBool>) {
     tokio::spawn(async move {
         loop {
             tokio::time::sleep(Duration::from_secs(1800)).await;
-            delete_db_by_exchange(EXCHANGE_NAME, "trades", 5 * 60).await;
+            delete_db_by_exchange(_EXCHANGE_NAME, "trades", 5 * 60).await;
         }
     });
 }
 
 // 读取数据
-pub async fn data_listener(response: ResponseData) {
+pub async fn _data_listener(response: ResponseData) {
     if response.code != 200 {
         return;
     }
@@ -130,7 +130,7 @@ pub async fn data_listener(response: ResponseData) {
 
                 // 更新到本地数据库
                 let trades_map = TRADES_MAP.lock().await;
-                update_trade(trade, trades_map, EXCHANGE_NAME).await;
+                update_trade(trade, trades_map, _EXCHANGE_NAME).await;
             }
         }
         _ => {

src/main.rs

@@ -40,9 +40,9 @@ async fn main() {
     gate_usdt_swap_data_listener::run_listener(running.clone()).await;
     coinex_usdt_swap_data_listener::run_listener(running.clone()).await;
     phemex_usdt_swap_data_listener::run_listener(running.clone()).await;
-    mexc_usdt_swap_data_listener::run_listener(running.clone()).await;
+    // mexc_usdt_swap_data_listener::run_listener(running.clone()).await;
     bybit_usdt_swap_data_listener::run_listener(running.clone()).await;
-    bitget_usdt_swap_data_listener::run_listener(running.clone()).await;
+    // bitget_usdt_swap_data_listener::run_listener(running.clone()).await;
     // gate_coin_spot_data_listener::run_listener(running.clone()).await;
     // panic错误捕获，panic级别的错误直接退出
     // let panic_running = running.clone();

src/mexc_usdt_swap_data_listener.rs

@@ -19,7 +19,7 @@ use crate::json_db_utils::{collect_special_trades_json, delete_db_by_exchange};
 use crate::listener_tools::{TradeMap, update_trade};
 use crate::msv::{generate_msv_by_trades, Indicators, parse_json_to_trades, delete_expire_data};
 
-const EXCHANGE_NAME: &str = "mexc_usdt_swap";
+const _EXCHANGE_NAME: &str = "mexc_usdt_swap";
 
 lazy_static! {
     // 给其他模块使用
@@ -29,7 +29,7 @@ lazy_static! {
     static ref MUL_MAP: Mutex<HashMap<String, Decimal>> = Mutex::new(HashMap::new());
 }
 
-pub async fn run_listener(is_shutdown_arc: Arc<AtomicBool>) {
+pub async fn _run_listener(is_shutdown_arc: Arc<AtomicBool>) {
     let name = "mexc_usdt_swap_listener";
     // 订阅所有币种
     let login = BTreeMap::new();
@@ -65,7 +65,7 @@ pub async fn run_listener(is_shutdown_arc: Arc<AtomicBool>) {
 
             // 建立链接
             ws.set_symbols(symbols_chunk);
-            ws.ws_connect_async(is_shutdown_clone, data_listener, &write_tx_am, write_rx).await.expect("链接失败(内部一个心跳线程应该已经关闭了)");
+            ws.ws_connect_async(is_shutdown_clone, _data_listener, &write_tx_am, write_rx).await.expect("链接失败(内部一个心跳线程应该已经关闭了)");
         });
     }
     // 每分钟计算msv
@@ -80,7 +80,7 @@ pub async fn run_listener(is_shutdown_arc: Arc<AtomicBool>) {
                 start_timestamp = end_timestamp - 60 * 1000 * 60 * 2;
             }
             for symbol in symbols.clone() {
-                let trades_value = collect_special_trades_json(start_timestamp, end_timestamp, EXCHANGE_NAME, &symbol).await;
+                let trades_value = collect_special_trades_json(start_timestamp, end_timestamp, _EXCHANGE_NAME, &symbol).await;
                 let trades = parse_json_to_trades(trades_value);
                 let msv = generate_msv_by_trades(trades, dec!(50), vec![], start_timestamp, end_timestamp);
                 let mut indicator_map = INDICATOR_MAP.lock().await;
@@ -110,13 +110,13 @@ pub async fn run_listener(is_shutdown_arc: Arc<AtomicBool>) {
     tokio::spawn(async move {
         loop {
             tokio::time::sleep(Duration::from_secs(1800)).await;
-            delete_db_by_exchange(EXCHANGE_NAME, "trades", 5 * 60).await;
+            delete_db_by_exchange(_EXCHANGE_NAME, "trades", 5 * 60).await;
         }
     });
 }
 
 // 读取数据
-pub async fn data_listener(response: ResponseData) {
+pub async fn _data_listener(response: ResponseData) {
     if response.code != 200 {
         return;
     }
@@ -136,7 +136,7 @@ pub async fn data_listener(response: ResponseData) {
 
                 // 更新到本地数据库
                 let trades_map = TRADES_MAP.lock().await;
-                update_trade(trade, trades_map, EXCHANGE_NAME).await;
+                update_trade(trade, trades_map, _EXCHANGE_NAME).await;
             }
         }
         _ => {

src/server.rs

@@ -9,7 +9,7 @@ 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, bitget_usdt_swap_data_listener, bybit_usdt_swap_data_listener, coinex_usdt_swap_data_listener, gate_coin_spot_data_listener, mexc_usdt_swap_data_listener, phemex_usdt_swap_data_listener, rank};
+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};
 
@@ -123,18 +123,18 @@ async fn get_rank_list(query: web::Query<RankQuery>) -> impl Responder {
         "phemex_usdt_swap" => {
             phemex_usdt_swap_data_listener::INDICATOR_MAP.lock().await
         }
-        "mexc_usdt_swap" => {
-            mexc_usdt_swap_data_listener::INDICATOR_MAP.lock().await
-        }
+        // "mexc_usdt_swap" => {
+        //     mexc_usdt_swap_data_listener::INDICATOR_MAP.lock().await
+        // }
         "bybit_usdt_swap" => {
             bybit_usdt_swap_data_listener::INDICATOR_MAP.lock().await
         }
-        "bitget_usdt_swap" => {
-            bitget_usdt_swap_data_listener::INDICATOR_MAP.lock().await
-        }
-        "gate_coin_spot" => {
-            gate_coin_spot_data_listener::INDICATOR_MAP.lock().await
-        }
+        // "bitget_usdt_swap" => {
+        //     bitget_usdt_swap_data_listener::INDICATOR_MAP.lock().await
+        // }
+        // "gate_coin_spot" => {
+        //     gate_coin_spot_data_listener::INDICATOR_MAP.lock().await
+        // }
         _ => {
             let response = Response {
                 query: serde_json::to_value(&query.into_inner()).unwrap(),
@@ -180,10 +180,10 @@ async fn get_exchanges() -> impl Responder {
         "gate_usdt_swap",
         "coinex_usdt_swap",
         "phemex_usdt_swap",
-        "mexc_usdt_swap",
+        // "mexc_usdt_swap",
         "bybit_usdt_swap",
-        "bitget_usdt_swap",
-        "gate_coin_spot",
+        // "bitget_usdt_swap",
+        // "gate_coin_spot",
     ];
     let response_data = json!(exchanges);