SH-Arbitrate/Arbitrate-Backend
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

实现解析压缩包 #143

Merged
qtz merged 5 commits from qtz3 into dev 2023-10-24 08:38:41 +00:00
Conversation 0 Commits 5 Files Changed 4
+120 -36
1 changed files with 120 additions and 36 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Showing only changes of commit f776276eb5 - Show all commits
ruoyi-system/src/main/java/com/ruoyi/wisdomarbitrate/service/impl/CaseApplicationServiceImpl.java
+104 -20
View File
@@ -255,7 +255,7 @@ public class CaseApplicationServiceImpl implements ICaseApplicationService {
OutputStream outStr = new FileOutputStream(file); OutputStream outStr = new FileOutputStream(file);
int bytesRead = 0; int bytesRead = 0;
byte[] buffer = new byte[8192]; byte[] buffer = new byte[8192];
while ((bytesRead = instream.read(buffer, 0, 8192)) != -1) { while ((bytesRead = instream.read(buffer, 0, 1024)) != -1) {
outStr.write(buffer, 0, bytesRead); outStr.write(buffer, 0, bytesRead);
} }
outStr.flush(); outStr.flush();
@@ -301,6 +301,7 @@ public class CaseApplicationServiceImpl implements ICaseApplicationService {
} }
} }
//保存目录和文件
if(allFilestr!=null&&allFilestr.size()>0){ if(allFilestr!=null&&allFilestr.size()>0){
for (String filestr : allFilestr) { for (String filestr : allFilestr) {
List<Integer> allindex = new ArrayList<>(); List<Integer> allindex = new ArrayList<>();
@@ -311,12 +312,23 @@ public class CaseApplicationServiceImpl implements ICaseApplicationService {
allindex.add(indexKey); allindex.add(indexKey);
} }
if(allindex!=null&&allindex.size()>0){ 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++) { for (int i = 0; i < allindex.size()-2; i++) {
//得到第2个 \ 和 第3个 \ 之间的目录 为一级（i+1）目录，
String substr = filestr.substring(allindex.get(i+1)+1,allindex.get(i+2)); String substr = filestr.substring(allindex.get(i+1)+1,allindex.get(i+2));
Integer series = i + 1; series = i + 1;
Integer idcaseEvidenceDirectory = null;
if(series==1){ if(series==1){
//查询这个级数的目录是否存在，若不存在，则新建这个目录
CaseEvidenceDirectory caseEvidenceDirectoryselect = new CaseEvidenceDirectory();
// caseEvidenceDirectoryselect.setCaseid(id);
caseEvidenceDirectoryselect.setEvidenceName(filestr.substring(allindex.get(i+1)+1,allindex.get(i+2)));
caseEvidenceDirectoryselect.setSeries(series);
List<CaseEvidenceDirectory> caseEvidenceDirectorys = caseEvidenceDirectoryMapper.selectList(caseEvidenceDirectoryselect);
if(caseEvidenceDirectorys!=null&&caseEvidenceDirectorys.size()>0){
continue;
}else {
CaseEvidenceDirectory caseEvidenceDirectory = new CaseEvidenceDirectory(); CaseEvidenceDirectory caseEvidenceDirectory = new CaseEvidenceDirectory();
caseEvidenceDirectory.setEvidenceName(substr); caseEvidenceDirectory.setEvidenceName(substr);
caseEvidenceDirectory.setSeries(series); caseEvidenceDirectory.setSeries(series);
@@ -326,42 +338,114 @@ public class CaseApplicationServiceImpl implements ICaseApplicationService {
caseEvidenceDirectory.setCreateTime(new Date()); caseEvidenceDirectory.setCreateTime(new Date());
caseEvidenceDirectoryMapper.save(caseEvidenceDirectory); caseEvidenceDirectoryMapper.save(caseEvidenceDirectory);
idcaseEvidenceDirectory = caseEvidenceDirectory.getId();
}
}else { }else {
//查询这个级数的目录是否存在，若不存在，则新建这个目录
CaseEvidenceDirectory directoryselect = new CaseEvidenceDirectory();
// directoryselect.setCaseid(id);
directoryselect.setEvidenceName(filestr.substring(allindex.get(i+1)+1,allindex.get(i+2)));
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);
caseEvidenceDirectoryselect.setEvidenceName(filestr.substring(allindex.get(i)+1,allindex.get(i+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 caseEvidenceDirectory = new CaseEvidenceDirectory();
caseEvidenceDirectory.setEvidenceName(substr); caseEvidenceDirectory.setEvidenceName(substr);
caseEvidenceDirectory.setSeries(series); caseEvidenceDirectory.setSeries(series);
caseEvidenceDirectory.setCreateBy(username);
caseEvidenceDirectory.setCreateTime(new Date());
//caseEvidenceDirectory.setCaseid(id);
caseEvidenceDirectory.setParentId(idcaseEvidenceDirectory); caseEvidenceDirectory.setParentId(parentId);
caseEvidenceDirectoryMapper.save(caseEvidenceDirectory); caseEvidenceDirectoryMapper.save(caseEvidenceDirectory);
}
} }
//通过 案件id 和 目录表 的各个层级的 级数 和 目录名称 查询目录表
//判断这个级数的目录是否已经在目录表中存在，
//若存在，不用新建这个目录，
//若不存在，则新建这个目录
//保存到目录表
} }
int lastIndex = allindex.size();
//得到 最后1个 \ 之后的目录 为文件名， //得到最后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);
caseEvidenceDirectoryselect.setEvidenceName(filestr.substring(allindex.get(lastIndex-1)+1,allindex.get(lastIndex)));
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);
caseEvidenceDirectory.setParentId(parentId);
caseEvidenceDirectoryMapper.save(caseEvidenceDirectory);
}
}
} }
return AjaxResult.success(); return AjaxResult.success();