struts2上传工具类

package com.midai.util;

import java.io.BufferedInputStream;
import java.io.BufferedOutputStream;
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.FileWriter;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.OutputStreamWriter;
import java.io.RandomAccessFile;
import java.util.Date;
import java.util.Enumeration;
import java.util.List;
import java.util.ListIterator;
import java.util.ResourceBundle;
import java.util.zip.ZipEntry;
import java.util.zip.ZipFile;
import java.util.zip.ZipOutputStream;

import org.jsoup.Jsoup;
import org.jsoup.nodes.Document;
import org.jsoup.nodes.Element;
import org.jsoup.select.Elements;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

/**
 *
 * @Description: 文件相关工具类
 * @Copyright: Copyright (c)2014-2015
 * @author: yue.yan
 * @version: $$Rev: 35 $$
 * @date: $$Date: 2014-07-25 16:12:49 +0800 (Fri, 25 Jul 2014) $$
 * @lastUpdate: $$Author$$
 *
 * Modification History:
 * Date			Author			Version			Description
 * -------------------------------------------------------------
 *
 */
public class FileUtil {
	private static final Logger logger = LoggerFactory.getLogger(FileUtil.class);
	private static final int BUFFER_SIZE = 1024;

	/**
	 * 取得文件的路径
	 * @param fileName
	 * @return String path
	 */
	public static String getFilePath(String fileName) {
		if (StringUtils.isNotBlank(fileName)) {
			fileName = fileName.replaceAll("\\\\", "/");
			return fileName.substring(0, fileName.lastIndexOf("/"));
	    }
		return "";
	}

	/**
	 * 取得文件名(不包括扩展名)
	 * @param path 文件路径
	 * @return String 不包括扩展名的文件名
	 */
	public static String getFileName(String path) {
		if (StringUtils.isNotBlank(path)) {
			path = path.replaceAll("\\\\", "/");
			if (path.contains(".")) {
				return path.substring(path.lastIndexOf("/") + 1, path.lastIndexOf("."));
			} else {
				return path.substring(path.lastIndexOf("/") + 1);
			}

		}
		return "";
	}

	/**
	 * 取得包括扩展名的文件名
	 * @param path 文件路径
	 * @return String 包括扩展名的文件名
	 */
	public static String getFileNameWithExtension(String path) {
		if (StringUtils.isNotBlank(path)) {
			path = path.replaceAll("\\\\", "/");
			return path.substring(path.lastIndexOf("/") + 1);
		}
		return "";
	}

	/**
	 * 取得文件扩展名
	 * @param path 文件路径
	 * @return String 文件扩展名
	 */
	public static String getExtension(String path) {
		if (StringUtils.isNotBlank(path)) {
			return path.substring(path.lastIndexOf(".") + 1).toLowerCase();
		}
		return "";
	}

    /**
     * <p>单个文件压缩成zip文件</p>
     * @param in 压缩文件输入流
     * @param out 压缩文件输出流
     * @param fileName 文件名
     * @return true:成功/false:失败
     */
    public static boolean zipFile(InputStream in, OutputStream out, String fileName) {
        try {
		    ZipOutputStream gzout = new ZipOutputStream(out);
		    ZipEntry entry = new ZipEntry(fileName);
		    gzout.putNextEntry( entry );

		    byte[] buf=new byte[BUFFER_SIZE];
		    int num; 

		    while ((num=in.read(buf)) != -1) {
		        gzout.write(buf,0,num);
		    }
		    gzout.close();
		    in.close();
        }catch(IOException e) {
        	logger.error(e.getMessage());
		    return false;
        }
        return true;
    }

    /**
     * <p>多文件压缩成zip文件</p>
     * @param files 待压缩文件
     * @param out 压缩文件输出流
     * @return true:成功/false:失败
     */
    public static boolean zipFile(List<File> files, OutputStream out) {
        try {
		    ZipOutputStream gzout = new ZipOutputStream(out);
		    FileInputStream in;
		    byte[] buf;
		    int num;
		    if (files != null) {
			    for (File oneFile : files) {
			    	if (!(oneFile.exists() && oneFile.canRead())) continue;
			    	in = new FileInputStream(oneFile);
			    	gzout.putNextEntry(new ZipEntry(oneFile.getName()));

				    buf=new byte[BUFFER_SIZE];

				    while ((num=in.read(buf)) != -1) {
				        gzout.write(buf,0,num);
				    }
				    in.close();
			    }
		    }
		    gzout.close();
        }catch(IOException e) {
        	logger.error(e.getMessage());
		    return false;
        }
        return true;
    }

	/**
	 * 解压ZIP文件
	 * @param file zip文件
	 * @return 解压出来的文件名
	 */
	public static String unZipFile(File file, String extension) {
		 try {
			 ZipFile zipfile = new ZipFile(file);
			 Enumeration<? extends ZipEntry> en = zipfile.entries();
			 ZipEntry entry = null;
			 String fileName = null;
			 while(en.hasMoreElements()) {
				 entry = en.nextElement();
				 if (StringUtils.isNotBlank(extension) && !getExtension(entry.getName()).equals(extension)) {
					 continue;
				 }
				 fileName = entry.getName();
				 InputStream entryis = zipfile.getInputStream(entry);
				 RandomAccessFile  fos = new RandomAccessFile (file.getPath() + entry.getName(), "rw");
				 int n;
				 byte[] bytes = new byte[BUFFER_SIZE];
				 while((n=entryis.read(bytes)) != -1) {
					 fos.write(bytes, 0, n);
				 }
				 fos.close();
				 entryis.close();
			}
			zipfile.close();
			return fileName;
		} catch (Exception e) {
			logger.error(e.getMessage());
		}
		return null;
	}

