Struct TaskTrackingRepository 

pub struct TaskTrackingRepository { /* private fields */ }

稿件监控仓储

Implementations

impl TaskTrackingRepository

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

构造仓储

pub async fn list_member_task_counts( &self, ) -> ApiResult<Vec<MemberTaskCountRow>>

查询组员任务计数列表

pub fn to_member_task_counts( rows: &[MemberTaskCountRow], ) -> Vec<MemberTaskCount>

转为 MemberTaskCount 列表

pub async fn list_unpublished_episodes( &self, ) -> ApiResult<Vec<UnpublishedEpisodeRow>>

查询全部未发布话数及详情

pub fn build_task_response( episodes: &[UnpublishedEpisodeRow], ) -> TaskTrackingResponse

按工作流规则构建 TaskTrackingResponse（对齐 Java buildWorkflowChain）

pub async fn count_pending_publish_episodes( &self, manga_tran_name: Option<&str>, ) -> ApiResult<i64>

统计嵌字完成且未发布的待处理话数

pub async fn list_pending_publish_episodes( &self, manga_tran_name: Option<&str>, page: i32, page_size: i32, ) -> ApiResult<Vec<PendingEpisodeRow>>

查询嵌字完成且未发布的待处理话数（SQL 分页）

pub async fn map_publish_episode_context( &self, manga_ids: &[i32], ) -> ApiResult<(HashMap<i32, String>, HashMap<i32, i32>)>

单次扫描：各漫画最新已发布话数标签 + 下一个待发布话数 ID

pub fn row_mangatb(row: &PendingEpisodeRow) -> Mangatb

PendingEpisodeRow 转 Mangatb