Method run

gui_qt6/workers.py:273–330

执行增强清理任务

(self)

        self.ide_name = get_ide_display_name(ide_type)

    def run(self):
        """执行增强清理任务"""
        import asyncio
        try:
            self.emit_progress(f"开始增强清理 {self.ide_name} (模式: {self.mode})")
            self.emit_status(f"正在执行增强清理...", "info")

            # 导入清理功能
            from augment_tools_core.database_manager import clean_ide_comprehensive

            # 执行异步清理
            async def run_cleanup():
                return await clean_ide_comprehensive(
                    ide_type=self.ide_type,
                    mode=self.mode,
                    keyword=self.keyword,
                    force_delete=self.force_delete,
                    kill_processes=self.kill_processes
                )

            # 在新的事件循环中运行
            try:
                loop = asyncio.get_event_loop()
            except RuntimeError:
                loop = asyncio.new_event_loop()
                asyncio.set_event_loop(loop)

            result = loop.run_until_complete(run_cleanup())

            if self.is_cancelled:
                return

            if result["success"]:
                # 显示详细结果
                self.emit_progress("清理结果:")
                if result.get("database_cleaned"):
                    self.emit_progress(f"  数据库清理: 删除 {result.get('database_entries_removed', 0)} 个条目")
                if result.get("files_deleted", 0) > 0:
                    self.emit_progress(f"  文件删除: {result['files_deleted']} 个文件")
                    self.emit_progress(f"    - globalStorage: {result.get('global_storage_files', 0)} 个")
                    self.emit_progress(f"    - workspaceStorage: {result.get('workspace_storage_files', 0)} 个")
                if result.get("processes_killed", 0) > 0:
                    self.emit_progress(f"  进程终止: {result['processes_killed']} 个进程")

                self.emit_progress("增强清理完成。")
                self.emit_status("增强清理完成", "success")
                self.task_completed.emit(True)
            else:
                error_messages = result.get("errors", ["未知错误"])
                for error in error_messages:
                    self.emit_progress(f"错误: {error}")
                self.emit_status("增强清理失败", "error")
                self.task_completed.emit(False)

        except Exception as e:
            self.emit_progress(f"增强清理时发生错误: {str(e)}")
            self.emit_status(f"清理失败: {str(e)}", "error")
            self.task_completed.emit(False)