完整版本

src/gate_usdt_swap_data_listener.rs

@@ -93,13 +93,10 @@ pub async fn run_listener(is_shutdown_arc: Arc<AtomicBool>) {
                         indicators.result_size = old_msv.result_size + msv.result_size;
                         indicators.total_size = old_msv.total_size + msv.total_size;
                         indicators.last_calc_time = msv.last_calc_time;
-                        info!("删除前： result_size：{}", indicators.result_size);
-
                         // 删除掉指定小时前的数据
                         delete_expire_data(indicators, 4)
                     }
                 };
-                info!("删除后： result_size：{}", new_msv.result_size);
                 indicator_map.insert(symbol, new_msv);
             }
             // 更新结束时间

src/main.rs

@@ -4,12 +4,12 @@ mod server;
 mod listener_tools;
 mod binance_usdt_swap_data_listener;
 mod gate_usdt_swap_data_listener;
-// mod coinex_usdt_swap_data_listener;
-// mod phemex_usdt_swap_data_listener;
-// mod mexc_usdt_swap_data_listener;
-// mod bybit_usdt_swap_data_listener;
-// mod bitget_usdt_swap_data_listener;
-// mod gate_coin_spot_data_listener;
+mod coinex_usdt_swap_data_listener;
+mod phemex_usdt_swap_data_listener;
+mod mexc_usdt_swap_data_listener;
+mod bybit_usdt_swap_data_listener;
+mod bitget_usdt_swap_data_listener;
+mod gate_coin_spot_data_listener;
 mod msv;
 mod rank;
 
@@ -38,12 +38,12 @@ async fn main() {
     // 启动各交易所的数据监听器
     binance_usdt_swap_data_listener::run_listener(running.clone()).await;
     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;
-    // bybit_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;
+    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;
+    bybit_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();
     std::panic::set_hook(Box::new(move |panic_info| {

src/server.rs

@@ -9,8 +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, rank};
+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::json_db_utils::{collect_special_trades_json, get_symbols_by_exchange};
 use crate::msv::{generate_msv_by_trades, Indicators, parse_json_to_trades};
 
@@ -115,27 +114,27 @@ async fn get_rank_list(query: web::Query<RankQuery>) -> impl Responder {
         "gate_usdt_swap" => {
             gate_usdt_swap_data_listener::INDICATOR_MAP.lock().await
         }
-        // "coinex_usdt_swap" => {
-        //     coinex_usdt_swap_data_listener::INDICATOR_MAP.lock().await
-        // }
+        "coinex_usdt_swap" => {
+            coinex_usdt_swap_data_listener::INDICATOR_MAP.lock().await
+        }
         "binance_usdt_swap" => {
             binance_usdt_swap_data_listener::INDICATOR_MAP.lock().await
         }
-        // "phemex_usdt_swap" => {
-        //     phemex_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
-        // }
+        "phemex_usdt_swap" => {
+            phemex_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
+        }
         _ => {
             let response = Response {
                 query: serde_json::to_value(&query.into_inner()).unwrap(),