支付网关一般不必太复杂
来源：dev.to
2024-08-15 08:18:44
0浏览
收藏
欢迎各位小伙伴来到golang学习网，相聚于此都是缘哈哈哈！今天我给大家带来《支付网关一般不必太复杂》，这篇文章主要讲到等等知识，如果你对文章相关的知识非常感兴趣或者正在自学，都可以关注我，我会持续更新相关文章！当然，有什么建议也欢迎在评论留言提出！一起学习！
在 node.js 和 fastify 中使用适配器模式集成支付网关
集成不同的支付网关似乎是一项具有挑战性的任务，但想象一下，如果有一个解决方案使这个过程变得简单而高效，您会感到多么安心。使用设计模式适配器，您将完全控制集成，从而更轻松地维护和扩展您的系统。
现在，想象一下掌握一项技能的力量，它不仅可以节省您的时间，还可以提高代码的质量。在本文中，我们将向您展示如何在使用 node.js 和 fastify 集成支付网关时脱颖而出，fastify 是一项赢得了世界各地开发者青睐的技术。
如果您致力于将自己的技能提升到一个新的水平，那么此内容适合您。让我们一起探索使用 woovi api 创建 pix 费用，以及使您在市场中脱颖而出的其他功能。
我们将介绍使用node.js和fastify集成支付网关。除了其他功能之外，您还将学习如何使用 woovi api 通过 pix 生成费用。
本文是 crazystack node.js 类的一部分，我们在其中使用 node.js 和 fastify 从头开始开发了 rest api。 您可以通过此处和此处的视频跟随本教程的开头部分。
项目结构
我们将以模块化的方式构建项目，每个支付网关都有自己的实现，但每个人都共享一个共同的合约。我们将使用typescript来确保静态类型和代码安全。
目录和文件
-
源代码/
- 合同/
- paymentgateway.ts（所有网关通用的合约）
- 适配器/
- wooviadapter.ts（woovi 网关实现）
- stripeadapter.ts（stripe 网关实现）
- pagarmeadapter.ts（pagar.me 网关的实现）
- index.ts（适配器入口点）
- 配置/
- env.ts（环境设置）
支付网关协议
第一步是定义所有支付网关都必须实现的合约。这确保所有网关具有相同的功能和相同的签名，确保一致性。
// src/contracts/paymentgateway.ts
export abstract class paymentgateway {
abstract createcharge(data: any): promise<any>;
abstract deletecharge(id: string): promise<any>;
abstract getcharge(id: string): promise<any>;
abstract createsubscription(data: any): promise<any>;
abstract getsubscription(id: string): promise<any>;
abstract createcustomer(data: any): promise<any>;
abstract getcustomer(id: string): promise<any>;
abstract getchargebycustomer(data: any): promise<any>;
}
支付网关适配器
wovi 支付网关
woovi 的适配器实现使用 axios 库进行 http 调用。
// src/adapters/wooviadapter.ts
import axios from "axios";
import { paymentgateway } from "../contracts";
import { env } from "../config";
export class woovipaymentgateway extends paymentgateway {
private apikey: string;
constructor(paymentkey: string) {
super();
this.apikey = paymentkey;
}
async deletecharge(id: string): promise<any> {
try {
const response = await axios.delete(
`https://api.openpix.com.br/api/v1/charge/${id}`,
{
headers: { authorization: this.apikey },
}
);
return response?.data;
} catch (e: any) {
return e?.response?.data;
}
}
async getcharge(id: string): promise<any> {
try {
const response = await axios.get(
`https://api.openpix.com.br/api/v1/charge/${id}`,
{
headers: { authorization: this.apikey, "content-type": "application/json" },
}
);
return response?.data;
} catch (e: any) {
return e?.response?.data;
}
}
async createcharge(data: any): promise<any> {
const { correlationid, value, comment } = data;
try {
const { data } = await axios.post(
"https://api.openpix.com.br/api/v1/charge?return_existing=true",
{ correlationid, value, comment },
{
headers: { authorization: this.apikey, "content-type": "application/json" },
}
);
return data;
} catch (e: any) {
return e?.response?.data;
}
}
async createsubscription(body: any): promise<any> {
try {
const { data } = await axios.post(
"https://api.openpix.com.br/api/v1/subscriptions",
body,
{
headers: { authorization: this.apikey, "content-type": "application/json" },
}
);
return data;
} catch (e: any) {
return e?.response?.data;
}
}
async getsubscription(id: string): promise<any> {
try {
const response = await axios.get(
`https://api.openpix.com.br/api/v1/subscriptions/${id}`,
{
headers: { authorization: this.apikey, "content-type": "application/json" },
}
);
return response?.data;
} catch (e: any) {
return e?.response?.data;
}
}
async createcustomer(body: any): promise<any> {
try {
const { data } = await axios.post(
"https://api.openpix.com.br/api/v1/customer",
body,
{
headers: { authorization: this.apikey, "content-type": "application/json" },
}
);
return data;
} catch (e: any) {
return e?.response?.data;
}
}
async getcustomer(id: string): promise<any> {
try {
const response = await axios.get(
`https://api.openpix.com.br/api/v1/customer/${id}`,
{
headers: { authorization: this.apikey, "content-type": "application/json" },
}
);
return response?.data;
} catch (e: any) {
return e?.response?.data;
}
}
async getchargebycustomer(correlationid: string): promise<any> {
try {
const response = await axios.get(
`https://api.openpix.com.br/api/v1/charge?customer=${correlationid}&status=active`,
{
headers: { authorization: this.apikey, "content-type": "application/json" },
}
);
return response?.data;
} catch (e: any) {
return e?.response?.data;
}
}
}
export const makewooviadapter = () => {
return new woovipaymentgateway(env.woovikey);
};
stripe支付网关
对于stripe，我们使用官方的stripe sdk。
// src/adapters/stripeadapter.ts
import { paymentgateway } from "../contracts";
import { env } from "../config";
import stripe from "stripe";
export class stripepaymentgateway extends paymentgateway {
private stripe: stripe;
constructor(paymentkey: string) {
super();
this.stripe = new stripe(paymentkey, {
apiversion: "2023-10-16",
typescript: true,
});
}
async createprice(amount: number): promise<any> {
try {
const price = await this.stripe.prices.create({
currency: "brl",
unit_amount: amount,
recurring: { interval: "month" },
product_data: { name: "gold plan" },
});
return { price };
} catch (e: any) {
return e?.response?.data;
}
}
async createsubscription(data: any): promise<any> {
try {
const subscription = await this.stripe.subscriptions.create({
customer: data?.customer?.id ?? data?.customer?.correlationid,
items: [{ price: data?.priceid }],
});
return { subscription };
} catch (e: any) {
return e?.response?.data;
}
}
async getsubscription(id: string): promise<any> {
try {
const subscription = await this.stripe.subscriptions.retrieve(id);
return { subscription };
} catch (e: any) {
return e?.response?.data;
}
}
async deletecharge(id: string): promise<any> {
try {
const charge = await this.stripe.paymentintents.update(id, {
metadata: { status: "canceled" },
});
return { charge, status: "ok" };
} catch (e: any) {
return e?.response?.data;
}
}
async getcharge(id: string): promise<any> {
try {
const charge = await this.stripe.paymentintents.retrieve(id);
return { charge };
} catch (e: any) {
return e?.response?.data;
}
}
async createcharge(data: any): promise<any> {
try {
const charge = await this.stripe.paymentintents.create({
amount: number(data?.value),
currency: "brl",
metadata: { metadata: json.stringify(data) },
automatic_payment_methods: { enabled: true },
});
return { charge };
} catch (e: any) {
return e?.response?.data;
}
}
async createcustomer(data: any): promise<any> {
const { email, description } = data;
try {
const customer: stripe.customer = await this.stripe.customers.create({
description,
email
,
});
return { customer };
} catch (e: any) {
return e?.response?.data;
}
}
async getcustomer(id: string): promise<any> {
try {
const customer = await this.stripe.customers.retrieve(id);
return { customer };
} catch (e: any) {
return e?.response?.data;
}
}
}
export const makestripeadapter = () => {
return new stripepaymentgateway(env.stripekeysecret);
};
pagar.me 支付网关
pagar.me 的文档详细介绍了如何使用其 api 创建客户端。通过向 /customers 端点发出 post 请求，可以在平台上注册新客户。需要注意的是，电子邮件字段是唯一的：如果已经存在具有相同电子邮件的客户，则数据将被更新，而不是创建新记录。此外，持有护照的客户只能使用有效的国际地址进行交易。
现在，根据这个文档解释pagarmeadapter：
解释 pagarmeadapter
pagarmeadapter 是适配器的实现，它允许您与 pagar.me api 交互以创建和管理客户、费用和订阅。它使用 axios 库对 pagar.me api 进行 http 调用。
创建客户函数
此函数向 pagar.me /customers 端点发送 post 请求，并在请求正文中传递客户数据。 axios 使用 api 令牌（bearer ${this.apikey}）处理身份验证并返回创建或更新的客户端数据。
使用示例：
async createcustomer(data: any): promise<any> {
try {
const response = await axios.post(
"https://api.pagar.me/1/customers",
data,
{
headers: { authorization: `bearer ${this.apikey}` },
}
);
return response?.data;
} catch (e: any) {
return e?.response?.data;
}
}
此功能对于使用适配器模式直接从 node.js 应用程序在 pagar.me 上注册或更新客户至关重要，确保系统的灵活性和模块化。
有关在 pagar.me 创建客户的更多详细信息，请参阅此处的官方文档。
获取客户
pagar.me 文档解释了如何使用 api 获取已注册客户的详细信息。具体的端点是 get https://api.pagar.me/core/v5/customers/{customer_id}，其中 {customer_id} 是您要查询的客户的标识符。
pagarmeadapter说明-getcustomer函数
pagarmeadapter 中的 getcustomer 函数正是执行此操作。它使用提供的 customer_id 向 pagar.me 端点发出 get 请求。这是它的工作原理：
- 身份验证： 该函数使用 api 令牌（bearer ${this.apikey}）来验证请求。
- 请求： 对 pagar.me 端点进行 get 调用，获取与 customer_id 对应的客户详细信息。
- response： 请求成功则返回客户端数据，失败则返回错误响应。
使用示例：
async getcustomer(id: string): promise<any> {
try {
const response = await axios.get(
`https://api.pagar.me/1/customers/${id}`,
{
headers: { authorization: `bearer ${this.apikey}` },
}
);
return response?.data;
} catch (e: any) {
return e?.response?.data;
}
}
此功能允许您直接从 pagar.me api 获取有关特定客户的详细信息，轻松将此功能集成到您的 node.js 系统中。更多详细信息，您可以参考这里的官方文档。
创建交易
pagar.me 文档解释了如何使用 api 获取已注册客户的详细信息。具体的端点是 get https://api.pagar.me/core/v5/customers/{customer_id}，其中 {customer_id} 是您要查询的客户的标识符。
pagarmeadapter说明-getcustomer函数
pagarmeadapter 中的 getcustomer 函数正是执行此操作。它使用提供的 customer_id 向 pagar.me 端点发出 get 请求。这是它的工作原理：
- 身份验证： 该函数使用 api 令牌（bearer ${this.apikey}）来验证请求。
- 请求： 对 pagar.me 端点进行 get 调用，获取与 customer_id 对应的客户详细信息。
- response： 请求成功则返回客户端数据，失败则返回错误响应。
使用示例：
async getcustomer(id: string): promise<any> {
try {
const response = await axios.get(
`https://api.pagar.me/1/customers/${id}`,
{
headers: { authorization: `bearer ${this.apikey}` },
}
);
return response?.data;
} catch (e: any) {
return e?.response?.data;
}
}
此功能允许您直接从 pagar.me api 获取有关特定客户的详细信息，并轻松将此功能集成到您的 node.js 系统中。更多详细信息，您可以参考这里的官方文档。
我们将按照 pagar.me api 文档扩展 pagarmeadapter 以包含处理信用卡交易的特定方法。我还将提供示例测试负载，您可以使用它来验证每种方法。
信用卡的 pagarmeadapter 方法
这是 pagarmeadapter 方法的实现：
import axios from "axios";
import { paymentgateway } from "../contracts";
import { env } from "../config";
export class pagarmepaymentgateway extends paymentgateway {
private apikey: string;
constructor(paymentkey: string) {
super();
this.apikey = paymentkey;
}
async createcharge(data: any): promise<any> {
try {
const response = await axios.post(
"https://api.pagar.me/1/transactions",
data,
{
headers: { authorization: `bearer ${this.apikey}` },
}
);
return response?.data;
} catch (e: any) {
return e?.response?.data;
}
}
async deletecharge(id: string): promise<any> {
try {
const response = await axios.delete(
`https://api.pagar.me/1/transactions/${id}`,
{
headers: { authorization: `bearer ${this.apikey}` },
}
);
return response?.data;
} catch (e: any) {
return e?.response?.data;
}
}
async getcharge(id: string): promise<any> {
try {
const response = await axios.get(
`https://api.pagar.me/1/transactions/${id}`,
{
headers: { authorization: `bearer ${this.apikey}` },
}
);
return response?.data;
} catch (e: any) {
return e?.response?.data;
}
}
async capturecharge(id: string, amount: number): promise<any> {
try {
const response = await axios.post(
`https://api.pagar.me/1/transactions/${id}/capture`,
{ amount },
{
headers: { authorization: `bearer ${this.apikey}` },
}
);
return response?.data;
} catch (e: any) {
return e?.response?.data;
}
}
async refundcharge(id: string, amount: number): promise<any> {
try {
const response = await axios.post(
`https://api.pagar.me/1/transactions/${id}/refund`,
{ amount },
{
headers: { authorization: `bearer ${this.apikey}` },
}
);
return response?.data;
} catch (e: any) {
return e?.response?.data;
}
}
}
export const makepagarmeadapter = () => {
return new pagarmepaymentgateway(env.pagarmekey);
};
测试有效负载示例
- 信用卡交易创建（验证和捕获）
{
"amount": 2990,
"payment_method": "credit_card",
"card_number": "4000000000000010",
"card_cvv": "123",
"card_expiration_date": "1225",
"card_holder_name": "tony stark",
"customer": {
"external_id": "#3311",
"name": "tony stark",
"type": "individual",
"country": "br",
"email": "tonystark@avengers.com",
"documents": [
{
"type": "cpf",
"number": "12345678909"
}
],
"phone_numbers": ["+5511999998888"],
"birthday": "1967-03-01"
},
"billing": {
"name": "tony stark",
"address": {
"country": "br",
"state": "sp",
"city": "sao paulo",
"neighborhood": "bela vista",
"street": "avenida paulista",
"street_number": "1000",
"zipcode": "01310000"
}
},
"items": [
{
"id": "r123",
"title": "chaveiro do tesseract",
"unit_price": 2990,
"quantity": 1,
"tangible": true
}
]
}
- 预授权交易捕获
{
"amount": 2990
}
- 交易退款
{
"amount": 2990
}
解释
- createcharge：创建新的信用卡交易。
- deletecharge：取消现有交易。
- getcharge：获取特定交易的详细信息。
- capturecharge：捕获先前已授权的交易。
- refundcharge：撤销交易。
这些方法涵盖了您可以使用 pagar.me api 对信用卡交易执行的主要操作。提供的有效负载是可用于测试这些功能的基本示例。
完整代码
// src/adapters/PagarmeAdapter.ts
import axios from "axios";
import { PaymentGateway } from "../contracts";
import { env } from "../config";
export class PagarmePaymentGateway extends PaymentGateway {
private apiKey: string;
constructor(paymentKey: string) {
super();
this.apiKey = paymentKey;
}
async createCharge(data: any): Promise<any> {
try {
const response = await axios.post(
"https://api.pagar.me/1/transactions",
data,
{
headers: { Authorization: `Bearer ${this.apiKey}` },
}
);
return response?.data;
} catch (e: any) {
return e?.response?.data;
}
}
async deleteCharge(id: string): Promise<any> {
try {
const response = await axios.delete(
`https://api.pagar.me/1/transactions/${id}`,
{
headers: { Authorization: `Bearer ${this.apiKey}` },
}
);
return response?.data;
} catch (e: any) {
return e?.response?.data;
}
}
async getCharge(id: string): Promise<any> {
try {
const response = await axios.get(
`https://api.pagar.me/1/transactions/${id}`,
{
headers: { Authorization: `Bearer ${this.apiKey}` },
}
);
return response?.data;
} catch (e: any) {
return e?.response?.data;
}
}
async createSubscription(data: any): Promise<any> {
try {
const response = await axios.post(
"https://api.pagar.me/1/subscriptions",
data,
{
headers: { Authorization: `Bearer ${this.apiKey}` },
}
);
return response?.data;
} catch (e: any) {
return e?.response?.data;
}
}
async getSubscription(id: string): Promise<any> {
try {
const response = await axios.get(
`https://api.pagar.me/1/subscriptions/${id}`,
{
headers: { Authorization: `Bearer ${this.apiKey}` },
}
);
return response?.data;
} catch (e: any) {
return e?.response?.data;
}
}
async createCustomer(data: any): Promise<any> {
try {
const response = await axios.post(
"https://api.pagar.me/1/customers",
data,
{
headers: { Authorization: `Bearer ${this.apiKey}` },
}
);
return response?.data;
} catch (e: any) {
return e?.response?.data;
}
}
async getCustomer(id: string): Promise<any> {
try {
const response = await axios.get(
`https://api.pagar.me/1/customers/${id}`,
{
headers: { Authorization: `Bearer ${this.apiKey}` },
}
);
return response?.data;
} catch (e: any) {
return e?.response?.data;
}
}
async getChargeByCustomer(correlationID: string): Promise<any> {
try {
const response = await axios.get(
`https://api.pagar.me/1/transactions?customer=${correlationID}`,
{
headers: { Authorization: `Bearer ${this.apiKey}` },
}
);
return response?.data;
} catch (e: any) {
return e?.response?.data;
}
}
}
export const makePagarmeAdapter = () => {
return new PagarmePaymentGateway(env.pagarmeKey);
};
结论
使用typescript中的adapter模式实现支付网关，使代码集成和维护变得更加容易。通过采用这种方法，您可以保证系统的灵活性和模块化，从而能够轻松添加或更换网关。
要更详细、更实际地了解如何使用 node.js 和 fastify 实现支付网关，请观看我们在 crazystack node.js 第 99 类中的完整视频教程。不要错过这个加深知识并掌握最佳支付系统开发实践的机会。
?重要链接：
- crazystack typescript 课程：crazystack.com.br
- github 上的存储库：crazystacknodejs
本课程是训练营形式的实用强化培训，重点针对想要改进编写代码方式的全职和高级开发人员。您将学习先进的概念，例如设计模式、清洁架构、tdd和ddd，并通过node.js和fastify应用于实际项目。
了解更多并报名！
到这里，我们也就讲完了《支付网关一般不必太复杂》的内容了。个人认为，基础知识的学习和巩固，是为了更好的将其运用到项目中，欢迎关注golang学习网公众号，带你了解更多关于的知识点！
版本声明
本文转载于：dev.to 如有侵犯，请联系study_golang@163.com删除
Java 中函数式编程如何提升代码可读性
- 上一篇
- Java 中函数式编程如何提升代码可读性
- 下一篇
- JavaScript 快速指南：数组方法
查看更多
最新文章
-
- 文章 · 前端 | 10分钟前 |
- 模板字符串进阶技巧与实战应用
- 341浏览 收藏
-
- 文章 · 前端 | 11分钟前 |
- 移动端JS触摸事件与手势识别教程
- 324浏览 收藏
-
- 文章 · 前端 | 13分钟前 |
- CSS表格宽度控制与布局优化技巧
- 262浏览 收藏
-
- 文章 · 前端 | 16分钟前 |
- Pywebview结合Paper.js的图形渲染方法
- 170浏览 收藏
-
- 文章 · 前端 | 19分钟前 |
- 设置已访问链接颜色的CSS方法
- 329浏览 收藏
-
- 文章 · 前端 | 28分钟前 |
- CSS多列卡片布局浮动教程
- 335浏览 收藏
-
- 文章 · 前端 | 32分钟前 |
- 函数柯里化是什么？JavaScript进阶技巧
- 468浏览 收藏
-
- 文章 · 前端 | 33分钟前 |
- 自然语言处理浏览器扩展开发教程
- 346浏览 收藏
-
- 文章 · 前端 | 38分钟前 |
- Generator函数在开发中的实用场景解析
- 371浏览 收藏
-
- 文章 · 前端 | 43分钟前 |
- 跨域问题解决方法全汇总
- 254浏览 收藏
-
- 文章 · 前端 | 43分钟前 |
- 移动端表单布局不一致？BulmaColumns解决方法
- 446浏览 收藏
查看更多
课程推荐
-
- 前端进阶之JavaScript设计模式
- 设计模式是开发人员在软件开发过程中面临一般问题时的解决方案，代表了最佳的实践。本课程的主打内容包括JS常见设计模式以及具体应用场景，打造一站式知识长龙服务，适合有JS基础的同学学习。
- 543次学习
-
- GO语言核心编程课程
- 本课程采用真实案例，全面具体可落地，从理论到实践，一步一步将GO核心编程技术、编程思想、底层实现融会贯通，使学习者贴近时代脉搏，做IT互联网时代的弄潮儿。
- 516次学习
-
- 简单聊聊mysql8与网络通信
- 如有问题加微信：Le-studyg；在课程中，我们将首先介绍MySQL8的新特性，包括性能优化、安全增强、新数据类型等，帮助学生快速熟悉MySQL8的最新功能。接着，我们将深入解析MySQL的网络通信机制，包括协议、连接管理、数据传输等，让
- 500次学习
-
- JavaScript正则表达式基础与实战
- 在任何一门编程语言中,正则表达式,都是一项重要的知识,它提供了高效的字符串匹配与捕获机制,可以极大的简化程序设计。
- 487次学习
-
- 从零制作响应式网站—Grid布局
- 本系列教程将展示从零制作一个假想的网络科技公司官网，分为导航，轮播，关于我们，成功案例，服务流程，团队介绍，数据部分，公司动态，底部信息等内容区块。网站整体采用CSSGrid布局，支持响应式，有流畅过渡和展现动画。
- 485次学习
查看更多
AI推荐
-
- ChatExcel酷表
- ChatExcel酷表是由北京大学团队打造的Excel聊天机器人，用自然语言操控表格，简化数据处理，告别繁琐操作，提升工作效率！适用于学生、上班族及政府人员。
- 3201次使用
-
- Any绘本
- 探索Any绘本（anypicturebook.com/zh），一款开源免费的AI绘本创作工具，基于Google Gemini与Flux AI模型，让您轻松创作个性化绘本。适用于家庭、教育、创作等多种场景，零门槛，高自由度，技术透明，本地可控。
- 3414次使用
-
- 可赞AI
- 可赞AI，AI驱动的办公可视化智能工具，助您轻松实现文本与可视化元素高效转化。无论是智能文档生成、多格式文本解析，还是一键生成专业图表、脑图、知识卡片，可赞AI都能让信息处理更清晰高效。覆盖数据汇报、会议纪要、内容营销等全场景，大幅提升办公效率，降低专业门槛，是您提升工作效率的得力助手。
- 3444次使用
-
- 星月写作
- 星月写作是国内首款聚焦中文网络小说创作的AI辅助工具，解决网文作者从构思到变现的全流程痛点。AI扫榜、专属模板、全链路适配，助力新人快速上手，资深作者效率倍增。
- 4552次使用
-
- MagicLight
- MagicLight.ai是全球首款叙事驱动型AI动画视频创作平台，专注于解决从故事想法到完整动画的全流程痛点。它通过自研AI模型，保障角色、风格、场景高度一致性，让零动画经验者也能高效产出专业级叙事内容。广泛适用于独立创作者、动画工作室、教育机构及企业营销，助您轻松实现创意落地与商业化。
- 3822次使用
查看更多
相关文章
-
- JavaScript函数定义及示例详解
- 2025-05-11 502浏览
-
- 优化用户界面体验的秘密武器：CSS开发项目经验大揭秘
- 2023-11-03 501浏览
-
- 使用微信小程序实现图片轮播特效
- 2023-11-21 501浏览
-
- 解析sessionStorage的存储能力与限制
- 2024-01-11 501浏览
-
- 探索冒泡活动对于团队合作的推动力
- 2024-01-13 501浏览
