修改celery 从配置文件读取地址

app/celery.py

@@ -8,7 +8,7 @@ from app.utils.jinjia2html_v2 import DataIntegrate
 
 celery_app = Celery(__name__)
 
-celery_conf = "redis://:{}@{}:{}/{}".format("qimeng123","118.190.63.109","56379","1")
+celery_conf = "redis://:{}@{}:{}/{}".format(redis_password,redis_host,redis_port,"1")
 celery_app.conf.update({"broker_url": celery_conf, "result_backend": celery_conf})
 
 

app/service/report_service.py

@@ -143,7 +143,7 @@ def edit_report(args):
             'update_time': datetime.datetime.now()
         })
         
-        save_pdf.delay(ifa_id, customer_id, pdf_name, type, report_data)
+        save_pdf.delay(ifa_id, res[0].customer_id, pdf_name, type, report_data)
         # try:
         #     dt = DataIntegrate(ifa_id=ifa_id, customer_id=res[0].customer_id, pdf_name=pdf_name, type=type)
         #     dt.render_data(data=json.loads(report_data.replace(template_folder, temp_img_save_folder)))