/*
*/
package com.***.app.mappcore.impl.util;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.FileOutputStream;
import java.io.IOException;
import java.nio.channels.FileChannel;
import com.ygsoft.ecp.service.log.EcpLogFactory;
import com.ygsoft.ecp.service.log.IEcpLog;
import com.ygsoft.ecp.service.tool.StringUtil;
/**
* 文件处理.<br>
*
* @author mapengfei <br>
* @version 1.0.0 2016年4月14日<br>
* @see
* @since JDK 1.5.0
*/
public class ForderUtil {
/**
* 日志
*/
private static final IEcpLog LOG = EcpLogFactory.getLog(ForderUtil.class);
/**
* 服务的基准路径.
*/
private static String BASE_PATH = SystemConfigUtil.get("SERVER_BASE_HOME", "FTP") + "\\ecpCloudServer\\wlp";
/**
* 服务节点的路径.
*/
private static String SERVER_PATH = BASE_PATH + "\\usr\\servers";
/**
* 根据路径删除指定的目录或文件，无论存在与否
*
* @param sPath
* 要删除的目录或文件
* @return 删除成功返回 true，否则返回 false。
*/
public static boolean deleteFolder(final String sPath) {
boolean flag = false;
File file = new File(sPath);
// 判断目录或文件是否存在
if (!file.exists()) { // 不存在返回 false
return flag;
} else {
// 判断是否为文件
if (file.isFile()) { // 为文件时调用删除文件方法
return deleteFile(sPath);
} else { // 为目录时调用删除目录方法
return deleteDirectory(sPath);
}
}
}
/**
* 删除目录（文件夹）以及目录下的文件
*
* @param sPath
* 被删除目录的文件路径
* @return 目录删除成功返回true，否则返回false
*/
private static boolean deleteDirectory(String sPath) {
// 如果sPath不以文件分隔符结尾，自动添加文件分隔符
if (!sPath.endsWith(File.separator)) {
sPath = sPath + File.separator;
}
File dirFile = new File(sPath);
// 如果dir对应的文件不存在，或者不是一个目录，则退出
if (!dirFile.exists() || !dirFile.isDirectory()) {
return false;
}
boolean flag = true;
// 删除文件夹下的所有文件(包括子目录)
File[] files = dirFile.listFiles();
for (int i = 0; i < files.length; i++) {
// 删除子文件
if (files[i].isFile()) {
flag = deleteFile(files[i].getAbsolutePath());
if (!flag)
break;
} // 删除子目录
else {
flag = deleteDirectory(files[i].getAbsolutePath());
if (!flag)
break;
}
}
if (!flag)
return false;
// 删除当前目录
if (dirFile.delete()) {
return true;
} else {
return false;
}
}
/**
* 删除单个文件
*
* @param sPath
* 被删除文件的文件名
* @return 单个文件删除成功返回true，否则返回false
*/
private static boolean deleteFile(final String sPath) {
boolean flag = false;
File file = new File(sPath);
// 路径为文件且不为空则进行删除
if (file.isFile() && file.exists()) {
file.delete();
flag = true;
}
return flag;
}
/**
* 文件通道复制方案
*
* @param s
* @param t
*/
public static void fileChannelCopy(final File from, final File to) {
// 文件输入流
FileInputStream fi = null;
// 文件输出流
FileOutputStream fo = null;
// 输入通道
FileChannel in = null;
// 输出通道
FileChannel out = null;
try {
// 读取流
fi = new FileInputStream(from);
// 输出流
fo = new FileOutputStream(to);
// 取得文件流通道
in = fi.getChannel();
out = fo.getChannel();
// 通道连接
in.transferTo(0, in.size(), out);
} catch (FileNotFoundException e) {
// 创建读出流异常
e.printStackTrace();
} catch (IOException e) {
// 通道联通出现异常
e.printStackTrace();
} finally {
try {
fi.close();
in.close();
fo.close();
out.close();
} catch (IOException e) {
// 流关闭异常
e.printStackTrace();
}
}
}
/**
* 从fromPath复制文件及目录到toPath
*
* @param fromPath
* 母体文件路径
* @param toPath
* 目标文件路径
* @param isZip
* 压缩标示
* @param zipPath
* zip压缩后的路径(该参数与isZip联合使用)
*/
public static void copyFile(String fromPath, String toPath, final String zipPath, final boolean isZip) {
// 如果sPath不以文件分隔符结尾，自动添加文件分隔符
if (!fromPath.endsWith(File.separator)) {
fromPath = fromPath + File.separator;
}
File dirFile = new File(fromPath);
mkdirsFileByPath(toPath);
if (dirFile.isDirectory()) {
// 复制文件夹下的所有文件(包括子目录)
File[] files = dirFile.listFiles();
for (int i = 0; i < files.length; i++) {
File f = files[i];
// 如果是文件
if (f.isFile()) {
File toFile = new File(toPath + "\\" + f.getName());
fileChannelCopy(f, toFile);
} else {
toPath = toPath + "\\" + f.getName();
mkdirsFileByPath(toPath);
}
}
} else {
File toFile = new File(toPath + "\\" + dirFile.getName());
fileChannelCopy(dirFile, toFile);
}
if (isZip && StringUtil.isNotEmptyString(zipPath)) {
try {
if (LOG.isDebugEnabled()) {
LOG.debug("开始压缩日志文件,压缩后的文件路径为" + fromPath + "\\" + "log.zip");
}
File zipFile = new File(zipPath);
if (zipFile.exists()) {
ForderUtil.deleteFolder(zipPath);
}
ZipMultiFile.zip(zipPath, "", toPath);
ForderUtil.deleteFolder(toPath);
} catch (Exception e) {
if (LOG.isDebugEnabled()) {
LOG.info("ForderUtil.copyFile压缩文件过程中失败");
}
e.printStackTrace();
}
} else {
if (LOG.isDebugEnabled()) {
LOG.info("ForderUtil.copyFile方法压缩标示为false或压缩路径为null" + zipPath);
}
}
}
/**
* 取得LOG日志压缩文件
*
* @param zipPath
* @param mappName
* @return
*/
public static String getLogZip(final String mappName) {
String toPath = SERVER_PATH + "\\" + mappName + "\\log";
String fromPath = SERVER_PATH + "\\" + mappName + "\\logs\\console.log";
String zipPath = SERVER_PATH + "\\" + mappName + "\\log.zip";
copyFile(fromPath, toPath, zipPath, true);
return zipPath;
}
/**
* 自动创建path
*
* @param path
* @return
*/
private static void mkdirsFileByPath(final String path) {
File toFile = new File(path);
if (!toFile.exists()) {
toFile.mkdirs();
}
}
public static void main(final String[] args) throws Exception {
String from = "D:\\ygecpcloud\\ecpCloudServer\\wlp\\usr\\servers\\mappstore\\logs";
String to = "D:\\ygecpcloud\\ecpCloudServer\\wlp\\usr\\servers\\mappstore\\log";
copyFile(from, to, "D:\\ygecpcloud\\ecpCloudServer\\wlp\\usr\\servers\\mappstore\\l.zip", true);
}
}