延迟过高 风控完善

strategy/src/quant.rs

@@ -10,7 +10,7 @@ use rust_decimal::prelude::{ToPrimitive, Zero};
 use rust_decimal_macros::dec;
 use serde_json::Value;
 use tokio::spawn;
-use tokio::sync::mpsc::{channel, Receiver, Sender};
+use tokio::sync::mpsc::{Receiver, Sender};
 use tokio::sync::Mutex;
 use tokio::task::JoinHandle;
 use tokio::time::sleep;
@@ -838,14 +838,12 @@ impl Quant {
             self.exit(10).await;
         }
         // 报单延迟风控，平均延迟允许上限5000ms
-        // TODO quant.platform_rest.avg_delay不存在
-        // if _self.platform_rest.avg_delay > 5000 {
-        //     let exit_msg = format!("{} 延迟爆表 触发风控 准备停机。", _self.params.account_name);
-        //     warn!(exit_msg);
-        //     _self.exit_msg = exit_msg;
-        //     // TODO quant.stop()不存在
-        //     // _self.stop()
-        // }
+        if self.platform_rest.get_request_avg_delay() > dec!(5000) {
+            let exit_msg = format!("{} 延迟爆表 触发风控 准备停机。", self.params.account_name);
+            warn!(exit_msg);
+            self.exit_msg = exit_msg;
+            self.exit(10).await;
+        }
 
         // 仓位异常风控，只在合约模式下执行
         if !self.exchange.contains("spot") {