修复ping-pong超时

exchanges/src/htx_swap_ws.rs

@@ -353,11 +353,11 @@ impl HtxSwapWs {
         //心跳包
         let ping = json_value["ping"].as_i64();
         match ping {
-            Some(_) => {
+            Some(ping_ts) => {
                 let pong = json!({
-                    "pong": Utc::now().timestamp()/100
+                    "pong": ping_ts
                 });
-                return ResponseData::new("".to_string(), -301, "success".to_string(), pong);
+                return ResponseData::new("".to_string(), -302, "success".to_string(), pong);
             }
             None => {}
         }
@@ -411,11 +411,12 @@ impl HtxSwapWs {
                 return res_data;
             }
             "ping" => {
+                let ts = json_value["ts"].as_str().unwrap();
                 let pong = json!({
                     "op": "pong",
-                    "ts": Utc::now().timestamp()
+                    "ts": ts
                 });
-                return ResponseData::new("".to_string(), -301, "success".to_string(), pong);
+                return ResponseData::new("".to_string(), -302, "success".to_string(), pong);
             }
             "sub" => {
                 res_data.channel = json_value["topic"].as_str().unwrap().to_string();

strategy/src/htx_usdt_swap.rs

@@ -106,7 +106,6 @@ async fn on_private_data(core_arc_clone: Arc<Mutex<Core>>,
     let position_channel = "positions_cross";
     let balance_channel = "accounts_cross";
     if response.channel.contains(order_channel) { // 订单频道
-        info!("订单推送： {}", response.data);
         trace_stack.set_source("htx_swap.orders".to_string());
         let orders = standard::handle_info::HandleSwapInfo::handle_order(HtxSwap, response.clone(), ct_val.clone());
         let mut order_infos:Vec<OrderInfo> = Vec::new();