feat(ocr): 结构图存储与记录——struct/命名空间+独立预算+新表（REQ-183）

Author: Aparencia

app/src-tauri/src/db.rs

@@ -173,6 +173,8 @@ impl Db {
         )?;
         // 关联查询索引（列表 has_note 子查询 + 笔记页来源跳转共用）
         conn.execute_batch("CREATE INDEX IF NOT EXISTS idx_notes_session ON notes(session_id)")?;
+        // v0.7.7（REQ-183）：结构图记录表（建表幂等——新库建表/旧库补表）
+        crate::db_structures::init(&conn)?;
         Ok(Self { conn: Arc::new(Mutex::new(conn)) })
     }
 

app/src-tauri/src/db_structures.rs

@@ -0,0 +1,124 @@
+//! 结构图记录存储（REQ-183 / v0.7.7）：session_structure_images 表 CRUD。
+//!
+//! @ai-context: 非线性结构图的持久化元数据（文件在会话目录 struct/，本表记录
+//!              归属/类型/坐标/时间/来源）——图库 UI 与将来笔记消费（按屏
+//!              screen_id 锚点）的数据源；文件删除由记录驱动。
+//! @ai-context: kind/source 为字符串枚举（不动 RegionKind——版面分析模块零
+//!              改动）；bbox 为 JSON 帧坐标；旧会话（无 screen_id）NULL 降级。
+
+use rusqlite::{params, Connection, OptionalExtension};
+
+use crate::db::Db;
+use crate::error::Result;
+
+/// 结构图记录（前端契约，camelCase）。
+#[derive(Debug, Clone, PartialEq, serde::Serialize, serde::Deserialize)]
+#[serde(rename_all = "camelCase")]
+pub struct StructureImageRecord {
+    pub id: i64,
+    pub session_id: i64,
+    /// 所属屏（NULL=旧数据无屏/手动无屏上下文）
+    #[serde(default)]
+    pub screen_id: Option<i64>,
+    /// table/formula/code/image/manual
+    pub kind: String,
+    /// 帧坐标 JSON {"x","y","w","h"}
+    pub bbox: String,
+    /// 裁剪源帧时间戳（屏内选优帧/手动屏 first_seen）
+    pub source_ts_ms: u64,
+    /// struct/xxx.webp 相对路径
+    pub crop_path: String,
+    /// auto/manual
+    pub source: String,
+    pub created_at: u64,
+}
+
+/// 建表（幂等；db::open 末尾调用——新库建表 + 旧库补表）。
+pub fn init(conn: &Connection) -> Result<()> {
+    conn.execute_batch(
+        "CREATE TABLE IF NOT EXISTS session_structure_images (
+            id INTEGER PRIMARY KEY AUTOINCREMENT,
+            session_id INTEGER NOT NULL REFERENCES sessions(id) ON DELETE CASCADE,
+            screen_id INTEGER,
+            kind TEXT NOT NULL,
+            bbox TEXT NOT NULL DEFAULT '{}',
+            source_ts_ms INTEGER NOT NULL,
+            crop_path TEXT NOT NULL,
+            source TEXT NOT NULL DEFAULT 'auto',
+            created_at INTEGER NOT NULL
+        );
+        CREATE INDEX IF NOT EXISTS idx_struct_images_session
+            ON session_structure_images(session_id, created_at);",
+    )?;
+    Ok(())
+}
+
+/// 插入记录（返回新 id）。
+pub fn insert_structure_image(db: &Db, rec: &StructureImageRecord) -> Result<i64> {
+    let conn = db.conn.lock().unwrap();
+    conn.execute(
+        "INSERT INTO session_structure_images
+            (session_id, screen_id, kind, bbox, source_ts_ms, crop_path, source, created_at)
+         VALUES (?1, ?2, ?3, ?4, ?5, ?6, ?7, ?8)",
+        params![
+            rec.session_id,
+            rec.screen_id,
+            rec.kind,
+            rec.bbox,
+            rec.source_ts_ms as i64,
+            rec.crop_path,
+            rec.source,
+            rec.created_at as i64,
+        ],
+    )?;
+    Ok(conn.last_insert_rowid())
+}
+
+/// 会话结构图列表（按入库时间升序——图库展示顺序）。
+pub fn list_structure_images(db: &Db, session_id: i64) -> Result<Vec<StructureImageRecord>> {
+    let conn = db.conn.lock().unwrap();
+    let mut stmt = conn.prepare(
+        "SELECT id, session_id, screen_id, kind, bbox, source_ts_ms, crop_path, source, created_at
+         FROM session_structure_images WHERE session_id = ?1 ORDER BY created_at ASC",
+    )?;
+    let rows = stmt
+        .query_map(params![session_id], row_to_record)?
+        .collect::<std::result::Result<Vec<_>, _>>()?;
+    Ok(rows)
+}
+
+/// 删除记录（返回被删记录——命令层据此删文件；不存在 → Ok(None)）。
+pub fn delete_structure_image(db: &Db, id: i64) -> Result<Option<StructureImageRecord>> {
+    let conn = db.conn.lock().unwrap();
+    let existing = conn
+        .query_row(
+            "SELECT id, session_id, screen_id, kind, bbox, source_ts_ms, crop_path, source, created_at
+             FROM session_structure_images WHERE id = ?1",
+            params![id],
+            row_to_record,
+        )
+        .optional()?;
+    if let Some(rec) = &existing {
+        conn.execute("DELETE FROM session_structure_images WHERE id = ?1", params![id])?;
+    }
+    Ok(existing)
+}
+
+/// 行 → 记录映射。
+fn row_to_record(row: &rusqlite::Row<'_>) -> rusqlite::Result<StructureImageRecord> {
+    Ok(StructureImageRecord {
+        id: row.get(0)?,
+        session_id: row.get(1)?,
+        screen_id: row.get(2)?,
+        kind: row.get(3)?,
+        bbox: row.get(4)?,
+        source_ts_ms: row.get::<_, i64>(5)? as u64,
+        crop_path: row.get(6)?,
+        source: row.get(7)?,
+        created_at: row.get::<_, i64>(8)? as u64,
+    })
+}
+
+#[cfg(test)]
+#[path = "db_structures_tests.rs"]
+mod tests;

