Google Sheets + Telegram: Cách Gửi Thông Báo Tự Động Cho Doanh Nghiệp 2026

// ============================================================
// CONFIG — lưu vào Script Properties (File → Project settings)
// ============================================================
function getConfig() {
  const props = PropertiesService.getScriptProperties()
  return {
    botToken: props.getProperty('TELEGRAM_BOT_TOKEN'),
    chatId: props.getProperty('TELEGRAM_CHAT_ID'),
  }
}

// Lưu config lần đầu (chạy 1 lần duy nhất)
function setupConfig() {
  PropertiesService.getScriptProperties().setProperties({
    'TELEGRAM_BOT_TOKEN': '7234567890:AAH1234abcd...', // Thay bằng token thật
    'TELEGRAM_CHAT_ID': '987654321',                   // Thay bằng chat ID thật
  })
  console.log('Config đã lưu!')
}

// ============================================================
// HÀM GỬI TIN NHẮN CHÍNH
// ============================================================
function sendTelegramMessage(text, parseMode = 'HTML') {
  const { botToken, chatId } = getConfig()

  if (!botToken || !chatId) {
    console.error('Chưa cấu hình Bot Token hoặc Chat ID!')
    return null
  }

  const url = `https://api.telegram.org/bot${botToken}/sendMessage`

  const payload = {
    chat_id: chatId,
    text: text,
    parse_mode: parseMode,
    disable_web_page_preview: true,
  }

  const options = {
    method: 'post',
    contentType: 'application/json',
    payload: JSON.stringify(payload),
    muteHttpExceptions: true,
  }

  try {
    const response = UrlFetchApp.fetch(url, options)
    const result = JSON.parse(response.getContentText())

    if (!result.ok) {
      console.error('Telegram API error:', result.description)
    }
    return result
  } catch (e) {
    console.error('Lỗi gửi Telegram:', e.message)
    return null
  }
}

// ============================================================
// TEST: Gửi tin nhắn thử nghiệm
// ============================================================
function testSendMessage() {
  const message = `
🤖 Bot đã kết nối thành công!

📅 Thời gian: ${new Date().toLocaleString('vi-VN')}
📊 Sheet: ${SpreadsheetApp.getActiveSpreadsheet().getName()}

Bot sẵn sàng gửi thông báo tự động.
`
  const result = sendTelegramMessage(message)
  if (result && result.ok) {
    SpreadsheetApp.getUi().alert('Gửi thành công! Kiểm tra Telegram của bạn.')
  }
}

// Trigger khi ô trong Sheet thay đổi
function onEdit(e) {
  const sheet = e.source.getActiveSheet()
  const range = e.range
  const col = range.getColumn()
  const row = range.getRow()
  const newValue = e.value
  const oldValue = e.oldValue

  // Chỉ xử lý Sheet "Orders" và cột D (trạng thái)
  if (sheet.getName() !== 'Orders' || col !== 4) return

  // Bỏ qua nếu không thay đổi hoặc là hàng header
  if (row === 1 || newValue === oldValue) return

  // Lấy thông tin đơn hàng từ cùng hàng đó
  const orderId = sheet.getRange(row, 1).getValue()   // Cột A: Mã đơn
  const customer = sheet.getRange(row, 2).getValue()  // Cột B: Khách hàng
  const amount = sheet.getRange(row, 3).getValue()    // Cột C: Giá trị

  // Chỉ gửi thông báo khi trạng thái chuyển sang PAID
  if (newValue === 'PAID') {
    const message = `
💰 Đơn hàng đã thanh toán!

🔖 Mã đơn: ${orderId}
👤 Khách: ${customer}
💵 Giá trị: ${formatCurrency(amount)}
📅 Thời gian: ${new Date().toLocaleString('vi-VN')}

✅ Trạng thái: PAID
`
    sendTelegramMessage(message)
  }

  // Gửi thông báo khi đơn bị hủy
  if (newValue === 'CANCELLED') {
    const message = `
❌ Đơn hàng bị hủy

🔖 Mã đơn: ${orderId}
👤 Khách: ${customer}
💵 Giá trị: ${formatCurrency(amount)}
⏰ Hủy lúc: ${new Date().toLocaleString('vi-VN')}
`
    sendTelegramMessage(message)
  }
}

