Commit 30e4398b by zhangxingmin

oss-v1版本

parent 0d051195
......@@ -58,6 +58,11 @@ public class ApiOssFileListResponse {
private String fileType;
/**
* 完整文件路径
*/
private String fileUrl;
/**
* 创建时间
*/
private LocalDateTime createTime;
......
package com.yd.oss.service.dao;
import com.yd.oss.feign.response.ApiOssFileListResponse;
import com.yd.oss.service.model.OssFile;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Param;
......@@ -37,4 +38,6 @@ public interface OssFileMapper extends BaseMapper<OssFile> {
// 标记文件为已删除
@Update("UPDATE oss_file SET is_deleted = true, deleted_time = NOW() WHERE file_key = #{fileKey}")
int markAsDeleted(@Param("fileKey") String fileKey);
List<ApiOssFileListResponse> list(@Param("objectBizId") String objectBizId);
}
package com.yd.oss.service.service;
import com.yd.oss.feign.response.ApiOssFileListResponse;
import com.yd.oss.service.dto.OssFileDto;
import com.yd.oss.service.model.OssFile;
import com.baomidou.mybatisplus.extension.service.IService;
......@@ -36,4 +37,6 @@ public interface IOssFileService extends IService<OssFile> {
List<OssFile> queryList(OssFileDto dto);
OssFile queryOne(String fileBizId);
List<ApiOssFileListResponse> list(String objectBizId);
}
......@@ -2,6 +2,7 @@ package com.yd.oss.service.service.impl;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.yd.common.exception.BusinessException;
import com.yd.oss.feign.response.ApiOssFileListResponse;
import com.yd.oss.service.dao.OssOperationLogMapper;
import com.yd.oss.service.dto.OssFileDto;
import com.yd.oss.service.model.OssFile;
......@@ -152,5 +153,10 @@ public class OssFileServiceImpl extends ServiceImpl<OssFileMapper, OssFile> impl
return this.getOne(new LambdaQueryWrapper<OssFile>().eq(OssFile::getFileBizId,fileBizId));
}
@Override
public List<ApiOssFileListResponse> list(String objectBizId) {
return this.baseMapper.list(objectBizId);
}
}
......@@ -2,4 +2,16 @@
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.yd.oss.service.dao.OssFileMapper">
<select id="list" resultType="com.yd.oss.feign.response.ApiOssFileListResponse">
select o.*,
concat('https://', op.bucket_name, '.', op.endpoint, '/', o.file_key) as fileUrl
from oss_file o
left join oss_provider op on op.provider_biz_id = o.provider_biz_id and op.is_deleted = 0
<where>
<if test="objectBizId != null and objectBizId != ''">
and o.object_biz_id = #{objectBizId}
</if>
and o.is_deleted = 0
</where>
</select>
</mapper>
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment