-
{'\u00A5'}{amount.toFixed(2)}
+
{'\u00A5'}{displayAmount.toFixed(2)}
+ {hasFeeDiff && (
+
+ 到账 ¥{amount.toFixed(2)}
+
+ )}
{expired ? TEXT_EXPIRED : `${TEXT_REMAINING}: ${timeLeft}`}
diff --git a/src/lib/easy-pay/provider.ts b/src/lib/easy-pay/provider.ts
index fcab030..df6bd9b 100644
--- a/src/lib/easy-pay/provider.ts
+++ b/src/lib/easy-pay/provider.ts
@@ -14,6 +14,7 @@ import { getEnv } from '@/lib/config';
export class EasyPayProvider implements PaymentProvider {
readonly name = 'easy-pay';
+ readonly providerKey = 'easypay';
readonly supportedTypes: PaymentType[] = ['alipay', 'wxpay'];
readonly defaultLimits = {
alipay: { singleMax: 1000, dailyMax: 10000 },
diff --git a/src/lib/order/fee.ts b/src/lib/order/fee.ts
new file mode 100644
index 0000000..16fb626
--- /dev/null
+++ b/src/lib/order/fee.ts
@@ -0,0 +1,38 @@
+import { initPaymentProviders, paymentRegistry } from '@/lib/payment';
+
+/**
+ * 获取指定支付渠道的手续费率（百分比）。
+ * 优先级：FEE_RATE_{TYPE} > FEE_RATE_PROVIDER_{KEY} > 0
+ */
+export function getMethodFeeRate(paymentType: string): number {
+ // 渠道级别：FEE_RATE_ALIPAY / FEE_RATE_WXPAY / FEE_RATE_STRIPE
+ const methodRaw = process.env[`FEE_RATE_${paymentType.toUpperCase()}`];
+ if (methodRaw !== undefined && methodRaw !== '') {
+ const num = Number(methodRaw);
+ if (Number.isFinite(num) && num >= 0) return num;
+ }
+
+ // 提供商级别：FEE_RATE_PROVIDER_EASYPAY / FEE_RATE_PROVIDER_STRIPE
+ initPaymentProviders();
+ const providerKey = paymentRegistry.getProviderKey(paymentType);
+ if (providerKey) {
+ const providerRaw = process.env[`FEE_RATE_PROVIDER_${providerKey.toUpperCase()}`];
+ if (providerRaw !== undefined && providerRaw !== '') {
+ const num = Number(providerRaw);
+ if (Number.isFinite(num) && num >= 0) return num;
+ }
+ }
+
+ return 0;
+}
+
+/**
+ * 根据到账金额和手续费率计算实付金额。
+ * feeAmount = ceil(rechargeAmount * feeRate / 100 * 100) / 100 （进一制到分）
+ * payAmount = rechargeAmount + feeAmount
+ */
+export function calculatePayAmount(rechargeAmount: number, feeRate: number): number {
+ if (feeRate <= 0) return rechargeAmount;
+ const feeAmount = Math.ceil(rechargeAmount * feeRate / 100 * 100) / 100;
+ return Math.round((rechargeAmount + feeAmount) * 100) / 100;
+}
diff --git a/src/lib/order/limits.ts b/src/lib/order/limits.ts
index fa117e5..cd198ba 100644
--- a/src/lib/order/limits.ts
+++ b/src/lib/order/limits.ts
@@ -1,6 +1,7 @@
import { prisma } from '@/lib/db';
import { getEnv } from '@/lib/config';
import { initPaymentProviders, paymentRegistry } from '@/lib/payment';
+import { getMethodFeeRate } from './fee';
/**
* 获取指定支付渠道的每日全平台限额（0 = 不限制）。
@@ -55,6 +56,8 @@ export interface MethodLimitStatus {
available: boolean;
/** 单笔限额，0 = 使用全局配置 MAX_RECHARGE_AMOUNT */
singleMax: number;
+ /** 手续费率百分比，0 = 无手续费 */
+ feeRate: number;
}
/**
@@ -85,6 +88,7 @@ export async function queryMethodLimits(
for (const type of paymentTypes) {
const dailyLimit = getMethodDailyLimit(type);
const singleMax = getMethodSingleLimit(type);
+ const feeRate = getMethodFeeRate(type);
const used = usageMap[type] ?? 0;
const remaining = dailyLimit > 0 ? Math.max(0, dailyLimit - used) : null;
result[type] = {
@@ -93,6 +97,7 @@ export async function queryMethodLimits(
remaining,
available: dailyLimit === 0 || used < dailyLimit,
singleMax,
+ feeRate,
};
}
return result;
diff --git a/src/lib/order/service.ts b/src/lib/order/service.ts
index 8f31487..fad0bd7 100644
--- a/src/lib/order/service.ts
+++ b/src/lib/order/service.ts
@@ -2,6 +2,7 @@ import { prisma } from '@/lib/db';
import { getEnv } from '@/lib/config';
import { generateRechargeCode } from './code-gen';
import { getMethodDailyLimit } from './limits';
+import { getMethodFeeRate, calculatePayAmount } from './fee';
import { initPaymentProviders, paymentRegistry } from '@/lib/payment';
import type { PaymentType, PaymentNotification } from '@/lib/payment';
import { getUser, createAndRedeem, subtractBalance } from '@/lib/sub2api/client';
@@ -22,6 +23,8 @@ export interface CreateOrderInput {
export interface CreateOrderResult {
orderId: string;
amount: number;
+ payAmount: number;
+ feeRate: number;
status: string;
paymentType: PaymentType;
userName: string;
@@ -96,6 +99,9 @@ export async function createOrder(input: CreateOrderInput): Promise
0 ? new Prisma.Decimal(feeRate.toFixed(2)) : null,
rechargeCode: '',
status: 'PENDING',
paymentType: input.paymentType,
@@ -125,9 +133,9 @@ export async function createOrder(input: CreateOrderInput): Promise {
throw new OrderError('INVALID_STATUS', 'Only completed orders can be refunded', 400);
}
- const amount = Number(order.amount);
+ const rechargeAmount = Number(order.amount);
+ const refundAmount = Number(order.payAmount ?? order.amount);
if (!input.force) {
try {
const user = await getUser(order.userId);
- if (user.balance < amount) {
+ if (user.balance < rechargeAmount) {
return {
success: false,
- warning: `User balance ${user.balance} is lower than refund ${amount}`,
+ warning: `User balance ${user.balance} is lower than refund ${rechargeAmount}`,
requireForce: true,
};
}
@@ -587,18 +599,18 @@ export async function processRefund(input: RefundInput): Promise {
await provider.refund({
tradeNo: order.paymentTradeNo,
orderId: order.id,
- amount,
+ amount: refundAmount,
reason: input.reason,
});
}
- await subtractBalance(order.userId, amount, `sub2apipay refund order:${order.id}`, `sub2apipay:refund:${order.id}`);
+ await subtractBalance(order.userId, rechargeAmount, `sub2apipay refund order:${order.id}`, `sub2apipay:refund:${order.id}`);
await prisma.order.update({
where: { id: input.orderId },
data: {
status: 'REFUNDED',
- refundAmount: new Prisma.Decimal(amount.toFixed(2)),
+ refundAmount: new Prisma.Decimal(refundAmount.toFixed(2)),
refundReason: input.reason || null,
refundAt: new Date(),
forceRefund: input.force || false,
@@ -609,7 +621,7 @@ export async function processRefund(input: RefundInput): Promise {
data: {
orderId: input.orderId,
action: 'REFUND_SUCCESS',
- detail: JSON.stringify({ amount, reason: input.reason, force: input.force }),
+ detail: JSON.stringify({ rechargeAmount, refundAmount, reason: input.reason, force: input.force }),
operator: 'admin',
},
});
diff --git a/src/lib/payment/registry.ts b/src/lib/payment/registry.ts
index c805543..e66a16f 100644
--- a/src/lib/payment/registry.ts
+++ b/src/lib/payment/registry.ts
@@ -30,6 +30,12 @@ export class PaymentProviderRegistry {
const provider = this.providers.get(type as PaymentType);
return provider?.defaultLimits?.[type];
}
+
+ /** 获取指定渠道对应的提供商 key（如 'easypay'、'stripe'） */
+ getProviderKey(type: string): string | undefined {
+ const provider = this.providers.get(type as PaymentType);
+ return provider?.providerKey;
+ }
}
export const paymentRegistry = new PaymentProviderRegistry();
diff --git a/src/lib/payment/types.ts b/src/lib/payment/types.ts
index 813080a..9cbb890 100644
--- a/src/lib/payment/types.ts
+++ b/src/lib/payment/types.ts
@@ -62,6 +62,7 @@ export interface MethodDefaultLimits {
/** Common interface that all payment providers must implement */
export interface PaymentProvider {
readonly name: string;
+ readonly providerKey: string;
readonly supportedTypes: PaymentType[];
/** 各渠道默认限额，key 为 PaymentType（如 'alipay'），可被环境变量覆盖 */
readonly defaultLimits?: Record;
diff --git a/src/lib/stripe/provider.ts b/src/lib/stripe/provider.ts
index 3f8c28c..e4c73f2 100644
--- a/src/lib/stripe/provider.ts
+++ b/src/lib/stripe/provider.ts
@@ -14,6 +14,7 @@ import type {
export class StripeProvider implements PaymentProvider {
readonly name = 'stripe';
+ readonly providerKey = 'stripe';
readonly supportedTypes: PaymentType[] = ['stripe'];
readonly defaultLimits = {
stripe: { singleMax: 0, dailyMax: 0 }, // 0 = unlimited