This commit is contained in:
luke 2025-06-19 18:27:14 +08:00
parent 8567f6bd62
commit f1d54c107e

View File

@ -164,13 +164,7 @@ public class FileWriteController {
private void handleAsyncRecord(String token, String bucket, String originFileNameWithSuffix, String suffix, private void handleAsyncRecord(String token, String bucket, String originFileNameWithSuffix, String suffix,
String s3FullPath, String url, byte[] fileBytes, boolean searchable) { String s3FullPath, String url, byte[] fileBytes, boolean searchable) {
try { try {
Optional<UserTokenDTO> userTokenDTO = userAppService.findToken(token); Optional<UserDTO> userDTO = userAppService.findUserByToken(token);
if (userTokenDTO.isEmpty()) {
logger.warn("异步写入失败:无效 token");
return;
}
Optional<UserDTO> userDTO = userAppService.findById(userTokenDTO.get().getUserId());
if (userDTO.isEmpty() || StrUtil.isBlank(userDTO.get().getUsername())) { if (userDTO.isEmpty() || StrUtil.isBlank(userDTO.get().getUsername())) {
logger.warn("异步写入失败:无法获取用户名"); logger.warn("异步写入失败:无法获取用户名");
return; return;