feat: add admin binding portal (wechat style)

谭苏航
1 parent 3785d15b
Showing 3 changed files with 417 additions and 106 deletions
admin/index.php
admin/style.css
migrate.php
--- a/admin/index.php 0 → 100644
View file @2acacd1
+++ b/admin/index.php 0 → 100644
View file @2acacd1
+<?php
+require_once __DIR__ . '/../vendor/autoload.php';
+
+// 加载配置 (.env 手动加载逻辑同 start.php)
+if (file_exists(__DIR__ . '/../.env')) {
+    $lines = file(__DIR__ . '/../.env', FILE_IGNORE_NEW_LINES | FILE_SKIP_EMPTY_LINES);
+    foreach ($lines as $line) {
+        if (strpos(trim($line), '#') === 0)
+            continue;
+        list($name, $value) = explode('=', $line, 2);
+        $_ENV[trim($name)] = trim($value);
+    }
+}
+
+// 简单的一致性检查 (实际生产环境应加上 Session 登录验证)
+// 这里假设通过 Basic Auth 或内网访问
+
+// 连接数据库
+try {
+    $dsn = "mysql:host={$_ENV['DB_HOST']};dbname={$_ENV['DB_NAME']};charset=utf8mb4";
+    $pdo = new PDO($dsn, $_ENV['DB_USER'], $_ENV['DB_PASS']);
+    $pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
+} catch (PDOException $e) {
+    die("Database connection failed: " . $e->getMessage());
+}
+
+// 处理绑定表单提交
+$message = '';
+if ($_SERVER['REQUEST_METHOD'] === 'POST' && isset($_POST['action']) && $_POST['action'] === 'bind') {
+    $deviceId = trim($_POST['device_id']);
+    $phone = trim($_POST['phone']);
+    $isPrimary = isset($_POST['is_primary']) ? 1 : 0;
+
+    if ($deviceId && $phone) {
+        // 1. 查找用户
+        $stmt = $pdo->prepare("SELECT id, nickname FROM users WHERE phone = ?");
+        $stmt->execute([$phone]);
+        $user = $stmt->fetch(PDO::FETCH_ASSOC);
+
+        if ($user) {
+            // 2. 插入/更新绑定
+            // 先检查是否已存在
+            $check = $pdo->prepare("SELECT id FROM user_device_bindings WHERE user_id = ? AND device_id = ?");
+            $check->execute([$user['id'], $deviceId]);
+
+            if (!$check->fetch()) {
+                $bind = $pdo->prepare("INSERT INTO user_device_bindings (user_id, device_id, is_primary, created_at) VALUES (?, ?, ?, NOW())");
+                $bind->execute([$user['id'], $deviceId, $isPrimary]);
+                $message = "<div style='color: green; margin-bottom: 20px;'>✅ 成功将设备 <b>$deviceId</b> 绑定给用户 <b>{$user['nickname']}</b></div>";
+            } else {
+                $message = "<div style='color: orange; margin-bottom: 20px;'>⚠️ 该用户已经绑定过此设备，无需重复操作。</div>";
+            }
+        } else {
+            $message = "<div style='color: red; margin-bottom: 20px;'>❌ 手机号 <b>$phone</b> 未找到。请确保用户已在小程序登录过。</div>";
+        }
+    }
+}
+
+// 获取设备列表 (Mock Data + Binding Count)
+// 实际项目应从 Redis 或 devices 表获取在线状态，这里先从 bindings 表反查活跃情况
+// 为了简化，我们列出 distinct device_id from bindings，或者列出 bindings
+$bindings = $pdo->query("
+    SELECT b.id, u.nickname, u.phone, b.device_id, b.is_primary, b.created_at
+    FROM user_device_bindings b
+    JOIN users u ON b.user_id = u.id
+    ORDER BY b.created_at DESC
+")->fetchAll(PDO::FETCH_ASSOC);
+
+?>
+<!DOCTYPE html>
+<html lang="zh-CN">
+
+<head>
+    <meta charset="UTF-8">
+    <meta name="viewport" content="width=device-width, initial-scale=1.0">
+    <title>Moltbot 管理后台</title>
+    <link rel="stylesheet" href="style.css">
+</head>
+
+<body>
+
+    <div class="header">
+        <div class="brand">Moltbot Admin</div>
+        <div>
+            <?php echo date('Y-m-d H:i'); ?>
+        </div>
+    </div>
+
+    <div class="container">
+
+        <?php echo $message; ?>
+
+        <!-- 新增绑定卡片 -->
+        <div class="card">
+            <div class="title">新增绑定</div>
+            <form method="POST" action="">
+                <input type="hidden" name="action" value="bind">
+                <div style="display: flex; gap: 20px;">
+                    <div class="form-group" style="flex: 1;">
+                        <label class="form-label">设备 ID</label>
+                        <input type="text" name="device_id" class="form-control" placeholder="例如: dev_test_001"
+                            required>
+                    </div>
+                    <div class="form-group" style="flex: 1;">
+                        <label class="form-label">用户手机号</label>
+                        <input type="text" name="phone" class="form-control" placeholder="输入用户注册手机号" required>
+                    </div>
+                </div>
+                <div class="form-group">
+                    <label>
+                        <input type="checkbox" name="is_primary" value="1" checked> 设为主设备 (默认)
+                    </label>
+                </div>
+                <button type="submit" class="btn btn-primary">立即绑定</button>
+            </form>
+        </div>
+
+        <!-- 绑定列表卡片 -->
+        <div class="card">
+            <div class="title">绑定记录 (
+                <?php echo count($bindings); ?>)
+            </div>
+            <table>
+                <thead>
+                    <tr>
+                        <th>用户</th>
+                        <th>手机号</th>
+                        <th>设备 ID</th>
+                        <th>主设备</th>
+                        <th>绑定时间</th>
+                        <th>操作</th>
+                    </tr>
+                </thead>
+                <tbody>
+                    <?php foreach ($bindings as $row): ?>
+                        <tr>
+                            <td>
+                                <?php echo htmlspecialchars($row['nickname']); ?>
+                            </td>
+                            <td>
+                                <?php echo htmlspecialchars($row['phone']); ?>
+                            </td>
+                            <td>
+                                <?php echo htmlspecialchars($row['device_id']); ?>
+                            </td>
+                            <td>
+                                <?php if ($row['is_primary']): ?>
+                                    <span style="color: var(--primary-color);">✔</span>
+                                <?php endif; ?>
+                            </td>
+                            <td>
+                                <?php echo $row['created_at']; ?>
+                            </td>
+                            <td>
+                                <a href="#" style="color: red; font-size: 12px; text-decoration: none;">解绑</a>
+                            </td>
+                        </tr>
+                    <?php endforeach; ?>
+                    <?php if (empty($bindings)): ?>
+                        <tr>
+                            <td colspan="6" style="text-align: center; color: #999;">暂无数据</td>
+                        </tr>
+                    <?php endif; ?>
+                </tbody>
+            </table>
+        </div>
+
+    </div>
+
+</body>
+
+</html>
--- a/admin/style.css 0 → 100644
View file @2acacd1
+++ b/admin/style.css 0 → 100644
View file @2acacd1
+/* Admin Style - WeUI Inspired */
+:root {
+    --primary-color: #07c160;
+    --primary-hover: #06ad56;
+    --bg-color: #f7f7f7;
+    --card-bg: #ffffff;
+    --text-main: #000000;
+    --text-secondary: #888888;
+    --border-color: #e5e5e5;
+}
+
+body {
+    margin: 0;
+    padding: 0;
+    font-family: -apple-system, BlinkMacSystemFont, 'Segoe UI', Roboto, 'Helvetica Neue', Arial, sans-serif;
+    background-color: var(--bg-color);
+    color: var(--text-main);
+}
+
+.header {
+    background-color: var(--card-bg);
+    padding: 15px 30px;
+    border-bottom: 1px solid var(--border-color);
+    display: flex;
+    justify-content: space-between;
+    align-items: center;
+}
+
+.brand {
+    font-size: 18px;
+    font-weight: 600;
+    color: var(--text-main);
+}
+
+.container {
+    max-width: 1000px;
+    margin: 30px auto;
+    padding: 0 20px;
+}
+
+.card {
+    background-color: var(--card-bg);
+    border-radius: 8px;
+    box-shadow: 0 1px 3px rgba(0,0,0,0.05);
+    padding: 24px;
+    margin-bottom: 24px;
+}
+
+.title {
+    font-size: 20px;
+    font-weight: 500;
+    margin-bottom: 24px;
+    border-left: 4px solid var(--primary-color);
+    padding-left: 12px;
+}
+
+/* Table */
+table {
+    width: 100%;
+    border-collapse: collapse;
+}
+
+th {
+    text-align: left;
+    color: var(--text-secondary);
+    font-weight: normal;
+    font-size: 14px;
+    padding: 10px;
+    border-bottom: 1px solid var(--border-color);
+}
+
+td {
+    padding: 12px 10px;
+    border-bottom: 1px solid var(--border-color);
+    font-size: 14px;
+}
+
+.status-dot {
+    display: inline-block;
+    width: 8px;
+    height: 8px;
+    border-radius: 50%;
+    margin-right: 6px;
+}
+
+.status-online { background-color: var(--primary-color); }
+.status-offline { background-color: #ccc; }
+
+/* Buttons */
+.btn {
+    display: inline-block;
+    padding: 8px 16px;
+    border-radius: 4px;
+    text-decoration: none;
+    font-size: 14px;
+    cursor: pointer;
+    border: none;
+    transition: background 0.2s;
+}
+
+.btn-primary {
+    background-color: var(--primary-color);
+    color: white;
+}
+
+.btn-primary:hover {
+    background-color: var(--primary-hover);
+}
+
+.btn-sm {
+    padding: 4px 10px;
+    font-size: 12px;
+}
+
+/* Forms */
+.form-group {
+    margin-bottom: 16px;
+}
+
+.form-label {
+    display: block;
+    margin-bottom: 8px;
+    color: var(--text-secondary);
+    font-size: 14px;
+}
+
+.form-control {
+    width: 100%;
+    padding: 10px;
+    border: 1px solid var(--border-color);
+    border-radius: 4px;
+    font-size: 14px;
+    box-sizing: border-box;
+}
+
+.form-control:focus {
+    outline: none;
+    border-color: var(--primary-color);
+}
--- a/migrate.php
View file @2acacd1
+++ b/migrate.php
View file @2acacd1
-<?php
-require_once __DIR__ . '/vendor/autoload.php';
-
-// Load .env (simple loader since we don't have dotenv lib installed in the basic container, 
-// or relying on docker-compose env injection)
-// Actually docker-compose injects env vars, so getenv() works.
-
-$host = getenv('DB_HOST');
-$user = getenv('DB_USER');
-$pass = getenv('DB_PASSWORD');
-$name = getenv('DB_NAME');
-$port = getenv('DB_PORT') ?: 3306;
-
-echo "Connecting to MySQL at $host...\n";
-
-try {
-    $dsn = "mysql:host=$host;port=$port;charset=utf8mb4";
-    $pdo = new PDO($dsn, $user, $pass, [
-        PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION,
-        PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_ASSOC
-    ]);
-
-    echo "Connected successfully.\n";
-
-    // Create Database if not exists
-    $pdo->exec("CREATE DATABASE IF NOT EXISTS `$name` DEFAULT CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci");
-    $pdo->exec("USE `$name`");
-    echo "Selected database '$name'.\n";
-
-    $sql = <<<SQL
--- Devices Table
-CREATE TABLE IF NOT EXISTS `devices` (
-    `id` VARCHAR(64) NOT NULL COMMENT '设备ID (Device ID)',
-    `secret` VARCHAR(128) NOT NULL COMMENT '连接密钥 (Hash)',
-    `name` VARCHAR(50) DEFAULT NULL COMMENT '设备昵称',
-    `status` ENUM('online', 'offline') DEFAULT 'offline' COMMENT '在线状态',
-    `last_seen` TIMESTAMP NULL DEFAULT NULL COMMENT '最后心跳时间',
-    `created_at` TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
-    `updated_at` TIMESTAMP DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
-    PRIMARY KEY (`id`)
-) ENGINE=InnoDB COMMENT='设备管理表';
-
--- Users Table
-CREATE TABLE IF NOT EXISTS `users` (
-    `id` BIGINT UNSIGNED NOT NULL AUTO_INCREMENT,
-    `phone` VARCHAR(20) NOT NULL COMMENT '手机号',
-    `wx_openid` VARCHAR(64) DEFAULT NULL COMMENT '微信 OpenID',
-    `wx_unionid` VARCHAR(64) DEFAULT NULL COMMENT '微信 UnionID',
-    `nickname` VARCHAR(50) DEFAULT NULL COMMENT '显示的昵称',
-    `avatar_url` VARCHAR(255) DEFAULT NULL,
-    `created_at` TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
-    `updated_at` TIMESTAMP DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
-    PRIMARY KEY (`id`),
-    UNIQUE KEY `uk_phone` (`phone`),
-    KEY `idx_wx_openid` (`wx_openid`)
-) ENGINE=InnoDB COMMENT='用户表';
-
--- Sessions Table (用户登录会话)
-CREATE TABLE IF NOT EXISTS `sessions` (
-    `id` BIGINT UNSIGNED NOT NULL AUTO_INCREMENT,
-    `user_id` BIGINT UNSIGNED NOT NULL COMMENT '用户ID',
-    `token` VARCHAR(128) NOT NULL COMMENT 'Session Token',
-    `device_info` JSON DEFAULT NULL COMMENT '登录设备信息',
-    `expires_at` TIMESTAMP NOT NULL COMMENT '过期时间',
-    `created_at` TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
-    PRIMARY KEY (`id`),
-    UNIQUE KEY `uk_token` (`token`),
-    KEY `idx_user` (`user_id`),
-    KEY `idx_expires` (`expires_at`)
-) ENGINE=InnoDB COMMENT='用户会话表';
-
--- User Device Bindings Table (手机号-设备绑定关系)
-CREATE TABLE IF NOT EXISTS `user_device_bindings` (
-    `id` BIGINT UNSIGNED NOT NULL AUTO_INCREMENT,
-    `user_id` BIGINT UNSIGNED NOT NULL COMMENT '用户ID',
-    `device_id` VARCHAR(64) NOT NULL COMMENT '设备ID',
-    `is_primary` TINYINT(1) DEFAULT 0 COMMENT '是否主设备',
-    `bound_at` TIMESTAMP DEFAULT CURRENT_TIMESTAMP COMMENT '绑定时间',
-    PRIMARY KEY (`id`),
-    UNIQUE KEY `uk_user_device` (`user_id`, `device_id`),
-    KEY `idx_device` (`device_id`)
-) ENGINE=InnoDB COMMENT='用户设备绑定表';
-
--- Device Logs Table
-CREATE TABLE IF NOT EXISTS `device_logs` (
-    `id` BIGINT UNSIGNED NOT NULL AUTO_INCREMENT,
-    `device_id` VARCHAR(64) NOT NULL,
-    `level` VARCHAR(10) DEFAULT 'INFO',
-    `message` TEXT NOT NULL,
-    `created_at` TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
-    PRIMARY KEY (`id`),
-    KEY `idx_device_time` (`device_id`, `created_at`)
-) ENGINE=InnoDB COMMENT='设备日志表';
-SQL;
-
-    $pdo->exec($sql);
-    echo "Tables created successfully.\n";
-
-    // Insert sample device if not exists
-    $pdo->exec("INSERT IGNORE INTO `devices` (`id`, `secret`, `name`, `status`) VALUES ('dev_test_001', '123456', 'My First Moltbot', 'offline')");
-    echo "Sample data inserted.\n";
-
-} catch (PDOException $e) {
-    echo "Database Error: " . $e->getMessage() . "\n";
-    exit(1);
-}
+<?php
+require_once __DIR__ . '/vendor/autoload.php';
+
+// Load .env (simple loader since we don't have dotenv lib installed in the basic container, 
+// or relying on docker-compose env injection)
+// Actually docker-compose injects env vars, so getenv() works.
+
+$host = getenv('DB_HOST');
+$user = getenv('DB_USER');
+$pass = getenv('DB_PASSWORD');
+$name = getenv('DB_NAME');
+$port = getenv('DB_PORT') ?: 3306;
+
+echo "Connecting to MySQL at $host...\n";
+
+try {
+    $dsn = "mysql:host=$host;port=$port;charset=utf8mb4";
+    $pdo = new PDO($dsn, $user, $pass, [
+        PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION,
+        PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_ASSOC
+    ]);
+
+    echo "Connected successfully.\n";
+
+    // Create Database if not exists
+    $pdo->exec("CREATE DATABASE IF NOT EXISTS `$name` DEFAULT CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci");
+    $pdo->exec("USE `$name`");
+    echo "Selected database '$name'.\n";
+
+    $sql = <<<SQL
+-- Devices Table
+CREATE TABLE IF NOT EXISTS `devices` (
+    `id` VARCHAR(64) NOT NULL COMMENT '设备ID (Device ID)',
+    `secret` VARCHAR(128) NOT NULL COMMENT '连接密钥 (Hash)',
+    `name` VARCHAR(50) DEFAULT NULL COMMENT '设备昵称',
+    `status` ENUM('online', 'offline') DEFAULT 'offline' COMMENT '在线状态',
+    `last_seen` TIMESTAMP NULL DEFAULT NULL COMMENT '最后心跳时间',
+    `created_at` TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
+    `updated_at` TIMESTAMP DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
+    PRIMARY KEY (`id`)
+) ENGINE=InnoDB COMMENT='设备管理表';
+
+-- Users Table
+CREATE TABLE IF NOT EXISTS `users` (
+    `id` BIGINT UNSIGNED NOT NULL AUTO_INCREMENT,
+    `phone` VARCHAR(20) NOT NULL COMMENT '手机号',
+    `wx_openid` VARCHAR(64) DEFAULT NULL COMMENT '微信 OpenID',
+    `wx_unionid` VARCHAR(64) DEFAULT NULL COMMENT '微信 UnionID',
+    `nickname` VARCHAR(50) DEFAULT NULL COMMENT '显示的昵称',
+    `avatar_url` VARCHAR(255) DEFAULT NULL,
+    `created_at` TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
+    `updated_at` TIMESTAMP DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
+    PRIMARY KEY (`id`),
+    UNIQUE KEY `uk_phone` (`phone`),
+    KEY `idx_wx_openid` (`wx_openid`)
+) ENGINE=InnoDB COMMENT='用户表';
+
+-- Sessions Table (用户登录会话)
+CREATE TABLE IF NOT EXISTS `sessions` (
+    `id` BIGINT UNSIGNED NOT NULL AUTO_INCREMENT,
+    `user_id` BIGINT UNSIGNED NOT NULL COMMENT '用户ID',
+    `token` VARCHAR(128) NOT NULL COMMENT 'Session Token',
+    `device_info` JSON DEFAULT NULL COMMENT '登录设备信息',
+    `expires_at` TIMESTAMP NOT NULL COMMENT '过期时间',
+    `created_at` TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
+    PRIMARY KEY (`id`),
+    UNIQUE KEY `uk_token` (`token`),
+    KEY `idx_user` (`user_id`),
+    KEY `idx_expires` (`expires_at`)
+) ENGINE=InnoDB COMMENT='用户会话表';
+
+-- User Device Bindings Table (手机号-设备绑定关系)
+CREATE TABLE IF NOT EXISTS `user_device_bindings` (
+    `id` BIGINT UNSIGNED NOT NULL AUTO_INCREMENT,
+    `user_id` BIGINT UNSIGNED NOT NULL COMMENT '用户ID',
+    `device_id` VARCHAR(64) NOT NULL COMMENT '设备ID',
+    `is_primary` TINYINT(1) DEFAULT 0 COMMENT '是否主设备',
+    `bound_at` TIMESTAMP DEFAULT CURRENT_TIMESTAMP COMMENT '绑定时间',
+    PRIMARY KEY (`id`),
+    UNIQUE KEY `uk_user_device` (`user_id`, `device_id`),
+    KEY `idx_device` (`device_id`)
+) ENGINE=InnoDB COMMENT='用户设备绑定表';
+
+-- Device Logs Table
+CREATE TABLE IF NOT EXISTS `device_logs` (
+    `id` BIGINT UNSIGNED NOT NULL AUTO_INCREMENT,
+    `device_id` VARCHAR(64) NOT NULL,
+    `level` VARCHAR(10) DEFAULT 'INFO',
+    `message` TEXT NOT NULL,
+    `created_at` TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
+    PRIMARY KEY (`id`),
+    KEY `idx_device_time` (`device_id`, `created_at`)
+) ENGINE=InnoDB COMMENT='设备日志表';
+SQL;
+
+    $pdo->exec($sql);
+    echo "Tables created successfully.\n";
+
+    // Insert sample device if not exists
+    $pdo->exec("INSERT IGNORE INTO `devices` (`id`, `secret`, `name`, `status`) VALUES ('dev_test_001', '123456', 'My First Moltbot', 'offline')");
+    echo "Sample data inserted.\n";
+
+} catch (PDOException $e) {
+    echo "Database Error: " . $e->getMessage() . "\n";
+    exit(1);
+}