[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_157":158,"_159":160},"routes/_app.x.$handle.$name",{"_96":95,"_32":45,"_105":86,"_27":106,"_13":14,"_107":-5,"_11":108,"_109":110,"_111":112,"_113":114,"_115":116,"_20":-5,"_117":-5,"_118":-5,"_119":25,"_120":121,"_122":123,"_124":-5,"_125":-5,"_126":127},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_43":44,"_32":45,"_38":46,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":-5,"_53":-5,"_18":54,"_55":-5,"_56":25,"_57":-5,"_58":-5,"_59":60,"_61":62,"_63":64,"_65":66,"_67":68,"_69":-5,"_70":71,"_72":71,"_73":74,"_75":74,"_76":74,"_77":71,"_78":71,"_79":80,"_81":82,"_83":84,"_85":25},"version",17,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":37,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",false,"deletedHere","path","main.ts","latestPath","fileId","21e2e8c0-5271-11f1-9fe8-ee650bb23af1","name","fileType","http","content","// KHÓA TOKEN TRỰC TIẾP TRÁNH LỖI MÔI TRƯỜNG VAL TOWN\nconst TOKEN = \"8842521974:AAHpKkdNYYQRnvwfDd3a-eZXVvYBBLeQHpw\";\nconst DB_URL = \"postgresql://postgres:password@helium/heliumdb?sslmode=disable\"; // Thay link db của bạn vào đây nếu cần\nconst ADMIN_ID = \"8353052961\";\nconst STORE_URL = \"https://t.me/PHL0990\";\n\nimport {\n Bot,\n webhookCallback,\n} from \"https://deno.land/x/grammy@v1.36.3/mod.ts\";\nimport postgres from \"https://deno.land/x/postgresjs@v3.4.5/mod.js\";\n\nconst sql = postgres(DB_URL, { ssl: \"require\" });\nconst bot = new Bot(TOKEN);\n\nfunction fmt(n) {\n return Number(n).toLocaleString(\"vi-VN\") + \"đ\";\n}\nfunction isAdmin(ctx) {\n return String(ctx.from?.id) === ADMIN_ID;\n}\n\nasync function getOrCreateUser(tgId, tgUser) {\n const username = tgUser || `tg_${tgId}`;\n const rows =\n await sql`SELECT * FROM users WHERE id_telegram = ${tgId} LIMIT 1`;\n if (rows.length) return rows[0];\n const [created] =\n await sql`INSERT INTO users (username, id_telegram, balance, total_deposit, total_spent, total_bought) VALUES (${username}, ${tgId}, 0, 0, 0, 0) RETURNING *`;\n return created;\n}\n\nconst mainKeyboard = {\n keyboard: [[{ text: \"💰 Số dư\" }, { text: \"🛍 Sản phẩm\" }], [{\n text: \"💳 Nạp tiền\",\n }, { text: \"🏆 Bảng xếp hạng\" }], [{ text: \"👤 Tài khoản\" }, {\n text: \"🔑 Mật khẩu\",\n }]],\n resize_keyboard: true,\n};\n\nbot.command(\"start\", async (ctx) => {\n const user = await getOrCreateUser(String(ctx.from.id), ctx.from.username);\n await ctx.reply(\n `👋 *Chào mừng đến với STORT PHL!*\\n\\n💰 Số dư: *${\n fmt(user.balance)\n }*\\n🔑 Dùng /setpassword để tạo mật khẩu web.`,\n { parse_mode: \"Markdown\", reply_markup: mainKeyboard },\n );\n});\n\nbot.command(\"help\", async (ctx) => {\n await ctx.reply(\n `📖 *HƯỚNG DẪN LỆNH:*\\n/balance - Xem số dư\\n/products - Xem sản phẩm\\n/deposit - Nạp tiền\\n/setpassword [mật khẩu] - Đặt pass web`,\n { parse_mode: \"Markdown\" },\n );\n});\n\nbot.command(\"balance\", async (ctx) => {\n const user = await getOrCreateUser(String(ctx.from.id), ctx.from.username);\n await ctx.reply(\n `💰 *Số dư:* ${fmt(user.balance)}\\n📥 *Tổng nạp:* ${\n fmt(user.total_deposit)\n }`,\n { parse_mode: \"Markdown\" },\n );\n});\n\nbot.command(\"products\", async (ctx) => {\n try {\n const categories = await sql`SELECT * FROM categories ORDER BY id`;\n const products = await sql`SELECT * FROM products ORDER BY cat_id, price`;\n let msg = `🛍 *DANH SÁCH SẢN PHẨM*\\n\\n`;\n for (const cat of categories) {\n const cp = products.filter((p) => p.cat_id === cat.id);\n if (!cp.length) continue;\n msg += `*${cat.name}*\\n`;\n cp.forEach((p) => {\n msg += ` • ${p.name} — *${fmt(p.price)}*\\n`;\n });\n msg += \"\\n\";\n }\n await ctx.reply(msg, { parse_mode: \"Markdown\" });\n } catch {\n await ctx.reply(\"❌ Lỗi kết nối dữ liệu sản phẩm.\");\n }\n});\n\nbot.command(\"deposit\", async (ctx) => {\n const user = await getOrCreateUser(String(ctx.from.id), ctx.from.username);\n await ctx.reply(\n `💳 *NẠP TIỀN TỰ ĐỘNG*\\n🏦 VCB: \\`1522608620\\`\\n👤 PHAM DOAN HOANG LONG\\n📝 Nội dung: \\`NAP ${user.username.toUpperCase()}\\``,\n { parse_mode: \"Markdown\" },\n );\n});\n\nbot.command(\"setpassword\", async (ctx) => {\n const parts = ctx.message.text.trim().split(/\\s+/);\n if (parts.length < 2) {\n return ctx.reply(\"❌ Cú pháp: /setpassword mật_khẩu_mới\");\n }\n const user = await getOrCreateUser(String(ctx.from.id), ctx.from.username);\n await sql`UPDATE users SET password = ${\n parts[1]\n } WHERE username = ${user.username}`;\n await ctx.reply(`✅ Đã đặt mật khẩu web thành công!`, {\n parse_mode: \"Markdown\",\n });\n});\n\nbot.hears(\"💰 Số dư\", (ctx) => bot.api.emulate(ctx.from.id, \"/balance\"));\nbot.hears(\"🛍 Sản phẩm\", (ctx) => bot.api.emulate(ctx.from.id, \"/products\"));\nbot.hears(\"💳 Nạp tiền\", (ctx) => bot.api.emulate(ctx.from.id, \"/deposit\"));\nbot.hears(\"🏆 Bảng xếp hạng\", async (ctx) => {\n const users =\n await sql`SELECT * FROM users ORDER BY total_deposit DESC LIMIT 10`;\n let msg = `🏆 *TOP NẠP TIỀN*\\n\\n`;\n users.forEach((u, i) => {\n msg += `${i + 1}. ${u.username} — *${fmt(u.total_deposit)}*\\n`;\n });\n await ctx.reply(msg, { parse_mode: \"Markdown\" });\n});\n\nbot.command(\"topup\", async (ctx) => {\n if (!isAdmin(ctx)) return;\n const parts = ctx.message.text.trim().split(/\\s+/);\n if (parts.length < 3) return ctx.reply(\"Cú pháp: /topup username sotien\");\n const username = parts[1], amount = parseInt(parts[2]);\n await sql`UPDATE users SET balance = balance + ${amount}, total_deposit = total_deposit + ${amount} WHERE username = ${username}`;\n ctx.reply(`✅ Đã nạp thành công ${fmt(amount)} cho ${username}`);\n});\n\nconst handleUpdate = webhookCallback(bot, \"std/http\");\nexport default async function handler(req) {\n if (req.method === \"POST\") return await handleUpdate(req);\n const url = new URL(req.url);\n if (url.searchParams.get(\"set_webhook\")) {\n await bot.api.setWebhook(url.searchParams.get(\"set_webhook\"));\n return new Response(\"OK Webhook\");\n }\n return new Response(\"Bot is running!\");\n}","import { Markup, Telegraf } from \"telegraf\";\nimport { drizzle } from \"drizzle-orm/node-postgres\";\nimport {\n bigint,\n integer,\n pgTable,\n serial,\n text,\n timestamp,\n} from \"drizzle-orm/pg-core\";\nimport { desc, eq } from \"drizzle-orm\";\nimport pg from \"pg\";\n\nconst { Pool } = pg;\n\n// ─── CONFIG ────────────────────────────────────────────────────────────────────\nconst BOT_TOKEN = process.env.TELEGRAM_BOT_TOKEN;\nconst DATABASE_URL = process.env.DATABASE_URL;\nconst ADMIN_ID = Number(process.env.ADMIN_ID ?? \"8353052961\");\nconst BOT_LINK = \"https://t.me/storephl0990bot\";\nconst BANK_NAME = \"Vietcombank\";\nconst BANK_ACCOUNT = \"1522608620\";\nconst BANK_HOLDER = \"PHAM DOAN HOANG LONG\";\nconst BANK_CODE = \"VCB\";\nconst MIN_DEPOSIT = 10000;\nconst REFERRAL_BONUS = 500;\n\nif (!BOT_TOKEN) throw new Error(\"TELEGRAM_BOT_TOKEN is required\");\nif (!DATABASE_URL) throw new Error(\"DATABASE_URL is required\");\n\n// ─── DATABASE ──────────────────────────────────────────────────────────────────\nconst pool = new Pool({ connectionString: DATABASE_URL });\nconst db = drizzle(pool);\n\nconst usersTable = pgTable(\"users\", {\n id: bigint(\"id\", { mode: \"number\" }).primaryKey(),\n username: text(\"username\"),\n firstName: text(\"first_name\"),\n lastName: text(\"last_name\"),\n balance: integer(\"balance\").notNull().default(0),\n totalDeposited: integer(\"total_deposited\").notNull().default(0),\n totalSpent: integer(\"total_spent\").notNull().default(0),\n totalPurchases: integer(\"total_purchases\").notNull().default(0),\n referredBy: bigint(\"referred_by\", { mode: \"number\" }),\n referralEarnings: integer(\"referral_earnings\").notNull().default(0),\n referralRewarded: integer(\"referral_rewarded\").notNull().default(0),\n createdAt: timestamp(\"created_at\").notNull().defaultNow(),\n});\n\nconst ordersTable = pgTable(\"orders\", {\n id: serial(\"id\").primaryKey(),\n userId: bigint(\"user_id\", { mode: \"number\" }).notNull(),\n productId: text(\"product_id\").notNull(),\n productName: text(\"product_name\").notNull(),\n duration: text(\"duration\").notNull(),\n price: integer(\"price\").notNull(),\n keyValue: text(\"key_value\"),\n status: text(\"status\").notNull().default(\"completed\"),\n createdAt: timestamp(\"created_at\").notNull().defaultNow(),\n});\n\nconst transactionsTable = pgTable(\"transactions\", {\n id: serial(\"id\").primaryKey(),\n userId: bigint(\"user_id\", { mode: \"number\" }).notNull(),\n amount: integer(\"amount\").notNull(),\n type: text(\"type\").notNull(),\n status: text(\"status\").notNull().default(\"pending\"),\n transferContent: text(\"transfer_content\"),\n note: text(\"note\"),\n approvedBy: bigint(\"approved_by\", { mode: \"number\" }),\n createdAt: timestamp(\"created_at\").notNull().defaultNow(),\n updatedAt: timestamp(\"updated_at\").notNull().defaultNow(),\n});\n\nconst priceOverridesTable = pgTable(\"price_overrides\", {\n id: serial(\"id\").primaryKey(),\n productId: text(\"product_id\").notNull(),\n duration: text(\"duration\").notNull(),\n price: integer(\"price\").notNull(),\n updatedAt: timestamp(\"updated_at\").notNull().defaultNow(),\n});\n\nasync function initDB() {\n await pool.query(`\n CREATE TABLE IF NOT EXISTS users (\n id BIGINT PRIMARY KEY,\n username TEXT,\n first_name TEXT,\n last_name TEXT,\n balance INTEGER NOT NULL DEFAULT 0,\n total_deposited INTEGER NOT NULL DEFAULT 0,\n total_spent INTEGER NOT NULL DEFAULT 0,\n total_purchases INTEGER NOT NULL DEFAULT 0,\n referred_by BIGINT,\n referral_earnings INTEGER NOT NULL DEFAULT 0,\n referral_rewarded INTEGER NOT NULL DEFAULT 0,\n created_at TIMESTAMP NOT NULL DEFAULT NOW()\n );\n CREATE TABLE IF NOT EXISTS orders (\n id SERIAL PRIMARY KEY,\n user_id BIGINT NOT NULL,\n product_id TEXT NOT NULL,\n product_name TEXT NOT NULL,\n duration TEXT NOT NULL,\n price INTEGER NOT NULL,\n key_value TEXT,\n status TEXT NOT NULL DEFAULT 'completed',\n created_at TIMESTAMP NOT NULL DEFAULT NOW()\n );\n CREATE TABLE IF NOT EXISTS transactions (\n id SERIAL PRIMARY KEY,\n user_id BIGINT NOT NULL,\n amount INTEGER NOT NULL,\n type TEXT NOT NULL,\n status TEXT NOT NULL DEFAULT 'pending',\n transfer_content TEXT,\n note TEXT,\n approved_by BIGINT,\n created_at TIMESTAMP NOT NULL DEFAULT NOW(),\n updated_at TIMESTAMP NOT NULL DEFAULT NOW()\n );\n CREATE TABLE IF NOT EXISTS price_overrides (\n id SERIAL PRIMARY KEY,\n product_id TEXT NOT NULL,\n duration TEXT NOT NULL,\n price INTEGER NOT NULL,\n updated_at TIMESTAMP NOT NULL DEFAULT NOW()\n );\n `);\n console.log(\"✅ Database tables ready\");\n}\n\n// ─── PRODUCTS ──────────────────────────────────────────────────────────────────\nconst PRODUCTS = [\n {\n id: \"migul_lite\",\n name: \"Migul Lite\",\n emoji: \"🛍️\",\n description: \"☠️ ALL SERVER ANTIBAND VIP\\naim, esp, no recoil\",\n packages: [{ duration: \"day\", durationLabel: \"1 Ngày\", price: 50000 }, {\n duration: \"week\",\n durationLabel: \"1 Tuần\",\n price: 150000,\n }, { duration: \"month\", durationLabel: \"1 Tháng\", price: 350000 }],\n },\n {\n id: \"migul_pro\",\n name: \"Migul Pro\",\n emoji: \"👑\",\n description:\n \"👑 ALL SERVER ANTIBAND VIP\\nkéo địch, quấn máu nhanh, teleport 8m, bắn xuyên tường, nhảy dù nhanh\",\n packages: [{ duration: \"week\", durationLabel: \"1 Tuần\", price: 215000 }, {\n duration: \"month\",\n durationLabel: \"1 Tháng\",\n price: 450000,\n }],\n },\n {\n id: \"migul_tipa\",\n name: \"Migul Tipa\",\n emoji: \"💎\",\n description: \"💎 Tipa ALL SERVER ANTIBAND VIP\",\n packages: [{ duration: \"week\", durationLabel: \"1 Tuần\", price: 80000 }, {\n duration: \"month\",\n durationLabel: \"1 Tháng\",\n price: 180000,\n }],\n },\n {\n id: \"fluorite\",\n name: \"IPA Fluorite Antiban\",\n emoji: \"🛍️\",\n description: \"🌟 ALL SERVER ANTIBAND VIP\\nBảo hành key zin\",\n packages: [\n { duration: \"day\", durationLabel: \"1 Ngày (+4h)\", price: 80000 },\n { duration: \"week\", durationLabel: \"1 Tuần (+1 ngày)\", price: 260000 },\n { duration: \"month\", durationLabel: \"1 Tháng (+2 ngày)\", price: 350000 },\n ],\n },\n {\n id: \"proxy_vip\",\n name: \"Proxy VIP\",\n emoji: \"🔒\",\n description:\n \"🌐 Proxy VIP tốc độ cao\\n🔗 https://chunchuche.io.vn\\nNhập key và ID Game để lấy cổng proxy.\",\n packages: [{ duration: \"day\", durationLabel: \"1 Ngày\", price: 20000 }, {\n duration: \"week\",\n durationLabel: \"7 Ngày\",\n price: 80000,\n }, { duration: \"month\", durationLabel: \"30 Ngày\", price: 180000 }],\n },\n {\n id: \"drip_android\",\n name: \"Drip Client Android\",\n emoji: \"🌟\",\n description: \"📱 Drip Client Android No Root\",\n packages: [{ duration: \"day\", durationLabel: \"1 Ngày\", price: 60000 }, {\n duration: \"week\",\n durationLabel: \"1 Tuần\",\n price: 75000,\n }, { duration: \"month\", durationLabel: \"1 Tháng\", price: 170000 }],\n },\n];\n\nfunction getProduct(id) {\n return PRODUCTS.find((p) => p.id === id);\n}\nfunction formatPrice(price) {\n return price.toLocaleString(\"vi-VN\") + \"đ\";\n}\n\nasync function getEffectivePrices(productId) {\n const overrides = await db.select().from(priceOverridesTable).where(\n eq(priceOverridesTable.productId, productId),\n );\n const map = {};\n for (const o of overrides) map[o.duration] = o.price;\n return map;\n}\nfunction applyOverrides(packages, overrides) {\n return packages.map((pkg) => ({\n ...pkg,\n price: overrides[pkg.duration] ?? pkg.price,\n }));\n}\n\n// ─── STATE (in-memory) ─────────────────────────────────────────────────────────\nconst userStates = new Map();\nconst adminStates = new Map();\nfunction getUserState(id) {\n return userStates.get(id) ?? { step: \"idle\" };\n}\nfunction setUserState(id, s) {\n userStates.set(id, s);\n}\nfunction clearUserState(id) {\n userStates.set(id, { step: \"idle\" });\n}\nfunction getAdminState(id) {\n return adminStates.get(id) ?? { step: \"idle\" };\n}\nfunction setAdminState(id, s) {\n adminStates.set(id, s);\n}\nfunction clearAdminState(id) {\n adminStates.set(id, { step: \"idle\" });\n}\n\n// ─── KEYBOARDS ─────────────────────────────────────────────────────────────────\nconst mainKeyboard = Markup.keyboard([\n [\"🛍️ Mua Key/Acc\", \"💳 Nạp Tiền\"],\n [\"💎 Cá Nhân\", \"🏆 Top Nạp\"],\n [\"📋 Lịch Sử Nạp\", \"📜 Lịch Sử Mua\"],\n [\"👨 Hỗ Trợ\"],\n]).resize().persistent();\n\nfunction productListKeyboard() {\n const buttons = PRODUCTS.map((p) =>\n Markup.button.callback(`${p.emoji} ${p.name}`, `product:${p.id}`)\n );\n const rows = [];\n for (let i = 0; i < buttons.length; i += 2) {\n rows.push(buttons.slice(i, i + 2));\n }\n rows.push([Markup.button.callback(\"🔙 Quay Lại\", \"back:main\")]);\n return Markup.inlineKeyboard(rows);\n}\nfunction productPackagesKeyboard(productId, packages) {\n const product = PRODUCTS.find((p) => p.id === productId);\n if (!product) return Markup.inlineKeyboard([]);\n const pkgs = packages ?? product.packages;\n const buttons = pkgs.map((pkg) =>\n Markup.button.callback(\n `${pkg.durationLabel} — ${formatPrice(pkg.price)}`,\n `buy:${productId}:${pkg.duration}`,\n )\n );\n return Markup.inlineKeyboard([...buttons.map((b) => [b]), [\n Markup.button.callback(\"🔙 Quay Lại\", \"back:products\"),\n ]]);\n}\nfunction confirmPurchaseKeyboard(productId, duration) {\n return Markup.inlineKeyboard([[\n Markup.button.callback(\n \"✅ Xác Nhận Mua\",\n `confirm:${productId}:${duration}`,\n ),\n Markup.button.callback(\"❌ Hủy\", \"back:products\"),\n ]]);\n}\nfunction cancelDepositKeyboard() {\n return Markup.inlineKeyboard([[\n Markup.button.callback(\"❌ Hủy Lệnh Nạp\", \"cancel:deposit\"),\n ]]);\n}\nfunction adminDepositKeyboard(txId, userId) {\n return Markup.inlineKeyboard([[\n Markup.button.callback(\"✅ Duyệt\", `admin:approve:${txId}:${userId}`),\n Markup.button.callback(\"❌ Từ Chối\", `admin:reject:${txId}:${userId}`),\n ]]);\n}\nfunction adminEnterKeyKeyboard(orderId) {\n return Markup.inlineKeyboard([\n [Markup.button.callback(\n `📝 Nhập Key cho đơn #${orderId}`,\n `admin:enterkey:${orderId}`,\n )],\n [Markup.button.callback(\n `❌ Hủy đơn #${orderId}`,\n `admin:cancelorder:${orderId}`,\n )],\n ]);\n}\n\n// ─── HELPERS ───────────────────────────────────────────────────────────────────\nfunction isAdmin(ctx) {\n return ctx.from?.id === ADMIN_ID;\n}\nfunction generateQR(amount, content) {\n return `https://img.vietqr.io/image/${BANK_CODE}-${BANK_ACCOUNT}-compact2.png?amount=${amount}&addInfo=${\n encodeURIComponent(content)\n }&accountName=${encodeURIComponent(BANK_HOLDER)}`;\n}\nasync function deleteMessages(ctx, chatId, ids) {\n for (const id of ids) {\n try {\n await ctx.telegram.deleteMessage(chatId, id);\n } catch {}\n }\n}\n\n// ─── HANDLERS: START ───────────────────────────────────────────────────────────\nasync function handleStart(ctx) {\n const tgUser = ctx.from;\n if (!tgUser) return;\n const startPayload = ctx.startPayload;\n const referrerId = startPayload ? parseInt(startPayload, 10) : null;\n const validReferrer =\n referrerId && !isNaN(referrerId) && referrerId !== tgUser.id\n ? referrerId\n : null;\n const existing = await db.select().from(usersTable).where(\n eq(usersTable.id, tgUser.id),\n ).limit(1);\n if (existing.length === 0) {\n let resolvedReferrer = null;\n if (validReferrer) {\n const [ref] = await db.select().from(usersTable).where(\n eq(usersTable.id, validReferrer),\n ).limit(1);\n if (ref) resolvedReferrer = validReferrer;\n }\n await db.insert(usersTable).values({\n id: tgUser.id,\n username: tgUser.username ?? null,\n firstName: tgUser.first_name,\n lastName: tgUser.last_name ?? null,\n balance: 0,\n totalDeposited: 0,\n totalSpent: 0,\n totalPurchases: 0,\n referredBy: resolvedReferrer,\n referralEarnings: 0,\n referralRewarded: 0,\n });\n } else {\n await db.update(usersTable).set({\n username: tgUser.username ?? null,\n firstName: tgUser.first_name,\n lastName: tgUser.last_name ?? null,\n }).where(eq(usersTable.id, tgUser.id));\n }\n const name = tgUser.first_name +\n (tgUser.last_name ? ` ${tgUser.last_name}` : \"\");\n await ctx.reply(\n `⭐ HỆ THỐNG DỊCH VỤ TỰ ĐỘNG\\n━━━━━━━━━━━━━━━━━━━━━━\\n\\n👋 Chào mừng ${name}\\nđã đến với Bot. Hệ thống luôn trực 24/7!\\n\\n🚀 Sử dụng Menu bên dưới để chọn tính năng.`,\n { parse_mode: \"HTML\", ...mainKeyboard },\n );\n}\n\n// ─── HANDLERS: SHOP ────────────────────────────────────────────────────────────\nasync function handleShop(ctx) {\n await ctx.reply(\n `🛍️ DANH SÁCH SẢN PHẨM\\n━━━━━━━━━━━━━━━━━━━━━━\\n\\nChào mừng bạn đến với cửa hàng!\\nVui lòng chọn danh mục bạn muốn xem:`,\n { parse_mode: \"HTML\", ...productListKeyboard() },\n );\n}\nasync function handleProductSelect(ctx, productId) {\n const product = getProduct(productId);\n if (!product) {\n await ctx.answerCbQuery(\"Sản phẩm không tồn tại!\");\n return;\n }\n const overrides = await getEffectivePrices(productId);\n const effectivePkgs = applyOverrides(product.packages, overrides);\n await ctx.editMessageText(\n `${product.emoji} ${product.name}\\n━━━━━━━━━━━━━━━━━━━━━━\\n\\n📋 Mô tả:\\n${product.description}\\n\\nChọn gói bạn muốn mua:`,\n {\n parse_mode: \"HTML\",\n ...productPackagesKeyboard(productId, effectivePkgs),\n },\n );\n await ctx.answerCbQuery();\n}\nasync function handleBuySelect(ctx, productId, duration) {\n const tgUser = ctx.from;\n if (!tgUser) return;\n const product = getProduct(productId);\n if (!product) {\n await ctx.answerCbQuery(\"Sản phẩm không tồn tại!\");\n return;\n }\n const overrides = await getEffectivePrices(productId);\n const effectivePkgs = applyOverrides(product.packages, overrides);\n const pkg = effectivePkgs.find((p) => p.duration === duration);\n if (!pkg) {\n await ctx.answerCbQuery(\"Gói không tồn tại!\");\n return;\n }\n const [user] = await db.select().from(usersTable).where(\n eq(usersTable.id, tgUser.id),\n ).limit(1);\n const balance = user?.balance ?? 0;\n const canAfford = balance >= pkg.price;\n await ctx.editMessageText(\n `🛒 XÁC NHẬN ĐƠN HÀNG\\n━━━━━━━━━━━━━━━━━━━━━━\\n\\n📦 Sản phẩm: ${product.name}\\n⏱️ Thời hạn: ${pkg.durationLabel}\\n💰 Giá: ${\n formatPrice(pkg.price)\n }\\n💳 Số dư: ${formatPrice(balance)}\\n` +\n (canAfford\n ? `✅ Số dư đủ để mua!`\n : `❌ Số dư không đủ! Cần thêm ${\n formatPrice(pkg.price - balance)\n }`),\n {\n parse_mode: \"HTML\",\n ...(canAfford\n ? confirmPurchaseKeyboard(productId, duration)\n : productPackagesKeyboard(productId, effectivePkgs)),\n },\n );\n await ctx.answerCbQuery();\n}\nasync function handleConfirmPurchase(ctx, productId, duration) {\n const tgUser = ctx.from;\n if (!tgUser) return;\n const product = getProduct(productId);\n if (!product) {\n await ctx.answerCbQuery(\"Sản phẩm không tồn tại!\");\n return;\n }\n const overrides = await getEffectivePrices(productId);\n const effectivePkgs = applyOverrides(product.packages, overrides);\n const pkg = effectivePkgs.find((p) => p.duration === duration);\n if (!pkg) {\n await ctx.answerCbQuery(\"Gói không tồn tại!\");\n return;\n }\n const [user] = await db.select().from(usersTable).where(\n eq(usersTable.id, tgUser.id),\n ).limit(1);\n if (!user || user.balance < pkg.price) {\n await ctx.answerCbQuery(\"Số dư không đủ!\");\n await ctx.editMessageText(\n `❌ Số dư không đủ!\\nVui lòng nạp thêm tiền và thử lại.`,\n { parse_mode: \"HTML\" },\n );\n return;\n }\n await db.update(usersTable).set({\n balance: user.balance - pkg.price,\n totalSpent: user.totalSpent + pkg.price,\n totalPurchases: user.totalPurchases + 1,\n }).where(eq(usersTable.id, tgUser.id));\n const [order] = await db.insert(ordersTable).values({\n userId: tgUser.id,\n productId,\n productName: product.name,\n duration,\n price: pkg.price,\n keyValue: null,\n status: \"waiting_key\",\n }).returning();\n if (!order) {\n await db.update(usersTable).set({\n balance: user.balance,\n totalSpent: user.totalSpent,\n totalPurchases: user.totalPurchases,\n }).where(eq(usersTable.id, tgUser.id));\n await ctx.editMessageText(\"❌ Có lỗi xảy ra, vui lòng thử lại!\");\n return;\n }\n await ctx.editMessageText(\n `✅ ĐẶT HÀNG THÀNH CÔNG!\\n━━━━━━━━━━━━━━━━━━━━━━\\n\\n📦 Sản phẩm: ${product.name}\\n⏱️ Thời hạn: ${pkg.durationLabel}\\n💰 Đã trừ: ${\n formatPrice(pkg.price)\n }\\n💳 Số dư còn: ${\n formatPrice(user.balance - pkg.price)\n }\\n\\n⏳ Đơn hàng #${order.id} đang xử lý...\\n🔑 Key sẽ được gửi khi admin xác nhận!`,\n { parse_mode: \"HTML\" },\n );\n await ctx.answerCbQuery(\"Đặt hàng thành công!\");\n const userName = user.firstName + (user.lastName ? ` ${user.lastName}` : \"\");\n try {\n await ctx.telegram.sendMessage(\n ADMIN_ID,\n `🛒 ĐƠN HÀNG MỚI #${order.id}\\n━━━━━━━━━━━━━━━━━━━━━━\\n\\n👤 Khách: ${userName}\\n🆔 ID: ${tgUser.id}\\n📱 Username: ${\n tgUser.username ? `@${tgUser.username}` : \"Không có\"\n }\\n\\n📦 Sản phẩm: ${product.name}\\n⏱️ Thời hạn: ${pkg.durationLabel}\\n💰 Giá: ${\n formatPrice(pkg.price)\n }\\n\\n👇 Nhấn nút bên dưới để nhập key:`,\n { parse_mode: \"HTML\", ...adminEnterKeyKeyboard(order.id) },\n );\n } catch (err) {\n console.error(\"Admin notification failed:\", err);\n }\n}\n\n// ─── HANDLERS: DEPOSIT ─────────────────────────────────────────────────────────\nasync function handleDeposit(ctx) {\n const tgUser = ctx.from;\n if (!tgUser) return;\n const state = getUserState(tgUser.id);\n if (state.step !== \"idle\") {\n await ctx.reply(\n `⚠️ Bạn đang có lệnh nạp đang chờ.\\nVui lòng hủy lệnh cũ trước!`,\n cancelDepositKeyboard(),\n );\n return;\n }\n const sent = await ctx.reply(\n `💸 TIẾN TRÌNH NẠP TIỀN TỰ ĐỘNG\\n━━━━━━━━━━━━━━━━━━━━━━\\n\\n👉 HƯỚNG DẪN:\\n1. Nhập số tiền vào khung chat.\\n2. Quét QR Code để chuyển khoản.\\n3. Sau khi chuyển khoản, admin xác nhận.\\n\\n🏧 Nhập số tiền (Tối thiểu ${\n formatPrice(MIN_DEPOSIT)\n }):`,\n { parse_mode: \"HTML\", ...cancelDepositKeyboard() },\n );\n setUserState(tgUser.id, {\n step: \"awaiting_deposit_amount\",\n messageIds: [sent.message_id],\n });\n}\nasync function handleDepositAmount(ctx, text) {\n const tgUser = ctx.from;\n if (!tgUser) return;\n const state = getUserState(tgUser.id);\n const existingMsgIds = state.step === \"awaiting_deposit_amount\"\n ? state.messageIds\n : [];\n const amount = parseInt(text.replace(/[.,\\s]/g, \"\"), 10);\n if (isNaN(amount) || amount < MIN_DEPOSIT) {\n await ctx.reply(\n `❌ Số tiền không hợp lệ!\\nTối thiểu ${formatPrice(MIN_DEPOSIT)}.`,\n cancelDepositKeyboard(),\n );\n return;\n }\n try {\n await ctx.deleteMessage();\n } catch {}\n const transferContent = `NAP ${tgUser.id} ${amount}`;\n const [transaction] = await db.insert(transactionsTable).values({\n userId: tgUser.id,\n amount,\n type: \"deposit\",\n status: \"pending\",\n transferContent,\n }).returning();\n if (!transaction) {\n await ctx.reply(\"❌ Có lỗi xảy ra, vui lòng thử lại!\");\n clearUserState(tgUser.id);\n return;\n }\n const qrMsg = await ctx.replyWithPhoto(generateQR(amount, transferContent), {\n caption:\n `💳 THÔNG TIN CHUYỂN KHOẢN\\n━━━━━━━━━━━━━━━━━━━━━━\\n\\n🏦 Ngân hàng: ${BANK_NAME}\\n💳 Số TK: ${BANK_ACCOUNT}\\n👤 Chủ TK: ${BANK_HOLDER}\\n💰 Số tiền: ${\n formatPrice(amount)\n }\\n📝 Nội dung CK: ${transferContent}\\n\\n⚠️ QUAN TRỌNG: Nhập đúng nội dung để được cộng tiền tự động!\\n\\n⏳ Sau khi chuyển khoản, vui lòng chờ admin xác nhận.`,\n parse_mode: \"HTML\",\n ...cancelDepositKeyboard(),\n });\n setUserState(tgUser.id, {\n step: \"awaiting_deposit_confirm\",\n amount,\n transactionId: transaction.id,\n messageIds: [...existingMsgIds, qrMsg.message_id],\n });\n try {\n const name = tgUser.first_name +\n (tgUser.last_name ? ` ${tgUser.last_name}` : \"\");\n await ctx.telegram.sendMessage(\n ADMIN_ID,\n `🔔 YÊU CẦU NẠP TIỀN MỚI\\n━━━━━━━━━━━━━━━━━━━━━━\\n\\n👤 User: ${name}\\n🆔 ID: ${tgUser.id}\\n📱 Username: ${\n tgUser.username ? `@${tgUser.username}` : \"Không có\"\n }\\n💰 Số tiền: ${\n formatPrice(amount)\n }\\n📝 Nội dung CK: ${transferContent}\\n🔢 Mã GD: #${transaction.id}`,\n {\n parse_mode: \"HTML\",\n ...adminDepositKeyboard(transaction.id, tgUser.id),\n },\n );\n } catch {}\n}\nasync function handleCancelDeposit(ctx) {\n const tgUser = ctx.from;\n if (!tgUser) return;\n const state = getUserState(tgUser.id);\n if (state.step === \"awaiting_deposit_confirm\") {\n await db.update(transactionsTable).set({ status: \"cancelled\" }).where(\n eq(transactionsTable.id, state.transactionId),\n );\n }\n const messageIds =\n (state.step === \"awaiting_deposit_amount\" ||\n state.step === \"awaiting_deposit_confirm\")\n ? state.messageIds\n : [];\n clearUserState(tgUser.id);\n await deleteMessages(ctx, tgUser.id, messageIds);\n if (ctx.callbackQuery) await ctx.answerCbQuery(\"Đã hủy lệnh nạp!\");\n await ctx.reply(\"✅ Đã hủy lệnh nạp tiền.\", mainKeyboard);\n}\nasync function handleAdminApprove(ctx, txId, userId) {\n const tgUser = ctx.from;\n if (!tgUser) return;\n const [tx] = await db.select().from(transactionsTable).where(\n eq(transactionsTable.id, txId),\n ).limit(1);\n if (!tx) {\n await ctx.answerCbQuery(\"Giao dịch không tồn tại!\");\n return;\n }\n if (tx.status !== \"pending\") {\n await ctx.answerCbQuery(\"Giao dịch đã được xử lý rồi!\");\n return;\n }\n await db.update(transactionsTable).set({\n status: \"approved\",\n approvedBy: tgUser.id,\n updatedAt: new Date(),\n }).where(eq(transactionsTable.id, txId));\n const [user] = await db.select().from(usersTable).where(\n eq(usersTable.id, userId),\n ).limit(1);\n const newBalance = (user?.balance ?? 0) + tx.amount;\n await db.update(usersTable).set({\n balance: newBalance,\n totalDeposited: (user?.totalDeposited ?? 0) + tx.amount,\n }).where(eq(usersTable.id, userId));\n await ctx.editMessageText(\n `✅ ĐÃ DUYỆT GIAO DỊCH #${txId}\\n💰 Đã cộng ${\n formatPrice(tx.amount)\n } cho user ID: ${userId}`,\n { parse_mode: \"HTML\" },\n );\n await ctx.answerCbQuery(\"Đã duyệt!\");\n const userState = getUserState(userId);\n const msgIds =\n (userState.step === \"awaiting_deposit_amount\" ||\n userState.step === \"awaiting_deposit_confirm\")\n ? userState.messageIds\n : [];\n await deleteMessages(ctx, userId, msgIds);\n clearUserState(userId);\n try {\n await ctx.telegram.sendMessage(\n userId,\n `✅ NẠP TIỀN THÀNH CÔNG!\\n━━━━━━━━━━━━━━━━━━━━━━\\n\\n💰 Số tiền nạp: ${\n formatPrice(tx.amount)\n }\\n💳 Số dư mới: ${\n formatPrice(newBalance)\n }\\n🔢 Mã GD: #${txId}\\n\\nCảm ơn bạn đã nạp tiền! 🎉`,\n { parse_mode: \"HTML\", ...mainKeyboard },\n );\n } catch {}\n if (user && user.referredBy && user.referralRewarded === 0) {\n const [referrer] = await db.select().from(usersTable).where(\n eq(usersTable.id, user.referredBy),\n ).limit(1);\n if (referrer) {\n await db.update(usersTable).set({\n balance: referrer.balance + REFERRAL_BONUS,\n referralEarnings: referrer.referralEarnings + REFERRAL_BONUS,\n }).where(eq(usersTable.id, referrer.id));\n await db.update(usersTable).set({ referralRewarded: 1 }).where(\n eq(usersTable.id, userId),\n );\n try {\n await ctx.telegram.sendMessage(\n referrer.id,\n `🎉 Bạn bè bạn vừa nạp tiền!\\n💰 Hoa hồng: ${\n formatPrice(REFERRAL_BONUS)\n }\\n💳 Số dư mới: ${\n formatPrice(referrer.balance + REFERRAL_BONUS)\n }`,\n { parse_mode: \"HTML\" },\n );\n } catch {}\n }\n }\n}\nasync function handleAdminReject(ctx, txId, userId) {\n const [tx] = await db.select().from(transactionsTable).where(\n eq(transactionsTable.id, txId),\n ).limit(1);\n if (!tx) {\n await ctx.answerCbQuery(\"Giao dịch không tồn tại!\");\n return;\n }\n if (tx.status !== \"pending\") {\n await ctx.answerCbQuery(\"Giao dịch đã được xử lý rồi!\");\n return;\n }\n await db.update(transactionsTable).set({\n status: \"rejected\",\n updatedAt: new Date(),\n }).where(eq(transactionsTable.id, txId));\n await ctx.editMessageText(\n `❌ ĐÃ TỪ CHỐI GIAO DỊCH #${txId}\\nUser ID: ${userId} — ${\n formatPrice(tx.amount)\n }`,\n { parse_mode: \"HTML\" },\n );\n await ctx.answerCbQuery(\"Đã từ chối!\");\n const userState = getUserState(userId);\n const msgIds =\n (userState.step === \"awaiting_deposit_amount\" ||\n userState.step === \"awaiting_deposit_confirm\")\n ? userState.messageIds\n : [];\n await deleteMessages(ctx, userId, msgIds);\n clearUserState(userId);\n try {\n await ctx.telegram.sendMessage(\n userId,\n `❌ Lệnh nạp tiền bị từ chối.\\n💰 Số tiền: ${\n formatPrice(tx.amount)\n }\\n\\nLiên hệ hỗ trợ nếu bạn đã chuyển khoản.`,\n { parse_mode: \"HTML\" },\n );\n } catch {}\n}\nasync function handleDepositHistory(ctx) {\n const tgUser = ctx.from;\n if (!tgUser) return;\n const txs = await db.select().from(transactionsTable).where(\n eq(transactionsTable.userId, tgUser.id),\n ).orderBy(desc(transactionsTable.createdAt)).limit(10);\n if (txs.length === 0) {\n await ctx.reply(\n `📋 LỊCH SỬ NẠP TIỀN\\n━━━━━━━━━━━━━━━━━━━━━━\\n\\nBạn chưa có giao dịch nạp tiền nào.`,\n { parse_mode: \"HTML\" },\n );\n return;\n }\n const emoji = {\n pending: \"⏳\",\n approved: \"✅\",\n rejected: \"❌\",\n cancelled: \"🚫\",\n };\n const lines = txs.map((t, i) =>\n `${i + 1}. ${emoji[t.status] ?? \"❓\"} ${formatPrice(t.amount)} — ${\n t.createdAt.toLocaleDateString(\"vi-VN\")\n }`\n ).join(\"\\n\");\n await ctx.reply(\n `📋 LỊCH SỬ NẠP TIỀN (10 gần nhất)\\n━━━━━━━━━━━━━━━━━━━━━━\\n\\n${lines}`,\n { parse_mode: \"HTML\" },\n );\n}\n\n// ─── HANDLERS: PROFILE / TOP / ORDER HISTORY ───────────────────────────────────\nasync function handleProfile(ctx) {\n const tgUser = ctx.from;\n if (!tgUser) return;\n const [user] = await db.select().from(usersTable).where(\n eq(usersTable.id, tgUser.id),\n ).limit(1);\n if (!user) {\n await ctx.reply(\"Vui lòng gõ /start để đăng ký tài khoản.\");\n return;\n }\n const name = user.firstName + (user.lastName ? ` ${user.lastName}` : \"\");\n const username = tgUser.username ? `@${tgUser.username}` : \"Không có\";\n await ctx.reply(\n `💎 THÔNG TIN TÀI KHOẢN CÁ NHÂN\\n━━━━━━━━━━━━━━━━━━━━━━\\n\\n🆔 ID: ${user.id}\\n👤 Tên: ${name}\\n📱 Username: ${username}\\n\\n💳 Số Dư Khả Dụng: ${\n formatPrice(user.balance)\n }\\n\\n📊 Thống Kê:\\n — Tổng tiền nạp: ${\n formatPrice(user.totalDeposited)\n }\\n — Tổng tiền tiêu: ${\n formatPrice(user.totalSpent)\n }\\n — Sản phẩm đã mua: ${user.totalPurchases} cái\\n\\n🤝 Chương Trình Giới Thiệu:\\n — Hoa hồng đã kiếm: ${\n formatPrice(user.referralEarnings)\n }\\n🔗 Link giới thiệu: ${BOT_LINK}?start=${user.id}\\n\\nGửi link này cho bạn bè để nhận hoa hồng!`,\n { parse_mode: \"HTML\" },\n );\n}\nasync function handleTopNap(ctx) {\n const users = await db.select().from(usersTable).orderBy(\n desc(usersTable.totalDeposited),\n ).limit(10);\n if (users.length === 0) {\n await ctx.reply(`🏆 TOP NẠP\\n━━━━━━━━━━━━━━━━━━━━━━\\n\\nChưa có dữ liệu.`);\n return;\n }\n const medals = [\"🥇\", \"🥈\", \"🥉\"];\n const lines = users.map((u, i) =>\n `${medals[i] ?? `${i + 1}.`} ${\n u.firstName + (u.lastName ? ` ${u.lastName}` : \"\")\n } — ${formatPrice(u.totalDeposited)}`\n );\n await ctx.reply(\n `🏆 TOP NẠP TIỀN\\n━━━━━━━━━━━━━━━━━━━━━━\\n\\n${lines.join(\"\\n\")}`,\n { parse_mode: \"HTML\" },\n );\n}\nasync function handleOrderHistory(ctx) {\n const tgUser = ctx.from;\n if (!tgUser) return;\n const orders = await db.select().from(ordersTable).where(\n eq(ordersTable.userId, tgUser.id),\n ).orderBy(desc(ordersTable.createdAt)).limit(20);\n if (orders.length === 0) {\n await ctx.reply(\n `📜 LỊCH SỬ MUA HÀNG\\n━━━━━━━━━━━━━━━━━━━━━━\\n\\nBạn chưa có đơn hàng nào.`,\n { parse_mode: \"HTML\" },\n );\n return;\n }\n const semoji = { waiting_key: \"⏳\", completed: \"✅\", cancelled: \"❌\" };\n const lines = orders.map((o, i) => {\n const keyLine = o.status === \"completed\" && o.keyValue\n ? `\\n 🔑 Key: ${o.keyValue}`\n : o.status === \"waiting_key\"\n ? `\\n ⏳ Đang chờ admin gửi key...`\n : \"\";\n return `${i + 1}. ${\n semoji[o.status] ?? \"❓\"\n } ${o.productName} (${o.duration})\\n 💰 ${\n formatPrice(o.price)\n } — ${o.createdAt.toLocaleDateString(\"vi-VN\")}${keyLine}`;\n });\n const chunks = [];\n let current =\n `📜 LỊCH SỬ MUA HÀNG (${orders.length} đơn)\\n━━━━━━━━━━━━━━━━━━━━━━\\n\\n`;\n for (const line of lines) {\n if ((current + line + \"\\n\\n\").length > 3800) {\n chunks.push(current);\n current = \"\";\n }\n current += line + \"\\n\\n\";\n }\n if (current.trim()) chunks.push(current);\n for (const chunk of chunks) await ctx.reply(chunk, { parse_mode: \"HTML\" });\n}\n\n// ─── HANDLERS: ADMIN ───────────────────────────────────────────────────────────\nasync function handleAdminEnterKey(ctx, orderId) {\n if (!isAdmin(ctx)) {\n await ctx.answerCbQuery(\"Bạn không có quyền!\");\n return;\n }\n const [order] = await db.select().from(ordersTable).where(\n eq(ordersTable.id, orderId),\n ).limit(1);\n if (!order) {\n await ctx.answerCbQuery(\"Đơn hàng không tồn tại!\");\n return;\n }\n if (order.status !== \"waiting_key\") {\n await ctx.answerCbQuery(\"Đơn hàng này đã được xử lý rồi!\");\n return;\n }\n setAdminState(ADMIN_ID, {\n step: \"awaiting_key_input\",\n orderId,\n userId: Number(order.userId),\n productName: order.productName,\n durationLabel: order.duration,\n });\n await ctx.answerCbQuery();\n await ctx.reply(\n `📝 NHẬP KEY CHO ĐƠN #${orderId}\\n━━━━━━━━━━━━━━━━━━━━━━\\n\\n📦 Sản phẩm: ${order.productName}\\n⏱️ Thời hạn: ${order.duration}\\n👤 User ID: ${order.userId}\\n\\n✏️ Hãy gõ key vào khung chat bên dưới:`,\n { parse_mode: \"HTML\" },\n );\n}\nasync function handleAdminCancelOrder(ctx, orderId) {\n if (!isAdmin(ctx)) {\n await ctx.answerCbQuery(\"Bạn không có quyền!\");\n return;\n }\n const [order] = await db.select().from(ordersTable).where(\n eq(ordersTable.id, orderId),\n ).limit(1);\n if (!order) {\n await ctx.answerCbQuery(\"Đơn hàng không tồn tại!\");\n return;\n }\n if (order.status !== \"waiting_key\") {\n await ctx.answerCbQuery(\"Đơn hàng đã được xử lý rồi!\");\n return;\n }\n await db.update(ordersTable).set({ status: \"cancelled\" }).where(\n eq(ordersTable.id, orderId),\n );\n const userId = Number(order.userId);\n const [user] = await db.select().from(usersTable).where(\n eq(usersTable.id, userId),\n ).limit(1);\n if (user) {\n await db.update(usersTable).set({\n balance: user.balance + order.price,\n totalSpent: Math.max(0, user.totalSpent - order.price),\n totalPurchases: Math.max(0, user.totalPurchases - 1),\n }).where(eq(usersTable.id, userId));\n }\n await ctx.editMessageReplyMarkup({ inline_keyboard: [] });\n await ctx.answerCbQuery(\"Đã hủy đơn và hoàn tiền!\");\n await ctx.reply(\n `✅ Đã hủy đơn #${orderId} và hoàn ${\n formatPrice(order.price)\n } cho user ID: ${userId}`,\n { parse_mode: \"HTML\" },\n );\n try {\n await ctx.telegram.sendMessage(\n userId,\n `❌ Đơn hàng #${orderId} đã bị hủy.\\n📦 ${order.productName}\\n💰 Đã hoàn: ${\n formatPrice(order.price)\n }\\n\\nLiên hệ hỗ trợ nếu cần.`,\n { parse_mode: \"HTML\" },\n );\n } catch {}\n}\nasync function handleAdminKeyInput(ctx, keyText) {\n if (!isAdmin(ctx)) return;\n const state = getAdminState(ADMIN_ID);\n if (state.step !== \"awaiting_key_input\") return;\n const key = keyText.trim();\n if (!key) {\n await ctx.reply(\"❌ Key không được để trống, vui lòng nhập lại:\");\n return;\n }\n const { orderId, userId, productName, durationLabel } = state;\n const [order] = await db.select().from(ordersTable).where(\n eq(ordersTable.id, orderId),\n ).limit(1);\n if (!order || order.status !== \"waiting_key\") {\n await ctx.reply(\"❌ Đơn hàng không còn hợp lệ.\");\n clearAdminState(ADMIN_ID);\n return;\n }\n await db.update(ordersTable).set({ keyValue: key, status: \"completed\" })\n .where(eq(ordersTable.id, orderId));\n clearAdminState(ADMIN_ID);\n await ctx.reply(\n `✅ Đã gửi key cho đơn #${orderId}!\\n🔑 Key: ${key}`,\n { parse_mode: \"HTML\" },\n );\n try {\n await ctx.telegram.sendMessage(\n userId,\n `🎉 KEY CỦA BẠN ĐÃ SẴN SÀNG!\\n━━━━━━━━━━━━━━━━━━━━━━\\n\\n📦 Sản phẩm: ${productName}\\n⏱️ Thời hạn: ${durationLabel}\\n🔢 Mã đơn: #${orderId}\\n\\n🔑 KEY CỦA BẠN:\\n${key}\\n\\n⚠️ Lưu key cẩn thận, không chia sẻ!`,\n { parse_mode: \"HTML\" },\n );\n } catch {\n await ctx.reply(\n `⚠️ Không thể gửi đến user ID: ${userId}. Key đã lưu vào đơn hàng.`,\n );\n }\n}\nasync function handleAddBalance(ctx, text) {\n if (!isAdmin(ctx)) {\n await ctx.reply(\"❌ Bạn không có quyền!\");\n return;\n }\n const parts = text.trim().split(/\\s+/);\n if (parts.length < 3) {\n await ctx.reply(`❌ Cú pháp: /addbalance user_id amount`, {\n parse_mode: \"HTML\",\n });\n return;\n }\n const userId = parseInt(parts[1], 10), amount = parseInt(parts[2], 10);\n if (isNaN(userId) || isNaN(amount) || amount <= 0) {\n await ctx.reply(\"❌ Thông tin không hợp lệ!\");\n return;\n }\n const [user] = await db.select().from(usersTable).where(\n eq(usersTable.id, userId),\n ).limit(1);\n if (!user) {\n await ctx.reply(`❌ Không tìm thấy user ID: ${userId}`);\n return;\n }\n await db.update(usersTable).set({\n balance: user.balance + amount,\n totalDeposited: user.totalDeposited + amount,\n }).where(eq(usersTable.id, userId));\n await db.insert(transactionsTable).values({\n userId,\n amount,\n type: \"manual_deposit\",\n status: \"approved\",\n note: \"Admin cộng tiền thủ công\",\n approvedBy: ctx.from.id,\n });\n const name = user.firstName + (user.lastName ? ` ${user.lastName}` : \"\");\n await ctx.reply(\n `✅ Đã cộng ${\n formatPrice(amount)\n } cho ${name} (ID: ${userId})\\n💳 Số dư mới: ${\n formatPrice(user.balance + amount)\n }`,\n { parse_mode: \"HTML\" },\n );\n try {\n await ctx.telegram.sendMessage(\n userId,\n `✅ Tài khoản được cộng ${\n formatPrice(amount)\n }!\\n💳 Số dư mới: ${formatPrice(user.balance + amount)}`,\n { parse_mode: \"HTML\" },\n );\n } catch {}\n}\nasync function handleUsers(ctx) {\n if (!isAdmin(ctx)) {\n await ctx.reply(\"❌ Bạn không có quyền!\");\n return;\n }\n const users = await db.select().from(usersTable).orderBy(usersTable.createdAt)\n .limit(30);\n if (users.length === 0) {\n await ctx.reply(\"Chưa có người dùng nào.\");\n return;\n }\n const lines = users.map((u, i) => {\n const name = u.firstName + (u.lastName ? ` ${u.lastName}` : \"\");\n return `${i + 1}. ${name} ${\n u.username ? `@${u.username}` : \"—\"\n }\\n 🆔 ${u.id} | 💳 ${formatPrice(u.balance)} | Nạp: ${\n formatPrice(u.totalDeposited)\n }`;\n });\n const chunks = [];\n let current =\n `👥 DANH SÁCH NGƯỜI DÙNG (${users.length})\\n━━━━━━━━━━━━━━━━━━━━━━\\n\\n`;\n for (const line of lines) {\n if ((current + line + \"\\n\").length > 3800) {\n chunks.push(current);\n current = \"\";\n }\n current += line + \"\\n\\n\";\n }\n if (current.trim()) chunks.push(current);\n for (const chunk of chunks) await ctx.reply(chunk, { parse_mode: \"HTML\" });\n}\nasync function handlePendingOrders(ctx) {\n if (!isAdmin(ctx)) {\n await ctx.reply(\"❌ Bạn không có quyền!\");\n return;\n }\n const pending = await db.select().from(ordersTable).where(\n eq(ordersTable.status, \"waiting_key\"),\n );\n if (pending.length === 0) {\n await ctx.reply(\n `📊 ĐƠN HÀNG ĐANG CHỜ KEY\\n━━━━━━━━━━━━━━━━━━━━━━\\n\\n✅ Không có đơn hàng nào đang chờ key.`,\n { parse_mode: \"HTML\" },\n );\n return;\n }\n const lines = pending.map((o) =>\n `🔸 #${o.id} — ${o.productName} (${o.duration}) — ${\n formatPrice(o.price)\n }\\n 👤 User ID: ${o.userId}`\n );\n const inlineRows = pending.map(\n (o) => [{\n text: `📝 Nhập Key #${o.id}`,\n callback_data: `admin:enterkey:${o.id}`,\n }, { text: `❌ Hủy #${o.id}`, callback_data: `admin:cancelorder:${o.id}` }]\n );\n await ctx.reply(\n `📊 ĐƠN HÀNG ĐANG CHỜ KEY (${pending.length})\\n━━━━━━━━━━━━━━━━━━━━━━\\n\\n${\n lines.join(\"\\n\\n\")\n }`,\n { parse_mode: \"HTML\", reply_markup: { inline_keyboard: inlineRows } },\n );\n}\nasync function handleSetPrice(ctx, text) {\n if (!isAdmin(ctx)) {\n await ctx.reply(\"❌ Bạn không có quyền!\");\n return;\n }\n const parts = text.trim().split(/\\s+/);\n if (parts.length < 4) {\n await ctx.reply(\n `❌ Cú pháp: /setprice [product_id] [duration] [price]\\n\\nVí dụ: /setprice migul_lite day 60000\\n\\nProduct IDs: migul_lite, migul_pro, migul_tipa, fluorite, proxy_vip, drip_android\\nDurations: day, week, month`,\n { parse_mode: \"HTML\" },\n );\n return;\n }\n const productId = parts[1],\n duration = parts[2],\n newPrice = parseInt(parts[3], 10);\n if (isNaN(newPrice) || newPrice <= 0) {\n await ctx.reply(\"❌ Giá không hợp lệ!\");\n return;\n }\n const existing = await db.select().from(priceOverridesTable).where(\n eq(priceOverridesTable.productId, productId),\n );\n const match = existing.find((r) => r.duration === duration);\n if (match) {\n await db.update(priceOverridesTable).set({\n price: newPrice,\n updatedAt: new Date(),\n }).where(eq(priceOverridesTable.id, match.id));\n } else {await db.insert(priceOverridesTable).values({\n productId,\n duration,\n price: newPrice,\n });}\n await ctx.reply(\n `✅ Đã cập nhật giá!\\n\\n📦 Sản phẩm: ${productId}\\n⏱️ Thời hạn: ${duration}\\n💰 Giá mới: ${\n formatPrice(newPrice)\n }`,\n { parse_mode: \"HTML\" },\n );\n}\nasync function handleBroadcast(ctx, text) {\n if (!isAdmin(ctx)) {\n await ctx.reply(\"❌ Bạn không có quyền!\");\n return;\n }\n const afterCommand = text.replace(/^\\/broadcast\\s*/i, \"\").trim();\n if (!afterCommand) {\n await ctx.reply(`❌ Cú pháp: /broadcast [nội dung]`, {\n parse_mode: \"HTML\",\n });\n return;\n }\n const users = await db.select({ id: usersTable.id }).from(usersTable);\n await ctx.reply(`📢 Đang gửi thông báo đến ${users.length} người dùng...`);\n let success = 0, failed = 0;\n for (const user of users) {\n try {\n await ctx.telegram.sendMessage(\n user.id,\n `📢 THÔNG BÁO TỪ ADMIN\\n━━━━━━━━━━━━━━━━━━━━━━\\n\\n${afterCommand}`,\n { parse_mode: \"HTML\" },\n );\n success++;\n await new Promise((r) => setTimeout(r, 50));\n } catch {\n failed++;\n }\n }\n await ctx.reply(\n `✅ Broadcast hoàn tất!\\n📨 Thành công: ${success}\\n❌ Thất bại: ${failed}`,\n { parse_mode: \"HTML\" },\n );\n}\nasync function handleAdminHelp(ctx) {\n if (!isAdmin(ctx)) return;\n await ctx.reply(\n `👑 LỆNH ADMIN\\n━━━━━━━━━━━━━━━━━━━━━━\\n\\n/users — Danh sách toàn bộ người dùng\\n/addbalance [id] [amount] — Cộng tiền thủ công\\n/setprice [product] [duration] [price] — Chỉnh giá sản phẩm\\n/pending — Đơn hàng đang chờ key (kèm nút xử lý)\\n/broadcast [nội dung] — Gửi thông báo toàn bộ user\\n/admin — Xem tất cả lệnh này`,\n { parse_mode: \"HTML\" },\n );\n}\n\n// ─── BOT SETUP ─────────────────────────────────────────────────────────────────\nconst bot = new Telegraf(BOT_TOKEN);\n\nbot.start(handleStart);\nbot.hears(\"🛍️ Mua Key/Acc\", handleShop);\nbot.hears(\"💳 Nạp Tiền\", handleDeposit);\nbot.hears(\"💎 Cá Nhân\", handleProfile);\nbot.hears(\"🏆 Top Nạp\", handleTopNap);\nbot.hears(\"📋 Lịch Sử Nạp\", handleDepositHistory);\nbot.hears(\"📜 Lịch Sử Mua\", handleOrderHistory);\nbot.hears(\"👨 Hỗ Trợ\", async (ctx) => {\n await ctx.reply(\n `👨 HỖ TRỢ KHÁCH HÀNG\\n━━━━━━━━━━━━━━━━━━━━━━\\n\\n📞 Liên hệ admin để được hỗ trợ:\\n🔗 https://t.me/PHL0990\\n\\n⏰ Thời gian hỗ trợ: 24/7\\n⚡ Phản hồi trong vòng vài phút!`,\n { parse_mode: \"HTML\" },\n );\n});\n\nbot.command(\"users\", handleUsers);\nbot.command(\"addbalance\", (ctx) => handleAddBalance(ctx, ctx.message.text));\nbot.command(\"setprice\", (ctx) => handleSetPrice(ctx, ctx.message.text));\nbot.command(\"pending\", handlePendingOrders);\nbot.command(\"broadcast\", (ctx) => handleBroadcast(ctx, ctx.message.text));\nbot.command(\"admin\", handleAdminHelp);\n\nbot.action(/^product:(.+)$/, async (ctx) => {\n if (ctx.match[1]) await handleProductSelect(ctx, ctx.match[1]);\n});\nbot.action(/^buy:(.+):(.+)$/, async (ctx) => {\n if (ctx.match[1] && ctx.match[2]) {\n await handleBuySelect(ctx, ctx.match[1], ctx.match[2]);\n }\n});\nbot.action(/^confirm:(.+):(.+)$/, async (ctx) => {\n if (ctx.match[1] && ctx.match[2]) {\n await handleConfirmPurchase(ctx, ctx.match[1], ctx.match[2]);\n }\n});\nbot.action(\"back:main\", async (ctx) => {\n await ctx.deleteMessage();\n await ctx.answerCbQuery();\n});\nbot.action(\"back:products\", async (ctx) => {\n const buttons = PRODUCTS.map((p) =>\n Markup.button.callback(`${p.emoji} ${p.name}`, `product:${p.id}`)\n );\n const rows = [];\n for (let i = 0; i < buttons.length; i += 2) {\n rows.push(buttons.slice(i, i + 2));\n }\n rows.push([Markup.button.callback(\"🔙 Quay Lại\", \"back:main\")]);\n await ctx.editMessageText(\n `🛍️ DANH SÁCH SẢN PHẨM\\n━━━━━━━━━━━━━━━━━━━━━━\\n\\nVui lòng chọn danh mục bạn muốn xem:`,\n { parse_mode: \"HTML\", ...Markup.inlineKeyboard(rows) },\n );\n await ctx.answerCbQuery();\n});\nbot.action(\"cancel:deposit\", handleCancelDeposit);\nbot.action(/^admin:approve:(\\d+):(\\d+)$/, async (ctx) => {\n if (!isAdmin(ctx)) {\n await ctx.answerCbQuery(\"Bạn không có quyền!\");\n return;\n }\n await handleAdminApprove(\n ctx,\n parseInt(ctx.match[1], 10),\n parseInt(ctx.match[2], 10),\n );\n});\nbot.action(/^admin:reject:(\\d+):(\\d+)$/, async (ctx) => {\n if (!isAdmin(ctx)) {\n await ctx.answerCbQuery(\"Bạn không có quyền!\");\n return;\n }\n await handleAdminReject(\n ctx,\n parseInt(ctx.match[1], 10),\n parseInt(ctx.match[2], 10),\n );\n});\nbot.action(/^admin:enterkey:(\\d+)$/, async (ctx) => {\n if (!isAdmin(ctx)) {\n await ctx.answerCbQuery(\"Bạn không có quyền!\");\n return;\n }\n await handleAdminEnterKey(ctx, parseInt(ctx.match[1], 10));\n});\nbot.action(/^admin:cancelorder:(\\d+)$/, async (ctx) => {\n if (!isAdmin(ctx)) {\n await ctx.answerCbQuery(\"Bạn không có quyền!\");\n return;\n }\n await handleAdminCancelOrder(ctx, parseInt(ctx.match[1], 10));\n});\n\nbot.on(\"text\", async (ctx) => {\n const tgUser = ctx.from;\n if (!tgUser) return;\n if (tgUser.id === ADMIN_ID) {\n const adminState = getAdminState(ADMIN_ID);\n if (adminState.step === \"awaiting_key_input\") {\n await handleAdminKeyInput(ctx, ctx.message.text);\n return;\n }\n }\n const state = getUserState(tgUser.id);\n if (state.step === \"awaiting_deposit_amount\") {\n await handleDepositAmount(ctx, ctx.message.text);\n }\n});\n\nbot.catch((err) => {\n console.error(\"Bot error:\", err);\n});\n\n// ─── START ─────────────────────────────────────────────────────────────────────\nawait initDB();\nawait bot.launch();\nconsole.log(\"🤖 Bot started successfully!\");\nprocess.once(\"SIGINT\", () => bot.stop(\"SIGINT\"));\nprocess.once(\"SIGTERM\", () => bot.stop(\"SIGTERM\"));","createdAt",["D",1779331003078],"branchVersion","branchId","21e08c7e-5271-11f1-9fe8-ee650bb23af1","id","21dfcbae-5271-11f1-9fe8-ee650bb23af1","untitled-7384",["D",1779078127828],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","imageUrl","f2481e92-a5b3-4e33-b5e5-16d09f5db5a7","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019e2e4a-a137-7707-9a63-fefdf136c1db","tursoName","21dfcbae527111f19fe8ee650bb23af1","tursoHostname","21dfcbae527111f19fe8ee650bb23af1-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789468254172],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_96":95,"_104":100},"org",{"_96":95,"_97":98,"_99":100,"_18":54,"_101":102,"_103":25},"branch",{"_13":14,"_32":86,"_43":42,"_87":44,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":45,"_94":95},"isOwned","main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","longpham","handle","displayName","LONG PHẠM","avatar","https://lh3.googleusercontent.com/a/ACg8ocJss9C4mawe-_hl76iYlqEJquNzBxJA2KXzp58yDjl-FFR1Ykqc=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_43":44,"_32":45,"_38":152,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":-5,"_53":-5,"_18":54,"_55":-5,"_56":25,"_57":-5,"_58":-5,"_59":60,"_61":62,"_63":64,"_65":66,"_67":153,"_69":-5,"_70":71,"_72":71,"_73":74,"_75":74,"_76":74,"_77":71,"_78":71,"_79":154,"_81":155,"_83":156,"_85":25},"tree",[147],"files",[147],"counts",{"_136":60,"_137":138,"_139":60,"_140":141,"_142":143},"contents",[128],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles",true,"grants","orgs","customDomains",{},{"_43":129,"_32":28,"_30":31,"_130":-5,"_41":42,"_40":14,"_131":123,"_38":132,"_13":133,"_33":34,"_35":37,"_24":25,"_134":-5,"_27":135},"e7475742-54bd-11f1-9d75-ee650bb23af1","parentId","latest",["D",1779331003078],16,"label",[28],"pulls","branches",1,"forks","envVars",{"_144":60,"_146":60},"connections",{"_144":60,"_145":60},"count","unfilledCount","emptyCount",{"_43":129,"_32":28,"_30":31,"_130":-5,"_41":42,"_40":14,"_131":123,"_38":148,"_13":133,"_33":34,"_35":37,"_24":25,"_134":-5,"_149":150,"_27":151},["D",1779331003078],"children",[],[28],["D",1779078127828],["D",1789468254172],{"_96":95,"_104":100},{"_96":95,"_97":98,"_99":100,"_18":54,"_101":102,"_103":25},{"_13":14,"_32":86,"_43":42,"_87":44,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":45,"_94":95},"ctx",{"_79":-5,"_125":190,"_191":192,"_193":194,"_195":25,"_196":25,"_197":25,"_198":123,"_199":-5,"_200":-7,"_201":-7,"_202":60,"_203":25,"_204":25,"_205":-5,"_206":25,"_207":25,"_208":25,"_209":-5},"ENV",{"_161":162,"_163":164,"_165":86,"_166":167,"_168":169,"_170":171,"_172":173,"_174":175,"_176":177,"_178":179,"_180":181,"_182":183,"_184":185,"_186":187,"_188":189},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v17