diff --git a/src/main/java/com/knowledge/base/infrastructure/north/controller/FileWriteController.java b/src/main/java/com/knowledge/base/infrastructure/north/controller/FileWriteController.java
index 201f40b..363943c 100644
--- a/src/main/java/com/knowledge/base/infrastructure/north/controller/FileWriteController.java
+++ b/src/main/java/com/knowledge/base/infrastructure/north/controller/FileWriteController.java
@@ -164,13 +164,7 @@ public class FileWriteController {
     private void handleAsyncRecord(String token, String bucket, String originFileNameWithSuffix, String suffix,
                                    String s3FullPath, String url, byte[] fileBytes, boolean searchable) {
         try {
-            Optional<UserTokenDTO> userTokenDTO = userAppService.findToken(token);
-            if (userTokenDTO.isEmpty()) {
-                logger.warn("异步写入失败：无效 token");
-                return;
-            }
-
-            Optional<UserDTO> userDTO = userAppService.findById(userTokenDTO.get().getUserId());
+            Optional<UserDTO> userDTO = userAppService.findUserByToken(token);
             if (userDTO.isEmpty() || StrUtil.isBlank(userDTO.get().getUsername())) {
                 logger.warn("异步写入失败：无法获取用户名");
                 return;