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

update dashboard

Browse Source
This commit is contained in:
MuslemRahimi 2024-09-10 08:26:56 +02:00
parent b6682f65b7
commit 0cc56b934d
1 changed files with 7 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
app/cron_dashboard.py
View File

@ -142,12 +142,12 @@ async def get_upcoming_earnings(session):
res_list = remove_duplicates(res_list) res_list = remove_duplicates(res_list)
res_list.sort(key=lambda x: x['marketCap'], reverse=True) res_list.sort(key=lambda x: x['marketCap'], reverse=True)
res_list = [{k: v for k, v in d.items() if k != 'marketCap'} for d in res_list] res_list = [{k: v for k, v in d.items() if k != 'marketCap'} for d in res_list]
print(res_list)
except Exception as e: except Exception as e:
print(e) print(e)
pass pass
return res_list[0:5] return res_list[:10]
async def get_recent_earnings(session): async def get_recent_earnings(session):
@ -194,11 +194,11 @@ async def get_recent_earnings(session):
#res_list.sort(key=lambda x: x['marketCap'], reverse=True) #res_list.sort(key=lambda x: x['marketCap'], reverse=True)
res_list.sort(key=lambda x: (-parse_time(x['time']).timestamp(), -x['marketCap'])) res_list.sort(key=lambda x: (-parse_time(x['time']).timestamp(), -x['marketCap']))
res_list = [{k: v for k, v in d.items() if k != 'marketCap'} for d in res_list] res_list = [{k: v for k, v in d.items() if k != 'marketCap'} for d in res_list]
return res_list[0:5] return res_list[0:10]
async def get_recent_dividends(session): async def get_recent_dividends(session):
url = "https://api.benzinga.com/api/v2.1/calendar/dividends" url = "https://api.benzinga.com/api/v2.1/calendar/dividends"
importance_list = ["2","3","4","5"] importance_list = ["1","2","3","4","5"]
res_list = [] res_list = []
for importance in importance_list: for importance in importance_list:
querystring = {"token": benzinga_api_key_extra,"parameters[importance]":importance,"parameters[date_from]":yesterday,"parameters[date_to]":today} querystring = {"token": benzinga_api_key_extra,"parameters[importance]":importance,"parameters[date_from]":yesterday,"parameters[date_to]":today}
@ -285,6 +285,9 @@ async def run():
top_sector = await get_top_sector(session) top_sector = await get_top_sector(session)
recent_dividends = await get_recent_dividends(session) recent_dividends = await get_recent_dividends(session)
#Avoid clashing of recent and upcoming earnings
upcoming_earnings = [item for item in upcoming_earnings if item['symbol'] not in [earning['symbol'] for earning in recent_earnings]]
try: try:
with open(f"json/retail-volume/data.json", 'r') as file: with open(f"json/retail-volume/data.json", 'r') as file:
retail_tracker = ujson.load(file)[0:5] retail_tracker = ujson.load(file)[0:5]