Sik/tradingbot
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Change timeout

Browse Source
This commit is contained in:
Sik Yoon 2024-05-20 22:22:02 +09:00
parent 30bc530f21
commit 6bec61cb2f
1 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/future/order.rs
View File

@ -54,7 +54,8 @@ pub async fn entry_position(
for element in &listup_positions { for element in &listup_positions {
available_usdt = get_future_available_usdt().await?; available_usdt = get_future_available_usdt().await?;
unit_trade_usdt = get_unit_trade_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 futures_exchange_info = futures_exchange_info_map.get(&element.symbol).unwrap();
let lot_step_size = futures_exchange_info.stepsize; let lot_step_size = futures_exchange_info.stepsize;
let tick_size = futures_exchange_info.ticksize; 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 server_epoch = get_server_epoch().await;
let orders_outdated = open_positioning_orders let orders_outdated = open_positioning_orders
.iter() .iter()
.filter(|&element| server_epoch - element.transact_time >= 30_000) .filter(|&element| server_epoch - element.transact_time >= 60_000)
.collect::<Vec<&PositionCoinList>>(); // wait up to 60 secs .collect::<Vec<&PositionCoinList>>(); // wait up to 60 secs
let orders_to_be_queried = open_positioning_orders let orders_to_be_queried = open_positioning_orders
.iter() .iter()
.filter(|&element| server_epoch - element.transact_time < 30_000) .filter(|&element| server_epoch - element.transact_time < 60_000)
.collect::<Vec<&PositionCoinList>>(); .collect::<Vec<&PositionCoinList>>();
// cancel orders outdated over 3mins and delete the records in [buy_ordered_coin_list] // 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<PositionCoinList> {
let select_table_name = String::from("future_ordered_coin_list"); let select_table_name = String::from("future_ordered_coin_list");
let select_columns = String::from("*"); let select_columns = String::from("*");
let select_condition = Some(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 data_struct = PositionCoinList::new();
let select_result = try_select_record( let select_result = try_select_record(