Struct TokenAccountModel 

pub struct TokenAccountModel {}

Implementations

impl TokenAccountModel

pub async fn get_by_user_id( &self, pool: &Pool<Postgres>, user_id: i64, ) -> Result<Option<TokenAccount>, Error>

按用户 ID 查询账户。

pub async fn get_or_create( &self, pool: &Pool<Postgres>, user_id: i64, ) -> Result<TokenAccount, Error>

若账户不存在则自动创建，返回当前账户信息。 通常在用户注册后调用。

pub async fn add_balance( &self, pool: &Pool<Postgres>, user_id: i64, amount: i64, ) -> Result<i64, Error>

原子性增加余额（充值）。 同步更新 total_recharged 汇总字段。 返回更新后的余额。

pub async fn deduct_balance( &self, pool: &Pool<Postgres>, user_id: i64, amount: i64, ) -> Result<i64, Error>

原子性扣减余额（消费）。 余额不足时返回 Error::InsufficientBalance（HTTP 402），不会产生负余额。 返回扣减后的余额。

Trait Implementations

impl Default for TokenAccountModel

fn default() -> TokenAccountModel

Returns the “default value” for a type.

impl Model for TokenAccountModel

type Output = TokenAccount

fn new() -> Self

async fn schema_view(&self, _pool: &Pool<Postgres>) -> SchemaView

async fn insert(&self, pool: &Pool<Postgres>, data: Value) -> Result<u64, Error>

async fn get_by_id( &self, pool: &Pool<Postgres>, id: u64, ) -> Result<Option<Self::Output>, Error>

async fn update_by_id( &self, pool: &Pool<Postgres>, id: u64, data: Value, ) -> Result<(), Error>

async fn delete_by_id( &self, pool: &Pool<Postgres>, id: u64, ) -> Result<(), Error>

async fn count( &self, pool: &Pool<Postgres>, params: &ModelListParams, ) -> Result<i64, Error>

async fn list( &self, pool: &Pool<Postgres>, params: &ModelListParams, ) -> Result<Vec<Self::Output>, Error>

fn push_filter_conditions<'args>( &self, qb: &mut QueryBuilder<'args, Postgres>, filters: &HashMap<String, String>, ) -> Result<(), Error>

fn keyword(&self) -> String

fn push_conditions<'args>( &self, qb: &mut QueryBuilder<'args, Postgres>, params: &ModelListParams, ) -> Result<(), Error>

fn list_and_count<'a>( &'a self, pool: &'a Pool<Postgres>, count: bool, params: &'a ModelListParams, ) -> impl Future<Output = Result<Value, Error>> + Send + 'a

fn search_options<'a>( &'a self, _pool: &'a Pool<Postgres>, _keyword: Option<String>, ) -> impl Future<Output = Result<Vec<SchemaOption>, Error>> + Send + 'a