admin/momentry_core
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fix 5W1H status endpoint: uuid to file_uuid

Browse Source
This commit is contained in:
Accusys
2026-05-08 03:05:36 +08:00
parent a19385d35b
commit 3caa35e096
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/api/five_w1h_agent_api.rs
View File

@@ -504,7 +504,7 @@ async fn get_5w1h_status(
) -> Result<Json<serde_json::Value>, (StatusCode, String)> { ) -> Result<Json<serde_json::Value>, (StatusCode, String)> {
let table = schema::table_name("videos"); let table = schema::table_name("videos");
let rows = sqlx::query(&format!( let rows = sqlx::query(&format!(
r#"SELECT uuid, processing_status->'agents'->'five_w1h' as s r#"SELECT file_uuid, processing_status->'agents'->'five_w1h' as s
FROM {} WHERE processing_status->'agents'->'five_w1h' IS NOT NULL FROM {} WHERE processing_status->'agents'->'five_w1h' IS NOT NULL
ORDER BY updated_at DESC LIMIT 50"#, table ORDER BY updated_at DESC LIMIT 50"#, table
)) ))
@@ -513,7 +513,7 @@ async fn get_5w1h_status(
let videos: Vec<serde_json::Value> = rows.iter().map(|r| { let videos: Vec<serde_json::Value> = rows.iter().map(|r| {
serde_json::json!({ serde_json::json!({
"uuid": r.try_get::<String,_>("uuid").unwrap_or_default(), "uuid": r.try_get::<String,_>("file_uuid").unwrap_or_default(),
"five_w1h_status": r.try_get::<Option<serde_json::Value>,_>("s").ok().flatten(), "five_w1h_status": r.try_get::<Option<serde_json::Value>,_>("s").ok().flatten(),
}) })
}).collect(); }).collect();