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

Add buy and sell of strategy 003

Browse Source
This commit is contained in:
Sik Yoon 2024-01-07 02:54:10 +09:00
parent 959f3022a0
commit 36aba8b864
1 changed files with 55 additions and 22 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

65
src/strategy_team/strategy_manager.rs
View File

@ -33,9 +33,9 @@ pub async fn execute_list_up_for_buy(
all_data: &AllData, all_data: &AllData,
) -> Result<(), Box<dyn std::error::Error + Send + Sync>> { ) -> Result<(), Box<dyn std::error::Error + Send + Sync>> {
let mut task_vec = Vec::new(); let mut task_vec = Vec::new();
// let all_data_c3 = all_data.clone(); let all_data_c3 = all_data.clone();
let all_data_c4 = all_data.clone(); let all_data_c4 = all_data.clone();
let all_data_c5 = all_data.clone(); // let all_data_c5 = all_data.clone();
let all_data_c6 = all_data.clone(); let all_data_c6 = all_data.clone();
// strategist_001(all_data).await?; // strategist_001(all_data).await?;
@ -44,11 +44,14 @@ pub async fn execute_list_up_for_buy(
// crate::strategy_team::strategy_003::list_up_for_buy(all_data_c3).await; // crate::strategy_team::strategy_003::list_up_for_buy(all_data_c3).await;
// })); // }));
task_vec.push(tokio::spawn(async move { task_vec.push(tokio::spawn(async move {
crate::strategy_team::strategy_004::list_up_for_buy(all_data_c4).await; crate::strategy_team::strategy_003::list_up_for_buy(all_data_c3).await;
})); }));
task_vec.push(tokio::spawn(async move { task_vec.push(tokio::spawn(async move {
crate::strategy_team::strategy_005::list_up_for_buy(all_data_c5).await; crate::strategy_team::strategy_004::list_up_for_buy(all_data_c4).await;
})); }));
// task_vec.push(tokio::spawn(async move {
// crate::strategy_team::strategy_005::list_up_for_buy(all_data_c5).await;
// }));
task_vec.push(tokio::spawn(async move { task_vec.push(tokio::spawn(async move {
crate::strategy_team::strategy_006::list_up_for_buy(all_data_c6).await; crate::strategy_team::strategy_006::list_up_for_buy(all_data_c6).await;
})); }));
@ -66,27 +69,57 @@ pub async fn execute_list_up_for_sell(
exchange_info_vec: &Vec<ExchangeInfo>, exchange_info_vec: &Vec<ExchangeInfo>,
trade_fee_vec: &Vec<TradeFee>, trade_fee_vec: &Vec<TradeFee>,
) -> Result<(), Box<dyn std::error::Error + Send + Sync>> { ) -> Result<(), Box<dyn std::error::Error + Send + Sync>> {
let all_data_c3 = all_data.clone();
let all_data_c4 = all_data.clone();
let all_data_c5 = all_data.clone();
let all_data_c6 = all_data.clone();
let exchange_info_vec_c3 = exchange_info_vec.clone();
let exchange_info_vec_c4 = exchange_info_vec.clone();
let exchange_info_vec_c5 = exchange_info_vec.clone();
let exchange_info_vec_c6 = exchange_info_vec.clone();
let trade_fee_vec_c3 = trade_fee_vec.clone();
let trade_fee_vec_c4 = trade_fee_vec.clone();
let trade_fee_vec_c5 = trade_fee_vec.clone();
let trade_fee_vec_c6 = trade_fee_vec.clone();
let mut task_vec = Vec::new();
task_vec.push(tokio::spawn(async move {
crate::strategy_team::strategy_003::list_up_for_sell(
&all_data_c3,
&exchange_info_vec_c3,
&trade_fee_vec_c3,
)
.await;
}));
task_vec.push(tokio::spawn(async move {
crate::strategy_team::strategy_004::list_up_for_sell( crate::strategy_team::strategy_004::list_up_for_sell(
all_data, &all_data_c4,
exchange_info_vec, &exchange_info_vec_c4,
trade_fee_vec, &trade_fee_vec_c4,
) )
.await?; .await;
}));
task_vec.push(tokio::spawn(async move {
crate::strategy_team::strategy_005::list_up_for_sell( crate::strategy_team::strategy_005::list_up_for_sell(
all_data, &all_data_c5,
exchange_info_vec, &exchange_info_vec_c5,
trade_fee_vec, &trade_fee_vec_c5,
) )
.await?; .await;
}));
task_vec.push(tokio::spawn(async move {
crate::strategy_team::strategy_006::list_up_for_sell( crate::strategy_team::strategy_006::list_up_for_sell(
all_data, &all_data_c6,
exchange_info_vec, &exchange_info_vec_c6,
trade_fee_vec, &trade_fee_vec_c6,
) )
.await?; .await;
}));
try_join_all(task_vec).await?;
Ok(()) Ok(())
} }