From 6bec61cb2fc393988c9414725a9898c8c7888efc Mon Sep 17 00:00:00 2001 From: Sik Yoon Date: Mon, 20 May 2024 22:22:02 +0900 Subject: [PATCH] Change timeout --- src/future/order.rs | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) diff --git a/src/future/order.rs b/src/future/order.rs index 244f03a..d10d6e2 100644 --- a/src/future/order.rs +++ b/src/future/order.rs @@ -54,7 +54,8 @@ pub async fn entry_position( for element in &listup_positions { available_usdt = get_future_available_usdt().await?; unit_trade_usdt = get_unit_trade_usdt().await; - if !available_usdt.is_zero() && !unit_trade_usdt.is_zero() && available_usdt >= unit_trade_usdt && futures_exchange_info_map.contains_key(&element.symbol) && price_map.get(&element.symbol).is_some() { + if !available_usdt.is_zero() && !unit_trade_usdt.is_zero() && available_usdt >= unit_trade_usdt && futures_exchange_info_map.contains_key(&element.symbol) && price_map.get(&element.symbol).is_some() + && server_epoch - element.registered_server_epoch < 10_000 { let futures_exchange_info = futures_exchange_info_map.get(&element.symbol).unwrap(); let lot_step_size = futures_exchange_info.stepsize; let tick_size = futures_exchange_info.ticksize; @@ -296,11 +297,11 @@ pub async fn monitoring_unfilled_order( let server_epoch = get_server_epoch().await; let orders_outdated = open_positioning_orders .iter() - .filter(|&element| server_epoch - element.transact_time >= 30_000) + .filter(|&element| server_epoch - element.transact_time >= 60_000) .collect::>(); // wait up to 60 secs let orders_to_be_queried = open_positioning_orders .iter() - .filter(|&element| server_epoch - element.transact_time < 30_000) + .filter(|&element| server_epoch - element.transact_time < 60_000) .collect::>(); // cancel orders outdated over 3mins and delete the records in [buy_ordered_coin_list] @@ -987,7 +988,7 @@ async fn select_open_positioning_orders() -> Vec { let select_table_name = String::from("future_ordered_coin_list"); let select_columns = String::from("*"); let select_condition = Some(String::from( - "WHERE order_type = 'POSITIONING' AND (status = 'NEW' OR status = 'PARTIALLY_FILLED')", + "WHERE order_type = 'POSITIONING' AND (status = 'LISTUP' OR status = 'NEW' OR status = 'PARTIALLY_FILLED')", )); let data_struct = PositionCoinList::new(); let select_result = try_select_record(