新增: anthropic 思维链解析入库与思考卡展示

- 流式与非流式 thinking 块接入 reasoning 通道
- 签名与密文块合规静默,请求侧零改动
- 历史映射透传 reasoning_content
- 思考卡数据源真推理文本优先

crates/df-ai/src/anthropic_helpers.rs

@@ -72,13 +72,16 @@ pub(crate) struct AnthropicResponse {
     pub usage: AnthropicUsage,
 }
 
-/// 响应 content 块（text 或 tool_use）
+/// 响应 content 块（text / tool_use / thinking）
 #[derive(Debug, Deserialize)]
 pub(crate) struct AnthropicContentBlock {
     #[serde(rename = "type")]
     pub block_type: String,
     #[serde(default)]
     pub text: Option<String>,
+    /// thinking 块推理正文（端点侧开启扩展思考时出现；本侧请求未启用 thinking，一般缺省）
+    #[serde(default)]
+    pub thinking: Option<String>,
     /// tool_use 块字段
     pub id: Option<String>,
     pub name: Option<String>,
@@ -119,7 +122,8 @@ pub(crate) const DEFAULT_MAX_TOKENS: u32 = 4096;
 /// 按 `type` 字段分发：
 /// - `message_start` → 用 `message.usage.input_tokens` 初始化累加器（output 置 0）。
 /// - `message_delta` → **output_tokens 是累计值（非增量）**，直接覆盖 `completion_tokens` 并重算 `total`。
-/// - `content_block_delta` (text_delta/input_json_delta) → 文本/工具入参增量。
+/// - `content_block_delta` (text_delta/input_json_delta/thinking_delta) → 文本/工具入参/思考增量，
+///   signature_delta 安静忽略。
 /// - `content_block_start` (tool_use) → 工具块开始，带 id+name。
 /// - `message_stop` → 返回 `finished=true` 终态 chunk，`usage` 取自累加器（`take()`）。
 /// - `error` → 返回 `finished=true` 终态空 chunk。
@@ -182,6 +186,17 @@ pub(crate) fn apply_anthropic_event(data: &str, usage_accum: &mut Option<TokenUs
         // 文本增量
         "content_block_delta" => {
             if let Some(delta) = v.get("delta") {
+                // thinking 增量：推理正文走 reasoning_content 通道（与 DeepSeek 同路入库展示），
+                // 不混入正文 delta。本侧请求未启用 thinking，此分支只为不丢端点侧自行产出的思考。
+                if delta.get("type").and_then(|t| t.as_str()) == Some("thinking_delta") {
+                    let text = delta.get("thinking").and_then(|t| t.as_str()).unwrap_or("").to_string();
+                    return StreamChunk { delta: String::new(), finished: false, tool_calls: None, usage: None, error: None, reasoning_content: Some(text) };
+                }
+                // signature_delta：thinking 块签名字段，仅回传校验用。DevFlow 从不把 thinking 回传
+                // anthropic 历史（丢弃 signature 后伪造回传必 400），签名无处消费，安静忽略。
+                if delta.get("type").and_then(|t| t.as_str()) == Some("signature_delta") {
+                    return StreamChunk { delta: String::new(), finished: false, tool_calls: None, usage: None, error: None, reasoning_content: None };
+                }
                 if delta.get("type").and_then(|t| t.as_str()) == Some("text_delta") {
                     let text = delta.get("text").and_then(|t| t.as_str()).unwrap_or("").to_string();
                     return StreamChunk { delta: text, finished: false, tool_calls: None, usage: None, error: None, reasoning_content: None };
@@ -209,6 +224,8 @@ pub(crate) fn apply_anthropic_event(data: &str, usage_accum: &mut Option<TokenUs
         }
         // 工具块开始：带 id + name
         "content_block_start" => {
+            // thinking / redacted_thinking 块起点无正文要记（正文随后经 thinking_delta 流出；
+            // redacted_thinking 为密文不可解析），落入末尾统一空 chunk 即安静跳过，不告警。
             if let Some(cb) = v.get("content_block") {
                 if cb.get("type").and_then(|t| t.as_str()) == Some("tool_use") {
                     let idx = v.get("index").and_then(|i| i.as_u64()).unwrap_or(0) as u32;