Struct EpisodeService 

pub struct EpisodeService;

话数服务

提供话数及关联数据（统计、发布）的完整业务逻辑。

Implementations

impl EpisodeService

pub async fn select_list_by_manga_id( state: &AppState, manga_id: i32, ) -> ApiResult<Vec<EpisodeSimpleListVo>>

按漫画 ID 查询话数简单列表。

返回包含文件信息的精简话数列表，用于上传页展示。 结果按 manga_episode 升序排列，仅包含未删除的话数记录。

返回值

返回漫画下所有未删除的话数列表，按 manga_episode 排序。

Errors

• AppError::Database — 数据库查询失败

Examples

use tdm_server::service::episode_service::EpisodeService;

let episodes = EpisodeService::select_list_by_manga_id(&state, manga_id).await?;
for ep in &episodes {
    println!("话数 {}: {}", ep.manga_episode, ep.manga_episode_name);
}

pub async fn update_manga_episodes( state: &AppState, requests: Vec<PublishLinkRequest>, ) -> ApiResult<()>

批量更新话数发布链接。

接收一组发布链接请求，批量更新数据库中的链接字段。 更新完成后会刷新任务追踪缓存，并为每个话数触发 RSS 订阅源刷新。

Errors

• AppError::Database — 数据库更新失败

Examples

let requests = vec![
    PublishLinkRequest { id: 1, publish_link: Some("https://example.com/1".into()) },
    PublishLinkRequest { id: 2, publish_link: Some("https://example.com/2".into()) },
];
EpisodeService::update_manga_episodes(&state, requests).await?;

pub async fn update_publish_link( state: &AppState, id: i32, publish_link: Option<String>, ) -> ApiResult<()>

更新单条话数的发布链接。

在写入前会检查新链接是否与其他话数冲突。更新成功后同样 会刷新任务追踪缓存和 RSS 订阅源。

Errors

• AppError::business("发布链接已存在喵") — 链接与其他话数冲突
• AppError::Database — 数据库操作失败

Examples

EpisodeService::update_publish_link(
    &state,
    42,
    Some("https://example.com/ch42".to_string()),
).await?;

pub async fn page_episode( state: &AppState, page: i32, page_size: i32, manga_id: i32, ) -> ApiResult<PageBean<EpisodeListVo>>

分页查询漫画话数。

获取指定漫画下的全部话数列表，然后在内存中进行分页截取。 返回标准分页对象 PageBean，包含当前页数据、总条数和总页数。

Errors

• AppError::Database — 数据库查询失败

Examples

// 查询第 1 页，每页 20 条
let page = EpisodeService::page_episode(&state, 1, 20, manga_id).await?;
println!("共 {} 条，当前页 {} 条", page.total, page.rows.len());

pub async fn delete_episode(state: &AppState, id: i32) -> ApiResult<()>

删除指定话数（软删除）。

将话数标记为删除状态，同时刷新任务追踪缓存并触发 RSS 订阅源 全量刷新。注意：此操作不会立即从数据库中物理删除数据。

Errors

• AppError::Database — 数据库操作失败

Examples

EpisodeService::delete_episode(&state, episode_id).await?;

pub async fn add_episodes( state: &AppState, dto: EpisodeEditDto, ) -> ApiResult<()>

新增话数（对齐 Java addEpisodes）。

支持两种模式：

• 批量模式：指定 manga_episode 起始值和 manga_episode_end 结束值， 在区间内逐条创建话数。
• 单话模式：仅指定 manga_episode，创建一条话数记录。

创建完成后会刷新任务追踪缓存并触发 RSS 全量刷新。

Errors

• AppError::business("缺少漫画 ID") — DTO 中未提供 manga_id
• AppError::business("起始话数格式不正确") — 话数序号不是有效整数
• AppError::business("结束话数格式不正确") — 结束序号不是有效整数
• AppError::business("该漫画单话已存在喵！") — 话数序号重复
• AppError::business("发布链接已存在喵") — 链接与其他话数冲突
• AppError::Database — 数据库操作失败

