仓位推送过滤

strategy/src/phemex_usdt_swap.rs

@@ -141,9 +141,9 @@ async fn on_private_data(core_arc_clone: Arc<Mutex<Core>>,
             let mut position_res = response.clone();
             position_res.data = position_res.data["positions_p"].clone();
             let positions = standard::handle_info::HandleSwapInfo::handle_position(PhemexSwap, &position_res, &ct_val);
-            info!("仓位推送：{:?}", positions);
+            info!("{} 仓位推送：{:?}", &target_symbol.replace("_", "").to_uppercase(), positions);
             // 只要正在运行中币对的仓位信息
-            let run_position: Vec<Position> = positions.into_iter().filter(|position| position.symbol.contains(&target_symbol)).collect();
+            let run_position: Vec<Position> = positions.into_iter().filter(|position| position.symbol.contains(&target_symbol.replace("_", "").to_uppercase())).collect();
             if run_position.len() > 0 {
                 let mut core = core_arc_clone.lock().await;
                 core.update_position(run_position).await;