上传下载优化

display-server/src/com/ai/server/bean/UploadDownloadBean.java

@@ -1,26 +1,18 @@
package com.ai.server.bean;
import java.io.BufferedInputStream;
import java.io.BufferedOutputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.InputStream;
import java.io.OutputStream;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.Iterator;
import java.util.List;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import org.apache.commons.fileupload.FileItem;
import org.apache.commons.fileupload.FileItemFactory;
import org.apache.commons.fileupload.disk.DiskFileItemFactory;
import org.apache.commons.fileupload.servlet.ServletFileUpload;
import org.apache.commons.fileupload.util.Streams;
import org.apache.commons.lang.StringUtils;
import com.ai.server.core.bean.DisplayBean;
import com.ai.server.util.ApplicationPath;
@@ -31,270 +23,115 @@ import com.ailk.mobile.util.FileUtil;
import com.ailk.mobile.util.MobileUtility;
/**
 * 
 * @author Lu
 *
 * @author huangbo
 * @date 2016-1-9 下午2:32:20 
 * @desc 上传下载使用范例
 */
public class UploadDownloadBean extends DisplayBean {
    
    /**
    * @Fields hasTimeRandom : 上传图片的路径中，是否包含时间串儿，例如：201511022351123_1234
    * 如果为true，则可以保证每次上传的图片不重名，可以保留原文件的名称不变，下载时候可获取原文件的名称。
    * 
    */
    private final boolean hasTimeRandom = false;
    
	/************************************************************************************
	 * 文件上传；
	 * 如果在参数param中包含USER_NAME键值对，那么文件将保存到USER_NAME对应的目录下；否则保存在TEMP目录下
	 * 
	 * @param param
	 * @return
	 * @throws Exception
	/**
	 * 文件上传
	 */
	/*public IData upload(IData param) throws Exception{
	    IData result = new DataMap();
	@SuppressWarnings("unchecked")
	public IData upload(IData param) throws Exception{
		/*1.判断请求和参数是否合法*/
		String filePath = param.getString("FILE_PATH", ""); //通过自定义参数决定文件存储规则
		if(filePath.equals("")){
			MobileUtility.error("请设置文件存储路径!");
		}
		/**固定文件名用于该场景测试*/
		String fileName = FileUtil.connectFilePath(filePath, "my.png");
		
		HttpServletRequest request = ServletManager.getRequest();
		if (!ServletFileUpload.isMultipartContent(request)) {
			MobileUtility.error("获取的上传文件并非以文件流格式传送，请核查！");
			MobileUtility.error("没有检测到文件,请重新提交!");
		}
		
		//没有则存储在临时目录
		String uploadPath = param.getString("UPLOAD_PATH","temp");
		//目录转换
		uploadPath = uploadPath.replace("\\", File.separator).replace("/", File.separator);
		//获取文件需要上传到的路径
		String savePath = FileUtil.connectFilePath(ApplicationPath.getFilePath(request), "upload", uploadPath);
		//result.put("SAVE_PATH", savePath);
		
		File file = new File(savePath);
		File file = new File(filePath);
		if(! file.exists() && ! file.mkdirs()){
			MobileUtility.error("生成上传临时文件夹失败，无法进行上传操作！");
			MobileUtility.error("创建上传文件夹失败!");
		}
		
		String fileName = param.getString("FILE_NAME",String.valueOf(System.currentTimeMillis()));
		//result.put("FILE_NAME", fileName);
		
		//获得磁盘文件条目工厂
		DiskFileItemFactory factory = new DiskFileItemFactory();
        //设置暂时存放的存储室，这个存储室可以和最终存储文件的目录不同
        factory.setRepository(file);
        //设置缓存的大小，当上传文件的容量超过该缓存时，将产生临时文件并存储于临时目录中.
        factory.setSizeThreshold(5*1024*1024);
        //文件上传处理
		/*2.处理上传文件的业务逻辑*/
		IData result = new DataMap();
		DiskFileItemFactory factory = new DiskFileItemFactory(); //获得磁盘文件条目工厂
        //factory.setSizeThreshold(5*1024*1024); //设置缓存的大小。上传文件超过缓存时,将存储在临时目录中。
        //factory.setRepository(file); //设置临时存储
        ServletFileUpload upload = new ServletFileUpload(factory);
        
