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];
int len=-1;
while ((len=in.read(buffer))!=-1) {
out.write(buffer,0,len);
}
} 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 © 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