function formatCurrency(amount) {
  return new Intl.NumberFormat('vi-VN', {
    style: 'currency', currency: 'VND'
  }).format(amount)
}

// Tạo time-based trigger tự động
function createDailyReportTrigger() {
  // Xóa trigger cũ nếu có
  const triggers = ScriptApp.getProjectTriggers()
  triggers.forEach(t => {
    if (t.getHandlerFunction() === 'sendDailyReport') {
      ScriptApp.deleteTrigger(t)
    }
  })

  // Tạo trigger mới: chạy mỗi ngày lúc 8:00 sáng
  ScriptApp.newTrigger('sendDailyReport')
    .timeBased()
    .everyDays(1)
    .atHour(8)
    .create()

  console.log('Đã tạo trigger báo cáo hàng ngày lúc 8:00')
}

// Chạy hàm này để đăng ký trigger (1 lần duy nhất)
function setup() {
  createDailyReportTrigger()
}

// Kiểm tra tồn kho và gửi cảnh báo
// Trigger: mỗi giờ hoặc mỗi khi Sheet "Inventory" thay đổi
function checkInventoryAlert() {
  const sheet = SpreadsheetApp.getActiveSpreadsheet()
    .getSheetByName('Inventory')

  if (!sheet) return

  const data = sheet.getDataRange().getValues()
  const headers = data[0] // Hàng đầu là tiêu đề
  const rows = data.slice(1) // Từ hàng 2 trở đi

  // Giả sử: Cột A=Mã SP, B=Tên SP, C=Tồn kho, D=Tồn kho tối thiểu
  const criticalItems = []  // Hết hàng (< 5)
  const lowItems = []       // Sắp hết (< tồn kho tối thiểu)

  rows.forEach((row, i) => {
    const [code, name, qty, minQty] = row
    if (!name || qty === '') return

    if (qty < 5) {
      criticalItems.push({ code, name, qty, minQty })
    } else if (qty < minQty) {
      lowItems.push({ code, name, qty, minQty })
    }
  })

  // Không có cảnh báo → không gửi
  if (criticalItems.length === 0 && lowItems.length === 0) return

  let message = '📦 CẢNH BÁO TỒN KHO
'
  message += `📅 ${new Date().toLocaleString('vi-VN')}

`

  if (criticalItems.length > 0) {
    message += '🔴 SẮP HẾT HÀNG (cần đặt gấp):
'
    criticalItems.forEach(item => {
      message += `  • ${item.name} (${item.code}): còn ${item.qty} cái
`
    })
    message += '
'
  }

  if (lowItems.length > 0) {
    message += '🟡 TỒN KHO THẤP (nên đặt thêm):
'
    lowItems.forEach(item => {
      message += `  • ${item.name}: còn ${item.qty}/${item.minQty} (min)
`
    })
  }

  message += `
👉 Xem bảng tồn kho`

  sendTelegramMessage(message)
}

// Trigger: onEdit trên Sheet "Orders"
// Phát hiện hàng mới được thêm vào (cột A vừa có giá trị mới)
function onOrderAdded(e) {
  const sheet = e.source.getActiveSheet()
  if (sheet.getName() !== 'Orders') return

  const range = e.range
  const row = range.getRow()
  const col = range.getColumn()

  // Chỉ xử lý khi điền vào cột A (Mã đơn) ở hàng mới
  if (col !== 1 || row === 1) return
  if (!e.value) return // Bỏ qua nếu xóa

  // Đợi một chút để người dùng điền xong các cột khác
  // (Dùng trigger onChange thay vì onEdit sẽ tốt hơn)
  Utilities.sleep(1000)

  const orderId = sheet.getRange(row, 1).getValue()
  const customer = sheet.getRange(row, 2).getValue()
  const phone = sheet.getRange(row, 3).getValue()
  const products = sheet.getRange(row, 4).getValue()
  const amount = sheet.getRange(row, 5).getValue()
  const address = sheet.getRange(row, 6).getValue()
  const note = sheet.getRange(row, 7).getValue()

  const message = `
🛒 ĐƠN HÀNG MỚI!

🔖 Mã đơn: ${orderId}
👤 Khách: ${customer}
📞 SĐT: ${phone}
🛍️ Sản phẩm: ${products}
💰 Giá trị: ${formatCurrency(amount)}
📍 Địa chỉ: ${address}
📝 Ghi chú: ${note || 'Không có'}
⏰ Thời gian: ${new Date().toLocaleString('vi-VN')}
`
  sendTelegramMessage(message)
}

