埋点信息

exchanges/src/coinex_swap_rest.rs

@@ -10,7 +10,7 @@ use serde_json::Value;
 use crate::http_tool::RestTool;
 use crate::response_base::ResponseData;
 use sha2::{Digest, Sha256};
-use tracing::{error};
+use tracing::{error, info};
 
 #[derive(Clone)]
 pub struct CoinexSwapRest {
@@ -346,6 +346,7 @@ impl CoinexSwapRest {
                                     None,
                                     Some(params.to_string()),
             ).await;
+            info!("通过交易所id取消：响应 {:?}", data);
             data
         } else if client_id != "" {  // 如果客户端id不为空，则用客户端id取消订单
             let params = serde_json::json!({
@@ -361,6 +362,7 @@ impl CoinexSwapRest {
                                         None,
                                         Some(params.to_string()),
             ).await;
+            info!("通过客户端id取消：响应 {:?}", data);
             // 非空的
             if data.code == 200 && !data.data.is_null() {
                 data.data = data.data.as_array().unwrap()[0]["data"].clone();

standard/src/coinex_swap.rs

@@ -510,7 +510,7 @@ impl Platform for CoinexSwap {
                     avg_price: Default::default(),
                     status: "NULL".to_string(),
                     order_type: "".to_string(),
-                    trace_stack:  TraceStack::new(0, Instant::now()).on_special("485 coinex_swap".to_string())
+                    trace_stack:  TraceStack::new(0, Instant::now()).on_special("513 coinex_swap".to_string())
                 };
             } else {
                 result = format_order_item(res_data_json, ct_val, "canceled");
@@ -762,7 +762,7 @@ pub fn format_order_item(order: Value, ct_val: Decimal, status: &str) -> Order {
         avg_price,
         status: custom_status,
         order_type: "limit".to_string(),
-        trace_stack: TraceStack::new(0, Instant::now()).on_special("688 trace_stack".to_string()),
+        trace_stack: TraceStack::new(0, Instant::now()).on_special("765 trace_stack".to_string()),
     };
     return rst_order;
 }

strategy/src/coinex_usdt_swap.rs

@@ -2,7 +2,6 @@ use tracing::{error, info};
 use std::collections::BTreeMap;
 use std::sync::Arc;
 use std::sync::atomic::AtomicBool;
-use futures_util::future::err;
 use rust_decimal::Decimal;
 use tokio::spawn;
 use tokio::sync::Mutex;