Explorar o código

新增bitget的一些基础判断。

skyfffire %!s(int64=2) %!d(string=hai) anos
pai
achega
fc857eca5e
Modificáronse 3 ficheiros con 9 adicións e 1 borrados
  1. 1 0
      global/src/public_params.rs
  2. 4 1
      strategy/src/quant.rs
  3. 4 0
      strategy/src/utils.rs

+ 1 - 0
global/src/public_params.rs

@@ -28,6 +28,7 @@ pub const COINEX_SPOT_LIMIT:i64 = 20;
 pub const COINEX_USDT_SWAP_LIMIT:i64 = 20;
 pub const OKEX_USDT_SWAP_LIMIT:i64 = 30;
 pub const BITGET_USDT_SWAP_LIMIT:i64 = 10;
+pub const BITGET_USDT_SPOT_LIMIT:i64 = 10;
 pub const BYBIT_USDT_SWAP_LIMIT:i64 = 1;
 pub const MEXC_SPOT_LIMIT:i64 = 333;
 pub const RATIO:i64 = 4;

+ 4 - 1
strategy/src/quant.rs

@@ -20,7 +20,7 @@ use global::public_params::{ASK_PRICE_INDEX, BID_PRICE_INDEX, LENGTH};
 use global::trace_stack::TraceStack;
 use standard::{Account, Market, Order, OrderCommand, Platform, Position, PositionModeEnum, SpecialTicker, Ticker};
 use standard::exchange::{Exchange};
-use standard::exchange::ExchangeEnum::{BinanceSpot, BinanceSwap, GateSpot, GateSwap, KucoinSwap};
+use standard::exchange::ExchangeEnum::{BinanceSpot, BinanceSwap, BitgetSpot, GateSpot, GateSwap, KucoinSwap};
 
 use crate::model::{LocalPosition, OrderInfo, TokenParam, TraderMsg};
 use crate::predictor::Predictor;
@@ -198,6 +198,9 @@ impl Quant {
                 },
                 "binance_spot" => {
                     Exchange::new(BinanceSpot, symbol, params.colo != 0i8, exchange_params, order_sender, error_sender).await
+                },
+                "bitget_spot" => {
+                    Exchange::new(BitgetSpot, symbol, params.colo != 0i8, exchange_params, order_sender, error_sender).await
                 }
                 _ => {
                     error!("203未找到对应的交易所rest枚举!");

+ 4 - 0
strategy/src/utils.rs

@@ -61,6 +61,8 @@ pub fn get_limit_requests_num_per_second(exchange: String) -> i64 {
         return public_params::COINEX_USDT_SWAP_LIMIT * public_params::RATIO;
     } else if exchange.eq("coinex_spot") {
         return public_params::COINEX_SPOT_LIMIT * public_params::RATIO;
+    } else if exchange.eq("bitget_spot") {
+        return public_params::BITGET_USDT_SPOT_LIMIT * public_params::RATIO;
     } else {
         error!("限频规则(ratio)未找到,请检查配置!");
         panic!("限频规则(ratio)未找到,请检查配置!");
@@ -85,6 +87,8 @@ pub fn get_limit_order_requests_num_per_second(exchange: String) -> i64 {
         return public_params::COINEX_USDT_SWAP_LIMIT
     } else if exchange.eq("coinex_spot") {
         return public_params::COINEX_SPOT_LIMIT
+    } else if exchange.eq("bitget_spot") {
+        return public_params::BITGET_USDT_SPOT_LIMIT
     } else {
         error!("限频规则(limit)未找到,请检查配置!");
         panic!("限频规则(limit)未找到,请检查配置!");