| | |
| | | String fileName = file.getName(); |
| | | // System.out.println("fileName = " + fileName); |
| | | InputStream is = ftp.retrieveFileStream(new String(fileName.getBytes("GBK"), FTP.DEFAULT_CONTROL_ENCODING)); |
| | | String substring1 = fileName.substring(0, 1); |
| | | String substring1 = fileName.substring(0, 2); |
| | | // System.out.println("substring1 = " + substring1); |
| | | if (substring1.equals("n")){ |
| | | if (substring1.equals("ni")){ |
| | | System.out.println("-------接收到内网回传的文件: " + fileName); |
| | | //把文件下载到本地 |
| | | FtpUtil.downloadFtpFile(ftpHost, ftpUserNameIn, ftpPasswordIn, ftpPort, ftpPath, localPath, fileName); |
| | |
| | | Result result = DataHandler.handler(s,uuid); |
| | | //删除本地文件 |
| | | MysqlCenlint.deletess(fileName); |
| | | FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserNameIn, ftpPasswordIn, ftpPath, fileName); |
| | | ftp.dele(fileName); |
| | | // FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserNameIn, ftpPasswordIn, ftpPath, fileName); |
| | | is.close(); |
| | | ftp.completePendingCommand(); |
| | | if (result.getCode()==200) { |
| | |
| | | //删除本地文件 |
| | | MysqlCenlint.deletess(fileName); |
| | | //删除 ftp 文件 |
| | | FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserNameIn, ftpPasswordIn, ftpPath, fileName); |
| | | // FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserNameIn, ftpPasswordIn, ftpPath, fileName); |
| | | ftp.dele(fileName); |
| | | //返回 |
| | | return result; |
| | | } |
| | |
| | | //删除本地文件 |
| | | MysqlCenlint.deletess(fileName); |
| | | //删除 ftp 文件 |
| | | FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserNameIn, ftpPasswordIn, ftpPath, fileName); |
| | | ftp.dele(fileName); |
| | | // FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserNameIn, ftpPasswordIn, ftpPath, fileName); |
| | | //返回 |
| | | return result; |
| | | } |
| | |
| | | if (null == is) { |
| | | return false; |
| | | } else { |
| | | String substring1 = fileName.substring(0, 4); |
| | | if (substring1.equals("nsql")) { |
| | | String substring1 = fileName.substring(0, 2); |
| | | if (substring1.equals("nq")) { |
| | | //把文件下载到本地 |
| | | FtpUtil.downloadFtpFile(ftpHost, ftpUserNameIn, ftpPasswordIn, ftpPort, ftpPath, localPath, fileName); |
| | | // |
| | |
| | | //删除本地服务器文件 |
| | | MysqlCenlint.deletess(fileName); |
| | | //删除 ftp 服务器文件 |
| | | FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserNameIn, ftpPasswordIn, ftpPath, fileName); |
| | | ftp.dele(fileName); |
| | | // FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserNameIn, ftpPasswordIn, ftpPath, fileName); |
| | | } |
| | | //关闭流 |
| | | is.close(); |
| | |
| | | //删除本地文件 |
| | | MysqlCenlint.deletess(fileName); |
| | | //删除 ftp 文件 |
| | | FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserNameIn, ftpPasswordIn, ftpPath, fileName); |
| | | ftp.dele(fileName); |
| | | // FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserNameIn, ftpPasswordIn, ftpPath, fileName); |
| | | //返回 |
| | | return result; |
| | | } |