function sendDailyReport() {
  const ss = SpreadsheetApp.getActiveSpreadsheet()
  const sheet = ss.getSheetByName('Orders')
  if (!sheet) return

  const today = new Date()
  const yesterday = new Date(today)
  yesterday.setDate(yesterday.getDate() - 1)

  const data = sheet.getDataRange().getValues()
  const rows = data.slice(1)

  // Lọc đơn hàng của hôm qua
  const yesterdayOrders = rows.filter(row => {
    const orderDate = new Date(row[0]) // Giả sử cột A là ngày đặt hàng
    return orderDate.toDateString() === yesterday.toDateString()
      && row[4] === 'PAID' // Cột E: trạng thái
  })

  // Tính toán
  const totalRevenue = yesterdayOrders.reduce((sum, row) => sum + (row[3] || 0), 0)
  const orderCount = yesterdayOrders.length
  const avgOrderValue = orderCount > 0 ? totalRevenue / orderCount : 0

  // Top sản phẩm (đếm tần suất trong cột C)
  const productCount = {}
  yesterdayOrders.forEach(row => {
    const product = row[2]
    productCount[product] = (productCount[product] || 0) + 1
  })
  const topProducts = Object.entries(productCount)
    .sort((a, b) => b[1] - a[1])
    .slice(0, 3)

  const dateStr = yesterday.toLocaleDateString('vi-VN', {
    weekday: 'long', year: 'numeric', month: 'long', day: 'numeric'
  })

  let message = `
📊 BÁO CÁO DOANH THU
📅 ${dateStr}

━━━━━━━━━━━━━━━━━━━━
💰 Doanh thu: ${formatCurrency(totalRevenue)}
📦 Số đơn: ${orderCount} đơn
📈 Giá trị TB: ${formatCurrency(avgOrderValue)}

🏆 Top sản phẩm:
`

  topProducts.forEach(([product, count], i) => {
    const medal = ['🥇', '🥈', '🥉'][i]
    message += `  ${medal} ${product}: ${count} đơn
`
  })

  // So sánh với hôm kia
  const dayBefore = new Date(yesterday)
  dayBefore.setDate(dayBefore.getDate() - 1)
  const dayBeforeOrders = rows.filter(row => {
    const orderDate = new Date(row[0])
    return orderDate.toDateString() === dayBefore.toDateString() && row[4] === 'PAID'
  })
  const dayBeforeRevenue = dayBeforeOrders.reduce((sum, row) => sum + (row[3] || 0), 0)

  if (dayBeforeRevenue > 0) {
    const growth = ((totalRevenue - dayBeforeRevenue) / dayBeforeRevenue * 100).toFixed(1)
    const arrow = growth >= 0 ? '📈' : '📉'
    message += `
${arrow} So với hôm kia: ${growth > 0 ? '+' : ''}${growth}%`
  }

  message += `

👉 Xem chi tiết`

  sendTelegramMessage(message)
}

