From 83017ea8e35c8412c95e4a22ebd063ce717c3cc9 Mon Sep 17 00:00:00 2001 From: Sik Yoon Date: Sat, 1 Jun 2024 13:14:25 +0900 Subject: [PATCH] Make closed position moved after wait time --- src/future/table_mgmt.rs | 24 ++++++++++++++---------- 1 file changed, 14 insertions(+), 10 deletions(-) diff --git a/src/future/table_mgmt.rs b/src/future/table_mgmt.rs index a6e2ee0..f2d95b0 100644 --- a/src/future/table_mgmt.rs +++ b/src/future/table_mgmt.rs @@ -7,6 +7,7 @@ use rust_decimal_macros::dec; use rust_decimal::prelude::ToPrimitive; use serde_json::Value; use reqwest::{Client, ClientBuilder}; +use crate::coex::exchange_team::*; pub async fn get_tradefee_balance(future_trade_fee: &mut FuturesTradeFee, client: &Client) -> Result<(), Box> { // building URL and API-keys @@ -393,8 +394,11 @@ pub async fn move_closed_positions() { "maximum_profit_percent", ]; + let server_epoch = get_server_epoch().await; + for element in closed_positions { - let mut insert_values = vec![ + if server_epoch - element.registered_server_epoch > 1_800_000 { + let mut insert_values = vec![ element.order_type.to_string(), // order_type element.status, // status element.symbol, // symbol @@ -416,15 +420,15 @@ pub async fn move_closed_positions() { element.maximum_profit_percent.to_string(), // maximum_profit_percent ]; - insert_one_record(&insert_table_name, &insert_columns, &insert_values).await; + insert_one_record(&insert_table_name, &insert_columns, &insert_values).await; - let mut condition_build = String::from("WHERE id = "); - condition_build.push_str(element.id.to_string().as_str()); - // condition_build.push_str(" AND symbol = \'"); - // condition_build.push_str(element.symbol.as_str()); - // condition_build.push('\''); - delete_record(&delete_table_name, &condition_build).await; - } - + let mut condition_build = String::from("WHERE id = "); + condition_build.push_str(element.id.to_string().as_str()); + // condition_build.push_str(" AND symbol = \'"); + // condition_build.push_str(element.symbol.as_str()); + // condition_build.push('\''); + delete_record(&delete_table_name, &condition_build).await; + } + } } } \ No newline at end of file