Package com.bytedesk.core.upload

Class UploadRestService

java.lang.Object

com.bytedesk.core.base.BaseRestService<UploadEntity,UploadRequest,UploadResponse>

com.bytedesk.core.upload.UploadRestService

@Service
public class UploadRestService
extends BaseRestService<UploadEntity,UploadRequest,UploadResponse>

Field Summary

Fields

Modifier and Type	Field	Description
private final AuthService	authService
private final BytedeskProperties	bytedeskProperties
private final org.modelmapper.ModelMapper	modelMapper
private final UidUtils	uidUtils
private final Path	uploadDir
private UploadMinioService	uploadMinioService
private final UploadRepository	uploadRepository
private final UploadSecurityConfig	uploadSecurityConfig
private final UploadSecurityLogger	uploadSecurityLogger
private UploadWatermarkService	uploadWatermarkService

Constructor Summary

Constructors

Constructor	Description
UploadRestService()

Method Summary

Modifier and Type	Method	Description
UploadResponse	convertToResponse(UploadEntity entity)
UploadResponse	create(UploadRequest request)
protected org.springframework.data.jpa.domain.Specification<UploadEntity>	createSpecification(UploadRequest request)	创建Specification对象，子类必须实现 用于queryByOrg的通用实现
void	delete(UploadRequest entity)
void	deleteAll()
void	deleteByUid(String uid)
void	deleteFile(String filename)
void	deleteFromMinio(String objectPath)	删除 MinIO 中的文件
protected UploadEntity	doSave(UploadEntity entity)	子类实现具体的保存逻辑
protected org.springframework.data.domain.Page<UploadEntity>	executePageQuery(org.springframework.data.jpa.domain.Specification<UploadEntity> spec, org.springframework.data.domain.Pageable pageable)	执行分页查询，子类必须实现 用于queryByOrg的通用实现
private String	extractRelativePathFromUrl(String fileUrl)	从文件URL中提取相对路径 例如：http://127.0.0.1:9003/file/2025/09/05/1757039824330_8577.pdf 提取为：2025/09/05/1757039824330_8577.pdf
boolean	fileExistsInMinio(String objectPath)	检查 MinIO 中文件是否存在
private String	filterAndRenameFileName(String fileName)
Optional<UploadEntity>	findByUid(String uid)
private String	getFileExt(String fileName)
private String	getFileSizeDescription()
String	getMinioDownloadUrl(String objectPath, int expiry)	获取 MinIO 文件下载URL（预签名URL）
private String	getMinioFolderByFileName(String fileName, UploadRequest request)	根据文件名确定 MinIO 存储文件夹
private String	getMinioFolderByFileType(org.springframework.web.multipart.MultipartFile file, UploadRequest request)	根据文件类型和请求信息确定 MinIO 存储文件夹
String	getMinioUploadUrl(String objectPath, int expiry)	获取 MinIO 文件上传URL（预签名URL）
UploadResponse	handleFileUpload(org.springframework.web.multipart.MultipartFile file, UploadRequest request)
UploadResponse	handleFileUpload(org.springframework.web.multipart.MultipartFile file, UploadRequest request, jakarta.servlet.http.HttpServletRequest httpRequest)
UploadEntity	handleOptimisticLockingFailureException(org.springframework.orm.ObjectOptimisticLockingFailureException e, UploadEntity entity)
void	initUploadDir()
private boolean	isAllowedFileType(String fileName, String contentType)
private boolean	isFileSizeValid(long fileSize)
private boolean	isImageFile(String fileName, String contentType)
Stream<Path>	loadAll()
org.springframework.core.io.Resource	loadAsResource(UploadEntity upload)	从 UploadEntity 加载文件资源 优先使用 fileUrl，如果 fileUrl 为空则使用 fileName
org.springframework.core.io.Resource	loadAsResource(String filenameOrPath)	加载文件资源 Resource resource2 = uploadRestService.loadAsResource("2025/09/05/1757039824330_8577.pdf");
String	store(org.springframework.web.multipart.MultipartFile file, String fileName)
String	store(org.springframework.web.multipart.MultipartFile file, String fileName, UploadRequest request)
String	storeFromUrl(String url, String fileName)
String	storeLocalFileToMinio(String localFilePath, String fileName, UploadRequest request)	将本地文件存储到 MinIO
String	storeToMinio(org.springframework.web.multipart.MultipartFile file, String fileName, UploadRequest request)	将文件存储到 MinIO
String	storeUrlToMinio(String url, String fileName, UploadRequest request)	从 URL 下载并存储到 MinIO
UploadResponse	update(UploadRequest request)

