diff --git a/blueprint_engine.py b/blueprint_engine.py
index 7d43e02..d1a8ede 100644
--- a/blueprint_engine.py
+++ b/blueprint_engine.py
@@ -45,9 +45,12 @@ def evaluate_blueprints(conn):
 
     for row in blueprints:
         town_id = str(row['town_id'])
-        town_row = conn.execute('SELECT data FROM town_state WHERE town_id = ?', (town_id,)).fetchone()
+        town_row = conn.execute('SELECT data, player_id, town_name FROM town_state WHERE town_id = ?', (town_id,)).fetchone()
         if not town_row:
             continue
+        
+        player_id = town_row['player_id']
+        town_name_db = town_row['town_name']
             
         try:
             town = json.loads(town_row['data'])
@@ -133,10 +136,10 @@ def evaluate_blueprints(conn):
             conn.execute('''
                 INSERT INTO commands (town_id, town_name, type, payload, status, player_id)
                 VALUES (?, ?, ?, ?, ?, ?)
-            ''', (town_id, town.get('town_name'), 'build', payload_str, 'pending', town.get('player_id')))
+            ''', (town_id, town_name_db, 'build', payload_str, 'pending', player_id))
         elif target_research:
             payload_str = json.dumps({"research_id": target_research})
             conn.execute('''
                 INSERT INTO commands (town_id, town_name, type, payload, status, player_id)
                 VALUES (?, ?, ?, ?, ?, ?)
-            ''', (town_id, town.get('town_name'), 'research', payload_str, 'pending', town.get('player_id')))
+            ''', (town_id, town_name_db, 'research', payload_str, 'pending', player_id))