# 程式碼實作
**2 hr**

[ToC]
## 1. Django 設定
1. 安裝套件

$ pip install Django

$ pip install line-bot-sdk

$ pip install pymysql

2. 建立專案

$ django-admin startproject '專案名稱'

cd '專案名稱'

3. 建立 APP：可以進行多個 Line Bot 開發

$ python manage.py startapp 'APP名稱'

4. 新建兩個資料夾

$ md static
$ md templates

static 用於靜態資料如圖片、檔案
templates 用於放寫好的 html
## 2. 在 `settings.py` 進行
1. 在最上面

import pymysql
pymysql.install_as_MySQLdb()

2. 設定 Channel Access Token & Channel Secret
第 22 行左右的地方

CHANNEL_ACCESS_TOKEN = 'Channel_access_token'
CHANNEL_SECRET = 'Channel_secret'

3. 於 INSTALLED_APPS 中設定建立的 APP 名稱

INSTALLED_APPS = [
    'django.contrib.admin',
    'django.contrib.auth',
    'django.contrib.contenttypes',
    'django.contrib.sessions',
    'django.contrib.messages',
    'django.contrib.staticfiles',
    '【app】' #新增 app 名稱
]

4. 於 TEMPLATES 中設定 templates 的資料夾路徑

'DIRS'[os.path.join(BASE_DIR,'templates')]

5. staitc

STATIC_URL = '/static'
STATICILES_DIRS = [os.path.join(BASE_DIR,'static')]

6. 語言及時區設定

## 利用 Django 連接資料庫 (共 7 個步驟)
1. `settings.py`

DATABASES = {
    'default': {
        'ENGINE': 'django.db.backends.mysql', 
        'NAME': '【your DB name】',                      
        'USER': '【your user name】',                      
        'PASSWORD': '【your password】',               
        'HOST': '',                           
        'PORT': '3306',                           
    }
}

2. debug
> 如果MySQL 服務器配置為使用 caching_sha2_password 或 sha256_password 作為身份驗證插件時，PyMySQL（這是 Django 用來與 MySQL 通信的一個 Python 庫）需要 cryptography 套件來加密密碼。

$ pip install cryptography

3. 同步資料庫

$ python manage.py inspectdb > 【your_app_name】/models.py

4. 檢查 `model.py` 有沒有你的 database
5. `admin.py` (後台資料)

5-1 from `models.py` import the database table

from django.contrib import admin

# Register your models here.
from 【your_app_name】.models import *

#【below is optional，想要做 5-2 再做就可以】
class user_message_admin(admin.ModelAdmin):
    list_display = ('uid', 'name', 'message', 'time')
admin.site.register(user_message, user_message_admin)

5-2 optional
若我們想從 Linebot 中記錄用戶 ID 以及訊息內容

#from django.db import models

# Create your models here.
class user_message(models.Model):
    uid = models.CharField(max_length=50, null=False, primary_key=True)  # user id
    name = models.CharField(max_length=50, blank=True, null=False) # LINE 名字
    message = models.CharField(max_length=600, blank=True, null=False) # 文字訊息紀錄
    time = models.DateTimeField(auto_now=True) # 日期時間

    def __str__(self):
        return self.name # print the user name in terminal

7. 更新資料庫
之後在 mysql workbench 有異動都可以直接輸這個更新

$ python manage.py makemigrations

$ python manage.py migrate

7-1. debug
有可能出現
>SyntaxError: source code string cannot contain null bytes

- 意思是有 null bytes 出現，而非一般的空格(ex. a + b，就屬於一般空格)
- 解決方式:
(1) 下載 hex editor (發行者 :microsoft)
(2) 右鍵點選檔案>開啟方式> 16 進位編輯器 > crtl+F 查找`00`
$\quad$在 16 進位中，一般空格應顯示`20`
$\quad$範例圖示如下
STEP1 
STEP2 
STEP 3 注意要選擇｢以二進位模式搜尋」(會自動變成 16 進位不用擔心)

(3) TIP
$\quad$因為 `model.py` 的 table 都是從 mysql 導入，比較有可能出錯，所以可以先從這邊下手
(4)
$\quad$ 4-1 找到有錯的檔案之後，用文字編輯器打開，複製所有程式。
$\quad$$\quad$$\quad$重新建立一個`.py`檔案，貼上 `models.py` 的內容。
$\quad$ 4-2 貼上後一樣用 16 進位的方式確認沒有出現 null bytes (`00`)
$\quad$ 4-3 用新檔案取代舊的 `models.py` (一樣的路徑、一樣的名字)
(5) 重新輸入 `$ python manage.py makemigrations`，確認沒有問題
- 這樣就 debug 結束了~
## 資料表操作
1. `views.py`
2. 將` models.py` 資料表匯入 `views.py`

from 【your_app_name】.models import *

3. 修改 `views.py`

from django.shortcuts import render

# Create your views here.
from app.models import *

import re
import logging
from django.conf import settings
from django.http import HttpResponse, HttpResponseBadRequest, HttpResponseForbidden
from django.views.decorators.csrf import csrf_exempt
from linebot import LineBotApi, WebhookParser
from linebot.exceptions import InvalidSignatureError, LineBotApiError
from linebot.models import MessageEvent, TextSendMessage
from .models import SnakeSpecies, Product, CareRequirements

line_bot_api = LineBotApi(settings.CHANNEL_ACCESS_TOKEN)
parser = WebhookParser(settings.CHANNEL_SECRET)

# 設置日誌

logger = logging.getLogger(__name__)