app/src-tauri/src/db_structures_tests.rs

@@ -0,0 +1,125 @@
+//! 结构图记录存储单测（REQ-183 / v0.7.7，AAA 模式）。
+//!
+//! @ai-context: 内存库隔离（不触碰真实数据）；外键 ON——记录必须先建真实会话；
+//!              覆盖建表幂等/CRUD/删除返回/排序/外键级联（删会话清记录）。
+
+use super::*;
+use crate::db::Db;
+
+/// 建会话（外键约束前置）→ 返回 session id。
+fn session(db: &Db) -> i64 {
+    db.create_session(&crate::types::NewSession {
+        title: "测试会话".to_string(),
+        source_window: None,
+        profile: None,
+    })
+    .unwrap()
+    .id
+}
+
+/// 构造记录（id 由 DB 分配）。
+fn rec(session_id: i64, kind: &str, ts: u64) -> StructureImageRecord {
+    StructureImageRecord {
+        id: 0,
+        session_id,
+        screen_id: Some(1),
+        kind: kind.to_string(),
+        bbox: r#"{"x":10,"y":20,"w":100,"h":50}"#.to_string(),
+        source_ts_ms: ts,
+        crop_path: format!("struct/{}.webp", ts),
+        source: "auto".to_string(),
+        created_at: ts,
+    }
+}
+
+#[test]
+fn insert_and_list_roundtrip() {
+    // Arrange：内存库 + 会话 + 两条记录
+    let db = Db::open(":memory:").unwrap();
+    let sid = session(&db);
+    let a = rec(sid, "table", 1_000);
+    let b = rec(sid, "image", 2_000);
+
+    // Act
+    let id_a = insert_structure_image(&db, &a).unwrap();
+    let id_b = insert_structure_image(&db, &b).unwrap();
+    let list = list_structure_images(&db, sid).unwrap();
+
+    // Assert：id 分配 + 按入库时间升序 + 字段完整
+    assert!(id_a < id_b);
+    assert_eq!(list.len(), 2);
+    assert_eq!(list[0].crop_path, "struct/1000.webp");
+    assert_eq!(list[1].kind, "image");
+    assert_eq!(list[1].source_ts_ms, 2_000);
+    assert_eq!(list[0].screen_id, Some(1));
+}
+
+#[test]
+fn list_scoped_to_session() {
+    // Arrange：两个会话各一条
+    let db = Db::open(":memory:").unwrap();
+    let s1 = session(&db);
+    let s2 = session(&db);
+    insert_structure_image(&db, &rec(s1, "code", 1_000)).unwrap();
+    insert_structure_image(&db, &rec(s2, "manual", 5_000)).unwrap();
+
+    // Act
+    let list = list_structure_images(&db, s1).unwrap();
+
+    // Assert：只返回会话 1
+    assert_eq!(list.len(), 1);
+    assert_eq!(list[0].session_id, s1);
+}
+
+#[test]
+fn delete_returns_record_then_missing() {
+    // Arrange
+    let db = Db::open(":memory:").unwrap();
+    let sid = session(&db);
+    let id = insert_structure_image(&db, &rec(sid, "formula", 3_000)).unwrap();
+
+    // Act：删除（返回记录）+ 再删（None）
+    let removed = delete_structure_image(&db, id).unwrap();
+    let again = delete_structure_image(&db, id).unwrap();
+
+    // Assert：首删返回记录（文件删除由命令层驱动），再删 None
+    assert_eq!(removed.as_ref().unwrap().kind, "formula");
+    assert_eq!(removed.unwrap().crop_path, "struct/3000.webp");
+    assert!(again.is_none());
+    assert!(list_structure_images(&db, sid).unwrap().is_empty());
+}
+
+#[test]
+fn init_is_idempotent_and_supports_null_screen() {
+    // Arrange：重复 init 不报错
+    let db = Db::open(":memory:").unwrap();
+    let sid = session(&db);
+
+    // Act：再次建表（幂等）+ 无屏记录（旧数据降级形态）
+    {
+        let conn = db.conn.lock().unwrap();
+        init(&conn).unwrap();
+    }
+    let mut old = rec(sid, "image", 1_000);
+    old.screen_id = None;
+    insert_structure_image(&db, &old).unwrap();
+    let list = list_structure_images(&db, sid).unwrap();
+
+    // Assert：幂等成功 + NULL screen_id 往返
+    assert_eq!(list[0].screen_id, None);
+}
+
+#[test]
+fn session_cascade_deletes_records() {
+    // Arrange：建会话 + 结构图记录
+    let db = Db::open(":memory:").unwrap();
+    let sid = session(&db);
+    insert_structure_image(&db, &rec(sid, "table", 1_000)).unwrap();
+    assert_eq!(list_structure_images(&db, sid).unwrap().len(), 1);
+
+    // Act：删除会话（外键级联）
+    db.delete_session(sid).unwrap();
+
+    // Assert：记录随会话清除
+    assert!(list_structure_images(&db, sid).unwrap().is_empty());
+}

