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

bugfixing screener

Browse Source
This commit is contained in:
MuslemRahimi 2025-02-27 11:32:33 +01:00
parent 70bf868ad9
commit e44a160b3e
1 changed files with 54 additions and 38 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

84
app/restart_json.py
View File

@ -67,19 +67,22 @@ def calculate_price_changes(symbol, item, con):
try: try:
# Loop through each time frame to calculate the change # Loop through each time frame to calculate the change
for name, date in time_frames.items(): for name, date in time_frames.items():
item[name] = None # Initialize to None try:
item[name] = None # Initialize to None
query = query_price.format(symbol=symbol) query = query_price.format(symbol=symbol)
data = pd.read_sql_query(query, con, params=(date,)) data = pd.read_sql_query(query, con, params=(date,))
# Check if data was retrieved and calculate the percentage change # Check if data was retrieved and calculate the percentage change
if not data.empty: if not data.empty:
past_price = data.iloc[0]['close'] past_price = data.iloc[0]['close']
current_price = item['price'] current_price = item['price']
change = round(((current_price - past_price) / past_price) * 100, 2) change = round(((current_price - past_price) / past_price) * 100, 2)
# Set item[name] to None if the change is -100 # Set item[name] to None if the change is -100
item[name] = None if change == -100 else change item[name] = None if change == -100 else change
except:
item[name] = None
except: except:
# Handle exceptions by setting all fields to None # Handle exceptions by setting all fields to None
@ -167,15 +170,18 @@ def count_consecutive_growth_years(financial_data, key_element):
prev_val = None prev_val = None
for data in financial_data: for data in financial_data:
current_val = data[key_element] #e.g. revenue try:
current_val = data[key_element] #e.g. revenue
if current_val is not None: if current_val is not None:
if prev_val is not None: if prev_val is not None:
if current_val > prev_val: if current_val > prev_val:
consecutive_years += 1 consecutive_years += 1
else: else:
consecutive_years = 0 consecutive_years = 0
prev_val = current_val prev_val = current_val
except:
pass
# Check one last time in case the streak continues to the end # Check one last time in case the streak continues to the end
@ -528,7 +534,10 @@ def get_financial_statements(item, symbol):
# Process each financial statement # Process each financial statement
for file_path, key_list in statements: for file_path, key_list in statements:
item.update(check_and_process(file_path, key_list)) try:
item.update(check_and_process(file_path, key_list))
except:
pass
try: try:
item['freeCashFlowMargin'] = round((item['freeCashFlow'] / item['revenue']) * 100,2) item['freeCashFlowMargin'] = round((item['freeCashFlow'] / item['revenue']) * 100,2)
@ -675,7 +684,7 @@ async def get_stock_screener(con):
# Iterate through stock_screener_data and update 'price' and 'changesPercentage' if symbols match # Iterate through stock_screener_data and update 'price' and 'changesPercentage' if symbols match
#test mode #test mode
#filtered_data = [item for item in stock_screener_data if item['symbol'] == 'AMD'] #filtered_data = [item for item in stock_screener_data if item['symbol'] == 'MCD']
for item in tqdm(stock_screener_data): for item in tqdm(stock_screener_data):
symbol = item['symbol'] symbol = item['symbol']
@ -747,13 +756,14 @@ async def get_stock_screener(con):
# Ensure there are enough elements in the list # Ensure there are enough elements in the list
if len(res) >= 5: if len(res) >= 5:
latest_revenue = int(res[0].get('revenue', 0)) latest_revenue = int(res[0].get('revenue', 0) or 0)
revenue_3_years_ago = int(res[2].get('revenue', 0)) revenue_3_years_ago = int(res[2].get('revenue', 0) or 0)
revenue_5_years_ago = int(res[4].get('revenue', 0)) revenue_5_years_ago = int(res[4].get('revenue', 0) or 0)
latest_eps = int(res[0].get('eps', 0) or 0)
eps_3_years_ago = int(res[2].get('eps', 0) or 0) # eps 3 years ago
eps_5_years_ago = int(res[4].get('eps', 0) or 0) # eps 5 years ago
latest_eps = int(res[0].get('eps', 0))
eps_3_years_ago = int(res[2].get('eps', 0)) # eps 3 years ago
eps_5_years_ago = int(res[4].get('eps', 0)) # eps 5 years ago
item['cagr3YearRevenue'] = calculate_cagr(revenue_3_years_ago, latest_revenue, 3) item['cagr3YearRevenue'] = calculate_cagr(revenue_3_years_ago, latest_revenue, 3)
item['cagr5YearRevenue'] = calculate_cagr(revenue_5_years_ago, latest_revenue, 5) item['cagr5YearRevenue'] = calculate_cagr(revenue_5_years_ago, latest_revenue, 5)
@ -771,12 +781,14 @@ async def get_stock_screener(con):
item['cagr3YearEPS'] = None item['cagr3YearEPS'] = None
item['cagr5YearEPS'] = None item['cagr5YearEPS'] = None
try: try:
with open(f"json/var/{symbol}.json", 'r') as file: with open(f"json/var/{symbol}.json", 'r') as file:
item['var'] = orjson.loads(file.read())['history'][-1]['var'] item['var'] = orjson.loads(file.read())['history'][-1]['var']
except: except:
item['var'] = None item['var'] = None
try: try:
with open(f"json/enterprise-values/{symbol}.json", 'r') as file: with open(f"json/enterprise-values/{symbol}.json", 'r') as file:
ev = orjson.loads(file.read())[-1]['enterpriseValue'] ev = orjson.loads(file.read())[-1]['enterpriseValue']
@ -794,14 +806,15 @@ async def get_stock_screener(con):
item['evEBIT'] = None item['evEBIT'] = None
item['evFCF'] = None item['evFCF'] = None
try: try:
with open(f"json/analyst/summary/{symbol}.json", 'r') as file: with open(f"json/analyst/summary/all_analyst/{symbol}.json", 'r') as file:
res = orjson.loads(file.read()) res = orjson.loads(file.read())
item['analystRating'] = res['consensusRating'] item['analystRating'] = res['consensusRating']
item['analystCounter'] = res['numOfAnalyst'] item['analystCounter'] = res['numOfAnalyst']
item['priceTarget'] = res['medianPriceTarget'] item['priceTarget'] = res['medianPriceTarget']
item['upside'] = round((item['priceTarget']/item['price']-1)*100, 1) if item['price'] else None item['upside'] = round((item['priceTarget']/item['price']-1)*100, 1) if item['price'] else None
except Exception as e: except:
item['analystRating'] = None item['analystRating'] = None
item['analystCounter'] = None item['analystCounter'] = None
item['priceTarget'] = None item['priceTarget'] = None
@ -829,7 +842,7 @@ async def get_stock_screener(con):
res = orjson.loads(file.read())[-1] res = orjson.loads(file.read())[-1]
item['failToDeliver'] = res['failToDeliver'] item['failToDeliver'] = res['failToDeliver']
item['relativeFTD'] = round((item['failToDeliver']/item['avgVolume'] )*100,2) item['relativeFTD'] = round((item['failToDeliver']/item['avgVolume'] )*100,2)
except Exception as e: except:
item['failToDeliver'] = None item['failToDeliver'] = None
item['relativeFTD'] = None item['relativeFTD'] = None
@ -840,7 +853,7 @@ async def get_stock_screener(con):
item['institutionalOwnership'] = 99.99 item['institutionalOwnership'] = 99.99
else: else:
item['institutionalOwnership'] = round(res['ownershipPercent'],2) item['institutionalOwnership'] = round(res['ownershipPercent'],2)
except Exception as e: except:
item['institutionalOwnership'] = None item['institutionalOwnership'] = None
try: try:
@ -1002,10 +1015,13 @@ async def get_stock_screener(con):
for item in stock_screener_data: for item in stock_screener_data:
for key, value in item.items(): for key, value in item.items():
if isinstance(value, float): try:
if math.isnan(value) or math.isinf(value): if isinstance(value, float):
item[key] = None if math.isnan(value) or math.isinf(value):
print(key) item[key] = None
print(key)
except:
pass
return stock_screener_data return stock_screener_data