AmineTMIRI/backend
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

update market movers

Browse Source
This commit is contained in:
MuslemRahimi 2024-10-28 19:00:06 +01:00
parent e3a128de6b
commit ffb9a36ff1
1 changed files with 8 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
app/cron_market_movers.py
View File

@ -140,7 +140,8 @@ async def get_gainer_loser_active_stocks():
volume = pd.read_sql_query(query, con) volume = pd.read_sql_query(query, con)
entry['marketCap'] = int(fundamental_data['marketCap'].iloc[0]) entry['marketCap'] = int(fundamental_data['marketCap'].iloc[0])
entry['volume'] = int(volume['volume'].iloc[0]) entry['volume'] = int(volume['volume'].iloc[0])
if entry['marketCap'] >= market_cap_threshold and entry['volume'] >= volume_threshold: entry['changesPercentage'] = round(entry['changesPercentage'],2)
if entry['marketCap'] >= market_cap_threshold and entry['volume'] >= volume_threshold and abs(entry['changesPercentage']) < 500:
filtered_gainer_json.append(entry) filtered_gainer_json.append(entry)
except: except:
entry['marketCap'] = None entry['marketCap'] = None
@ -156,7 +157,8 @@ async def get_gainer_loser_active_stocks():
volume = pd.read_sql_query(query, con) volume = pd.read_sql_query(query, con)
entry['marketCap'] = int(fundamental_data['marketCap'].iloc[0]) entry['marketCap'] = int(fundamental_data['marketCap'].iloc[0])
entry['volume'] = int(volume['volume'].iloc[0]) entry['volume'] = int(volume['volume'].iloc[0])
if entry['marketCap'] >= market_cap_threshold and entry['volume'] >= volume_threshold: entry['changesPercentage'] = round(entry['changesPercentage'],2)
if entry['marketCap'] >= market_cap_threshold and entry['volume'] >= volume_threshold and abs(entry['changesPercentage']) < 500:
filtered_loser_json.append(entry) filtered_loser_json.append(entry)
except: except:
entry['marketCap'] = None entry['marketCap'] = None
@ -173,7 +175,9 @@ async def get_gainer_loser_active_stocks():
volume = pd.read_sql_query(query, con) volume = pd.read_sql_query(query, con)
entry['marketCap'] = int(fundamental_data['marketCap'].iloc[0]) entry['marketCap'] = int(fundamental_data['marketCap'].iloc[0])
entry['volume'] = int(volume['volume'].iloc[0]) entry['volume'] = int(volume['volume'].iloc[0])
filtered_active_json.append(entry) entry['changesPercentage'] = round(entry['changesPercentage'],2)
if abs(entry['changesPercentage']) < 500:
filtered_active_json.append(entry)
except: except:
entry['marketCap'] = None entry['marketCap'] = None
entry['volume'] = None entry['volume'] = None
@ -194,7 +198,7 @@ async def get_gainer_loser_active_stocks():
SELECT SELECT
gainer,loser,most_active gainer,loser,most_active
FROM FROM
market_movers market_movers
""" """
past_gainer = pd.read_sql_query(query_market_movers, con) past_gainer = pd.read_sql_query(query_market_movers, con)