app/src-tauri/src/image_store.rs

@@ -267,7 +267,8 @@ pub fn encode_webp_public(bgraw: &[u8], width: u32, height: u32, path: &Path) ->
 }
 
 /// BGRA8 → RGB（纯函数；尺寸/长度不匹配返回 None）。
-fn bgra_to_rgb(bgraw: &[u8], width: u32, height: u32) -> Option<image::RgbImage> {
+/// @ai-context: pub(crate)（v0.7.7 REQ-183）：structure_store 结构图存储复用。
+pub(crate) fn bgra_to_rgb(bgraw: &[u8], width: u32, height: u32) -> Option<image::RgbImage> {
     let pixel_len = width as usize * height as usize * 4;
     if width == 0 || height == 0 || bgraw.len() != pixel_len {
         return None;
@@ -280,7 +281,8 @@ fn bgra_to_rgb(bgraw: &[u8], width: u32, height: u32) -> Option<image::RgbImage>
 }
 
 /// 编码 WebP（lossless）到文件（纯 IO）。
-fn encode_webp(rgb: &image::RgbImage, path: &Path) -> Result<()> {
+/// @ai-context: pub(crate)（v0.7.7 REQ-183）：structure_store 结构图存储复用。
+pub(crate) fn encode_webp(rgb: &image::RgbImage, path: &Path) -> Result<()> {
     let mut out = std::io::Cursor::new(Vec::new());
     let encoder = image::codecs::webp::WebPEncoder::new_lossless(&mut out);
     rgb.write_with_encoder(encoder)
@@ -290,7 +292,8 @@ fn encode_webp(rgb: &image::RgbImage, path: &Path) -> Result<()> {
 }
 
 /// 缩略图（最近邻缩小 BGRA 到 THUMB 尺寸，保持宽高比；纯函数）。
-fn resize_bgra(bgraw: &[u8], width: u32, height: u32) -> Option<image::RgbImage> {
+/// @ai-context: pub(crate)（v0.7.7 REQ-183）：structure_store 结构图缩略图复用。
+pub(crate) fn resize_bgra(bgraw: &[u8], width: u32, height: u32) -> Option<image::RgbImage> {
     let rgb = bgra_to_rgb(bgraw, width, height)?;
     if width <= THUMB_MAX_WIDTH && height <= THUMB_MAX_HEIGHT {
         return Some(rgb);

app/src-tauri/src/lib.rs

@@ -61,6 +61,8 @@ mod commands_video;
 mod concat;
 mod db;
 mod db_artifacts;
+// v0.7.7（REQ-183）：结构图记录存储——session_structure_images 表 CRUD
+mod db_structures;
 // v0.7.0 M1.5（REQ-108）：会话信号事件数据层（统一信号事件表读写）
 mod db_session_events;
 mod db_sessions;
@@ -154,6 +156,8 @@ mod structure_models;
 mod structure_note;
 // v0.7.7（REQ-182）：结构图检测纯函数——diagram_likeness/pick_sharpest/区域过滤
 mod structure_detect;
+// v0.7.7（REQ-183）：结构图存储——struct/ 命名空间 + 独立预算 + 去重
+mod structure_store;
 mod structure_tier;
 mod stutter_fold;
 mod subtitle;