Oracle EBS OAF上传文件到服务器实例.doc

很多时候，我们会遇到这种需求：用户需要上传csv数据文件到EBS服务器，然后程序读取数据到数据库。不同的用户上传的路径也不同，比如采购用户，需要上传采购数据，BOM用户，需要上传BOM清单，财务用户需要上传日记账数据，等等。实现方式有很多。比如，DBA在服务器端分别共享文件夹给不同的用户，文件夹设置密码（这个方式最便捷，我公司就是用这种方式）。本帖简单实现的是另外一个方法，在EBS注册一个OAF页面，通过javaftp的方式，把文件上传到EBS服务器。如下图：用户应该可以选择需要上传的路径。（数据可以在value set设置，具体权限控制需要自己酌情考虑）OAF截图：java代码：（简单测试通过，能从本机把文件上传到EBS服务器上，参数都是写死的硬代码）MyFtp.javapackage oracle.apps.ak.uploadfile.webui;/java ftp upload import java.io.File; import java.io.FileInputStream; import java.io.FileNotFoundException; import java.io.FileOutputStream; import java.io.IOException; import java.io.InputStream; import java.io.OutputStream; import .TelnetOutputStream; import .ftp.FtpClient; import sun.security.action.OpenFileInputStreamAction; public class MyFtp public static void SimonTestFTP(String serverPath) MyFtp ftpTest = new MyFtp(); /UploadCO ftpTest = new UploadCO(); String serverUrl = hostname; String userName = username; String passWord = password; String uploadFile = D:/SIMON_TEST_FTP.csv; /String serverPath = server path; /上传文件到Ftp服务器 ftpTest.uploadToFtpServer(serverUrl , userName, passWord, uploadFile, serverPath); public void uploadToFtpServer(String serverUrl, String userName, String passWord, String uploadFile, String serverPath) FtpClient ftpClient; try ftpClient = new FtpClient();/打开ftp客户端 /登录到Ftp服务器 boolean isOpenSuccess = loginToFtpServer(ftpClient, serverUrl, userName, passWord); if (isOpenSuccess) /以下几步顺序不能错 /进入服务器的指定目录 ftpClient.cd(serverPath); OutputStream outputStream = getFtpClientOutputStream(ftpClient, uploadFile); InputStream inputStream = getLocalFileInputStream(uploadFile); writeToFtpServer(outputStream, inputStream); close(ftpClient,outputStream, inputStream);/关闭 catch(Exception e) e.printStackTrace(); /*从Ftp服务器上下载文件*/ public void downloadFormFtp(String serverUrl, String userName, String passWord, String downLoadFile, String serverPath) FtpClient ftpClient = null; try ftpClient = new FtpClient(); boolean isOpenSuccess = loginToFtpServer(ftpClient, serverUrl, userName, passWord); if (isOpenSuccess) /以下几步顺序不能错 /进入服务器的指定目录 ftpClient.cd(serverPath); OutputStream outputStream = new FileOutputStream(new File(E:test.csv); InputStream inputStream = getFtpClientInputStream(ftpClient, downLoadFile); writeToLocal(inputStream, outputStream); close(ftpClient,outputStream, inputStream);/关闭 catch (Exception e) /* 登录到Ftp服务器 */ public boolean loginToFtpServer(FtpClient ftpClient,String serverUrl, String userName, String passWord) try ftpClient.openServer(serverUrl); ftpClient.login(userName, passWord); return true; catch (IOException e) System.out.println(Ftp 客户端打开失败); return false; /* 得到ftp客户端的输出流 */ public OutputStream getFtpClientOutputStream(FtpClient ftpClient, String uploadFile) throws IOException ftpClient.binary(); /因为已经进入到了服务的目录，只要在目录下建一个文件就行，所以只要文件名，不要路径 File file = new File(uploadFile); return ftpClient.put(file.getName(); /* 得到ftp客户端的输出流 */ public InputStream getFtpClientInputStream(FtpClient ftpClient, String downLoadFile) throws IOException ftpClient.binary(); /因为已经进入到了服务的目录，只要在目录下建一个文件就行，所以只要文件名，不要路径 File file = new File(downLoadFile); return ftpClient.get(file.getName(); /* 得到本地文件的输入流 */ public InputStream getLocalFileInputStream(String fileName) throws FileNotFoundException return new FileInputStream(new File(fileName); /* 向ftp服务器写入文件 */ public void writeToFtpServer(OutputStream outputStream, InputStream inputStream) throws IOException byte bytes = new byte1024; while(inputStream.read(bytes) != -1) outputStream.write(bytes,0,bytes.length); outputStream.flush(); /*下载文件到本地*/ public void writeToLocal(InputStream inputStream, OutputStream outputStream) throws IOException byte bytes = new byte1024; while(inputStream.read(bytes) != -1) outputStream.write(bytes,0,bytes.length); /* 关闭 */ public void close(FtpClient ftpClient, OutputStream outputStream, InputStream inputStream) throws IOException if(inputStream != null) inputStream.close(); if(outputStream != null) outputStream.close(); if(ftpClient != null) ftpClient.closeServer(); OAFUPLOAD.java/*=+ | Copyright (c) 2001, 2005 Oracle Corporation, Redwood Shores, CA, USA | | All rights reserved. | +=+ | HISTORY | +=*/package oracle.apps.ak.uploadfile.webui;import mon.VersionInfo;import oracle.apps.fnd.framework.OAException;import oracle.apps.fnd.framework.webui.OAControllerImpl;import oracle.apps.fnd.framework.webui.OAPageContext;import oracle.apps.fnd.framework.webui.beans.OAWebBean; /* * Controller for . */public class UploadCO extends OAControllerImpl public static final String RCS_ID=$Header$; public static final boolean RCS_ID_RECORDED = VersionInfo.recordClassVersion(RCS_ID, %packagename%); /* * Layout and page setup logic for a region. * param pageContext the current OA page context * param webBean the web bean corresponding to the region */ public void processRequest(OAPageContext pageContext, OAWebBean webBean) cessRequest(pageContext, webBean); /* * Procedure to handle form submissions for form elements in * a region. * param pageContext the current OA page context * param webBean the web bean corresponding to the region */ public void processFormRequest(OAPageContext pageContext, OAWebBean webBean) cessFormRequest(pageContext, webBean); if (pageContext