From 404c56e1348fe79edd811f91184a45a24775481f Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E8=83=A1=E5=B0=A7?= Date: Sun, 27 Apr 2025 15:24:28 +0800 Subject: [PATCH] =?UTF-8?q?=E5=B1=8F=E8=94=BD=E5=88=A0=E9=99=A4=E6=96=87?= =?UTF-8?q?=E4=BB=B6=E4=BB=A3=E7=A0=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- sf_machine_connect/models/ftp_operate.py | 56 ++++++++++++------------ 1 file changed, 28 insertions(+), 28 deletions(-) diff --git a/sf_machine_connect/models/ftp_operate.py b/sf_machine_connect/models/ftp_operate.py index 89230170..b6724588 100644 --- a/sf_machine_connect/models/ftp_operate.py +++ b/sf_machine_connect/models/ftp_operate.py @@ -312,37 +312,37 @@ def transfer_files( logging.info(f"已传输文件: {item}") # 清空目标目录下的所有内容 - try: - target_ftp.ftp.cwd(target_dir) - files = target_ftp.ftp.nlst() + # try: + # target_ftp.ftp.cwd(target_dir) + # files = target_ftp.ftp.nlst() - for f in files: - try: - # 尝试删除文件 - target_ftp.ftp.delete(f) - except: - try: - # 如果删除失败,可能是目录,递归删除目录 - def remove_dir(path): - target_ftp.ftp.cwd(path) - sub_files = target_ftp.ftp.nlst() - for sf in sub_files: - try: - target_ftp.ftp.delete(sf) - except: - remove_dir(f"{path}/{sf}") - target_ftp.ftp.cwd('..') - target_ftp.ftp.rmd(path) + # for f in files: + # try: + # # 尝试删除文件 + # target_ftp.ftp.delete(f) + # except: + # try: + # # 如果删除失败,可能是目录,递归删除目录 + # def remove_dir(path): + # target_ftp.ftp.cwd(path) + # sub_files = target_ftp.ftp.nlst() + # for sf in sub_files: + # try: + # target_ftp.ftp.delete(sf) + # except: + # remove_dir(f"{path}/{sf}") + # target_ftp.ftp.cwd('..') + # target_ftp.ftp.rmd(path) - remove_dir(f"{target_dir}/{f}") - except: - logging.error(f"无法删除 {f}") - pass + # remove_dir(f"{target_dir}/{f}") + # except: + # logging.error(f"无法删除 {f}") + # pass - logging.info(f"已清空目标目录 {target_dir}") - except Exception as e: - logging.error(f"清空目标目录失败: {str(e)}") - raise Exception(f"清空目标目录失败: {str(e)}") + # logging.info(f"已清空目标目录 {target_dir}") + # except Exception as e: + # logging.error(f"清空目标目录失败: {str(e)}") + # raise Exception(f"清空目标目录失败: {str(e)}") # 开始遍历 traverse_dir(source_dir)