#!/usr/bin/python
# -*- coding: GBK -*-
# -*- coding: UTF-8 -*-
from ftplib import FTP
import os
import datetime
ftp_server = '127.0.0.1' # 對應ftp服務器地址
username = 'ponshine' # 用戶名
password = '1qaz2wsx' # 密碼
ftp_path = '/GBCC/' # ftp目錄
local_path = "C:\F\python\pythonwangtest\wyjj2\\" #本地的目錄
# 連接FTP
def ftpconnect():
  ftp = FTP()
  ftp.set_debuglevel(2) # 打開調試級別2，顯示詳細信息
  ftp.connect(ftp_server, 21) # 連接
  ftp.login(username, password) # 登錄，如果匿名登錄則用空串代替即可
  return ftp
# 獲取當前的年月日時分秒
def getdatetime():
  i = datetime.datetime.now()
  date = ("%s%s%s%s%s%s" % (i.year, i.month, i.day, i.hour,i.minute,i.second))
  return date # 需返回才能取值
# 獲取當前的年月日
def getdate():
  import datetime
  i = datetime.datetime.now()
  date = ("%s%s%s" % (i.year, i.month, i.day))
  return date # 需返回才能取值
def downloadfile(remotepath, localpath):
  ftp = ftpconnect() # 連接ftp
  print ftp.getwelcome() # 顯示ftp服務器歡迎信息
  ftp_filename = ftp.nlst(remotepath) # 運用nlst()獲取文件名
  print 'ftp_filename: ', ftp_filename # ftp上的文件名
  for eachfile in ftp_filename: # 循壞取文件名
    if eachfile.endswith('.AVL'):
      localpath_files = eachfile.split("/")
      localpath_file = localpath_files[len(localpath_files) - 1] # 文件名：localpath_file= GBCC_201611102155_01.AVL
      print "localpath_file--->" + localpath_file
      # 創(chuàng)建記錄下載文件名的文件名
      writefiletext = local_path + getdate() + ".txt" # 記錄下載后的文件名
      print "writefile_text--->" + writefiletext　　　　　　 
      if os.path.exists(writefiletext):
        print writefiletext + "is exists"
      else:
        print writefiletext + "is not exists"
        makefile = open(writefiletext,"w+")
        makefile.close()
      files = open(writefiletext, "r") # 打開黑名單表
      print "writefiletext--->" + writefiletext
      try:
        all_the_text = files.read()
        print "all_the_text-------》" + all_the_text
        if all_the_text.__contains__(localpath_file):
          print "文件已下載，不需要重復下載"
        else:
          print "文件沒有下載，現(xiàn)在開始下載"
          bufsize = 1024 # 設置緩沖塊大小
          fp = open(localpath + localpath_file, "wb+")
          ftp.retrbinary('RETR ' + eachfile, fp.write, bufsize) # 下載文件
          fo = open(writefiletext,"ab+")
          fo.write(localpath_file + "\n") # 將每個文件名寫入文件
          fo.flush() # 刷新文件
          fo.close()
          fp.flush()
      finally:
        print "結束了"
        files.close()
  ftp.set_debuglevel(0)
  ftp.close()
if __name__ == "__main__":
  downloadfile("/GBCC", "C:\F\python\pythonwangtest\wyjj2\\")

#過濾黑名單列表中出現(xiàn)的
def in_lists(str):
  str_lists=[]
  fd = open('./filter/blacklist')
  for line in fd.readlines():
    str_lists.append(line.strip())
  if str in str_lists:
    return 0
  else:
    return 1