Tích hợp qua API và webhook

curl -X POST https://app.bankopenapi.com/api/v1/payment-requests \
  -H "Authorization: Bearer $BANKOPENAPI_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{
    "amount": 150000,
    "orderId": "DH1028",
    "description": "Đơn hàng DH1028"
  }'

const res = await fetch("https://app.bankopenapi.com/api/v1/payment-requests", {
  method: "POST",
  headers: {
    Authorization: `Bearer ${process.env.BANKOPENAPI_API_KEY}`,
    "Content-Type": "application/json",
  },
  body: JSON.stringify({
    amount: 150000,
    orderId: "DH1028",
    description: "Đơn hàng DH1028",
  }),
});
const data = await res.json();
if (!res.ok) throw new Error(`${data.error.code}: ${data.error.message}`);
console.log(data);

<?php
$ch = curl_init('https://app.bankopenapi.com/api/v1/payment-requests');
curl_setopt_array($ch, [
    CURLOPT_RETURNTRANSFER => true,
    CURLOPT_POST => true,
    CURLOPT_HTTPHEADER => [
        'Authorization: Bearer ' . getenv('BANKOPENAPI_API_KEY'),
        'Content-Type: application/json',
    ],
    CURLOPT_POSTFIELDS => json_encode([
        'amount' => 150000,
        'orderId' => 'DH1028',
        'description' => 'Đơn hàng DH1028',
    ]),
]);
$data = json_decode(curl_exec($ch), true);
$status = curl_getinfo($ch, CURLINFO_HTTP_CODE);
curl_close($ch);
if ($status >= 400) {
    throw new Exception($data['error']['code'] . ': ' . $data['error']['message']);
}
print_r($data);

import os
import requests

res = requests.post(
    "https://app.bankopenapi.com/api/v1/payment-requests",
    headers={"Authorization": f"Bearer {os.environ['BANKOPENAPI_API_KEY']}"},
    json={
        "amount": 150000,
        "orderId": "DH1028",
        "description": "Đơn hàng DH1028",
    },
    timeout=15,
)
data = res.json()
if not res.ok:
    raise RuntimeError(f"{data['error']['code']}: {data['error']['message']}")
print(data)

import QRCode from "qrcode"; // npm install qrcode

// Chuỗi VietQR (chuẩn EMVCo của NAPAS) từ trường transfer của yêu cầu thanh toán
const tlv = (id, value) => id + String(value.length).padStart(2, "0") + value;

function crc16(s) {
  let crc = 0xffff;
  for (let i = 0; i < s.length; i++) {
    crc ^= s.charCodeAt(i) << 8;
    for (let j = 0; j < 8; j++) crc = (crc & 0x8000 ? (crc << 1) ^ 0x1021 : crc << 1) & 0xffff;
  }
  return crc.toString(16).toUpperCase().padStart(4, "0");
}

export function vietqr({ bankBin, accountNumber, amount, content }) {
  const merchant = tlv("00", "A000000727") + tlv("01", tlv("00", bankBin) + tlv("01", accountNumber)) + tlv("02", "QRIBFTTA");
  const payload =
    tlv("00", "01") +
    tlv("01", amount > 0 ? "12" : "11") +
    tlv("38", merchant) +
    tlv("53", "704") +
    (amount > 0 ? tlv("54", String(amount)) : "") +
    tlv("58", "VN") +
    (content ? tlv("62", tlv("08", content)) : "") +
    "6304";
  return payload + crc16(payload);
}

// Vẽ ảnh QR (data URL) để đặt vào thẻ <img>
const dataUrl = await QRCode.toDataURL(vietqr(paymentRequest.transfer), { width: 320, margin: 2 });
// <img src={dataUrl} alt="Mã VietQR">

<?php
// Chuỗi VietQR (chuẩn EMVCo của NAPAS) từ trường transfer của yêu cầu thanh toán
function tlv(string $id, string $value): string
{
    return $id . str_pad((string) strlen($value), 2, '0', STR_PAD_LEFT) . $value;
}

function crc16(string $s): string
{
    $crc = 0xFFFF;
    for ($i = 0; $i < strlen($s); $i++) {
        $crc ^= ord($s[$i]) << 8;
        for ($j = 0; $j < 8; $j++) {
            $crc = ($crc & 0x8000 ? ($crc << 1) ^ 0x1021 : $crc << 1) & 0xFFFF;
        }
    }
    return sprintf('%04X', $crc);
}

function vietqr(array $t): string
{
    $merchant = tlv('00', 'A000000727') . tlv('01', tlv('00', $t['bankBin']) . tlv('01', $t['accountNumber'])) . tlv('02', 'QRIBFTTA');
    $payload = tlv('00', '01')
        . tlv('01', $t['amount'] > 0 ? '12' : '11')
        . tlv('38', $merchant)
        . tlv('53', '704')
        . ($t['amount'] > 0 ? tlv('54', (string) $t['amount']) : '')
        . tlv('58', 'VN')
        . ($t['content'] ? tlv('62', tlv('08', $t['content'])) : '')
        . '6304';
    return $payload . crc16($payload);
}

