feat：启停插件自动备份与恢复

app/startup/lifecycle.py

@@ -9,7 +9,7 @@ from app.startup.command_initializer import init_command, stop_command, restart_
 from app.startup.memory_initializer import init_memory_manager, stop_memory_manager
 from app.startup.modules_initializer import init_modules, stop_modules
 from app.startup.monitor_initializer import stop_monitor, init_monitor
-from app.startup.plugins_initializer import init_plugins, stop_plugins, sync_plugins
+from app.startup.plugins_initializer import init_plugins, stop_plugins, sync_plugins, backup_plugins, restore_plugins
 from app.startup.routers_initializer import init_routers
 from app.startup.scheduler_initializer import stop_scheduler, init_scheduler, init_plugin_scheduler
 from app.startup.workflow_initializer import init_workflow, stop_workflow
@@ -38,6 +38,8 @@ async def lifespan(app: FastAPI):
     init_modules()
     # 初始化路由
     init_routers(app)
+    # 恢复插件备份
+    restore_plugins()
     # 初始化插件
     init_plugins()
     # 初始化定时器
@@ -67,6 +69,8 @@ async def lifespan(app: FastAPI):
             pass
         except Exception as e:
             print(str(e))
+        # 备份插件
+        backup_plugins()
         # 停止内存管理器
         stop_memory_manager()
         # 停止工作流

app/startup/plugins_initializer.py

@@ -1,5 +1,7 @@
 import asyncio
+import shutil
 
+from app.core.config import settings
 from app.core.plugin import PluginManager
 from app.log import logger
 
@@ -75,3 +77,93 @@ def stop_plugins():
         plugin_manager.stop_monitor()
     except Exception as e:
         logger.error(f"停止插件时发生错误：{e}", exc_info=True)
+
+
+def backup_plugins():
+    """
+    备份插件到用户配置目录
+    """
+    try:
+        # 使用绝对路径确保准确性
+        plugins_dir = settings.ROOT_PATH / "app" / "plugins"
+        backup_dir = settings.CONFIG_PATH / "plugins_backup"
+        
+        if not plugins_dir.exists():
+            logger.info("插件目录不存在，跳过备份")
+            return
+            
+        # 确保备份目录存在
+        backup_dir.mkdir(parents=True, exist_ok=True)
+        
+        # 需要排除的文件和目录
+        exclude_items = {"__init__.py", "__pycache__", ".DS_Store"}
+        
+        # 遍历插件目录，备份除排除项外的所有内容
+        for item in plugins_dir.iterdir():
+            if item.name in exclude_items:
+                continue
+                
+            target_path = backup_dir / item.name
+            
+            # 如果是目录
+            if item.is_dir():
+                if target_path.exists():
+                    shutil.rmtree(target_path)
+                shutil.copytree(item, target_path)
+                logger.info(f"已备份插件目录: {item.name}")
+            # 如果是文件
+            elif item.is_file():
+                shutil.copy2(item, target_path)
+                logger.info(f"已备份插件文件: {item.name}")
+                
+        logger.info(f"插件备份完成，备份位置: {backup_dir}")
+        
+    except Exception as e:
+        logger.error(f"插件备份失败: {str(e)}")
+
+
+def restore_plugins():
+    """
+    从备份恢复插件到app/plugins目录，恢复完成后删除备份
+    """
+    try:
+        # 使用绝对路径确保准确性
+        plugins_dir = settings.ROOT_PATH / "app" / "plugins"
+        backup_dir = settings.CONFIG_PATH / "plugins_backup"
+        
+        if not backup_dir.exists():
+            logger.info("插件备份目录不存在，跳过恢复")
+            return
+            
+        # 确保插件目录存在
+        plugins_dir.mkdir(parents=True, exist_ok=True)
+        
+        # 遍历备份目录，恢复所有内容
+        restored_count = 0
+        for item in backup_dir.iterdir():
+            target_path = plugins_dir / item.name
+            
+            # 如果是目录
+            if item.is_dir():
+                if target_path.exists():
+                    shutil.rmtree(target_path)
+                shutil.copytree(item, target_path)
+                logger.info(f"已恢复插件目录: {item.name}")
+                restored_count += 1
+            # 如果是文件
+            elif item.is_file():
+                shutil.copy2(item, target_path)
+                logger.info(f"已恢复插件文件: {item.name}")
+                restored_count += 1
+                
+        logger.info(f"插件恢复完成，共恢复 {restored_count} 个项目")
+        
+        # 恢复完成后删除备份目录
+        try:
+            shutil.rmtree(backup_dir)
+            logger.info(f"已删除插件备份目录: {backup_dir}")
+        except Exception as e:
+            logger.warning(f"删除备份目录失败: {str(e)}")
+        
+    except Exception as e:
+        logger.error(f"插件恢复失败: {str(e)}")