ruoyi-admin/src/main/java/com/ruoyi/web/controller/wisdomarbitrate/CaseApplicationController.java

@@ -96,6 +96,8 @@ public class CaseApplicationController extends BaseController {
         return toAjax(caseApplicationService.submitCaseApplication(batchCaseApplication.getIds()));
     }
 
+
+
     /**
      * 删除立案数据
      */
@@ -158,6 +160,21 @@ public class CaseApplicationController extends BaseController {
         return success(sealUrlRecordselect);
     }
 
+
+    /**
+     * 案件证据材料压缩包上传
+     *
+     * @param file      附件
+     * @param id        案件申请id
+     * @return
+     */
+    @PostMapping("/upload")
+    public AjaxResult uploadZipFile(@RequestParam("file") MultipartFile file, Long id) {
+        String username = this.getUsername();
+        Long userId = this.getUserId();
+        return caseApplicationService.uploadZipFile(file, id, username, userId);
+    }
+
     /**
      * 立案申请导入模板下载
      */

ruoyi-system/src/main/java/com/ruoyi/wisdomarbitrate/service/ICaseApplicationService.java

@@ -8,6 +8,7 @@ import com.ruoyi.wisdomarbitrate.domain.CaseApplication;
 import com.ruoyi.wisdomarbitrate.domain.SealSignRecord;
 import com.ruoyi.wisdomarbitrate.domain.vo.SendRoomNoMessageVO;
 import com.ruoyi.wisdomarbitrate.domain.vo.ToDoCount;
+import org.springframework.web.multipart.MultipartFile;
 
 import java.util.List;
 
@@ -72,4 +73,6 @@ public interface ICaseApplicationService {
      * @return
      */
     int updateCaseLockStatus(CaseApplication caseApplication);
+
+    AjaxResult uploadZipFile(MultipartFile file, Long id, String username, Long userId);
 }

ruoyi-system/src/main/java/com/ruoyi/wisdomarbitrate/service/impl/CaseApplicationServiceImpl.java

@@ -35,13 +35,14 @@ import com.ruoyi.wisdomarbitrate.domain.vo.SendRoomNoMessageVO;
 import com.ruoyi.wisdomarbitrate.mapper.*;
 import com.ruoyi.wisdomarbitrate.service.ICaseApplicationService;
 import com.ruoyi.wisdomarbitrate.utils.SignAward;
+import com.ruoyi.wisdomarbitrate.utils.UnZipFileUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.multipart.MultipartFile;
 
-import java.io.File;
+import java.io.*;
-import java.io.IOException;
 import java.math.BigDecimal;
 import java.nio.file.Files;
 import java.nio.file.Path;
