dedecms实现留言回复

CREATE TABLE `dede_msg` (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `msgtitle` varchar(255) NOT NULL,
  `msgtype` tinyint(1) NOT NULL DEFAULT '0',
  `msgstatus` tinyint(1) NOT NULL DEFAULT '0',
  `msgfrom` varchar(255) NOT NULL,
  `msgto` varchar(255) NOT NULL,
  `msgcontent` text NOT NULL,
  `dtime` int(11) NOT NULL,
  PRIMARY KEY (`id`)
);

CREATE TABLE `dede_msg_reply` (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `msgid` int(11) NOT NULL,
  `replycontent` text NOT NULL,
  `replyer` varchar(255) NOT NULL,
  `replytime` int(11) NOT NULL,
  PRIMARY KEY (`id`)
);

<?php
// 连接数据库
$db = new PDO('mysql:host=localhost;dbname=dedecms', 'username', 'password');

// 获取留言列表
$stmt = $db->query("SELECT * FROM dede_msg");
$messages = $stmt->fetchAll(PDO::FETCH_ASSOC);

foreach ($messages as $message) {
    echo "Title: " . htmlspecialchars($message['msgtitle']) . "<br>";
    echo "From: " . htmlspecialchars($message['msgfrom']) . "<br>";
    echo "Content: " . htmlspecialchars($message['msgcontent']) . "<br>";

    // 获取回复列表
    $replyStmt = $db->query("SELECT * FROM dede_msg_reply WHERE msgid = " . $message['id']);
    $replies = $replyStmt->fetchAll(PDO::FETCH_ASSOC);

    foreach ($replies as $reply) {
        echo "Reply by: " . htmlspecialchars($reply['replyer']) . "<br>";
        echo "Reply content: " . htmlspecialchars($reply['replycontent']) . "<br>";
    }

    echo "<hr>";
}

// 添加回复功能
if ($_SERVER['REQUEST_METHOD'] == 'POST' && isset($_POST['reply'])) {
    $msgid = $_POST['msgid'];
    $replycontent = $_POST['replycontent'];
    $replyer = $_POST['replyer'];

    $stmt = $db->prepare("INSERT INTO dede_msg_reply (msgid, replycontent, replyer, replytime) VALUES (?, ?, ?, ?)");
    $stmt->execute([$msgid, $replycontent, $replyer, time()]);
}
?>

<form method="post">
    <input type="hidden" name="msgid" value="1">
    <textarea name="replycontent"></textarea><br>
    <input type="text" name="replyer" placeholder="Your Name"><br>
    <button type="submit" name="reply">Reply</button>
</form>