function sendDeadlineReminder() {
  const sheet = SpreadsheetApp.getActiveSpreadsheet()
    .getSheetByName('Tasks')
  if (!sheet) return

  const data = sheet.getDataRange().getValues()
  const rows = data.slice(1)
  const today = new Date()
  today.setHours(0, 0, 0, 0)

  const overdueTask = []
  const todayTasks = []
  const upcomingTasks = []

  rows.forEach(row => {
    const [taskId, taskName, assignee, deadline, status] = row
    if (!taskName || status === 'DONE' || !deadline) return

    const deadlineDate = new Date(deadline)
    deadlineDate.setHours(0, 0, 0, 0)

    const diffDays = Math.floor((deadlineDate - today) / (1000 * 60 * 60 * 24))

    if (diffDays < 0) {
      overdueTask.push({ taskName, assignee, deadline: deadlineDate, diffDays })
    } else if (diffDays === 0) {
      todayTasks.push({ taskName, assignee })
    } else if (diffDays <= 3) {
      upcomingTasks.push({ taskName, assignee, diffDays })
    }
  })

  if (overdueTask.length === 0 && todayTasks.length === 0 && upcomingTasks.length === 0) {
    return // Không có gì cần nhắc
  }

  let message = `⏰ NHẮC NHỞ DEADLINE
📅 ${today.toLocaleDateString('vi-VN')}

`

  if (overdueTask.length > 0) {
    message += `🔴 QUÁ HẠN (${overdueTask.length} task):
`
    overdueTask.forEach(t => {
      message += `  • ${t.taskName} — ${t.assignee} (quá ${Math.abs(t.diffDays)} ngày)
`
    })
    message += '
'
  }

  if (todayTasks.length > 0) {
    message += `🟠 HÔM NAY (${todayTasks.length} task):
`
    todayTasks.forEach(t => {
      message += `  • ${t.taskName} — ${t.assignee}
`
    })
    message += '
'
  }

  if (upcomingTasks.length > 0) {
    message += `🟡 SẮP ĐẾN HẠN:
`
    upcomingTasks.forEach(t => {
      message += `  • ${t.taskName} — còn ${t.diffDays} ngày
`
    })
  }

  sendTelegramMessage(message)
}

// Phát hiện giá trị bất thường trong doanh thu
function detectAnomalies() {
  const sheet = SpreadsheetApp.getActiveSpreadsheet()
    .getSheetByName('Sales')
  if (!sheet) return

  const revenueCol = sheet.getRange('E2:E100').getValues().flat()
    .filter(v => v > 0)

  if (revenueCol.length < 10) return // Cần đủ data

  // Tính trung bình và độ lệch chuẩn
  const avg = revenueCol.reduce((a, b) => a + b) / revenueCol.length
  const stdDev = Math.sqrt(
    revenueCol.map(x => (x - avg) ** 2).reduce((a, b) => a + b) / revenueCol.length
  )

  // Ngưỡng bất thường: ngoài 3 sigma
  const upperBound = avg + 3 * stdDev
  const lowerBound = avg - 3 * stdDev

  const lastRow = sheet.getLastRow()
  const lastRevenue = sheet.getRange(lastRow, 5).getValue()

  if (lastRevenue > upperBound) {
    sendTelegramMessage(`
🚨 GIÁ TRỊ BẤT THƯỜNG!

Doanh thu hàng ${lastRow}: ${formatCurrency(lastRevenue)}
Mức trung bình: ${formatCurrency(avg)}
Cao hơn trung bình: ${((lastRevenue/avg - 1) * 100).toFixed(0)}%

Vui lòng kiểm tra lại đơn hàng.
`)
  }
}

