LINE Bot 與 Odoo 整合開發 - 蘇勃任

整合目標#

透過 LINE Bot 讓使用者直接在 LINE 中：

查詢訂單狀態
接收出貨通知
查詢產品庫存
線上客服對話

系統架構#

1
┌─────────────────────────────────────┐
2
│          LINE Platform              │
3
│    Messaging API / Webhook          │
4
└─────────────────┬───────────────────┘
5
                  │
6
          ┌───────▼───────┐
7
          │   Node.js     │
8
          │   Bot Server  │
9
          └───────┬───────┘
10
                  │
11
          ┌───────▼───────┐
12
          │  Odoo XML-RPC │
13
          │     API       │
14
          └───────┬───────┘
15
                  │
16
          ┌───────▼───────┐
17
          │   Odoo 17     │
18
          │  ERP System   │
19
          └───────────────┘

LINE Bot 設定#

Webhook 設定#

1
// Express.js Webhook 處理
2
const express = require('express');
3
const line = require('@line/bot-sdk');
4

5
const config = {
6
    channelAccessToken: process.env.LINE_CHANNEL_ACCESS_TOKEN,
7
    channelSecret: process.env.LINE_CHANNEL_SECRET
8
};
9

10
const client = new line.Client(config);
11
const app = express();
12

13
app.post('/webhook', line.middleware(config), async (req, res) => {
14
    const events = req.body.events;
15

16
    await Promise.all(events.map(handleEvent));
17
    res.status(200).end();
18
});
19

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

25
    const userMessage = event.message.text;
26
    const replyToken = event.replyToken;
27

28
    // 訊息路由
29
    if (userMessage.startsWith('訂單')) {
30
        return handleOrderQuery(replyToken, userMessage);
31
    } else if (userMessage.startsWith('庫存')) {
32
        return handleStockQuery(replyToken, userMessage);
33
    } else {
34
        return handleDefault(replyToken);
35
    }
36
}

訂單查詢功能#

1
const OdooAPI = require('./odoo-api');
2

3
async function handleOrderQuery(replyToken, message) {
4
    // 解析訂單編號
5
    const orderNo = message.replace('訂單', '').trim();
6

7
    // 查詢 Odoo
8
    const order = await OdooAPI.searchOrder(orderNo);
9

10
    if (!order) {
11
        return client.replyMessage(replyToken, {
12
            type: 'text',
13
            text: '找不到此訂單，請確認訂單編號'
14
        });
15
    }
16

17
    // 建立訂單卡片
18
    const flexMessage = createOrderCard(order);
19
    return client.replyMessage(replyToken, flexMessage);
20
}
21

22
function createOrderCard(order) {
23
    return {
24
        type: 'flex',
25
        altText: `訂單 ${order.name}`,
26
        contents: {
27
            type: 'bubble',
28
            header: {
29
                type: 'box',
30
                layout: 'vertical',
31
                contents: [{
32
                    type: 'text',
33
                    text: order.name,
34
                    weight: 'bold',
35
                    size: 'xl'
36
                }]
37
            },
38
            body: {
39
                type: 'box',
40
                layout: 'vertical',
41
                contents: [
42
                    { type: 'text', text: `狀態：${order.state}` },
43
                    { type: 'text', text: `金額：NT$ ${order.amount_total}` },
44
                    { type: 'text', text: `日期：${order.date_order}` }
45
                ]
46
            }
47
        }
48
    };
49
}

Odoo API 封裝#

1
const xmlrpc = require('xmlrpc');
2

