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

Keep transaction time information

Browse Source
This commit is contained in:
Sik Yoon 2024-02-25 02:42:15 +09:00
parent 50ccd6e8a8
commit 6c32e12cab
1 changed files with 3 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/coex/order_team.rs
View File

@ -703,7 +703,6 @@ pub async fn limit_order_sell(
]; ];
let mut insert_values: Vec<Vec<String>> = Vec::new(); let mut insert_values: Vec<Vec<String>> = Vec::new();
let mut insert_value_container: Vec<String> = Vec::new(); let mut insert_value_container: Vec<String> = Vec::new();
let server_epoch = get_server_epoch().await;
unsafe { unsafe {
if RUNNING_MODE == SIMUL && buy_ordered_coin.status == "SIMUL" { if RUNNING_MODE == SIMUL && buy_ordered_coin.status == "SIMUL" {
if exchange_info_map.contains_key(&buy_ordered_coin.symbol) && trade_fee_map.contains_key(&buy_ordered_coin.symbol) { if exchange_info_map.contains_key(&buy_ordered_coin.symbol) && trade_fee_map.contains_key(&buy_ordered_coin.symbol) {
@ -718,7 +717,7 @@ pub async fn limit_order_sell(
insert_value_container.push(buy_ordered_coin.symbol.to_string()); // symbol insert_value_container.push(buy_ordered_coin.symbol.to_string()); // symbol
insert_value_container.push(0.to_string()); // buy_order_id insert_value_container.push(0.to_string()); // buy_order_id
insert_value_container.push(0.to_string()); // sell_order_id insert_value_container.push(0.to_string()); // sell_order_id
insert_value_container.push(server_epoch.to_string()); // transact_time insert_value_container.push(buy_ordered_coin.transact_time.to_string()); // transact_time
insert_value_container.push(buy_ordered_coin.close_time.to_string()); // close_time insert_value_container.push(buy_ordered_coin.close_time.to_string()); // close_time
insert_value_container.push(String::from("SIMUL")); // status insert_value_container.push(String::from("SIMUL")); // status
insert_value_container.push(buy_ordered_coin.used_usdt.to_string()); // used_usdt insert_value_container.push(buy_ordered_coin.used_usdt.to_string()); // used_usdt
@ -806,7 +805,7 @@ pub async fn limit_order_sell(
insert_value_container.push(buy_ordered_coin.order_id.to_string()); // buy_order_id insert_value_container.push(buy_ordered_coin.order_id.to_string()); // buy_order_id
insert_value_container insert_value_container
.push(T.get("orderId").unwrap().as_u64().unwrap().to_string()); // sell_order_id .push(T.get("orderId").unwrap().as_u64().unwrap().to_string()); // sell_order_id
insert_value_container.push(server_epoch.to_string()); // transact_time insert_value_container.push(buy_ordered_coin.transact_time.to_string()); // transact_time
insert_value_container.push(buy_ordered_coin.close_time.to_string()); // close_time insert_value_container.push(buy_ordered_coin.close_time.to_string()); // close_time
insert_value_container insert_value_container
.push(T.get("status").unwrap().as_str().unwrap().to_string()); // status .push(T.get("status").unwrap().as_str().unwrap().to_string()); // status
@ -1461,10 +1460,9 @@ pub async fn cancel_sell_order(
decimal_mul(rest_base_qty, decimal_sub(dec!(1), trade_fee)); decimal_mul(rest_base_qty, decimal_sub(dec!(1), trade_fee));
let mut insert_values: Vec<Vec<String>> = Vec::new(); let mut insert_values: Vec<Vec<String>> = Vec::new();
let mut insert_value_container: Vec<String> = Vec::new(); let mut insert_value_container: Vec<String> = Vec::new();
let server_epoch = get_server_epoch().await;
insert_value_container.push(order.symbol.clone()); // symbol insert_value_container.push(order.symbol.clone()); // symbol
insert_value_container.push(order.buy_order_id.to_string()); // order_id insert_value_container.push(order.buy_order_id.to_string()); // order_id
insert_value_container.push(server_epoch.to_string()); // transact_time insert_value_container.push(order.transact_time.to_string()); // transact_time
insert_value_container.push(order.close_time.to_string()); // close_time insert_value_container.push(order.close_time.to_string()); // close_time
insert_value_container.push(String::from("FILLED")); // status insert_value_container.push(String::from("FILLED")); // status
insert_value_container.push(rest_used_usdt.to_string()); // used_usdt insert_value_container.push(rest_used_usdt.to_string()); // used_usdt