kate522/wordpress-theme-aksrt
1
0 Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

修复两个问题

Browse Source
This commit is contained in:
kate522 committed 2026-08-24 16:38:03 +08:00
1 parent 48a82403b2
commit 58f3f42bf8
15 files changed
+173 -23
Download Patch File Download Diff File Expand all files Collapse all files

No files matched your search

src/Core/DomainModel.php
+2
View File
@@ -27,6 +27,7 @@ class DomainModel {
public const ORDER_PRODUCT_RESOURCE = 'resource';
public const ORDER_PRODUCT_VIP = 'vip';
public const ORDER_PRODUCT_RECHARGE = 'recharge';
public const ORDER_PRODUCT_POINTS = 'points';
/**
* Human labels for aksrt_order.product_type (front-end order center).
@@ -38,6 +39,7 @@ class DomainModel {
self::ORDER_PRODUCT_RESOURCE => __('付费内容', 'aksrt'),
self::ORDER_PRODUCT_VIP => __('VIP 会员', 'aksrt'),
self::ORDER_PRODUCT_RECHARGE => __('余额充值', 'aksrt'),
self::ORDER_PRODUCT_POINTS => __('积分购买', 'aksrt'),
];
}
src/Credits/BalanceServiceRest.php
+48 -3
View File
@@ -12,6 +12,12 @@ trait BalanceServiceRest {
public function register_routes(): void {
register_rest_route('aksrt/v1', '/pay/assets', [
'methods' => \WP_REST_Server::READABLE,
'callback' => [$this, 'rest_asset_snapshot'],
'permission_callback' => [$this, 'check_asset_rest'],
]);
register_rest_route('aksrt/v1', '/pay/balance/charge', [
[
'methods' => \WP_REST_Server::READABLE,
@@ -68,6 +74,17 @@ trait BalanceServiceRest {
}
public function rest_asset_snapshot(\WP_REST_Request $request) {
$user_id = get_current_user_id();
return rest_ensure_response([
'success' => true,
'data' => [
'wallet_balance' => \AKSRT\Ledger\LedgerService::get_instance()->balance_decimal($user_id),
'credit_balance' => (string) \AKSRT\Ledger\LedgerService::get_instance()->balance($user_id, \AKSRT\Ledger\AssetType::POINTS),
],
]);
}
public function check_asset_rest(\WP_REST_Request $request) {
if (!is_user_logged_in()) {
return new \WP_Error('aksrt_need_login', __('请先登录', 'aksrt'), ['status' => 401]);
@@ -356,9 +373,36 @@ trait BalanceServiceRest {
}
return true;
};
$business_mutation = static function () use ($user_id, $amount, $points, $operation_key) {
$order_number = 'PX' . strtoupper(substr(hash('sha256', $operation_key), 0, 30));
$business_mutation = static function (int $transaction_id) use ($user_id, $amount, $points, $operation_key, $order_number) {
if (!class_exists('\\AKSRT\\Payment\\OrderRepository')) {
return new \WP_Error('aksrt_order_unavailable', __('订单服务不可用', 'aksrt'), ['status' => 500]);
}
$note = wp_json_encode([
'points_exchange' => 1,
'points' => $points,
'product_title' => sprintf(__('购买 %d 积分', 'aksrt'), $points),
], JSON_UNESCAPED_UNICODE | JSON_UNESCAPED_SLASHES);
$created = \AKSRT\Payment\OrderRepository::get_instance()->create([
'order_number' => $order_number,
'user_id' => $user_id,
'product_type' => \AKSRT\Core\DomainModel::ORDER_PRODUCT_POINTS,
'product_id' => 0,
'amount' => $amount->decimal(),
'currency' => 'CNY',
'status' => \AKSRT\Payment\Order::STATUS_COMPLETED,
'payment_method' => 'balance',
'payment_transaction_id' => 'ledger_' . $transaction_id,
'paid_at' => current_time('mysql'),
'completed_at' => current_time('mysql'),
'note' => is_string($note) ? $note : '',
'request_key' => $operation_key,
]);
if ($created !== $order_number) {
return new \WP_Error('aksrt_order_create_failed', __('积分订单创建失败', 'aksrt'), ['status' => 500]);
}
if (class_exists('\\AKSRT\\Payment\\CommissionLedger')) {
return \AKSRT\Payment\CommissionLedger::get_instance()->record_points_exchange($user_id, $amount->decimal(), $points, $operation_key);
return \AKSRT\Payment\CommissionLedger::get_instance()->record_points_exchange($user_id, $amount->decimal(), $points, $operation_key, $order_number);
}
return true;
};
@@ -368,7 +412,7 @@ trait BalanceServiceRest {
$points,
$operation_key,
'points_exchange',
['type' => 'points_exchange', 'key' => $operation_key],
['type' => 'order', 'key' => $order_number],
sprintf(__('余额兑换 %d 积分', 'aksrt'), $points),
['rate' => $rate],
$guard,
@@ -384,6 +428,7 @@ trait BalanceServiceRest {
'wallet_balance' => \AKSRT\Ledger\AssetAmount::from_minor(\AKSRT\Ledger\AssetType::BALANCE, $result->balance($user_id, \AKSRT\Ledger\AssetType::BALANCE))->decimal(),
'credit_balance' => $result->balance($user_id, \AKSRT\Ledger\AssetType::POINTS),
'points' => $points,
'order_number' => $order_number,
'reload' => true,
]]);
}
src/Payment/ChargeCard.php
+1
View File
@@ -714,6 +714,7 @@ class ChargeCard {
$amount = $parsed_amount->decimal();
$currency = 'CNY';
} elseif ($type === self::TYPE_CREDITS) {
$product_type = \AKSRT\Core\DomainModel::ORDER_PRODUCT_POINTS;
$amount = (int) ($meta['points'] ?? 0);
$currency = 'points';
}
src/Payment/CommissionLedger.php
+2 -2
View File
@@ -28,9 +28,9 @@ final class CommissionLedger {
? true
: new \WP_Error('aksrt_commission_write_failed', __('返佣记录写入失败', 'aksrt'), ['status' => 500]);
}
public function record_points_exchange(int $user_id, string $amount, int $points, string $operation_key): bool {
public function record_points_exchange(int $user_id, string $amount, int $points, string $operation_key, string $order_number): bool {
$result = $this->record_paid_order([
'order_number' => 'PX' . substr(hash('sha256', $operation_key), 0, 30),
'order_number' => $order_number,
'product_type' => 'credits',
'user_id' => $user_id,
'amount' => $amount,
src/Payment/OrderCenterQuery.php
+17 -2
View File
@@ -89,14 +89,29 @@ final class OrderCenterQuery {
public function database_statuses(): array {
return match ($this->status()) {
self::STATUS_PENDING => [Order::STATUS_CREATED, Order::STATUS_PENDING],
self::STATUS_COMPLETED => [Order::STATUS_PAID],
self::STATUS_CLOSED => [Order::STATUS_CANCELLED, Order::STATUS_EXPIRED],
self::STATUS_COMPLETED => [
Order::STATUS_PAID,
Order::STATUS_DELIVERED,
Order::STATUS_COMPLETED,
Order::STATUS_PENDING_REVIEW,
],
self::STATUS_CLOSED => [
Order::STATUS_CANCELLED,
Order::STATUS_EXPIRED,
Order::STATUS_REFUNDING,
Order::STATUS_REFUNDED,
],
default => [
Order::STATUS_CREATED,
Order::STATUS_PENDING,
Order::STATUS_PAID,
Order::STATUS_DELIVERED,
Order::STATUS_COMPLETED,
Order::STATUS_PENDING_REVIEW,
Order::STATUS_CANCELLED,
Order::STATUS_EXPIRED,
Order::STATUS_REFUNDING,
Order::STATUS_REFUNDED,
],
};
}
src/Payment/OrderRepositoryCore.php
+7 -4
View File
@@ -59,9 +59,10 @@ trait OrderRepositoryCore {
'payment_transaction_id' => sanitize_text_field((string) ($data['payment_transaction_id'] ?? '')),
'created_at' => $data['created_at'] ?? current_time('mysql'),
'paid_at' => $data['paid_at'] ?? null,
'completed_at' => $data['completed_at'] ?? null,
'note' => $note,
];
$formats = ['%s', '%d', '%s', '%d', '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s'];
$formats = ['%s', '%d', '%s', '%d', '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s'];
// Pending orders always receive an expiry. Explicit caller values remain
// supported for compatibility, while new flows use the shared runtime policy.
@@ -204,20 +205,22 @@ trait OrderRepositoryCore {
$parts = $this->get_user_order_query_parts($user_id, $args);
$pending_statuses = [Order::STATUS_CREATED, Order::STATUS_PENDING];
$paid_status = Order::STATUS_PAID;
$completed_statuses = [Order::STATUS_PAID, Order::STATUS_DELIVERED, Order::STATUS_COMPLETED, Order::STATUS_PENDING_REVIEW];
$completed_placeholders = implode(', ', array_fill(0, count($completed_statuses), '%s'));
$known_statuses = OrderCenterQuery::from_array([])->database_statuses();
$known_placeholders = implode(', ', array_fill(0, count($known_statuses), '%s'));
$sql = "SELECT
(SELECT COUNT(*) FROM {$this->table()} {$parts['where']}) AS filtered_total,
COUNT(*) AS known_total,
SUM(CASE WHEN status IN (%s, %s) THEN 1 ELSE 0 END) AS pending,
SUM(CASE WHEN status = %s THEN 1 ELSE 0 END) AS completed
SUM(CASE WHEN status IN ({$completed_placeholders}) THEN 1 ELSE 0 END) AS completed
FROM {$this->table()}
WHERE user_id = %d AND status IN ({$known_placeholders})";
$params = array_merge(
$parts['params'],
$pending_statuses,
[$paid_status, $user_id],
$completed_statuses,
[$user_id],
$known_statuses
);
$row = $wpdb->get_row($wpdb->prepare($sql, $params), ARRAY_A);
src/Payment/UserOrders.php
+8 -4
View File
@@ -286,8 +286,8 @@ class UserOrders {
private function status_group(string $status): string {
return match ($status) {
Order::STATUS_CREATED, Order::STATUS_PENDING => OrderCenterQuery::STATUS_PENDING,
Order::STATUS_PAID => OrderCenterQuery::STATUS_COMPLETED,
Order::STATUS_CANCELLED, Order::STATUS_EXPIRED => OrderCenterQuery::STATUS_CLOSED,
Order::STATUS_PAID, Order::STATUS_DELIVERED, Order::STATUS_COMPLETED, Order::STATUS_PENDING_REVIEW => OrderCenterQuery::STATUS_COMPLETED,
Order::STATUS_CANCELLED, Order::STATUS_EXPIRED, Order::STATUS_REFUNDING, Order::STATUS_REFUNDED => OrderCenterQuery::STATUS_CLOSED,
default => OrderCenterQuery::STATUS_CLOSED,
};
}
@@ -313,6 +313,9 @@ class UserOrders {
if ($type === DomainModel::ORDER_PRODUCT_RECHARGE) {
return __('余额充值', 'aksrt');
}
if ($type === DomainModel::ORDER_PRODUCT_POINTS) {
return __('积分购买', 'aksrt');
}
if ($product_id > 0) {
$cache_key = (string) $product_id;
if (!array_key_exists($cache_key, $this->post_title_cache)) {
@@ -354,7 +357,7 @@ class UserOrders {
if ($type === DomainModel::ORDER_PRODUCT_VIP) {
$url = function_exists('aksrt_get_user_center_tab_url') ? aksrt_get_user_center_tab_url('vip') : '';
} elseif ($type === DomainModel::ORDER_PRODUCT_RECHARGE) {
} elseif (in_array($type, [DomainModel::ORDER_PRODUCT_RECHARGE, DomainModel::ORDER_PRODUCT_POINTS], true)) {
$url = function_exists('aksrt_get_user_center_tab_url') ? aksrt_get_user_center_tab_url('credits') : '';
} else {
$url = $post_id > 0 ? get_permalink($post_id) : '';
@@ -368,6 +371,7 @@ class UserOrders {
return match ($type) {
DomainModel::ORDER_PRODUCT_VIP => __('查看会员权益', 'aksrt'),
DomainModel::ORDER_PRODUCT_RECHARGE => __('查看余额', 'aksrt'),
DomainModel::ORDER_PRODUCT_POINTS => __('查看积分', 'aksrt'),
default => __('打开已购内容', 'aksrt'),
};
}
@@ -421,7 +425,7 @@ class UserOrders {
if (!$order) {
return ['success' => false, 'message' => __('当前订单状态不可支付。', 'aksrt')];
}
if ($this->status_group((string) ($order['status'] ?? '')) === OrderCenterQuery::STATUS_PAID) {
if ($this->status_group((string) ($order['status'] ?? '')) === OrderCenterQuery::STATUS_COMPLETED) {
$ledger_key = \AKSRT\Ledger\OperationKey::deterministic('order-payment', [$order_number]);
$history = \AKSRT\Ledger\LedgerQuery::get_instance()->history(['operation_key' => $ledger_key, 'page' => 1, 'per_page' => 1]);
if (!empty($history['items'][0])) {