springmvc+mybatis+html 下将查询数据以excell形式上传到ftp（下）

  1 package com.ninefbank.smallpay.admin.util;
  2 
  3 import java.io.BufferedOutputStream;
  4 import java.io.File;
  5 import java.io.FileInputStream;
  6 import java.io.FileOutputStream;
  7 import java.io.IOException;
  8 import java.io.OutputStream;
  9 
 10 import org.apache.commons.lang3.StringUtils;
 11 import org.apache.commons.net.ftp.FTPClient;
 12 import org.apache.commons.net.ftp.FTPClientConfig;
 13 import org.apache.commons.net.ftp.FTPFile;
 14 import org.apache.commons.net.ftp.FTPReply;
 15 import org.slf4j.Logger;
 16 import org.slf4j.LoggerFactory;
 17 
 18 import com.jcraft.jsch.Channel;
 19 import com.jcraft.jsch.ChannelSftp;
 20 import com.jcraft.jsch.JSch;
 21 import com.jcraft.jsch.Session;
 22 import com.ninefbank.smallpay.admin.common.Ftp;
 23 import com.ninefbank.smallpay.common.util.DateUtil;
 24 import com.ninefbank.smallpay.common.vo.FtpRequest;
 25 
 26 public class FtpUtils {
 27     private static Logger logger = LoggerFactory.getLogger(FtpUtils.class);
 28     private static FTPClient ftp;
 29     private static String LOCAL_CHARSET = "GBK";
 30     
 31     
 32     /* 获取ftp连接
 33      * @param f
 34      * @return
 35      * @throws Exception
 36      */
 37     public static boolean connectFtp(Ftp f) throws Exception{
 38         ftp=new FTPClient();
 39         boolean flag=false;
 40         int reply;
 41         if (f.getPort()==null) {
 42             ftp.connect(f.getIpAddr(),21);
 43         }else{
 44             ftp.connect(f.getIpAddr(),f.getPort());
 45         }
 46         ftp.login(f.getUserName(), f.getPwd());
 47         ftp.setFileType(FTPClient.BINARY_FILE_TYPE);
 48         reply = ftp.getReplyCode();      
 49         if (!FTPReply.isPositiveCompletion(reply)) {      
 50               ftp.disconnect();      
 51               return flag;      
 52         }      
 53         ftp.changeWorkingDirectory(f.getPath());      
 54         flag = true;      
 55         return flag;
 56     }
 57      /* 下载链接配置
 58       * @param f
 59       * @param localBaseDir 本地目录
 60       * @param remoteBaseDir 远程目录
 61       * @throws Exception
 62       */
 63      public static void startDown(Ftp f,String localBaseDir,String remoteBaseDir ,FtpRequest reqs) throws Exception{
 64          if (FtpUtils.connectFtp(f)) {
 65              
 66              try { 
 67                  String ip = reqs.getIp();
 68                  int port = Integer.parseInt(reqs.getPort());
 69                  String userName = reqs.getUserName();
 70                  String userPwd = reqs.getPwd();
 71                  String path = reqs.getDownloadPath();
 72                  String fileName = reqs.getFileName();
 73                  String localPath = reqs.getLocalPath();
 74                  FTPFile[] files = null; 
 75                  FTPClient ftpClient = new FTPClient();
 76                  ftpClient.connect(ip, port);
 77                  // 登录
 78                  ftpClient.login(userName, userPwd);
 79                  // 设置传输协议
 80                  ftpClient.setRemoteVerificationEnabled(false);
 81                  ftpClient.enterLocalPassiveMode();
 82                  ftpClient.setFileType(FTPClient.BINARY_FILE_TYPE);
 83                  ftpClient.setListHiddenFiles(true);
 84 //                 ftpClient.configure(new FTPClientConfig(FTPClientConfig.SYST_UNIX)); 
 85                  if (FTPReply.isPositiveCompletion(ftpClient.sendCommand(
 86                          "OPTS UTF8", "ON"))) {// 开启服务器对UTF-8的支持，如果服务器支持就用UTF-8编码，否则就使用本地编码（GBK）.
 87                          LOCAL_CHARSET = "UTF-8";
 88                          }
 89                  ftpClient.setControlEncoding(LOCAL_CHARSET);
 90                  boolean changedir = ftpClient.changeWorkingDirectory(remoteBaseDir); 
 91                  if (changedir) { 
 92                      
 93                      
 94 //                     ftp.setControlEncoding("GBK"); 
 95                       
 96                      files = ftpClient.listFiles(); 
 97                      for (int i = 0; i < files.length; i++) { 
 98                          try{ 
 99                              if(fileName.equals(files[i].getName())){
100                                  downloadFile(ftpClient,files[i], localBaseDir, remoteBaseDir); 
101                              }
102                              
103                          }catch(Exception e){ 
104                              logger.error("异常信息："+e); 
105                              logger.error("<"+files[i].getName()+">下载失败"); 
106                          } 
107                      } 
108                  } 
109              } catch (Exception e) { 
110                  logger.error("异常信息："+e); 
111                  logger.error("下载过程中出现异常"); 
112              } 
113          }else{
114              logger.error("链接失败！");
115          }
116          
117      }
118      
119      
120      /** 
121       * 
122       * 下载FTP文件 
123       * 当你需要下载FTP文件的时候，调用此方法 
124       * 根据<b>获取的文件名，本地地址，远程地址</b>进行下载 
125       * 
126       * @param ftpFile 
127       * @param relativeLocalPath 
128       * @param relativeRemotePath 
129       */ 
130      private  static void downloadFile(FTPClient ftpClient,FTPFile ftpFile, String relativeLocalPath,String relativeRemotePath) { 
131          if (ftpFile.isFile()) {
132              if (ftpFile.getName().indexOf("?") == -1) { 
133                  OutputStream outputStream = null; 
134                  try { 
135                       String f= new String(ftpFile.getName().getBytes("GBK"), "iso-8859-1");  
136                      File locaFile= new File(relativeLocalPath+ ftpFile.getName()); 
137                      //判断文件是否存在，存在则返回 
138                      if(locaFile.exists()){ 
139                          return; 
140                      }else{ 
141                          outputStream = new FileOutputStream(relativeLocalPath+ ftpFile.getName()); 
142                          ftpClient.retrieveFile(new String(ftpFile.getName().getBytes("GBK"),"ISO-8859-1"), outputStream); 
143                          outputStream.flush(); 
144                          outputStream.close(); 
145                      } 
146                  } catch (Exception e) { 
147                      logger.error("异常信息："+e);
148                  } finally { 
149                      try { 
150                          if (outputStream != null){ 
151                              outputStream.close(); 
152                          }
153                      } catch (IOException e) { 
154                         logger.error("输出文件流异常"); 
155                      } 
156                  } 
157              } 
158          }
159      } 
160     
161 }