	private static void writeFile(File src, File dst) {
        try {
            InputStream in = null;
            OutputStream out = null;
            try {

                in = new BufferedInputStream(new FileInputStream(src),
                        BUFFER_SIZE);
                out = new BufferedOutputStream(new FileOutputStream(dst),
                        BUFFER_SIZE);
                byte[] buffer = new byte[BUFFER_SIZE];
                while (in.read(buffer) > 0) {
                    out.write(buffer);
                }
            } finally {
                if (null != in) {
                    in.close();
                }
                if (null != out) {
                    out.close();
                }
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

	private static void writeHtmlFile(File htmlFile, File dst) throws IOException {

		FileInputStream fr = new FileInputStream(htmlFile);
		InputStreamReader brs = new InputStreamReader(fr,"utf-8");
		BufferedReader br = new BufferedReader(brs); 

		FileOutputStream fos=new FileOutputStream(dst);
		BufferedWriter bw=new BufferedWriter(new OutputStreamWriter(fos,"UTF8")); 

        String input = null;  

        //每读一行进行一次写入动作
        while(true)
        {
        	input = br.readLine();
        	if(input == null){
        		break;
        	}
            bw.write(input);
            //newLine()方法写入与操作系统相依的换行字符,依执行环境当时的OS来决定该输出那种换行字符
            bw.newLine();
        }
        br.close();
        bw.close();
    }  

	private static void writeHtmlFile(String html, File dst) throws IOException {

		   FileWriter fw = null;
		   BufferedWriter bw = null;
		try {
			fw = new FileWriter(dst, false);
			bw = new BufferedWriter(fw);
			bw.write(html);
		} catch (IOException e) {

			e.printStackTrace();
		} finally{
			 bw.close();
	         fw.close();
		}

	}

	public static String updateFile(File upload,String uploadFileName){

		ResourceBundle rb = ResourceBundle.getBundle("init");
		String path = rb.getString("picture.path");
		Date d = new Date();
		//生产环境文件保存路径
		String fileName = d.getTime() + getFileExp(uploadFileName);
		//开发环境文件保存路径
//		String savePath="/upload"+"/" + d.getTime() + getFileExp(uploadFileName);
		//String toSrc = ServletActionContext.getServletContext().getRealPath(savePath); // 使用時間戳作為文件名
		String toSrc = path + "/" + fileName ;
		//生产环境文件保存路径
		File f = new File(path);
		//开发环境文件保存路径
//		File f = new File(ServletActionContext.getServletContext().getRealPath("upload"));
		logger.info("======================================"+toSrc+"=====================");
        // 创建文件夹
        if (!f.exists()) {
            f.mkdirs();
        }

		File toFile = new File(toSrc);
		writeFile(upload, toFile);
		return fileName;
	}
	//此方法可上传
	public static String updateWWWFile(File upload,String uploadFileName, String dir){

		ResourceBundle rb = ResourceBundle.getBundle("init");
		//String path = rb.getString("www.picture.path");
		String localPath = rb.getString("www.picture.path");
		Date d = new Date();
		//生产环境文件保存路径
		String fileName = d.getTime() + getFileExp(uploadFileName);
		//开发环境文件保存路径
//		String savePath="/upload"+"/" + d.getTime() + getFileExp(uploadFileName);
		//String toSrc = ServletActionContext.getServletContext().getRealPath(savePath); // 使用時間戳作為文件名
		if (StringUtils.isNotEmpty(dir)) {
			localPath +="/" + dir ;
		}
		String toSrc = localPath + "/" + fileName ;
		//生产环境文件保存路径
		File f = new File(localPath);
		//开发环境文件保存路径
//		File f = new File(ServletActionContext.getServletContext().getRealPath("upload"));
		logger.info("======================================"+toSrc+"=====================");
        // 创建文件夹
        if (!f.exists()) {
            f.mkdirs();
        }

		File toFile = new File(toSrc);
		writeFile(upload, toFile);

		return fileName;
	}

	//222
	public static String updateWWWHtmlFile(File upload,String uploadFileName, String dir) throws IOException{

		ResourceBundle rb = ResourceBundle.getBundle("init");
		String path = rb.getString("www.picture.path");
		Date d = new Date();
		//生产环境文件保存路径
		String fileName = d.getTime() + ".html";
		//开发环境文件保存路径
//		String savePath="/upload"+"/" + d.getTime() + getFileExp(uploadFileName);
		//String toSrc = ServletActionContext.getServletContext().getRealPath(savePath); // 使用時間戳作為文件名
		if (StringUtils.isNotEmpty(dir)) {
			path +="/" + dir ;
		}
		String toSrc = path + "/" + fileName ;
		//生产环境文件保存路径
		File f = new File(path);

		//开发环境文件保存路径
//		File f = new File(ServletActionContext.getServletContext().getRealPath("upload"));
		logger.info("======================================"+toSrc+"=====================");
        // 创建文件夹
        if (!f.exists()) {
            f.mkdirs();
        }

		File toFile = new File(toSrc);
		writeHtmlFile(upload, toFile);

		return fileName;
	}

	public static String updateWWWHtmlFile(String htmlTitle,String htmlContents, String dir) throws IOException{

		ResourceBundle rb = ResourceBundle.getBundle("init");
		String path = rb.getString("www.picture.path");
		Date d = new Date();
		//生产环境文件保存路径
		String fileName = d.getTime() + ".html";
		//开发环境文件保存路径
//		String savePath="/upload"+"/" + d.getTime() + getFileExp(uploadFileName);
		//String toSrc = ServletActionContext.getServletContext().getRealPath(savePath); // 使用時間戳作為文件名
		if (StringUtils.isNotEmpty(dir)) {
			path +="/" + dir ;
		}
		String toSrc = path + "/" + fileName ;
		//生产环境文件保存路径
		File f = new File(path);

		Document doc = Jsoup.parseBodyFragment(htmlContents);
		Elements objectEles = doc.getElementsByTag("object");

		if(objectEles != null){
			ListIterator<Element> objectElesList = objectEles.listIterator();
			if(objectElesList.hasNext()){

				Element objectEle = objectElesList.next();

				if(!"video".equals(objectEle.parent().tagName())){
					Element embedEle = objectEle.getElementsByTag("embed").get(0);
					String objectHtml = objectEle.outerHtml();
					String src = embedEle.attr("src");
					String width = objectEle.attr("width");
					String height = objectEle.attr("height");
					String videoUrl = "";
					if(StringUtils.isNotEmpty(src) && src.contains("?") && src.contains("=")){
						videoUrl = src.split("\\?")[1].split("\\=")[1];
					}else if(!src.contains("\\?")){
						videoUrl = src;
					}

					StringBuffer sb = new StringBuffer();
					sb.append("<video controls='controls' width='"+width+"' height='"+height+"' preload='auto' >");
					sb.append("<source allowfullscreen='true' quality='high' src='"+videoUrl+"' type='video/mp4'/>");
					sb.append(objectHtml);
					sb.append("您的浏览器不支持此种视频格式。");
					sb.append("</video>");
					objectEle.after(sb.toString()).nextElementSibling();
//					Element videoEle = objectEle.after(sb.toString()).nextElementSibling();
//					videoEle.attr("preload","none").attr("poster","http://www.feiliu.com/zt/img/20120417/img01.jpg");
//					videoEle.append(objectHtml);
//					videoEle.appendText("您的浏览器不支持此种视频格式。");
					objectEle.remove();
				}else{
					Element videoEle = objectEle.parent();
					videoEle.attr("preload", "auto");
//					videoEle.attr("autoplay", "autoplay");
				}

			}
		}

		String html = doc.body().html();
		StringBuffer sb = new StringBuffer("");
		sb.append("<!DOCTYPE html>");
		sb.append("<html>");
		sb.append("<head>");
		sb.append("<title>"+htmlTitle+"</title>");
		sb.append("<meta http-equiv=\"Content-Type\" content=\"text/html; charset=utf-8\" />");
		sb.append("</head>");
		sb.append("<body>");
		sb.append(html);
		sb.append("</body>");
		sb.append("</html>");
		//开发环境文件保存路径
//		File f = new File(ServletActionContext.getServletContext().getRealPath("upload"));
		logger.info("======================================"+toSrc+"=====================");
        // 创建文件夹
        if (!f.exists()) {
            f.mkdirs();
        }

		File toFile = new File(toSrc);
		writeHtmlFile(sb.toString(), toFile);

		return fileName;
	}

	// 上传文件的文件名

    private static String getFileExp(String name) {
        int pos = name.lastIndexOf(".");

        return name.substring(pos);
    }
}

/**
 * Copyright &copy; 2012-2013 <a href="https://github.com/thinkgem/jeesite">JeeSite</a> All rights reserved.
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 */
package com.midai.util;

import java.io.BufferedWriter;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.FileWriter;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.util.zip.ZipEntry;
import java.util.zip.ZipOutputStream;

import org.apache.commons.lang3.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

/**
 * 文件操作工具类
 * 实现文件的创建、删除、复制、压缩、解压以及目录的创建、删除、复制、压缩解压等功能
 * @author ThinkGem
 * @version 2013-06-21
 */
public class FileUtils extends org.apache.commons.io.FileUtils {

	private static Logger log = LoggerFactory.getLogger(FileUtils.class);

	/**
	 * 复制单个文件,如果目标文件存在,则不覆盖
	 * @param srcFileName 待复制的文件名
	 * @param descFileName 目标文件名
	 * @return 如果复制成功,则返回true,否则返回false
	 */
	public static boolean copyFile(String srcFileName, String descFileName) {
		return FileUtils.copyFileCover(srcFileName, descFileName, false);
	}

	/**
	 * 复制单个文件
	 * @param srcFileName 待复制的文件名
	 * @param descFileName 目标文件名
	 * @param coverlay 如果目标文件已存在,是否覆盖
	 * @return 如果复制成功,则返回true,否则返回false
	 */
	public static boolean copyFileCover(String srcFileName,
			String descFileName, boolean coverlay) {
		File srcFile = new File(srcFileName);
		// 判断源文件是否存在
		if (!srcFile.exists()) {
			log.debug("复制文件失败,源文件 " + srcFileName + " 不存在!");
			return false;
		}
		// 判断源文件是否是合法的文件
		else if (!srcFile.isFile()) {
			log.debug("复制文件失败," + srcFileName + " 不是一个文件!");
			return false;
		}
		File descFile = new File(descFileName);
		// 判断目标文件是否存在
		if (descFile.exists()) {
			// 如果目标文件存在,并且允许覆盖
			if (coverlay) {
				log.debug("目标文件已存在,准备删除!");
				if (!FileUtils.delFile(descFileName)) {
					log.debug("删除目标文件 " + descFileName + " 失败!");
					return false;
				}
			} else {
				log.debug("复制文件失败,目标文件 " + descFileName + " 已存在!");
				return false;
			}
		} else {
			if (!descFile.getParentFile().exists()) {
				// 如果目标文件所在的目录不存在,则创建目录
				log.debug("目标文件所在的目录不存在,创建目录!");
				// 创建目标文件所在的目录
				if (!descFile.getParentFile().mkdirs()) {
					log.debug("创建目标文件所在的目录失败!");
					return false;
				}
			}
		}

		// 准备复制文件
		// 读取的位数
		int readByte = 0;
		InputStream ins = null;
		OutputStream outs = null;
		try {
			// 打开源文件
			ins = new FileInputStream(srcFile);
			// 打开目标文件的输出流
			outs = new FileOutputStream(descFile);
			byte[] buf = new byte[1024];
			// 一次读取1024个字节,当readByte为-1时表示文件已经读取完毕
			while ((readByte = ins.read(buf)) != -1) {
				// 将读取的字节流写入到输出流
				outs.write(buf, 0, readByte);
			}
			log.debug("复制单个文件 " + srcFileName + " 到" + descFileName
					+ "成功!");
			return true;
		} catch (Exception e) {
			log.debug("复制文件失败:" + e.getMessage());
			return false;
		} finally {
			// 关闭输入输出流,首先关闭输出流,然后再关闭输入流
			if (outs != null) {
				try {
					outs.close();
				} catch (IOException oute) {
					oute.printStackTrace();
				}
			}
			if (ins != null) {
				try {
					ins.close();
				} catch (IOException ine) {
					ine.printStackTrace();
				}
			}
		}
	}

	/**
	 * 复制整个目录的内容,如果目标目录存在,则不覆盖
	 * @param srcDirName 源目录名
	 * @param descDirName 目标目录名
	 * @return 如果复制成功返回true,否则返回false
	 */
	public static boolean copyDirectory(String srcDirName, String descDirName) {
		return FileUtils.copyDirectoryCover(srcDirName, descDirName,
				false);
	}

	/**
	 * 复制整个目录的内容
	 * @param srcDirName 源目录名
	 * @param descDirName 目标目录名
	 * @param coverlay 如果目标目录存在,是否覆盖
	 * @return 如果复制成功返回true,否则返回false
	 */
	public static boolean copyDirectoryCover(String srcDirName,
			String descDirName, boolean coverlay) {
		File srcDir = new File(srcDirName);
		// 判断源目录是否存在
		if (!srcDir.exists()) {
			log.debug("复制目录失败,源目录 " + srcDirName + " 不存在!");
			return false;
		}
		// 判断源目录是否是目录
		else if (!srcDir.isDirectory()) {
			log.debug("复制目录失败," + srcDirName + " 不是一个目录!");
			return false;
		}
		// 如果目标文件夹名不以文件分隔符结尾,自动添加文件分隔符
		String descDirNames = descDirName;
		if (!descDirNames.endsWith(File.separator)) {
			descDirNames = descDirNames + File.separator;
		}
		File descDir = new File(descDirNames);
		// 如果目标文件夹存在
		if (descDir.exists()) {
			if (coverlay) {
				// 允许覆盖目标目录
				log.debug("目标目录已存在,准备删除!");
				if (!FileUtils.delFile(descDirNames)) {
					log.debug("删除目录 " + descDirNames + " 失败!");
					return false;
				}
			} else {
				log.debug("目标目录复制失败,目标目录 " + descDirNames + " 已存在!");
				return false;
			}
		} else {
			// 创建目标目录
			log.debug("目标目录不存在,准备创建!");
			if (!descDir.mkdirs()) {
				log.debug("创建目标目录失败!");
				return false;
			}

		}

		boolean flag = true;
		// 列出源目录下的所有文件名和子目录名
		File[] files = srcDir.listFiles();
		for (int i = 0; i < files.length; i++) {
			// 如果是一个单个文件,则直接复制
			if (files[i].isFile()) {
				flag = FileUtils.copyFile(files[i].getAbsolutePath(),
						descDirName + files[i].getName());
				// 如果拷贝文件失败,则退出循环
				if (!flag) {
					break;
				}
			}
			// 如果是子目录,则继续复制目录
			if (files[i].isDirectory()) {
				flag = FileUtils.copyDirectory(files[i]
						.getAbsolutePath(), descDirName + files[i].getName());
				// 如果拷贝目录失败,则退出循环
				if (!flag) {
					break;
				}
			}
		}

		if (!flag) {
			log.debug("复制目录 " + srcDirName + " 到 " + descDirName + " 失败!");
			return false;
		}
		log.debug("复制目录 " + srcDirName + " 到 " + descDirName + " 成功!");
		return true;

	}

	/**
	 *
	 * 删除文件,可以删除单个文件或文件夹
	 *
	 * @param fileName 被删除的文件名
	 * @return 如果删除成功,则返回true,否是返回false
	 */
	public static boolean delFile(String fileName) {
 		File file = new File(fileName);
		if (!file.exists()) {
			log.debug(fileName + " 文件不存在!");
			return true;
		} else {
			if (file.isFile()) {
				return FileUtils.deleteFile(fileName);
			} else {
				return FileUtils.deleteDirectory(fileName);
			}
		}
	}

	/**
	 *
	 * 删除单个文件
	 *
	 * @param fileName 被删除的文件名
	 * @return 如果删除成功,则返回true,否则返回false
	 */
	public static boolean deleteFile(String fileName) {
		File file = new File(fileName);
		if (file.exists() && file.isFile()) {
			if (file.delete()) {
				log.debug("删除单个文件 " + fileName + " 成功!");
				return true;
			} else {
				log.debug("删除单个文件 " + fileName + " 失败!");
				return false;
			}
		} else {
			log.debug(fileName + " 文件不存在!");
			return true;
		}
	}

	/**
	 *
	 * 删除目录及目录下的文件
	 *
	 * @param dirName 被删除的目录所在的文件路径
	 * @return 如果目录删除成功,则返回true,否则返回false
	 */
	public static boolean deleteDirectory(String dirName) {
		String dirNames = dirName;
		if (!dirNames.endsWith(File.separator)) {
			dirNames = dirNames + File.separator;
		}
		File dirFile = new File(dirNames);
		if (!dirFile.exists() || !dirFile.isDirectory()) {
			log.debug(dirNames + " 目录不存在!");
			return true;
		}
		boolean flag = true;
		// 列出全部文件及子目录
		File[] files = dirFile.listFiles();
		for (int i = 0; i < files.length; i++) {
			// 删除子文件
			if (files[i].isFile()) {
				flag = FileUtils.deleteFile(files[i].getAbsolutePath());
				// 如果删除文件失败,则退出循环
				if (!flag) {
					break;
				}
			}
			// 删除子目录
			else if (files[i].isDirectory()) {
				flag = FileUtils.deleteDirectory(files[i]
						.getAbsolutePath());
				// 如果删除子目录失败,则退出循环
				if (!flag) {
					break;
				}
			}
		}

		if (!flag) {
			log.debug("删除目录失败!");
			return false;
		}
		// 删除当前目录
		if (dirFile.delete()) {
			log.debug("删除目录 " + dirName + " 成功!");
			return true;
		} else {
			log.debug("删除目录 " + dirName + " 失败!");
			return false;
		}

	}

	/**
	 * 创建单个文件
	 * @param descFileName 文件名,包含路径
	 * @return 如果创建成功,则返回true,否则返回false
	 */
	public static boolean createFile(String descFileName) {
		File file = new File(descFileName);
		if (file.exists()) {
			log.debug("文件 " + descFileName + " 已存在!");
			return false;
		}
		if (descFileName.endsWith(File.separator)) {
			log.debug(descFileName + " 为目录,不能创建目录!");
			return false;
		}
		if (!file.getParentFile().exists()) {
			// 如果文件所在的目录不存在,则创建目录
			if (!file.getParentFile().mkdirs()) {
				log.debug("创建文件所在的目录失败!");
				return false;
			}
		}

		// 创建文件
		try {
			if (file.createNewFile()) {
				log.debug(descFileName + " 文件创建成功!");
				return true;
			} else {
				log.debug(descFileName + " 文件创建失败!");
				return false;
			}
		} catch (Exception e) {
			e.printStackTrace();
			log.debug(descFileName + " 文件创建失败!");
			return false;
		}

	}

	/**
	 * 创建目录
	 * @param descDirName 目录名,包含路径
	 * @return 如果创建成功,则返回true,否则返回false
	 */
	public static boolean createDirectory(String descDirName) {
		String descDirNames = descDirName;
		if (!descDirNames.endsWith(File.separator)) {
			descDirNames = descDirNames + File.separator;
		}
		File descDir = new File(descDirNames);
		if (descDir.exists()) {
			log.debug("目录 " + descDirNames + " 已存在!");
			return false;
		}
		// 创建目录
		if (descDir.mkdirs()) {
			log.debug("目录 " + descDirNames + " 创建成功!");
			return true;
		} else {
			log.debug("目录 " + descDirNames + " 创建失败!");
			return false;
		}

	}

	/**
	 * 压缩文件或目录
	 * @param srcDirName 压缩的根目录
	 * @param fileName 根目录下的待压缩的文件名或文件夹名,其中*或""表示跟目录下的全部文件
	 * @param descFileName 目标zip文件
	 */
	public static void zipFiles(String srcDirName, String fileName,
			String descFileName) {
		// 判断目录是否存在
		if (srcDirName == null) {
			log.debug("文件压缩失败,目录 " + srcDirName + " 不存在!");
			return;
		}
		File fileDir = new File(srcDirName);
		if (!fileDir.exists() || !fileDir.isDirectory()) {
			log.debug("文件压缩失败,目录 " + srcDirName + " 不存在!");
			return;
		}
		String dirPath = fileDir.getAbsolutePath();
		File descFile = new File(descFileName);
		try {
			ZipOutputStream zouts = new ZipOutputStream(new FileOutputStream(
					descFile));
			if ("*".equals(fileName) || "".equals(fileName)) {
				FileUtils.zipDirectoryToZipFile(dirPath, fileDir, zouts);
			} else {
				File file = new File(fileDir, fileName);
				if (file.isFile()) {
					FileUtils.zipFilesToZipFile(dirPath, file, zouts);
				} else {
					FileUtils
							.zipDirectoryToZipFile(dirPath, file, zouts);
				}
			}
			zouts.close();
			log.debug(descFileName + " 文件压缩成功!");
		} catch (Exception e) {
			log.debug("文件压缩失败:" + e.getMessage());
			e.printStackTrace();
		}

	}

	/**
	 * 将目录压缩到ZIP输出流
	 * @param dirPath 目录路径
	 * @param fileDir 文件信息
	 * @param zouts 输出流
	 */
	public static void zipDirectoryToZipFile(String dirPath, File fileDir,
			ZipOutputStream zouts) {
		if (fileDir.isDirectory()) {
			File[] files = fileDir.listFiles();
			// 空的文件夹
			if (files.length == 0) {
				// 目录信息
				ZipEntry entry = new ZipEntry(getEntryName(dirPath, fileDir));
				try {
					zouts.putNextEntry(entry);
					zouts.closeEntry();
				} catch (Exception e) {
					e.printStackTrace();
				}
				return;
			}

			for (int i = 0; i < files.length; i++) {
				if (files[i].isFile()) {
					// 如果是文件,则调用文件压缩方法
					FileUtils
							.zipFilesToZipFile(dirPath, files[i], zouts);
				} else {
					// 如果是目录,则递归调用
					FileUtils.zipDirectoryToZipFile(dirPath, files[i],
							zouts);
				}
			}

		}

	}

	/**
	 * 将文件压缩到ZIP输出流
	 * @param dirPath 目录路径
	 * @param file 文件
	 * @param zouts 输出流
	 */
	public static void zipFilesToZipFile(String dirPath, File file,
			ZipOutputStream zouts) {
		FileInputStream fin = null;
		ZipEntry entry = null;
		// 创建复制缓冲区
		byte[] buf = new byte[4096];
		int readByte = 0;
		if (file.isFile()) {
			try {
				// 创建一个文件输入流
				fin = new FileInputStream(file);
				// 创建一个ZipEntry
				entry = new ZipEntry(getEntryName(dirPath, file));
				// 存储信息到压缩文件
				zouts.putNextEntry(entry);
				// 复制字节到压缩文件
				while ((readByte = fin.read(buf)) != -1) {
					zouts.write(buf, 0, readByte);
				}
				zouts.closeEntry();
				fin.close();
				System.out
						.println("添加文件 " + file.getAbsolutePath() + " 到zip文件中!");
			} catch (Exception e) {
				e.printStackTrace();
			}
		}

	}

	/**
	 * 获取待压缩文件在ZIP文件中entry的名字,即相对于跟目录的相对路径名
	 * @param dirPath 目录名
	 * @param file entry文件名
	 * @return
	 */
	private static String getEntryName(String dirPath, File file) {
		String dirPaths = dirPath;
		if (!dirPaths.endsWith(File.separator)) {
			dirPaths = dirPaths + File.separator;
		}
		String filePath = file.getAbsolutePath();
		// 对于目录,必须在entry名字后面加上"/",表示它将以目录项存储
		if (file.isDirectory()) {
			filePath += "/";
		}
		int index = filePath.indexOf(dirPaths);

		return filePath.substring(index + dirPaths.length());
	}

	public static String getAbsolutePath(String urlPath) {
		if(StringUtils.isBlank(urlPath)) {
			return "";
		} else {
			return SpringContextHolder.getRootRealPath() + urlPath.substring(urlPath.indexOf("/", 1), urlPath.length());
		}
	}

	/**
	 * 将内容写入文件
	 * @param content
	 * @param filePath
	 */
	public static void writeFile(String content, String filePath) {
		try {
			if (FileUtils.createFile(filePath)){
				FileWriter fileWriter = new FileWriter(filePath, true);
				BufferedWriter bufferedWriter = new BufferedWriter(fileWriter);
				bufferedWriter.write(content);
				bufferedWriter.close();
				fileWriter.close();
			}else{
				log.info("生成失败,文件已存在!");
			}
		} catch (Exception e) {
			e.printStackTrace();
		}
	}

}
package com.midai.action.information;

import java.io.File;
import java.io.IOException;
import java.util.ResourceBundle;

import org.apache.commons.lang.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;

import bsh.StringUtil;

import com.midai.action.BaseAction;
import com.midai.pojo.Information;
import com.midai.service.IInformationService;
import com.midai.util.Constants;
import com.midai.util.FileUtil;
import com.midai.util.SerializeUtils;

public class InformationAction extends BaseAction {

	private static final long serialVersionUID = 1L;
	@Autowired
	private IInformationService informationService;
	private String infoID;
	private Information info;

	//旧路径
	private String appImgOldURL;
	private String pcImgOldURL;
	private String appHtmlOldURL;
	private String pcHtmlOldURL;

	//上传图片属性
	private File appImg;
	private String appImgContentType;
	private String appImgFileName;

	private File pcImg;
	private String pcImgContentType;
	private String pcImgFileName;

	private File appHtml;
	private String appHtmlContentType;
	private String appHtmlFileName;

	private File pcHtml;
	private String pcHtmlContentType;
	private String pcHtmlFileName;

	/**
	 * 上传文件大小验证 默认为2M
	 * */
	public void validateAddInformation(){
		if(this.appImg!=null){
			if(this.appImg.length()>Constants.MAXSIZE){
				this.addFieldError("appImg", "手机端图片不能超过2M");
			}
		}
		if(this.pcImg!=null){
			if(this.pcImg.length()>Constants.MAXSIZE){
				this.addFieldError("pcImg", "电脑端图片不能超过2M");
			}
		}
		if(this.appHtml!=null){
			if(this.appHtml.length()>Constants.MAXSIZE){
				this.addFieldError("appHtml", "手机端网页不能超过2M");
			}
		}
		if(this.pcHtml!=null){
			if(this.pcHtml.length()>Constants.MAXSIZE){
				this.addFieldError("pcHtml", "电脑端网页不能超过2M");
			}
		}
	}
	/**
	 * 添加公司新闻资讯
	 * @return
	 */
	public String addInformation(){
		try {
			if(info==null){
				info=new Information();
			}
			ResourceBundle rb = ResourceBundle.getBundle("init");
			String path = rb.getString("www.picture.path.read");
			String localPath = rb.getString("www.picture.path");
			if("1".equals(info.getUpdateFlg())){
				if (this.appImg!=null) {
					String fileName = FileUtil.updateWWWFile(this.appImg,this.appImgFileName,Constants.UPLOAD_INFO_APP_PICTURE);
					info.setAppImgURL(path+"/"+Constants.UPLOAD_INFO_APP_PICTURE+"/" + fileName);
					File oldFile = new File(localPath+"/"+Constants.UPLOAD_INFO_APP_PICTURE+"/"+FileUtil.getFileNameWithExtension(appImgOldURL));
					if(oldFile.isFile() || oldFile.exists()){
						oldFile.delete();
					};
				}else{
					if(StringUtils.isNotEmpty(appImgOldURL)){
						info.setAppImgURL(path+"/"+Constants.UPLOAD_INFO_APP_PICTURE+"/"+FileUtil.getFileNameWithExtension(appImgOldURL));
					}
				}
				if (this.pcImg!=null) {
					String fileName = FileUtil.updateWWWFile(this.pcImg,this.pcImgFileName,Constants.UPLOAD_INFO_PC_PICTURE);
					info.setPcImgURL(path+"/"+Constants.UPLOAD_INFO_PC_PICTURE+"/" + fileName);
					File oldFile = new File(localPath+"/"+Constants.UPLOAD_INFO_PC_PICTURE+"/"+FileUtil.getFileNameWithExtension(pcImgOldURL));
					if(oldFile.isFile() || oldFile.exists()){
						oldFile.delete();
					};
				}else{
					if(StringUtils.isNotEmpty(pcImgOldURL)){
						info.setPcImgURL(path+"/"+Constants.UPLOAD_INFO_PC_PICTURE+"/"+FileUtil.getFileNameWithExtension(pcImgOldURL));
					}
				}
				if (this.appHtml!=null) {
					String fileName = FileUtil.updateWWWFile(this.appHtml,this.appHtmlFileName,Constants.UPLOAD_INFO_APP_HTML);
					info.setAppHtmlURL(path+"/"+Constants.UPLOAD_INFO_APP_HTML+"/" + fileName);
					File oldFile = new File(localPath+"/"+Constants.UPLOAD_INFO_APP_HTML+"/"+FileUtil.getFileNameWithExtension(appHtmlOldURL));
					if(oldFile.isFile() || oldFile.exists()){
						oldFile.delete();
					};
				}else{
					if(StringUtils.isNotEmpty(appHtmlOldURL)){
						info.setAppHtmlURL(path+"/"+Constants.UPLOAD_INFO_APP_HTML+"/"+FileUtil.getFileNameWithExtension(appHtmlOldURL));
					}
				}
				if (this.pcHtml!=null) {
					String fileName = FileUtil.updateWWWFile(this.pcHtml,this.pcHtmlFileName,Constants.UPLOAD_INFO_PC_HTML);
					info.setPcHtmlURL(path+"/"+Constants.UPLOAD_INFO_PC_HTML+"/" + fileName);
					File oldFile = new File(localPath+"/"+Constants.UPLOAD_INFO_PC_HTML+"/"+FileUtil.getFileNameWithExtension(pcHtmlOldURL));
					if(oldFile.isFile() || oldFile.exists()){
						oldFile.delete();
					};
				}else{
					if(StringUtils.isNotEmpty(pcHtmlOldURL)){
						info.setPcHtmlURL(path+"/"+Constants.UPLOAD_INFO_PC_HTML+"/"+FileUtil.getFileNameWithExtension(pcHtmlOldURL));
					}
				}
				informationService.updateInformation(info);
			}else{
				if (this.appImg!=null) {
					String fileName = FileUtil.updateWWWFile(this.appImg,this.appImgFileName,Constants.UPLOAD_INFO_APP_PICTURE);
					info.setAppImgURL(path+"/"+Constants.UPLOAD_INFO_APP_PICTURE+"/" + fileName);
				}
				if (this.pcImg!=null) {
					String fileName = FileUtil.updateWWWFile(this.pcImg,this.pcImgFileName,Constants.UPLOAD_INFO_PC_PICTURE);
					info.setPcImgURL(path+"/"+Constants.UPLOAD_INFO_PC_PICTURE+"/" + fileName);
				}
				if (this.appHtml!=null) {
					String fileName = FileUtil.updateWWWFile(this.appHtml,this.appHtmlFileName,Constants.UPLOAD_INFO_APP_HTML);
					info.setAppHtmlURL(path+"/"+Constants.UPLOAD_INFO_APP_HTML+"/" + fileName);
				}
				if (this.pcHtml!=null) {
					String fileName = FileUtil.updateWWWFile(this.pcHtml,this.pcHtmlFileName,Constants.UPLOAD_INFO_PC_HTML);
					info.setPcHtmlURL(path+"/"+Constants.UPLOAD_INFO_PC_HTML+"/" + fileName);
				}
				informationService.addInfo(info);
			}
		} catch (Exception e) {
			e.printStackTrace();
		}
		return SUCCESS;
	}
}

Java国际软件交流中心 398918539

时间: 2024-07-30 22:43:05

struts2上传工具类的相关文章

spring mvc 文件上传工具类

虽然文件上传在框架中,已经不是什么困难的事情了,但自己还是开发了一个文件上传工具类,是基于springmvc文件上传的. 工具类只需要传入需要的两个参数,就可以上传到任何想要上传的路径: 参数1:HttpServletRequest request 参数2:String storePath   //文件存储相对路径 ,例如:"/upload","/image","/local/file" 返回值:上传到服务器的相对路径 一:代码实现 import

文件上传工具类 UploadUtil.java

package com.util; 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.util

文件上传工具类——傻瓜式上传文件

转载请注明原文地址:http://www.cnblogs.com/ygj0930/p/6128382.html 在前面  (http://www.cnblogs.com/ygj0930/p/6073505.html)  我们提到过Javaweb开发的文件上传功能的实现,需要借助第三方jar包,并且要创建factory呀.设置临时文件区路径呀等等,十分繁琐.而作为一个开发人员,不可能每次实现文件上传时都从头到尾做那么多工序.这时候,我们可以把这些繁琐的工作封装起来,把一个个功能做成以供调用的方法.

文件上传工具类(重命名,以及判断类型)

public class FileUploadUtil {     public static final List<String> ALLOW_TYPES = Arrays.asList(             "image/jpg","image/jpeg","image/png","image/gif"     ); //文件重命名     public static String rename(Strin

PHP 图片上传工具类(支持多文件上传)

====================ImageUploadTool======================== <?php class ImageUploadTool { private $file; //文件信息 private $fileList; //文件列表 private $inputName; //标签名称 private $uploadPath; //上传路径 private $fileMaxSize; //最大尺寸 private $uploadFiles; //上传文件

iOS开发 - 封装文件上传工具类

文件上传的步骤 1.设置请求头 * 目的:告诉服务器请求体里面的内容并非普通的参数,而是包含了文件参数 [request setValue:@"multipart/form-data; boundary=maljob" forHTTPHeaderField:@"Content-Type"]; 2.设置请求体 * 作用:存放参数(文件参数和非文件参数) 1> 非文件参数 [body appendData:MalJobEncode(@"--maljob\

ASP.NET 图片上传工具类 upload image简单好用功能齐全

使用方法: UploadImage ui = new UploadImage(); //可选参数 //ui.SetWordWater = "哈哈";//文字水印 ui.SetPicWater = Server.MapPath("2.png");//图片水印(图片和文字都赋值图片有效) ui.SetPositionWater = 4;//水印图片的位置 0居中.1左上角.2右上角.3左下角.4右下角 ui.SetSmallImgHeight = "110,4

FileUploadUtil----文件上传工具类

1 package com.gootrip.util; 2 3 import java.io.File; 4 import java.util.*; 5 import org.apache.commons.fileupload.*; 6 import javax.servlet.http.HttpServletRequest; 7 import java.util.regex.Pattern; 8 import java.io.IOException; 9 import org.apache.c

springboot图片上传工具类

package com.wiscom.ism.webapi.ismUtil; import org.apache.commons.io.FileUtils; import org.springframework.stereotype.Component; import org.springframework.util.ResourceUtils; import java.io.File; import java.io.FileNotFoundException; import java.io.I