Commit 2e5adf52 authored by pengxiong's avatar pengxiong

fix

parent c8f4412b
import datetime
from celery import Celery from celery import Celery
from sqlalchemy import and_, or_ from sqlalchemy import and_, or_
...@@ -27,6 +29,7 @@ def save_pdf(id, ifa_id, customer_id, pdf_name, type, report_data): ...@@ -27,6 +29,7 @@ def save_pdf(id, ifa_id, customer_id, pdf_name, type, report_data):
pass pass
with TAMP_SQL(tamp_diagnose_app_engine) as tamp_diagnose_app: with TAMP_SQL(tamp_diagnose_app_engine) as tamp_diagnose_app:
tamp_diagnose_session = tamp_diagnose_app.session tamp_diagnose_session = tamp_diagnose_app.session
res = None
if type == 1: if type == 1:
res = tamp_diagnose_session.query(HoldReport).filter(and_( res = tamp_diagnose_session.query(HoldReport).filter(and_(
HoldReport.id == id, HoldReport.id == id,
...@@ -44,12 +47,14 @@ def save_pdf(id, ifa_id, customer_id, pdf_name, type, report_data): ...@@ -44,12 +47,14 @@ def save_pdf(id, ifa_id, customer_id, pdf_name, type, report_data):
)) ))
else: else:
return False return False
if res.all():
res.update({ res.update({
'file': pdf_name, 'file': pdf_name,
'update_status': 2, 'update_status': 2,
'update_time': datetime.datetime.now() 'update_time': datetime.datetime.now()
}) })
return True return True
...@@ -208,7 +208,7 @@ def make_report(args): ...@@ -208,7 +208,7 @@ def make_report(args):
record_id = report_record.id record_id = report_record.id
save_pdf.delay(record_id, ifa_id, customer_id, pdf_name, type, report_data) save_pdf.delay(record_id, ifa_id, customer_id, pdf_name, type, report_data)
return True return {'record_id': record_id}
# pid = os.fork() # pid = os.fork()
# if pid == 0: # if pid == 0:
# try: # try:
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment