瀏覽代碼

撤單邏輯恢復之前的。

skyfffire 1 年之前
父節點
當前提交
195094cc4c
共有 1 個文件被更改,包括 21 次插入21 次删除
  1. 21 21
      strategy/src/strategy.rs

+ 21 - 21
strategy/src/strategy.rs

@@ -826,35 +826,35 @@ impl Strategy {
     pub fn _cancel_open(&self, command: &mut OrderCommand, local_orders: &HashMap<String, OrderInfo>) {
         // debug!(?command);
         // 挂单范围
-        // let long_upper = self.open_dist[0];
-        // let long_lower = self.open_dist[1];
-        // let short_lower = self.open_dist[2];
-        // let short_upper = self.open_dist[3];
+        let long_upper = self.open_dist[0];
+        let long_lower = self.open_dist[1];
+        let short_lower = self.open_dist[2];
+        let short_upper = self.open_dist[3];
 
         for order_client_id in local_orders.keys() {
             let order = local_orders.get(order_client_id).unwrap();
             let key = format!("Cancel{}", *order_client_id);
             let value = vec![order.client_id.clone(), order.order_id.clone()];
 
-            if self.local_time - order.local_time > 100 {
-                command.cancel.insert(key, value);
-            }
-            // // 开多订单处理
-            // if order.side == "kd".to_string() {
-            //     // 在价格范围内时不处理
-            //     if order.price <= long_upper && order.price >= long_lower {
-            //         continue
-            //     }
-            //     // debug!(?key, ?order.price, ?long_upper, ?long_lower);
-            //     command.cancel.insert(key, value);
-            // } else if order.side == "kk".to_string() { // 开空订单处理
-            //     // 在价格范围内时不处理
-            //     if order.price >= short_lower && order.price <= short_upper {
-            //         continue
-            //     }
-            //     // debug!(?key, ?order.price, ?short_lower, ?short_upper);
+            // if self.local_time - order.local_time > 100 {
             //     command.cancel.insert(key, value);
             // }
+            // 开多订单处理
+            if order.side == "kd".to_string() {
+                // 在价格范围内时不处理
+                if order.price <= long_upper && order.price >= long_lower {
+                    continue
+                }
+                // debug!(?key, ?order.price, ?long_upper, ?long_lower);
+                command.cancel.insert(key, value);
+            } else if order.side == "kk".to_string() { // 开空订单处理
+                // 在价格范围内时不处理
+                if order.price >= short_lower && order.price <= short_upper {
+                    continue
+                }
+                // debug!(?key, ?order.price, ?short_lower, ?short_upper);
+                command.cancel.insert(key, value);
+            }
         }
     }