3
class OdooAPI {
4
    constructor() {
5
        this.url = process.env.ODOO_URL;
6
        this.db = process.env.ODOO_DB;
7
        this.uid = null;
8
    }
9

10
    async authenticate() {
11
        const client = xmlrpc.createClient({
12
            url: `${this.url}/xmlrpc/2/common`
13
        });
14

15
        return new Promise((resolve, reject) => {
16
            client.methodCall('authenticate', [
17
                this.db,
18
                process.env.ODOO_USER,
19
                process.env.ODOO_PASSWORD,
20
                {}
21
            ], (err, uid) => {
22
                if (err) reject(err);
23
                this.uid = uid;
24
                resolve(uid);
25
            });
26
        });
27
    }
28

29
    async searchOrder(orderNo) {
30
        const client = xmlrpc.createClient({
31
            url: `${this.url}/xmlrpc/2/object`
32
        });
33

34
        return new Promise((resolve, reject) => {
35
            client.methodCall('execute_kw', [
36
                this.db, this.uid, process.env.ODOO_PASSWORD,
37
                'sale.order', 'search_read',
38
                [[['name', '=', orderNo]]],
39
                { fields: ['name', 'state', 'amount_total', 'date_order'] }
40
            ], (err, result) => {
41
                if (err) reject(err);
42
                resolve(result[0] || null);
43
            });
44
        });
45
    }
46

47
    async getStock(productName) {
48
        const client = xmlrpc.createClient({
49
            url: `${this.url}/xmlrpc/2/object`
50
        });
51

52
        return new Promise((resolve, reject) => {
53
            client.methodCall('execute_kw', [
54
                this.db, this.uid, process.env.ODOO_PASSWORD,
55
                'product.product', 'search_read',
56
                [[['name', 'ilike', productName]]],
57
                { fields: ['name', 'qty_available', 'virtual_available'] }
58
            ], (err, result) => {
59
                if (err) reject(err);
60
                resolve(result);
61
            });
62
        });
63
    }
64
}
65

66
module.exports = new OdooAPI();

主動推播通知#

1
# Odoo 中發送 LINE 通知
2
class SaleOrder(models.Model):
3
    _inherit = 'sale.order'
4

5
    def action_confirm(self):
6
        res = super().action_confirm()
7

8
        # 發送 LINE 通知
9
        if self.partner_id.line_user_id:
10
            self._send_line_notification()
11

12
        return res
13

14
    def _send_line_notification(self):
15
        message = f"""
16
        📦 訂單確認通知
17

18
        訂單編號：{self.name}
19
        金額：NT$ {self.amount_total:,.0f}
20

21
        感謝您的訂購！
22
        """
23

24
        self.env['line.messaging'].send_push_message(
25
            self.partner_id.line_user_id,
26
            message
27
        )

1
{
2
    "size": { "width": 2500, "height": 843 },
3
    "selected": true,
4
    "name": "主選單",
5
    "areas": [
6
        {
7
            "bounds": { "x": 0, "y": 0, "width": 833, "height": 843 },
8
            "action": { "type": "message", "text": "訂單查詢" }
9
        },
10
        {
11
            "bounds": { "x": 833, "y": 0, "width": 833, "height": 843 },
12
            "action": { "type": "message", "text": "庫存查詢" }
13
        },
14
        {
15
            "bounds": { "x": 1666, "y": 0, "width": 834, "height": 843 },
16
            "action": { "type": "uri", "uri": "https://liff.line.me/xxx" }
17
        }
18
    ]
19
}

部署架構#

1
┌─────────────────────────────────────┐
2
│           Cloud Server              │
3
├─────────────────────────────────────┤
4
│  ┌─────────────┐  ┌─────────────┐  │
5
│  │   nginx     │  │   PM2       │  │
6
│  │   reverse   │──│   Node.js   │  │
7
│  │   proxy     │  │   Bot       │  │
8
│  └─────────────┘  └─────────────┘  │
9
│                         │          │
10
│                   ┌─────▼─────┐    │
11
│                   │   Odoo    │    │
12
│                   │   Server  │    │
13
│                   └───────────┘    │
14
└─────────────────────────────────────┘

成效#

功能	效益
訂單查詢	客服詢問減少 50%
出貨通知	顧客滿意度提升 30%
自動回覆	24/7 即時服務

整合目標#

系統架構#

LINE Bot 設定#

Webhook 設定#

訂單查詢功能#

Odoo API 封裝#

主動推播通知#

Rich Menu 設計#

部署架構#

成效#