Hệ Thống Điều Phối Vận Hành

1. Endpoint Cloud Function Webhook:

2. Cơ chế Delta Sync tự động (Chỉ gửi dòng mới):

• Tự động nhận diện dòng mới: Script tự động thêm cột "Trạng thái đồng bộ" ở cuối bảng. Dòng nào mới thêm hoặc chưa đồng bộ sẽ được lọc ra để gửi riêng sang hệ thống.
• Tiết kiệm 99.9% chi phí Firestore: Thay vì gửi toàn bộ 1.600 dòng mỗi lần, script chỉ gửi 1-2 dòng vừa gõ, Firestore chỉ tốn 1-2 lượt đọc/ghi.
• Tự động đóng dấu & tô xanh: Khi đồng bộ thành công, ô trạng thái sẽ tự động điền Đã đồng bộ (HH:mm dd/MM) kèm nền xanh lá cây.
• Sửa đổi đơn cũ cực dễ: Nếu muốn cập nhật lại thông tin một tài xế cũ, chỉ cần xóa chữ "Đã đồng bộ" ở dòng đó, hệ thống sẽ tự động cập nhật lại thông tin mới sang bốc số.

3. Mã Google Apps Script Delta Sync (Tiện ích mở rộng > Apps Script):

/**
 * =========================================================================
 * GOOGLE APPS SCRIPT: DELTA SYNC THÔNG MINH SANG HỆ THỐNG XANH SM
 * Cơ chế: Chỉ gửi đúng các dòng mới / chỉnh sửa chưa đồng bộ
 * =========================================================================
 */

function onOpen() {
  SpreadsheetApp.getUi()
    .createMenu('🚗 XANH SM')
    .addItem('⚡ Quét & Đồng bộ các dòng mới (Delta Sync)', 'autoSyncNewRows')
    .addSeparator()
    .addItem('🔄 Đồng bộ toàn bộ bảng (Dự phòng)', 'syncAllRowsBackup')
    .addToUi();
}

/**
 * 1. TỰ ĐỘNG ĐỒNG BỘ CÁC DÒNG MỚI (DELTA SYNC)
 * Có thể cài Trigger theo thời gian (Time-driven: mỗi 1 - 5 phút/lần)
 */
function autoSyncNewRows() {
  var ss = SpreadsheetApp.getActiveSpreadsheet();
  var sheet = getDeliverySheet(ss);
  if (!sheet) return;

  var data = sheet.getDataRange().getValues();
  if (data.length <= 1) return;

  var headerRowIdx = findHeaderRowIdx(data);
  var headers = data[headerRowIdx].map(function(h) { return String(h || '').trim().toLowerCase(); });
  var cols = mapColumns(headers);

  // Tìm hoặc khởi tạo cột 'Trạng thái đồng bộ'
  var colSyncStatus = -1;
  for (var c = 0; c < headers.length; c++) {
    if (headers[c].indexOf('trạng thái sync') !== -1 || headers[c].indexOf('trạng thái đồng bộ') !== -1 || headers[c].indexOf('đồng bộ bốc số') !== -1) {
      colSyncStatus = c;
      break;
    }
  }

  // Nếu chưa có cột trạng thái, tự tạo tiêu đề ở cột kế tiếp
  if (colSyncStatus === -1) {
    colSyncStatus = headers.length;
    sheet.getRange(headerRowIdx + 1, colSyncStatus + 1).setValue("Trạng thái đồng bộ").setFontWeight("bold").setBackground("#e8eaed");
  }

  var deltaOrders = [];
  var targetRowIndices = []; // Lưu số dòng thực tế trên Sheet (1-indexed)

  for (var i = headerRowIdx + 1; i < data.length; i++) {
    var row = data[i];
    var currentStatus = String(row[colSyncStatus] || '').trim();

    // Nếu đã đồng bộ rồi thì BỎ QUA NGAY (không gửi lại)
    if (currentStatus.indexOf('Đã đồng bộ') === 0 || currentStatus.indexOf('Thành công') === 0) {
      continue;
    }

    var parsed = parseOrderRow(row, cols);
    // Chỉ gửi khi dòng có tối thiểu Tên VÀ (CCCD hoặc SĐT)
    if (parsed && parsed.name && (parsed.cccd || parsed.phone)) {
      deltaOrders.push(parsed);
      targetRowIndices.push(i + 1);
    }
  }

  // Nếu không có dòng mới nào cần đồng bộ, KẾT THÚC NGAY (0 HTTP request, 0 lượt đọc Firestore)
  if (deltaOrders.length === 0) {
    return;
  }

  Logger.log("Phát hiện " + deltaOrders.length + " dòng mới cần đồng bộ...");
  var res = sendOrdersToFirebase(deltaOrders);
  if (res && res.success) {
    var nowStr = Utilities.formatDate(new Date(), "GMT+7", "HH:mm dd/MM");
    // Đánh dấu xanh vào các dòng đã đồng bộ thành công
    for (var k = 0; k < targetRowIndices.length; k++) {
      var rIdx = targetRowIndices[k];
      sheet.getRange(rIdx, colSyncStatus + 1)
        .setValue("Đã đồng bộ (" + nowStr + ")")
        .setBackground("#e6f4ea")
        .setFontColor("#137333");
    }
    ss.toast("Đã tự động nạp " + deltaOrders.length + " đơn mới sang hệ thống bốc số!", "🚗 XANH SM", 6);
  }
}

