package com.ruoyi.web.test;
|
|
import com.ruoyi.common.config.RuoYiConfig;
|
import com.ruoyi.common.core.domain.AjaxResult;
|
import com.ruoyi.common.utils.file.FileUploadUtils;
|
import com.ruoyi.common.utils.file.FileUtils;
|
import com.smartor.domain.ServiceSubtaskDetail;
|
import com.smartor.domain.ThiedInhospInfo;
|
import io.swagger.models.auth.In;
|
import org.junit.Test;
|
import org.springframework.mock.web.MockMultipartFile;
|
import org.springframework.web.multipart.MultipartFile;
|
|
import java.io.*;
|
import java.math.BigInteger;
|
import java.nio.file.Files;
|
import java.security.MessageDigest;
|
import java.util.ArrayList;
|
import java.util.List;
|
import java.util.concurrent.CompletableFuture;
|
import java.util.regex.Matcher;
|
import java.util.regex.Pattern;
|
import java.util.stream.Collectors;
|
|
import static cn.hutool.core.convert.Convert.toHex;
|
import static org.eclipse.jetty.http.HttpGenerator.CHUNK_SIZE;
|
|
//@SpringBootTest
|
//@RunWith(SpringRunner.class)
|
public class MQTest {
|
|
@Test
|
public void testSend22() {
|
// uploadFileInChunks(new File("C:\\Users\\86176\\Desktop\\19-图解es内部基于_version乐观锁控制.mp4"));
|
File file = new File("C:\\Users\\86176\\Desktop\\19-图解es内部基于_version乐观锁控制.mp4");
|
|
|
FileInputStream input = null;
|
try {
|
input = new FileInputStream(new File("C:\\Users\\86176\\Desktop\\19-图解es内部基于_version乐观锁控制.mp4"));
|
MultipartFile multipartFile = new MockMultipartFile(file.getName(), file.getName(), "application/octet-stream", input);
|
aa(multipartFile);
|
} catch (FileNotFoundException e) {
|
e.printStackTrace();
|
} catch (IOException e) {
|
e.printStackTrace();
|
}
|
|
}
|
|
@Test
|
public void bb() {
|
int i = 61 /60;
|
System.out.println(i);
|
}
|
|
public void aa(MultipartFile file) throws IOException {
|
System.out.println("开始Aa：" + System.currentTimeMillis());
|
String filePath = "D:\\test\\Ab";
|
// 上传并返回新文件名称
|
String fileName = FileUploadUtils.upload(filePath, file);
|
System.out.println("结束Aa：" + System.currentTimeMillis());
|
|
}
|
|
|
public static String encode(String arg) {
|
if (arg == null) {
|
arg = "";
|
}
|
MessageDigest md5 = null;
|
try {
|
md5 = MessageDigest.getInstance("MD5");
|
md5.update(arg.getBytes("UTF-8"));
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
return toHex(md5.digest());
|
}
|
|
}
|
