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))