新增 kucion 的设置风险等级接口

exchanges/src/kucoin_swap_rest.rs

@@ -245,7 +245,7 @@ impl KucoinSwapRest {
     }
     //批量测但
     pub async fn cancel_orders(&mut self, symbol: String) -> ResponseData {
-        let  params = serde_json::json!({   });
+        let params = serde_json::json!({   });
         let data = self.request("DELETE".to_string(),
                                 "/api/v1".to_string(),
                                 format!("/orders?symbol={}", symbol),
@@ -277,6 +277,32 @@ impl KucoinSwapRest {
         ).await;
         data
     }
+    //设置杠杆（修改階梯風險限額等級）
+    pub async fn set_leverage(&mut self, symbol: String, level: i8) -> ResponseData {
+        let params = serde_json::json!({
+            "symbol":symbol,
+            "level":level,
+        });
+        let data = self.request("POST".to_string(),
+                                "/api/v1".to_string(),
+                                format!("/position/risk-limit-level/change"),
+                                true,
+                                params.to_string(),
+        ).await;
+        data
+    }
+    //查看杠杆（查詢杠桿代幣信息）
+    pub async fn get_leverage(&mut self,symbol:String) -> ResponseData {
+        let params = serde_json::json!({
+        });
+        let data = self.request("GET".to_string(),
+                                "/api/v1".to_string(),
+                                format!("/contracts/risk-limit/{}",symbol),
+                                true,
+                                params.to_string(),
+        ).await;
+        data
+    }
     /*******************************************************************************************************/
     /*****************************************工具函数********************************************************/
     /*******************************************************************************************************/

exchanges/src/okx_swap_rest.rs

@@ -413,7 +413,7 @@ impl OkxSwapRest {
 
     //res_data 解析
     pub fn res_data_analysis(result: Result<ResponseData, reqwest::Error>, base_url: String, params: String) -> ResponseData {
-        trace!("原始数据：{:?}",result);
+        // trace!("原始数据：{:?}",result);
         match result {
             Ok(res_data) => {
                 if res_data.code != "200" {

exchanges/tests/kucoin_swap_test.rs

@@ -86,6 +86,26 @@ async fn rest_get_server_time_test() {
 }
 
 
+//rest-杠杆测试
+#[tokio::test]
+async fn rest_leverage_test() {
+    global::log_utils::init_log_with_trace();
+
+    // //查询杠杆
+    let mut rest = get_rest();
+    // let rep_data = rest.get_leverage("ADAUSDTM".to_string()).await;
+    // trace!("查询杠杆{:?}",rep_data);
+
+    //设置杠杆
+    let rep_data2 = rest.set_leverage("BLZUSDTM".to_string(), 1).await;
+    trace!("设置杠杆{:?}",rep_data2);
+
+    // //查询杠杆
+    // let rep_data3 = rest.get_leverage("BLZUSDTM".to_string()).await;
+    // trace!("查询杠杆{:?}",rep_data3);
+}
+
+
 async fn get_ws(btree_map: BTreeMap<String, String>, type_v: KucoinWsType, tx: Sender<ResponseData>) -> KucoinSwapWs {
     let mut ku_ws = KucoinSwapWs::new(false, btree_map.clone(),
                                       type_v, tx).await;