Struct OssRepository 

pub struct OssRepository { /* private fields */ }

OSS 仓储

Implementations

impl OssRepository

pub fn new(pool: Pool<MySql>, config: AppConfig) -> Self

构造仓储

pub async fn upsert_oss(&self, dto: &OssDto, member_id: i32) -> ApiResult<i32>

新增或更新 OSS 记录，绑定到话数岗位列。

若该话数岗位已有 OSS 记录则 UPDATE，否则 INSERT。

返回值

返回 OSS 记录 ID。

Errors

• AppError::business("话数不存在喵") — episode_id 不存在
• AppError::Database — 写入失败

pub async fn delete_oss(&self, oss_id: i32) -> ApiResult<Option<String>>

删除 OSS 记录

pub async fn get_upload_credential( &self, episode_id: i32, post_name: &str, filename: &str, ) -> ApiResult<OssCredential>

获取上传凭证

pub async fn get_download_credential( &self, episode_id: i32, post_name: &str, ) -> ApiResult<OssCredential>

获取下载凭证

pub async fn get_image_upload_credential( &self, image_type: &str, filename: &str, ) -> ApiResult<OssCredential>

获取图片上传凭证（对齐 Java generateImageObjectKey + imageBucket）

pub async fn get_object_key(&self, oss_id: i32) -> ApiResult<Option<String>>

按 ID 查询 objectKey