123

xx-universal/xx-universal-api/pom.xml

@@ -60,6 +60,18 @@
             <groupId>com.google.code.gson</groupId>
             <artifactId>gson</artifactId>
         </dependency>
+        <!--zip4j依赖,解压zip压缩-->
+        <dependency>
+            <groupId>net.lingala.zip4j</groupId>
+            <artifactId>zip4j</artifactId>
+            <version>1.3.2</version>
+        </dependency>
+        <!--解压rar压缩-->
+        <dependency>
+            <groupId>com.github.junrar</groupId>
+            <artifactId>junrar</artifactId>
+            <version>0.7</version>
+        </dependency>
     </dependencies>
 
 

xx-universal/xx-universal-api/src/main/java/com/xxfc/platform/universal/constant/enumerate/FileTypeEnum.java

+package com.xxfc.platform.universal.constant.enumerate;
+
+import lombok.AllArgsConstructor;
+import lombok.NoArgsConstructor;
+
+
+@AllArgsConstructor
+@NoArgsConstructor
+public enum FileTypeEnum {
+    FILE_TYPE_ZIP("application/zip", ".zip"),
+    FILE_TYPE_RAR("application/octet-stream", ".rar");
+    public String type;
+    public String fileStufix;
+
+    public static String getFileStufix(String type) {
+        for (FileTypeEnum orderTypeEnum : FileTypeEnum.values()) {
+            if (orderTypeEnum.type.equals(type)) {
+                return orderTypeEnum.fileStufix;
+            }
+        }
+        return null;
+    }
+
+}

xx-universal/xx-universal-api/src/main/java/com/xxfc/platform/universal/utils/UnPackeUtil.java

+package com.xxfc.platform.universal.utils;
+
+import com.github.junrar.Archive;
+import com.github.junrar.rarfile.FileHeader;
+import lombok.extern.slf4j.Slf4j;
+import net.lingala.zip4j.core.ZipFile;
+import java.io.*;
+import java.util.zip.ZipEntry;
+import java.util.zip.ZipInputStream;
+
+
+/**
+ * 解压rar/zip工具类
+ */
+@Slf4j
+public class UnPackeUtil {
+
+    /**
+     * zip文件解压
+     *
+     * @param destPath 解压文件路径
+     * @param zipFile  压缩文件
+     * @param password 解压密码(如果有)
+     */
+    public static void unPackZip(File zipFile, String password, String destPath) {
+        try {
+            ZipFile zip = new ZipFile(zipFile);
+            /*zip4j默认用GBK编码去解压,这里设置编码为GBK的*/
+            zip.setFileNameCharset("GBK");
+            log.info("begin unpack zip file....");
+            zip.extractAll(destPath);
+            // 如果解压需要密码
+            if (zip.isEncrypted()) {
+                zip.setPassword(password);
+            }
+        } catch (Exception e) {
+            log.error("unPack zip file to " + destPath + " fail ....", e.getMessage(), e);
+
+        }
+
+    }
+
+    /**
+     * rar文件解压(不支持有密码的压缩包)
+     *
+     * @param rarFile  rar压缩包
+     * @param destPath 解压保存路径
+     */
+    public static void unPackRar(File rarFile, String destPath) {
+        try (Archive archive = new Archive(rarFile)) {
+            if (null != archive) {
+                FileHeader fileHeader = archive.nextFileHeader();
+                File file = null;
+                while (null != fileHeader) {
+                    // 防止文件名中文乱码问题的处理
+                    String fileName = fileHeader.getFileNameW().isEmpty() ? fileHeader.getFileNameString() : fileHeader.getFileNameW();
+                    if (fileHeader.isDirectory()) {
+                        //是文件夹
+                        file = new File(destPath + File.separator + fileName);
+                        file.mkdirs();
+                    } else {
+                        //不是文件夹
+                        file = new File(destPath + File.separator + fileName.trim());
+                        if (!file.exists()) {
+                            if (!file.getParentFile().exists()) {
+                                // 相对路径可能多级，可能需要创建父目录.
+                                file.getParentFile().mkdirs();
+                            }
+                            file.createNewFile();
+                        }
+                        FileOutputStream os = new FileOutputStream(file);
+                        archive.extractFile(fileHeader, os);
+                        os.close();
+                    }
+                    fileHeader = archive.nextFileHeader();
+                }
+            }
+        } catch (Exception e) {
+            log.error("unpack rar file fail....", e.getMessage(), e);
+        }
+    }
+
+
+
+}
\ No newline at end of file

xx-universal/xx-universal-server/src/main/java/com/xxfc/platform/universal/config/CommonConfig.java

@@ -13,9 +13,9 @@ public class CommonConfig {
     public MultipartConfigElement multipartConfigElement() {
         MultipartConfigFactory factory = new MultipartConfigFactory();
         //  单个数据大小
-        factory.setMaxFileSize("10240KB"); // KB,MB
+        factory.setMaxFileSize("102400KB"); // KB,MB
         /// 总上传数据大小
-        factory.setMaxRequestSize("102400KB");
+        factory.setMaxRequestSize("502400KB");
         return factory.createMultipartConfig();
     }
 }
\ No newline at end of file

xx-universal/xx-universal-server/src/main/java/com/xxfc/platform/universal/controller/UploadController.java

@@ -2,9 +2,11 @@ package com.xxfc.platform.universal.controller;
 
 import com.alibaba.fastjson.JSONObject;
 import com.github.wxiaoqi.security.auth.client.annotation.IgnoreUserToken;
+import com.github.wxiaoqi.security.common.msg.ObjectRestResponse;
 import com.github.wxiaoqi.security.common.util.result.JsonResultUtil;
 import com.xxfc.platform.universal.dto.ImgDTO;
 import com.xxfc.platform.universal.dto.UploadImgDTO;
