Add cleanup functionality for collapsed houses in HouseWorker: Implement methods to delete collapsed buyable houses and user houses, including notifications for affected users. Update SQL queries to support this new feature, enhancing house management and user experience.

src/worker/house.rs

@@ -10,7 +10,10 @@ use crate::worker::sql::{
     QUERY_ADD_NEW_BUYABLE_HOUSE,
     QUERY_UPDATE_BUYABLE_HOUSE_STATE,
     QUERY_UPDATE_USER_HOUSE_STATE,
+    QUERY_DELETE_COLLAPSED_BUYABLE_HOUSES,
+    QUERY_DELETE_COLLAPSED_USER_HOUSES,
 };
+use crate::worker::{insert_notification_conn, publish_update_status};
 
 pub struct HouseWorker {
     base: BaseWorker,
@@ -23,7 +26,7 @@ impl HouseWorker {
         }
     }
 
-    fn run_loop(pool: ConnectionPool, _broker: MessageBroker, state: Arc<WorkerState>) {
+    fn run_loop(pool: ConnectionPool, broker: MessageBroker, state: Arc<WorkerState>) {
         let mut last_hourly_run: Option<Instant> = None;
         let mut last_daily_run: Option<Instant> = None;
 
@@ -40,6 +43,9 @@ impl HouseWorker {
                 if let Err(err) = Self::perform_task_inner(&pool) {
                     eprintln!("[HouseWorker] Fehler in performTask: {err}");
                 }
+                if let Err(err) = Self::cleanup_collapsed_houses(&pool, &broker) {
+                    eprintln!("[HouseWorker] Fehler in cleanup_collapsed_houses: {err}");
+                }
                 last_hourly_run = Some(now);
             }
 
@@ -53,6 +59,10 @@ impl HouseWorker {
                 if let Err(err) = Self::perform_house_state_change_inner(&pool) {
                     eprintln!("[HouseWorker] Fehler in performHouseStateChange: {err}");
                 }
+                // Nach der täglichen Verschlechterung direkt zusammengefallene Häuser aufräumen.
+                if let Err(err) = Self::cleanup_collapsed_houses(&pool, &broker) {
+                    eprintln!("[HouseWorker] Fehler in cleanup_collapsed_houses: {err}");
+                }
                 last_daily_run = Some(now);
             }
 
@@ -101,6 +111,57 @@ impl HouseWorker {
 
         Ok(())
     }
+
+    fn cleanup_collapsed_houses(pool: &ConnectionPool, broker: &MessageBroker) -> Result<(), DbError> {
+        let mut conn = pool
+            .get()
+            .map_err(|e| DbError::new(format!("[HouseWorker] DB-Verbindung fehlgeschlagen: {e}")))?;
+
+        conn.prepare(
+            "delete_collapsed_buyable_houses",
+            QUERY_DELETE_COLLAPSED_BUYABLE_HOUSES,
+        )?;
+        conn.prepare(
+            "delete_collapsed_user_houses",
+            QUERY_DELETE_COLLAPSED_USER_HOUSES,
+        )?;
+
+        // 1) Kaufbare Häuser (ohne Besitzer) löschen
+        let deleted_buyable = conn.execute("delete_collapsed_buyable_houses", &[])?;
+        if !deleted_buyable.is_empty() {
+            eprintln!(
+                "[HouseWorker] {} kaufbare(s) Haus/Häuser zusammengefallen und entfernt",
+                deleted_buyable.len()
+            );
+        }
+
+        // 2) Häuser im Besitz löschen + Owner informieren
+        let deleted_user_houses = conn.execute("delete_collapsed_user_houses", &[])?;
+        if deleted_user_houses.is_empty() {
+            return Ok(());
+        }
+
+        for row in deleted_user_houses {
+            let house_id = row
+                .get("house_id")
+                .and_then(|v| v.parse::<i32>().ok())
+                .unwrap_or(-1);
+            let user_id = row
+                .get("user_id")
+                .and_then(|v| v.parse::<i32>().ok())
+                .unwrap_or(-1);
+            if house_id < 0 || user_id < 0 {
+                continue;
+            }
+
+            // Notification + Frontend-Update
+            let tr = format!(r#"{{"tr":"house.collapsed","house_id":{}}}"#, house_id);
+            let _ = insert_notification_conn(&mut conn, user_id, &tr, None);
+            publish_update_status(broker, user_id);
+        }
+
+        Ok(())
+    }
 }
 
 impl Worker for HouseWorker {