# 組件源碼 ``` /** * <b>方法描述：</b> FTP文件上傳 <br/> * <b>創建者：</b> admin <br/> * <b>創建時間：</b> 2018-05-08 18:20:45 <br/> * * @param ftpHost * 入參|FTP服務器地址|{@link java.lang.String} * @param ftpPort * 入參|FTP服務器端口|{@link java.lang.Integer} * @param ftpUser * 入參|FTP用戶|{@link java.lang.String} * @param ftpPswd * 入參|FTP密碼|{@link java.lang.String} * @param localFile * 入參|本地文件|{@link java.lang.String} * @param remoteFile * 入參|上傳目錄文件|{@link java.lang.String} * @return -1 異常<br/> * 0 失敗<br/> * 1 成功<br/> */ @Component(label = "FTP文件上傳", style = "判斷型", type = "同步組件", comment = "FTP文件上傳", version = "1.0.0", deprecated = false, author = "admin", date = "2018-05-08 06:20:45") @InParams(param = { @Param(name = "ftpHost", comment = "FTP服務器地址", type = java.lang.String.class), @Param(name = "ftpPort", comment = "FTP服務器端口", type = java.lang.Integer.class), @Param(name = "ftpUser", comment = "FTP用戶", type = java.lang.String.class), @Param(name = "ftpPswd", comment = "FTP密碼", type = java.lang.String.class), @Param(name = "localFile", comment = "本地文件", type = java.lang.String.class), @Param(name = "remoteFile", comment = "上傳目錄文件", type = java.lang.String.class) }) @Returns(returns = { @Return(id = "-1", desp = "異常"), @Return(id = "0", desp = "失敗"), @Return(id = "1", desp = "成功") }) public static ResultBase P_ftpUpload(String ftpHost, Integer ftpPort, String ftpUser, String ftpPswd, String localFile, String remoteFile) { InputStream input = null; File fileUp = new File(localFile); if (!fileUp.exists() || !fileUp.isFile()) { return ResultBase.newFailureResult("TPTX0001", "上傳文件不存在"); } try { input = new FileInputStream(fileUp); } catch (FileNotFoundException e1) { AppLog.error(e1); return ResultBase.newFailureResult("TPTX0002", "上傳文件不存在"); } if (ftpPort == null || ftpPort < 1) ftpPort = 21; String[] strATmp = localFile.replaceAll("\\\\", "/").split("/"); String fileName = strATmp[strATmp.length - 1]; String svrPath = remoteFile.replaceAll("\\\\", "/"); if (!svrPath.endsWith("/")) { strATmp = svrPath.replaceAll("\\\\", "/").split("/"); fileName = strATmp[strATmp.length - 1]; svrPath = svrPath .substring(0, svrPath.length() - fileName.length()); } FTPClient ftp = new FTPClient(); try { ftp.connect(ftpHost, ftpPort); ftp.login(ftpUser, ftpPswd); int reply = ftp.getReplyCode(); if (!FTPReply.isPositiveCompletion(reply)) { ftp.disconnect(); return ResultBase.newFailureResult("TPTX0003", "登錄FTP服務失敗"); } if (StringUtils.isNotEmpty(svrPath) && !ftp.changeWorkingDirectory(svrPath)) { ftp.disconnect(); return ResultBase.newFailureResult("TPTX0004", "遠程目錄" + svrPath + "不存在"); } ftp.setFileType(FTP.BINARY_FILE_TYPE); fileName = new String(fileName.getBytes("GBK"), "iso-8859-1"); ftp.storeFile(fileName, input); input.close(); ftp.logout(); return ResultBase.newSuccessResult(); } catch (Exception e) { AppLog.error(e); return ResultBase.newExceptionResult("TPTX0005", "FTP上傳文件異常：" + AppLog.errorMsg(e)); } finally { try { ftp.disconnect(); } catch (Exception ioe) { AppLog.error(ioe); } } } ``` # 交易中組件使用方式  # 參數說明及示例 ## 入口參數 FTP服務器地址：FTP 所在服務地址，示例： `__REQ__["serverName"]` FTP服務器端口：FTP 服務端口，示例： `__REQ__["port"]` FTP用戶：FTP 用戶名，示例： `__REQ__["user"]` FTP密碼：FTP 密碼，示例： `__REQ__["pwd"]` 本地文件：需要上傳的文件，示例： `"D:\\work\\CQYY\\workspace\\abc.txt"` 上傳目錄文件：FTP 服務器目錄，示例： `"/opt"`