fix 3
This commit is contained in:
@@ -45,10 +45,13 @@ def evaluate_blueprints(conn):
|
|||||||
|
|
||||||
for row in blueprints:
|
for row in blueprints:
|
||||||
town_id = str(row['town_id'])
|
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:
|
if not town_row:
|
||||||
continue
|
continue
|
||||||
|
|
||||||
|
player_id = town_row['player_id']
|
||||||
|
town_name_db = town_row['town_name']
|
||||||
|
|
||||||
try:
|
try:
|
||||||
town = json.loads(town_row['data'])
|
town = json.loads(town_row['data'])
|
||||||
except Exception:
|
except Exception:
|
||||||
@@ -133,10 +136,10 @@ def evaluate_blueprints(conn):
|
|||||||
conn.execute('''
|
conn.execute('''
|
||||||
INSERT INTO commands (town_id, town_name, type, payload, status, player_id)
|
INSERT INTO commands (town_id, town_name, type, payload, status, player_id)
|
||||||
VALUES (?, ?, ?, ?, ?, ?)
|
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:
|
elif target_research:
|
||||||
payload_str = json.dumps({"research_id": target_research})
|
payload_str = json.dumps({"research_id": target_research})
|
||||||
conn.execute('''
|
conn.execute('''
|
||||||
INSERT INTO commands (town_id, town_name, type, payload, status, player_id)
|
INSERT INTO commands (town_id, town_name, type, payload, status, player_id)
|
||||||
VALUES (?, ?, ?, ?, ?, ?)
|
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))
|
||||||
|
|||||||
Reference in New Issue
Block a user