fix: StreamingResponse心跳保活+assert_text跳过重复AI调用

1. HTTP连接保活（引擎端，不依赖插件重编译）
   - routes.py: Web蓝本测试改用StreamingResponse
   - 每20秒发送心跳空格保持TCP连接活跃
   - 测试完成后发送完整JSON结果
   - 空格在JSON.parse时自动忽略，前端零改动

2. 减少不必要的AI API调用
   - assert_text步骤已用纯文本匹配验证，不再重复截图+调AI
   - 每个assert_text步骤节省一次截图分析API调用（约8秒+tokens）
   - 只有screenshot动作和非assert_text的expected字段才调AI

3. WebSocket完整报告后备（上次提交的补充）
   - websocket.py: send_test_done支持full_report参数
   - 测试完成后WS推送完整报告dict

Author: zcj220

src/api/routes.py

@@ -503,73 +503,95 @@ async def _on_step(step: int, status: str, desc: str) -> None:
             on_step=_on_step,
         )
 
-        try:
-            await ws_manager.send_log(f"蓝本测试开始: {blueprint.app_name}")
-            report = await runner.run(blueprint)
+        # 使用 StreamingResponse + 心跳保活，防止 HTTP 连接在长测试中断开
+        # 每 20 秒发送一个空格作为心跳，测试完成后发送完整 JSON 结果
+        import asyncio as _asyncio
+        from fastapi.responses import StreamingResponse as _StreamingResponse
 
-            # v1.3：保存记忆（Bug模式提取）
-            if memory_store and report.bugs:
-                try:
-                    from src.memory.compressor import MemoryCompressor
-                    compressor = MemoryCompressor(memory_store)
-                    compressor.extract_from_report(report)
-                except Exception as mem_err:
-                    logger.warning("蓝本测试记忆提取失败: {}", mem_err)
+        result_holder: dict = {}
 
-            from src.api.models import StepDetail, BugDetail
-            stopped = test_controller.was_stopped
-            if stopped:
-                test_controller.reset()
-            pass_rate = report.passed_steps / report.total_steps * 100 if report.total_steps > 0 else 0
-            response = TestReportResponse(
-                test_name=report.test_name,
-                url=report.url,
-                total_steps=report.total_steps,
-                passed_steps=report.passed_steps,
-                failed_steps=report.failed_steps,
-                bug_count=len(report.bugs),
-                pass_rate=pass_rate,
-                duration_seconds=report.duration_seconds,
-                report_markdown=report.report_markdown,
-                stopped=stopped,
-                steps=[
-                    StepDetail(
-                        step=r.step,
-                        action=r.action.value if hasattr(r.action, 'value') else str(r.action),
-                        description=r.description,
-                        status=r.status.value if hasattr(r.status, 'value') else str(r.status),
-                        duration_seconds=r.duration_seconds,
-                        error_message=r.error_message,
-                        screenshot_path=r.screenshot_path,
-                    )
-                    for r in report.step_results
-                ],
-                bugs=[
-                    BugDetail(
-                        severity=b.severity.value if hasattr(b.severity, 'value') else str(b.severity),
-                        title=b.title,
-                        description=b.description,
-                        category=b.category,
-                        location=b.location,
-                        step_number=b.step_number,
-                        screenshot_path=b.screenshot_path,
-                    )
-                    for b in report.bugs
-                ],
-            )
-
-            # 通过 WebSocket 推送完整报告（作为 HTTP response 的后备）
-            # 即使 HTTP 连接中途断开，WebView 也能通过 WS 拿到结果
+        async def _run_test():
             try:
-                report_dict = response.model_dump()
-            except AttributeError:
-                report_dict = response.dict()
-            await ws_manager.send_test_done(pass_rate, len(report.bugs), full_report=report_dict)
+                await ws_manager.send_log(f"蓝本测试开始: {blueprint.app_name}")
+                report = await runner.run(blueprint)
 
