update

web/robo_controller.py

@@ -9,7 +9,7 @@ from apscheduler.schedulers.asyncio import AsyncIOScheduler
 from apscheduler.triggers.date import DateTrigger
 from empyrical import sharpe_ratio, annual_volatility
 from fastapi import FastAPI, Request
-from py_jftech import prev_workday, filter_weekend, autowired, next_workday
+from py_jftech import prev_workday, filter_weekend, autowired, next_workday, sendmail, format_date, get_config
 from starlette.responses import JSONResponse
 
 import main
@@ -23,6 +23,16 @@ REC_GID = 'E3886FBA-123B-7890-123E-123456BEEED'
 fund_infos, cp, roi, risk = None, None, None, None
 
 
+def send_email():
+    email = get_config('reports.exports.real-daily.email')
+    receives = email['receives']
+    copies = email['copies'] if 'copies' in email and email['copies'] is not None else []
+    recommends = recommend()
+    subject = email['subject'].format(today=format_date(dt.today()))
+    content = json.dumps(recommends)
+    sendmail(receives=receives, copies=copies, subject=subject, content=content)
+
+
 def get_today_rec():
     from portfolios.dao import robo_mpt_portfolios as rmp
     from api import PortfoliosType, PortfoliosRisk
@@ -105,6 +115,7 @@ async def startup_event():
         scheduler.add_job(main.start, trigger=DateTrigger(run_date=current_time))
     # 开启定时任务，执行实盘
     scheduler.add_job(main.start, 'cron', day_of_week='0-4', hour=10, minute=00)
+    scheduler.add_job(send_email, 'cron', day_of_week='0-4', hour=10, minute=5)
     scheduler.start()