Telegram Bot + n8n: Thông Báo & Quản Lý Kinh Doanh Từ Xa

$# Lấy chat_id sau khi nhắn /start cho bot
$curl "https://api.telegram.org/bot{YOUR_BOT_TOKEN}/getUpdates"
$
$# Kết quả trả về — tìm trường "id" trong "chat"
$# {
$#   "result": [{
$#     "message": {
$#       "chat": { "id": 123456789, "type": "private" },
$#       "text": "/start"
$#     }
$#   }]
$# }
$
$# Đăng ký Webhook để bot nhận lệnh real-time
$curl "https://api.telegram.org/bot{YOUR_BOT_TOKEN}/setWebhook" \
$  -d "url=https://your-n8n.com/webhook/telegram-commands"
$
$# Xác nhận webhook đã active
$curl "https://api.telegram.org/bot{YOUR_BOT_TOKEN}/getWebhookInfo"

// n8n Code node — chạy bằng JavaScript
const order = $input.first().json;
// Format tiền Việt Nam
const formatVND = (amount) =>
  new Intl.NumberFormat("vi-VN").format(amount) + "đ";
// Format danh sách sản phẩm
const itemsList = order.line_items
  .map((item) => `  • ${item.name} x${item.quantity} — ${formatVND(item.price * item.quantity)}`)
  .join("\n");
// Xác định badge ưu tiên
const total = order.total_price;
const badge =
  total >= 5000000 ? "🔴 PREMIUM" :
  order.note ? "🟡 CHUYÊN BIỆT" : "🟢 THƯỜNG";
// Tạo nội dung tin nhắn Telegram (MarkdownV2)
const message = `${badge} ĐƠN HÀNG MỚI #${order.order_number}
👤 Khách: ${order.customer.first_name} ${order.customer.last_name}
📞 SĐT: ${order.shipping_address.phone}
📍 Địa chỉ: ${order.shipping_address.address1}, ${order.shipping_address.city}
🛍️ Sản phẩm:
${itemsList}
💰 Tổng tiền: ${formatVND(total)}
💳 Thanh toán: ${order.payment_gateway}
⏰ Lúc: ${new Date(order.created_at).toLocaleString("vi-VN")}`;
return [{ json: { message, order_id: order.id, total } }];

{
  "chat_id": "-100123456789",
  "text": "🚨 CẢNH BÁO TỒN KHO — 14:00 ngày 29/03/2026\n\nSản phẩm sắp hết hàng:\n\n🔴 HẾT HÀNG (cần nhập ngay):\n  • Áo thun nam trắng size L — 0 cái\n  • Quần short xanh size M — 0 cái\n\n🟡 SẮP HẾT (còn 1–5):\n  • Áo polo đen size XL — còn 3 cái\n  • Đầm hoa size S — còn 2 cái\n\n🟢 CẦN THEO DÕI (còn 6–15):\n  • Áo khoác dù nữ size M — còn 8 cái\n\n👉 Truy cập trang quản lý để tạo đơn nhập hàng:\nhttps://admin.yourshop.com/inventory",
  "parse_mode": "HTML",
  "reply_markup": {
    "inline_keyboard": [[
      { "text": "Xem danh sách đầy đủ", "url": "https://admin.yourshop.com/inventory" },
      { "text": "Đã xử lý", "callback_data": "inventory_ack_1711692000" }
    ]]
  }
}

// n8n Code node — tổng hợp báo cáo cuối ngày
const orders = $('Lấy dữ liệu đơn hàng').all();
const yesterday = $('Dữ liệu hôm qua').first().json;
const today = {
  totalOrders: orders.length,
  revenue: orders.reduce((sum, o) => sum + o.json.total, 0),
  avgOrder: 0,
};
today.avgOrder = today.revenue / today.totalOrders || 0;
// Tính % thay đổi so với hôm qua
const pctOrders = ((today.totalOrders - yesterday.totalOrders) / yesterday.totalOrders * 100).toFixed(1);
const pctRevenue = ((today.revenue - yesterday.revenue) / yesterday.revenue * 100).toFixed(1);
const arrowOrders = pctOrders >= 0 ? "▲" : "▼";
const arrowRevenue = pctRevenue >= 0 ? "▲" : "▼";
// Tìm sản phẩm bán chạy
const productMap = {};
orders.forEach((o) => {
  o.json.items?.forEach((item) => {
    productMap[item.name] = (productMap[item.name] || 0) + item.qty;
  });
});
const topProduct = Object.entries(productMap).sort((a, b) => b[1] - a[1])[0];
const formatVND = (n) => new Intl.NumberFormat("vi-VN").format(n) + "đ";
const dateStr = new Date().toLocaleDateString("vi-VN", { weekday: "long", day: "2-digit", month: "2-digit", year: "numeric" });
const report = `📊 <b>BÁO CÁO NGÀY — ${dateStr}</b>
📦 Đơn hàng: <b>${today.totalOrders}</b> ${arrowOrders}${Math.abs(pctOrders)}% so với hôm qua
💰 Doanh thu: <b>${formatVND(today.revenue)}</b> ${arrowRevenue}${Math.abs(pctRevenue)}%
🧾 Đơn trung bình: <b>${formatVND(today.avgOrder)}</b>
🏆 Sản phẩm bán chạy: <b>${topProduct?.[0] ?? "—"}</b> (${topProduct?.[1] ?? 0} cái)
${today.revenue >= yesterday.revenue ? "✅ Hôm nay tốt hơn hôm qua!" : "⚠️ Doanh thu giảm — cần theo dõi."}`;
return [{ json: { report } }];

// n8n Code node — xử lý lệnh /task từ Telegram
const msg = $input.first().json.message;
const text = msg.text || "";
const fromUser = msg.from.username || msg.from.first_name;
const chatId = msg.chat.id;
// Ví dụ lệnh: /task @nguyen mua nguyên liệu tháng 4 deadline:2026-04-05
const taskRegex = /^\/task\s+@?(\S+)\s+(.+?)(?:\s+deadline:(\d{4}-\d{2}-\d{2}))?$/i;
const match = text.match(taskRegex);
if (!match) {
  return [{
    json: {
      reply: "❌ Cú pháp không đúng.\nDùng: /task @tên nội_dung deadline:YYYY-MM-DD\nVí dụ: /task @nam mua nguyên liệu deadline:2026-04-05",
      chat_id: chatId,
      valid: false,
    }
  }];
}
const [, assignee, description, deadline] = match;
const taskId = `TASK-${Date.now().toString(36).toUpperCase()}`;
return [{
  json: {
    task_id: taskId,
    assignee: assignee.replace("@", ""),
    description: description.trim(),
    deadline: deadline || null,
    created_by: fromUser,
    created_at: new Date().toISOString(),
    status: "pending",
    chat_id: chatId,
    valid: true,
    reply: `✅ Task đã tạo!\n\n📋 <b>${taskId}</b>\n👤 Giao cho: @${assignee.replace("@", "")}\n📝 Nội dung: ${description.trim()}${deadline ? `\n⏰ Deadline: ${deadline}` : ""}\n\nBạn @${assignee.replace("@", "")} sẽ được thông báo ngay.`,
  }
}];