From 350c50888bac0a31aeff6c838b67cac23186708d Mon Sep 17 00:00:00 2001 From: zhouchengrong Date: Wed, 11 Dec 2024 11:16:41 +0800 Subject: [PATCH] design design batch --- app/api/api_design.py | 2 +- app/service/design_batch/utils/save_json.py | 10 ++++++++-- 2 files changed, 9 insertions(+), 3 deletions(-) diff --git a/app/api/api_design.py b/app/api/api_design.py index 665d544..f12e170 100644 --- a/app/api/api_design.py +++ b/app/api/api_design.py @@ -445,7 +445,7 @@ async def design(file: UploadFile = File(...), async def save_request_file(contents, file_name): # 创建保存文件的目录（如果不存在） - save_dir = os.path.join(os.getcwd(), "design_batch", "request_data") + save_dir = os.path.join(os.getcwd(), "service/design_batch", "request_data") if not os.path.exists(save_dir): os.makedirs(save_dir) # 处理文件 diff --git a/app/service/design_batch/utils/save_json.py b/app/service/design_batch/utils/save_json.py index 9acd916..f8f2925 100644 --- a/app/service/design_batch/utils/save_json.py +++ b/app/service/design_batch/utils/save_json.py @@ -1,13 +1,19 @@ import json import logging +import os logger = logging.getLogger() def oss_upload_json(oss_client, json_data, object_name): try: - with open(f"app/service/design_batch/response_json/{object_name}", 'w') as file: + save_dir = os.path.join(os.getcwd(), "service/design_batch", "response_data") + if not os.path.exists(save_dir): + os.makedirs(save_dir) + # 处理文件 + file_path = os.path.join(save_dir, object_name) + with open(file_path, 'w') as file: json.dump(json_data, file, indent=4) - oss_client.fput_object("test", object_name, f"app/service/design_batch/response_json/{object_name}") + oss_client.fput_object("test", object_name, file_path) except Exception as e: logger.warning(str(e))