From 2293c1204ba67cf7c51da12a27011e191dc177bd Mon Sep 17 00:00:00 2001
From: "Torsten Schulz (local)" <tsschulz@gmx.net>
Date: Wed, 4 Feb 2026 09:10:31 +0100
Subject: [PATCH] Add SQL query for product price history: Introduced a new
 query to insert regional product prices into the history table, calculating
 prices based on sell cost and worth percentage. Updated
 ValueRecalculationWorker to log current prices for affected regions,
 enhancing price tracking functionality.

---
 src/worker/sql.rs                 | 14 ++++++++++++++
 src/worker/value_recalculation.rs | 13 +++++++++++++
 2 files changed, 27 insertions(+)

diff --git a/src/worker/sql.rs b/src/worker/sql.rs
index afb5786..0fab301 100644
--- a/src/worker/sql.rs
+++ b/src/worker/sql.rs
@@ -1607,6 +1607,20 @@ pub const QUERY_HOURLY_PRICE_RECALCULATION: &str = r#"
        AND tpw.product_id = adj.product_id;
 "#;
 
+/// Fügt für eine Region Preise in die Historie ein.
+/// Berechnet den regionalen Produktpreis als sell_cost * worth_percent / 100.
+pub const QUERY_INSERT_PRODUCT_PRICE_HISTORY: &str = r#"
+    INSERT INTO falukant_log.product_price_history (product_id, region_id, price, recorded_at)
+    SELECT
+        tpw.product_id,
+        tpw.region_id,
+        ROUND(ftp.sell_cost * tpw.worth_percent / 100.0, 2) AS price,
+        NOW() AS recorded_at
+    FROM falukant_data.town_product_worth tpw
+    JOIN falukant_type.product ftp ON ftp.id = tpw.product_id
+    WHERE tpw.region_id = $1;
+"#;
+
 pub const QUERY_SET_MARRIAGES_BY_PARTY: &str = r#"
     WITH updated_relations AS (
         UPDATE falukant_data.relationship AS rel
diff --git a/src/worker/value_recalculation.rs b/src/worker/value_recalculation.rs
index 3af3990..ea932c3 100644
--- a/src/worker/value_recalculation.rs
+++ b/src/worker/value_recalculation.rs
@@ -14,6 +14,7 @@ use crate::worker::sql::{
     QUERY_DELETE_REGION_SELL_PRICE,
     QUERY_GET_SELL_REGIONS,
     QUERY_HOURLY_PRICE_RECALCULATION,
+    QUERY_INSERT_PRODUCT_PRICE_HISTORY,
     QUERY_SET_MARRIAGES_BY_PARTY,
     QUERY_GET_STUDYINGS_TO_EXECUTE,
     QUERY_GET_OWN_CHARACTER_ID,
@@ -139,11 +140,17 @@ impl ValueRecalculationWorker {
         conn.prepare("update_region_sell_price", QUERY_UPDATE_REGION_SELL_PRICE)?;
         conn.execute("update_region_sell_price", &[])?;
 
+        // Preis-Historie für betroffene Regionen erfassen
+        conn.prepare("insert_price_history", QUERY_INSERT_PRODUCT_PRICE_HISTORY)?;
+
         conn.prepare("get_sell_regions", QUERY_GET_SELL_REGIONS)?;
         let regions = conn.execute("get_sell_regions", &[])?;
 
         for row in regions {
             if let Some(region_id) = row.get("region_id").and_then(|v| v.parse::<i32>().ok()) {
+                // Aktuelle Preise dieser Region in die Historie schreiben
+                let _ = conn.execute("insert_price_history", &[&region_id]);
+
                 let message =
                     format!(r#"{{"event":"price_update","region_id":{}}}"#, region_id);
                 broker.publish(message);
@@ -167,6 +174,9 @@ impl ValueRecalculationWorker {
         conn.prepare("hourly_price_recalculation", QUERY_HOURLY_PRICE_RECALCULATION)?;
         let _updated_rows = conn.execute("hourly_price_recalculation", &[])?;
 
+        // Prepared Statement für Preis-Historie
+        conn.prepare("insert_price_history", QUERY_INSERT_PRODUCT_PRICE_HISTORY)?;
+
         // Sammle alle betroffenen Regionen für Event-Benachrichtigungen
         let mut affected_regions = HashSet::new();
         
@@ -191,6 +201,9 @@ impl ValueRecalculationWorker {
 
         // Benachrichtige alle betroffenen Regionen über Preisänderungen
         for region_id in affected_regions {
+            // aktuellen Preisstand in die Historie schreiben
+            let _ = conn.execute("insert_price_history", &[&region_id]);
+
             let message =
                 format!(r#"{{"event":"price_update","region_id":{}}}"#, region_id);
             broker.publish(message);