diff --git a/sf_mrs_connect/models/ftp_operate.py b/sf_mrs_connect/models/ftp_operate.py index 40585fe7..a5bb0aab 100644 --- a/sf_mrs_connect/models/ftp_operate.py +++ b/sf_mrs_connect/models/ftp_operate.py @@ -40,6 +40,23 @@ class FtpController(): except Exception: return 0 + # 下载目录下的检测文件 + def download_reportfile_tree(self, target_dir, serverdir, reportpath): + try: + logging.info("进入FTP目录 ") + self.ftp.cwd(target_dir) # 切换工作路径 + logging.info('FTP目录:%s' % target_dir) + remotenames = self.ftp.nlst() + logging.info('FTP目录检测报告文件:%s' % remotenames) + for file in remotenames: + server = os.path.join(serverdir, file) + logging.info('server' % server) + if file.find(reportpath) != -1: + self.download_file(server, file) + return 1 + except: + return False + # 下载指定目录下的指定文件 def download_file(self, serverfile, remotefile): file_handler = open(serverfile, 'wb')