-            return response
-        except Exception as e:
-            logger.error("蓝本测试执行失败: {}", e)
-            raise HTTPException(status_code=500, detail=f"蓝本测试执行失败: {e}")
+                if memory_store and report.bugs:
+                    try:
+                        from src.memory.compressor import MemoryCompressor
+                        compressor = MemoryCompressor(memory_store)
+                        compressor.extract_from_report(report)
+                    except Exception as mem_err:
+                        logger.warning("蓝本测试记忆提取失败: {}", mem_err)
+
+                from src.api.models import StepDetail, BugDetail
+                stopped = test_controller.was_stopped
+                if stopped:
+                    test_controller.reset()
+                pass_rate = report.passed_steps / report.total_steps * 100 if report.total_steps > 0 else 0
+                response = TestReportResponse(
+                    test_name=report.test_name,
+                    url=report.url,
+                    total_steps=report.total_steps,
+                    passed_steps=report.passed_steps,
+                    failed_steps=report.failed_steps,
+                    bug_count=len(report.bugs),
+                    pass_rate=pass_rate,
+                    duration_seconds=report.duration_seconds,
+                    report_markdown=report.report_markdown,
+                    stopped=stopped,
+                    steps=[
+                        StepDetail(
+                            step=r.step,
+                            action=r.action.value if hasattr(r.action, 'value') else str(r.action),
+                            description=r.description,
+                            status=r.status.value if hasattr(r.status, 'value') else str(r.status),
+                            duration_seconds=r.duration_seconds,
+                            error_message=r.error_message,
+                            screenshot_path=r.screenshot_path,
+                        )
+                        for r in report.step_results
+                    ],
+                    bugs=[
+                        BugDetail(
+                            severity=b.severity.value if hasattr(b.severity, 'value') else str(b.severity),
+                            title=b.title,
+                            description=b.description,
+                            category=b.category,
+                            location=b.location,
+                            step_number=b.step_number,
+                            screenshot_path=b.screenshot_path,
+                        )
+                        for b in report.bugs
+                    ],
+                )
+                try:
+                    report_dict = response.model_dump()
+                except AttributeError:
+                    report_dict = response.dict()
+                await ws_manager.send_test_done(pass_rate, len(report.bugs), full_report=report_dict)
+                result_holder["data"] = report_dict
+            except Exception as e:
+                logger.error("蓝本测试执行失败: {}", e)
+                result_holder["error"] = str(e)
+
+        async def _stream_with_heartbeat():
+            task = _asyncio.create_task(_run_test())
+            while not task.done():
+                await _asyncio.sleep(20)
+                if not task.done():
+                    yield b" "  # 心跳空格，保持HTTP连接活跃
+            await task  # 确保异常被传播
+            if "error" in result_holder:
+                import json as _json
+                yield _json.dumps({"detail": result_holder["error"]}).encode("utf-8")
+            else:
+                import json as _json
+                yield _json.dumps(result_holder.get("data", {})).encode("utf-8")
+
+        return _StreamingResponse(
+            _stream_with_heartbeat(),
+            media_type="application/json",
+        )
 
     @router.post("/test/mobile-blueprint", response_model=TestReportResponse, tags=["测试"])
     async def run_mobile_blueprint_test(req: RunMobileBlueprintRequest) -> TestReportResponse:

src/testing/blueprint_runner.py

@@ -523,7 +523,9 @@ async def _execute_step(
                 await asyncio.sleep(step_def.wait_after_ms / 1000.0)
 
             # 只在蓝本写了screenshot动作 或 有expected需要AI验证时才截图
-            need_screenshot = (step_def.action == "screenshot") or (step_def.expected and self._ai)
+            # assert_text 已经用纯文本匹配验证过了，不需要再调AI浪费tokens
+            need_ai_verify = (step_def.expected and self._ai and step_def.action != "assert_text")
+            need_screenshot = (step_def.action == "screenshot") or need_ai_verify
             if need_screenshot:
                 screenshot_path_obj = await self._browser.screenshot(f"step{step_num}_{step_def.action}")
                 screenshot_path = str(screenshot_path_obj)
@@ -537,10 +539,10 @@ async def _execute_step(
                     except Exception as e:
                         logger.debug("截图推送失败: {}", e)
 
-            # AI视觉验证（如果有预期结果描述）
+            # AI视觉验证（如果有预期结果描述，但 assert_text 已用文本匹配，跳过）
             ai_verdict = "passed"
             ai_detail = ""
-            if step_def.expected and self._ai and screenshot_path:
+            if need_ai_verify and screenshot_path:
                 ai_verdict, ai_detail = await self._ai_verify(screenshot_path, step_def.expected)
 
             elapsed = time.time() - start