Browse Source

修改kucoin获取全部仓位合约价值错误问题

gepangpang 2 years ago
parent
commit
dd052a092e
2 changed files with 3 additions and 4 deletions
  1. 1 2
      standard/src/kucoin_swap.rs
  2. 2 2
      standard/tests/kucoin_swap_test.rs

+ 1 - 2
standard/src/kucoin_swap.rs

@@ -131,14 +131,13 @@ impl Platform for KucoinSwap {
 
     async fn get_positions(&mut self) -> Result<Vec<Position>, Error> {
         let symbol_array: Vec<&str> = self.symbol.split("_").collect();
-        let ct_val = self.market.ct_val;
         let res_data = self.request.get_positions(symbol_array[1].to_string()).await;
         if res_data.code == "200" {
             let res_data_str = &res_data.data;
             let res_data_json: Vec<serde_json::Value> = serde_json::from_str(res_data_str).unwrap();
             let mut result = Vec::new();
             for item in res_data_json.iter() {
-                result.push(kucoin_handle::format_position_item(item, ct_val))
+                result.push(kucoin_handle::format_position_item(item, Decimal::ONE))
             }
             Ok(result)
         } else {

+ 2 - 2
standard/tests/kucoin_swap_test.rs

@@ -195,7 +195,7 @@ async fn test_take_order() {
     global::log_utils::init_log_with_trace();
 
     let mut kucoin_swap_exchange: Box<dyn Platform> = test_new_exchange(ExchangeEnum::KucoinSwap, SYMBOL).await;
-    let kucoin_take_order = kucoin_swap_exchange.take_order("999999", "kk", dec!(0.2), dec!(100)).await;
+    let kucoin_take_order = kucoin_swap_exchange.take_order("999999", "kk", dec!(0), dec!(100)).await;
     trace!(?kucoin_take_order);
 }
 
@@ -206,7 +206,7 @@ async fn test_cancel_order() {
     global::log_utils::init_log_with_trace();
 
     let mut kucoin_swap_exchange: Box<dyn Platform> = test_new_exchange(ExchangeEnum::KucoinSwap, SYMBOL).await;
-    let kucoin_cancel_order = kucoin_swap_exchange.cancel_order("96039854680322048", "").await;
+    let kucoin_cancel_order = kucoin_swap_exchange.cancel_order("108721685804371970", "").await;
     trace!(?kucoin_cancel_order);
 }