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

Update filtering

Browse Source
This commit is contained in:
Sik Yoon 2024-06-01 13:23:44 +09:00
parent 83017ea8e3
commit e3479e346a
2 changed files with 28 additions and 28 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
src/strategy_team/future_strategy_long.rs
View File

@ -33,24 +33,24 @@ pub async fn list_up_for_buy(
// sma3_close(current) > sma3_open (current), sma3_close(prev) < sma3_open (prev) // sma3_close(current) > sma3_open (current), sma3_close(prev) < sma3_open (prev)
let mut keys_to_remove: HashSet<String> = HashSet::new(); let mut keys_to_remove: HashSet<String> = HashSet::new();
let ema30 = ema(30, &alldata.rt_price_1m_vec, &filtered_data).await?; let dema15 = dema(15, &alldata.rt_price_1m_vec, &filtered_data).await?;
let ema100 = ema(100, &alldata.rt_price_1m_vec, &filtered_data).await?; let dema100 = dema(100, &alldata.rt_price_1m_vec, &filtered_data).await?;
let server_epoch = get_server_epoch().await; let server_epoch = get_server_epoch().await;
for (symbol, values) in &mut filtered_data { for (symbol, values) in &mut filtered_data {
let mut do_buy = false; let mut do_buy = false;
let price_and_closetime = get_current_price_decimal(&symbol, &alldata.rt_price_1m_vec).await; let price_and_closetime = get_current_price_decimal(&symbol, &alldata.rt_price_1m_vec).await;
if let (Some(ema30_vec), Some(ema100_vec), Some(current_info)) = (ema30.get(symbol), ema100.get(symbol), price_and_closetime) { if let (Some(dema15_vec), Some(dema100_vec), Some(current_info)) = (dema15.get(symbol), dema100.get(symbol), price_and_closetime) {
if ema30_vec.len() > 10 if dema15_vec.len() > 10
&& ema100_vec.len() > 10 && dema100_vec.len() > 10
&& ema30_vec.last().unwrap().close_time > server_epoch && dema15_vec.last().unwrap().close_time > server_epoch
&& ema30_vec.last().unwrap().close_time == ema100_vec.last().unwrap().close_time && dema15_vec.last().unwrap().close_time == dema100_vec.last().unwrap().close_time
{ {
if ema30_vec.last().unwrap().ema_value > ema100_vec.last().unwrap().ema_value if dema15_vec.last().unwrap().dema_value > dema100_vec.last().unwrap().dema_value
&& ema30_vec[ema30_vec.len()-1].ema_value - ema100_vec[ema100_vec.len()-1].ema_value > ema30_vec[ema30_vec.len()-2].ema_value - ema100_vec[ema100_vec.len()-2].ema_value && dema15_vec[dema15_vec.len()-1].dema_value - dema100_vec[dema100_vec.len()-1].dema_value > dema15_vec[dema15_vec.len()-2].dema_value - dema100_vec[dema100_vec.len()-2].dema_value
&& ema30_vec[ema30_vec.len()-2].ema_value - ema100_vec[ema100_vec.len()-2].ema_value > ema30_vec[ema30_vec.len()-3].ema_value - ema100_vec[ema100_vec.len()-3].ema_value && dema15_vec[dema15_vec.len()-2].dema_value - dema100_vec[dema100_vec.len()-2].dema_value > dema15_vec[dema15_vec.len()-3].dema_value - dema100_vec[dema100_vec.len()-3].dema_value
&& ema30_vec[ema30_vec.len()-3].ema_value - ema100_vec[ema100_vec.len()-3].ema_value > ema30_vec[ema30_vec.len()-4].ema_value - ema100_vec[ema100_vec.len()-4].ema_value && dema15_vec[dema15_vec.len()-3].dema_value - dema100_vec[dema100_vec.len()-3].dema_value > dema15_vec[dema15_vec.len()-4].dema_value - dema100_vec[dema100_vec.len()-4].dema_value
&& ema30_vec[ema30_vec.len()-4].ema_value - ema100_vec[ema100_vec.len()-4].ema_value > ema30_vec[ema30_vec.len()-5].ema_value - ema100_vec[ema100_vec.len()-5].ema_value && dema15_vec[dema15_vec.len()-4].dema_value - dema100_vec[dema100_vec.len()-4].dema_value > dema15_vec[dema15_vec.len()-5].dema_value - dema100_vec[dema100_vec.len()-5].dema_value
&& ema30_vec[ema30_vec.len()-5].ema_value - ema100_vec[ema100_vec.len()-5].ema_value > ema30_vec[ema30_vec.len()-6].ema_value - ema100_vec[ema100_vec.len()-6].ema_value && dema15_vec[dema15_vec.len()-5].dema_value - dema100_vec[dema100_vec.len()-5].dema_value > dema15_vec[dema15_vec.len()-6].dema_value - dema100_vec[dema100_vec.len()-6].dema_value
{ {
values.current_price = current_info.0; values.current_price = current_info.0;
values.closetime = current_info.1; values.closetime = current_info.1;
@ -355,7 +355,7 @@ pub async fn list_up_for_sell(all_data: &AllData, futures_exchange_info_map: &Ha
is_sell = true; is_sell = true;
} else if supertrend_1m_map.get(&element.symbol).is_some_and(|a| a.len() > 10 && a.last().is_some_and(|b| b.close_time > server_epoch && b.area == SuperTrendArea::DOWN)) { } else if supertrend_1m_map.get(&element.symbol).is_some_and(|a| a.len() > 10 && a.last().is_some_and(|b| b.close_time > server_epoch && b.area == SuperTrendArea::DOWN)) {
is_sell = true; is_sell = true;
} else if adx_vec.get(&element.symbol).is_some_and(|a| a.len() > 10 && a.last().is_some_and(|b| b.close_time > server_epoch && b.adx < 20.0)) { } else if server_epoch - element.close_time > 300_000 && adx_vec.get(&element.symbol).is_some_and(|a| a.len() > 10 && a.last().is_some_and(|b| b.close_time > server_epoch && b.adx < 20.0)) {
is_sell = true; is_sell = true;
} }

28
src/strategy_team/future_strategy_short.rs
View File

@ -33,24 +33,24 @@ pub async fn list_up_for_buy(
// sma3_close(current) > sma3_open (current), sma3_close(prev) < sma3_open (prev) // sma3_close(current) > sma3_open (current), sma3_close(prev) < sma3_open (prev)
let mut keys_to_remove: HashSet<String> = HashSet::new(); let mut keys_to_remove: HashSet<String> = HashSet::new();
let ema30 = ema(30, &alldata.rt_price_1m_vec, &filtered_data).await?; let dema15 = dema(15, &alldata.rt_price_1m_vec, &filtered_data).await?;
let ema100 = ema(100, &alldata.rt_price_1m_vec, &filtered_data).await?; let dema100 = dema(100, &alldata.rt_price_1m_vec, &filtered_data).await?;
let server_epoch = get_server_epoch().await; let server_epoch = get_server_epoch().await;
for (symbol, values) in &mut filtered_data { for (symbol, values) in &mut filtered_data {
let mut do_buy = false; let mut do_buy = false;
let price_and_closetime = get_current_price_decimal(&symbol, &alldata.rt_price_1m_vec).await; let price_and_closetime = get_current_price_decimal(&symbol, &alldata.rt_price_1m_vec).await;
if let (Some(ema30_vec), Some(ema100_vec), Some(current_info)) = (ema30.get(symbol), ema100.get(symbol), price_and_closetime) { if let (Some(dema15_vec), Some(dema100_vec), Some(current_info)) = (dema15.get(symbol), dema100.get(symbol), price_and_closetime) {
if ema30_vec.len() > 20 if dema15_vec.len() > 20
&& ema100_vec.len() > 20 && dema100_vec.len() > 20
&& ema30_vec.last().unwrap().close_time > server_epoch && dema15_vec.last().unwrap().close_time > server_epoch
&& ema30_vec.last().unwrap().close_time == ema100_vec.last().unwrap().close_time && dema15_vec.last().unwrap().close_time == dema100_vec.last().unwrap().close_time
{ {
if ema30_vec.last().unwrap().ema_value < ema100_vec.last().unwrap().ema_value if dema15_vec.last().unwrap().dema_value < dema100_vec.last().unwrap().dema_value
&& (ema30_vec[ema30_vec.len()-1].ema_value - ema100_vec[ema100_vec.len()-1].ema_value).abs() < (ema30_vec[ema30_vec.len()-2].ema_value - ema100_vec[ema100_vec.len()-2].ema_value).abs() && (dema15_vec[dema15_vec.len()-1].dema_value - dema100_vec[dema100_vec.len()-1].dema_value).abs() < (dema15_vec[dema15_vec.len()-2].dema_value - dema100_vec[dema100_vec.len()-2].dema_value).abs()
&& (ema30_vec[ema30_vec.len()-2].ema_value - ema100_vec[ema100_vec.len()-2].ema_value).abs() < (ema30_vec[ema30_vec.len()-3].ema_value - ema100_vec[ema100_vec.len()-3].ema_value).abs() && (dema15_vec[dema15_vec.len()-2].dema_value - dema100_vec[dema100_vec.len()-2].dema_value).abs() < (dema15_vec[dema15_vec.len()-3].dema_value - dema100_vec[dema100_vec.len()-3].dema_value).abs()
&& (ema30_vec[ema30_vec.len()-3].ema_value - ema100_vec[ema100_vec.len()-3].ema_value).abs() < (ema30_vec[ema30_vec.len()-4].ema_value - ema100_vec[ema100_vec.len()-4].ema_value).abs() && (dema15_vec[dema15_vec.len()-3].dema_value - dema100_vec[dema100_vec.len()-3].dema_value).abs() < (dema15_vec[dema15_vec.len()-4].dema_value - dema100_vec[dema100_vec.len()-4].dema_value).abs()
&& (ema30_vec[ema30_vec.len()-4].ema_value - ema100_vec[ema100_vec.len()-4].ema_value).abs() < (ema30_vec[ema30_vec.len()-5].ema_value - ema100_vec[ema100_vec.len()-5].ema_value).abs() && (dema15_vec[dema15_vec.len()-4].dema_value - dema100_vec[dema100_vec.len()-4].dema_value).abs() < (dema15_vec[dema15_vec.len()-5].dema_value - dema100_vec[dema100_vec.len()-5].dema_value).abs()
&& (ema30_vec[ema30_vec.len()-5].ema_value - ema100_vec[ema100_vec.len()-5].ema_value).abs() < (ema30_vec[ema30_vec.len()-6].ema_value - ema100_vec[ema100_vec.len()-6].ema_value).abs() && (dema15_vec[dema15_vec.len()-5].dema_value - dema100_vec[dema100_vec.len()-5].dema_value).abs() < (dema15_vec[dema15_vec.len()-6].dema_value - dema100_vec[dema100_vec.len()-6].dema_value).abs()
{ {
values.current_price = current_info.0; values.current_price = current_info.0;
values.closetime = current_info.1; values.closetime = current_info.1;
@ -363,7 +363,7 @@ pub async fn list_up_for_sell(all_data: &AllData, futures_exchange_info_map: &Ha
is_sell = true; is_sell = true;
} else if supertrend_1m_map.get(&element.symbol).is_some_and(|a| a.len() > 10 && a.last().is_some_and(|b| b.close_time > server_epoch && b.area == SuperTrendArea::UP)) { } else if supertrend_1m_map.get(&element.symbol).is_some_and(|a| a.len() > 10 && a.last().is_some_and(|b| b.close_time > server_epoch && b.area == SuperTrendArea::UP)) {
is_sell = true; is_sell = true;
} else if adx_vec.get(&element.symbol).is_some_and(|a| a.len() > 10 && a.last().is_some_and(|b| b.close_time > server_epoch && b.adx < 20.0)) { } else if server_epoch - element.close_time > 300_000 && adx_vec.get(&element.symbol).is_some_and(|a| a.len() > 10 && a.last().is_some_and(|b| b.close_time > server_epoch && b.adx < 20.0)) {
is_sell = true; is_sell = true;
} }