feat: 实现WebSocket定时刷新与任务创建通知机制

- 新增 WebSocket 连接管理器 (websocket_manager.py)
- 后端定时广播刷新通知给前端
- 新任务创建时自动触发前端刷新
- 刷新间隔配置存储在后端 (system_config.json)
- 新增配置 API (/api/config/refresh-interval)
- 前端从后端加载和保存刷新间隔配置
- 刷新间隔范围调整为 1-60 分钟

Author: lanshuizhiyue

src/backEnd/.gitignore

@@ -225,3 +225,4 @@ gunicorn.pid
 # 会话文件
 sessions/
 *.session
+data/

src/backEnd/api/commonApi/configController.py

@@ -1,7 +1,9 @@
 # 系统配置管理控制器
 import os
+import json
 import logging
 from typing import Optional
+from pathlib import Path
 
 from fastapi import APIRouter, Depends, status
 from pydantic import BaseModel
@@ -13,11 +15,68 @@
     get_default_http_request_temp_dir
 )
 from utils.auth import get_current_user
+from utils.websocket_manager import ws_manager
 
 logger = logging.getLogger(__name__)
 
 router = APIRouter(prefix="/config")
 
+# 配置文件路径
+CONFIG_FILE = Path(__file__).parent.parent.parent / "data" / "system_config.json"
+
+# 默认配置
+DEFAULT_CONFIG = {
+    "refreshInterval": 5  # 默认5分钟
+}
+
+
+def _ensure_config_dir():
+    """确保配置目录存在"""
+    CONFIG_FILE.parent.mkdir(parents=True, exist_ok=True)
+
+
+def _load_system_config() -> dict:
+    """加载系统配置"""
+    try:
+        if CONFIG_FILE.exists():
+            with open(CONFIG_FILE, 'r', encoding='utf-8') as f:
+                config = json.load(f)
+                # 合并默认配置
+                return {**DEFAULT_CONFIG, **config}
+    except Exception as e:
+        logger.error(f"加载系统配置失败: {e}")
+    return DEFAULT_CONFIG.copy()
+
+
+def _save_system_config(config: dict):
+    """保存系统配置"""
+    try:
+        _ensure_config_dir()
+        with open(CONFIG_FILE, 'w', encoding='utf-8') as f:
+            json.dump(config, f, ensure_ascii=False, indent=2)
+        logger.info(f"系统配置已保存: {config}")
+    except Exception as e:
+        logger.error(f"保存系统配置失败: {e}")
+        raise
+
+
+def get_refresh_interval() -> int:
+    """获取刷新间隔（分钟）"""
+    config = _load_system_config()
+    return config.get("refreshInterval", DEFAULT_CONFIG["refreshInterval"])
+
+
+def set_refresh_interval(interval: int):
+    """设置刷新间隔（分钟）"""
+    # 限制范围 1-60 分钟
+    interval = max(1, min(60, interval))
+    config = _load_system_config()
+    config["refreshInterval"] = interval
+    _save_system_config(config)
+    # 更新 WebSocket 管理器的刷新间隔
+    ws_manager.update_refresh_interval(interval)
+    return interval
+
 
 class TempDirConfigRequest(BaseModel):
     """临时文件目录配置请求"""
@@ -170,3 +229,70 @@ async def reset_temp_dir_config(current_user: dict = Depends(get_current_user)):
             success=False,
             code=status.HTTP_500_INTERNAL_SERVER_ERROR
         )
+
+
+class RefreshIntervalRequest(BaseModel):
+    """刷新间隔配置请求"""
+    interval: int  # 刷新间隔（分钟）
+
+
+@router.get('/refresh-interval')
+async def get_refresh_interval_config(current_user: dict = Depends(get_current_user)):
+    """
+    获取数据刷新间隔配置
+    """
+    try:
+        interval = get_refresh_interval()
+        
+        return BaseResponseMsg(
+            data={
+                "refreshInterval": interval,
+                "minInterval": 1,
+                "maxInterval": 60
+            },
+            msg="success",
+            success=True,
+            code=status.HTTP_200_OK
+        )
+    except Exception as e:
+        logger.error(f"获取刷新间隔配置失败: {e}")
+        return BaseResponseMsg(
+            data=None,
+            msg=f"Failed to get refresh interval: {str(e)}",
+            success=False,
+            code=status.HTTP_500_INTERNAL_SERVER_ERROR
+        )
+
+
+@router.post('/refresh-interval')
+async def set_refresh_interval_config(
+    request: RefreshIntervalRequest,
+    current_user: dict = Depends(get_current_user)
+):
+    """
+    设置数据刷新间隔
+    - interval: 刷新间隔（分钟），范围 1-60
+    """
+    try:
+        new_interval = set_refresh_interval(request.interval)
+        
+        logger.info(f"刷新间隔已设置为 {new_interval} 分钟")
+        
+        return BaseResponseMsg(
+            data={
+                "refreshInterval": new_interval,
+                "minInterval": 1,
+                "maxInterval": 60
+            },
+            msg=f"刷新间隔已设置为 {new_interval} 分钟",
+            success=True,
+            code=status.HTTP_200_OK
+        )
+    except Exception as e:
+        logger.error(f"设置刷新间隔失败: {e}")
+        return BaseResponseMsg(
+            data=None,
+            msg=f"Failed to set refresh interval: {str(e)}",
+            success=False,
+            code=status.HTTP_500_INTERNAL_SERVER_ERROR
+        )

