Improve AI workflows and chapter export

Author: felixchaos

.dockerignore

@@ -14,6 +14,7 @@ build/
 
 # Node
 node_modules/
+**/node_modules/
 npm-debug.log*
 yarn-debug.log*
 yarn-error.log*
@@ -78,4 +79,4 @@ backend/.instance_id
 # Docker相关
 Dockerfile
 .dockerignore
-docker-compose*.yml
+docker-compose*.yml

.gitignore

@@ -37,6 +37,7 @@ env/
 *~
 .DS_Store
 .kilocode/
+.playwright-cli/
 
 # Environment variables
 .env

backend/.env.example

@@ -53,6 +53,8 @@ CORS_ORIGINS=["http://localhost:8000","http://127.0.0.1:8000"]
 # HTTP_PROXY=http://your-proxy:port
 # HTTPS_PROXY=http://your-proxy:port
 # NO_PROXY=localhost,127.0.0.1
+# 仅本地 Clash fake-ip DNS 场景需要开启；生产环境建议保持 false
+ALLOW_DNS_PROXY_FAKE_IP=false
 
 # ==========================================
 # AI 服务配置（至少配置一个）

backend/app/api/chapters.py

@@ -75,6 +75,23 @@ async def get_db_write_lock(user_id: str) -> Lock:
     return db_write_locks[user_id]
 
 
+def _is_gemini_prompt_blocked_error(error: Optional[str]) -> bool:
+    if not error:
+        return False
+    markers = (
+        "promptFeedback.blockReason=PROHIBITED_CONTENT",
+        "Gemini 请求被拦截",
+    )
+    return any(marker in error for marker in markers)
+
+
+def _is_same_ai_service(left: AIService, right: AIService) -> bool:
+    return (
+        left.api_provider == right.api_provider
+        and left.default_model == right.default_model
+    )
+
+
 @router.post("", response_model=ChapterResponse, summary="创建章节")
 async def create_chapter(
     chapter: ChapterCreate,
@@ -969,11 +986,56 @@ async def on_retry_callback(attempt: int, max_retries: int, wait_time: int, erro
             on_retry=on_retry_callback,
             characters_info=characters_info
         )
+
+        analysis_error = getattr(analyzer, "last_error", None)
+
+        if not analysis_result and _is_gemini_prompt_blocked_error(analysis_error):
+            fallback_ai_service = await get_user_ai_service_from_db_by_usage(
+                user_id=user_id,
+                db=db_session,
+                usage="default"
+            )
+
+            if not _is_same_ai_service(ai_service, fallback_ai_service):
+                logger.warning(
+                    "⚠️ 章节分析专用 Gemini 模型被内容策略拦截，"
+                    f"改用默认模型兜底: {fallback_ai_service.api_provider}/{fallback_ai_service.default_model}"
+                )
+                async with write_lock:
+                    task.status = 'running'
+                    task.progress = max(task.progress or 0, 40)
+                    task.error_message = f"专用 Gemini 模型被拦截，正在使用默认模型兜底：{analysis_error[:150]}"
+                    await db_session.commit()
+
+                fallback_analyzer = PlotAnalyzer(fallback_ai_service)
+                analysis_result = await fallback_analyzer.analyze_chapter(
+                    chapter_number=chapter.chapter_number,
+                    title=chapter.title,
+                    content=chapter.content,
+                    word_count=chapter.word_count or len(chapter.content),
+                    user_id=user_id,
+                    db=db_session,
+                    max_retries=2,
+                    existing_foreshadows=existing_foreshadows,
+                    on_retry=on_retry_callback,
+                    characters_info=characters_info
+                )
+
+                if not analysis_result:
+                    fallback_error = getattr(fallback_analyzer, "last_error", None)
+                    analysis_error = (
+                        f"{analysis_error}；默认模型兜底失败: "
+                        f"{fallback_error or '未知错误'}"
+                    )
+                else:
+                    analysis_error = None
+            else:
+                logger.warning("⚠️ 默认模型与章节分析模型相同，跳过兜底重试")
 
         if not analysis_result:
             async with write_lock:
                 task.status = 'failed'
-                task.error_message = 'AI分析失败，请检查日志'
+                task.error_message = (analysis_error or 'AI分析失败，请检查日志')[:500]
                 task.completed_at = datetime.now()
                 await db_session.commit()
             logger.error(f"❌ AI分析失败: {chapter_id}")
@@ -1266,6 +1328,7 @@ async def on_retry_callback(attempt: int, max_retries: int, wait_time: int, erro
                 async with write_lock:
                     task.progress = 100
                     task.status = 'completed'
+                    task.error_message = None
                     task.completed_at = datetime.now()
                     await db_session.commit()
                     update_success = True
@@ -3281,9 +3344,14 @@ async def execute_batch_generation_in_order(
 
                                 # 直接根据返回值判断
                                 if not analysis_result:
-                                    last_analysis_error = "分析函数返回失败"
+                                    try:
+                                        await db_session.refresh(analysis_task)
+                                        last_analysis_error = analysis_task.error_message or "分析函数返回失败"
+                                    except Exception as refresh_error:
+                                        logger.warning(f"⚠️ 刷新分析任务错误信息失败: {refresh_error}")
+                                        last_analysis_error = "分析函数返回失败"
                                     logger.error(f"❌ 章节分析失败: 第{chapter.chapter_number}章")
-                                    raise Exception(f"章节分析失败")
+                                    raise Exception(last_analysis_error)
 
                                 # 分析成功
                                 analysis_success = True
@@ -4486,4 +4554,3 @@ async def apply_partial_regenerate(
         "old_word_count": old_word_count,
         "message": "局部重写已应用"
     }
-