@@ -84,6 +85,8 @@ public class CaseApplicationServiceImpl implements ICaseApplicationService {
     private SealSignRecordMapper sealSignRecordMapper;
     @Autowired
     private CaseLogRecordMapper caseLogRecordMapper;
+    @Autowired
+    private   CaseEvidenceDirectoryMapper caseEvidenceDirectoryMapper;
     // 手机号正则
     private static final Pattern TELEPHONE_REGX =  Pattern.compile("^1(3\\d|4[5-9]|5[0-35-9]|6[2567]|7[0-8]|8\\d|9[0-35-9])\\d{8}$");
 
@@ -247,6 +250,209 @@ public class CaseApplicationServiceImpl implements ICaseApplicationService {
         return caseApplicationMapper.updateCaseLockStatus(caseApplication.getId(),caseApplication.getLockStatus());
     }
 
+    public  void inputChangeToFile(InputStream instream, File file) {
+        try {
+            OutputStream outStr = new FileOutputStream(file);
+            int bytesRead = 0;
+            byte[] buffer = new byte[8192];
+            while ((bytesRead = instream.read(buffer, 0, 1024)) != -1) {
+                outStr.write(buffer, 0, bytesRead);
+            }
+            outStr.flush();
+            outStr.close();
+            instream.close();
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+    }
+
+    @Override
+    @Transactional
+    public AjaxResult uploadZipFile(MultipartFile file, Long id, String username, Long userId) {
+        if (file.isEmpty()) {
+            return AjaxResult.error("请选择要上传的文件");
+        }
+//        String targetPath =  "/home/ruoyi/uploadPath/upload/unzipFile";
+//        String targetPath =  "F:\\testZip\\unzipFile";
+        String targetPath =  "F:\\testZip\\unzipFile";
+        File zipFile = null;
+        InputStream ins = null;
+        try {
+            ins = file.getInputStream();
+            zipFile = new File(file.getOriginalFilename());
+            inputChangeToFile(ins, zipFile);
+        } catch (IOException e) {
+            e.printStackTrace();
+        }
+        //解压缩上传的压缩包
+        UnZipFileUtils.unZipFile(zipFile,targetPath);
+
+        //得到解压缩的所有文件
+        String zipName = file.getOriginalFilename();
+        String zipPath = "F:\\testZip\\unzipFile\\"+zipName;
+//        String zipPath =  "/home/ruoyi/uploadPath/upload/unzipFile"+zipName;
+        File dirUnzipPath = new File(zipPath);
+        List<File> allFiles = new ArrayList<>();
+        List<String> allFilestr = new ArrayList<>();
+        UnZipFileUtils.getFiles(dirUnzipPath,allFiles);
+        if(allFiles!=null&&allFiles.size()>0){
+            for (File fileIter : allFiles) {
+                System.out.println(fileIter.getAbsolutePath());
+                allFilestr.add(fileIter.getAbsolutePath());
+            }
+        }
+
+        //保存目录和文件
+        if(allFilestr!=null&&allFilestr.size()>0){
+            for (String filestr : allFilestr) {
+                List<Integer> allindex = new ArrayList<>();
+                int indexKey = filestr.indexOf("\\");
+                allindex.add(indexKey);
+                while (indexKey != -1) {
+                    indexKey = filestr.indexOf("\\", indexKey + 1);
+                    allindex.add(indexKey);
+                }
+                if(allindex!=null&&allindex.size()>0){
+                    String substrOne = filestr.substring(allindex.get(2)+1,allindex.get(3));
+                    Integer series = null;
+                    for (int i = 0; i < allindex.size()-2; i++) {
+                        String substr = filestr.substring(allindex.get(i+2)+1,allindex.get(i+3));
+                        series = i + 1;
+
+                        if(series==1){
+
+                            //查询这个级数的目录是否存在，若不存在，则新建这个目录
+                            CaseEvidenceDirectory caseEvidenceDirectoryselect = new CaseEvidenceDirectory();
+                            caseEvidenceDirectoryselect.setCaseId(id.intValue());
+                            caseEvidenceDirectoryselect.setEvidenceName(filestr.substring(allindex.get(i+2)+1,allindex.get(i+3)));
+                            caseEvidenceDirectoryselect.setSeries(series);
+                            List<CaseEvidenceDirectory>  caseEvidenceDirectorys = caseEvidenceDirectoryMapper.selectList(caseEvidenceDirectoryselect);
+                            if(caseEvidenceDirectorys!=null&&caseEvidenceDirectorys.size()>0){
+                                continue;
+                            }else {
+                                CaseEvidenceDirectory caseEvidenceDirectory = new CaseEvidenceDirectory();
+                                caseEvidenceDirectory.setEvidenceName(substr);
+                                caseEvidenceDirectory.setSeries(series);
+
+                                caseEvidenceDirectory.setCaseId(id.intValue());
+                                caseEvidenceDirectory.setCreateBy(username);
+                                caseEvidenceDirectory.setCreateTime(new Date());
+
+                                caseEvidenceDirectoryMapper.save(caseEvidenceDirectory);
+
+                            }
+                        }else {
+                            //查询这个级数的目录是否存在，若不存在，则新建这个目录
+                            CaseEvidenceDirectory directoryselect = new CaseEvidenceDirectory();
+                            directoryselect.setCaseId(id.intValue());
+                            directoryselect.setEvidenceName(filestr.substring(allindex.get(i+2)+1,allindex.get(i+3)));
+                            directoryselect.setSeries(series);
+                            List<CaseEvidenceDirectory>  evidenceDirectorys = caseEvidenceDirectoryMapper.selectList(directoryselect);
+                            if(evidenceDirectorys!=null&&evidenceDirectorys.size()>0){
+                                continue;
+                            }else {
+                                Integer parentId = null;
+                                CaseEvidenceDirectory caseEvidenceDirectoryselect = new CaseEvidenceDirectory();
+                                caseEvidenceDirectoryselect.setCaseId(id.intValue());
+                                caseEvidenceDirectoryselect.setEvidenceName(filestr.substring(allindex.get(i+1)+1,allindex.get(i+2)));
+                                caseEvidenceDirectoryselect.setSeries(series-1);
+                                List<CaseEvidenceDirectory>  caseEvidenceDirectorys = caseEvidenceDirectoryMapper.selectList(caseEvidenceDirectoryselect);
+                                if(caseEvidenceDirectorys!=null&&caseEvidenceDirectorys.size()>0){
+                                    parentId = caseEvidenceDirectorys.get(0).getId();
+                                }
+
+                                CaseEvidenceDirectory caseEvidenceDirectory = new CaseEvidenceDirectory();
+                                caseEvidenceDirectory.setEvidenceName(substr);
+                                caseEvidenceDirectory.setSeries(series);
+                                caseEvidenceDirectory.setCreateBy(username);
+                                caseEvidenceDirectory.setCreateTime(new Date());
+                                caseEvidenceDirectory.setCaseId(id.intValue());
+
+                                caseEvidenceDirectory.setParentId(parentId);
+
+                                caseEvidenceDirectoryMapper.save(caseEvidenceDirectory);
+
+                            }
+
+                        }
+                    }
+
+                    //得到最后1级的目录，即文件
+                    int lastIndex = allindex.size()-2;
+                    String substrfile = filestr.substring(lastIndex+1);
+
+                    //保存到附件表
+                    LocalDate now = LocalDate.now();
+                    String year = Integer.toString(now.getYear());
+                    String month = String.format("%02d", now.getMonthValue());
+                    String day = String.format("%02d", now.getDayOfMonth());
+//                    String saveFolderPath = "/home/ruoyi/uploadPath/upload/" + year + "/" + month + "/" + day;
+                    String saveFolderPath = "D:/data/" + year + "/" + month + "/" + day;
+                    String fileName = UUID.randomUUID().toString().replace("-", "")+ "_"  + substrfile;
+                    String resultFilePath = saveFolderPath + "/" + fileName;
+
+                    try {
+                        FileInputStream fis = new FileInputStream(new File(filestr));
+                        FileOutputStream fos = new FileOutputStream(new File(resultFilePath));
+                        byte b[] = new byte[1024];
+                        int len=0;
+                        while((len=fis.read(b))!=-1){
+                            fos.write(b);
+                        }
+
+                    } catch (IOException e) {
+                        AjaxResult.error("文件解压异常",e);
+                    }
+
+                    Integer annexType = null;
+                    if("申请书".equals(substrOne)){
+                        annexType = 1;
+                    }else if("证据材料".equals(substrOne)){
+                        annexType = 2;
+                    }
+                    String savePath = "/home/ruoyi/uploadPath/upload";
+                    String saveName = "/profile/upload/" + year + "/" + month + "/" + day + "/" + fileName;
+                    //将附件保存到附件表里
+                    CaseAttach caseAttach = CaseAttach.builder()
+                            .caseAppliId(id)
+                            .annexName(saveName)
+                            .annexPath(savePath)
+                            .annexType(annexType)
+                            .build();
+                    int i = caseAttachMapper.save(caseAttach);
+
+                    Integer annexId = caseAttach.getAnnexId();
+
+                    //保存到目录表
+                    Integer parentId = null;
+                    CaseEvidenceDirectory caseEvidenceDirectoryselect = new CaseEvidenceDirectory();
+                    caseEvidenceDirectoryselect.setCaseId(id.intValue());
+                    caseEvidenceDirectoryselect.setEvidenceName(filestr.substring(allindex.get(lastIndex)+1,allindex.get(lastIndex+1)));
+                    caseEvidenceDirectoryselect.setSeries(series-1);
+                    List<CaseEvidenceDirectory>  caseEvidenceDirectorys = caseEvidenceDirectoryMapper.selectList(caseEvidenceDirectoryselect);
+                    if(caseEvidenceDirectorys!=null&&caseEvidenceDirectorys.size()>0){
+                        parentId = caseEvidenceDirectorys.get(0).getId();
+                    }
+
+                    CaseEvidenceDirectory caseEvidenceDirectory = new CaseEvidenceDirectory();
+                    caseEvidenceDirectory.setEvidenceName(substrfile);
+                    caseEvidenceDirectory.setSeries(series);
+                    caseEvidenceDirectory.setCreateBy(username);
+                    caseEvidenceDirectory.setCreateTime(new Date());
+                    caseEvidenceDirectory.setAnnexId(annexId);
+                    caseEvidenceDirectory.setCaseId(id.intValue());
+
+                    caseEvidenceDirectory.setParentId(parentId);
+
+                    caseEvidenceDirectoryMapper.save(caseEvidenceDirectory);
+                }
+            }
+        }
+
+        return AjaxResult.success();
+
+    }
+
     private List<CaseLogRecord> getNofinishCasenode(Integer caseStatus) {
         CaseLogRecord caseLogRecord1 = new CaseLogRecord();
         caseLogRecord1.setCaseNodeName("立案审查");

ruoyi-system/src/main/java/com/ruoyi/wisdomarbitrate/utils/UnZipFileUtils.java

@@ -0,0 +1,126 @@
+package com.ruoyi.wisdomarbitrate.utils;
+
+import lombok.extern.slf4j.Slf4j;
+
+import java.io.File;
+import java.io.FileOutputStream;
+import java.io.IOException;
+import java.io.InputStream;
+import java.nio.charset.Charset;
+import java.util.ArrayList;
+import java.util.Enumeration;
+import java.util.List;
+import java.util.zip.ZipEntry;
+import java.util.zip.ZipFile;
+
+@Slf4j
+public class UnZipFileUtils {
+
+    public static void main(String[] args) {
+        // 压缩包路径
+//        String zipPath = "F:\\testZip\\zipFile\\上传申请书证据材料.zip";
+        // 解压后存放路径
+//        String targetPath =  "F:\\testZip\\unzipFile";
+//        unZipFile(new File(zipPath),targetPath);
+
+
+//        String zipPath = "F:\\testZip\\unzipFile\\上传申请书证据材料";
+//        File dirUnzipPath = new File(zipPath);
+//        List<File> allFiles = new ArrayList<>();
+//        getFiles(dirUnzipPath,allFiles);
+//        if(allFiles!=null&&allFiles.size()>0){
+//            for (File fileIter : allFiles) {
+//                System.out.println(fileIter.getName());
+//                System.out.println(fileIter.getAbsolutePath());
+//            }
+//        }
+
+         String key = "\\";
+         String str = "F:\\testZip\\上传申请书证据材料\\证据材料\\仲裁裁决书模板.docx";
+        List<Integer> allindex = new ArrayList<>();
+        int a = str.indexOf(key);//*第一个出现的索引位置
+        allindex.add(a);
+        while (a != -1) {
+            System.out.print(a + "\t");
+            a = str.indexOf(key, a + 1);//*从这个索引往后开始第一个出现的位置
+            allindex.add(a);
+        }
+        String substr = str.substring(allindex.get(1)+1,allindex.get(2));
+        System.out.println("substr---"+substr);
+
+
+    }
+
+    public static boolean unZipFile(File aboriginalFile, String targetPath) {
+        if (!aboriginalFile.exists()) {
+            log.error("此文件不存在：",aboriginalFile.getPath());
+            return false;
+        }
+        try {
+            ZipFile srcZipFile = new ZipFile(aboriginalFile, Charset.forName("GBK"));
+            for (Enumeration enumeration = srcZipFile.entries(); enumeration.hasMoreElements(); ) {
+                ZipEntry entryZip = (ZipEntry) enumeration.nextElement();
+                //若是文件夹，就创建文件夹
+                if (entryZip.isDirectory()) {
+                    String directPath = targetPath + File.separator + entryZip.getName();
+                    File directFile = new File(directPath);
+                    boolean makeDirs = directFile.mkdirs();
+                    System.out.println("创建文件夹是否成功:" +makeDirs);
+                } else {
+                    //若是文件，就创建文件
+                    File sourceFile = new File(targetPath + File.separator + entryZip.getName());
+                    if(!sourceFile.getParentFile().exists()){
+                        boolean mDirect = sourceFile.getParentFile().mkdirs();
+                        System.out.println("创建压缩文件时，创建父文件夹是否成功:" +mDirect);
+                    }
+                    boolean newUnZipFile = sourceFile.createNewFile();
+                    if (newUnZipFile){
+                        // 将压缩文件内容写入到这个文件中
+                        try{
+                            InputStream is = srcZipFile.getInputStream(entryZip);
+                            FileOutputStream fos = new FileOutputStream(sourceFile);
+                            int len;
+                            byte[] buf = new byte[2048];
+                            while ((len = is.read(buf)) != -1) {
+                                fos.write(buf, 0, len);
+                            }
+                        } catch (Exception e){
+                            log.error("解压失败",e);
+                        }
+                    }
+                }
+            }
+            return true;
+
+        } catch (IOException e) {
+            log.error("解压失败",e);
+            return false;
+        }
+
+    }
+
+
+    public static void getFiles(File fileSource, List<File> allFiles) {
+        if (!fileSource.exists()) {
+            System.out.println("目录不存在");
+            return;
+        }
+        File[] fileArray = fileSource.listFiles();
+        if(fileArray!=null&&fileArray.length>0){
+            for (File fileIter : fileArray) {
+                if (fileIter.isDirectory()) {
+                    getFiles(fileIter,allFiles);
+                }else {
+                    allFiles.add(fileIter);
+                }
+
+            }
+
+        }
+    }
+
+
+
+
+
+}