@csrf_exempt
def callback(request):
    if request.method != 'POST':
        return HttpResponseBadRequest()

    signature = request.META.get('HTTP_X_LINE_SIGNATURE', '')
    body = request.body.decode('utf-8')

    # 日誌輸出
    logger.info(f"Request body: {body}")
    logger.info(f"Signature: {signature}")

    try:
        events = parser.parse(body, signature)
    except InvalidSignatureError:
        logger.error("Invalid signature error")
        return HttpResponseForbidden()
    except LineBotApiError as e:
        logger.error(f"LineBotApiError: {str(e)}")
        return HttpResponseBadRequest()

    for event in events:
        if isinstance(event, MessageEvent):
            handle_message(event)

    return HttpResponse('OK')

def handle_message(event):
    message_text = event.message.text.strip()
    if "蛇的學名" in message_text:
        scientific_name = extract_scientific_name(message_text)
        species_exists = SnakeSpecies.objects.filter(scientific_name=scientific_name).exists()
        if species_exists:
            reply_text = f"蛇類 {scientific_name} 已經存在於資料庫中。"
        else:
            reply_text = f"您所輸入的蛇類不存在，請您建立新的檔案。若要建立，請回覆 OK"
        line_bot_api.reply_message(event.reply_token, TextSendMessage(text=reply_text))
    elif "new" in message_text:
        # 调用 handle_snake_species 并传递 message_text，这个函数负责发送回复
        handle_snake_species(event, message_text)
    elif "【學名】" in message_text:
        handle_read(event, message_text)
    elif "刪除產品編號" in message_text:
        handle_delete(event, message_text)
    elif "更新" in message_text:
        handle_update(event, message_text)


def extract_scientific_name(text):
    # 假设用户会按照【學名】snake的格式输入
    pattern = r'蛇的學名[:：](.+)'
    match = re.search(pattern, text)
    return match.group(1) if match else None

def extract_scientific_name2(text):
    # 假设用户会按照【學名】snake的格式输入
    pattern = r'【學名】(\w+\s?\w*)'
    match = re.search(pattern, text)
    return match.group(1) if match else None

def handle_snake_species(event, message_text):
    data = parse_data(message_text)
    if data:
        species, created = SnakeSpecies.objects.get_or_create(
            scientific_name=data['scientific_name'],
            chinese_name=data['chinese_name'],
            defaults={'amount': data['amount']}
        )
        if created:
            #reply_text = f"儲存成功，蛇類編號為 {species.id}" //這個有錯，好像讀不出來整個掰掰
            reply_text = "儲存成功"
        else:
            reply_text = "儲存失敗"
    else:
        reply_text = "儲存失敗，請確認訊息格式是否有誤"
    line_bot_api.reply_message(event.reply_token, TextSendMessage(text=reply_text))

def parse_data(text):
    pattern = r'.*\n【學名】(\w+)\n【中文名稱】(\S+)\n【數量】(\d+)'
    match = re.search(pattern, text, re.MULTILINE | re.DOTALL)
    if match:
        return {
            'scientific_name': match.group(1),
            'chinese_name': match.group(2),
            'amount': int(match.group(3))
        }
    return None


def handle_read(event, message_text):
    # 提取学名
    scientific_name = extract_scientific_name2(message_text)
    if not scientific_name:
        line_bot_api.reply_message(event.reply_token, TextSendMessage(text="格式错误,请重新输入。"))
        return

    # 查询数据库,获取所有匹配的 SnakeSpecies 对象
    matching_species = SnakeSpecies.objects.filter(scientific_name=scientific_name)
    if matching_species:
        # 构建产品名称列表
        product_names = [f"{species.chinese_name} (數量: {species.amount})" for species in matching_species]
        product_names_str = "\n".join(product_names)
        reply_text = f"以下是與學名 '{scientific_name}' 匹配的產品:\n\n{product_names_str}"
        line_bot_api.reply_message(event.reply_token, TextSendMessage(text=reply_text))

        return

    # 如果没有匹配的对象
    line_bot_api.reply_message(event.reply_token, TextSendMessage(text="没有找到对应的蛇类。"))
    return


def handle_update(event, message_text):
    pattern = r'【產品編號:(\d+)】(\d+)'
    match = re.search(pattern, message_text)
    if match:
        product_id, new_price = match.groups()
        try:
            # 尝试获取产品
            product = Product.objects.get(product_id=int(product_id))
            # 更新价格
            product.price = float(new_price)
            product.save()
            reply_text = f"產品編號 {product_id} 的價格已更新為 {new_price}"
        except Product.DoesNotExist:
            reply_text = f"没有找到產品編號 {product_id} 的產品。"
        except Exception as e:
            reply_text = f"錯誤: {str(e)}"
    else:
        reply_text = "格式錯誤"
    # 发送回复消息
    line_bot_api.reply_message(event.reply_token, TextSendMessage(text=reply_text))

def handle_delete(event, message_text):
     # 假设用户输入格式为：“【刪除產品編號】12345”
    pattern = r'【刪除產品編號】(\d+)'
    match = re.search(pattern, message_text)
    if not match:
        line_bot_api.reply_message(event.reply_token, TextSendMessage(text="格式錯誤"))
        return

    product_id = int(match.group(1))
    try:
        product = Product.objects.get(product_id=product_id)
        product.delete()
        reply_text = f"產品編號 {product_id} 已成功删除。"
    except Product.DoesNotExist:
        reply_text = f"沒有找到 {product_id} "
    except Exception as e:
        reply_text = f"刪除過程中出現錯誤 {str(e)}"

    line_bot_api.reply_message(event.reply_token, TextSendMessage(text=reply_text))