代码提交:测试类上传

dev_2.0.0
liu 1 year ago
parent 7571705f6e
commit 878e0146fa

@ -6,6 +6,7 @@ import io.minio.http.Method;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import java.io.InputStream; import java.io.InputStream;
import java.util.UUID;
@Slf4j @Slf4j
public class MinioUtil { public class MinioUtil {
@ -29,9 +30,9 @@ public class MinioUtil {
/** /**
* *
*/ */
public static String uploadFile(InputStream stream, String objectName) throws Exception { public static String uploadFile(InputStream stream) throws Exception {
ObjectWriteResponse objectWriteResponse = minioClient.putObject(PutObjectArgs.builder().bucket(bucketName).object(objectName) ObjectWriteResponse objectWriteResponse = minioClient.putObject(PutObjectArgs.builder().bucket(bucketName).object(UUID.randomUUID().toString())
.stream(stream, -1, 10485760).build()); .stream(stream, stream.available(), -1).build());
return objectWriteResponse.object(); return objectWriteResponse.object();
} }
@ -43,7 +44,6 @@ public class MinioUtil {
} }
/** /**
* *
*/ */
@ -52,8 +52,6 @@ public class MinioUtil {
} }
/** /**
* *
* *
@ -81,5 +79,4 @@ public class MinioUtil {
} }
} }

@ -93,7 +93,7 @@ public class TestController {
@PostMapping("testFileUpload") @PostMapping("testFileUpload")
public String testFileUpload(MultipartFile file) throws Exception { public String testFileUpload(MultipartFile file) throws Exception {
return MinioUtil.uploadFile(file.getInputStream(), UUID.randomUUID().toString()); return MinioUtil.uploadFile(file.getInputStream());
} }
@PostMapping("downloadFile") @PostMapping("downloadFile")

@ -34,10 +34,10 @@ public class VideoUpdateTest {
@Autowired @Autowired
private AskPatientAnswerService askPatientAnswerService; private AskPatientAnswerService askPatientAnswerService;
private String filePath = "/Users/flevance/Desktop/虚拟病人/语料库/video_texts/";
@Test @Test
public void saveDefaultAnswerVideo() throws Exception { public void saveDefaultAnswerVideo() throws Exception {
String filePath = "/Users/flevance/Desktop/虚拟病人/语料库/video_texts/";
List<AskTemplateQuestionLibrary> list = askTemplateQuestionLibraryService.list(); List<AskTemplateQuestionLibrary> list = askTemplateQuestionLibraryService.list();
for (AskTemplateQuestionLibrary library : list) { for (AskTemplateQuestionLibrary library : list) {
String defaultAnswerCode = library.getDefaultAnswerCode(); String defaultAnswerCode = library.getDefaultAnswerCode();
@ -50,7 +50,7 @@ public class VideoUpdateTest {
BufferedInputStream inputStream = FileUtil.getInputStream(file); BufferedInputStream inputStream = FileUtil.getInputStream(file);
fileResource.setFileSize(inputStream.available()); fileResource.setFileSize(inputStream.available());
String minioId = MinioUtil.uploadFile(inputStream, defaultAnswerCode); String minioId = MinioUtil.uploadFile(inputStream);
fileResource.setMinioId(minioId); fileResource.setMinioId(minioId);
fileResource.insert(); fileResource.insert();
askTemplateQuestionLibraryService.lambdaUpdate() askTemplateQuestionLibraryService.lambdaUpdate()
@ -66,7 +66,6 @@ public class VideoUpdateTest {
@Test @Test
public void saveDiseaseVideo() throws Exception { public void saveDiseaseVideo() throws Exception {
String filePath = "/Users/flevance/Desktop/虚拟病人/语料库/video_texts/";
List<AskPatientAnswer> list = askPatientAnswerService.list(); List<AskPatientAnswer> list = askPatientAnswerService.list();
for (AskPatientAnswer answer : list) { for (AskPatientAnswer answer : list) {
String code = answer.getCode(); String code = answer.getCode();
@ -79,7 +78,7 @@ public class VideoUpdateTest {
BufferedInputStream inputStream = FileUtil.getInputStream(file); BufferedInputStream inputStream = FileUtil.getInputStream(file);
fileResource.setFileSize(inputStream.available()); fileResource.setFileSize(inputStream.available());
String minioId = MinioUtil.uploadFile(inputStream, code); String minioId = MinioUtil.uploadFile(inputStream);
fileResource.setMinioId(minioId); fileResource.setMinioId(minioId);
fileResource.insert(); fileResource.insert();
askPatientAnswerService.lambdaUpdate() askPatientAnswerService.lambdaUpdate()

Loading…
Cancel
Save