Struct RewardRepository 

pub struct RewardRepository { /* private fields */ }

奖励仓储

Implementations

impl RewardRepository

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

构造仓储

pub async fn list_rewards(&self, event_id: i32) -> ApiResult<Vec<Rewardtb>>

查询活动奖品列表

pub async fn get_reward_by_id( &self, reward_id: i32, ) -> ApiResult<Option<RewardRow>>

按 ID 查询奖品

pub async fn deduct_exchange_balance( &self, member_id: i32, amount: i32, ) -> ApiResult<u64>

扣减兑换余额

pub async fn deduct_lucky_balance( &self, member_id: i32, amount: i32, ) -> ApiResult<u64>

扣减抽奖余额

pub async fn get_ticket_number( &self, member_id: i32, ) -> ApiResult<Option<TicketNumberRow>>

查询组员奖券账户

pub async fn insert_reward_record( &self, member_id: i32, reward_id: i32, exchange_number: i32, ) -> ApiResult<i64>

新增兑换记录

pub async fn insert_lucky_tickets( &self, member_id: i32, reward_id: i32, event_id: i32, physical_category: Option<i16>, count: i32, ) -> ApiResult<()>

批量新增抽奖券

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

查询兑换记录

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

查询奖券汇总

pub async fn select_winner( &self, reward_id: i32, event_id: i32, ) -> ApiResult<Option<RewardWinnerDto>>

随机抽取中奖者

pub async fn block_winner( &self, event_id: i32, status: i16, winner_id: i32, physical_category: Option<i16>, ) -> ApiResult<()>

封锁中奖者同类奖券

pub async fn update_ticket_status( &self, ticket_id: &str, status: i16, record_id: i64, ) -> ApiResult<()>

更新奖券状态

pub async fn decrement_stock( &self, reward_id: i32, event_id: i32, count: i32, ) -> ApiResult<u64>

扣减奖品库存

pub async fn mark_non_win_tickets(&self, reward_id: i32) -> ApiResult<()>

标记未中奖券

pub async fn has_opened_rewards(&self, event_id: i32) -> ApiResult<bool>

检查活动是否已经开奖

pub async fn update_event_deadline( &self, event_id: i32, end_time: NaiveDateTime, ) -> ApiResult<()>

更新活动下所有奖品截止时间

pub async fn get_reward_balance( &self, member_id: i32, event_id: i32, ) -> ApiResult<EventBalanceDto>

查询活动余额

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

查询奖券明细

pub async fn check_account_exists(&self, member_id: i32) -> ApiResult<bool>

检测转账目标账户

pub async fn check_balance_account_exists( &self, member_id: i32, event_id: i32, ) -> ApiResult<bool>

检测指定活动余额账户是否存在

pub async fn create_balance_account( &self, member_id: i32, event_id: i32, ) -> ApiResult<()>

创建余额账户

pub async fn transfer_decr( &self, from_id: i32, event_id: i32, ticket_type: i32, amount: i32, ) -> ApiResult<u64>

转账扣减余额

pub async fn transfer_incr( &self, to_id: i32, event_id: i32, ticket_type: i32, amount: i32, ) -> ApiResult<()>

转账增加余额

pub async fn insert_transfer_log( &self, from_id: i32, to_id: i32, event_id: i32, ticket_type: i32, amount: i32, ) -> ApiResult<()>

写入转账日志

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

查询转账日志