|
|
|
|
@ -51,6 +51,13 @@ public class SysOssServiceImpl implements ISysOssService {
|
|
|
|
|
|
|
|
|
|
private final SysOssMapper baseMapper;
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* 查询OSS对象存储列表
|
|
|
|
|
*
|
|
|
|
|
* @param bo OSS对象存储分页查询对象
|
|
|
|
|
* @param pageQuery 分页查询实体类
|
|
|
|
|
* @return 结果
|
|
|
|
|
*/
|
|
|
|
|
@Override
|
|
|
|
|
public TableDataInfo<SysOssVo> queryPageList(SysOssBo bo, PageQuery pageQuery) {
|
|
|
|
|
LambdaQueryWrapper<SysOss> lqw = buildQueryWrapper(bo);
|
|
|
|
|
@ -60,6 +67,12 @@ public class SysOssServiceImpl implements ISysOssService {
|
|
|
|
|
return TableDataInfo.build(result);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* 根据一组 ossIds 获取对应的 SysOssVo 列表
|
|
|
|
|
*
|
|
|
|
|
* @param ossIds 一组文件在数据库中的唯一标识集合
|
|
|
|
|
* @return 包含 SysOssVo 对象的列表
|
|
|
|
|
*/
|
|
|
|
|
@Override
|
|
|
|
|
public List<SysOssVo> listByIds(Collection<Long> ossIds) {
|
|
|
|
|
List<SysOssVo> list = new ArrayList<>();
|
|
|
|
|
@ -71,11 +84,18 @@ public class SysOssServiceImpl implements ISysOssService {
|
|
|
|
|
} catch (Exception ignored) {
|
|
|
|
|
// 如果oss异常无法连接则将数据直接返回
|
|
|
|
|
list.add(vo);
|
|
|
|
|
} }
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
return list;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* 根据一组 ossIds 获取对应文件的 URL 列表
|
|
|
|
|
*
|
|
|
|
|
* @param ossIds 以逗号分隔的 ossId 字符串
|
|
|
|
|
* @return 以逗号分隔的文件 URL 字符串
|
|
|
|
|
*/
|
|
|
|
|
@Override
|
|
|
|
|
public String selectUrlByIds(String ossIds) {
|
|
|
|
|
List<String> list = new ArrayList<>();
|
|
|
|
|
@ -108,12 +128,24 @@ public class SysOssServiceImpl implements ISysOssService {
|
|
|
|
|
return lqw;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* 根据 ossId 从缓存或数据库中获取 SysOssVo 对象
|
|
|
|
|
*
|
|
|
|
|
* @param ossId 文件在数据库中的唯一标识
|
|
|
|
|
* @return SysOssVo 对象，包含文件信息
|
|
|
|
|
*/
|
|
|
|
|
@Cacheable(cacheNames = CacheNames.SYS_OSS, key = "#ossId")
|
|
|
|
|
@Override
|
|
|
|
|
public SysOssVo getById(Long ossId) {
|
|
|
|
|
return baseMapper.selectVoById(ossId);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* 文件下载方法，支持一次性下载完整文件
|
|
|
|
|
*
|
|
|
|
|
* @param ossId OSS对象ID
|
|
|
|
|
* @param response HttpServletResponse对象，用于设置响应头和向客户端发送文件内容
|
|
|
|
|
*/
|
|
|
|
|
@Override
|
|
|
|
|
public void download(Long ossId, HttpServletResponse response) throws IOException {
|
|
|
|
|
SysOssVo sysOss = SpringUtils.getAopProxy(this).getById(ossId);
|
|
|
|
|
@ -123,7 +155,7 @@ public class SysOssServiceImpl implements ISysOssService {
|
|
|
|
|
FileUtils.setAttachmentResponseHeader(response, sysOss.getOriginalName());
|
|
|
|
|
response.setContentType(MediaType.APPLICATION_OCTET_STREAM_VALUE + "; charset=UTF-8");
|
|
|
|
|
OssClient storage = OssFactory.instance(sysOss.getService());
|
|
|
|
|
try(InputStream inputStream = storage.getObjectContent(sysOss.getUrl())) {
|
|
|
|
|
try (InputStream inputStream = storage.getObjectContent(sysOss.getUrl())) {
|
|
|
|
|
int available = inputStream.available();
|
|
|
|
|
IoUtil.copy(inputStream, response.getOutputStream(), available);
|
|
|
|
|
response.setContentLength(available);
|
|
|
|
|
@ -132,6 +164,13 @@ public class SysOssServiceImpl implements ISysOssService {
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* 上传 MultipartFile 到对象存储服务，并保存文件信息到数据库
|
|
|
|
|
*
|
|
|
|
|
* @param file 要上传的 MultipartFile 对象
|
|
|
|
|
* @return 上传成功后的 SysOssVo 对象，包含文件信息
|
|
|
|
|
* @throws ServiceException 如果上传过程中发生异常，则抛出 ServiceException 异常
|
|
|
|
|
*/
|
|
|
|
|
@Override
|
|
|
|
|
public SysOssVo upload(MultipartFile file) {
|
|
|
|
|
String originalfileName = file.getOriginalFilename();
|
|
|
|
|
@ -147,6 +186,12 @@ public class SysOssServiceImpl implements ISysOssService {
|
|
|
|
|
return buildResultEntity(originalfileName, suffix, storage.getConfigKey(), uploadResult);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* 上传文件到对象存储服务，并保存文件信息到数据库
|
|
|
|
|
*
|
|
|
|
|
* @param file 要上传的文件对象
|
|
|
|
|
* @return 上传成功后的 SysOssVo 对象，包含文件信息
|
|
|
|
|
*/
|
|
|
|
|
@Override
|
|
|
|
|
public SysOssVo upload(File file) {
|
|
|
|
|
String originalfileName = file.getName();
|
|
|
|
|
@ -169,6 +214,12 @@ public class SysOssServiceImpl implements ISysOssService {
|
|
|
|
|
return this.matchingUrl(sysOssVo);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* 新增OSS对象存储
|
|
|
|
|
*
|
|
|
|
|
* @param bo SysOssBo 对象，包含待插入的数据
|
|
|
|
|
* @return 插入操作是否成功的布尔值
|
|
|
|
|
*/
|
|
|
|
|
@Override
|
|
|
|
|
public Boolean insertByBo(SysOssBo bo) {
|
|
|
|
|
SysOss oss = BeanUtil.toBean(bo, SysOss.class);
|
|
|
|
|
@ -179,6 +230,13 @@ public class SysOssServiceImpl implements ISysOssService {
|
|
|
|
|
return flag;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* 删除OSS对象存储
|
|
|
|
|
*
|
|
|
|
|
* @param ids OSS对象ID串
|
|
|
|
|
* @param isValid 判断是否需要校验
|
|
|
|
|
* @return 结果
|
|
|
|
|
*/
|
|
|
|
|
@Override
|
|
|
|
|
public Boolean deleteWithValidByIds(Collection<Long> ids, Boolean isValid) {
|
|
|
|
|
if (isValid) {
|
|
|
|
|
@ -193,7 +251,7 @@ public class SysOssServiceImpl implements ISysOssService {
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* 匹配Url
|
|
|
|
|
* 桶类型为 private 的URL 修改为临时URL时长为120s
|
|
|
|
|
*
|
|
|
|
|
* @param oss OSS对象
|
|
|
|
|
* @return oss 匹配Url的OSS对象
|
|
|
|
|
|
AprilWind
1 year ago