处理一下log。

exchanges/src/bitget_swap_ws.rs

@@ -3,7 +3,7 @@ use std::sync::atomic::AtomicBool;
 use chrono::{Utc};
 use futures_channel::mpsc::{UnboundedReceiver, UnboundedSender};
 use serde_json::{json, Value};
-use tracing::{error, info, trace};
+use tracing::{info, trace, warn};
 use ring::hmac;
 use tokio::sync::Mutex;
 use tokio_tungstenite::tungstenite::{Error, Message};
@@ -240,7 +240,7 @@ impl BitgetSwapWs {
                                                  login_is, tag.clone(), subscribe_array.clone(), write_to_socket_rx_arc.clone(),
                                                  Self::message_text, Self::message_ping, Self::message_pong).await;
 
-                error!("bitget_usdt_swap socket 断连，重连中……");
+                warn!("bitget_usdt_swap socket 断连，重连中……");
             }
         });
         tokio::try_join!(t2).unwrap();

global/src/log_utils.rs

@@ -1,6 +1,6 @@
 use std::fmt::Debug;
 use std::io;
-use tracing::{Event, Subscriber};
+use tracing::{Event, Subscriber, warn};
 use tracing_appender_timezone::non_blocking::WorkerGuard;
 use tracing_subscriber::{fmt, Layer};
 use tracing_subscriber::layer::{Context, SubscriberExt};
@@ -36,7 +36,7 @@ impl<S> Layer<S> for ReportingLayer
             };
             event.record(&mut visitor);
 
-            panic!("Unhandle error: {}", self.app_name)
+            warn!("Unhandle error: {}", self.app_name)
         }
     }
 }