2.15 排查开评定标

This commit is contained in:
zy123 2025-02-15 13:41:48 +08:00
parent a0e1add4f7
commit ac45c66cc2
2 changed files with 11 additions and 12 deletions

View File

@ -52,7 +52,6 @@ def qianwen_long(file_id, user_query, max_retries=2, backoff_factor=1.0, need_ex
- backoff_factor: 指数退避的基础等待时间默认 1.0 - backoff_factor: 指数退避的基础等待时间默认 1.0
- need_extra: 是否需要返回额外数据默认 False - need_extra: 是否需要返回额外数据默认 False
""" """
logger.info("zy123")
client = OpenAI( client = OpenAI(
api_key=os.getenv("DASHSCOPE_API_KEY"), api_key=os.getenv("DASHSCOPE_API_KEY"),
base_url="https://dashscope.aliyuncs.com/compatible-mode/v1" base_url="https://dashscope.aliyuncs.com/compatible-mode/v1"

View File

@ -228,11 +228,11 @@ def goods_bid_main(output_folder, file_path, file_type, unique_id):
with concurrent.futures.ThreadPoolExecutor() as executor: with concurrent.futures.ThreadPoolExecutor() 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'], #技术评分 商务评分
processed_data['evaluation_method_path'],logger), # processed_data['evaluation_method_path'],logger),
#
'invalid_requirements': executor.submit(fetch_invalid_requirements, processed_data['invalid_added_docx'], #无效标与废标项 # 'invalid_requirements': executor.submit(fetch_invalid_requirements, processed_data['invalid_added_docx'], #无效标与废标项
output_folder,logger), # output_folder,logger),
'bidding_documents_requirements': executor.submit(fetch_bidding_documents_requirements,processed_data['invalid_deleted_docx'],processed_data['merged_baseinfo_path'], 'bidding_documents_requirements': executor.submit(fetch_bidding_documents_requirements,processed_data['invalid_deleted_docx'],processed_data['merged_baseinfo_path'],
processed_data['clause_path'],logger), #投标文件要求 processed_data['clause_path'],logger), #投标文件要求
@ -240,12 +240,12 @@ def goods_bid_main(output_folder, file_path, file_type, unique_id):
'opening_bid': executor.submit(fetch_bid_opening, processed_data['invalid_deleted_docx'],processed_data['merged_baseinfo_path'], 'opening_bid': executor.submit(fetch_bid_opening, processed_data['invalid_deleted_docx'],processed_data['merged_baseinfo_path'],
processed_data['clause_path'],logger), #开评定标流程 processed_data['clause_path'],logger), #开评定标流程
'base_info': executor.submit(fetch_project_basic_info, processed_data['invalid_deleted_docx'],processed_data['merged_baseinfo_path'], #基础信息 # 'base_info': executor.submit(fetch_project_basic_info, processed_data['invalid_deleted_docx'],processed_data['merged_baseinfo_path'], #基础信息
processed_data['procurement_path'],processed_data['clause_path'],logger), # processed_data['procurement_path'],processed_data['clause_path'],logger),
#
'qualification_review': executor.submit(fetch_qualification_review, processed_data['invalid_deleted_docx'], #资格审查 # 'qualification_review': executor.submit(fetch_qualification_review, processed_data['invalid_deleted_docx'], #资格审查
processed_data['qualification_path'], # processed_data['qualification_path'],
processed_data['notice_path'],logger), # processed_data['notice_path'],logger),
} }
# 提前处理这些不依赖的任务,按完成顺序返回 # 提前处理这些不依赖的任务,按完成顺序返回