lukeye/doc-parser-server
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

add osupload log

Browse Source
This commit is contained in:
Luke.Ye 2025-08-01 23:38:13 +08:00
parent 2e7ab01ed6
commit 49e175c0a1
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/main/java/com/knowledge/base/infrastructure/north/controller/FileWriteController.java
View File

@ -3,6 +3,7 @@ package com.knowledge.base.infrastructure.north.controller;
import cn.hutool.core.io.FileUtil; import cn.hutool.core.io.FileUtil;
import cn.hutool.core.lang.UUID; import cn.hutool.core.lang.UUID;
import cn.hutool.core.util.StrUtil; import cn.hutool.core.util.StrUtil;
import cn.hutool.json.JSONUtil;
import com.knowledge.base.application.service.DocAppService; import com.knowledge.base.application.service.DocAppService;
import com.knowledge.base.application.service.UserAppService; import com.knowledge.base.application.service.UserAppService;
import com.knowledge.base.domain.common.enums.DocMetaPropEnum; import com.knowledge.base.domain.common.enums.DocMetaPropEnum;
@ -143,6 +144,7 @@ public class FileWriteController {
// file字段在主线程停止后，会自动删除，因此需要先转出来 // file字段在主线程停止后，会自动删除，因此需要先转出来
byte[] fileBytes = file.getBytes(); byte[] fileBytes = file.getBytes();
logger.info("[FileWriteController#uploadFolderToOS] 已上传至对象存储: {}", originalName);
ThreadPoolUtil.execute(() -> ThreadPoolUtil.execute(() ->
handleAsyncRecord(finalToken, bucket, originFileNameWithSuffix, suffix, s3FullPath, finalUrl, fileBytes, searchable) handleAsyncRecord(finalToken, bucket, originFileNameWithSuffix, suffix, s3FullPath, finalUrl, fileBytes, searchable)
); );
@ -217,6 +219,7 @@ public class FileWriteController {
dto.setUploadTime(now.toString()); dto.setUploadTime(now.toString());
dto.setExpireTime(expireTime.toString()); dto.setExpireTime(expireTime.toString());
docAppService.saveOSUplodRecord(dto); docAppService.saveOSUplodRecord(dto);
logger.info("[OS异步写入] 初始化上传记录成功. OSRecordDTO = {}", JSONUtil.toJsonStr(dto));
// 允许保存到本地 // 允许保存到本地
if (allowSaveToLocal) { if (allowSaveToLocal) {