轮训任务加上 执行方法

app/utils/timed_task.py

@@ -9,6 +9,7 @@
 from app.api.engine import tamp_user_engine, tamp_order_engine, TAMP_SQL
 from sqlalchemy.ext.declarative import declarative_base
 from sqlalchemy import Column, String, Integer
+from app.utils.jinjia2html import DataIntegrate
 
 Base = declarative_base()
 class IfaUser(Base):
@@ -36,6 +37,10 @@ class Customer(Base):
 
 def call_month_report(ifauser_id, ifauser_name, customer_id, customer_name):
     print('开始制作IFA: {}, 客户: {}的基金月报'.format(ifauser_name, customer_name))
+    try:
+        DataIntegrate(ifauser_id, customer_id, customer_name)
+    except:
+        print("发生异常，下一个走起！")