commit

src/phemex_usdt_swap_data_listener.rs

@@ -34,6 +34,7 @@ pub async fn run_listener(is_shutdown_arc: Arc<AtomicBool>) {
     let mut phemex_rest = PhemexSwapRest::new(false, login);
     let params = json!({});
     let response = phemex_rest.get_market(params).await;
+    let mut loc_symbols = vec![];
     let mut symbols = vec![];
     if response.code == 200 {
         let symbol_infos = response.data["perpProductsV2"].as_array().unwrap();
@@ -47,6 +48,7 @@ pub async fn run_listener(is_shutdown_arc: Arc<AtomicBool>) {
             let mul = Decimal::ONE;
             mul_map.insert(loc_symbol.clone(), mul);
 
+            loc_symbols.push(loc_symbol);
             symbols.push(symbol)
         }
     }
@@ -75,7 +77,7 @@ pub async fn run_listener(is_shutdown_arc: Arc<AtomicBool>) {
         loop {
             let end_timestamp = Utc::now().timestamp_millis();
             let start_timestamp = end_timestamp - 60 * 1000 * 60;
-            for symbol in symbols.clone() {
+            for symbol in loc_symbols.clone() {
                 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);