java中zip导入

1.MultipartFile对象接收前端传入文件 

2.对zip文件进行校验

     @AutoLog(value = "设计文档-zip文件批量导入（需提前导入树结构）")
     @ApiOperation(value = "设计文档-zip文件批量导入（需提前导入树结构）", notes = "设计文档-zip文件批量导入（需提前导入树结构）")
     @RequestMapping(value = "/addZip", method = RequestMethod.POST, produces = {"application/json;charset=UTF-8"})
     @Transactional
     public ResponseEntity addZip(@RequestParam("file") MultipartFile file) {
         Result<JSONObject> result = new Result<>();
         JSONObject jsonObject = new JSONObject();
         if (file == null) {
             log.info("function=add, file is null!");
             result.error500("上传的文件为null！");
             return new ResponseEntity<Result<JSONObject>>(result, HttpStatus.BAD_REQUEST);
         }
         //校验文件大小，超过2GB不允许上传
         long fileSize = file.getSize();
         if(fileSize > CmpConstant.TWO_GB) {
             result.error500("文件大小超过2GB");
             return new ResponseEntity<Result<JSONObject>>(result, HttpStatus.BAD_REQUEST);
         }
         //MD5Util.getMD5(file);
         String md5 = "0";
         String fileName = file.getOriginalFilename();
         log.info("function=add, md5={} , fileName={}", md5, fileName);
         jsonObject.put("fileTokens", null);
         if (StringUtils.isEmpty(md5) || StringUtils.isEmpty(fileName)) {
             log.info("function=add,md5 or fileName is empty! md5={} , fileName={}", md5, fileName);
             result.error500("md5或fileName为空！");
             return new ResponseEntity<Result<JSONObject>>(result, HttpStatus.BAD_REQUEST);
         }
         int fileNameLength = fileName.length();
         if(fileNameLength > 50) {
             log.info("function=add, fileNameLength greater than 50!");
             result.error500("文件名长度超过50字节！");
             return new ResponseEntity<Result<JSONObject>>(result, HttpStatus.BAD_REQUEST);
         }

         String multipartFileName = file.getOriginalFilename();
         if (StringUtils.isEmpty(multipartFileName)) {
             log.info("function=add, multipartFileName is empty!");
             result.setResult(jsonObject);
             result.error500("上传的文件名为空！");
             return new ResponseEntity<Result<JSONObject>>(result, HttpStatus.BAD_REQUEST);
         }
         try{
             Future<designDoc> uploadResult = designDocService.fileUploadAndSave(file, md5, null,"0");
             designDoc docsignDocInstance = uploadResult.get();
             jsonObject.put("fileTokens", docsignDocInstance.getId());
             jsonObject.put("docsignDoc", docsignDocInstance);
             log.info("function=add, result JSONObject={}", jsonObject);
             result.setResult(jsonObject);
             result.success("上传成功！");
             return new ResponseEntity<Result<JSONObject>>(result, HttpStatus.CREATED);
         } catch (Exception e){
             result.error500(e.getMessage());
             result.setSuccess(false);
             return new ResponseEntity<Result<JSONObject>>(result, HttpStatus.BAD_REQUEST);
         }
     }

 

3.根据传入file，保存zip文件

File file = new File(fileSavePath);
        createFile(file);
        try {
            try {
                InputStream stream = multipartFile.getInputStream();
                FileOutputStream out = new FileOutputStream(file);
                int read;
                final byte[] bytes = new byte[1024];
                while ((read = stream.read(bytes)) != -1) {
                    out.write(bytes, 0, read);
                }

                out.flush();
                stream.close();
            } catch (Exception e) {

            }

            log.info("function=fileUploadAndSave, upload succeed!");
        } catch (Throwable e) {
            e.printStackTrace();
            log.info("function=fileUploadAndSave, upload fail!");
            return null;
        }

private void createFile(File file) {
        if (file.exists()) {
            System.out.println("exists");
        } else {
            try {
                File pf = file.getParentFile();
                if (pf == null) {
                    file.createNewFile();
                } else {
                    if (!pf.exists()) {
                        pf.mkdirs();
                    }
                    file.createNewFile();
                }
                System.out.println("mkdirs");
            } catch (Exception e) {
                System.out.println("IOException");
                e.printStackTrace();
            }

        }
    }

 

 

4.解压缩文件到指定目录

 // 解压缩文件到指定目录
        String unzipPath = fileSavePath.substring(0,fileSavePath.lastIndexOf("."));
        FileUnZip.zipToFile(fileSavePath, unzipPath);
        File modelPropPath = new File(unzipPath);
        File[] modelPropFiles = modelPropPath.listFiles();

 

5.扫描解压缩的文件，将所有模型属性数据并入库

 List<UploadFile> uploadFileList = new ArrayList<>();
        List<DesignDocTree> designDocTreeModelList = new ArrayList<>();
        List<designDoc> designdocList = new ArrayList<>();
        JSONObject codeObject = new JSONObject();
        int treeI = 0;
        for (File docsignDocFile : modelPropFiles) {
        //业务处理     
}