278 lines
11 KiB
JavaScript
278 lines
11 KiB
JavaScript
|
|
|||
|
|
let alipay = require("alipay-sdk");
|
|||
|
|
const AlipaySdkConfig = {
|
|||
|
|
appId: process.env.CONFIG_ALIPAY_MINI_APPID,
|
|||
|
|
privateKey:process.env.CONFIG_ALIPAY_MINI_PRIVATE_KEY,
|
|||
|
|
alipayPublicKey:process.env.CONFIG_ALIPAY_MINI_PUBLIC_KEY,
|
|||
|
|
};
|
|||
|
|
const AlipaySdk = alipay.AlipaySdk;
|
|||
|
|
const alipaySdk = new AlipaySdk(AlipaySdkConfig);
|
|||
|
|
const notifyUrl = process.env.CONFIG_ALIPAY_PAY_NOTIFY
|
|||
|
|
|
|||
|
|
console.log('===============支付宝AppId')
|
|||
|
|
console.log(AlipaySdkConfig.appId)
|
|||
|
|
console.log('===============支付宝公钥')
|
|||
|
|
console.log(AlipaySdkConfig.alipayPublicKey)
|
|||
|
|
console.log('===============支付宝私钥')
|
|||
|
|
console.log(AlipaySdkConfig.privateKey)
|
|||
|
|
const TradeStatus = {
|
|||
|
|
WAIT_BUYER_PAY: 'WAIT_BUYER_PAY',//交易创建，等待买家付款
|
|||
|
|
TRADE_CLOSED: 'TRADE_CLOSED',//未付款交易超时关闭，或支付完成后全额退款
|
|||
|
|
TRADE_SUCCESS: 'TRADE_SUCCESS',//交易成功
|
|||
|
|
TRADE_FINISHED: 'TRADE_FINISHED',//交易完成
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
class aliplayApi {
|
|||
|
|
/**
|
|||
|
|
* 获取accToken
|
|||
|
|
* @param {obj} param0
|
|||
|
|
*/
|
|||
|
|
static async accToken({ code }) {
|
|||
|
|
try {
|
|||
|
|
let params = {
|
|||
|
|
grantType: 'authorization_code',
|
|||
|
|
code,
|
|||
|
|
};
|
|||
|
|
let options = {};
|
|||
|
|
let res = await alipaySdk.exec("alipay.system.oauth.token", params, options);
|
|||
|
|
const accessToken = res && res.accessToken ? res.accessToken : '';
|
|||
|
|
if (accessToken) return accessToken
|
|||
|
|
return Promise.reject({ message: res && res.subMsg ? res.subMsg : '获取token失败' });
|
|||
|
|
}
|
|||
|
|
catch (e) {
|
|||
|
|
return Promise.reject({ message: e.message || '获取token失败' });
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
/**
|
|||
|
|
* 获取用户信息
|
|||
|
|
* @param {obj} param0
|
|||
|
|
*/
|
|||
|
|
static async userInfo(auth_token) {
|
|||
|
|
try {
|
|||
|
|
let res = await alipaySdk.exec("alipay.user.info.share", { auth_token }, {});
|
|||
|
|
if (res && res.code === '10000') {
|
|||
|
|
const { avatar, certNo, mobile, userName, userId } = res;
|
|||
|
|
return { avatar, certNo, mobile, userName, userId };
|
|||
|
|
}
|
|||
|
|
return Promise.reject({ message: res && res.subMsg ? res.subMsg : '获取用户信息失败' });
|
|||
|
|
}
|
|||
|
|
catch (e) {
|
|||
|
|
return Promise.reject({ message: e.message || '获取用户信息失败' });
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
/**
|
|||
|
|
* 创建支付宝交易订单
|
|||
|
|
* @param {Object} params - 订单参数
|
|||
|
|
* @param {String} params.outTradeNo - 商户订单号，必填
|
|||
|
|
* @param {String} params.totalAmount - 订单总金额，单位为元，精确到小数点后两位，必填
|
|||
|
|
* @param {String} params.subject - 订单标题，必填
|
|||
|
|
* @param {String} params.buyerId - 买家支付宝用户ID，小程序场景下必填
|
|||
|
|
* @param {String} params.timeExpire - 订单绝对超时时间 【示例值】2021-12-31 10:05:00
|
|||
|
|
*/
|
|||
|
|
static async createTrade({ outTradeNo, totalAmount, subject, buyerId, timeExpire }) {
|
|||
|
|
try {
|
|||
|
|
// 参数校验
|
|||
|
|
if (!outTradeNo) {
|
|||
|
|
return Promise.reject({ message: '商户订单号不能为空' });
|
|||
|
|
}
|
|||
|
|
if (!totalAmount) {
|
|||
|
|
return Promise.reject({ message: '订单总金额不能为空' });
|
|||
|
|
}
|
|||
|
|
if (!subject) {
|
|||
|
|
return Promise.reject({ message: '订单标题不能为空' });
|
|||
|
|
}
|
|||
|
|
if (!buyerId) {
|
|||
|
|
return Promise.reject({ message: '买家支付宝用户ID不能为空' });
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// 构建请求参数
|
|||
|
|
let bizContent = {
|
|||
|
|
out_trade_no: outTradeNo,
|
|||
|
|
total_amount: totalAmount,
|
|||
|
|
subject: subject,
|
|||
|
|
buyer_id: buyerId,
|
|||
|
|
product_code: 'JSAPI_PAY',
|
|||
|
|
time_expire: timeExpire,
|
|||
|
|
op_app_id: AlipaySdkConfig.appId,
|
|||
|
|
};
|
|||
|
|
|
|||
|
|
let res = await alipaySdk.exec("alipay.trade.create", { notifyUrl, bizContent });
|
|||
|
|
console.log('支付宝创建交易订单响应===')
|
|||
|
|
console.log(res)
|
|||
|
|
console.log('notifyUrl', notifyUrl)
|
|||
|
|
// 检查响应结果
|
|||
|
|
if (res && res.code === '10000') {
|
|||
|
|
// 返回交易号
|
|||
|
|
return {
|
|||
|
|
notifyUrl,
|
|||
|
|
appId: AlipaySdkConfig.appId,
|
|||
|
|
tradeNo: res.tradeNo, // 支付宝交易号
|
|||
|
|
outTradeNo: res.outTradeNo, // 商户订单号
|
|||
|
|
};
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// 返回错误信息
|
|||
|
|
return Promise.reject({
|
|||
|
|
message: res && res.subMsg ? res.subMsg : '创建交易失败',
|
|||
|
|
code: res && res.code ? res.code : '',
|
|||
|
|
});
|
|||
|
|
} catch (e) {
|
|||
|
|
return Promise.reject({ message: `创建交易失败: ${e.message}` });
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
static async queryTrade(trade_no) {
|
|||
|
|
try {
|
|||
|
|
let res = await alipaySdk.exec("alipay.trade.query", { bizContent: { trade_no } });
|
|||
|
|
if (res && res.code === '10000') {
|
|||
|
|
return res
|
|||
|
|
}
|
|||
|
|
return Promise.reject({
|
|||
|
|
message: res && res.subMsg ? res.subMsg : '创建交易失败',
|
|||
|
|
code: res && res.code ? res.code : '',
|
|||
|
|
});
|
|||
|
|
} catch (e) {
|
|||
|
|
return Promise.reject({ message: `查询交易失败: ${e.message}` });
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
/**
|
|||
|
|
* 解析支付宝支付成功回调
|
|||
|
|
* @param {Object} notifyData - 支付宝回调数据（可以是 req.body 或 req.query）
|
|||
|
|
* @returns {Object} 解析后的回调数据
|
|||
|
|
* @returns {String} outTradeNo - 商户订单号
|
|||
|
|
* @returns {String} tradeNo - 支付宝交易号
|
|||
|
|
* @returns {String} tradeStatus - 交易状态
|
|||
|
|
* @returns {String} totalAmount - 订单总金额
|
|||
|
|
* @returns {String} buyerId - 买家支付宝用户ID
|
|||
|
|
* @returns {String} gmtPayment - 支付时间
|
|||
|
|
*/
|
|||
|
|
static parsePayNotify(notifyData) {
|
|||
|
|
try {
|
|||
|
|
// 如果 notifyData 是对象，直接使用；如果是数组，取第一个元素
|
|||
|
|
const params = notifyData && typeof notifyData === 'object' ? notifyData : {};
|
|||
|
|
|
|||
|
|
// 验证签名
|
|||
|
|
// 支付宝SDK的签名验证方法可能因版本而异
|
|||
|
|
// 尝试使用 checkNotifySign 方法验证签名，如果不存在则使用 verify 方法
|
|||
|
|
let signVerified = false;
|
|||
|
|
if (typeof alipaySdk.checkNotifySign === 'function') {
|
|||
|
|
signVerified = alipaySdk.checkNotifySign(params, AlipaySdkConfig.alipayPublicKey);
|
|||
|
|
} else if (typeof alipaySdk.verify === 'function') {
|
|||
|
|
signVerified = alipaySdk.verify(params, AlipaySdkConfig.alipayPublicKey);
|
|||
|
|
} else if (typeof alipay.checkNotifySign === 'function') {
|
|||
|
|
// 尝试使用静态方法
|
|||
|
|
signVerified = alipay.checkNotifySign(params, AlipaySdkConfig.alipayPublicKey);
|
|||
|
|
} else {
|
|||
|
|
// 如果SDK没有提供验证方法，记录警告但继续处理（生产环境建议实现签名验证）
|
|||
|
|
console.warn('警告：支付宝SDK未找到签名验证方法，请确保实现签名验证逻辑');
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
if (!signVerified) {
|
|||
|
|
return Promise.reject({ message: '签名验证失败', verified: false });
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// 解析回调数据
|
|||
|
|
const result = {
|
|||
|
|
outTradeNo: params.out_trade_no || params.outTradeNo, // 商户订单号
|
|||
|
|
tradeNo: params.trade_no || params.tradeNo, // 支付宝交易号
|
|||
|
|
tradeStatus: params.trade_status || params.tradeStatus, // 交易状态
|
|||
|
|
totalAmount: params.total_amount || params.totalAmount, // 订单总金额
|
|||
|
|
buyerId: params.buyer_id || params.buyerId, // 买家支付宝用户ID
|
|||
|
|
buyerLogonId: params.buyer_logon_id || params.buyerLogonId, // 买家支付宝账号
|
|||
|
|
sellerId: params.seller_id || params.sellerId, // 卖家支付宝用户ID
|
|||
|
|
sellerEmail: params.seller_email || params.sellerEmail, // 卖家支付宝账号
|
|||
|
|
gmtCreate: params.gmt_create || params.gmtCreate, // 交易创建时间
|
|||
|
|
gmtPayment: params.gmt_payment || params.gmtPayment, // 交易支付时间
|
|||
|
|
gmtClose: params.gmt_close || params.gmtClose, // 交易关闭时间
|
|||
|
|
subject: params.subject, // 订单标题
|
|||
|
|
body: params.body, // 订单描述
|
|||
|
|
receiptAmount: params.receipt_amount || params.receiptAmount, // 实收金额
|
|||
|
|
invoiceAmount: params.invoice_amount || params.invoiceAmount, // 开票金额
|
|||
|
|
pointAmount: params.point_amount || params.pointAmount, // 集分宝金额
|
|||
|
|
fundBillList: params.fund_bill_list || params.fundBillList, // 支付金额信息
|
|||
|
|
charset: params.charset, // 编码格式
|
|||
|
|
notifyId: params.notify_id || params.notifyId, // 通知校验ID
|
|||
|
|
notifyType: params.notify_type || params.notifyType, // 通知类型
|
|||
|
|
notifyTime: params.notify_time || params.notifyTime, // 通知时间
|
|||
|
|
version: params.version, // 接口版本
|
|||
|
|
signType: params.sign_type || params.signType, // 签名类型
|
|||
|
|
sign: params.sign, // 签名
|
|||
|
|
appId: params.app_id || params.appId, // 支付宝分配给开发者的应用Id
|
|||
|
|
verified: true, // 签名验证通过标识
|
|||
|
|
};
|
|||
|
|
|
|||
|
|
// 检查交易状态
|
|||
|
|
const tradeStatus = result.tradeStatus;
|
|||
|
|
if (tradeStatus === 'TRADE_SUCCESS' || tradeStatus === 'TRADE_FINISHED') {
|
|||
|
|
result.isSuccess = true;
|
|||
|
|
} else {
|
|||
|
|
result.isSuccess = false;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
return result;
|
|||
|
|
} catch (e) {
|
|||
|
|
return Promise.reject({
|
|||
|
|
message: `解析支付回调失败: ${e.message}`,
|
|||
|
|
verified: false,
|
|||
|
|
error: e
|
|||
|
|
});
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
static parseRefundNotify(notifyData) {
|
|||
|
|
try {
|
|||
|
|
const params = notifyData && typeof notifyData === 'object' ? notifyData : {};
|
|||
|
|
let signVerified = false;
|
|||
|
|
if (typeof alipaySdk.checkNotifySign === 'function') {
|
|||
|
|
signVerified = alipaySdk.checkNotifySign(params, AlipaySdkConfig.alipayPublicKey);
|
|||
|
|
} else if (typeof alipaySdk.verify === 'function') {
|
|||
|
|
signVerified = alipaySdk.verify(params, AlipaySdkConfig.alipayPublicKey);
|
|||
|
|
} else if (typeof alipay.checkNotifySign === 'function') {
|
|||
|
|
signVerified = alipay.checkNotifySign(params, AlipaySdkConfig.alipayPublicKey);
|
|||
|
|
} else {
|
|||
|
|
console.warn('警告：支付宝SDK未找到签名验证方法，请确保实现签名验证逻辑');
|
|||
|
|
}
|
|||
|
|
if (!signVerified) {
|
|||
|
|
return Promise.reject({ message: '签名验证失败', verified: false });
|
|||
|
|
}
|
|||
|
|
return params;
|
|||
|
|
} catch (e) {
|
|||
|
|
return Promise.reject({ message: `解析退款回调失败: ${e.message}` });
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
static async refundTrade({ tradeNo, totalAmount: refundAmount, refundReason }) {
|
|||
|
|
try {
|
|||
|
|
let res = await alipaySdk.exec("alipay.trade.refund", {
|
|||
|
|
bizContent: {
|
|||
|
|
refund_amount: refundAmount,
|
|||
|
|
trade_no: tradeNo,
|
|||
|
|
refund_reason: refundReason
|
|||
|
|
}
|
|||
|
|
});
|
|||
|
|
if (res && res.code === '10000') {
|
|||
|
|
return res
|
|||
|
|
}
|
|||
|
|
return Promise.reject({
|
|||
|
|
message: res && res.subMsg ? res.subMsg : '退款失败',
|
|||
|
|
code: res && res.code ? res.code : '',
|
|||
|
|
});
|
|||
|
|
} catch (e) {
|
|||
|
|
return Promise.reject({ message: `退款失败: ${e.message}` });
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
static async queryRefundDetail(trade_no, out_request_no) {
|
|||
|
|
try {
|
|||
|
|
let res = await alipaySdk.exec("alipay.trade.fastpay.refund.query", { bizContent: { trade_no, out_request_no, query_options: ['gmt_refund_pay'] } });
|
|||
|
|
if (res && res.code === '10000') {
|
|||
|
|
return { success: true, data: res }
|
|||
|
|
}
|
|||
|
|
return { success: false, message: res && res.subMsg ? res.subMsg : '查询退款失败', data: res };
|
|||
|
|
} catch (e) {
|
|||
|
|
return Promise.reject({ message: `查询退款详情失败: ${e.message}` });
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
};
|
|||
|
|
|
|||
|
|
module.exports = aliplayApi;
|