管道基础大数据平台系统开发-【后端】-Server
1
13693261870
2023-02-10 014639637a80b0549cc0aee00b9a9670fb57827c
src/main/java/com/lf/server/helper/ZipHelper.java
@@ -4,6 +4,7 @@
import org.apache.commons.logging.LogFactory;
import java.io.*;
import java.nio.charset.Charset;
import java.util.Enumeration;
import java.util.zip.ZipEntry;
import java.util.zip.ZipFile;
@@ -21,18 +22,23 @@
    private final static Log log = LogFactory.getLog(ZipHelper.class);
    /**
     * 解压缩
     * Zip解压
     *
     * @param filePath zip文件
     * @param zipDir   解压路径
     * @return 成功是/否
     */
    public static boolean unzip(String filePath, String zipDir) {
        ZipFile zipFile = null;
        try {
            int count;
            ZipFile zipfile = new ZipFile(filePath);
            File dir = new File(zipDir);
            if (!dir.exists() || !dir.isDirectory()) {
                dir.mkdirs();
            }
            Enumeration e = zipfile.entries();
            int count;
            zipFile = new ZipFile(filePath, Charset.forName("GBK"));
            Enumeration e = zipFile.entries();
            while (e.hasMoreElements()) {
                ZipEntry entry = (ZipEntry) e.nextElement();
                if (entry.isDirectory()) {
@@ -43,52 +49,65 @@
                    continue;
                }
                BufferedInputStream is = new BufferedInputStream(zipfile.getInputStream(entry));
                BufferedInputStream is = new BufferedInputStream(zipFile.getInputStream(entry));
                FileOutputStream fos = new FileOutputStream(zipDir + File.separator + entry.getName());
                BufferedOutputStream dest = new BufferedOutputStream(fos, BUFFER_SIZE);
                while ((count = is.read(BUFFER, 0, BUFFER_SIZE)) != -1) {
                    dest.write(BUFFER, 0, count);
                }
                dest.flush();
                dest.close();
                fos.close();
                is.close();
            }
            return true;
        } catch (Exception ex) {
            log.error(ex.getMessage() + ex.getStackTrace() + "\n");
            log.error(ex.getMessage(), ex);
            return false;
        } finally {
            try {
                if (null != zipFile) {
                    zipFile.close();
                }
            } catch (Exception e) {
                log.error(e.getMessage(), e);
            }
        }
    }
    /**
     * Zip压缩
     *
     * @param zipFile   Zip源文件
     * @param zipFile   zip源文件
     * @param sourceDir 源文件夹
     * @return 成功是/否
     */
    public static boolean zip(String zipFile, String sourceDir) {
        FileOutputStream fos = null;
        ZipOutputStream zos = null;
        try {
            FileOutputStream fileOutputStream = new FileOutputStream(zipFile);
            zos = new ZipOutputStream(fileOutputStream);
            fos = new FileOutputStream(zipFile);
            zos = new ZipOutputStream(fos);
            File sourceFile = new File(sourceDir);
            compress(sourceFile, zos, sourceFile.getName());
            return true;
        } catch (Exception ex) {
            log.error(ex.getMessage() + ex.getStackTrace() + "\n");
            log.error(ex.getMessage(), ex);
            return false;
        } finally {
            try {
                if (zos != null) {
                if (null != zos) {
                    zos.close();
                }
                if (null != fos) {
                    fos.close();
                }
            } catch (Exception e) {
                log.error(e.getMessage() + e.getStackTrace() + "\n");
                log.error(e.getMessage(), e);
            }
        }
    }
@@ -96,9 +115,9 @@
    /**
     * Zip压缩
     *
     * @param sourceFile Zip源文件
     * @param zos        Zip输出流
     * @param name       Zip文件名称
     * @param sourceFile zip源文件
     * @param zos        zip输出流
     * @param name       zip文件名称
     * @throws Exception
     */
    public static void compress(File sourceFile, ZipOutputStream zos, String name) throws Exception {