diff --git a/src/coin_health_check_team/monitors.rs b/src/coin_health_check_team/monitors.rs index f3529d0..04d2490 100644 --- a/src/coin_health_check_team/monitors.rs +++ b/src/coin_health_check_team/monitors.rs @@ -28,119 +28,121 @@ pub async fn collect_valid_usde_trade( symbol: String, } - // if RUNNING_MODE == SIMUL { // || RUNNING_MODE == REAL { - // let mut usdt_trades = UsdtTrades { symbol: String::new() }; + + let mut usdt_trades = UsdtTrades { symbol: String::new() }; - // let fetch_table_name = String::from("all_24h_change"); - // let column_name = String::from("symbol"); - // let mut condition_build = String::from("WHERE symbol LIKE '%BUSD' AND symbol NOT LIKE '%DOWNUSDT'"); - // condition_build.push_str(" AND symbol NOT LIKE '%UPUSDT' AND firstId >= 0 AND lastId >= 0"); - // condition_build.push_str(" AND symbol NOT IN (SELECT symbol FROM stop_usdt_trades)"); - // // add unnessesary coins - // condition_build.push_str(" AND symbol NOT LIKE 'BUSDUSDT'"); - // condition_build.push_str(" AND symbol NOT LIKE 'TUSDUSDT'"); - // condition_build.push_str(" AND symbol NOT LIKE 'USDPUSDT'"); - // condition_build.push_str(" AND symbol NOT LIKE 'SUSDUSDT'"); - // condition_build.push_str(" AND symbol NOT LIKE 'AUDUSDT'"); - // condition_build.push_str(" AND symbol NOT LIKE 'EURUSDT'"); - // condition_build.push_str(" AND symbol NOT LIKE 'GBPUSDT'"); - // condition_build.push_str(" AND symbol NOT LIKE 'USDCUSDT'"); - // condition_build.push_str(" AND symbol NOT LIKE 'BZRXUSDT'"); - // condition_build.push_str(" AND symbol NOT LIKE 'USTUSDT'"); - // condition_build.push_str(" AND symbol NOT LIKE 'NBTUSDT'"); - // condition_build.push_str(" AND symbol NOT LIKE 'VGXUSDT'"); - // condition_build.push_str(" AND symbol NOT LIKE 'RAMPUSDT'"); - // condition_build.push_str(" AND symbol NOT LIKE 'TORNUSDT'"); - // condition_build.push_str(" AND symbol NOT LIKE 'BTTCUSDT'"); - // condition_build.push_str(" AND symbol NOT LIKE 'BTCSTUSDT'"); - // condition_build.push_str(" AND symbol NOT LIKE 'ACAUSDT'"); - // condition_build.push_str(" AND symbol NOT LIKE 'ANCUSDT'"); - // let condition = Some(condition_build); + let fetch_table_name = String::from("all_24h_change"); + let column_name = String::from("symbol"); + let mut condition_build = String::from("WHERE symbol LIKE '%USDT' AND symbol NOT LIKE '%DOWNUSDT'"); + condition_build.push_str(" AND symbol NOT LIKE '%UPUSDT' AND firstId >= 0 AND lastId >= 0"); + condition_build.push_str(" AND symbol NOT IN (SELECT symbol FROM stop_usdt_trades)"); + // add unnessesary coins + condition_build.push_str(" AND symbol NOT LIKE 'BUSDUSDT'"); + condition_build.push_str(" AND symbol NOT LIKE 'USTCUSDT'"); + condition_build.push_str(" AND symbol NOT LIKE 'FDUSDUSDT'"); + condition_build.push_str(" AND symbol NOT LIKE 'TUSDUSDT'"); + condition_build.push_str(" AND symbol NOT LIKE 'USDPUSDT'"); + condition_build.push_str(" AND symbol NOT LIKE 'SUSDUSDT'"); + condition_build.push_str(" AND symbol NOT LIKE 'AUDUSDT'"); + condition_build.push_str(" AND symbol NOT LIKE 'EURUSDT'"); + condition_build.push_str(" AND symbol NOT LIKE 'GBPUSDT'"); + condition_build.push_str(" AND symbol NOT LIKE 'USDCUSDT'"); + condition_build.push_str(" AND symbol NOT LIKE 'BZRXUSDT'"); + condition_build.push_str(" AND symbol NOT LIKE 'USTUSDT'"); + condition_build.push_str(" AND symbol NOT LIKE 'NBTUSDT'"); + condition_build.push_str(" AND symbol NOT LIKE 'VGXUSDT'"); + condition_build.push_str(" AND symbol NOT LIKE 'RAMPUSDT'"); + condition_build.push_str(" AND symbol NOT LIKE 'TORNUSDT'"); + condition_build.push_str(" AND symbol NOT LIKE 'BTTCUSDT'"); + condition_build.push_str(" AND symbol NOT LIKE 'BTCSTUSDT'"); + condition_build.push_str(" AND symbol NOT LIKE 'ACAUSDT'"); + condition_build.push_str(" AND symbol NOT LIKE 'ANCUSDT'"); + let condition = Some(condition_build); - // let select_result = select_record(&fetch_table_name, &column_name, &condition, &usdt_trades).await?; + let select_result = select_record(&fetch_table_name, &column_name, &condition, &usdt_trades).await?; + let table_name = String::from("valid_usdt_trades"); + let columns = vec!["symbol"]; + let mut symbol_vec: Vec = Vec::new(); + let mut value_wrapper: Vec> = Vec::new(); + for element in select_result { + let mut inner_vec: Vec = Vec::new(); + inner_vec.push(element.symbol.clone()); + value_wrapper.push(inner_vec); + symbol_vec.push(element.symbol); + } + *valid_usdt_trade_vec = symbol_vec; + delete_all_rows(&table_name).await?; + insert_records(&table_name, &columns, &value_wrapper).await?; + + + // major trades + // if RUNNING_MODE == TEST || RUNNING_MODE == REAL || RUNNING_MODE == SIMUL { // let table_name = String::from("valid_usdt_trades"); // let columns = vec!["symbol"]; // let mut symbol_vec: Vec = Vec::new(); // let mut value_wrapper: Vec> = Vec::new(); - // for element in select_result { - // let mut inner_vec: Vec = Vec::new(); - // inner_vec.push(element.symbol.clone()); - // value_wrapper.push(inner_vec); - // symbol_vec.push(element.symbol); - // } + + // value_wrapper.push(vec![String::from("BTCUSDT")]); + // value_wrapper.push(vec![String::from("ETHUSDT")]); + // value_wrapper.push(vec![String::from("XRPUSDT")]); + // value_wrapper.push(vec![String::from("DOGEUSDT")]); + // value_wrapper.push(vec![String::from("LTCUSDT")]); + // value_wrapper.push(vec![String::from("TRXUSDT")]); + // value_wrapper.push(vec![String::from("DOTUSDT")]); + // value_wrapper.push(vec![String::from("LINKUSDT")]); + // value_wrapper.push(vec![String::from("AVAXUSDT")]); + // value_wrapper.push(vec![String::from("BCHUSDT")]); + // value_wrapper.push(vec![String::from("SHIBUSDT")]); + // value_wrapper.push(vec![String::from("APTUSDT")]); + // value_wrapper.push(vec![String::from("ARBUSDT")]); + // value_wrapper.push(vec![String::from("ETCUSDT")]); + // value_wrapper.push(vec![String::from("XMRUSDT")]); + // value_wrapper.push(vec![String::from("HBARUSDT")]); + // value_wrapper.push(vec![String::from("UNIUSDT")]); + // value_wrapper.push(vec![String::from("XLMUSDT")]); + // value_wrapper.push(vec![String::from("VETUSDT")]); + // value_wrapper.push(vec![String::from("QNTUSDT")]); + // value_wrapper.push(vec![String::from("GRTUSDT")]); + // value_wrapper.push(vec![String::from("AAVEUSDT")]); + // value_wrapper.push(vec![String::from("EGLDUSDT")]); + // value_wrapper.push(vec![String::from("LDOUSDT")]); + // value_wrapper.push(vec![String::from("STXUSDT")]); + // value_wrapper.push(vec![String::from("MKRUSDT")]); + // value_wrapper.push(vec![String::from("OPUSDT")]); + + // symbol_vec.push(String::from("BTCUSDT")); + // symbol_vec.push(String::from("ETHUSDT")); + // symbol_vec.push(String::from("XRPUSDT")); + // symbol_vec.push(String::from("DOGEUSDT")); + // symbol_vec.push(String::from("LTCUSDT")); + // symbol_vec.push(String::from("TRXUSDT")); + // symbol_vec.push(String::from("DOTUSDT")); + // symbol_vec.push(String::from("LINKUSDT")); + // symbol_vec.push(String::from("AVAXUSDT")); + // symbol_vec.push(String::from("BCHUSDT")); + // symbol_vec.push(String::from("SHIBUSDT")); + // symbol_vec.push(String::from("APTUSDT")); + // symbol_vec.push(String::from("ARBUSDT")); + // symbol_vec.push(String::from("ETCUSDT")); + // symbol_vec.push(String::from("XMRUSDT")); + // symbol_vec.push(String::from("HBARUSDT")); + // symbol_vec.push(String::from("UNIUSDT")); + // symbol_vec.push(String::from("XLMUSDT")); + // symbol_vec.push(String::from("VETUSDT")); + // symbol_vec.push(String::from("QNTUSDT")); + // symbol_vec.push(String::from("GRTUSDT")); + // symbol_vec.push(String::from("AAVEUSDT")); + // symbol_vec.push(String::from("EGLDUSDT")); + // symbol_vec.push(String::from("LDOUSDT")); + // symbol_vec.push(String::from("STXUSDT")); + // symbol_vec.push(String::from("MKRUSDT")); + // symbol_vec.push(String::from("OPUSDT")); + // *valid_usdt_trade_vec = symbol_vec; // delete_all_rows(&table_name).await?; // insert_records(&table_name, &columns, &value_wrapper).await?; - // } else - if RUNNING_MODE == TEST || RUNNING_MODE == REAL || RUNNING_MODE == SIMUL { - let table_name = String::from("valid_usdt_trades"); - let columns = vec!["symbol"]; - let mut symbol_vec: Vec = Vec::new(); - let mut value_wrapper: Vec> = Vec::new(); - - value_wrapper.push(vec![String::from("BTCUSDT")]); - value_wrapper.push(vec![String::from("ETHUSDT")]); - value_wrapper.push(vec![String::from("XRPUSDT")]); - value_wrapper.push(vec![String::from("DOGEUSDT")]); - value_wrapper.push(vec![String::from("LTCUSDT")]); - value_wrapper.push(vec![String::from("TRXUSDT")]); - value_wrapper.push(vec![String::from("DOTUSDT")]); - value_wrapper.push(vec![String::from("LINKUSDT")]); - value_wrapper.push(vec![String::from("AVAXUSDT")]); - value_wrapper.push(vec![String::from("BCHUSDT")]); - value_wrapper.push(vec![String::from("SHIBUSDT")]); - value_wrapper.push(vec![String::from("APTUSDT")]); - value_wrapper.push(vec![String::from("ARBUSDT")]); - value_wrapper.push(vec![String::from("ETCUSDT")]); - value_wrapper.push(vec![String::from("XMRUSDT")]); - value_wrapper.push(vec![String::from("HBARUSDT")]); - value_wrapper.push(vec![String::from("UNIUSDT")]); - value_wrapper.push(vec![String::from("XLMUSDT")]); - value_wrapper.push(vec![String::from("VETUSDT")]); - value_wrapper.push(vec![String::from("QNTUSDT")]); - value_wrapper.push(vec![String::from("GRTUSDT")]); - value_wrapper.push(vec![String::from("AAVEUSDT")]); - value_wrapper.push(vec![String::from("EGLDUSDT")]); - value_wrapper.push(vec![String::from("LDOUSDT")]); - value_wrapper.push(vec![String::from("STXUSDT")]); - value_wrapper.push(vec![String::from("MKRUSDT")]); - value_wrapper.push(vec![String::from("OPUSDT")]); - - symbol_vec.push(String::from("BTCUSDT")); - symbol_vec.push(String::from("ETHUSDT")); - symbol_vec.push(String::from("XRPUSDT")); - symbol_vec.push(String::from("DOGEUSDT")); - symbol_vec.push(String::from("LTCUSDT")); - symbol_vec.push(String::from("TRXUSDT")); - symbol_vec.push(String::from("DOTUSDT")); - symbol_vec.push(String::from("LINKUSDT")); - symbol_vec.push(String::from("AVAXUSDT")); - symbol_vec.push(String::from("BCHUSDT")); - symbol_vec.push(String::from("SHIBUSDT")); - symbol_vec.push(String::from("APTUSDT")); - symbol_vec.push(String::from("ARBUSDT")); - symbol_vec.push(String::from("ETCUSDT")); - symbol_vec.push(String::from("XMRUSDT")); - symbol_vec.push(String::from("HBARUSDT")); - symbol_vec.push(String::from("UNIUSDT")); - symbol_vec.push(String::from("XLMUSDT")); - symbol_vec.push(String::from("VETUSDT")); - symbol_vec.push(String::from("QNTUSDT")); - symbol_vec.push(String::from("GRTUSDT")); - symbol_vec.push(String::from("AAVEUSDT")); - symbol_vec.push(String::from("EGLDUSDT")); - symbol_vec.push(String::from("LDOUSDT")); - symbol_vec.push(String::from("STXUSDT")); - symbol_vec.push(String::from("MKRUSDT")); - symbol_vec.push(String::from("OPUSDT")); - - *valid_usdt_trade_vec = symbol_vec; - delete_all_rows(&table_name).await?; - insert_records(&table_name, &columns, &value_wrapper).await?; - } - - // println!("valid USDT trades 완료"); + // } Ok(()) }