Struct EpisodeRepository 

pub struct EpisodeRepository { /* private fields */ }

话数仓储

Implementations

impl EpisodeRepository

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

构造仓储

pub async fn list_by_manga_id( &self, manga_id: i32, ) -> ApiResult<Vec<EpisodeSimpleListVo>>

按漫画 ID 查询话数简单列表（含文件信息）。

返回值

返回漫画下所有话数，按 manga_episode 数字降序排列。

pub async fn list_full_by_manga_id( &self, manga_id: i32, ) -> ApiResult<Vec<EpisodeListVo>>

按漫画 ID 查询话数完整列表

pub async fn get_by_id(&self, id: i32) -> ApiResult<Option<EpisodeDetailVo>>

按 ID 查询话数详情。

返回值

• Ok(Some(detail)) — 找到话数
• Ok(None) — 话数不存在

pub async fn get_legacy_file_path( &self, id: i32, post_name: &str, ) -> ApiResult<Option<String>>

查询话数本地稿件路径（translatorFile / proofreaderFile / timerFile）

pub async fn set_legacy_file_path( &self, id: i32, post_name: &str, path: &str, ) -> ApiResult<()>

更新话数本地稿件路径

pub async fn get_newest_by_manga_id( &self, manga_id: i32, ) -> ApiResult<Option<NewestEpisodeVo>>

查询漫画最新话

pub async fn page_uploaded_submit( &self, page: i32, page_size: i32, manga_tran_name: Option<&str>, username: Option<&str>, ) -> ApiResult<(i64, Vec<UploadPageVo>)>

分页查询已上传稿件（SQL LIMIT/OFFSET，对齐 Java PageHelper）

pub async fn count_episode_by_number( &self, manga_id: i32, manga_episode: &str, ) -> ApiResult<i64>

统计同漫画下相同话数标签数量

pub async fn touch_manga_update_time(&self, manga_id: i32) -> ApiResult<()>

刷新漫画更新时间

pub async fn insert(&self, dto: &EpisodeEditDto) -> ApiResult<i32>

新增话数（对齐 Java insertEpisode）

pub async fn insert_detail( &self, episode_id: i32, dto: &EpisodeEditDto, ) -> ApiResult<()>

新增话数详情及岗位接稿时间（对齐 Java insertEpisodeDetail）

pub async fn update_publish_link_only( &self, id: i32, publish_link: Option<String>, ) -> ApiResult<()>

仅更新发布链接

pub async fn update(&self, dto: &EpisodeEditDto) -> ApiResult<()>

更新话数（对齐 Java updateMangaEpisode）

pub async fn delete_by_id(&self, id: i32) -> ApiResult<()>

删除话数及详情

pub async fn update_publish_links_batch( &self, requests: &[PublishLinkRequest], ) -> ApiResult<()>

批量更新发布链接

pub async fn count_publish_link( &self, publish_link: &str, exclude_id: Option<i32>, ) -> ApiResult<i64>

检测发布链接是否重复

pub async fn get_statistic_count( &self, start: NaiveDateTime, end: NaiveDateTime, ) -> ApiResult<PostCompletionStats>

统计时间段内各岗位完成数

pub fn stats_from_post(stats: &PostCompletionStats) -> Statistics

转为 Statistics（对齐 Java getStatisticCount）

pub async fn get_member_statistics( &self, start: DateTime<Utc>, end: DateTime<Utc>, member_id: Option<i32>, ) -> ApiResult<Vec<MemberStatistics>>

查询组员完成统计（对齐 Java MembertbDao.selectMemberStatistics）

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

回退指定岗位流程

pub async fn list_unpublished_with_detail( &self, ) -> ApiResult<Vec<EpisodeListVo>>

查询未发布话数（任务追踪用）