+import com.xxfc.platform.universal.service.FileUploadService;
 import com.xxfc.platform.universal.service.UploadService;
 import com.xxfc.platform.universal.utils.ImgBase64Util;
 import com.xxfc.platform.universal.utils.PublicMsg;
@@ -38,6 +40,8 @@ public class UploadController{
 
        @Autowired
        UploadService uploadService;
+        @Autowired
+        FileUploadService fileUploadService;
 
       private static Integer MAX_DRIVING_LICENSE_SIZE = 10 * 1024 * 1024;//10M
 
@@ -158,5 +162,12 @@ public class UploadController{
         ueditor.setTitle(upfile.getOriginalFilename());
         return ueditor;
     }
+
+    @RequestMapping(value="/app/unauth/zip", method = RequestMethod.POST)
+    public ObjectRestResponse zip(
+            @RequestParam("file")MultipartFile upfile,
+            @RequestParam(value = "prefix",defaultValue = "renovate")String prefix) throws Exception {
+        return fileUploadService.handlerUpload(upfile,null,prefix);
+    }
 }
 

xx-universal/xx-universal-server/src/main/java/com/xxfc/platform/universal/service/FileUploadService.java

+package com.xxfc.platform.universal.service;
+
+import com.github.wxiaoqi.security.common.msg.ObjectRestResponse;
+import org.springframework.web.multipart.MultipartFile;
+
+public interface FileUploadService {
+
+    public ObjectRestResponse handlerUpload(MultipartFile zipFile,String password,String prefix)throws Exception;
+}

xx-universal/xx-universal-server/src/main/java/com/xxfc/platform/universal/service/UploadService.java

@@ -23,7 +23,7 @@ import java.util.UUID;
 import java.util.concurrent.TimeUnit;
 
 @Service
-public class UploadService {
+public class    UploadService {
 
     public static final DateTimeFormatter DEFAULT_DATE_TIME_FORMATTER = DateTimeFormat.forPattern("yyyy-MM-dd");
     @Value("${universal.baseUploadPath}")

xx-universal/xx-universal-server/src/main/java/com/xxfc/platform/universal/service/impl/FileUploadServiceImpl.java

+package com.xxfc.platform.universal.service.impl;
+
+
+import com.github.wxiaoqi.security.common.msg.ObjectRestResponse;
+import com.github.wxiaoqi.security.common.util.process.ResultCode;
+import com.xxfc.platform.universal.constant.enumerate.FileTypeEnum;
+import com.xxfc.platform.universal.service.FileUploadService;
+import com.xxfc.platform.universal.utils.UnPackeUtil;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.stereotype.Service;
+import org.springframework.web.multipart.MultipartFile;
+
+import java.io.*;
+import java.util.zip.ZipEntry;
+import java.util.zip.ZipFile;
+import java.util.zip.ZipInputStream;
+
+
+@Service
+@Slf4j
+public class FileUploadServiceImpl  implements FileUploadService {
+
+    @Value("${universal.uploadPath}")
+    private String uploadPath ;
+    @Value("${universal.url}")
+    private String xx_url ;
+
+    @Override
+    public ObjectRestResponse handlerUpload(MultipartFile zipFile,String password,String prefix)throws Exception {
+        if (null == zipFile) {
+            return ObjectRestResponse.createFailedResult(ResultCode.FAILED_CODE,"请上传压缩文件!");
+        }
+        boolean isZipPack = true;
+        String fileContentType = zipFile.getContentType();
+        //将压缩包保存在指定路径
+        String packFilePath = uploadPath + File.separator + zipFile.getName();
+        if (FileTypeEnum.FILE_TYPE_ZIP.type.equals(fileContentType)) {
+            //zip解压缩处理
+            packFilePath += FileTypeEnum.FILE_TYPE_ZIP.fileStufix;
+        } else if (FileTypeEnum.FILE_TYPE_RAR.type.equals(fileContentType)) {
+            //rar解压缩处理
+            packFilePath += FileTypeEnum.FILE_TYPE_RAR.fileStufix;
+            isZipPack = false;
+        } else {
+            return ObjectRestResponse.createFailedResult(ResultCode.FAILED_CODE,"上传的压缩包格式不正确,仅支持rar和zip压缩文件!");
+        }
+        File file = new File(packFilePath);
+        try {
+            zipFile.transferTo(file);
+        } catch (IOException e) {
+            log.error("zip file save to " + uploadPath + " error", e.getMessage(), e);
+            return ObjectRestResponse.createFailedResult(ResultCode.FAILED_CODE,"保存压缩文件到:" + uploadPath + " 失败!");
+        }
+        if (isZipPack) {
+            //zip压缩包
+            UnPackeUtil.unPackZip(file, password, uploadPath);
+        } else {
+            //rar压缩包
+            UnPackeUtil.unPackRar(file, uploadPath);
+        }
+
+        String path=readZipFile(packFilePath);
+        if (StringUtils.isNotBlank(path)){
+            path=xx_url+"/"+prefix+"/"+path;
+            return ObjectRestResponse.succ(path);
+        }else {
+            return ObjectRestResponse.createDefaultFail();
+        }
+
+    }
+
+    public static String readZipFile(String file) throws Exception {
+        ZipFile zf = new ZipFile(file);
+        InputStream in = new BufferedInputStream(new FileInputStream(file));
+        ZipInputStream zin = new ZipInputStream(in);
+        ZipEntry ze;
+        String path=null;
+        while ((ze = zin.getNextEntry()) != null) {
+            if (ze.isDirectory()) {
+            } else {
+                path= ze.getName();
+            }
+        }
+        zin.closeEntry();
+        return path;
+    }
+
+
+
+}