refactor(phase-3-2): split UI large files (theme_optimizer + home_page)

src/scenefab/ui/main/components/_monitor_widget.py

@@ -0,0 +1,235 @@
+#!/usr/bin/env python3
+
+"""
+导出进度监控组件
+提供实时导出进度监控和状态显示
+"""
+
+import time
+from typing import Optional
+
+from PySide6.QtCore import Qt, QTimer, Signal
+from PySide6.QtGui import QFont
+from PySide6.QtWidgets import (
+    QDialog,
+    QGroupBox,
+    QHBoxLayout,
+    QLabel,
+    QMessageBox,
+    QProgressBar,
+    QPushButton,
+    QScrollArea,
+    QSplitter,
+    QVBoxLayout,
+    QWidget,
+)
+
+from scenefab.logger import Logger
+from scenefab.ui.main.components._progress_widget import ExportProgressWidget
+
+from ...components.design_system import Colors
+from ...export.export_system import ExportStatus, ExportTask
+from ...main.components.export_stats import ExportStatisticsWidget
+from ...main.components.monitor_widgets import PerformanceChart
+
+
+class ExportMonitorWidget(QWidget):
+    """导出监控主部件"""
+
+    def __init__(self, export_system, parent=None):
+        super().__init__(parent)
+        self.export_system = export_system
+        self.logger = Logger.get_logger(__name__)
+        self.tasks: list[ExportTask] = []
+        self.active_task_widgets: dict[str, ExportProgressWidget] = {}
+        self.setup_ui()
+        self.setup_timer()
+
+    def setup_ui(self):
+        """设置UI"""
+        layout = QVBoxLayout(self)
+        layout.setContentsMargins(0, 0, 0, 0)
+
+        # 统计信息
+        self.statistics_widget = ExportStatisticsWidget()
+        layout.addWidget(self.statistics_widget)
+
+        # 分割器
+        splitter = QSplitter(Qt.Orientation.Vertical)
+
+        # 活动任务区域
+        active_group = QGroupBox("活动任务")
+        active_layout = QVBoxLayout(active_group)
+
+        self.active_tasks_scroll = QScrollArea()
+        self.active_tasks_scroll.setWidgetResizable(True)
+        self.active_tasks_widget = QWidget()
+        self.active_tasks_layout = QVBoxLayout(self.active_tasks_widget)
+        self.active_tasks_layout.setContentsMargins(0, 0, 0, 0)
+        self.active_tasks_layout.addStretch()
+
+        self.active_tasks_scroll.setWidget(self.active_tasks_widget)
+        active_layout.addWidget(self.active_tasks_scroll)
+
+        # 速度图表
+        speed_group = QGroupBox("导出速度")
+        speed_layout = QVBoxLayout(speed_group)
+
+        self.speed_chart = PerformanceChart("导出速度", max_value=50)
+        self.speed_chart.setMinimumHeight(150)
+        speed_layout.addWidget(self.speed_chart)
+
+        # 添加到分割器
+        splitter.addWidget(active_group)
+        splitter.addWidget(speed_group)
+
+        # 设置分割器比例
+        splitter.setSizes([400, 150])
+
+        layout.addWidget(splitter)
+
+    def setup_timer(self):
+        """设置定时器"""
+        self.update_timer = QTimer()
+        self.update_timer.timeout.connect(self.update_display)
+        self.update_timer.start(1000)  # 每秒更新一次
+
+    def update_display(self):
+        """更新显示"""
+        try:
+            # 获取任务列表
+            tasks = self.export_system.get_task_history()
+
+            # 过滤出活动任务（处理中、排队中、待处理）
+            active_tasks = [t for t in tasks if t.status.value in ["processing", "queued", "pending"]]
+
+            # 更新统计信息
+            self.statistics_widget.update_statistics(tasks)
+
+            # 更新活动任务显示
+            self.update_active_tasks(active_tasks)
+
+            # 更新速度图表
+            self.update_speed_chart(active_tasks)
+
+        except Exception as e:
+            self.logger.error(f"Failed to update monitor display: {e}")
+
+    def update_active_tasks(self, tasks: list[ExportTask]):
+        """更新活动任务显示"""
+        # 创建任务ID到任务的映射
+        current_task_ids = {task.id for task in tasks}
+        existing_task_ids = set(self.active_task_widgets.keys())
+
+        # 移除已完成的任务部件
+        for task_id in existing_task_ids - current_task_ids:
+            widget = self.active_task_widgets.pop(task_id, None)
+            if widget:
+                self.active_tasks_layout.removeWidget(widget)
+                widget.deleteLater()
+
+        # 添加新任务部件
+        for task in tasks:
+            if task.id not in self.active_task_widgets:
+                widget = ExportProgressWidget(task)
+                widget.task_clicked.connect(self.on_task_clicked)
+                self.active_task_widgets[task.id] = widget
+
+                # 插入到布局中（在拉伸之前）
+                self.active_tasks_layout.insertWidget(
+                    self.active_tasks_layout.count() - 1, widget
+                )
+            else:
+                # 更新现有部件
+                widget = self.active_task_widgets[task.id]
+                widget.task = task
+                widget.update_display()
+
+    def update_speed_chart(self, tasks: list[ExportTask]):
+        """更新速度图表"""
+        # 计算总体导出速度
+        total_speed = 0
+        active_count = 0
+
+        for task in tasks:
+            if task.status == ExportStatus.PROCESSING and task.started_at:
+                elapsed_time = time.time() - task.started_at
+                if elapsed_time > 0 and task.progress > 0:
+                    # 简化的速度计算（假设平均文件大小）
+                    estimated_size = 100  # MB (假设值)
+                    processed_size = estimated_size * (task.progress / 100)
+                    speed = processed_size / elapsed_time  # MB/s
+                    total_speed += speed
+                    active_count += 1
+
+        # 添加到速度历史
+        self.speed_chart.add_data_point(total_speed)
+
+    def on_task_clicked(self, task_id: str):
+        """任务点击事件"""
+        # 查找任务详情
+        task = None
+        for t in self.tasks:
+            if t.id == task_id:
+                task = t
+                break
+
+        if task:
+            self.show_task_details(task)
+
+    def show_task_details(self, task: ExportTask):
+        """显示任务详情"""
+        # 这里可以实现任务详情对话框
+        self.logger.info(f"Show task details: {task.id}")
+
+    def cleanup(self):
+        """清理资源"""
+        try:
+            self.update_timer.stop()
+        except RuntimeError as e:
+            self.logger.debug(f"Timer already stopped: {e}")
+        except Exception as e:
+            self.logger.warning(f"Cleanup failed: {e}")
+
+    def update_theme(self, is_dark: bool = True):
+        """更新主题"""
+        if is_dark:
+            self.setStyleSheet(f"""
+                QGroupBox {{
+                    border: 1px solid {Colors.BorderDefault};
+                    border-radius: 4px;
+                    margin-top: 8px;
+                    padding-top: 8px;
+                    color: {Colors.TextPrimary};
+                }}
+                QProgressBar {{
+                    border: 1px solid {Colors.BorderDefault};
+                    border-radius: 4px;
+                    text-align: center;
+                    background-color: {Colors.BgElevated};
+                }}
+                QProgressBar::chunk {{
+                    background-color: {Colors.Primary};
+                }}
+            """)
+        else:
+            self.setStyleSheet(f"""
+                QGroupBox {{
+                    border: 1px solid {Colors.BorderDefault};
+                    border-radius: 4px;
+                    margin-top: 8px;
+                    padding-top: 8px;
+                    color: {Colors.TextPrimary};
+                }}
+                QProgressBar {{
+                    border: 1px solid {Colors.BorderDefault};
+                    border-radius: 4px;
+                    text-align: center;
+                    background-color: {Colors.BgSurface};
+                }}
+                QProgressBar::chunk {{
+                    background-color: {Colors.Primary};
+                }}
+            """)
+
+

