121 lines
3.6 KiB
TypeScript
121 lines
3.6 KiB
TypeScript
import type {
|
|
PaymentProvider,
|
|
PaymentType,
|
|
CreatePaymentRequest,
|
|
CreatePaymentResponse,
|
|
QueryOrderResponse,
|
|
PaymentNotification,
|
|
RefundRequest,
|
|
RefundResponse,
|
|
} from '@/lib/payment/types';
|
|
import { pageExecute, execute } from './client';
|
|
import { verifySign } from './sign';
|
|
import { getEnv } from '@/lib/config';
|
|
import type { AlipayTradeQueryResponse, AlipayTradeRefundResponse, AlipayTradeCloseResponse } from './types';
|
|
|
|
export class AlipayProvider implements PaymentProvider {
|
|
readonly name = 'alipay';
|
|
readonly providerKey = 'alipay';
|
|
readonly supportedTypes: PaymentType[] = ['alipay'];
|
|
readonly defaultLimits = {
|
|
alipay: { singleMax: 1000, dailyMax: 10000 },
|
|
};
|
|
|
|
async createPayment(request: CreatePaymentRequest): Promise<CreatePaymentResponse> {
|
|
const url = pageExecute(
|
|
{
|
|
out_trade_no: request.orderId,
|
|
product_code: 'FAST_INSTANT_TRADE_PAY',
|
|
total_amount: request.amount.toFixed(2),
|
|
subject: request.subject,
|
|
},
|
|
{
|
|
notifyUrl: request.notifyUrl,
|
|
returnUrl: request.returnUrl,
|
|
},
|
|
);
|
|
|
|
return {
|
|
tradeNo: request.orderId,
|
|
payUrl: url,
|
|
};
|
|
}
|
|
|
|
async queryOrder(tradeNo: string): Promise<QueryOrderResponse> {
|
|
const result = await execute<AlipayTradeQueryResponse>('alipay.trade.query', {
|
|
out_trade_no: tradeNo,
|
|
});
|
|
|
|
let status: 'pending' | 'paid' | 'failed' | 'refunded';
|
|
switch (result.trade_status) {
|
|
case 'TRADE_SUCCESS':
|
|
case 'TRADE_FINISHED':
|
|
status = 'paid';
|
|
break;
|
|
case 'TRADE_CLOSED':
|
|
status = 'failed';
|
|
break;
|
|
default:
|
|
status = 'pending';
|
|
}
|
|
|
|
return {
|
|
tradeNo: result.trade_no || tradeNo,
|
|
status,
|
|
amount: parseFloat(result.total_amount || '0'),
|
|
paidAt: result.send_pay_date ? new Date(result.send_pay_date) : undefined,
|
|
};
|
|
}
|
|
|
|
async verifyNotification(rawBody: string | Buffer, _headers: Record<string, string>): Promise<PaymentNotification> {
|
|
const env = getEnv();
|
|
const body = typeof rawBody === 'string' ? rawBody : rawBody.toString('utf-8');
|
|
const searchParams = new URLSearchParams(body);
|
|
|
|
const params: Record<string, string> = {};
|
|
for (const [key, value] of searchParams.entries()) {
|
|
params[key] = value;
|
|
}
|
|
|
|
const sign = params.sign || '';
|
|
const paramsForVerify: Record<string, string> = {};
|
|
for (const [key, value] of Object.entries(params)) {
|
|
if (key !== 'sign' && key !== 'sign_type' && value !== undefined && value !== null) {
|
|
paramsForVerify[key] = value;
|
|
}
|
|
}
|
|
|
|
if (!env.ALIPAY_PUBLIC_KEY || !verifySign(paramsForVerify, env.ALIPAY_PUBLIC_KEY, sign)) {
|
|
throw new Error('Alipay notification signature verification failed');
|
|
}
|
|
|
|
return {
|
|
tradeNo: params.trade_no || '',
|
|
orderId: params.out_trade_no || '',
|
|
amount: parseFloat(params.total_amount || '0'),
|
|
status:
|
|
params.trade_status === 'TRADE_SUCCESS' || params.trade_status === 'TRADE_FINISHED' ? 'success' : 'failed',
|
|
rawData: params,
|
|
};
|
|
}
|
|
|
|
async refund(request: RefundRequest): Promise<RefundResponse> {
|
|
const result = await execute<AlipayTradeRefundResponse>('alipay.trade.refund', {
|
|
out_trade_no: request.orderId,
|
|
refund_amount: request.amount.toFixed(2),
|
|
refund_reason: request.reason || '',
|
|
});
|
|
|
|
return {
|
|
refundId: result.trade_no || `${request.orderId}-refund`,
|
|
status: result.fund_change === 'Y' ? 'success' : 'pending',
|
|
};
|
|
}
|
|
|
|
async cancelPayment(tradeNo: string): Promise<void> {
|
|
await execute<AlipayTradeCloseResponse>('alipay.trade.close', {
|
|
out_trade_no: tradeNo,
|
|
});
|
|
}
|
|
}
|