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-11-23 21:42:54 +01:00
parent 2333987de1
commit d48aa58bd6
2 changed files with 49 additions and 43 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
app/cron_analyst_db.py
View File

@ -269,6 +269,7 @@ async def get_analyst_ratings(analyst_id, session):
for item in filtered_data: for item in filtered_data:
try: try:
if item.get("rating_prior",None) == "Buy" and item.get("rating_current",None) == "Buy": if item.get("rating_prior",None) == "Buy" and item.get("rating_current",None) == "Buy":
if float(item.get("adjusted_pt_prior", 0)) < float(item.get('adjusted_pt_current', 0)):
item["rating_current"] = "Strong Buy" item["rating_current"] = "Strong Buy"
except: except:
pass pass
@ -427,7 +428,7 @@ async def run():
analyst_list = await get_all_analyst_stats() analyst_list = await get_all_analyst_stats()
print('Number of analysts:', len(analyst_list)) print('Number of analysts:', len(analyst_list))
#Test Mode #Test Modes
#analyst_list = [ item for item in analyst_list if item['analystId'] =='5a02da51efacff00010633d2'] #analyst_list = [ item for item in analyst_list if item['analystId'] =='5a02da51efacff00010633d2']
# Step2: Get rating history for each individual analyst and score the analyst # Step2: Get rating history for each individual analyst and score the analyst

5
app/cron_analyst_ticker.py
View File

@ -221,6 +221,7 @@ def run(chunk, analyst_list, con):
ticker_filtered_data = [item for item in res_list if item['ticker'] == ticker] ticker_filtered_data = [item for item in res_list if item['ticker'] == ticker]
if len(ticker_filtered_data) != 0: if len(ticker_filtered_data) != 0:
for item in ticker_filtered_data: for item in ticker_filtered_data:
try:
if item['rating_current'] == 'Strong Sell' or item['rating_current'] == 'Strong Buy': if item['rating_current'] == 'Strong Sell' or item['rating_current'] == 'Strong Buy':
pass pass
elif item['rating_current'] == 'Accumulate' and item['rating_prior'] == 'Buy': elif item['rating_current'] == 'Accumulate' and item['rating_prior'] == 'Buy':
@ -244,6 +245,8 @@ def run(chunk, analyst_list, con):
item['rating_current'] = 'Buy' item['rating_current'] = 'Buy'
elif item['rating_current'] == 'Buy' and (item['action_company'] == 'Raises' or item['action_pt'] == 'Raises'): elif item['rating_current'] == 'Buy' and (item['action_company'] == 'Raises' or item['action_pt'] == 'Raises'):
item['rating_current'] = 'Strong Buy' item['rating_current'] = 'Strong Buy'
elif item.get("rating_prior",None) == "Buy" and item.get("rating_current",None) == "Buy" and (float(item.get("adjusted_pt_prior", 0)) < float(item.get('adjusted_pt_current', 0))):
item["rating_current"] = "Strong Buy"
elif item['rating_current'] == 'Overweight' and (item['action_company'] == 'Maintains' or item['action_company'] == 'Upgrades' or item['action_company'] == 'Reiterates' or item['action_pt'] == 'Raises'): elif item['rating_current'] == 'Overweight' and (item['action_company'] == 'Maintains' or item['action_company'] == 'Upgrades' or item['action_company'] == 'Reiterates' or item['action_pt'] == 'Raises'):
item['rating_current'] = 'Buy' item['rating_current'] = 'Buy'
elif item['rating_current'] == 'Positive' or item['rating_current'] == 'Sector Outperform': elif item['rating_current'] == 'Positive' or item['rating_current'] == 'Sector Outperform':
@ -263,6 +266,8 @@ def run(chunk, analyst_list, con):
elif item['rating_current'] == 'Peer Perform' and item['action_pt'] == 'Announces': elif item['rating_current'] == 'Peer Perform' and item['action_pt'] == 'Announces':
item['rating_current'] = 'Hold' item['rating_current'] = 'Hold'
item['action_company'] = 'Initiates' item['action_company'] = 'Initiates'
except:
pass
summary = get_summary(ticker_filtered_data) summary = get_summary(ticker_filtered_data)