Raspberry Pi Zero 2 WとRasTech Raspberry Pi カメラで作る二次元コード受付システム

import tkinter as tk # GUIライブラリ、tkinterモジュールを読み込む
import requests # HTTP通信を行うライブラリ
from picamera2 import Picamera2 # カメラ制御用ライブラリ（picamera2）からPicamera2クラスを読み込む
import cv2 # 画像処理ライブラリ cv2を読み込む
from pyzbar import pyzbar #QRコード解析ライブラリ（pyzbar）からpyzbarモジュールを読み込む
import time # 時間に関する処理、timeを読み込む

SERVER_URL = "https://xxxxxxxxxxx/update.php"

def update_flag(id_num):
    try:
        r = requests.get(f"{SERVER_URL}?id={id_num}&flg=2")
        data = r.json()
        if data.get("status") == "success":
            record = data.get("data", {})
            update_ui(record)
        else:
            update_ui({"error": data.get("message")})
    except Exception as e:
        update_ui({"error": str(e)})

def update_ui(record):
    # 一旦クリア
    for w in frame_result.winfo_children():
        w.destroy()

    if "error" in record:
        tk.Label(frame_result, text=f"エラー: {record['error']}", fg="red").pack(anchor="w")
        return

    tk.Label(frame_result, text=f"No: {record.get('id')}", font=("Arial", 14)).pack(anchor="w")
    tk.Label(frame_result, text=f"申込日時: {record.get('created_at')}", font=("Arial", 14)).pack(anchor="w")
    tk.Label(frame_result, text=f"分科会: {record.get('special_lecture')}", font=("Arial", 14)).pack(anchor="w")
    tk.Label(frame_result, text=f"お名前: {record.get('name')}（{record.get('name_kana')}）", font=("Arial", 14)).pack(anchor="w")
    tk.Label(frame_result, text=f"email: {record.get('email')}", font=("Arial", 14)).pack(anchor="w")

# Tkinter ウィンドウ
root = tk.Tk()
root.title("QRコード読み取り結果")
root.geometry("500x300")

frame_result = tk.Frame(root)
frame_result.pack(fill="both", expand=True, padx=10, pady=10)

# カメラ初期化
picam2 = Picamera2()
picam2.preview_configuration.main.size = (640, 480)
picam2.preview_configuration.main.format = "RGB888"
picam2.configure("preview")
picam2.start()

last_id_num = None

def capture_loop():
    global last_id_num

    frame = picam2.capture_array()
    decoded_objs = pyzbar.decode(frame)

    for obj in decoded_objs:
        id_num = obj.data.decode("utf-8")
        if id_num != last_id_num:
            last_id_num = id_num
            update_flag(id_num)
            time.sleep(1)

    # 50ms ごとにループ
    root.after(50, capture_loop)

# ループ開始
capture_loop()

# Tkinterのウィンドウを開いたまま、QRコード読み取りを受け付け続ける
root.mainloop()

# 終了処理
picam2.stop()
cv2.destroyAllWindows()

<?php
// =========================================
// CORSとレスポンス設定（外部からのアクセスを許可）
// =========================================
header("Access-Control-Allow-Origin: *");
header("Access-Control-Allow-Methods: GET, POST, OPTIONS");
header("Access-Control-Allow-Headers: Content-Type");
header("Content-Type: application/json; charset=UTF-8");

// =========================================
// データベース接続情報（本番用）
// =========================================
$dsn = 'mysql:host=xxxxxxxxxxxxxx;dbname=xxxxxxxxxxxxxx;charset=utf8mb4';
$user = 'xxxxxxxxxxxxxx';
$pass = 'xxxxxxxxxxxxxx';

try {
    // =========================================
    // PDOでデータベースに接続
    // =========================================
    $pdo = new PDO($dsn, $user, $pass);
    $pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION); // 例外モード
    $pdo->setAttribute(PDO::ATTR_EMULATE_PREPARES, false);         // エミュレーション無効（セキュリティ向上）

    // =========================================
    // GETパラメータ（id, flg）が指定されているか確認
    // =========================================
    if (isset($_GET['id']) && isset($_GET['flg'])) {
        $id = (int)$_GET['id'];   // idを整数に変換
        $flg = (int)$_GET['flg']; // flgを整数に変換

        // =========================================
        // customersテーブルのflg値を更新
        // =========================================
        $stmt = $pdo->prepare("UPDATE customers SET flg = ? WHERE id = ?");
        $stmt->execute([$flg, $id]);

        // =========================================
        // 更新後のレコード情報を取得
        // =========================================
        $stmt = $pdo->prepare("
            SELECT id, created_at, special_lecture, name, name_kana, email 
            FROM customers 
            WHERE id = ?
        ");
        $stmt->execute([$id]);
        $row = $stmt->fetch(PDO::FETCH_ASSOC);

        // =========================================
        // レコードが存在する場合：成功レスポンス
        // =========================================
        if ($row) {
            echo json_encode([
                "status" => "success",
                "message" => "更新しました",
                "data" => $row
            ], JSON_UNESCAPED_UNICODE | JSON_PRETTY_PRINT);
        } else {
            // =========================================
            // レコードが見つからない場合：エラー
            // =========================================
            echo json_encode([
                "status" => "error",
                "message" => "データが見つかりません"
            ]);
        }
    } else {
        // =========================================
        // パラメータ不足の場合のエラー
        // =========================================
        echo json_encode([
            "status" => "error",
            "message" => "パラメータが不足しています"
        ]);
    }
} catch (PDOException $e) {
    // =========================================
    // データベース接続または実行時エラー処理
    // =========================================
    echo json_encode([
        "status" => "error",
        "message" => "接続エラー: " . $e->getMessage()
    ]);
}