Update filtering
This commit is contained in:
parent
a3a61f24c6
commit
33221f253a
|
|
@ -141,23 +141,23 @@ pub async fn list_up_for_buy(
|
||||||
remove_keys(&mut filtered_data, keys_to_remove).await;
|
remove_keys(&mut filtered_data, keys_to_remove).await;
|
||||||
|
|
||||||
// Wiliams -50.0 > %R(100)
|
// Wiliams -50.0 > %R(100)
|
||||||
// let mut keys_to_remove: HashSet<String> = HashSet::new();
|
let mut keys_to_remove: HashSet<String> = HashSet::new();
|
||||||
// let mut wpr100_map = wiliams_percent_r(100, &alldata.rt_price_1m_vec, &filtered_data).await?;
|
let mut wpr100_map = wiliams_percent_r(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;
|
||||||
// if let Some(wpr100_vec) = wpr100_map.get(symbol) {
|
if let Some(wpr100_vec) = wpr100_map.get(symbol) {
|
||||||
// if wpr100_vec.len() > 15
|
if wpr100_vec.len() > 15
|
||||||
// && wpr100_vec.last().unwrap().close_time > server_epoch
|
&& wpr100_vec.last().unwrap().close_time > server_epoch
|
||||||
// && wpr100_vec.last().unwrap().r_value < -50.0 {
|
&& wpr100_vec.last().unwrap().r_value < -50.0 {
|
||||||
// do_buy = true;
|
do_buy = true;
|
||||||
// }
|
}
|
||||||
// }
|
}
|
||||||
// if do_buy == false {
|
if do_buy == false {
|
||||||
// keys_to_remove.insert(symbol.clone());
|
keys_to_remove.insert(symbol.clone());
|
||||||
// }
|
}
|
||||||
// }
|
}
|
||||||
// remove_keys(&mut filtered_data, keys_to_remove).await;
|
remove_keys(&mut filtered_data, keys_to_remove).await;
|
||||||
|
|
||||||
// current Tema(15) > current Tema(30)
|
// current Tema(15) > current Tema(30)
|
||||||
// let mut keys_to_remove: HashSet<String> = HashSet::new();
|
// let mut keys_to_remove: HashSet<String> = HashSet::new();
|
||||||
|
|
@ -349,15 +349,16 @@ pub async fn list_up_for_sell(all_data: &AllData, futures_exchange_info_map: &Ha
|
||||||
.build()
|
.build()
|
||||||
.unwrap();
|
.unwrap();
|
||||||
|
|
||||||
let mut supertrend_vec: Vec<SupertrendData> = Vec::new();
|
|
||||||
let server_epoch = get_server_epoch().await;
|
let server_epoch = get_server_epoch().await;
|
||||||
let mut filtered_symbols: HashMap<String, FilteredDataValue> = HashMap::new();
|
|
||||||
for element in &filled_positions {
|
// let mut supertrend_vec: Vec<SupertrendData> = Vec::new();
|
||||||
filtered_symbols.insert(element.symbol.clone(), FilteredDataValue::new());
|
// let mut filtered_symbols: HashMap<String, FilteredDataValue> = HashMap::new();
|
||||||
}
|
// for element in &filled_positions {
|
||||||
let supertrend_1m_map =
|
// filtered_symbols.insert(element.symbol.clone(), FilteredDataValue::new());
|
||||||
supertrend(30, 2.0, true, &all_data.rt_price_1m_vec, &filtered_symbols).await?;
|
// }
|
||||||
let adx_vec = adx(15, 15, &all_data.rt_price_1m_vec, &filtered_symbols).await?;
|
// let supertrend_1m_map =
|
||||||
|
// supertrend(30, 2.0, true, &all_data.rt_price_1m_vec, &filtered_symbols).await?;
|
||||||
|
// let adx_vec = adx(15, 15, &all_data.rt_price_1m_vec, &filtered_symbols).await?;
|
||||||
for element in filled_positions {
|
for element in filled_positions {
|
||||||
let mut is_sell = false;
|
let mut is_sell = false;
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -141,23 +141,23 @@ pub async fn list_up_for_buy(
|
||||||
remove_keys(&mut filtered_data, keys_to_remove).await;
|
remove_keys(&mut filtered_data, keys_to_remove).await;
|
||||||
|
|
||||||
// Wiliams -50.0 < %R(100)
|
// Wiliams -50.0 < %R(100)
|
||||||
// let mut keys_to_remove: HashSet<String> = HashSet::new();
|
let mut keys_to_remove: HashSet<String> = HashSet::new();
|
||||||
// let mut wpr100_map = wiliams_percent_r(100, &alldata.rt_price_1m_vec, &filtered_data).await?;
|
let mut wpr100_map = wiliams_percent_r(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;
|
||||||
// if let Some(wpr100_vec) = wpr100_map.get(symbol) {
|
if let Some(wpr100_vec) = wpr100_map.get(symbol) {
|
||||||
// if wpr100_vec.len() > 15
|
if wpr100_vec.len() > 15
|
||||||
// && wpr100_vec.last().unwrap().close_time > server_epoch
|
&& wpr100_vec.last().unwrap().close_time > server_epoch
|
||||||
// && wpr100_vec.last().unwrap().r_value > -50.0 {
|
&& wpr100_vec.last().unwrap().r_value > -50.0 {
|
||||||
// do_buy = true;
|
do_buy = true;
|
||||||
// }
|
}
|
||||||
// }
|
}
|
||||||
// if do_buy == false {
|
if do_buy == false {
|
||||||
// keys_to_remove.insert(symbol.clone());
|
keys_to_remove.insert(symbol.clone());
|
||||||
// }
|
}
|
||||||
// }
|
}
|
||||||
// remove_keys(&mut filtered_data, keys_to_remove).await;
|
remove_keys(&mut filtered_data, keys_to_remove).await;
|
||||||
|
|
||||||
// current Tema(15) < current Tema(30)
|
// current Tema(15) < current Tema(30)
|
||||||
// let mut keys_to_remove: HashSet<String> = HashSet::new();
|
// let mut keys_to_remove: HashSet<String> = HashSet::new();
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue
Block a user