coinex 延迟交易交易所订阅

exchanges/src/coinex_swap_ws.rs

@@ -363,13 +363,16 @@ impl CoinexSwapWs {
                                     None => {
                                         // 登录成功逻辑处理
                                         let mut login_data = LOGIN_DATA.lock().await;
-
-                                        if login_data.0 && !login_data.1 {
-                                            login_data.1 = true;
-                                            res_data.channel = "server.sign".to_string();
-                                            res_data.code = -200;
-                                        } else {
-                                            res_data.code = 400;
+                                        if login_data.0 { // 需要登录
+                                            if !login_data.1{
+                                                login_data.1 = true;
+                                                res_data.channel = "server.sign".to_string();
+                                                res_data.code = -200;
+                                            }else {
+                                                res_data.code = 400;
+                                            }
+                                        }  else { // 不需要登录
+                                            res_data.code = 200;
                                         }
                                     }
                                     _ =>{

exchanges/src/socket_tool.rs

@@ -64,7 +64,7 @@ impl AbstractWsMode {
         };
         // 如果不需要事先登录，则直接订阅消息
         if !is_first_login {
-            info!("订阅内容：{:?}", subscribe_array.clone());
+            info!("不需要登录，订阅内容：{:?}", subscribe_array.clone());
             for s in &subscribe_array {
                 let mut write_lock = ws_write_arc.lock().await;
                 write_lock.send(Message::Text(s.parse().unwrap())).await.expect("订阅消息失败");

strategy/src/exchange_disguise.rs

@@ -1,8 +1,10 @@
 use std::collections::BTreeMap;
 use std::sync::Arc;
 use std::sync::atomic::AtomicBool;
+use std::time::Duration;
 use rust_decimal::Decimal;
 use tokio::sync::Mutex;
+use tokio::time::Sleep;
 use global::trace_stack::TraceStack;
 use standard::SpecialDepth;
 
@@ -46,6 +48,7 @@ pub async fn run_transactional_exchange(is_shutdown_arc :Arc<AtomicBool>,
             bybit_swap_run(is_shutdown_arc,true, core_arc, name, symbols, is_colo, exchange_params).await;
         }
         "coinex_usdt_swap" => {
+            tokio::time::sleep(Duration::from_secs(1)).await;
             coinex_swap_run(is_shutdown_arc,true, core_arc, name, symbols, is_colo, exchange_params).await;
         }
         _ => {