update code level
This commit is contained in:
@@ -27,14 +27,14 @@ impl Database {
|
||||
let album_id = &result.album_id;
|
||||
let person_name = result.person_name.as_deref();
|
||||
|
||||
if let Some(name) = person_name {
|
||||
// ── 标记处理时间(person_name 列已迁移到 search.db)──
|
||||
sqlx::query(
|
||||
"UPDATE albums SET processed_at = datetime('now') WHERE id = ?"
|
||||
)
|
||||
.bind(album_id)
|
||||
.execute(&mut **tx).await?;
|
||||
// ── 标记处理时间(无论是否有人物,只要进了解析管线就标记)──
|
||||
sqlx::query(
|
||||
"UPDATE albums SET processed_at = datetime('now') WHERE id = ?"
|
||||
)
|
||||
.bind(album_id)
|
||||
.execute(&mut **tx).await?;
|
||||
|
||||
if let Some(name) = person_name {
|
||||
// ── insert or ignore 人物 ──
|
||||
let pid = sqlx::query_scalar::<_, i64>(
|
||||
"INSERT INTO persons (name, display_name) VALUES (?, ?) ON CONFLICT(name) DO UPDATE SET name = name RETURNING id"
|
||||
|
||||
Reference in New Issue
Block a user