Examples

// 批量创建话数 1~10
let dto = EpisodeEditDto {
    manga_id: Some(100),
    manga_episode: Some("1".into()),
    manga_episode_end: Some("10".into()),
    ..Default::default()
};
EpisodeService::add_episodes(&state, dto).await?;

// 创建单话
let dto = EpisodeEditDto {
    manga_id: Some(100),
    manga_episode: Some("11".into()),
    ..Default::default()
};
EpisodeService::add_episodes(&state, dto).await?;

pub async fn get_manga_episode_by_id( state: &AppState, id: i32, ) -> ApiResult<EpisodeDetailVo>

按 ID 查询单条话数详情。

返回话数的完整信息，包括主表字段和详情字段。 如果话数已被软删除或不存在，返回业务错误。

Errors

• AppError::business("话数不存在喵") — 指定 ID 的话数不存在
• AppError::Database — 数据库查询失败

Examples

let episode = EpisodeService::get_manga_episode_by_id(&state, 42).await?;
println!("话数名称: {}", episode.manga_episode_name);

pub async fn get_newest_manga_episode_by_id( state: &AppState, manga_id: i32, ) -> ApiResult<NewestEpisodeVo>

查询漫画最新话。

获取指定漫画下序号最大的话数记录。常用于展示连载漫画的 最近更新情况。

Errors

• AppError::business("该漫画尚无单话喵") — 漫画下没有话数记录
• AppError::Database — 数据库查询失败

Examples

let newest = EpisodeService::get_newest_manga_episode_by_id(&state, manga_id).await?;
println!("最新话: {}", newest.manga_episode);

pub async fn update_manga_episode( state: &AppState, dto: EpisodeEditDto, ) -> ApiResult<()>

更新话数信息。

根据 DTO 中提供的字段更新话数主表。更新完成后刷新任务追踪 缓存并触发 RSS 全量刷新。

Errors

• AppError::Database — 数据库更新失败

Examples

let dto = EpisodeEditDto {
    id: Some(42),
    manga_episode_name: Some("新标题".into()),
    ..Default::default()
};
EpisodeService::update_manga_episode(&state, dto).await?;

pub async fn get_uploaded_submit( state: &AppState, page: i32, page_size: i32, manga_tran_name: Option<String>, username: Option<String>, ) -> ApiResult<PageBean<UploadPageVo>>

分页查询已上传稿件列表。

在数据库层面执行分页查询和计数，支持按漫画译名和用户名筛选。 返回标准分页对象 PageBean<UploadPageVo>。

Errors

• AppError::Database — 数据库查询失败

Examples

// 按译名筛选，查询第 1 页
let page = EpisodeService::get_uploaded_submit(
    &state, 1, 20,
    Some("进击的巨人".into()),
    None,
).await?;

pub async fn get_statistics( state: &AppState, start: &str, end: &str, ) -> ApiResult<Statistics>

任意时间段统计

pub async fn get_statistics_list(state: &AppState) -> ApiResult<Vec<Statistics>>

预设时间段统计列表（6 项：日/月/年 + 上期对比）

pub async fn get_member_statistics( state: &AppState, start: DateTime<Utc>, end: DateTime<Utc>, ) -> ApiResult<Vec<MemberStatistics>>

组员完成统计

pub async fn rollback_episode( state: &AppState, episode_id: i32, workflow_type: &str, ) -> ApiResult<()>

回退流程

pub async fn upload_manga_file( state: &AppState, data: Bytes, episode_id: i32, my_name: &str, manga_id: i32, original_filename: &str, ) -> ApiResult<()>

上传话数工作文件（对齐 Java MangaFileUtils + 更新 DB 路径）

pub async fn download_episode_file( state: &AppState, req: EpisodeDownloadRequest, ) -> ApiResult<(String, Bytes)>

下载话数工作文件（legacy 路径 → 规范目录 → OSS 回退）