Google Sheets Integration

Manual Trigger → Google Sheets (Read)

LINE Webhook → Function → Google Sheets (Append)

// แปลงข้อมูลจาก LINE
const message = $json.message;
const userId = $json.userId;

return [{
  json: {
    timestamp: new Date().toISOString(),
    user_id: userId,
    message: message,
    processed: false
  }
}];

Schedule Trigger → Google Sheets (Read) → Function → Google Sheets (Update)

// อัปเดตสถานะ
const data = $input.all();
const updated = data.map(item => ({
  ...item.json,
  processed: true,
  updated_at: new Date().toISOString()
}));

return updated.map(item => ({ json: item }));

LINE Webhook → Function (Validate) → Google Sheets (Append) → LINE (Reply)

// ตรวจสอบข้อมูลการสมัคร
const message = $json.message;
const userId = $json.userId;

// แยกข้อมูล
const parts = message.split(',');
if (parts.length < 3) {
  return [{
    json: {
      replyToken: $json.replyToken,
      response: '❌ กรุณากรอกข้อมูลให้ครบ:\nชื่อ,เบอร์โทร,อีเมล\nตัวอย่าง: สมชาย,0812345678,somchai@email.com'
    }
  }];
}

const [name, phone, email] = parts.map(p => p.trim());

// ตรวจสอบรูปแบบ
if (!name || !phone.match(/^\d{10}$/) || !email.includes('@')) {
  return [{
    json: {
      replyToken: $json.replyToken,
      response: '❌ ข้อมูลไม่ถูกต้อง:\n- ชื่อ: ต้องไม่ว่าง\n- เบอร์: 10 หลัก\n- อีเมล: ต้องมี @'
    }
  }];
}

return [{
  json: {
    replyToken: $json.replyToken,
    customerData: {
      timestamp: new Date().toISOString(),
      user_id: userId,
      name: name,
      phone: phone,
      email: email,
      status: 'pending'
    },
    response: `✅ ลงทะเบียนสำเร็จ!\nชื่อ: ${name}\nเบอร์: ${phone}\nอีเมล: ${email}\n\nเราจะติดต่อกลับโดยเร็วครับ`
  }
}];

Schedule (Daily) → Google Sheets (Read Orders) → Function (Check Status) → Google Sheets (Update) → LINE (Notify)

// ตรวจสอบสถานะออเดอร์
const orders = $input.all();
const notifications = [];

for (const order of orders) {
  const data = order.json;
  
  // ตรวจสอบว่าผ่าน 3 วันแล้วยังไม่จัดส่ง
  const orderDate = new Date(data.order_date);
  const today = new Date();
  const daysDiff = (today - orderDate) / (1000 * 60 * 60 * 24);
  
  if (daysDiff > 3 && data.status === 'processing') {
    notifications.push({
      user_id: data.user_id,
      message: `📦 อัปเดตสถานะออเดอร์ #${data.order_id}\nสถานะ: กำลังจัดเรียงสินค้า\nวันที่สั่ง: ${data.order_date}\n\nขออภัยในความล่าช้าครับ 🙏`
    });
    
    // อัปเดตสถานะ
    data.status = 'delayed';
    data.notification_sent = true;
  }
}

return notifications.map(notif => ({ json: notif }));

Schedule (Hourly) → Google Sheets (Read) → Function (Analyze) → Google Sheets (Write Summary)

// วิเคราะห์ข้อมูล
const data = $input.all();
const analysis = {
  total_messages: data.length,
  unique_users: new Set(data.map(item => item.json.user_id)).size,
  today_messages: data.filter(item => {
    const date = new Date(item.json.timestamp);
    const today = new Date();
    return date.toDateString() === today.toDateString();
  }).length,
  top_keywords: {},
  response_rate: 0
};

// นับคำที่พบบ่อย
const allMessages = data.map(item => item.json.message.toLowerCase()).join(' ');
const words = allMessages.match(/\b\w+\b/g) || [];
words.forEach(word => {
  if (word.length > 2) {
    analysis.top_keywords[word] = (analysis.top_keywords[word] || 0) + 1;
  }
});

// เรียงคำที่พบบ่อยสุด 10 อันดับ
analysis.top_keywords = Object.entries(analysis.top_keywords)
  .sort((a, b) => b[1] - a[1])
  .slice(0, 10)
  .reduce((obj, [word, count]) => {
    obj[word] = count;
    return obj;
  }, {});

return [{
  json: {
    timestamp: new Date().toISOString(),
    ...analysis
  }
}];