src/backEnd/api/commonApi/webTaskController.py

@@ -10,6 +10,7 @@
 from model.requestModel.TaskRequest import TaskAddRequest
 from service.taskService import taskService
 from utils.auth import get_current_user
+from utils.websocket_manager import ws_manager
 
 logger = logging.getLogger(__name__)
 
@@ -73,6 +74,9 @@ async def add_task_from_web(
 
             if res.success:
                 logger.info(f"[Web] Task created successfully: {res.data}")
+                # 通知前端刷新数据
+                task_id = res.data.get('taskid') if isinstance(res.data, dict) else None
+                await ws_manager.notify_task_created(task_id)
             else:
                 logger.warning(f"[Web] Task creation failed: {res.msg}")
 

src/backEnd/app.py

@@ -1,8 +1,10 @@
 import logging
 import time
 import os
+import asyncio
 from typing import Union
-from fastapi import FastAPI
+from contextlib import asynccontextmanager
+from fastapi import FastAPI, WebSocket, WebSocketDisconnect
 from fastapi.responses import RedirectResponse
 from fastapi.staticfiles import StaticFiles
 from fastapi.responses import FileResponse
@@ -16,9 +18,27 @@
 from api.commonApi.scanPreset import router as scan_preset_router
 from api.commonApi.webTaskController import router as web_task_router
 from config import VERSION
+from utils.websocket_manager import ws_manager
+from api.commonApi.configController import get_refresh_interval
 
 logger = logging.getLogger(__name__)
-app = FastAPI()
+
+# 生命周期管理
+@asynccontextmanager
+async def lifespan(app: FastAPI):
+    """FastAPI 生命周期管理"""
+    # 启动时，从配置加载刷新间隔
+    initial_interval = get_refresh_interval()
+    print(f"[WebSocket] 启动 WebSocket 管理器，刷新间隔: {initial_interval} 分钟")
+    ws_manager.start(initial_interval)
+    logger.info(f"WebSocket 管理器已启动，刷新间隔: {initial_interval} 分钟")
+    yield
+    # 关闭时
+    await ws_manager.stop()
+    print("[WebSocket] WebSocket 管理器已停止")
+    logger.info("WebSocket 管理器已停止")
+
+app = FastAPI(lifespan=lifespan)
 
 # 记录服务启动时间
 START_TIME = time.time()
@@ -81,6 +101,52 @@ def health_check():
         }
     }
 
+# WebSocket 端点
+@app.websocket("/ws")
+async def websocket_endpoint(websocket: WebSocket):
+    """
+    WebSocket 连接端点
+    
+    用于实时通信，后端定时推送刷新通知给前端
+    """
+    await ws_manager.connect(websocket)
+    try:
+        while True:
+            # 接收客户端消息
+            data = await websocket.receive_json()
+            await ws_manager.handle_message(websocket, data)
+    except WebSocketDisconnect:
+        await ws_manager.disconnect(websocket)
+    except Exception as e:
+        logger.error(f"WebSocket 错误: {e}")
+        await ws_manager.disconnect(websocket)
+
+@app.get("/api/ws/status")
+def get_ws_status():
+    """获取 WebSocket 状态"""
+    return {
+        "code": 200,
+        "success": True,
+        "message": "success",
+        "data": {
+            "connectionCount": ws_manager.connection_count,
+            "refreshInterval": ws_manager.refresh_interval
+        }
+    }
+
+@app.post("/api/ws/refresh-interval")
+def set_refresh_interval(interval: int):
+    """设置刷新间隔"""
+    ws_manager.update_refresh_interval(interval)
+    return {
+        "code": 200,
+        "success": True,
+        "message": "success",
+        "data": {
+            "refreshInterval": ws_manager.refresh_interval
+        }
+    }
+
 # 返回 index.html 文件
 @app.get("/")
 async def read_root():