修改woox交易所数量问题

src/main.rs

@@ -48,11 +48,11 @@ async fn main() {
     // bingx_usdt_swap_data_listener::run_listener(running.clone()).await;
     // coinsph_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;
-    htx_usdt_swap_data_listener::run_listener(running.clone()).await;
-    phemex_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;
+    // htx_usdt_swap_data_listener::run_listener(running.clone()).await;
+    // phemex_usdt_swap_data_listener::run_listener(running.clone()).await;
     woo_usdt_swap_data_listener::run_listener(running.clone()).await;
     // panic错误捕获，panic级别的错误直接退出
     // let panic_running = running.clone();

standard/src/woo_swap_handle.rs

@@ -38,11 +38,12 @@ pub fn format_trade_items(res_data: &ResponseData) -> Vec<Trade> {
     for item in result {
         let side = item["b"] == "BUY";
         let size = Decimal::from_f64(item["a"].as_f64().unwrap()).unwrap();
+        let price = Decimal::from_f64(item["p"].as_f64().unwrap()).unwrap();
         trades.push(Trade {
             id: res_data.data["ts"].to_string(),
             time: Decimal::from_i64(res_data.data["ts"].as_i64().unwrap()).unwrap(),
-            size: if side { size } else { -size },
-            price: Decimal::from_f64(item["p"].as_f64().unwrap()).unwrap(),
+            size: if side { size * price } else { -size * price },
+            price,
             symbol: item["s"].as_str().unwrap().replace("PERP_", ""),
         })
     }