feat: add reference system

Author: imrim12

app/pages/checkout.vue

@@ -21,11 +21,13 @@ useSeoMeta({
 
 defineOgImageComponent('Saas')
 
+const { t } = useI18n()
+
 const route = useRoute()
 
 const checkoutQr = computed(() => String(route.query.qr))
 const checkoutInfo = computed(() => {
-  const query = parseQuery(checkoutQr.value)
+  const query = parseQuery(checkoutQr.value.split('?')[1] || '')
 
   return query
 })
@@ -49,11 +51,11 @@ whenever(data, (response) => {
     navigateTo({ path: '/app' })
   }
   else {
-    notifyError({
-      content: 'We have not received your payment yet. Please try again later, or contact support if the issue persists.',
+    notifyWarning({
+      content: t('We have not received your payment yet. Please try again later, or contact support if the issue persists.'),
     })
   }
-})
+}, { immediate: true })
 </script>
 
 <template>
@@ -62,6 +64,12 @@ whenever(data, (response) => {
       :title="page.topup.title"
       :description="page.topup.description"
     >
+      <UBanner
+        icon="i-lucide-triangle-alert"
+        color="warning"
+        :title="$t('Modification of the transaction is prohibited and could potentially lead to account suspension!')"
+      />
+
       <div class="grid md:grid-cols-2 gap-4 items-start">
         <div class="flex justify-center">
           <img
@@ -84,9 +92,14 @@ whenever(data, (response) => {
               <span class="text-lg font-semibold text-gray-900 dark:text-white">{{ checkoutInfo.bank }}</span>
             </div>
 
+            <div class="flex justify-between items-center">
+              <span class="text-lg font-medium text-gray-500 dark:text-gray-400">{{ $t('Bank Number') }}</span>
+              <span class="text-lg font-semibold text-gray-900 dark:text-white">{{ checkoutInfo.acc }}</span>
+            </div>
+
             <div class="flex justify-between items-center">
               <span class="text-lg font-medium text-gray-500 dark:text-gray-400">{{ $t('Amount') }}</span>
-              <span class="text-xl font-bold text-primary-500 dark:text-primary-400">{{ checkoutInfo.amount }}</span>
+              <span class="text-xl font-bold text-primary-500 dark:text-primary-400">{{ new Intl.NumberFormat('en-US', { style: 'currency', currency: 'VND' }).format(Number(checkoutInfo.amount)) }}</span>
             </div>
 
             <div class="flex justify-between items-start">

i18n/en.json

@@ -228,8 +228,13 @@
   "Infor": "Infor",
   "Payment Summary": "Payment Summary",
   "Bank Name": "Bank Name",
+  "Bank Number": "Bank Number",
   "Amount": "Amount",
   "Description": "Description",
+  "Discount": "Discount",
+  "We have not received your payment yet. Please try again later, or contact support if the issue persists.": "We have not received your payment yet. Please try again later, or contact support if the issue persists.",
   "Please verify the details before proceeding with the payment.": "Please verify the details before proceeding with the payment.",
-  "I have transfered the money! (Click here)": "I have transfered the money! (Click here)"
+  "Modification of the transaction is prohibited and could potentially lead to account suspension!": "Modification of the transaction is prohibited and could potentially lead to account suspension!",
+  "I have transfered the money! (Click here)": "I have transfered the money! (Click here)",
+  "No discount applied!": "No discount applied!"
 }

i18n/vi.json

@@ -228,8 +228,13 @@
   "Infor": "Thông tin",
   "Payment Summary": "Thông tin thanh toán",
   "Bank Name": "Ngân hàng",
+  "Bank Number": "Số tài khoản",
   "Amount": "Số tiền",
   "Description": "Mô tả",
-  "Please verify the details before proceeding with the payment.": "Vui lòng xác minh thông tin trước khi tiếp tục thanh toán.",
-  "I have transfered the money! (Click here)": "Tôi đã chuyển tiền! (Nhấp vào đây)"
+  "Discount": "Giảm giá",
+  "We have not received your payment yet. Please try again later, or contact support if the issue persists.": "Chúng tôi chưa nhận được thanh toán của bạn. Vui lòng thử lại trong giây lát, hoặc liên hệ với bộ phận hỗ trợ nếu vấn đề vẫn tiếp diễn.",
+  "Please verify the details before proceeding with the payment.": "Vui lòng xác minh các chi tiết trước khi tiếp tục thanh toán.",
+  "Modification of the transaction is prohibited and could potentially lead to account suspension!": "Việc sửa đổi nội dung giao dịch bị cấm và có thể dẫn đến việc tạm ngưng tài khoản!",
+  "I have transfered the money! (Click here)": "Tôi đã chuyển tiền! (Nhấp vào đây)",
+  "No discount applied!": "Không có mã giảm giá!"
 }

package.json

@@ -1,7 +1,7 @@
 {
   "name": "@thecodeorigin/nuxt",
   "type": "module",
-  "version": "2.6.3",
+  "version": "2.7.0",
   "publishConfig": {
     "registry": "https://registry.npmjs.org",
     "access": "public"

server/api/payments/sepay/webhook.post.ts

@@ -3,35 +3,21 @@ import { z } from 'zod'
 
 export default defineEventHandler(async (event) => {
   try {
-    // {
-    //   gateway: "ACB",
-    //   transactionDate: "2025-05-23 23:34:40",
-    //   accountNumber: "17228427",
-    //   subAccount: null,
-    //   code: "SPN8NHOSTING123",
-    //   content: "MBVCB.9604208212.518683.SPN8NHOSTING123.CT tu 0041000331568 NGUYEN HUU NGUYEN Y toi 17228427 NGUYEN HUU NGUYEN Y tai ACB GD 518683-052325 23:34:40",
-    //   transferType: "in",
-    //   description: "BankAPINotify MBVCB.9604208212.518683.SPN8NHOSTING123.CT tu 0041000331568 NGUYEN HUU NGUYEN Y toi 17228427 NGUYEN HUU NGUYEN Y tai ACB GD 518683-052325 23:34:40",
-    //   transferAmount: 2000,
-    //   referenceCode: "3165",
-    //   accumulated: 0,
-    //   id: 13425123,
-    // }
     const body = await readValidatedBody(
       event,
       payload => z.object({
-        accountNumber: z.string(),
-        accumulated: z.number(),
-        code: z.string(),
-        content: z.string(),
-        description: z.string(),
-        gateway: z.string(),
-        id: z.number(),
-        referenceCode: z.string(),
-        subAccount: z.string().optional().nullable(),
-        transactionDate: z.string(),
-        transferAmount: z.number(),
-        transferType: z.string(),
+        accountNumber: z.string(), // e.g., "17228427"
+        accumulated: z.number(), // e.g., 0
+        code: z.string(), // e.g., "SPN8NHOSTING123"
+        content: z.string(), // e.g., "MBVCB.9604208212.518683.SPN8NHOSTING123.CT tu 0041000331568 NGUYEN HUU NGUYEN Y toi 17228427 NGUYEN HUU NGUYEN Y tai ACB GD 518683-052325 23:34:40"
+        description: z.string(), // e.g., "BankAPINotify MBVCB.9604208212.518683.SPN8NHOSTING123.CT tu 0041000331568 NGUYEN HUU NGUYEN Y toi 17228427 NGUYEN HUU NGUYEN Y tai ACB GD 518683-052325 23:34:40"
+        gateway: z.string(), // e.g., "ACB"
+        id: z.number(), // e.g., 13425123
+        referenceCode: z.string(), // e.g., "3165"
+        subAccount: z.string().optional().nullable(), // e.g., null
+        transactionDate: z.string(), // e.g., "2025-05-23 23:34:40"
+        transferAmount: z.number(), // e.g., 2000
+        transferType: z.string(), // e.g., "in"
       }).parse(payload),
     )
 
@@ -61,10 +47,20 @@ export default defineEventHandler(async (event) => {
 
     logger.log(`[SePay Webhook] Processing transaction: code=${orderCode}, status=${transactionStatus}`)
 
-    const priceDiscount = Number(paymentTransactionOfProvider.payment.order.package.price_discount)
-    const price = Number(paymentTransactionOfProvider.payment.order.package.price)
+    const userId = paymentTransactionOfProvider.payment.order.user_id
+
+    const { getUserBestPrice, createReferenceUsage } = useReference()
+
+    const reference = paymentTransactionOfProvider.payment.order.reference
+
+    const price = await getUserBestPrice(
+      userId,
+      Number(paymentTransactionOfProvider.payment.order.package.price),
+      Number(paymentTransactionOfProvider.payment.order.package.price_discount),
+      reference?.code,
+    )
 
-    if (priceDiscount !== Number(body.transferAmount) && price !== Number(body.transferAmount)) {
+    if (price !== Number(body.transferAmount)) {
       logger.error(`[SePay Webhook] Amount mismatch, transaction [${paymentTransactionOfProvider.id}]: expected=${price}, received=${body.transferAmount}`)
 
       throw createError({
@@ -74,7 +70,6 @@ export default defineEventHandler(async (event) => {
     }
 
     const creditAmount = Number(paymentTransactionOfProvider.payment.order.package.amount)
-    const userId = paymentTransactionOfProvider.payment.order.user_id
 
     // The userId is already the UUID from our database since we've updated
     // our schemas to use UUID references between tables
@@ -98,6 +93,14 @@ export default defineEventHandler(async (event) => {
 
     await updatePaymentStatus(paymentTransactionOfProvider.payment.id, transactionStatus)
 
+    if (reference) {
+      await createReferenceUsage(
+        userId,
+        reference.id || '',
+        paymentTransactionOfProvider.id,
+      )
+    }
+
     logger.log(`[SePay Webhook] Transaction updated successfully: id=${paymentTransactionOfProvider.id}, status=${transactionStatus}`)
 
     logger.log('[SePay Webhook] Webhook processing completed successfully')

server/api/ref/[referCode].get.ts

@@ -0,0 +1,19 @@
+import { withQuery } from 'ufo'
+
+export default defineEventHandler(async (event) => {
+  try {
+    const { referCode } = await defineEventOptions(event, { params: [REFERENCE_CODE_COOKIE_NAME] })
+
+    setCookie(event, REFERENCE_CODE_COOKIE_NAME, referCode, {
+      httpOnly: true,
+    })
+
+    return sendRedirect(event, withQuery('/pricing', { referCode }), 301)
+  }
+  catch (error: any) {
+    throw createError({
+      statusCode: 503,
+      statusMessage: error.message,
+    })
+  }
+})

server/composables/usePayment.ts

@@ -3,11 +3,12 @@ import { PaymentStatus, orderTable, paymentProviderTransactionTable, paymentTabl
 import type { Order, Payment, PaymentProviderTransaction } from '../types/models'
 
 export function usePayment() {
-  async function createOrder(productId: string, userId: string): Promise<Order> {
+  async function createOrder(productId: string, userId: string, referenceId?: string): Promise<Order> {
     return (
       await db.insert(orderTable).values({
         product_id: productId,
         user_id: userId,
+        reference_id: referenceId,
       }).returning()
     )[0]
   }
@@ -55,6 +56,7 @@ export function usePayment() {
     | (PaymentProviderTransaction & {
       payment: Payment & {
         order: Order & {
+          reference: any
           package: any
         }
       }
@@ -68,6 +70,7 @@ export function usePayment() {
           with: {
             order: {
               with: {
+                reference: true,
                 package: true,
               },
             },

server/composables/useReference.ts

@@ -0,0 +1,90 @@
+import { eq, sql } from 'drizzle-orm'
+import { referenceTable, referenceUsageTable } from '../db/schemas'
+
+export const REFERENCE_CODE_COOKIE_NAME = 'referCode'
+
+export function useReference() {
+  function getReferenceById(referenceId: string) {
+    return db.query.referenceTable.findFirst({
+      where(schema, { eq }) {
+        return eq(schema.id, referenceId)
+      },
+    })
+  }
+
+  function getReferenceByCode(referenceCode: string) {
+    return db.query.referenceTable.findFirst({
+      where(schema, { eq }) {
+        return eq(schema.code, referenceCode)
+      },
+    })
+  }
+
+  function getUserReferenceUsage(userId: string) {
+    return db.query.referenceUsageTable.findFirst({
+      where(schema, { eq }) {
+        return eq(schema.user_id, userId)
+      },
+    })
+  }
+
+  async function getUserBestPrice(userId: string, originalPrice: number, discountPrice?: number | null, referCode?: string | null) {
+    const userReferenceUsage = await getUserReferenceUsage(userId)
+
+    let price = originalPrice
+
+    if (!userReferenceUsage && referCode) {
+      const reference = await getReferenceByCode(referCode)
+
+      if (reference) {
+        const referenceInStock = reference.quantity === null || reference.quantity > 0
+
+        if (referenceInStock && reference?.percentage) {
+          price = originalPrice * (1 - reference.percentage / 100)
+        }
+        else if (referenceInStock && reference?.amount) {
+          price = originalPrice - reference.amount
+        }
+      }
+    }
+
+    // use the best price for the customer
+    price = Math.ceil(
+      discountPrice
+        ? Math.min(discountPrice, price)
+        : price,
+    )
+
+    if (!price) {
+      throw createError({
+        statusCode: 400,
+        statusMessage: ErrorMessage.BAD_REQUEST,
+      })
+    }
+
+    return price
+  }
+
+  async function createReferenceUsage(userId: string, referenceId: string, paymentProviderTransactionId: string) {
+    const referenceUsage = await db.insert(referenceUsageTable).values({
+      user_id: userId,
+      reference_id: referenceId,
+      payment_provider_transaction_id: paymentProviderTransactionId,
+    }).returning()
+
+    await db.update(referenceTable)
+      .set({
+        quantity: sql`${referenceTable.quantity} - 1`,
+      })
+      .where(eq(referenceTable.id, referenceId))
+
+    return referenceUsage[0]
+  }
+
+  return {
+    getReferenceById,
+    getUserReferenceUsage,
+    getUserBestPrice,
+    createReferenceUsage,
+  }
+}

server/db/schemas/index.ts

@@ -4,6 +4,8 @@ export * from './products.schema'
 
 export * from './enum.schema'
 
+export * from './identities.schema'
+
 export * from './payment_provider_transactions.schema'
 
 export * from './notifications.schema'
@@ -16,4 +18,6 @@ export * from './payments.schema'
 
 export * from './users.schema'
 
-export * from './identities.schema'
+export * from './reference_usages.schema'
+
+export * from './references.schema'

server/db/schemas/orders.schema.ts

@@ -3,13 +3,16 @@ import { relations } from 'drizzle-orm/relations'
 import { paymentTable } from './payments.schema'
 import { productTable } from './products.schema'
 import { userTable } from './users.schema'
+import { referenceTable } from './references.schema'
 
 export const orderTable = pgTable('orders', {
   id: uuid('id').defaultRandom().primaryKey().notNull(),
   user_id: uuid('user_id')
     .references(() => userTable.id, { onDelete: 'cascade', onUpdate: 'cascade' }).notNull(),
   product_id: uuid('product_id')
     .references(() => productTable.id, { onDelete: 'no action', onUpdate: 'no action' }),
+  reference_id: uuid('reference_id')
+    .references(() => referenceTable.id, { onDelete: 'no action', onUpdate: 'no action' }),
   created_at: timestamp('created_at', { withTimezone: true }).defaultNow().notNull(),
   updated_at: timestamp('updated_at', { withTimezone: true }).defaultNow().$onUpdate(() => new Date()),
 })
@@ -27,4 +30,8 @@ export const userOrderRelations = relations(orderTable, ({ one }) => ({
     fields: [orderTable.user_id],
     references: [userTable.id],
   }),
+  reference: one(referenceTable, {
+    fields: [orderTable.reference_id],
+    references: [referenceTable.id],
+  }),
 }))