Methods inherited from class com.bytedesk.core.base.BaseRestService

deleteByOrgUid, findByOrgUid, getUidFromRequest, queryByOrg, queryByUid, queryByUser, recover, save, setUserUidToRequest

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

uploadDir

private final Path uploadDir

uidUtils

private final UidUtils uidUtils

modelMapper

private final org.modelmapper.ModelMapper modelMapper

uploadRepository

private final UploadRepository uploadRepository

bytedeskProperties

private final BytedeskProperties bytedeskProperties

authService

private final AuthService authService

uploadSecurityConfig

private final UploadSecurityConfig uploadSecurityConfig

uploadSecurityLogger

private final UploadSecurityLogger uploadSecurityLogger

uploadWatermarkService

@Autowired(required=false)
private UploadWatermarkService uploadWatermarkService

uploadMinioService

@Autowired(required=false)
private UploadMinioService uploadMinioService

Constructor Details

UploadRestService

public UploadRestService()

Method Details

createSpecification

protected org.springframework.data.jpa.domain.Specification<UploadEntity> createSpecification(UploadRequest request)

Description copied from class: BaseRestService

创建Specification对象，子类必须实现 用于queryByOrg的通用实现

Specified by:

createSpecification in class BaseRestService<UploadEntity,UploadRequest,UploadResponse>

executePageQuery

protected org.springframework.data.domain.Page<UploadEntity> executePageQuery(org.springframework.data.jpa.domain.Specification<UploadEntity> spec,
 org.springframework.data.domain.Pageable pageable)

Description copied from class: BaseRestService

执行分页查询，子类必须实现 用于queryByOrg的通用实现

Specified by:

executePageQuery in class BaseRestService<UploadEntity,UploadRequest,UploadResponse>

findByUid

public Optional<UploadEntity> findByUid(String uid)

Specified by:

findByUid in class BaseRestService<UploadEntity,UploadRequest,UploadResponse>

create

public UploadResponse create(UploadRequest request)

Specified by:

create in class BaseRestService<UploadEntity,UploadRequest,UploadResponse>

update

public UploadResponse update(UploadRequest request)

Specified by:

update in class BaseRestService<UploadEntity,UploadRequest,UploadResponse>

doSave

protected UploadEntity doSave(UploadEntity entity)

Description copied from class: BaseRestService

子类实现具体的保存逻辑

Specified by:

doSave in class BaseRestService<UploadEntity,UploadRequest,UploadResponse>

handleOptimisticLockingFailureException

public UploadEntity handleOptimisticLockingFailureException(org.springframework.orm.ObjectOptimisticLockingFailureException e,
 UploadEntity entity)

Specified by:

handleOptimisticLockingFailureException in class BaseRestService<UploadEntity,UploadRequest,UploadResponse>

storeFromUrl

public String storeFromUrl(String url,
 String fileName)

store

public String store(org.springframework.web.multipart.MultipartFile file,
 String fileName)

store

public String store(org.springframework.web.multipart.MultipartFile file,
 String fileName,
 UploadRequest request)

isAllowedFileType

private boolean isAllowedFileType(String fileName,
 String contentType)

isImageFile

private boolean isImageFile(String fileName,
 String contentType)

getFileExt

private String getFileExt(String fileName)

filterAndRenameFileName

private String filterAndRenameFileName(String fileName)

isFileSizeValid

private boolean isFileSizeValid(long fileSize)

getFileSizeDescription

private String getFileSizeDescription()

loadAll

public Stream<Path> loadAll()

loadAsResource

public org.springframework.core.io.Resource loadAsResource(UploadEntity upload)

