diff --git a/src/worker/house.rs b/src/worker/house.rs index 28ec5ab..153d7b0 100644 --- a/src/worker/house.rs +++ b/src/worker/house.rs @@ -68,17 +68,34 @@ impl HouseWorker { conn.prepare("get_new_house_data", QUERY_GET_NEW_HOUSE_DATA)?; let rows = conn.execute("get_new_house_data", &[])?; + eprintln!("[HouseWorker] Query zurückgegeben: {} Häuser gefunden", rows.len()); + conn.prepare("add_new_buyable_house", QUERY_ADD_NEW_BUYABLE_HOUSE)?; + let mut inserted_count = 0; for row in rows { if let Some(house_id) = row .get("house_id") .and_then(|v| v.parse::().ok()) { - conn.execute("add_new_buyable_house", &[&house_id])?; + match conn.execute("add_new_buyable_house", &[&house_id]) { + Ok(_) => { + inserted_count += 1; + eprintln!("[HouseWorker] Neues kaufbares Haus erstellt: house_type_id={}", house_id); + } + Err(err) => { + eprintln!("[HouseWorker] Fehler beim Erstellen von buyable_house (house_type_id={}): {}", house_id, err); + } + } } } + if inserted_count > 0 { + eprintln!("[HouseWorker] {} neue kaufbare Häuser erstellt", inserted_count); + } else { + eprintln!("[HouseWorker] Keine neuen kaufbaren Häuser erstellt"); + } + Ok(()) } diff --git a/src/worker/sql.rs b/src/worker/sql.rs index 6e88ce7..244959c 100644 --- a/src/worker/sql.rs +++ b/src/worker/sql.rs @@ -458,7 +458,7 @@ pub const QUERY_GET_NEW_HOUSE_DATA: &str = r#" FROM falukant_type.house AS h WHERE - random() < 0.0001 + random() < 0.01 AND label_tr <> 'under_bridge'; "#;