/**
 * 2. TỰ ĐỘNG RESET TRẠNG THÁI KHI SỬA THÔNG TIN CỦA DÒNG ĐÃ SYNC
 */
function onEdit(e) {
  if (!e || !e.range) return;
  var sheet = e.range.getSheet();
  var row = e.range.getRow();
  var col = e.range.getColumn();
  if (row <= 1) return;

  var lastCol = sheet.getLastColumn();
  // Nếu sửa đổi ở các cột thông tin (từ cột 1 đến cột trước trạng thái sync)
  if (col < lastCol) {
    var statusCell = sheet.getRange(row, lastCol);
    var statusVal = String(statusCell.getValue() || '');
    if (statusVal.indexOf('Đã đồng bộ') === 0) {
      // Tự động xóa trạng thái để kích hoạt sync lại thông tin mới
      statusCell.setValue('').setBackground(null).setFontColor(null);
    }
  }
}

/**
 * 3. ĐỒNG BỘ TOÀN BỘ BẢNG (DỰ PHÒNG KHI CẦN RESET)
 */
function syncAllRowsBackup() {
  var ss = SpreadsheetApp.getActiveSpreadsheet();
  var sheet = getDeliverySheet(ss);
  if (!sheet) return;

  var data = sheet.getDataRange().getValues();
  var headerRowIdx = findHeaderRowIdx(data);
  var cols = mapColumns(data[headerRowIdx].map(function(h) { return String(h || '').trim().toLowerCase(); }));

  var allOrders = [];
  for (var i = headerRowIdx + 1; i < data.length; i++) {
    var parsed = parseOrderRow(data[i], cols);
    if (parsed && parsed.name && (parsed.cccd || parsed.phone)) {
      allOrders.push(parsed);
    }
  }

  if (allOrders.length === 0) return;
  ss.toast("Đang đồng bộ toàn bộ " + allOrders.length + " đơn...", "Đang xử lý", 10);
  var res = sendOrdersToFirebase(allOrders);
  if (res) ss.toast(res.message || "Đồng bộ hoàn tất!", "🚗 XANH SM", 8);
}

// =================== CÁC HÀM HỖ TRỢ CHUẨN HÓA ===================
function getDeliverySheet(ss) {
  var sheets = ss.getSheets();
  for (var s = 0; s < sheets.length; s++) {
    var sName = sheets[s].getName().toLowerCase();
    if (sName.indexOf('nhận xe') !== -1 || sName.indexOf('bàn giao') !== -1 || sName.indexOf('rto') !== -1) {
      return sheets[s];
    }
  }
  return ss.getActiveSheet();
}

