Переглянути джерело

紧急修复线上测试版本

skyfffire 2 роки тому
батько
коміт
686f5b6221

+ 16 - 0
global/src/trace_stack.rs

@@ -27,4 +27,20 @@ impl fmt::Display for TraceStack {
               // self.quant_end - self.quant_start,
               self.strategy_end - self.strategy_start)
     }
+}
+
+impl Default for TraceStack {
+    fn default() -> Self {
+        TraceStack {
+            network: 0,
+            format_start: 0,
+            format_end: 0,
+            quant_start: 0,
+            quant_end: 0,
+            strategy_start: 0,
+            strategy_end: 0,
+            source: "".to_string(),
+            order_command: "".to_string(),
+        }
+    }
 }

+ 1 - 0
src/quant_libs.rs

@@ -63,6 +63,7 @@ pub async fn init(params: Params, ws_running: Arc<AtomicBool>, running: Arc<Atom
                             create_time: 0,
                             status: order.status,
                             fee: Default::default(),
+                            trace_stack: Default::default(),
                         };
 
                         quant.update_local_order(order_info.clone());

+ 2 - 0
strategy/src/exchange_disguise.rs

@@ -154,6 +154,7 @@ async fn gate_swap_run(bool_v1 :Arc<AtomicBool>, type_num: i8, quant_arc: Arc<Mu
                                 create_time: 0,
                                 status: order.status,
                                 fee: Default::default(),
+                                trace_stack: Default::default(),
                             };
                             order_infos.push(order_info);
                         }
@@ -293,6 +294,7 @@ async fn kucoin_swap_run(bool_v1 :Arc<AtomicBool>, type_num: i8, quant_arc: Arc<
                                 create_time: 0,
                                 status: order.status,
                                 fee: Default::default(),
+                                trace_stack: Default::default(),
                             };
                             order_infos.push(order_info);
                         }

+ 2 - 0
strategy/src/quant.rs

@@ -285,6 +285,7 @@ impl Quant {
                                 create_time: 0,
                                 status: "".to_string(),
                                 fee: Decimal::ZERO,
+                                trace_stack: Default::default(),
                             };
                             if val.status== "NEW" {
                                 local_order_info.client_id = val.custom_id;
@@ -747,6 +748,7 @@ impl Quant {
                     create_time: self.strategy.local_time,
                     status: "".to_string(),
                     fee: Default::default(),
+                    trace_stack: Default::default(),
                 };
                 // 本地挂单表
                 self.local_orders.insert(limits.get(j).unwrap()[3].clone(), order_info.clone());