|
@@ -292,6 +292,7 @@ public class MinioUtil {
|
|
|
|
|
|
|
|
fileSuffix=fileSuffix.substring(1, fileSuffix.length());
|
|
fileSuffix=fileSuffix.substring(1, fileSuffix.length());
|
|
|
|
|
|
|
|
|
|
+ //预先获取转换后的文件minio中地址,这个必须和回头要实际存储的转换后的minio地址相同
|
|
|
String fileUrl = UFOPUtils.getUploadFileUrl(md5, fileSuffix);
|
|
String fileUrl = UFOPUtils.getUploadFileUrl(md5, fileSuffix);
|
|
|
logger.info("开始合并");
|
|
logger.info("开始合并");
|
|
|
// 获取所有分块
|
|
// 获取所有分块
|
|
@@ -332,7 +333,9 @@ public class MinioUtil {
|
|
|
|
|
|
|
|
String url = fileUrl;
|
|
String url = fileUrl;
|
|
|
logger.info("插入的的url是:" + url);
|
|
logger.info("插入的的url是:" + url);
|
|
|
|
|
+ //文件分片没有问题,并且已经执行完合并,合并到指定地址之后,插入数据库信息,并对特定格式执行预览转换
|
|
|
Map<String,Object> map = this.insertUrl(url, fileSize,md5,fileName,affiliationFuncType);
|
|
Map<String,Object> map = this.insertUrl(url, fileSize,md5,fileName,affiliationFuncType);
|
|
|
|
|
+ //分片合并,插入进数据库之后,执行删除分片
|
|
|
Boolean deleteResult = this.deleteChunks(md5);
|
|
Boolean deleteResult = this.deleteChunks(md5);
|
|
|
logger.info(map.toString());
|
|
logger.info(map.toString());
|
|
|
logger.info(deleteResult.toString());
|
|
logger.info(deleteResult.toString());
|
|
@@ -399,6 +402,7 @@ public class MinioUtil {
|
|
|
resourceUserFileMapper.insert(resourceUserFile);
|
|
resourceUserFileMapper.insert(resourceUserFile);
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
|
|
+ //文件数据插入完毕,创建一个新线程,来执行发送消息给kafka,进行转码任务
|
|
|
ExecutorService threadPool = CheckThreadPool.getExecutor();
|
|
ExecutorService threadPool = CheckThreadPool.getExecutor();
|
|
|
String userId = StpLoginUserUtil.getLoginUser().getId();
|
|
String userId = StpLoginUserUtil.getLoginUser().getId();
|
|
|
try {
|
|
try {
|