从 UploadEntity 加载文件资源 优先使用 fileUrl，如果 fileUrl 为空则使用 fileName

Parameters:

upload - UploadEntity 对象

Returns:

Resource

extractRelativePathFromUrl

private String extractRelativePathFromUrl(String fileUrl)

从文件URL中提取相对路径 例如：http://127.0.0.1:9003/file/2025/09/05/1757039824330_8577.pdf 提取为：2025/09/05/1757039824330_8577.pdf

Parameters:

fileUrl - 完整的文件URL

Returns:

相对路径，如果提取失败返回null

loadAsResource

public org.springframework.core.io.Resource loadAsResource(String filenameOrPath)

加载文件资源 Resource resource2 = uploadRestService.loadAsResource("2025/09/05/1757039824330_8577.pdf");

Parameters:

filenameOrPath - 文件名（如：20240916144702_身份证-背面.jpg）或完整路径（如：2025/09/05/1757039824330_8577.pdf）

Returns:

Resource

initUploadDir

public void initUploadDir()

deleteFile

public void deleteFile(String filename)

deleteAll

public void deleteAll()

deleteByUid

public void deleteByUid(String uid)

Specified by:

deleteByUid in class BaseRestService<UploadEntity,UploadRequest,UploadResponse>

delete

public void delete(UploadRequest entity)

Specified by:

delete in class BaseRestService<UploadEntity,UploadRequest,UploadResponse>

convertToResponse

public UploadResponse convertToResponse(UploadEntity entity)

Specified by:

convertToResponse in class BaseRestService<UploadEntity,UploadRequest,UploadResponse>

handleFileUpload

public UploadResponse handleFileUpload(org.springframework.web.multipart.MultipartFile file,
 UploadRequest request)

handleFileUpload

public UploadResponse handleFileUpload(org.springframework.web.multipart.MultipartFile file,
 UploadRequest request,
 jakarta.servlet.http.HttpServletRequest httpRequest)

storeToMinio

public String storeToMinio(org.springframework.web.multipart.MultipartFile file,
 String fileName,
 UploadRequest request)

将文件存储到 MinIO

Parameters:

file - MultipartFile 文件

fileName - 文件名

request - 上传请求

Returns:

文件访问URL

storeLocalFileToMinio

public String storeLocalFileToMinio(String localFilePath,
 String fileName,
 UploadRequest request)

将本地文件存储到 MinIO

Parameters:

localFilePath - 本地文件路径

fileName - 文件名

request - 上传请求

Returns:

文件访问URL

storeUrlToMinio

public String storeUrlToMinio(String url,
 String fileName,
 UploadRequest request)

从 URL 下载并存储到 MinIO

Parameters:

url - 文件URL

fileName - 文件名

request - 上传请求

Returns:

文件访问URL

getMinioFolderByFileType

private String getMinioFolderByFileType(org.springframework.web.multipart.MultipartFile file,
 UploadRequest request)

根据文件类型和请求信息确定 MinIO 存储文件夹

Parameters:

file - MultipartFile 文件

request - 上传请求

Returns:

存储文件夹路径

getMinioFolderByFileName

private String getMinioFolderByFileName(String fileName,
 UploadRequest request)

根据文件名确定 MinIO 存储文件夹

Parameters:

fileName - 文件名

request - 上传请求

Returns:

存储文件夹路径

deleteFromMinio

public void deleteFromMinio(String objectPath)

删除 MinIO 中的文件

Parameters:

objectPath - 对象路径

fileExistsInMinio

public boolean fileExistsInMinio(String objectPath)

检查 MinIO 中文件是否存在

Parameters:

objectPath - 对象路径

Returns:

是否存在

getMinioDownloadUrl

public String getMinioDownloadUrl(String objectPath,
 int expiry)

获取 MinIO 文件下载URL（预签名URL）

Parameters:

objectPath - 对象路径

expiry - 过期时间（秒）

Returns:

预签名URL

getMinioUploadUrl

public String getMinioUploadUrl(String objectPath,
 int expiry)

获取 MinIO 文件上传URL（预签名URL）

Parameters:

objectPath - 对象路径

expiry - 过期时间（秒）

Returns:

预签名URL