增加nginx的标签

nginx_tab.py

@@ -0,0 +1,785 @@
+import os
+import sys
+from PySide6.QtWidgets import (QWidget, QVBoxLayout, QHBoxLayout, QPushButton, 
+                               QLabel, QTextEdit, QFileDialog, QMessageBox, 
+                               QLineEdit, QDialog, QDialogButtonBox)
+from PySide6.QtCore import QThread, Signal
+from loguru import logger
+
+class PasswordDialog(QDialog):
+    def __init__(self, parent=None):
+        super().__init__(parent)
+        self.setWindowTitle("输入密码")
+        self.setMinimumWidth(300)
+        
+        layout = QVBoxLayout()
+        
+        # 提示标签
+        label = QLabel("请输入sudo密码:")
+        layout.addWidget(label)
+        
+        # 密码输入框
+        self.password_input = QLineEdit()
+        self.password_input.setEchoMode(QLineEdit.Password)
+        layout.addWidget(self.password_input)
+        
+        # 按钮
+        button_box = QDialogButtonBox(QDialogButtonBox.Ok | QDialogButtonBox.Cancel)
+        button_box.accepted.connect(self.accept)
+        button_box.rejected.connect(self.reject)
+        layout.addWidget(button_box)
+        
+        self.setLayout(layout)
+    
+    def get_password(self):
+        return self.password_input.text()
+
+class NginxInstallThread(QThread):
+    """安装Nginx的线程"""
+    result_ready = Signal(bool, str)
+    
+    def __init__(self, ssh_client, password):
+        super().__init__()
+        self.ssh_client = ssh_client
+        self.password = password
+        
+    def run(self):
+        try:
+            logger.info("开始安装Nginx")
+            
+            # 使用bash -c将命令组合在一起，确保密码对所有sudo命令有效
+            stdin, stdout, stderr = self.ssh_client.exec_command(f"bash -c 'echo \"{self.password}\" | sudo -S apt update && echo \"{self.password}\" | sudo -S apt install -y nginx'")
+            exit_status = stdout.channel.recv_exit_status()
+            
+            output = stdout.read().decode()
+            error = stderr.read().decode()
+            
+            if exit_status == 0:
+                # 验证安装
+                logger.info("验证Nginx安装")
+                stdin, stdout, stderr = self.ssh_client.exec_command("nginx -v")
+                version_exit_status = stdout.channel.recv_exit_status()
+                nginx_version = stdout.read().decode().strip()
+                version_error = stderr.read().decode()
+                
+                logger.info(f"Nginx版本检查状态: {version_exit_status}")
+                logger.info(f"Nginx版本信息: {nginx_version}")
+                if version_error:
+                    logger.error(f"Nginx版本检查错误: {version_error}")
+                
+                if nginx_version:
+                    self.result_ready.emit(True, f"Nginx安装成功: {nginx_version}")
+                    logger.info(f"Nginx安装成功: {nginx_version}")
+                else:
+                    self.result_ready.emit(False, "Nginx安装后无法获取版本信息")
+                    logger.error("Nginx安装后无法获取版本信息")
+            else:
+                self.result_ready.emit(False, f"Nginx安装失败: {error}")
+                logger.error(f"Nginx安装失败: {error}")
+                
+        except Exception as e:
+            error_msg = str(e)
+            self.result_ready.emit(False, error_msg)
+            logger.error(f"Nginx安装异常: {error_msg}")
+
+class NginxConfigThread(QThread):
+    """处理Nginx配置文件的线程"""
+    result_ready = Signal(bool, str)
+    
+    def __init__(self, ssh_client, config_content, config_path, password, operation="upload"):
+        super().__init__()
+        self.ssh_client = ssh_client
+        self.config_content = config_content
+        self.config_path = config_path
+        self.password = password
+        self.operation = operation  # "upload" 或 "download"
+        
+    def run(self):
+        try:
+            logger.info(f"开始处理Nginx配置文件: {self.config_path}, 操作: {self.operation}")
+            
+            if self.operation == "upload":
+                # 上传配置文件
+                # 创建临时文件
+                temp_file = "/tmp/nginx_config.conf"
+                
+                # 将配置内容写入临时文件
+                stdin, stdout, stderr = self.ssh_client.exec_command(f"cat > {temp_file} << 'EOF'\n{self.config_content}\nEOF")
+                exit_status = stdout.channel.recv_exit_status()
+                
+                if exit_status != 0:
+                    error = stderr.read().decode()
+                    self.result_ready.emit(False, f"创建临时文件失败: {error}")
+                    logger.error(f"创建临时文件失败: {error}")
+                    return
+                
+                # 备份原配置文件
+                backup_cmd = f"bash -c 'echo \"{self.password}\" | sudo -S cp {self.config_path} {self.config_path}.bak'"
+                stdin, stdout, stderr = self.ssh_client.exec_command(backup_cmd)
+                backup_status = stdout.channel.recv_exit_status()
+                
+                if backup_status != 0:
+                    error = stderr.read().decode()
+                    logger.warning(f"备份原配置文件失败: {error}")
+                
+                # 移动临时文件到目标位置
+                move_cmd = f"bash -c 'echo \"{self.password}\" | sudo -S mv {temp_file} {self.config_path}'"
+                stdin, stdout, stderr = self.ssh_client.exec_command(move_cmd)
+                move_status = stdout.channel.recv_exit_status()
+                
+                if move_status == 0:
+                    self.result_ready.emit(True, f"配置文件上传成功: {self.config_path}")
+                    logger.info(f"配置文件上传成功: {self.config_path}")
+                else:
+                    error = stderr.read().decode()
+                    self.result_ready.emit(False, f"配置文件上传失败: {error}")
+                    logger.error(f"配置文件上传失败: {error}")
+                    
+            elif self.operation == "download":
+                # 下载配置文件
+                download_cmd = f"bash -c 'echo \"{self.password}\" | sudo -S cat {self.config_path}'"
+                stdin, stdout, stderr = self.ssh_client.exec_command(download_cmd)
+                exit_status = stdout.channel.recv_exit_status()
+                
+                if exit_status == 0:
+                    config_content = stdout.read().decode()
+                    self.result_ready.emit(True, config_content)
+                    logger.info(f"配置文件下载成功: {self.config_path}")
+                else:
+                    error = stderr.read().decode()
+                    self.result_ready.emit(False, f"配置文件下载失败: {error}")
+                    logger.error(f"配置文件下载失败: {error}")
+                    
+        except Exception as e:
+            error_msg = str(e)
+            self.result_ready.emit(False, error_msg)
+            logger.error(f"Nginx配置文件处理异常: {error_msg}")
+
+class NginxControlThread(QThread):
+    """控制Nginx服务的线程"""
+    result_ready = Signal(bool, str)
+    
+    def __init__(self, ssh_client, password, action):
+        super().__init__()
+        self.ssh_client = ssh_client
+        self.password = password
+        self.action = action  # "restart", "enable", "disable", "status"
+        
+    def run(self):
+        try:
+            logger.info(f"开始执行Nginx服务操作: {self.action}")
+            
+            if self.action == "restart":
+                command = f"bash -c 'echo \"{self.password}\" | sudo -S systemctl restart nginx'"
+            elif self.action == "enable":
+                command = f"bash -c 'echo \"{self.password}\" | sudo -S systemctl enable nginx'"
+            elif self.action == "disable":
+                command = f"bash -c 'echo \"{self.password}\" | sudo -S systemctl disable nginx'"
+            elif self.action == "status":
+                command = f"bash -c 'echo \"{self.password}\" | sudo -S systemctl status nginx'"
+            elif self.action == "configtest":
+                command = f"bash -c 'echo \"{self.password}\" | sudo -S nginx -t'"
+            else:
+                self.result_ready.emit(False, f"不支持的操作: {self.action}")
+                logger.error(f"不支持的操作: {self.action}")
+                return
+            
+            stdin, stdout, stderr = self.ssh_client.exec_command(command)
+            exit_status = stdout.channel.recv_exit_status()
+            
+            output = stdout.read().decode()
+            error = stderr.read().decode()
+            
+            if exit_status == 0:
+                self.result_ready.emit(True, f"Nginx {self.action} 操作成功\n{output}")
+                logger.info(f"Nginx {self.action} 操作成功")
+            else:
+                self.result_ready.emit(False, f"Nginx {self.action} 操作失败: {error}")
+                logger.error(f"Nginx {self.action} 操作失败: {error}")
+                
+        except Exception as e:
+            error_msg = str(e)
+            self.result_ready.emit(False, error_msg)
+            logger.error(f"Nginx服务控制异常: {error_msg}")
+
+class NginxSiteThread(QThread):
+    """处理Nginx站点配置的线程"""
+    result_ready = Signal(bool, str)
+    
+    def __init__(self, ssh_client, site_config, site_name, password, operation="create"):
+        super().__init__()
+        self.ssh_client = ssh_client
+        self.site_config = site_config
+        self.site_name = site_name
+        self.password = password
+        self.operation = operation  # "create" 或 "enable"
+        
+    def run(self):
+        try:
+            logger.info(f"开始处理Nginx站点配置: {self.site_name}, 操作: {self.operation}")
+            
+            if self.operation == "create":
+                # 创建站点配置文件
+                site_path = f"/etc/nginx/sites-available/{self.site_name}"
+                
+                # 创建临时文件
+                temp_file = f"/tmp/{self.site_name}.conf"
+                
+                # 将配置内容写入临时文件
+                stdin, stdout, stderr = self.ssh_client.exec_command(f"cat > {temp_file} << 'EOF'\n{self.site_config}\nEOF")
+                exit_status = stdout.channel.recv_exit_status()
+                
+                if exit_status != 0:
+                    error = stderr.read().decode()
+                    self.result_ready.emit(False, f"创建临时文件失败: {error}")
+                    logger.error(f"创建临时文件失败: {error}")
+                    return
+                
+                # 移动临时文件到目标位置
+                move_cmd = f"bash -c 'echo \"{self.password}\" | sudo -S mv {temp_file} {site_path}'"
+                stdin, stdout, stderr = self.ssh_client.exec_command(move_cmd)
+                move_status = stdout.channel.recv_exit_status()
+                
+                if move_status == 0:
+                    self.result_ready.emit(True, f"站点配置文件创建成功: {site_path}")
+                    logger.info(f"站点配置文件创建成功: {site_path}")
+                else:
+                    error = stderr.read().decode()
+                    self.result_ready.emit(False, f"站点配置文件创建失败: {error}")
+                    logger.error(f"站点配置文件创建失败: {error}")
+                    
+            elif self.operation == "enable":
+                # 启用站点配置
+                enable_cmd = f"bash -c 'echo \"{self.password}\" | sudo -S ln -s /etc/nginx/sites-available/{self.site_name} /etc/nginx/sites-enabled/'"
+                stdin, stdout, stderr = self.ssh_client.exec_command(enable_cmd)
+                exit_status = stdout.channel.recv_exit_status()
+                
+                if exit_status == 0:
+                    self.result_ready.emit(True, f"站点配置启用成功: {self.site_name}")
+                    logger.info(f"站点配置启用成功: {self.site_name}")
+                else:
+                    error = stderr.read().decode()
+                    self.result_ready.emit(False, f"站点配置启用失败: {error}")
+                    logger.error(f"站点配置启用失败: {error}")
+                    
+        except Exception as e:
+            error_msg = str(e)
+            self.result_ready.emit(False, error_msg)
+            logger.error(f"Nginx站点配置处理异常: {error_msg}")
+
+class NginxTab(QWidget):
+    def __init__(self):
+        super().__init__()
+        self.ssh_client = None
+        self.username = ""
+        self.project_name = ""
+        self.server_ip = ""
+        self.init_ui()
+        
+    def init_ui(self):
+        layout = QVBoxLayout()
+        
+        # Nginx安装区域
+        install_layout = QHBoxLayout()
+        
+        # 安装Nginx按钮
+        self.install_nginx_btn = QPushButton("安装Nginx")
+        self.install_nginx_btn.clicked.connect(self.install_nginx)
+        install_layout.addWidget(self.install_nginx_btn)
+        
+        layout.addLayout(install_layout)
+        
+        # Nginx主配置文件区域
+        main_config_layout = QVBoxLayout()
+        main_config_layout.addWidget(QLabel("Nginx主配置文件编辑器:"))
+        
+        # 主配置文件编辑文本框
+        self.main_config_editor = QTextEdit()
+        self.main_config_editor.setReadOnly(False)
+        main_config_layout.addWidget(self.main_config_editor)
+        
+        # 主配置文件操作按钮
+        main_config_btn_layout = QHBoxLayout()
+        
+        # 下载主配置文件按钮
+        self.download_main_config_btn = QPushButton("下载主配置文件")
+        self.download_main_config_btn.clicked.connect(self.download_main_config)
+        main_config_btn_layout.addWidget(self.download_main_config_btn)
+        
+        # 上传主配置文件按钮
+        self.upload_main_config_btn = QPushButton("上传主配置文件")
+        self.upload_main_config_btn.clicked.connect(self.upload_main_config)
+        main_config_btn_layout.addWidget(self.upload_main_config_btn)
+        
+        main_config_layout.addLayout(main_config_btn_layout)
+        layout.addLayout(main_config_layout)
+        
+        # Nginx站点配置区域
+        site_config_layout = QVBoxLayout()
+        site_config_layout.addWidget(QLabel("Nginx站点配置编辑器:"))
+        
+        # 站点配置编辑文本框
+        self.site_config_editor = QTextEdit()
+        self.site_config_editor.setReadOnly(False)
+        site_config_layout.addWidget(self.site_config_editor)
+        
+        # 站点配置操作按钮
+        site_config_btn_layout = QHBoxLayout()
+        
+        # 创建站点配置按钮
+        self.create_site_config_btn = QPushButton("创建站点配置")
+        self.create_site_config_btn.clicked.connect(self.create_site_config)
+        site_config_btn_layout.addWidget(self.create_site_config_btn)
+        
+        # 启用站点配置按钮
+        self.enable_site_config_btn = QPushButton("启用站点配置")
+        self.enable_site_config_btn.clicked.connect(self.enable_site_config)
+        site_config_btn_layout.addWidget(self.enable_site_config_btn)
+        
+        site_config_layout.addLayout(site_config_btn_layout)
+        layout.addLayout(site_config_layout)
+        
+        # Nginx控制区域
+        control_layout = QHBoxLayout()
+        
+        # 重启Nginx按钮
+        self.restart_nginx_btn = QPushButton("重启Nginx")
+        self.restart_nginx_btn.clicked.connect(self.restart_nginx)
+        control_layout.addWidget(self.restart_nginx_btn)
+        
+        # 查看Nginx状态按钮
+        self.check_nginx_status_btn = QPushButton("查看Nginx状态")
+        self.check_nginx_status_btn.clicked.connect(self.check_nginx_status)
+        control_layout.addWidget(self.check_nginx_status_btn)
+        
+        layout.addLayout(control_layout)
+        
+        # 输出区域
+        self.output_text = QTextEdit()
+        self.output_text.setReadOnly(True)
+        layout.addWidget(self.output_text)
+        
+        self.setLayout(layout)
+        
+        # 初始化配置文件内容
+        self.init_config_content()
+    
+    def init_config_content(self):
+        """初始化配置文件内容"""
+        # 初始化主配置文件内容
+        main_config_content = '''# 全局块：配置Nginx进程的基本运行参数 
+user www-data;  # Nginx进程运行的用户/组（默认是www-data，不是你的登录用户xiaji） 
+worker_processes auto;  # 工作进程数，auto表示自动匹配CPU核心数 
+pid /run/nginx.pid;  # Nginx进程PID文件路径 
+include /etc/nginx/modules-enabled/*.conf;  # 加载启用的模块配置 
+
+
+# events块：配置Nginx与客户端的网络连接 
+events { 
+    worker_connections 768;  # 每个工作进程的最大并发连接数 
+    # multi_accept on;  # 可选：允许工作进程同时接受多个连接（默认注释） 
+} 
+
+
+# http块：配置HTTP服务的全局参数（核心部分） 
+http { 
+    ## 
+    # 基础配置 
+    ## 
+    sendfile on;  # 启用高效文件传输模式 
+    tcp_nopush on;  # 配合sendfile使用，优化TCP传输 
+    tcp_nodelay on;  # 禁用Nagle算法，减少小数据包延迟 
+    keepalive_timeout 65;  # 长连接超时时间（秒） 
+    types_hash_max_size 2048;  # 类型哈希表的最大大小（优化MIME类型查找） 
+
+    include /etc/nginx/mime.types;  # 加载MIME类型映射文件 
+    default_type application/octet-stream;  # 默认MIME类型（未匹配时返回二进制流） 
+
+    ## 
+    # 日志配置 
+    ## 
+    access_log /var/log/nginx/access.log;  # 访问日志路径 
+    error_log /var/log/nginx/error.log;  # 错误日志路径 
+
+    ## 
+    # SSL/TLS配置（全局默认值） 
+    ## 
+    ssl_protocols TLSv1.2 TLSv1.3;  # 支持的SSL/TLS协议（禁用不安全的旧协议） 
+    ssl_prefer_server_ciphers on;  # 优先使用服务器端指定的加密套件 
+
+    ## 
+    # Gzip压缩配置 
+    ## 
+    gzip on;  # 启用Gzip压缩 
+    # gzip_vary on;  # 可选：在响应头添加Vary: Accept-Encoding（默认注释） 
+    # gzip_proxied any;  # 可选：对代理请求也启用压缩（默认注释） 
+    # gzip_comp_level 6;  # 可选：压缩级别（1-9，默认6）（默认注释） 
+    # gzip_buffers 16 8k;  # 可选：压缩缓冲区大小（默认注释） 
+    # gzip_http_version 1.1;  # 可选：支持的HTTP版本（默认注释） 
+    # gzip_types text/plain text/css application/json application/javascript text/xml application/xml application/xml+rss text/javascript;  # 可选：指定压缩的MIME类型（默认注释） 
+
+    ## 
+    # 加载站点配置（关键：默认站点配置不在nginx.conf里，而是通过include引入） 
+    ## 
+    include /etc/nginx/conf.d/*.conf;  # 加载conf.d目录下的自定义配置 
+    include /etc/nginx/sites-enabled/*;  # 加载启用的站点配置（默认站点在这里） 
+} 
+
+
+# 可选：加载流处理配置（如TCP/UDP代理，默认注释） 
+# include /etc/nginx/streams-enabled/*.conf;'''
+        self.main_config_editor.setPlainText(main_config_content)
+        
+        # 初始化站点配置文件内容
+        site_config_content = "server {\n"
+        site_config_content += "    listen 80;\n"
+        site_config_content += "    server_name 【IP地址】;\n\n"
+        site_config_content += "    # 转发动态请求到Gunicorn\n"
+        site_config_content += "    location / {\n"
+        site_config_content += "        proxy_pass http://【IP地址】:8000;\n"
+        site_config_content += "        proxy_set_header Host $host;\n"
+        site_config_content += "        proxy_set_header X-Real-IP $remote_addr;\n"
+        site_config_content += "    }\n"
+        site_config_content += "}\n"
+        self.site_config_editor.setPlainText(site_config_content)
+    
+    def update_config_content(self):
+        """更新配置文件内容"""
+        # 更新主配置文件内容
+        main_config_content = self.main_config_editor.toPlainText()
+        main_config_content = main_config_content.replace("xiaji", self.username)
+        self.main_config_editor.setPlainText(main_config_content)
+        
+        # 更新站点配置文件内容
+        site_config_content = self.site_config_editor.toPlainText()
+        site_config_content = site_config_content.replace("【IP地址】", self.server_ip)
+        self.site_config_editor.setPlainText(site_config_content)
+    
+    def set_ssh_client(self, ssh_client):
+        """设置SSH客户端"""
+        self.ssh_client = ssh_client
+        logger.info("Nginx标签页已设置SSH客户端")
+        
+    def set_username(self, username):
+        """设置用户名"""
+        self.username = username
+        logger.info(f"Nginx标签页已设置用户名: {username}")
+        
+    def set_project_info(self, project_name, server_ip):
+        """设置项目信息"""
+        self.project_name = project_name
+        self.server_ip = server_ip
+        logger.info(f"Nginx标签页已设置项目信息: {project_name}, {server_ip}")
+        
+        # 更新配置文件内容
+        self.update_config_content()
+    
+    def append_output(self, text):
+        """添加输出到文本框"""
+        self.output_text.append(text)
+    
+    def install_nginx(self):
+        """安装Nginx"""
+        if not self.ssh_client:
+            self.append_output("错误: 未连接到服务器")
+            return
+            
+        # 请求用户输入sudo密码
+        dialog = PasswordDialog(self)
+        if dialog.exec_() == QDialog.Accepted:
+            password = dialog.get_password()
+            self.append_output("正在安装Nginx...")
+            
+            # 创建并启动Nginx安装线程
+            self.install_thread = NginxInstallThread(self.ssh_client, password)
+            self.install_thread.result_ready.connect(self.on_install_result)
+            self.install_thread.start()
+        else:
+            self.append_output("用户取消了密码输入")
+    
+    def on_install_result(self, success, message):
+        """处理安装结果"""
+        if success:
+            self.append_output(f"安装成功: {message}")
+            logger.info(f"Nginx安装成功: {message}")
+            QMessageBox.information(self, "成功", message)
+        else:
+            self.append_output(f"安装失败: {message}")
+            logger.error(f"Nginx安装失败: {message}")
+            QMessageBox.warning(self, "错误", f"Nginx安装失败: {message}")
+    
+    def download_main_config(self):
+        """下载主配置文件"""
+        if not self.ssh_client:
+            self.append_output("错误: 未连接到服务器")
+            return
+            
+        # 请求用户输入sudo密码
+        dialog = PasswordDialog(self)
+        if dialog.exec_() == QDialog.Accepted:
+            password = dialog.get_password()
+            self.append_output("正在下载Nginx主配置文件...")
+            
+            # 创建并启动配置文件下载线程
+            self.config_thread = NginxConfigThread(self.ssh_client, "", "/etc/nginx/nginx.conf", password, "download")
+            self.config_thread.result_ready.connect(self.on_download_main_config_result)
+            self.config_thread.start()
+        else:
+            self.append_output("用户取消了密码输入")
+    
+    def on_download_main_config_result(self, success, message):
+        """处理下载主配置文件结果"""
+        if success:
+            self.main_config_editor.setPlainText(message)
+            self.append_output("主配置文件下载成功")
+            logger.info("Nginx主配置文件下载成功")
+        else:
+            self.append_output(f"主配置文件下载失败: {message}")
+            logger.error(f"Nginx主配置文件下载失败: {message}")
+    
+    def upload_main_config(self):
+        """上传主配置文件"""
+        if not self.ssh_client:
+            self.append_output("错误: 未连接到服务器")
+            return
+            
+        config_content = self.main_config_editor.toPlainText()
+        
+        # 请求用户输入sudo密码
+        dialog = PasswordDialog(self)
+        if dialog.exec_() == QDialog.Accepted:
+            password = dialog.get_password()
+            self.append_output("正在上传Nginx主配置文件...")
+            
+            # 创建并启动配置文件上传线程
+            self.config_thread = NginxConfigThread(self.ssh_client, config_content, "/etc/nginx/nginx.conf", password, "upload")
+            self.config_thread.result_ready.connect(self.on_upload_main_config_result)
+            self.config_thread.start()
+        else:
+            self.append_output("用户取消了密码输入")
+    
+    def on_upload_main_config_result(self, success, message):
+        """处理上传主配置文件结果"""
+        if success:
+            self.append_output(f"上传成功: {message}")
+            logger.info(f"Nginx主配置文件上传成功: {message}")
+            QMessageBox.information(self, "成功", message)
+            
+            # 上传主配置文件后检查配置文件语法
+            self.append_output("正在检查Nginx配置文件语法...")
+            
+            # 请求用户输入sudo密码
+            dialog = PasswordDialog(self)
+            if dialog.exec_() == QDialog.Accepted:
+                password = dialog.get_password()
+                
+                # 创建并启动Nginx配置检查线程
+                self.check_thread = NginxControlThread(self.ssh_client, password, "configtest")
+                self.check_thread.result_ready.connect(self.on_upload_configtest_result)
+                self.check_thread.start()
+            else:
+                self.append_output("用户取消了密码输入")
+        else:
+            self.append_output(f"上传失败: {message}")
+            logger.error(f"Nginx主配置文件上传失败: {message}")
+            QMessageBox.warning(self, "错误", f"Nginx主配置文件上传失败: {message}")
+    
+    def on_upload_configtest_result(self, success, message):
+        """处理上传主配置文件后的配置测试结果"""
+        if success:
+            self.append_output("配置文件语法检查通过")
+            logger.info("Nginx主配置文件上传后语法检查通过")
+        else:
+            self.append_output(f"配置文件语法检查失败: {message}")
+            logger.error(f"Nginx主配置文件上传后语法检查失败: {message}")
+            QMessageBox.warning(self, "错误", f"Nginx配置文件语法检查失败: {message}")
+    
+    def create_site_config(self):
+        """创建站点配置"""
+        if not self.ssh_client:
+            self.append_output("错误: 未连接到服务器")
+            return
+            
+        if not self.project_name:
+            self.append_output("错误: 未设置项目名")
+            return
+            
+        site_config = self.site_config_editor.toPlainText()
+        
+        # 请求用户输入sudo密码
+        dialog = PasswordDialog(self)
+        if dialog.exec_() == QDialog.Accepted:
+            password = dialog.get_password()
+            self.append_output(f"正在创建站点配置文件: {self.project_name}...")
+            
+            # 创建并启动站点配置创建线程
+            self.site_thread = NginxSiteThread(self.ssh_client, site_config, self.project_name, password, "create")
+            self.site_thread.result_ready.connect(self.on_create_site_config_result)
+            self.site_thread.start()
+        else:
+            self.append_output("用户取消了密码输入")
+    
+    def on_create_site_config_result(self, success, message):
+        """处理创建站点配置结果"""
+        if success:
+            self.append_output(f"创建成功: {message}")
+            logger.info(f"Nginx站点配置创建成功: {message}")
+            QMessageBox.information(self, "成功", message)
+            
+            # 创建站点配置文件后检查配置文件语法
+            self.append_output("正在检查Nginx配置文件语法...")
+            
+            # 请求用户输入sudo密码
+            dialog = PasswordDialog(self)
+            if dialog.exec_() == QDialog.Accepted:
+                password = dialog.get_password()
+                
+                # 创建并启动Nginx配置检查线程
+                self.check_thread = NginxControlThread(self.ssh_client, password, "configtest")
+                self.check_thread.result_ready.connect(self.on_create_configtest_result)
+                self.check_thread.start()
+            else:
+                self.append_output("用户取消了密码输入")
+        else:
+            self.append_output(f"创建失败: {message}")
+            logger.error(f"Nginx站点配置创建失败: {message}")
+            QMessageBox.warning(self, "错误", f"Nginx站点配置创建失败: {message}")
+    
+    def on_create_configtest_result(self, success, message):
+        """处理创建站点配置文件后的配置测试结果"""
+        if success:
+            self.append_output("配置文件语法检查通过")
+            logger.info("Nginx站点配置文件创建后语法检查通过")
+        else:
+            self.append_output(f"配置文件语法检查失败: {message}")
+            logger.error(f"Nginx站点配置文件创建后语法检查失败: {message}")
+            QMessageBox.warning(self, "错误", f"Nginx配置文件语法检查失败: {message}")
+    
+    def enable_site_config(self):
+        """启用站点配置"""
+        if not self.ssh_client:
+            self.append_output("错误: 未连接到服务器")
+            return
+            
+        if not self.project_name:
+            self.append_output("错误: 未设置项目名")
+            return
+            
+        # 请求用户输入sudo密码
+        dialog = PasswordDialog(self)
+        if dialog.exec_() == QDialog.Accepted:
+            password = dialog.get_password()
+            self.append_output(f"正在启用站点配置: {self.project_name}...")
+            
+            # 创建并启动站点配置启用线程
+            self.site_thread = NginxSiteThread(self.ssh_client, "", self.project_name, password, "enable")
+            self.site_thread.result_ready.connect(self.on_enable_site_config_result)
+            self.site_thread.start()
+        else:
+            self.append_output("用户取消了密码输入")
+    
+    def on_enable_site_config_result(self, success, message):
+        """处理启用站点配置结果"""
+        if success:
+            self.append_output(f"启用成功: {message}")
+            logger.info(f"Nginx站点配置启用成功: {message}")
+            QMessageBox.information(self, "成功", message)
+            
+            # 启用站点后检查配置文件语法
+            self.append_output("正在检查Nginx配置文件语法...")
+            
+            # 请求用户输入sudo密码
+            dialog = PasswordDialog(self)
+            if dialog.exec_() == QDialog.Accepted:
+                password = dialog.get_password()
+                
+                # 创建并启动Nginx配置检查线程
+                self.check_thread = NginxControlThread(self.ssh_client, password, "configtest")
+                self.check_thread.result_ready.connect(self.on_enable_configtest_result)
+                self.check_thread.start()
+            else:
+                self.append_output("用户取消了密码输入")
+        else:
+            self.append_output(f"启用失败: {message}")
+            logger.error(f"Nginx站点配置启用失败: {message}")
+            QMessageBox.warning(self, "错误", f"Nginx站点配置启用失败: {message}")
+    
+    def on_enable_configtest_result(self, success, message):
+        """处理启用站点后的配置测试结果"""
+        if success:
+            self.append_output("配置文件语法检查通过")
+            logger.info("Nginx站点配置启用后语法检查通过")
+        else:
+            self.append_output(f"配置文件语法检查失败: {message}")
+            logger.error(f"Nginx站点配置启用后语法检查失败: {message}")
+            QMessageBox.warning(self, "错误", f"Nginx配置文件语法检查失败: {message}")
+    
+    def restart_nginx(self):
+        """重启Nginx"""
+        if not self.ssh_client:
+            self.append_output("错误: 未连接到服务器")
+            return
+            
+        # 请求用户输入sudo密码
+        dialog = PasswordDialog(self)
+        if dialog.exec_() == QDialog.Accepted:
+            password = dialog.get_password()
+            self.append_output("正在检查Nginx配置文件语法...")
+            
+            # 创建并启动Nginx配置检查线程
+            self.check_thread = NginxControlThread(self.ssh_client, password, "configtest")
+            self.check_thread.result_ready.connect(self.on_configtest_result)
+            self.check_thread.start()
+        else:
+            self.append_output("用户取消了密码输入")
+    
+    def on_configtest_result(self, success, message):
+        """处理配置测试结果"""
+        if success:
+            self.append_output("配置文件语法检查通过，正在重启Nginx...")
+            
+            # 请求用户输入sudo密码
+            dialog = PasswordDialog(self)
+            if dialog.exec_() == QDialog.Accepted:
+                password = dialog.get_password()
+                
+                # 创建并启动Nginx控制线程
+                self.control_thread = NginxControlThread(self.ssh_client, password, "restart")
+                self.control_thread.result_ready.connect(self.on_control_result)
+                self.control_thread.start()
+            else:
+                self.append_output("用户取消了密码输入")
+        else:
+            self.append_output(f"配置文件语法检查失败: {message}")
+            logger.error(f"Nginx配置文件语法检查失败: {message}")
+            QMessageBox.warning(self, "错误", f"Nginx配置文件语法检查失败: {message}")
+    
+    def check_nginx_status(self):
+        """查看Nginx状态"""
+        if not self.ssh_client:
+            self.append_output("错误: 未连接到服务器")
+            return
+            
+        # 请求用户输入sudo密码
+        dialog = PasswordDialog(self)
+        if dialog.exec_() == QDialog.Accepted:
+            password = dialog.get_password()
+            self.append_output("正在查看Nginx状态...")
+            
+            # 创建并启动Nginx控制线程
+            self.control_thread = NginxControlThread(self.ssh_client, password, "status")
+            self.control_thread.result_ready.connect(self.on_control_result)
+            self.control_thread.start()
+        else:
+            self.append_output("用户取消了密码输入")
+    
+    def on_control_result(self, success, message):
+        """处理控制结果"""
+        if success:
+            self.append_output(f"操作成功: {message}")
+            logger.info(f"Nginx服务控制成功: {message}")
+            QMessageBox.information(self, "成功", message)
+        else:
+            self.append_output(f"操作失败: {message}")
+            logger.error(f"Nginx服务控制失败: {message}")
+            QMessageBox.warning(self, "错误", f"Nginx服务控制失败: {message}")