download_program_file方法添加关闭ftp
This commit is contained in:
@@ -28,15 +28,11 @@ class FtpController():
|
|||||||
logging.info("dirname:%s" % os.path.dirname(path))
|
logging.info("dirname:%s" % os.path.dirname(path))
|
||||||
directories = os.path.normpath(path).split(os.path.sep)
|
directories = os.path.normpath(path).split(os.path.sep)
|
||||||
# 切换到上级目录
|
# 切换到上级目录
|
||||||
current_dir = '/'
|
|
||||||
for directory in directories:
|
for directory in directories:
|
||||||
if directory:
|
if directory:
|
||||||
# 检查目录是否存在
|
# 检查目录是否存在
|
||||||
if (directory in ['NC']) or (directory not in ['home', 'ftp', 'ftp_root', 'NC']):
|
if (directory in ['NC']) or (directory not in ['home', 'ftp', 'ftp_root', 'NC']):
|
||||||
self.ftp.cwd(directory)
|
self.ftp.cwd(directory)
|
||||||
if directory not in ['home', 'ftp', 'ftp_root', 'NC']:
|
|
||||||
# 切换到新的目录
|
|
||||||
self.ftp.cwd(directory)
|
|
||||||
return os.path.basename(path)
|
return os.path.basename(path)
|
||||||
except Exception as e:
|
except Exception as e:
|
||||||
logging.error(f"Error checking file: {e}")
|
logging.error(f"Error checking file: {e}")
|
||||||
@@ -69,6 +65,9 @@ class FtpController():
|
|||||||
return True
|
return True
|
||||||
except:
|
except:
|
||||||
return False
|
return False
|
||||||
|
finally:
|
||||||
|
self.ftp.quit()
|
||||||
|
logging.info("ftp已关闭")
|
||||||
|
|
||||||
# # 检测字符串的编码
|
# # 检测字符串的编码
|
||||||
# def detect_encoding(self, s):
|
# def detect_encoding(self, s):
|
||||||
|
|||||||
Reference in New Issue
Block a user