标签:
common.uploadPhoto=function(){ $("#uploadFile").uploadify({ swf: ‘/ecp/res/web/plugins/uploadify/uploadify.swf‘, //[必须设置]swf的路径 uploader:common.uploader, //[必须设置]上传文件触发的url buttonImg:‘/ecp/res/web/img/152743_719516335.png‘, width: 120, //设置浏览按钮的宽度 ,默认值:110 height:25, //设置浏览按钮的高度, 默认值:30。 fileObjName:‘file‘, //上传文件name auto:common.flag, //设置为true当选择文件后就直接上传了,为false需要点击上传按钮才上传 buttonText: ‘选择上传图片‘ , //浏览按钮的文本,默认值:BROWSE multi: true, //设置为true时可以上传多个文件 queueID: ‘some_file_queue‘, //文件队列的ID,该ID与存放文件队列的div的ID一致 fileTypeExts:‘*.jpg;*.jpge;*.gif;*.png;*.bmp‘, //允许上传的文件后缀 fileSizeLimit:‘5MB‘, //上传文件的大小限制 queueSizeLimit: common.queueSizeLimit, //上传数量 progressData : ‘all‘, //队列中显示文件上传进度的方式:all-上传速度+百分比,percentage-百分比,speed-上传速度 removeCompleted : true, //上传成功后的文件,是否在队列中自动删除 method:‘post‘, //和后台交互的方式:post/get onUploadSuccess: function(file, data, response){ data= eval(‘(‘ + data + ‘)‘); common.showPhoto(file,data); var url=data.newImgPath[0]; url=url.substring(url.lastIndexOf("/"),url.length); var oldnames=$("#oldnames").val(); var newnames=$("#newnames").val(); if(oldnames=="" ||oldnames==null){ oldnames="/"+file.name; }else{ oldnames=oldnames+";/"+file.name; } if(newnames=="" || newnames==null){ newnames=url; }else{ newnames=newnames+";"+url; } $("#oldnames").val(oldnames); $("#newnames").val(newnames); common.uploadSize+=1; }, onFallback:function(){ alert("您未安装FLASH控件,无法上传图片!请安装FLASH控件后再试。"); }, //当每个文件添加至队列后触发 onSelect :function(file){ /*alert( ‘id: ‘ + file.id+ ‘ - 索引: ‘ + file.index+ ‘ - 文件名: ‘ + file.name + ‘ - 文件大小: ‘ + file.size+ ‘ - 类型: ‘ + file.type+ ‘ - 创建日期: ‘ + file.creationdate + ‘ - 修改日期: ‘ + file.modificationdate+ ‘ - 文件状态: ‘ + file.filestatus); */ }, //当队列中的所有文件全部完成上传时触发 onQueueComplete : function(stats){ /*alert( ‘成功上传的文件数: ‘ + stats.uploadsSuccessful + ‘ - 上传出错的文件数: ‘ + stats.uploadsErrored); */ common.uploadSuccess(); }, //当文件选定发生错误时触发 onSelectError:function(file, errorCode, errorMsg){ switch(errorCode) { case -100: alert("上传的文件数量已经超出系统限制的"+$(‘#uploadFile‘).uploadify(‘settings‘,"queueSizeLimit")+"个文件!"); break; case -110: alert("文件 ["+file.name+"] 大小超出系统限制的"+$(‘#uploadFile‘).uploadify(‘settings‘,‘fileSizeLimit‘)+"大小!"); break; case -120: alert("文件 ["+file.name+"] 大小异常!"); break; case -130: alert("文件 ["+file.name+"] 类型不正确!"); break; } $("#some_file_queue").empty(); /* alert( ‘id: ‘ + file.id+ ‘ - 索引: ‘ + file.index+ ‘ - 文件名: ‘ + file.name + ‘ - 文件大小: ‘ + file.size+ ‘ - 类型: ‘ + file.type+ ‘ - 创建日期: ‘ + file.creationdate + ‘ - 修改日期: ‘ + file.modificationdate+ ‘ - 文件状态: ‘ + file.filestatus + ‘ - 错误代码: ‘ + errorCode+ ‘ - 错误信息: ‘ + errorMsg); */ }, onDialogClose : function(swfuploadifyQueue) {//当文件选择对话框关闭时触发 if(swfuploadifyQueue.filesSelected<common.queueSizeLimit){ if(swfuploadifyQueue.filesSelected>common.queueSizeLimit-common.uploadSize){ $("#uploadFile").uploadify(‘cancel‘,‘*‘); alert("上传的文件数量已经超出系统限制的"+$(‘#uploadFile‘).uploadify(‘settings‘,"queueSizeLimit")+"个文件!"); } } }, onUploadStart: function (file) { common.onUploadStart(); } }); if(!common.flag) common.uploadBind(); };
<div>
<div id="some_file_queue" style="display:none"></div>
<input type="file" name="file" id="uploadFile" />
</div>
<!-- 上传 -->
<package name="upload" namespace="/bs-ui/upload" extends="bs">
<action name="*!*" class="com.daasan.ecp.upload.{1}" method="{2}">
<result type="json" />
<result name="upload" type="json">
<param name="excludeProperties">file,fileContentType,fileFileName</param>
</result>
</action>
</package>
public class UploadAction extends ActionSupport { /* * 成员变量的名称不能随意更改, * private File file; 变量的名称必须和jsp中上传文件标签中的name属性的值一致. * private String fileFileName; 变量的名称必须为"上传文件的名称+FileName". * private String fileContentType; 变量的名称必须为"上传文件的名称+ContentType", */ private static final long serialVersionUID = 1L; private List<File> file; private List<String> fileFileName; private List<String> fileContentType; private List<String> newImgPath = new ArrayList<String>(); private String id; public String uploadFileTemp() { Map<String, String> map=UploadUtil.getEcpDir(); String url=ServletActionContext.getRequest().getContextPath()+map.get("uploadTemp")+"/"; for(int i=0;i<file.size();i++) { newImgPath.add(url+UploadUtil.upload(file.get(i), fileFileName.get(i),map.get("uploadTemp"))); } return "upload"; } public String uploadAlbumPhoto() { try { Map<String, String> map=UploadUtil.getEcpDir(); HttpServletRequest request=ServletActionContext.getRequest(); String url=ServletActionContext.getRequest().getContextPath()+map.get("uploadTemp"); EcpFtpUtil.connectServer(); for(int i=0;i<file.size();i++){ String newName="/"+UploadUtil.upload(file.get(i), fileFileName.get(i),map.get("uploadTemp")); newImgPath.add(url+newName); String uploadPath=map.get("uploadShopPhoto")+"/"+album.getMember().getId()+"/"+album.getServerName(); String uploadTempPath=map.get("uploadShopPhoto")+"/"+album.getMember().getId()+map.get("temp")+"/"; String uploadTemp=request.getRealPath(map.get("uploadTemp")); String ext=UploadUtil.getExtention(newName);//后缀 String name=UploadUtil.getExtName(newName);//截取后缀 String detail=name+"."+EcpUtil.PHOTO_DETAILWH+ext; String thumb=name+"."+EcpUtil.PHOTO_THUMBWH+ext; UploadUtil.getftpUpload(newName, uploadPath,uploadTemp); } EcpFtpUtil.closeConnect(); } catch (IOException e) { e.printStackTrace(); } catch (BsException e) { e.printStackTrace(); } return "upload"; } public List<File> getFile() { return file; } public void setFile(List<File> file) { this.file = file; } public List<String> getFileFileName() { return fileFileName; } public void setFileFileName(List<String> fileFileName) { this.fileFileName = fileFileName; } public List<String> getFileContentType() { return fileContentType; } public void setFileContentType(List<String> fileContentType) { this.fileContentType = fileContentType; } public List<String> getNewImgPath() { return newImgPath; } public void setNewImgPath(List<String> newImgPath) { this.newImgPath = newImgPath; } public String getId() { return id; } public void setId(String id) { this.id = id; } }
/** * 图片上传工具类 * @author Think * */ public class UploadUtil { private static String default_config = "/businessConfig/" + "http.properties"; public static Properties ps = new Properties(); private static void loadPs() { try { Class<?> config_class = Class .forName("com.daasan.ecp.util.UploadUtil"); InputStream is = config_class.getClassLoader().getResourceAsStream( default_config); ps.load(is); } catch (Exception e) { e.printStackTrace(); } // String // path="webapp/WEB-INF/classes/ftp.properties"; /* * String path = ServletActionContext.getServletContext().getRealPath( * "/WEB-INF/classes/businessConfig/http.properties"); File file = new * File(path); InputStream in = null; try { in = new * FileInputStream(file); ps.load(in); } catch (FileNotFoundException e) * { e.printStackTrace(); } catch (IOException e) { e.printStackTrace(); * } */ } /** * @param file * 文件 * @param fileFileName * 文件名 * @param dir * 临时目录 * @return * @throws IOException */ @SuppressWarnings("deprecation") public static String upload(File file, String fileFileName, String dir) { String root = ServletActionContext.getRequest().getRealPath(dir); String newPath = getNewPath(getExtention(fileFileName)); File destFile = new File(root, newPath); try { FileUtils.copyFile(file, destFile); } catch (IOException e) { e.printStackTrace(); } return newPath; } /** * 将手机端应用程序APK上传到临时目录(不改变源文件名称) * * @param file * 文件 * @param fileFileName * 文件名 * @param dir * 临时目录 * @return * @throws IOException */ @SuppressWarnings("deprecation") public static String upload2(File file, String fileFileName, String dir) { String root = ServletActionContext.getRequest().getRealPath(dir); File destFile = new File(root, fileFileName); try { FileUtils.copyFile(file, destFile); } catch (IOException e) { e.printStackTrace(); } return fileFileName; } /** * @param dir * 临时目录 * @param url * 文件路径 * @param newDir * 新目录 * @return */ @SuppressWarnings("deprecation") public static boolean getUploadServer(String dir, String url, String newDir) { boolean flag = false; String oldUrl = ServletActionContext.getRequest().getRealPath(dir) + url; File oldFile = new File(oldUrl); File destFile = new File(newDir, url); try { FileUtils.copyFile(oldFile, destFile); deleteFile(oldUrl); flag = true; } catch (IOException e) { e.printStackTrace(); } return flag; } public static void getftpUpload(String newNames, String uploadPath, String uploadTemp) throws IOException { EcpFtpUtil.makeDirectory(uploadPath); String oldUrl = uploadTemp + newNames; File oldFile = new File(oldUrl); EcpFtpUtil.ftpUpload(oldFile, uploadPath, newNames.substring(1,newNames.length())); } /** * apk上传使用 * */ public static void getftpUpload2(String newNames, String uploadPath, String uploadTemp) throws IOException { EcpFtpUtil.makeDirectory(uploadPath); String oldUrl = uploadTemp + newNames; File oldFile = new File(oldUrl); EcpFtpUtil.ftpUpload(oldFile, uploadPath, newNames.substring(0,newNames.length())); } public static void getFileFtpUpload(File file, String uploadPath, String newfileName) throws IOException { EcpFtpUtil.connectServer(); EcpFtpUtil.makeDirectory(uploadPath); EcpFtpUtil.ftpUpload(file, uploadPath,newfileName); EcpFtpUtil.closeConnect(); } public static void batchFtpUpload(String[] newNames, String uploadPath, String uploadTemp) throws IOException { EcpFtpUtil.makeDirectory(uploadPath); for (int i = 0; i < newNames.length; i++) { String oldUrl = uploadTemp + newNames[i]; File oldFile = new File(oldUrl); EcpFtpUtil.ftpUpload(oldFile, uploadPath, newNames[i].substring(1,newNames[i].length())); } }; public static String getExtention(String fileFileName) { int idx = fileFileName.lastIndexOf("."); String extention = fileFileName.substring(idx); // 文件后缀 return extention; } public static String getExtName(String fileFileName) { int idx = fileFileName.lastIndexOf("."); String name = fileFileName.substring(0, idx); // 文件后缀 return name; } public static String getNewPath(String extention) { String time = CalDateUtil.getCurrDate("yyyyMMddHHmmssSSS"); String newPath = time + extention; // 新的文件名(日期+后缀) return newPath; } /** * 删除单个文件 * * @param sPath * 被删除文件的文件名 * @return * @return 单个文件删除成功返回true,否则返回false */ private static boolean deleteFile(String sPath) { boolean flag = false; File file = new File(sPath); // 路径为文件且不为空则进行删除 if (file.isFile() && file.exists()) { file.delete(); flag = true; } return flag; } /** * 获取服务器上传目录 */ private static UploadBean getUplodDir() { loadPs(); UploadBean uploadBean = new UploadBean(); uploadBean.setIp(ps.getProperty("ftp.ip")); uploadBean.setPort(ps.getProperty("down.port")); uploadBean.setDownIp(ps.getProperty("down.ip")); uploadBean.setRemoteDir(ps.getProperty("ftp.remoteDir")); uploadBean.setpRootDir(ps.getProperty("project.rootDir")); return uploadBean; } public static Map<String, String> getEcpDir() { UploadBean b = getUplodDir(); String uploadTemp = b.getpRootDir() + b.getPtemp();// 图片上传的临时目录 String uploadShop = b.getEcpDir() + b.getShop(); String uploadShopPhoto = uploadShop + b.getImage();// 店铺图片上传目录 Map<String, String> map = new HashMap<String, String>(); map.put("uploadTemp", uploadTemp); map.put("uploadBrand", uploadBrand); return map; } }
import java.io.File; import java.io.FileInputStream; import java.io.IOException; import java.io.InputStream; import java.text.SimpleDateFormat; import java.util.Properties; import org.apache.commons.io.IOUtils; import org.apache.commons.net.ftp.FTPClient; import org.apache.commons.net.ftp.FTPFile; /** * 资源上传到ftp工具类 * @author Think * */ public class EcpFtpUtil { private static String ip;//FTP服务器hostname private static int port;//FTP服务器端口 private static String username;//FTP登录账号 private static String password;//FTP登录密码 public static FTPClient ftpClient; private static String remoteDir; //FTP服务器保存目录,如果是根目录则为“/”A public final static String default_config = "/businessConfig/" + "http.properties"; /** * 初始化参数 */ private static void setParam(){ //String pathPro = ServletActionContext.getServletContext().getRealPath( //"/WEB-INF/classes/businessConfig/ftp.properties"); /*String pathPro="D:/dsworkspace/.metadata/.plugins/org.eclipse.wst.server.core/tmp0/wtpwebapps/ecp/WEB-INF/classes/businessConfig/http.properties"; File file = new File(pathPro); InputStream in = null; try { in = new FileInputStream(file); Properties ps = new Properties(); ps.load(in); ip = ps.getProperty("ftp.ip"); username = ps.getProperty("ftp.username"); password = ps.getProperty("ftp.password"); remoteDir = ps.getProperty("ftp.remoteDir"); } catch (IOException e) { e.printStackTrace(); } finally { if (in != null) try { in.close(); } catch (IOException e) { e.printStackTrace(); } }*/ try { Class<?> config_class = Class .forName("com.daasan.ecp.util.EcpFtpUtil"); InputStream is = config_class.getClassLoader().getResourceAsStream( default_config); Properties ps = new Properties(); ps.load(is); ip = ps.getProperty("ftp.ip"); username = ps.getProperty("ftp.username"); password = ps.getProperty("ftp.password"); remoteDir = ps.getProperty("ftp.remoteDir"); } catch (Exception e) { e.printStackTrace(); } } /** * * @param file 本地文件 * @param path 上传到服务器目录 * @param newfileName 新文件名 * @return */ @SuppressWarnings("unused") public static boolean ftpUpload(File file,String path,String newfileName){ boolean flag=false; FileInputStream fis = null; try { fis = new FileInputStream(file); if (fis == null){ System.out.println("本地文件不存在"); } ftpClient.setBufferSize(1024); ftpClient.setControlEncoding("GBK"); ftpClient.setFileType(FTPClient.BINARY_FILE_TYPE);//设置传输二进制文件 ftpClient.changeWorkingDirectory(path); ftpClient.storeFile(newfileName, fis); System.out.println("upload success!"); flag=true; } catch (IOException e) { flag=false; System.out.println("upload File false!"); e.printStackTrace(); throw new RuntimeException("FTP客户端出错!", e); } finally { IOUtils.closeQuietly(fis); } return flag; } /** * 连接ftp服务端 * @创建人 * @创建时间 */ public static void connectServer() { try { setParam(); if(ftpClient == null || !ftpClient.isConnected()){ ftpClient = new FTPClient(); System.out.println("ftpIp:" + ip + "|userName:" + username + "|password:" + password); ftpClient.connect(ip); ftpClient.login(username, password); System.out.println("ftp login success!"); ftpClient.setDefaultPort(port); } ftpClient.changeWorkingDirectory(remoteDir); } catch (Exception e) { e.printStackTrace(); throw new RuntimeException("打开FTP连接发生异常!", e); } } /** * 关闭ftp服务连接 * @创建人 * @创建时间 */ public static void closeConnect() { try { ftpClient.disconnect(); } catch (IOException e) { e.printStackTrace(); throw new RuntimeException("关闭FTP连接发生异常!", e); } } /** * 进入到服务器的某个目录下 * * @param directory * @return */ public static FTPFile[] changeWorkingDirectory(String directory) { try { ftpClient.changeWorkingDirectory(directory); FTPFile[] files = ftpClient.listFiles(directory); return files; } catch (IOException ioe) { ioe.printStackTrace(); } return null; } public static boolean makeDirectory(String path) throws IOException { if (!ftpClient.changeWorkingDirectory(path)) { String[] paths=path.split("/"); String temp=""; for (int i = 0; i < paths.length; i++) { if("".equals(paths[i]))continue; if (!ftpClient.changeWorkingDirectory(temp+"/"+paths[i])) { if (!ftpClient.makeDirectory(temp+"/"+paths[i])) { System.out.println("创建文件目录【"+paths[i]+"】 失败!"); return false; } } temp+="/"+paths[i]; } } return true; } public static void main(String[] args) { connectServer(); /* File file=new File("D:/test1.txt"); try { makeDirectory("/ecp/member/item/id"); } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } ftpUpload(file,"/ecp/member/item/id","test111.txt");*/ FTPFile[] files=changeWorkingDirectory(""); for (int i = 0; i < files.length; i++) { System.out.print(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(files[i].getTimestamp().getTime())+"\n"); } closeConnect(); } }
标签:
原文地址:http://www.cnblogs.com/zt528/p/4286493.html