zy123/zbparse
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

2.18 空的docx无法被识别为非招标文件

Browse Source
This commit is contained in:
zy123 2025-02-18 16:11:53 +08:00
parent a5ca902d55
commit ca816f46de
1 changed files with 2 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
flask_app/routes/货物标解析main.py
View File

@ -11,7 +11,6 @@ from flask_app.货物标.基础信息解析货物标版 import combine_basic_inf
from flask_app.general.投标人须知正文提取指定内容 import extract_from_notice from flask_app.general.投标人须知正文提取指定内容 import extract_from_notice
from flask_app.general.截取pdf_main import truncate_pdf_multiple from flask_app.general.截取pdf_main import truncate_pdf_multiple
from concurrent.futures import as_completed, ProcessPoolExecutor from concurrent.futures import as_completed, ProcessPoolExecutor
import concurrent.futures
from flask_app.general.投标人须知正文条款提取成json文件 import convert_clause_to_json from flask_app.general.投标人须知正文条款提取成json文件 import convert_clause_to_json
from flask_app.general.无效标和废标公共代码 import combine_find_invalid from flask_app.general.无效标和废标公共代码 import combine_find_invalid
from flask_app.货物标.资格审查main import combine_qualification_review from flask_app.货物标.资格审查main import combine_qualification_review
@ -242,7 +241,7 @@ def goods_bid_main(output_folder, file_path, file_type, unique_id):
} }
yield json.dumps(error_response, ensure_ascii=False) yield json.dumps(error_response, ensure_ascii=False)
return # 停止进一步处理 return # 停止进一步处理
with concurrent.futures.ThreadPoolExecutor() as executor: #开启子进程，能保证运行结束后回收资源消耗 with ProcessPoolExecutor() as executor: #开启子进程，能保证运行结束后回收资源消耗
# 立即启动不依赖 knowledge_name 和 index 的任务 # 立即启动不依赖 knowledge_name 和 index 的任务
futures = { futures = {
'evaluation_standards': executor.submit(fetch_evaluation_standards,processed_data['invalid_deleted_docx'], #技术评分 商务评分 'evaluation_standards': executor.submit(fetch_evaluation_standards,processed_data['invalid_deleted_docx'], #技术评分 商务评分
@ -266,7 +265,7 @@ def goods_bid_main(output_folder, file_path, file_type, unique_id):
} }
# 提前处理这些不依赖的任务，按完成顺序返回 # 提前处理这些不依赖的任务，按完成顺序返回
for future in concurrent.futures.as_completed(futures.values()): #as_completed：哪个先运行结束就先返回 for future in as_completed(futures.values()): #as_completed：哪个先运行结束就先返回
key = next(k for k, v in futures.items() if v == future) key = next(k for k, v in futures.items() if v == future)
try: try:
result = future.result() result = future.result()