日志的一些优化

global/src/log_utils.rs

@@ -1,4 +1,4 @@
-use tracing_subscriber::{EnvFilter, FmtSubscriber};
+use tracing_subscriber::{FmtSubscriber};
 
 pub fn init_log_with_debug() {
     final_init(tracing::Level::DEBUG)
@@ -13,15 +13,15 @@ pub fn init_log_with_info() {
 }
 
 pub fn final_init(level: tracing::Level) {
-    let filter = EnvFilter::from_default_env()
-        .add_directive("exchanges=trace".parse().unwrap())
-        .add_directive("global=trace".parse().unwrap())
-        .add_directive("standard=trace".parse().unwrap())
-        .add_directive("tests=trace".parse().unwrap())
-        .add_directive("strategy=trace".parse().unwrap());
+    // let filter = EnvFilter::from_default_env()
+    //     .add_directive("exchanges=trace".parse().unwrap())
+    //     .add_directive("global=trace".parse().unwrap())
+    //     .add_directive("standard=trace".parse().unwrap())
+    //     .add_directive("tests=trace".parse().unwrap())
+    //     .add_directive("strategy=trace".parse().unwrap());
 
     let subscriber = FmtSubscriber::builder()
-        .with_env_filter(filter)
+        // .with_env_filter(filter)
         .with_max_level(level)
         .with_span_events(tracing_subscriber::fmt::format::FmtSpan::FULL)
         .finish();

src/main.rs

@@ -38,11 +38,11 @@ async fn main() {
     info!("quant初始化……");
     quant_arc.lock().await.before_trade().await;
     let ref_name = quant_arc.lock().await.ref_name[0].clone();
-    // quant::run_refer(quant_arc.clone(), ref_name, params.ref_pair.clone(), exchange_params.clone()).await;
+    quant::run_refer(quant_arc.clone(), ref_name, params.ref_pair.clone(), exchange_params.clone()).await;
 
     exchange_params.clear();
-    exchange_params.insert("access_key".to_string(), "4181c882718a95e72122ac1d52c88533".to_string());
-    exchange_params.insert("secret_key".to_string(), "de82d1507b843ff08d81a0e9b878b721359f274937216b307834b570b676fa3c".to_string());
+    exchange_params.insert("access_key".to_string(), params.access_key);
+    exchange_params.insert("secret_key".to_string(), params.secret_key);
     // 交易交易所
     quant::run_transaction(quant_arc.clone(), trade_name, vec![params.pair], exchange_params.clone()).await;