package com.wdxc.util;

 import java.io.File;

 import java.io.FileOutputStream;

 import java.io.IOException;

 import java.io.OutputStream;

 import org.apache.commons.net.ftp.FTPClient;

 import org.apache.commons.net.ftp.FTPClientConfig;

 import org.apache.commons.net.ftp.FTPFile;

 import org.apache.commons.net.ftp.FTPReply;

 import org.apache.log4j.Logger;

 /**

  * FTP文件下载

  * @author wangbo

  *

  */

 public class FTPUtil {

     private static Logger logger = Logger.getLogger(FTPUtil.class);

     private static int port = 21;

     private static String username = "xxxxxx";

     private static String password = "xxxxxxxxxxxxxxxxxx";

     public static boolean fileDown(String ip,String fileDir,String saveFTPDir){

         FTPClient ftp = null;

         File file = new File(saveFTPDir);

         if(!file.exists() && !file.isDirectory()){//如果文件夹不存在则创建

             logger.debug("文件目录不存在，创建。");

             file.mkdirs();

         }

         try{

             //ftp的数据下载

             ftp = new FTPClient();

             ftp.connect(ip, port);

             ftp.login(username, password);

             ftp.setFileType(FTPClient.BINARY_FILE_TYPE);//传输图片的话设置文件类型为二进制

             //ftp.setControlEncoding("UTF-8");//如果有中文文件名的话需要设置

             //设置linux环境

             FTPClientConfig conf = new FTPClientConfig( FTPClientConfig.SYST_UNIX);

             ftp.configure(conf);

             //判断是否连接成功

             int reply = ftp.getReplyCode();

             if (!FTPReply.isPositiveCompletion(reply)){

                 ftp.disconnect();

                 logger.debug("FTP服务无法连接！");

                 return false;

             }

             //设置访问被动模式

             ftp.setRemoteVerificationEnabled(false);

             ftp.enterLocalPassiveMode();

             //切换工作目录到文件所在的目录

             //boolean dir = ftp.changeWorkingDirectory(new String(fileDir.getBytes(),FTP.DEFAULT_CONTROL_ENCODING));//如果是中文路径需要处理

             boolean dir = ftp.changeWorkingDirectory(fileDir);

             if (dir) {

                 //检索ftp目录下所有的文件

                 FTPFile[] fs = ftp.listFiles();

                 for(FTPFile f : fs){

                       File localFile = new File(saveFTPDir+f.getName());

                       OutputStream ios = new FileOutputStream(localFile);

                       ftp.retrieveFile(f.getName(), ios);

                       ios.close();

                 }

                 return true;

             }else {

                 logger.debug("服务器编码方式可能有问题，请检查！");

                 return false;

             }

         }catch (Exception e){

             e.printStackTrace();

             logger.debug("ftp下载文件发生异常！");

             return false;

         }finally{

             if(ftp != null)  try {ftp.disconnect();} catch (IOException ioe) {}

         }

     }

 }