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

bugfixing

Browse Source
This commit is contained in:
MuslemRahimi 2024-07-22 17:51:19 +02:00
parent 95cc145ea5
commit 39c1e93572
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
app/cron_market_movers.py
View File

@ -129,6 +129,7 @@ async def get_gainer_loser_active_stocks():
active_json = [{k: v for k, v in stock.items() if stock['symbol'] in symbols} for stock in active_json] active_json = [{k: v for k, v in stock.items() if stock['symbol'] in symbols} for stock in active_json]
active_json = [entry for entry in active_json if entry] active_json = [entry for entry in active_json if entry]
filtered_active_json = []
for entry in active_json: for entry in active_json:
try: try:
symbol = entry['symbol'] symbol = entry['symbol']
@ -137,11 +138,12 @@ 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)
except: except:
entry['marketCap'] = None entry['marketCap'] = None
entry['volume'] = None entry['volume'] = None
active_json = sorted(active_json, key=lambda x: (x['marketCap'] >= 10**9, x['volume']), reverse=True) active_json = sorted(filtered_active_json, key=lambda x: (x['marketCap'] >= 10**9, x['volume']), reverse=True)
stocks = gainer_json[:20] + loser_json[:20] + active_json[:20] stocks = gainer_json[:20] + loser_json[:20] + active_json[:20]