        OutputStream out = null;
        InputStream in = null;
        System.out.println(ApplicationPath.getFilePath(request));
		try{
        	List<?> fileList = upload.parseRequest(request);
			/*多个上传文件*/
            List<FileItem> fileList = upload.parseRequest(request);
            for(int i = 0; i < fileList.size(); i++){
            	FileItem item = (FileItem)fileList.get(i);
                //获取表单的属性名字
                String name = item.getFieldName();
                 
            	//如果获取的 表单信息是普通的文本信息
                if(item.isFormField()){
                 	//获取用户具体输入的字符串，因为表单提交过来的是字符串类型的
                 	String value = item.getString();
                    request.setAttribute(name, value);
                    //获取用户保存目录
            	FileItem item = fileList.get(i);
                String name = item.getFieldName();//获取表单的属性名
                
                /*处理表单数据*/
                if (item.isFormField()) {
                    request.setAttribute(name, item.getString());
                }else{
                	//获取路径名
	             	String value = item.getName();
	                int start = value.lastIndexOf("\\");
	                String filename = value.substring(start + 1);
	                //保存文件名
	                request.setAttribute(name, filename);
	                
	                //检查保存目录
	                File saveDir = new File(savePath);
	         		if(! saveDir.exists() && ! saveDir.mkdirs()){
	         			MobileUtility.error("生成上传保存文件夹失败，无法进行上传操作！");
	         		}
	         		//设置保存文件
	                File saveFile = new File(savePath, filename);
	                //写到磁盘上
	                OutputStream out = new FileOutputStream(saveFile);
	                InputStream in = item.getInputStream();
	                
					String value = item.getName();
					request.setAttribute(name, value); // 保存文件名
	         		/*保存文件*/
	                File uploadFile = new File(fileName);
	                out = new FileOutputStream(uploadFile);
	                in = item.getInputStream();
	                int length = 0;
	                byte[] buf = new byte[1024];
	                //写出到文件中
	                while((length = in.read(buf) ) != -1) {
	                    //在BUF数组中取出数据写到（输出流）磁盘上
	                    out.write(buf, 0, length);
	                }
	                out.flush();
	                in.close();
	                out.close();
	                log.debug("获取上传文件的总共的容量：" + item.getSize());
	                result.put("size", item.getSize());
               }
           }
	                log.debug("上传文件大小为：" + item.getSize());
                }
        	}
            result.put("FILE_NMAE", fileName);
       }catch (Exception e) {
    	   MobileUtility.error("上传失败", e);
       }finally{
    	   if(in!=null)
    		   in.close();
    	   if(out!=null)
    		   out.close();
       }
       return result;
	}*/
	/************************************************************************************
	 * 文件下载；
	 * 
	 * @param param
	 * @return
	 * @throws Exception
	 */
	/*public IData download(IData param) throws Exception{
		HttpServletRequest request = ServletManager.getRequest();
		HttpServletResponse response = ServletManager.getResponse();
		//获取文件需要上传到的路径
		String fileName = request.getParameter("FILE_PATH");
		String mineType = request.getParameter("MINE_TYPE");
		log.debug("MINE类型为：[" + mineType + "]");
//		log.debug(request.getParameter("USER_NAME"));
//		log.debug(request.getParameter("SESSION_ID"));
		//获取文件地址
		String filePath = ApplicationPath.getFilePath(request) + "upload" + File.separator + fileName;
		File file = new File(filePath);
		if(! file.isFile())
			throw new RuntimeException("上传的文件不存在，请检查文件路径！");
		response.reset();
		response.setContentType(mineType);
		InputStream in = new FileInputStream(file);
        
        int length = 0;
        byte[] buf = new byte[1024];
        //写出到文件中
        OutputStream out = response.getOutputStream();
        while((length = in.read(buf) ) != -1) {
            //在BUF数组中取出数据写到（输出流）磁盘上
        	out.write(buf, 0, length);
        }
        out.flush();
        in.close();
        out.close();
        response.flushBuffer();
		
		return null;
	}*/
	}
	
	public IData upload(IData param) throws Exception{
	    IData returnMap = new DataMap();  // 返回的对象
        HttpServletRequest request = ServletManager.getRequest();
        HttpServletResponse response = ServletManager.getResponse();
        response.setContentType("text/html;charset=UTF-8");
        response.setHeader("Cache-Control", "no-cache");
        if (!ServletFileUpload.isMultipartContent(request)) {
            MobileUtility.error("获取的上传文件并非以文件流格式传送，请核查！");
        }
        
        log.debug("【上传资源开始。。。】");
        Date date = new Date();// 获取当前时间
        SimpleDateFormat formatter = new SimpleDateFormat("yyyyMMddHHmmssSSS");
        String dateStr = formatter.format(date);
        int random = (int)(Math.random()*10000);
        String dateStr_random = dateStr+"_"+random;  //时间字符串+随机数 最后一级别的文件夹
        String path = null; // 存放数据库用 相对路径 path = typePath + dateStr_random + fileName
        String rootDir = ApplicationPath.getFilePath(request).replace("//", File.separator).replace("\\", File.separator) + "upload"; // eg:F:\eclipseWorkspace3\android-share\display-server\web
        String typePath = null;
        String filePath = null;  // 上传服务器用 绝对路径 filePath = rootDir + typePath + dateStr_random + fileName
        String fileName = null;
        BufferedInputStream in = null;
        BufferedOutputStream outStream = null;
        try {
            // 获得磁盘文件条目工厂
            FileItemFactory factory = new DiskFileItemFactory();
            // 高水平的API文件上传处理
            ServletFileUpload upload = new ServletFileUpload(factory);
            upload.setHeaderEncoding("UTF-8");
            // 获取多个上传文件
            List<?> fileList = upload.parseRequest(request);
            // 遍历上传文件写入磁盘
            Iterator<?> it = fileList.iterator();
            
            while (it.hasNext()) {
                FileItem item = (FileItem) it.next();
                if (item == null) {
                    continue;
                }
                //获取表单的属性名字
                String name = item.getFieldName();
                //如果获取的表单信息,是普通的文本信息
                if (item.isFormField()) {
                    //获取用户具体输入的字符串，因为表单提交过来的是字符串类型的
                    String value = item.getString();
                    if ("data".equals(name)) {
                        IData postData = new DataMap(value);
                        typePath = postData.getString("UPLOAD_PATH", "temp");
                        fileName = postData.getString("FILE_NAME");
                    }
                    request.setAttribute(name, value);
                    continue;
                }
                
                // 获取路径名
                String value = item.getName();
                if (value != null) {
                    // 索引到最后一个反斜杠
                    int start = value.lastIndexOf("\\");
                    // 截取 上传文件的 字符串名字，加1是 去掉反斜杠，
                    String originalFileName = value.substring(start + 1);   // 文件名称
                    if (StringUtils.isEmpty(fileName)) {
                        fileName = originalFileName;
                    } 
                    
                    String mulu = null;
                    if (hasTimeRandom) {
                        path = FileUtil.connectFilePath(typePath, dateStr_random, fileName);
                        mulu = FileUtil.connectFilePath(rootDir, typePath, dateStr_random);
                    }
                    else {
                        path = FileUtil.connectFilePath(typePath, fileName);
                        mulu = FileUtil.connectFilePath(rootDir, typePath);
                    }
                    filePath = FileUtil.connectFilePath(rootDir, path);
                    File file = new File(mulu);
                    if (!file.isDirectory()) {
                        log.debug("目录不存在，自动生成目录:" + mulu);
                        file.mkdirs();
                    }
                    in = new BufferedInputStream(item.getInputStream());// 获得文件输入流
                    outStream = new BufferedOutputStream(new FileOutputStream(new File(filePath)));// 获得文件输出流
                    long filelenth = Streams.copy(in, outStream, true);// 开始把文件写到你指定的上传文件夹
                    
                    returnMap.put("size", filelenth);
                    returnMap.put("lujing", path);
                    returnMap.put("fileName", fileName);
                    
                }
            }
            log.debug("【上传结束：】" + returnMap.toString());
        } catch (Exception e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        finally {
            if (in != null) {
                try {
                    in.close();
                }
                catch (Exception e) {
                    throw new RuntimeException(e);
                }
            }
            if (outStream != null) {
                try {
                    outStream.close();
                }
                catch (Exception e) {
                    throw new RuntimeException(e);
                }
	/*public IData download(IData param) throws Exception{
	HttpServletRequest request = ServletManager.getRequest();
	HttpServletResponse response = ServletManager.getResponse();
	//获取文件需要上传到的路径
	String fileName = request.getParameter("FILE_PATH");
	String mineType = request.getParameter("MINE_TYPE");
	log.debug("MINE类型为：[" + mineType + "]");
//	log.debug(request.getParameter("USER_NAME"));
//	log.debug(request.getParameter("SESSION_ID"));
	//获取文件地址
	String filePath = ApplicationPath.getFilePath(request) + "upload" + File.separator + fileName;
	File file = new File(filePath);
	if(! file.isFile())
		throw new RuntimeException("上传的文件不存在，请检查文件路径！");
            }
        }
       
        return returnMap;
	response.reset();
	response.setContentType(mineType);
	InputStream in = new FileInputStream(file);
    
    int length = 0;
    byte[] buf = new byte[1024];
    //写出到文件中
    OutputStream out = response.getOutputStream();
    while((length = in.read(buf) ) != -1) {
        //在BUF数组中取出数据写到（输出流）磁盘上
    	out.write(buf, 0, length);
    }
    out.flush();
    in.close();
    out.close();
    response.flushBuffer();
	
	return null;
}*/
	
	public InputStream download(IData param) throws Exception{
        HttpServletRequest request = ServletManager.getRequest();

display-server/web/biz/js/plugin/uploaddownload.js

@@ -1,33 +1,52 @@
require(["domReady!","wadeMobile", "util"], function(doc,WadeMobile) {
	var iscroll = new iScroll("content");
	var picDir = "picture";
	
	/*选择图片*/
	$("#getPicture").tap(function() {
		WadeMobile.getPicture(function(filePath){
			$("#uploadFilePath").html(filePath);
		});
	});
	
	//上传
	$("#upload").tap(function() {
		var uploadFile = $("#uploadFilePath").html();
		if(!uploadFile){
			alert("请先选择上传文件!");
			return;
		}
		/*单文件上传*/
		WadeMobile.getPicture(function(filePath){
			var params = Wade.DataMap();
			params.put("UPLOAD_PATH","photo"); // 图片上传的制定相对路径，如果没有设置，默认值temp
			params.put("FILE_NAME","my.png");   // 图片默认的名字，如果没有设置，取原图片的名字
			//服务端SESSION_ID不能为空,服务端配置verify="false"并不校验
			params.put("SESSION_ID",new Date().getTime());
			WadeMobile.uploadWithServlet(filePath, "UploadDownloadBean.upload", params.toString(), function(result){
				var data = new Wade.DataMap(result);
				alert(result);
				alert("上传文件的大小：" + data.get("size") + "字节，文件路径：" + data.get("lujing"));
				$("#fileUpload").html(data.get("lujing"));
			});
		var params = Wade.DataMap();
		params.put("FILE_PATH",picDir);
		//服务端SESSION_ID不能为空,服务端配置verify="false"并不校验
		params.put("SESSION_ID",new Date().getTime());
		WadeMobile.uploadWithServlet(uploadFile, "UploadDownloadBean.upload", params.toString(), function(result){
			alert(result);
			var data = new Wade.DataMap(result);
			alert(data);
			$("#fileUpload").html(data.get("FILE_NMAE"));
		});
		/*多文件上传*/
		//有待补充
	});
	
	//下载
	$("#download").tap(function() {
		//文件保存路径
		var savePath = "/my123.png";
		
		var savePath = picDir+"/my.png"; //支持绝对路径和相对路径
		var params = new Wade.DataMap();
		params.put("FILE_PATH", "photo/my.png");//下载文件的相对路径
		params.put("FILE_PATH", picDir);//下载文件的相对路径
		//服务端SESSION_ID不能为空,服务端配置verify="false"并不校验
		params.put("SESSION_ID",new Date().getTime());
		WadeMobile.downloadWithServlet(savePath, "UploadDownloadBean.download", params.toString(), function(result){
			$("#downloadFilePath").html(savePath);
			
			/*var width = $("#downloadPicture").width();
			var height = $("#downloadPicture").height();
			$("#downloadPicture").removeClass("e_imagePlaceHolder");
			$("#downloadPicture").html("<img height='" + height + "' width='" + width + "' src='" + path + "'/>");
			iscroll.refresh();*/
			alert(result);
		});
	});