gate可以支持交易

strategy/src/bybit_usdt_swap.rs

@@ -37,12 +37,12 @@ pub(crate) async fn reference_bybit_swap_run(is_shutdown_arc: Arc<AtomicBool>,
         let core_arc_clone = Arc::clone(&core_arc);
         let mut rest = core_arc_clone.lock().await.platform_rest.clone_box();
         let multiplier = rest.get_self_market().multiplier;
-        let mut records = rest.get_record("1".to_string()).await.unwrap();
-        for record in records.iter_mut() {
-            let core_arc_clone = core_arc.clone();
-
-            on_record(core_arc_clone, record).await
-        }
+        // let mut records = rest.get_record("1".to_string()).await.unwrap();
+        // for record in records.iter_mut() {
+        //     let core_arc_clone = core_arc.clone();
+        //
+        //     on_record(core_arc_clone, record).await
+        // }
 
         let depth_asks = Arc::new(Mutex::new(Vec::new()));
         let depth_bids = Arc::new(Mutex::new(Vec::new()));

strategy/src/gate_usdt_swap.rs

@@ -49,7 +49,8 @@ pub async fn gate_swap_run(is_shutdown_arc: Arc<AtomicBool>,
             ws = GateSwapWs::new_label(name.clone(), is_colo, Some(login_param),
                                        GateSwapWsType::PublicAndPrivate("usdt".to_string()));
             ws.set_subscribe(vec![
-                // GateSwapSubscribeType::PuFuturesTrades,
+                GateSwapSubscribeType::PuFuturesTrades,
+                GateSwapSubscribeType::PuFuturesBookTicker,
 
                 GateSwapSubscribeType::PrFuturesOrders(user_id.clone()),
                 GateSwapSubscribeType::PrFuturesPositions(user_id.clone()),
@@ -121,7 +122,7 @@ async fn on_data(core_arc: Arc<Mutex<Core>>,
             for trade in trades.iter_mut() {
                 let core_arc_clone = core_arc.clone();
 
-                on_trade(core_arc_clone, &response.label, &mut trace_stack, &trade, 1).await;
+                on_trade(core_arc_clone, &response.label, &mut trace_stack, &trade, 0).await;
             }
         }
         "futures.balances" => {

strategy/src/predictor.rs

@@ -456,10 +456,6 @@ impl Predictor {
             return;
         }
 
-        if self.trade_long_vec.len() < 100 {
-            return;
-        }
-
         self.is_ready = true;
         info!("========================================行情数据预热完毕==================================")
     }