kate522
8e0f9d989d
Introduce AKSRT_Balance (user_meta aksrt_balance + balance_log) for Zibll-like pay_balance wallet. User center assets panel shows wallet and points; balance gateway/card-pass/refunds credit cash when enabled.
278 lines
8.3 KiB
PHP
278 lines
8.3 KiB
PHP
<?php
|
|
/**
|
|
* AKSRT cash wallet (站内余额) — separate from points/credits.
|
|
*
|
|
* Storage:
|
|
* - Balance: user_meta `aksrt_balance` (float, 2 decimals)
|
|
* - Ledger: `{prefix}aksrt_balance_log`
|
|
*
|
|
* Mirrors Zibll zibpay_get_user_balance / zibpay_update_user_balance.
|
|
*
|
|
* @package AKSRT
|
|
*/
|
|
|
|
defined('ABSPATH') || exit;
|
|
|
|
class AKSRT_Balance {
|
|
|
|
public const META_KEY = 'aksrt_balance';
|
|
|
|
/**
|
|
* Current cash balance (yuan).
|
|
*/
|
|
public static function balance(int $user_id): float {
|
|
if ($user_id <= 0) {
|
|
return 0.0;
|
|
}
|
|
$val = get_user_meta($user_id, self::META_KEY, true);
|
|
return is_numeric($val) ? round((float) $val, 2) : 0.0;
|
|
}
|
|
|
|
public static function get_balance(int $user_id): float {
|
|
return self::balance($user_id);
|
|
}
|
|
|
|
/**
|
|
* Credit cash wallet.
|
|
*
|
|
* @param array<string,mixed> $ref
|
|
* @return float|WP_Error New balance.
|
|
*/
|
|
public static function add(int $user_id, float $delta, string $reason, array $ref = [], string $remark = '') {
|
|
if ($user_id <= 0) {
|
|
return new WP_Error('aksrt_balance_user', __('用户无效', 'aksrt'));
|
|
}
|
|
$delta = round((float) $delta, 2);
|
|
if ($delta <= 0) {
|
|
return new WP_Error('aksrt_balance_delta', __('增加余额必须为正数', 'aksrt'));
|
|
}
|
|
|
|
$new = self::atomic_update($user_id, $delta, false);
|
|
if ($new === null) {
|
|
return new WP_Error('aksrt_balance_db', __('余额写入失败', 'aksrt'));
|
|
}
|
|
self::log($user_id, $delta, $new, $reason, $ref, $remark);
|
|
do_action('aksrt_balance_added', $user_id, $delta, $reason, $new);
|
|
return $new;
|
|
}
|
|
|
|
/**
|
|
* Debit cash wallet.
|
|
*
|
|
* @param array<string,mixed> $ref
|
|
* @return float|WP_Error New balance.
|
|
*/
|
|
public static function deduct(int $user_id, float $cost, string $reason, array $ref = [], string $remark = '') {
|
|
if ($user_id <= 0) {
|
|
return new WP_Error('aksrt_balance_user', __('用户无效', 'aksrt'));
|
|
}
|
|
$cost = round((float) $cost, 2);
|
|
if ($cost < 0) {
|
|
return new WP_Error('aksrt_balance_delta', __('扣减余额必须为非负数', 'aksrt'));
|
|
}
|
|
if ($cost === 0.0) {
|
|
return self::balance($user_id);
|
|
}
|
|
|
|
$new = self::atomic_update($user_id, $cost, true);
|
|
if ($new === null) {
|
|
$current = self::balance($user_id);
|
|
return new WP_Error('aksrt_balance_insufficient', __('余额不足', 'aksrt'), [
|
|
'balance' => $current,
|
|
'cost' => $cost,
|
|
]);
|
|
}
|
|
self::log($user_id, -$cost, $new, $reason, $ref, $remark);
|
|
do_action('aksrt_balance_deducted', $user_id, $cost, $reason, $new);
|
|
return $new;
|
|
}
|
|
|
|
/**
|
|
* @return float|null
|
|
*/
|
|
private static function atomic_update(int $user_id, float $abs_delta, bool $is_deduct) {
|
|
global $wpdb;
|
|
|
|
$abs_delta = round(abs($abs_delta), 2);
|
|
$meta_key = self::META_KEY;
|
|
$table = $wpdb->usermeta;
|
|
|
|
// Ensure meta row exists.
|
|
$exists = $wpdb->get_var($wpdb->prepare(
|
|
"SELECT umeta_id FROM {$table} WHERE user_id = %d AND meta_key = %s LIMIT 1",
|
|
$user_id,
|
|
$meta_key
|
|
));
|
|
if (!$exists) {
|
|
add_user_meta($user_id, $meta_key, '0', true);
|
|
}
|
|
|
|
if ($is_deduct) {
|
|
// phpcs:ignore WordPress.DB.PreparedSQL.InterpolatedNotPrepared
|
|
$updated = $wpdb->query($wpdb->prepare(
|
|
"UPDATE {$table}
|
|
SET meta_value = CAST(ROUND(CAST(meta_value AS DECIMAL(18,2)) - %f, 2) AS CHAR)
|
|
WHERE user_id = %d AND meta_key = %s
|
|
AND CAST(meta_value AS DECIMAL(18,2)) >= %f",
|
|
$abs_delta,
|
|
$user_id,
|
|
$meta_key,
|
|
$abs_delta
|
|
));
|
|
} else {
|
|
// phpcs:ignore WordPress.DB.PreparedSQL.InterpolatedNotPrepared
|
|
$updated = $wpdb->query($wpdb->prepare(
|
|
"UPDATE {$table}
|
|
SET meta_value = CAST(ROUND(CAST(meta_value AS DECIMAL(18,2)) + %f, 2) AS CHAR)
|
|
WHERE user_id = %d AND meta_key = %s",
|
|
$abs_delta,
|
|
$user_id,
|
|
$meta_key
|
|
));
|
|
}
|
|
|
|
if ($updated !== 1) {
|
|
return null;
|
|
}
|
|
|
|
wp_cache_delete($user_id, 'user_meta');
|
|
return self::balance($user_id);
|
|
}
|
|
|
|
/**
|
|
* @param array<string,mixed> $ref
|
|
*/
|
|
public static function log(int $user_id, float $delta, float $balance_after, string $reason, array $ref = [], string $remark = ''): void {
|
|
global $wpdb;
|
|
if (!class_exists('AKSRT_DB_Migrator')) {
|
|
return;
|
|
}
|
|
$table = AKSRT_DB_Migrator::table('balance_log');
|
|
if ($table === '') {
|
|
return;
|
|
}
|
|
|
|
$ip = '';
|
|
if (!empty($_SERVER['REMOTE_ADDR'])) {
|
|
$ip = sanitize_text_field(wp_unslash((string) $_SERVER['REMOTE_ADDR']));
|
|
}
|
|
$ua = '';
|
|
if (!empty($_SERVER['HTTP_USER_AGENT'])) {
|
|
$ua = substr(sanitize_text_field(wp_unslash((string) $_SERVER['HTTP_USER_AGENT'])), 0, 255);
|
|
}
|
|
|
|
// phpcs:ignore WordPress.DB.DirectDatabaseQuery.DirectQuery
|
|
$wpdb->insert(
|
|
$table,
|
|
[
|
|
'user_id' => $user_id,
|
|
'delta' => round($delta, 2),
|
|
'balance_after' => round($balance_after, 2),
|
|
'reason' => sanitize_key(substr($reason, 0, 64)),
|
|
'remark' => $remark !== '' ? sanitize_text_field(substr($remark, 0, 255)) : null,
|
|
'ref_type' => isset($ref['type']) ? sanitize_key((string) $ref['type']) : null,
|
|
'ref_id' => isset($ref['id']) ? (int) $ref['id'] : (isset($ref['ref_id']) ? (int) $ref['ref_id'] : null),
|
|
'ip' => $ip !== '' ? $ip : null,
|
|
'ua' => $ua !== '' ? $ua : null,
|
|
'created_at' => current_time('mysql', true),
|
|
],
|
|
['%d', '%f', '%f', '%s', '%s', '%s', '%d', '%s', '%s', '%s']
|
|
);
|
|
}
|
|
|
|
/**
|
|
* @param array<string,mixed> $args
|
|
* @return array{items:array<int,array<string,mixed>>,total:int}
|
|
*/
|
|
public static function get_log(array $args = []): array {
|
|
global $wpdb;
|
|
if (!class_exists('AKSRT_DB_Migrator')) {
|
|
return ['items' => [], 'total' => 0];
|
|
}
|
|
$table = AKSRT_DB_Migrator::table('balance_log');
|
|
if ($table === '') {
|
|
return ['items' => [], 'total' => 0];
|
|
}
|
|
|
|
$user_id = max(0, (int) ($args['user_id'] ?? 0));
|
|
$page = max(1, (int) ($args['page'] ?? 1));
|
|
$per_page = max(1, min(50, (int) ($args['per_page'] ?? 10)));
|
|
$offset = ($page - 1) * $per_page;
|
|
|
|
$where = '1=1';
|
|
$params = [];
|
|
if ($user_id > 0) {
|
|
$where .= ' AND user_id = %d';
|
|
$params[] = $user_id;
|
|
}
|
|
|
|
// phpcs:ignore WordPress.DB.PreparedSQL.InterpolatedNotPrepared
|
|
$total_sql = "SELECT COUNT(*) FROM {$table} WHERE {$where}";
|
|
// phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
|
|
$total = (int) ($params ? $wpdb->get_var($wpdb->prepare($total_sql, $params)) : $wpdb->get_var($total_sql));
|
|
|
|
// phpcs:ignore WordPress.DB.PreparedSQL.InterpolatedNotPrepared
|
|
$list_sql = "SELECT * FROM {$table} WHERE {$where} ORDER BY id DESC LIMIT %d OFFSET %d";
|
|
$list_params = array_merge($params, [$per_page, $offset]);
|
|
// phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
|
|
$rows = $wpdb->get_results($wpdb->prepare($list_sql, $list_params), ARRAY_A);
|
|
if (!is_array($rows)) {
|
|
$rows = [];
|
|
}
|
|
|
|
$items = [];
|
|
foreach ($rows as $row) {
|
|
$items[] = [
|
|
'id' => (int) ($row['id'] ?? 0),
|
|
'user_id' => (int) ($row['user_id'] ?? 0),
|
|
'delta' => round((float) ($row['delta'] ?? 0), 2),
|
|
'balance_after' => round((float) ($row['balance_after'] ?? 0), 2),
|
|
'reason' => (string) ($row['reason'] ?? ''),
|
|
'remark' => (string) ($row['remark'] ?? ''),
|
|
'created_at' => (string) ($row['created_at'] ?? ''),
|
|
];
|
|
}
|
|
|
|
return ['items' => $items, 'total' => $total];
|
|
}
|
|
|
|
/**
|
|
* Whether cash wallet feature is enabled (Zibll pay_balance_s).
|
|
*/
|
|
public static function enabled(): bool {
|
|
if (!class_exists('AKSRT_Settings')) {
|
|
return false;
|
|
}
|
|
if (method_exists('AKSRT_Settings', 'get_payment_recharge_settings')) {
|
|
$cfg = AKSRT_Settings::get_payment_recharge_settings();
|
|
return !empty($cfg['enabled']);
|
|
}
|
|
return !empty(AKSRT_Settings::get_all()['pay_balance_s']);
|
|
}
|
|
|
|
/**
|
|
* Format yuan for display.
|
|
*/
|
|
public static function format(float $amount): string {
|
|
return number_format_i18n(round($amount, 2), 2);
|
|
}
|
|
|
|
/**
|
|
* Reason label for ledger UI.
|
|
*/
|
|
public static function reason_label(string $reason): string {
|
|
$map = [
|
|
'card_pass_balance' => __('卡密充值', 'aksrt'),
|
|
'order_payment' => __('订单支付', 'aksrt'),
|
|
'order_refund' => __('订单退款', 'aksrt'),
|
|
'recharge' => __('余额充值', 'aksrt'),
|
|
'transfer_in' => __('转入', 'aksrt'),
|
|
'transfer_out' => __('转出', 'aksrt'),
|
|
'admin' => __('管理员调整', 'aksrt'),
|
|
'exchange_from_credits' => __('积分兑换', 'aksrt'),
|
|
];
|
|
$key = sanitize_key($reason);
|
|
return $map[$key] ?? ($reason !== '' ? $reason : __('余额变动', 'aksrt'));
|
|
}
|
|
}
|