Struct MemberRepository 

pub struct MemberRepository { /* private fields */ }

组员仓储

Implementations

impl MemberRepository

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

构造仓储

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

按 ID 查询组员（含岗位列表，单 SQL JOIN）。

返回值

返回包含岗位 ID 列表的 Member。

Errors

• AppError::business("组员不存在喵") — ID 不存在
• AppError::Database — 查询失败

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

鉴权用组员快照（单 SQL，含岗位 ID）

pub async fn find_for_login( &self, username: &str, ) -> ApiResult<Option<(Member, String)>>

登录查询：按用户名或邮箱查找组员及 bcrypt 密码哈希。

返回值

• Ok(Some((member, pwd_hash))) — 找到匹配组员
• Ok(None) — 用户名不存在

Errors

• AppError::Database — 查询失败

pub async fn page_list( &self, username: Option<&str>, post: Option<i16>, intern: Option<i16>, email: Option<&str>, page: i32, page_size: i32, ) -> ApiResult<(i64, Vec<Member>)>

分页查询组员（先分页取 id，再批量 enrich 岗位/驻站数）

pub async fn all_cache(&self) -> ApiResult<Vec<MemberCache>>

全量组员缓存列表（单 SQL 聚合岗位，对齐 Java MPJ join）

pub async fn delete_members(&self, ids: &[i32]) -> ApiResult<()>

删除组员

pub async fn insert_member(&self, m: &Member) -> ApiResult<i32>

新增组员

pub async fn update_member(&self, m: &Member) -> ApiResult<()>

更新组员

pub async fn replace_posts( &self, member_id: i32, post_ids: &[i32], ) -> ApiResult<()>

更新岗位

pub async fn update_password(&self, id: i32, new_pwd: &str) -> ApiResult<()>

改密

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

取密码哈希

pub async fn exists_username(&self, username: &str) -> ApiResult<bool>

用户名重复检查

pub async fn exists_email(&self, email: &str) -> ApiResult<bool>

邮箱重复检查

pub async fn is_valid_invitation(&self, code: i32) -> ApiResult<bool>

邀请码有效

pub async fn list_invitation_codes(&self) -> ApiResult<Vec<InvitationCode>>

邀请码列表

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

删除邀请码

pub async fn add_invitation(&self, code: i32) -> ApiResult<()>

新增邀请码

pub async fn page_member_episodes( &self, member_id: i32, page: i32, page_size: i32, ) -> ApiResult<(i64, Vec<MemberEpisodeVo>)>

组员话数分页（SQL COUNT + LIMIT）

pub async fn list_member_episodes( &self, member_id: i32, ) -> ApiResult<Vec<MemberEpisodeVo>>

组员话数列表（全量，仅供兼容）

pub async fn take_episode(&self, ep: &MemberEpisode) -> ApiResult<()>

接稿

pub async fn submit_episode(&self, ep: &MemberEpisode) -> ApiResult<()>

交稿

pub async fn get_member_reminder_rss( &self, ) -> ApiResult<Vec<MemberReminderRssRow>>

三月未交稿组员（对齐 Java MemberMapper.getMemberReminderRss）

pub async fn get_post_ids_by_member( &self, member_id: i32, ) -> ApiResult<Vec<i32>>

查询组员岗位 ID 列表

pub async fn stationed_manga_post_groups( &self, member_id: i32, ) -> ApiResult<HashMap<i32, Vec<i32>>>

常驻漫画岗位分组

pub async fn get_posts_map( &self, member_ids: &[i32], ) -> ApiResult<HashMap<i32, Vec<i32>>>

批量查询组员岗位 ID