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-09-10 08:06:05 +02:00
parent badae04653
commit b6682f65b7
1 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
app/cron_dashboard.py
View File

@ -5,7 +5,6 @@ import sqlite3
import pandas as pd import pandas as pd
import asyncio import asyncio
import pytz import pytz
import time
import os import os
from dotenv import load_dotenv from dotenv import load_dotenv
from datetime import datetime, timedelta, date from datetime import datetime, timedelta, date
@ -108,15 +107,17 @@ async def get_upcoming_earnings(session):
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]":tomorrow,"parameters[date_to]":tomorrow,"parameters[date_sort]":"date"} querystring = {"token": benzinga_api_key_extra,"parameters[importance]":importance,"parameters[date_from]":today,"parameters[date_to]":tomorrow,"parameters[date_sort]":"date"}
try: try:
async with session.get(url, params=querystring, headers=headers) as response: async with session.get(url, params=querystring, headers=headers) as response:
res = ujson.loads(await response.text())['earnings'] res = ujson.loads(await response.text())['earnings']
res = [e for e in res if datetime.strptime(e['date'], "%Y-%m-%d").date() != date.today() or datetime.strptime(e['time'], "%H:%M:%S").time() >= datetime.strptime("16:00:00", "%H:%M:%S").time()]
for item in res: for item in res:
try: try:
symbol = item['ticker'] symbol = item['ticker']
name = item['name'] name = item['name']
time = item['time'] time = item['time']
is_today = True if item['date'] == datetime.today().strftime('%Y-%m-%d') else False
eps_prior = float(item['eps_prior']) if item['eps_prior'] != '' else 0 eps_prior = float(item['eps_prior']) if item['eps_prior'] != '' else 0
eps_est = float(item['eps_est']) if item['eps_est'] != '' else 0 eps_est = float(item['eps_est']) if item['eps_est'] != '' else 0
revenue_est = float(item['revenue_est']) if item['revenue_est'] != '' else 0 revenue_est = float(item['revenue_est']) if item['revenue_est'] != '' else 0
@ -128,6 +129,7 @@ async def get_upcoming_earnings(session):
'symbol': symbol, 'symbol': symbol,
'name': name, 'name': name,
'time': time, 'time': time,
'isToday': is_today,
'marketCap': market_cap, 'marketCap': market_cap,
'epsPrior':eps_prior, 'epsPrior':eps_prior,
'epsEst': eps_est, 'epsEst': eps_est,
@ -140,6 +142,7 @@ 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