function findHeaderRowIdx(data) {
  for (var r = 0; r < Math.min(5, data.length); r++) {
    var rowStr = data[r].map(function(c) { return String(c || '').trim().toLowerCase(); });
    if (rowStr.some(function(h) { return h.indexOf('mã') !== -1 || h.indexOf('cccd') !== -1 || h.indexOf('họ') !== -1 || h.indexOf('sđt') !== -1; })) {
      return r;
    }
  }
  return 0;
}

function mapColumns(headers) {
  function findCol(keywords, fallback) {
    for (var i = 0; i < headers.length; i++) {
      for (var k = 0; k < keywords.length; k++) {
        if (headers[i].indexOf(keywords[k]) !== -1) return i;
      }
    }
    return fallback;
  }
  return {
    orderCode: findCol(['mã đơn hàng', 'mã đơn', 'order_code', 'order', 'mã hợp đồng', 'mã'], 0),
    name:      findCol(['họ và tên', 'họ tên', 'tên lái xe', 'tên tài xế', 'tên', 'full_name', 'name'], 1),
    cccd:      findCol(['cccd', 'số cccd', 'căn cước', 'cmnd'], 2),
    phone:     findCol(['sđt', 'sdt', 'số điện thoại', 'điện thoại', 'phone', 'tel', 'mobile'], 3),
    email:     findCol(['email', 'mail'], 4),
    vehicle:   findCol(['dòng xe', 'loại xe', 'vehicle'], 5),
    color:     findCol(['màu ngoại thất', 'màu xe', 'màu', 'color'], 6),
    region:    findCol(['khu vực nhận xe', 'khu vực', 'kho', 'region'], 7),
    date:      findCol(['ngày nhận xe', 'ngày nhận', 'ngày bàn giao', 'lịch nhận', 'ngày hẹn', 'ngày thanh toán', 'ngày tt', 'date'], 8)
  };
}

function parseOrderRow(row, cols) {
  var orderCode = String(row[cols.orderCode] || '').trim();
  var name = String(row[cols.name] || '').trim();
  var cccd = String(row[cols.cccd] || '').replace(/'/g, '').replace(/\D/g, '').trim();
  var phone = String(row[cols.phone] || '').replace(/'/g, '').replace(/\D/g, '').trim();

  if (!name && !cccd && !phone) return null;
  if (orderCode.indexOf('#') === 0) orderCode = '';

  if (cccd.length === 10 && cccd.indexOf('0') === 0 && phone.length === 12) {
    var tmp = cccd; cccd = phone; phone = tmp;
  }

  var rawDateVal = row[cols.date];
  var formattedDate = '';
  if (rawDateVal instanceof Date) {
    formattedDate = Utilities.formatDate(rawDateVal, "GMT+7", "dd/MM/yyyy");
  } else if (rawDateVal) {
    formattedDate = String(rawDateVal).trim();
  }

  var region = String(row[cols.region] || '').trim();
  if (region.indexOf('GMT') !== -1 || region.indexOf('Indochina') !== -1) region = '';

  return {
    orderCode: orderCode,
    name: name,
    cccd: cccd,
    phone: phone,
    email: String(row[cols.email] || '').trim(),
    vehicleType: String(row[cols.vehicle] || '').trim(),
    color: String(row[cols.color] || '').trim(),
    region: region,
    paymentDate: formattedDate
  };
}

function sendOrdersToFirebase(orders) {
  var url = 'https://asia-southeast1-greensm-8d69b.cloudfunctions.net/syncDeliveryOrders';
  var options = {
    method: 'post',
    contentType: 'application/json',
    payload: JSON.stringify({ orders: orders }),
    muteHttpExceptions: true
  };
  try {
    var response = UrlFetchApp.fetch(url, options);
    return JSON.parse(response.getContentText());
  } catch(e) {
    Logger.log("Lỗi gửi dữ liệu: " + e.message);
    return null;
  }
}