|
|
@@ -9,7 +9,7 @@ use rust_decimal::Decimal;
|
|
|
use rust_decimal::prelude::FromPrimitive;
|
|
|
use serde::{Deserialize, Serialize};
|
|
|
use serde_json::json;
|
|
|
-use tracing::error;
|
|
|
+use tracing::{debug, error};
|
|
|
use exchanges::okx_swap_rest::OkxSwapRest;
|
|
|
use global::trace_stack::TraceStack;
|
|
|
use crate::exchange::ExchangeEnum;
|
|
|
@@ -796,7 +796,7 @@ impl Platform for OkxSwap {
|
|
|
avg_price: Decimal::ZERO,
|
|
|
status: "NEW".to_string(),
|
|
|
order_type: "".to_string(),
|
|
|
- trace_stack: TraceStack::default().on_special("798 okx_swap".to_string()),
|
|
|
+ trace_stack: TraceStack::default().on_special("799 okx_swap".to_string()),
|
|
|
};
|
|
|
Ok(result)
|
|
|
} else {
|
|
|
@@ -850,7 +850,7 @@ impl Platform for OkxSwap {
|
|
|
avg_price: Decimal::ZERO,
|
|
|
status: "NEW".to_string(),
|
|
|
order_type: "".to_string(),
|
|
|
- trace_stack: TraceStack::default().on_special("852 okx_swap".to_string()),
|
|
|
+ trace_stack: TraceStack::default().on_special("853 okx_swap".to_string()),
|
|
|
};
|
|
|
Ok(result)
|
|
|
} else {
|
|
|
@@ -876,7 +876,7 @@ impl Platform for OkxSwap {
|
|
|
avg_price: Decimal::ZERO,
|
|
|
status: "REMOVE".to_string(),
|
|
|
order_type: "".to_string(),
|
|
|
- trace_stack: TraceStack::default().on_special("854 okx_swap".to_string()),
|
|
|
+ trace_stack: TraceStack::default().on_special("879 okx_swap".to_string()),
|
|
|
};
|
|
|
Ok(result)
|
|
|
} else {
|
|
|
@@ -1027,6 +1027,8 @@ impl Platform for OkxSwap {
|
|
|
}
|
|
|
|
|
|
pub fn format_order_item(data: SwapOrder, ct_val: Decimal) -> Order {
|
|
|
+ debug!("format-order-start, okx_swap");
|
|
|
+ debug!(?data);
|
|
|
let custom_status = if ["canceled", "filled", "mmp_canceled"].contains(&data.state.as_str()) {
|
|
|
"REMOVE".to_string()
|
|
|
} else if ["live", "partially_filled"].contains(&data.state.as_str()) {
|
|
|
@@ -1035,7 +1037,7 @@ pub fn format_order_item(data: SwapOrder, ct_val: Decimal) -> Order {
|
|
|
"NULL".to_string()
|
|
|
};
|
|
|
|
|
|
- Order {
|
|
|
+ let result = Order {
|
|
|
id: data.ord_id,
|
|
|
custom_id: data.cl_ord_id,
|
|
|
price: data.px,
|
|
|
@@ -1044,6 +1046,9 @@ pub fn format_order_item(data: SwapOrder, ct_val: Decimal) -> Order {
|
|
|
avg_price: if data.avg_px != "" { Decimal::from_str(&data.avg_px).unwrap() } else { Decimal::ZERO },
|
|
|
status: custom_status,
|
|
|
order_type: data.ord_type,
|
|
|
- trace_stack: TraceStack::default().on_special("1022 okx_swap".to_string()),
|
|
|
- }
|
|
|
+ trace_stack: TraceStack::default().on_special("1049 okx_swap".to_string()),
|
|
|
+ };
|
|
|
+ debug!(?result);
|
|
|
+ debug!("format-order-end, okx_swap");
|
|
|
+ result
|
|
|
}
|