// Gửi báo cáo tuần mỗi sáng thứ 2 lúc 9:00
function sendWeeklyReport() {
  const today = new Date()
  if (today.getDay() !== 1) return // Chỉ chạy thứ 2

  const ss = SpreadsheetApp.getActiveSpreadsheet()
  const sheet = ss.getSheetByName('Orders')
  const data = sheet.getDataRange().getValues().slice(1)

  // Tuần trước: thứ 2 đến chủ nhật
  const lastMonday = new Date(today)
  lastMonday.setDate(today.getDate() - 7)
  lastMonday.setHours(0, 0, 0, 0)

  const lastSunday = new Date(today)
  lastSunday.setDate(today.getDate() - 1)
  lastSunday.setHours(23, 59, 59, 999)

  const weekOrders = data.filter(row => {
    const d = new Date(row[0])
    return d >= lastMonday && d <= lastSunday && row[4] === 'PAID'
  })

  const totalRevenue = weekOrders.reduce((s, r) => s + (r[3] || 0), 0)
  const orderCount = weekOrders.length
  const newCustomers = new Set(weekOrders.map(r => r[1])).size

  // Doanh thu từng ngày
  const dailyRevenue = {}
  const days = ['CN', 'T2', 'T3', 'T4', 'T5', 'T6', 'T7']
  weekOrders.forEach(row => {
    const d = new Date(row[0])
    const dayKey = days[d.getDay()]
    dailyRevenue[dayKey] = (dailyRevenue[dayKey] || 0) + (row[3] || 0)
  })

  let message = `
📊 BÁO CÁO TUẦN
📅 ${lastMonday.toLocaleDateString('vi-VN')} – ${lastSunday.toLocaleDateString('vi-VN')}

━━━━━━━━━━━━━━━━━━━━
💰 Tổng doanh thu: ${formatCurrency(totalRevenue)}
📦 Số đơn hàng: ${orderCount}
👥 Khách hàng: ${newCustomers}

📅 Theo ngày:
`

  Object.entries(dailyRevenue)
    .sort()
    .forEach(([day, rev]) => {
      const bar = '█'.repeat(Math.min(10, Math.floor(rev / (totalRevenue / orderCount) * 2)))
      message += `  ${day}: ${bar} ${formatCurrency(rev)}
`
    })

  message += `
👉 Xem bảng chi tiết`

  sendTelegramMessage(message)
}

// Gửi đến nhiều chat khác nhau
function sendToMultipleChats(message) {
  const props = PropertiesService.getScriptProperties()
  const botToken = props.getProperty('TELEGRAM_BOT_TOKEN')

  // Danh sách nhận: managers group + owner personal
  const chatIds = [
    props.getProperty('TELEGRAM_GROUP_MANAGERS'),   // Nhóm quản lý
    props.getProperty('TELEGRAM_OWNER_ID'),          // Chủ doanh nghiệp
  ].filter(Boolean) // Bỏ qua giá trị null/empty

  chatIds.forEach(chatId => {
    const url = `https://api.telegram.org/bot${botToken}/sendMessage`
    UrlFetchApp.fetch(url, {
      method: 'post',
      contentType: 'application/json',
      payload: JSON.stringify({ chat_id: chatId, text: message, parse_mode: 'HTML' }),
      muteHttpExceptions: true,
    })
  })
}

// Gửi document/file (ví dụ báo cáo Excel)
function sendDocument(fileId, caption) {
  const { botToken, chatId } = getConfig()
  const url = `https://api.telegram.org/bot${botToken}/sendDocument`

  UrlFetchApp.fetch(url, {
    method: 'post',
    contentType: 'application/json',
    payload: JSON.stringify({
      chat_id: chatId,
      document: fileId, // Google Drive file ID
      caption: caption,
    }),
    muteHttpExceptions: true,
  })
}

// Wrapper an toàn cho sendTelegramMessage với retry
function sendTelegramMessageSafe(text, retries = 3) {
  for (let attempt = 1; attempt <= retries; attempt++) {
    try {
      const result = sendTelegramMessage(text)
      if (result && result.ok) return result

      // Xử lý rate limit (429 Too Many Requests)
      if (result && result.error_code === 429) {
        const retryAfter = result.parameters?.retry_after || 5
        console.log(`Rate limited. Chờ ${retryAfter}s...`)
        Utilities.sleep(retryAfter * 1000)
        continue
      }

      console.error(`Lần ${attempt}: Telegram lỗi:`, result?.description)
    } catch (e) {
      console.error(`Lần ${attempt}: Exception:`, e.message)
      if (attempt < retries) Utilities.sleep(2000)
    }
  }
  console.error('Gửi Telegram thất bại sau', retries, 'lần thử')
  return null
}

// Log lỗi vào Sheet để theo dõi
function logError(functionName, errorMessage) {
  try {
    const logSheet = SpreadsheetApp.getActiveSpreadsheet()
      .getSheetByName('Error Log')
    if (!logSheet) return

    logSheet.appendRow([
      new Date(),
      functionName,
      errorMessage,
      Session.getActiveUser().getEmail()
    ])
  } catch (e) {
    console.error('Không thể ghi log:', e.message)
  }
}