|
package org.springblade.mdm.test;
|
|
import com.github.xiaoymin.knife4j.annotations.ApiOperationSupport;
|
import io.swagger.v3.oas.annotations.Operation;
|
import io.swagger.v3.oas.annotations.Parameter;
|
import io.swagger.v3.oas.annotations.tags.Tag;
|
import lombok.AllArgsConstructor;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springblade.core.oss.OssTemplate;
|
import org.springblade.core.tenant.annotation.NonDS;
|
import org.springblade.core.tool.api.R;
|
import org.springblade.core.tool.utils.FileUtil;
|
import org.springframework.web.bind.annotation.GetMapping;
|
import org.springframework.web.bind.annotation.RequestMapping;
|
import org.springframework.web.bind.annotation.RestController;
|
|
import java.io.*;
|
import java.net.URI;
|
import java.nio.file.*;
|
import java.util.*;
|
import java.util.zip.ZipEntry;
|
import java.util.zip.ZipFile;
|
import java.util.zip.ZipInputStream;
|
|
/**
|
* 流程管理接口
|
*
|
* @author Chill
|
*/
|
@NonDS
|
@RestController
|
@RequestMapping("/test/")
|
@AllArgsConstructor
|
@Tag(name = "MDM系统接口", description = "引入blade-system的接口")
|
@Slf4j
|
public class OssTestController {
|
private final OssTemplate ossTemplate;
|
@GetMapping("/readzip")
|
@ApiOperationSupport(order = 2)
|
@Operation(summary = "读zip")
|
public R<String> readzip(@Parameter(description = "机构父节点id") Long deptId) throws IOException {
|
R<String> r = R.data("");
|
InputStream inputStream = new FileInputStream("d:/spd.zip");
|
byte[] zipData = FileUtil.copyToByteArray(inputStream);
|
Path tempFile = Files.createTempFile("tempzip", ".zip");
|
// 写入字节数据到临时文件
|
Files.write(tempFile, zipData, StandardOpenOption.WRITE);
|
|
Map<String, String> env = new HashMap<>();
|
env.put("create", "true");
|
URI uri = URI.create("jar:file:/inmemory.zip");
|
List<String> entryNameList = new ArrayList<>();
|
String entryn = "CP1-13-1/CP1-13-1-1-1-1.txt";
|
try (ZipFile zipFile = new ZipFile(tempFile.toFile())) {
|
Enumeration<? extends ZipEntry> entris = zipFile.entries();
|
ZipEntry entry;
|
while(entris.hasMoreElements()) {
|
entry = entris.nextElement();
|
entryNameList.add(entry.getName());
|
}
|
//便利完成直接取树
|
entry = zipFile.getEntry(entryn);
|
InputStream ins = zipFile.getInputStream(entry);
|
Path outputPath = Paths.get("d:/downtest.txt");
|
Files.copy(ins, outputPath, StandardCopyOption.REPLACE_EXISTING);
|
}
|
|
System.out.println(entryNameList);
|
|
/*
|
try (ZipFile zipFile = new ZipFile(tempFile.toFile())) {
|
ZipEntry entry = zipFile.getEntry(entryn);
|
InputStream ins = zipFile.getInputStream(entry);
|
|
Path outputPath = Paths.get("d:/downtest.txt");
|
Files.copy(ins, outputPath, StandardCopyOption.REPLACE_EXISTING);
|
}
|
|
List<String> entryNameList = new ArrayList<>();
|
try (SeekableInMemoryByteChannel channel = new SeekableInMemoryByteChannel(bytes);
|
ZipFile zipFile = new ZipFile(channel)) {
|
|
ZipArchiveEntry entry;
|
Enumeration<ZipArchiveEntry> entries = zipFile.getEntries();
|
String entryn = "CP1-13-1/CP1-13-1-1-1-1.txt";
|
while (entries.hasMoreElements()) {
|
entry = entries.nextElement();
|
entryNameList.add(entry.getName());
|
}
|
}*/
|
/*
|
try (SeekableInMemoryByteChannel channel = new SeekableInMemoryByteChannel(bytes);
|
ZipFile zipFile = new ZipFile(channel)) {
|
List<String> dirList = entryNameList.stream().filter(s -> s.endsWith("/")).toList();
|
for(String dir : dirList) {
|
entryNameList.stream().filter(s -> s.startsWith(dir)).forEach(entryName -> {
|
ZipArchiveEntry fileEntry = zipFile.getEntry(entryName);
|
//ZipArchiveEntry fileEntry = entryMap.get(entryName);
|
String fileName = StringUtils.removeStart(entryName,dir);//去除文件名路径部分
|
try {
|
InputStream ins = zipFile.getInputStream(fileEntry);
|
ByteArrayInputStream byteS = new ByteArrayInputStream(ins.readAllBytes());
|
|
Path outputPath = Paths.get("d:/downtest.txt");
|
Files.copy(byteS, outputPath, StandardCopyOption.REPLACE_EXISTING);
|
byteS.reset();
|
|
BladeFile newOssFile = ossTemplate.putFile("mdm", fileName, byteS);
|
r.setData(newOssFile.getName());
|
System.out.println(newOssFile.getName());
|
} catch (IOException e) {
|
throw new RuntimeException(e);
|
}
|
});
|
}
|
}*/
|
return r;
|
}
|
|
}
|
