修改胚料部分
This commit is contained in:
@@ -19,25 +19,24 @@ class FtpController():
|
||||
try:
|
||||
self.ftp.connect(host, port)
|
||||
self.ftp.login(username, password)
|
||||
logging.info("连接成功: ")
|
||||
except:
|
||||
logging.info("连接失败: ")
|
||||
|
||||
# 下载目录下的文件
|
||||
def download_file_tree(self, remotepath, serverdir):
|
||||
def download_file_tree(self, target_dir, serverdir):
|
||||
self.ftp.cwd(target_dir) # 切换工作路径
|
||||
if not os.path.exists(serverdir):
|
||||
os.makedirs(serverdir)
|
||||
self.ftp.cwd(remotepath)
|
||||
remotenames = self.ftp.nlst()
|
||||
for file in remotenames:
|
||||
server = os.path.join(serverdir, file)
|
||||
if file.find(".") != -1:
|
||||
self.download_file(server, file)
|
||||
else:
|
||||
return False
|
||||
remotenames = self.ftp.nlst()
|
||||
for file in remotenames:
|
||||
server = os.path.join(serverdir, file)
|
||||
if file.find(".") != -1:
|
||||
self.download_file(server, file)
|
||||
return
|
||||
|
||||
# 下载指定目录下的指定文件
|
||||
def download_file(self, serverfile, remotefile):
|
||||
file_handler = open(serverfile, 'wb')
|
||||
self.ftp.retrbinary('RETR ' + remotefile, file_handler.write)
|
||||
file_handler.close()
|
||||
|
||||
|
||||
Reference in New Issue
Block a user