Khách chuyển thiếu, thừa, sai nội dung: code xử lý sao, đối soát cuối ngày

// webhook-monapay.js: nhận webhook MONA Pay bằng Express
const express = require('express');
const crypto  = require('crypto');

const app    = express();
const SECRET = process.env.MONA_WEBHOOK_SECRET;

app.post('/webhook/monapay', express.raw({ type: 'application/json' }), async (req, res) => {
  const timestamp = req.header('X-Mona-Timestamp') || '';
  const signature = req.header('X-Mona-Signature') || '';
  const rawBody   = req.body.toString('utf8');

  // Verify chữ ký
  const expected = 'sha256=' + crypto.createHmac('sha256', SECRET).update(timestamp + '.' + rawBody).digest('hex');
  const hopLe = signature.length === expected.length && crypto.timingSafeEqual(Buffer.from(signature), Buffer.from(expected));
  if (!hopLe || Math.abs(Date.now() / 1000 - Number(timestamp)) > 300) {
    return res.status(401).send('sai chu ky hoac qua han');
  }

  // Trả 200 ngay
  res.status(200).send('OK');

  const data = JSON.parse(rawBody);
  
  // TODO: Xử lý Idempotency bằng data.transaction_code trước khi tiếp tục
  // let inserted = await db.insertIgnore('giao_dich', { transaction_code: data.transaction_code, ... });
  // if (!inserted) return;

  // Luật khớp đơn hàng
  let donHang = await db.findOrderByAccount(data.account_number); // Ưu tiên 1: Khớp VA
  
  if (!donHang) {
    // Ưu tiên 2: Khớp nội dung chứa mã đơn
    donHang = await db.findOrderInDescription(data.description); 
  }

  if (donHang) {
    if (data.amount === donHang.total) {
      await db.updateOrderStatus(donHang.id, 'paid');
    } else if (data.amount < donHang.total) {
      await db.updateOrderStatus(donHang.id, 'underpaid', data.amount);
    } else {
      await db.updateOrderStatus(donHang.id, 'paid');
      await db.addCustomerCredit(donHang.customer_id, data.amount - donHang.total); // Ghi nhận tiền dư
    }
  }
});

# Giả lập khách chuyển tiền dư
SECRET='secret_hmac_cua_anh_chi'
URL='https://ten-mien-cua-anh-chi.vn/webhook/monapay'
TS=$(date +%s)
BODY='{"amount":3000000,"description":"Thanh toan DH10234","transfer_date":"10:30:00 28/08/2026","transaction_code":"FT26240001234","account_number":"1234567890","bank_name":"ACB","type":"income"}'

SIG=$(printf '%s.%s' "$TS" "$BODY" | openssl dgst -sha256 -hmac "$SECRET" | awk '{print $2}')

curl -X POST "$URL" \
  -H 'Content-Type: application/json' \
  -H "X-Mona-Timestamp: $TS" \
  -H "X-Mona-Signature: sha256=$SIG" \
  --data "$BODY"

async function* monaTransactions(va) {
  for (let page = 1; ; page++) {
    const r = await fetch(`https://api.monapay.vn/api/v1/acb/virtual-account/transactions?virtual_account_number=${va}&page=${page}&limit=100`, {
      headers: { Authorization: `Bearer ${process.env.MONA_TOKEN}` },
    });
    const j = await r.json();
    if (!j.success) throw new Error(j.message);
    yield* j.data.data;
    if (!j.data.has_next) break;
  }
}

// Chạy cronjob đối soát cuối ngày
for await (const tx of monaTransactions('MONA0000010234')) {
  if (tx.debit_or_credit !== 'credit') continue;
  await db.upsertByTransactionCode(tx.transaction_code, tx); // UNIQUE(transaction_code)
  // Thực hiện lại logic khớp đơn hàng nếu giao dịch chưa được ghi nhận
}