Update database/db.py

database/db.py

@@ -141,6 +141,58 @@ def insert_bet(
         ],
     )
 
+def read_recommendation_audit_view(conn) -> pd.DataFrame:
+    ensure_recommendation_logs_table(conn)
+    ensure_recommendation_outcomes_table(conn)
+
+    query = """
+    SELECT
+        l.created_at,
+        l.game_pk,
+        l.away_team,
+        l.home_team,
+        l.status,
+        l.slot,
+        l.batter_name,
+        l.pitcher_name,
+        l.ev90,
+        l.hit_prob,
+        l.hr_prob,
+        l.tb2p_prob,
+        l.fair_hit_odds,
+        l.fair_hr_odds,
+        l.fair_tb2p_odds,
+        l.book_hit_odds,
+        l.book_hr_odds,
+        l.book_tb2p_odds,
+        l.hit_edge,
+        l.hr_edge,
+        l.tb2p_edge,
+        l.adjusted_edge,
+        l.hit_bet_ev,
+        l.hr_bet_ev,
+        l.tb2p_bet_ev,
+        l.confidence,
+        l.confidence_bucket,
+        l.recommendation_tier,
+        l.priority_score,
+        l.reason_tags,
+        l.starter_stays_next_batter_prob,
+        l.starter_stays_next_inning_prob,
+        l.bullpen_entry_prob,
+        o.realized_hit,
+        o.realized_hr,
+        o.realized_tb2p,
+        o.graded_at,
+        o.outcome_source
+    FROM recommendation_logs l
+    LEFT JOIN recommendation_outcomes o
+      ON l.game_pk = o.game_pk
+     AND l.batter_name = o.batter_name
+     AND l.slot = o.slot
+    ORDER BY l.created_at DESC
+    """
+    return conn.execute(query).df()
 
 def ensure_recommendation_outcomes_table(conn) -> None:
     conn.execute(