Struct TaskTrackingRepository 

pub struct TaskTrackingRepository { /* private fields */ }

稿件监控仓储

Implementations

impl TaskTrackingRepository

pub fn new(pool: PgPool) -> Self

从 PgPool 构造

pub fn from_db(db: DatabaseConnection) -> Self

从 DatabaseConnection 构造

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>>

查询全部未发布话数及详情（UNION 分桶，可走工序 partial index）

pub async fn list_episode_tasks_response( &self, ) -> ApiResult<TaskTrackingResponse>

查询未发布话数并直接构建任务看板响应（避免二次映射）

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（聚合 SQL，避免拉全量话数）

pub async fn page_workflow_episodes( &self, q: &WorkflowEpisodeQuery, ) -> ApiResult<(i64, Vec<WorkflowEpisodeItem>)>

工序汇总筛选：分页列表（含 total，单次 SQL）

pub async fn count_workflow_episodes( &self, q: &WorkflowEpisodeQuery, ) -> ApiResult<i64>

工序汇总筛选：计数

pub async fn list_workflow_episodes( &self, q: &WorkflowEpisodeQuery, ) -> ApiResult<Vec<WorkflowEpisodeItem>>

工序汇总筛选：分页列表

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

PendingEpisodeRow 转 Mangatb