src/scenefab/ui/main/components/_progress_dialog.py

@@ -0,0 +1,163 @@
+#!/usr/bin/env python3
+
+"""
+导出进度监控组件
+提供实时导出进度监控和状态显示
+"""
+
+import time
+from typing import Optional
+
+from PySide6.QtCore import Qt, QTimer, Signal
+from PySide6.QtGui import QFont
+from PySide6.QtWidgets import (
+    QDialog,
+    QGroupBox,
+    QHBoxLayout,
+    QLabel,
+    QMessageBox,
+    QProgressBar,
+    QPushButton,
+    QScrollArea,
+    QSplitter,
+    QVBoxLayout,
+    QWidget,
+)
+
+from scenefab.logger import Logger
+from scenefab.ui.main.components._monitor_widget import ExportMonitorWidget
+
+from ...components.design_system import Colors
+from ...export.export_system import ExportStatus, ExportTask
+from ...main.components.export_stats import ExportStatisticsWidget
+from ...main.components.monitor_widgets import PerformanceChart
+
+
+class ExportProgressDialog(QDialog):
+    """导出进度对话框"""
+
+    def __init__(self, export_system, parent=None):
+        super().__init__(parent)
+        self.export_system = export_system
+        self.logger = Logger.get_logger(__name__)
+        self.setup_ui()
+        self.setup_signals()
+
+    def setup_ui(self):
+        """设置UI"""
+        self.setWindowTitle("导出进度")
+        self.setMinimumSize(600, 400)
+        self.setModal(False)
+
+        layout = QVBoxLayout(self)
+
+        # 监控部件
+        self.monitor_widget = ExportMonitorWidget(self.export_system)
+        layout.addWidget(self.monitor_widget)
+
+        # 操作按钮
+        button_layout = QHBoxLayout()
+
+        self.hide_btn = QPushButton("隐藏")
+        self.hide_btn.clicked.connect(self.hide)
+
+        self.cancel_all_btn = QPushButton("取消全部")
+        self.cancel_all_btn.clicked.connect(self.cancel_all_tasks)
+
+        button_layout.addStretch()
+        button_layout.addWidget(self.hide_btn)
+        button_layout.addWidget(self.cancel_all_btn)
+
+        layout.addLayout(button_layout)
+
+    def setup_signals(self):
+        """设置信号连接"""
+        # 连接导出系统信号
+        self.export_system.export_started.connect(self.on_export_started)
+        self.export_system.export_progress.connect(self.on_export_progress)
+        self.export_system.export_completed.connect(self.on_export_completed)
+        self.export_system.export_failed.connect(self.on_export_failed)
+
+    def on_export_started(self, task_id: str):
+        """导出开始事件"""
+        self.show()
+        self.raise_()
+        self.activateWindow()
+
+    def on_export_progress(self, task_id: str, progress: float):
+        """导出进度事件"""
+        # 更新进度条
+        if hasattr(self, 'progress_bar'):
+            self.progress_bar.setValue(int(progress * 100))
+        if hasattr(self, 'progress_label'):
+            self.progress_label.setText(f"{int(progress * 100)}%")
+
+    def on_export_completed(self, task_id: str, output_path: str):
+        """导出完成事件"""
+        # 检查是否所有任务都已完成
+        try:
+            tasks = self.export_system.get_task_history()
+            active_tasks = [t for t in tasks if t.status.value in ["processing", "queued", "pending"]]
+
+            if not active_tasks:
+                # 所有任务完成，显示完成通知
+                self.show_completion_notification()
+        except Exception as e:
+            self.logger.error(f"Failed to check completion status: {e}")
+
+    def on_export_failed(self, task_id: str, error_message: str):
+        """导出失败事件"""
+        # 显示错误通知
+        from PySide6.QtWidgets import QMessageBox
+        QMessageBox.critical(
+            self,
+            "导出失败",
+            f"任务 {task_id} 导出失败：\n{error_message}"
+        )
+        # 更新状态显示
+        if hasattr(self, 'status_label'):
+            self.status_label.setText("导出失败")
+        if hasattr(self, 'progress_bar'):
+            self.progress_bar.setValue(0)
+
+    def cancel_all_tasks(self):
+        """取消所有任务"""
+        reply = self.logger.question(
+            "确认取消", "确定要取消所有导出任务吗？",
+            QMessageBox.StandardButton.Yes | QMessageBox.StandardButton.No
+        )
+
+        if reply == QMessageBox.StandardButton.Yes:
+            try:
+                tasks = self.export_system.get_task_history()
+                cancelled_count = 0
+
+                for task in tasks:
+                    if task.status.value in ["processing", "queued", "pending"]:
+                        if self.export_system.cancel_export(task.id):
+                            cancelled_count += 1
+
+                QMessageBox.information(self, "成功", f"已取消 {cancelled_count} 个任务")
+
+            except Exception as e:
+                QMessageBox.critical(self, "错误", f"取消任务失败: {str(e)}")
+
+    def show_completion_notification(self):
+        """显示完成通知"""
+        try:
+            tasks = self.export_system.get_task_history()
+            completed_count = len([t for t in tasks if t.status.value == "completed"])
+            failed_count = len([t for t in tasks if t.status.value == "failed"])
+
+            message = f"导出完成！\\n成功: {completed_count} 个任务"
+            if failed_count > 0:
+                message += f"\\n失败: {failed_count} 个任务"
+
+            QMessageBox.information(self, "导出完成", message)
+
+        except Exception as e:
+            self.logger.error(f"Failed to show completion notification: {e}")
+
+    def cleanup(self):
+        """清理资源"""
+        self.monitor_widget.cleanup()