บทเรียนพัฒนา LINE Chatbot: สร้างบอทแรกของคุณ

mkdir my-line-bot && cd my-line-bot
npm init -y
npm install @line/bot-sdk express dotenv

mkdir my-line-bot && cd my-line-bot
python -m venv venv
source venv/bin/activate  # Windows: venv\Scripts\activate
pip install line-bot-sdk flask python-dotenv

LINE_CHANNEL_SECRET=your_channel_secret
LINE_CHANNEL_ACCESS_TOKEN=your_channel_access_token
PORT=3000

// index.js
const express = require('express');
const { Client, middleware } = require('@line/bot-sdk');
require('dotenv').config();

const config = {
  channelSecret: process.env.LINE_CHANNEL_SECRET,
  channelAccessToken: process.env.LINE_CHANNEL_ACCESS_TOKEN,
};

const client = new Client(config);
const app = express();

// Webhook endpoint
app.post('/webhook', middleware(config), async (req, res) => {
  try {
    const events = req.body.events;
    await Promise.all(events.map(handleEvent));
    res.status(200).json({ status: 'ok' });
  } catch (err) {
    console.error(err);
    res.status(500).end();
  }
});

async function handleEvent(event) {
  if (event.type !== 'message' || event.message.type !== 'text') {
    return null;
  }

  const userMessage = event.message.text;
  const replyToken = event.replyToken;

  // Simple echo bot
  return client.replyMessage(replyToken, {
    type: 'text',
    text: `คุณพูดว่า: ${userMessage}`,
  });
}

const PORT = process.env.PORT || 3000;
app.listen(PORT, () => {
  console.log(`Bot is running on port ${PORT}`);
});

# app.py
from flask import Flask, request, abort
from linebot import LineBotApi, WebhookHandler
from linebot.exceptions import InvalidSignatureError
from linebot.models import MessageEvent, TextMessage, TextSendMessage
import os
from dotenv import load_dotenv

load_dotenv()

app = Flask(__name__)

line_bot_api = LineBotApi(os.getenv('LINE_CHANNEL_ACCESS_TOKEN'))
handler = WebhookHandler(os.getenv('LINE_CHANNEL_SECRET'))

@app.route('/webhook', methods=['POST'])
def webhook():
    signature = request.headers.get('X-Line-Signature')
    body = request.get_data(as_text=True)

    try:
        handler.handle(body, signature)
    except InvalidSignatureError:
        abort(400)

    return 'OK'

@handler.add(MessageEvent, message=TextMessage)
def handle_message(event):
    user_message = event.message.text

    # Simple echo bot
    line_bot_api.reply_message(
        event.reply_token,
        TextSendMessage(text=f'คุณพูดว่า: {user_message}')
    )

if __name__ == '__main__':
    app.run(port=int(os.getenv('PORT', 3000)))

{
  type: 'text',
  text: 'สวัสดี! วันนี้ช่วยอะไรได้บ้างคะ?'
}

{
  type: 'flex',
  altText: 'Product Card',
  contents: {
    type: 'bubble',
    hero: {
      type: 'image',
      url: 'https://example.com/product.jpg',
      size: 'full',
      aspectRatio: '20:13'
    },
    body: {
      type: 'box',
      layout: 'vertical',
      contents: [
        {
          type: 'text',
          text: 'ชื่อสินค้า',
          weight: 'bold',
          size: 'xl'
        },
        {
          type: 'text',
          text: '฿1,299',
          color: '#06C755'
        }
      ]
    }
  }
}

{
  type: 'text',
  text: 'คุณต้องการทำอะไร?',
  quickReply: {
    items: [
      {
        type: 'action',
        action: {
          type: 'message',
          label: 'ดูสินค้า',
          text: 'แสดงสินค้า'
        }
      },
      {
        type: 'action',
        action: {
          type: 'message',
          label: 'ติดต่อซัพพอร์ต',
          text: 'ต้องการความช่วยเหลือ'
        }
      }
    ]
  }
}

// Simple in-memory state (ใช้ Redis/database ใน production)
const userStates = new Map();

async function handleEvent(event) {
  const userId = event.source.userId;
  const userState = userStates.get(userId) || { step: 'initial' };
  const message = event.message.text;

  switch (userState.step) {
    case 'initial':
      if (message === 'สั่งซื้อ') {
        userStates.set(userId, { step: 'select_product' });
        return client.replyMessage(event.replyToken, {
          type: 'text',
          text: 'คุณต้องการสั่งอะไร?',
          quickReply: {
            items: [
              { type: 'action', action: { type: 'message', label: 'พิซซ่า', text: 'พิซซ่า' }},
              { type: 'action', action: { type: 'message', label: 'เบอร์เกอร์', text: 'เบอร์เกอร์' }}
            ]
          }
        });
      }
      break;

    case 'select_product':
      userStates.set(userId, { step: 'confirm', product: message });
      return client.replyMessage(event.replyToken, {
        type: 'text',
        text: `ยืนยันสั่ง: ${message}?`,
        quickReply: {
          items: [
            { type: 'action', action: { type: 'message', label: 'ใช่', text: 'ยืนยัน' }},
            { type: 'action', action: { type: 'message', label: 'ไม่', text: 'ยกเลิก' }}
          ]
        }
      });

    case 'confirm':
      if (message === 'ยืนยัน') {
        userStates.delete(userId);
        return client.replyMessage(event.replyToken, {
          type: 'text',
          text: `ยืนยันการสั่ง: ${userState.product}! ขอบคุณค่ะ!`
        });
      }
      break;
  }
}

const OpenAI = require('openai');
const openai = new OpenAI({ apiKey: process.env.OPENAI_API_KEY });

async function getAIResponse(userMessage, context = []) {
  const completion = await openai.chat.completions.create({
    model: 'gpt-4',
    messages: [
      {
        role: 'system',
        content: `คุณคือบอทบริการลูกค้าที่เป็นมิตรสำหรับร้านอาหาร
                  ตอบกระชับ (ต่ำกว่า 200 ตัวอักษรสำหรับ LINE)
                  เมนู: พิซซ่า (฿299), เบอร์เกอร์ (฿199), พาสต้า (฿249)
                  เวลาเปิด: 10:00-22:00 ทุกวัน`
      },
      ...context,
      { role: 'user', content: userMessage }
    ],
    max_tokens: 150
  });

  return completion.choices[0].message.content;
}

npm install -g vercel
vercel --prod

npm install -g @railway/cli
railway login
railway init
railway up