$qr = vietqr($paymentRequest['transfer']);
// Vẽ ảnh bằng thư viện QR bất kỳ, vd. composer require chillerlan/php-qrcode

import qrcode  # pip install "qrcode[pil]"


# Chuỗi VietQR (chuẩn EMVCo của NAPAS) từ trường transfer của yêu cầu thanh toán
def tlv(id: str, value: str) -> str:
    return f"{id}{len(value):02d}{value}"


def crc16(s: str) -> str:
    crc = 0xFFFF
    for ch in s.encode("ascii"):
        crc ^= ch << 8
        for _ in range(8):
            crc = ((crc << 1) ^ 0x1021 if crc & 0x8000 else crc << 1) & 0xFFFF
    return f"{crc:04X}"


def vietqr(t: dict) -> str:
    merchant = tlv("00", "A000000727") + tlv("01", tlv("00", t["bankBin"]) + tlv("01", t["accountNumber"])) + tlv("02", "QRIBFTTA")
    payload = (
        tlv("00", "01")
        + tlv("01", "12" if t["amount"] > 0 else "11")
        + tlv("38", merchant)
        + tlv("53", "704")
        + (tlv("54", str(t["amount"])) if t["amount"] > 0 else "")
        + tlv("58", "VN")
        + (tlv("62", tlv("08", t["content"])) if t["content"] else "")
        + "6304"
    )
    return payload + crc16(payload)


# Vẽ ảnh QR
qrcode.make(vietqr(payment_request["transfer"])).save("vietqr.png")

import express from "express";
import { Webhook } from "standardwebhooks";

const app = express();
// Signing secret của endpoint (dạng "whsec_..."), lấy ở trang Webhook trong app
const wh = new Webhook(process.env.BANKOPENAPI_WEBHOOK_SECRET);

// express.raw giữ nguyên body thô: verify phải chạy trên đúng chuỗi BankOpenAPI đã ký
app.post("/webhooks/bankopenapi", express.raw({ type: "application/json" }), async (req, res) => {
  let event;
  try {
    event = wh.verify(req.body, req.headers);
  } catch {
    return res.status(400).send("Invalid signature");
  }

  // Chống xử lý trùng: một sự kiện giữ nguyên event.id qua mọi lần retry
  if (await alreadyProcessed(event.id)) return res.sendStatus(200);

  if (event.type === "payment_request.paid") {
    await markOrderPaid(event.data.orderId, event.data);
  }

  await markProcessed(event.id);
  res.sendStatus(200);
});

app.listen(3000);

<?php
// composer require standard-webhooks/standard-webhooks  (PHP 8+)
require __DIR__ . '/vendor/autoload.php';

use StandardWebhooks\Webhook;
use StandardWebhooks\Exception\WebhookVerificationException;

$payload = file_get_contents('php://input');
// Thư viện đọc header bằng tên chữ thường: webhook-id, webhook-timestamp, webhook-signature
$headers = array_change_key_case(getallheaders(), CASE_LOWER);

try {
    $wh = new Webhook(getenv('BANKOPENAPI_WEBHOOK_SECRET'));
    $event = $wh->verify($payload, $headers);
} catch (WebhookVerificationException $e) {
    http_response_code(400);
    exit('Invalid signature');
}

// Chống xử lý trùng: một sự kiện giữ nguyên id qua mọi lần retry
if (alreadyProcessed($event['id'])) {
    http_response_code(200);
    exit;
}

if ($event['type'] === 'payment_request.paid') {
    markOrderPaid($event['data']['orderId'], $event['data']);
}

markProcessed($event['id']);
http_response_code(200);

import os
from flask import Flask, request
from standardwebhooks import Webhook, WebhookVerificationError

app = Flask(__name__)
# Signing secret của endpoint (dạng "whsec_..."), lấy ở trang Webhook trong app
wh = Webhook(os.environ["BANKOPENAPI_WEBHOOK_SECRET"])


@app.post("/webhooks/bankopenapi")
def bankopenapi_webhook():
    try:
        # get_data() trả body thô (bytes), đúng chuỗi BankOpenAPI đã ký
        event = wh.verify(request.get_data(), dict(request.headers))
    except WebhookVerificationError:
        return "Invalid signature", 400

    # Chống xử lý trùng: một sự kiện giữ nguyên id qua mọi lần retry
    if already_processed(event["id"]):
        return "", 200

    if event["type"] == "payment_request.paid":
        mark_order_paid(event["data"]["orderId"], event["data"])

    mark_processed(event["id"])
    return "", 200