ak/file
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

!63 代码合并

Browse Source 
Merge pull request !63 from MAC/develop
This commit is contained in:
MAC 2021-07-10 03:46:33 +00:00 committed by Gitee
commit 1ea94c09d4
1 changed files with 6 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
src/main/java/com/qiwenshare/file/controller/OfficeController.java
View File

@ -286,19 +286,17 @@ public class OfficeController {
URL url = new URL(downloadUri); URL url = new URL(downloadUri);
HttpURLConnection connection = (HttpURLConnection) url.openConnection(); HttpURLConnection connection = (HttpURLConnection) url.openConnection();
String md5Str = ""; // String md5Str = "";
int fileLength = 0; int fileLength = 0;
try { try {
InputStream stream = connection.getInputStream(); InputStream stream = connection.getInputStream();
fileLength = connection.getContentLength();
md5Str = DigestUtils.md5Hex(stream);
Writer writer1 = ufoFactory.getWriter(fileBean.getStorageType()); Writer writer1 = ufoFactory.getWriter(fileBean.getStorageType());
WriteFile writeFile = new WriteFile(); WriteFile writeFile = new WriteFile();
writeFile.setFileUrl(fileBean.getFileUrl()); writeFile.setFileUrl(fileBean.getFileUrl());
log.info("当前修改文件大小为：" + fileLength); log.info("当前修改文件大小为：" + fileLength);
log.info("当前修改文件md5为：" + md5Str); // log.info("当前修改文件md5为：" + md5Str);
writeFile.setFileSize(connection.getContentLength()); writeFile.setFileSize(connection.getContentLength());
writer1.write(stream, writeFile); writer1.write(stream, writeFile);
} catch (Exception e) { } catch (Exception e) {
@ -311,10 +309,11 @@ public class OfficeController {
.eq(UserFile::getUserFileId, userFileId); .eq(UserFile::getUserFileId, userFileId);
userFileService.update(userFileUpdateWrapper); userFileService.update(userFileUpdateWrapper);
LambdaUpdateWrapper<FileBean> lambdaUpdateWrapper = new LambdaUpdateWrapper<>(); LambdaUpdateWrapper<FileBean> lambdaUpdateWrapper = new LambdaUpdateWrapper<>();
fileLength = connection.getContentLength();
log.info("当前修改文件大小为2222：" + Long.valueOf(fileLength)); log.info("当前修改文件大小为2222：" + Long.valueOf(fileLength));
lambdaUpdateWrapper lambdaUpdateWrapper
.set(FileBean::getIdentifier, md5Str) // .set(FileBean::getIdentifier, md5Str)
.set(FileBean::getFileSize, Long.valueOf(fileLength)) .set(FileBean::getFileSize, Long.valueOf(fileLength))
.eq(FileBean::getFileId, fileId); .eq(FileBean::getFileId, fileId);
fileService.update(lambdaUpdateWrapper); fileService.update(lambdaUpdateWrapper);
@ -323,7 +322,7 @@ public class OfficeController {
} }
} }
} }
if("3".equals(status)||"7".equals(status)) {//不强制手动保存时为6,"6".equals(status) if("3".equals(status)||"7".equals(status)) {//不强制手动保存时为6,"6".equals(status)
log.debug("====保存失败:"); log.debug("====保存失败:");
writer.write("{\"error\":1}"); writer.write("{\"error\":1}");