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

Make closed position moved after wait time

Browse Source
This commit is contained in:
Sik Yoon 2024-06-01 13:14:25 +09:00
parent daf1fc1256
commit 83017ea8e3
1 changed files with 14 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
src/future/table_mgmt.rs
View File

@ -7,6 +7,7 @@ use rust_decimal_macros::dec;
use rust_decimal::prelude::ToPrimitive; use rust_decimal::prelude::ToPrimitive;
use serde_json::Value; use serde_json::Value;
use reqwest::{Client, ClientBuilder}; use reqwest::{Client, ClientBuilder};
use crate::coex::exchange_team::*;
pub async fn get_tradefee_balance(future_trade_fee: &mut FuturesTradeFee, client: &Client) -> Result<(), Box<dyn std::error::Error + Send + Sync>> { pub async fn get_tradefee_balance(future_trade_fee: &mut FuturesTradeFee, client: &Client) -> Result<(), Box<dyn std::error::Error + Send + Sync>> {
// building URL and API-keys // building URL and API-keys
@ -393,8 +394,11 @@ pub async fn move_closed_positions() {
"maximum_profit_percent", "maximum_profit_percent",
]; ];
let server_epoch = get_server_epoch().await;
for element in closed_positions { 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.order_type.to_string(), // order_type
element.status, // status element.status, // status
element.symbol, // symbol element.symbol, // symbol
@ -416,15 +420,15 @@ pub async fn move_closed_positions() {
element.maximum_profit_percent.to_string(), // maximum_profit_percent 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;
}
}
} }
} }