diff --git a/sf_mrs_connect/models/ftp_operate.py b/sf_mrs_connect/models/ftp_operate.py index 6d7d172c..3183c0f6 100644 --- a/sf_mrs_connect/models/ftp_operate.py +++ b/sf_mrs_connect/models/ftp_operate.py @@ -28,15 +28,11 @@ class FtpController(): logging.info("dirname:%s" % os.path.dirname(path)) directories = os.path.normpath(path).split(os.path.sep) # 切换到上级目录 - current_dir = '/' for directory in directories: if directory: # 检查目录是否存在 if (directory in ['NC']) or (directory not in ['home', 'ftp', 'ftp_root', 'NC']): self.ftp.cwd(directory) - if directory not in ['home', 'ftp', 'ftp_root', 'NC']: - # 切换到新的目录 - self.ftp.cwd(directory) return os.path.basename(path) except Exception as e: logging.error(f"Error checking file: {e}") @@ -69,6 +65,9 @@ class FtpController(): return True except: return False + finally: + self.ftp.quit() + logging.info("ftp已关闭") # # 检测字符串的编码 # def detect_encoding(self, s):