package com.yinhai.team.action;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import org.apache.commons.net.ftp.FTPClient;
import org.apache.commons.net.ftp.FTPFile;
import org.apache.commons.net.ftp.FTPReply;
public class FavFTPUtil {
   /**
    * 上傳文件（可供Action/Controller層使用）未測試
    * @param hostname FTP服務(wù)器地址 
    * @param port FTP服務(wù)器端口號(hào)
    * @param username FTP登錄帳號(hào)
    * @param password FTP登錄密碼
    * @param pathname FTP服務(wù)器保存目錄
    * @param fileName 上傳到FTP服務(wù)器后的文件名稱
    * @param inputStream 輸入文件流
    * @return
    */
   public static boolean uploadFile(String hostname, int port, String username, String password, String pathname, String fileName, InputStream inputStream){
    boolean flag = false;
    FTPClient ftpClient = new FTPClient();
    ftpClient.setControlEncoding("UTF-8");
    try {
     //連接FTP服務(wù)器
     ftpClient.connect(hostname, port);
     //登錄FTP服務(wù)器
     ftpClient.login(username, password);
     //是否成功登錄FTP服務(wù)器
     int replyCode = ftpClient.getReplyCode();
     if(!FTPReply.isPositiveCompletion(replyCode)){
      return flag;
     }
     ftpClient.setFileType(FTPClient.BINARY_FILE_TYPE);
     ftpClient.makeDirectory(pathname);
     ftpClient.changeWorkingDirectory(pathname);
     ftpClient.storeFile(fileName, inputStream);
     inputStream.close();
     ftpClient.logout();
     flag = true;
    } catch (Exception e) {
     e.printStackTrace();
    } finally{
     if(ftpClient.isConnected()){
      try {
       ftpClient.disconnect();
      } catch (IOException e) {
       e.printStackTrace();
      }
     }
    }
    return flag;
   }
   /**
    * 上傳文件（可對(duì)文件進(jìn)行重命名）未測試
    * @param hostname FTP服務(wù)器地址
    * @param port FTP服務(wù)器端口號(hào)
    * @param username FTP登錄帳號(hào)
    * @param password FTP登錄密碼
    * @param pathname FTP服務(wù)器保存目錄
    * @param filename 上傳到FTP服務(wù)器后的文件名稱
    * @param originfilename 待上傳文件的名稱（絕對(duì)地址）
    * @return
    */
   public static boolean uploadFileFromProduction(String hostname, int port, String username, String password, String pathname, String filename, String originfilename){
    boolean flag = false;
    try {
     InputStream inputStream = new FileInputStream(new File(originfilename));
     flag = uploadFile(hostname, port, username, password, pathname, filename, inputStream);
    } catch (Exception e) {
     e.printStackTrace();
    }
    return flag;
   }
   /**
    * 上傳文件（不可以進(jìn)行文件的重命名操作） 未測試
    * @param hostname FTP服務(wù)器地址
    * @param port FTP服務(wù)器端口號(hào)
    * @param username FTP登錄帳號(hào)
    * @param password FTP登錄密碼
    * @param pathname FTP服務(wù)器保存目錄
    * @param originfilename 待上傳文件的名稱（絕對(duì)地址）
    * @return
    */
   public static boolean uploadFileFromProduction(String hostname, int port, String username, String password, String pathname, String originfilename){
    boolean flag = false;
    try {
     String fileName = new File(originfilename).getName();
     InputStream inputStream = new FileInputStream(new File(originfilename));
     flag = uploadFile(hostname, port, username, password, pathname, fileName, inputStream);
    } catch (Exception e) {
     e.printStackTrace();
    }
    return flag;
   }
   /** 
    * 刪除文件 未測試
    * @param hostname FTP服務(wù)器地址
    * @param port FTP服務(wù)器端口號(hào)
    * @param username FTP登錄帳號(hào)
    * @param password FTP登錄密碼
    * @param pathname FTP服務(wù)器保存目錄
    * @param filename 要?jiǎng)h除的文件名稱
    * @return
    */
   public static boolean deleteFile(String hostname, int port, String username, String password, String pathname, String filename){
    boolean flag = false;
    FTPClient ftpClient = new FTPClient();
    try {
     //連接FTP服務(wù)器
     ftpClient.connect(hostname, port);
     //登錄FTP服務(wù)器
     ftpClient.login(username, password);
     //驗(yàn)證FTP服務(wù)器是否登錄成功
     int replyCode = ftpClient.getReplyCode();
     if(!FTPReply.isPositiveCompletion(replyCode)){
      return flag;
     }
     //切換FTP目錄
     ftpClient.changeWorkingDirectory(pathname);
     ftpClient.dele(filename);
     ftpClient.logout();
     flag = true;
    } catch (Exception e) {
     e.printStackTrace();
    } finally{
     if(ftpClient.isConnected()){
      try {
       ftpClient.logout();
      } catch (IOException e) {
      }
     }
    }
    return flag;
   }
   /**
    * 下載文件 
    * @param hostname FTP服務(wù)器地址
    * @param port FTP服務(wù)器端口號(hào)
    * @param username FTP登錄帳號(hào)
    * @param password FTP登錄密碼
    * @param pathname FTP服務(wù)器文件目錄
    * @param filename 文件名稱
    * @param localpath 下載后的文件路徑
    * @return
    */
  public static boolean downloadFile(String hostname, int port, String username, String password, String pathname, String filename, String localpath){
    boolean flag = false;
    FTPClient ftpClient = new FTPClient();
    try {
     //連接FTP服務(wù)器
     ftpClient.connect(hostname, port);
     //登錄FTP服務(wù)器
     ftpClient.login(username, password);
     //驗(yàn)證FTP服務(wù)器是否登錄成功
     int replyCode = ftpClient.getReplyCode();
     if(!FTPReply.isPositiveCompletion(replyCode)){
      return flag;
     }
     //切換FTP目錄
     boolean b = ftpClient.changeWorkingDirectory(new String(pathname.getBytes(),"ISO-8859-1"));
     System.out.println(b);
     FTPFile[] ftpFiles = ftpClient.listFiles();
     for(FTPFile file : ftpFiles){
       String fName = new String(file.getName().getBytes("iso-8859-1"), "UTF-8");
       System.out.println(fName);
      if(filename.equalsIgnoreCase(fName)){
       File localFile = new File(localpath + "/" + fName);
       OutputStream os = new FileOutputStream(localFile);
       ftpClient.retrieveFile(file.getName(), os);
       os.close();
      }
     }
     ftpClient.logout();
     flag = true;
    } catch (Exception e) {
     e.printStackTrace();
    } finally{
     if(ftpClient.isConnected()){
      try {
       ftpClient.logout();
      } catch (IOException e) {
      }
     }
    }
    return flag;
   }
}