File: //opt/trading-bot/audit_vh.py
import pymysql
import json
from datetime import datetime
try:
conn = pymysql.connect(
host="localhost",
user="root",
password="Mngt98HY!df^7h",
database="TradingSystem",
cursorclass=pymysql.cursors.DictCursor
)
with conn.cursor() as cur:
print("--- LAST 20 PORTFOLIO STATES ---")
cur.execute("SELECT id, equity, cash, exposure, ts FROM portfolio_state WHERE strategy_name='VolatilityHunter' ORDER BY id DESC LIMIT 20")
for row in cur.fetchall():
print("ID: {} | Equity: {:.2f} | Cash: {:.2f} | Exposure: {:.2f} | TS: {}".format(row['id'], row['equity'], row['cash'], row['exposure'], row['ts']))
print("\n--- LAST 10 SIGNALS ---")
cur.execute("SELECT id, symbol, signal_json, ts FROM signals WHERE strategy_name='VolatilityHunter' ORDER BY id DESC LIMIT 10")
for row in cur.fetchall():
print("ID: {} | Action: {} | TS: {}".format(row['id'], row['signal_json'], row['ts']))
print("\n--- LAST 10 ORDERS ---")
cur.execute("SELECT id, order_id, symbol, side, qty, price, ts FROM orders WHERE strategy_name='VolatilityHunter' ORDER BY id DESC LIMIT 10")
for row in cur.fetchall():
print("ID: {} | OrderID: {} | {} {} {} @ {:.2f} | TS: {}".format(row['id'], row['order_id'], row['side'], row['qty'], row['symbol'], row['price'], row['ts']))
conn.close()
except Exception as e:
print("ERROR: {}".format(e))