diff --git a/app/cron_borrowed_share.py b/app/cron_borrowed_share.py index badaf5f..8fe488d 100644 --- a/app/cron_borrowed_share.py +++ b/app/cron_borrowed_share.py @@ -65,7 +65,7 @@ async def run(): for i in tqdm(range(0, len(tasks), batch_size)): batch = tasks[i:i + batch_size] await asyncio.gather(*batch) - await asyncio.sleep(5) + await asyncio.sleep(30) if __name__ == "__main__": try: diff --git a/app/restart_json.py b/app/restart_json.py index ded4a5e..3a828f4 100755 --- a/app/restart_json.py +++ b/app/restart_json.py @@ -150,6 +150,14 @@ def get_financial_statements(item, symbol): item['freeCashFlowYield'] = (item['freeCashFlow'] / item['marketCap']) * 100 except: item['freeCashFlowYield'] = None + try: + item['revenuePerEmployee'] = round((item['revenue'] / item['employees']),2) + except: + item['revenuePerEmployee'] = None + try: + item['profitPerEmployee'] = round((item['netIncome'] / item['employees']),2) + except: + item['profitPerEmployee'] = None return item @@ -220,6 +228,15 @@ async def get_stock_screener(con): if symbol in stocks_data_map: item['price'], item['changesPercentage'] = stocks_data_map[symbol] + try: + with open(f"json/stockdeck/{symbol}.json", 'r') as file: + res = orjson.loads(file.read())[0] + item['employees'] = int(res['fullTimeEmployees']) + item['sharesOutStanding'] = int(res['sharesOutstanding']) + except: + item['employees'] = None + item['sharesOutStanding'] = None + #Financial Statements item.update(get_financial_statements(item, symbol))