#!/usr/local/bin/python3.5
###Description: 上传业务log到FTP199
###Author: Tonny.Deng
###DateTime: 2016-11-22
import os,sys,shutil,time,datetime,re,socket,subprocess
import ftplib
##########################
backup_dir = "/dockerlogs/"
ip_addr = socket.gethostbyname(socket.gethostname())
ports = sorted(os.listdir(backup_dir))
yesterday = (datetime.datetime.now() - datetime.timedelta(days=1)).strftime("%Y-%m-%d")
thirday = (datetime.datetime.now() - datetime.timedelta(days=2)).strftime("%Y-%m-%d")
###############取log文件
pattern = re.compile(r‘‘ + thirday + ‘*.log$‘ )
#pattern = re.compile(r‘‘ + thirday + ‘*.log‘ )
###############取服务端口列表目录
for port in (ports):
   port_dir = backup_dir + port
   ftp_dir = ip_addr + "/" + port
##############判断ftp上是否有对应目录，没有则创建,此次判断是两个目录 如：192.168.20.130/8000 这两个目录是否存在
   ftp = ftplib.FTP("192.xxxxx")
   ftp.login("sxxxxxxxxxxxxxx","xxxxxxxxx,10)
   try:
      ftp.mkd(ip_addr)
      ftp.cwd(ip_addr)
      try:
         ftp.mkd(port)
         ftp.quit()
      except ftplib.error_perm:
         ftp.quit()
   except ftplib.error_perm:
      ftp.cwd(ip_addr)
      try:
         ftp.mkd(port)
         ftp.quit()
      except ftplib.error_perm:
         ftp.quit()
##############取端口目录下的service目录
   for services in sorted(os.listdir(port_dir)):
      services_dir = port_dir + "/" + services
##############判断services目录是否存在，即第三级 如：192.168.20.130/8000/yunwei
      ftp = ftplib.FTP("192.xxxxxx")
      ftp.login("syxxxxxx","sxxxxxx",10)
      ftp.cwd(ftp_dir)
      try:
         ftp.mkd(services)
      except ftplib.error_perm:
         ftp.quit()
#############遍历service目录中的符合的文件
      for file in sorted(os.listdir(services_dir)):
         match = pattern.search(file)
         if match:
#############匹配到文件后进行 文件名 更换操作，方便上传
            ftpdir_service = ftp_dir + "/" + services
#############登录到ftp上的对应目录，准备上传
            ftp = ftplib.FTP("19xxxxxxxxxx")
            ftp.login("sxxxxx","syxxxxxxx",10)
            ftp.cwd(ftpdir_service)
            filename = services_dir + "/" + file
#############上传压缩文件到ftp
            os.environ[‘filename‘] = str(filename)
            os.system(‘gzip $filename‘)
            filename_gz = filename +  ".gz"
#############只读模式打开本地需要上传的文件
            filename_put = open(filename_gz,‘rb‘)
            ftp.storbinary(‘STOR %s‘ % os.path.basename(filename_gz),filename_put)
            ftp.nlst()