commit

src/main.rs

@@ -52,12 +52,12 @@ async fn main() {
     // bitget_usdt_swap_data_listener::run_listener(running.clone()).await;
     // htx_usdt_swap_data_listener::run_listener(running.clone()).await;
 
-    // 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;
-    // gate_usdt_spot_data_listener::run_listener(running.clone()).await;
-    // mexc_usdt_swap_data_listener::run_listener(running.clone()).await;
+    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;
+    gate_usdt_spot_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;
     // panic错误捕获，panic级别的错误直接退出
     // let panic_running = running.clone();

standard/src/exchange_struct_handler.rs

@@ -145,10 +145,6 @@ impl ExchangeStructHandler {
             ExchangeEnum::BybitSwap => {
                 bybit_swap_handle::format_trade_items(&res_data)
             }
-            _ => {
-                error!("未找到该交易所！trades_handle: {:?}", exchange);
-                panic!("未找到该交易所！trades_handle: {:?}", exchange);
-            }
         }
     }
     // 处理Ticker信息