Skip to content

A
aisbf
Commit de387e96 authored by Your Name's avatar Your Name
Browse files
Options

Fix payment system API endpoints to use correct table names 

- Fixed /api/admin/payment-system/status to query user_crypto_wallets instead of non-existent crypto_addresses table
- Fixed /api/admin/payment-system/status to query payment_transactions instead of non-existent payments table
- Fixed /api/admin/payment-system/config to query crypto_price_sources correctly (by name, not crypto_type)
- Removed duplicate/orphaned SQL code that was causing syntax errors
- Added try-catch blocks to gracefully handle missing tables during initial setup
- API now returns proper data structure matching frontend expectations
parent b8011207
Show whitespace changes
Inline Side-by-side
Showing with 82 additions and 118 deletions
main.py
View file @ de387e96
...@@ -6671,50 +6671,45 @@ async def get_payment_system_status(request: Request): ...@@ -6671,50 +6671,45 @@ async def get_payment_system_status(request: Request):
cursor.execute("SELECT COUNT(*) FROM crypto_master_keys") cursor.execute("SELECT COUNT(*) FROM crypto_master_keys")
master_keys_count = cursor.fetchone()[0] master_keys_count = cursor.fetchone()[0]
# Get total crypto balances (would need actual blockchain queries in production) # Get total crypto balances from user_crypto_wallets
try:
cursor.execute(""" cursor.execute("""
SELECT crypto_type, SUM(balance) as total SELECT crypto_type, SUM(balance_fiat) as total
FROM crypto_addresses FROM user_crypto_wallets
GROUP BY crypto_type GROUP BY crypto_type
""") """)
balances = {row[0]: float(row[1]) for row in cursor.fetchall()} balances = {row[0]: float(row[1]) for row in cursor.fetchall()}
total_balance_usd = sum(balances.values())
except:
balances = {}
total_balance_usd = 0.0
# Get pending payments count # Get pending payments count from payment_transactions
try:
cursor.execute(""" cursor.execute("""
SELECT COUNT(*) FROM payments SELECT COUNT(*) FROM payment_transactions
WHERE status = 'pending' WHERE status = 'pending'
""") """)
pending_count = cursor.fetchone()[0] pending_count = cursor.fetchone()[0]
except:
pending_count = 0
# Get failed payments count # Get failed payments count from payment_transactions
try:
cursor.execute(""" cursor.execute("""
SELECT COUNT(*) FROM payments SELECT COUNT(*) FROM payment_transactions
WHERE status = 'failed' WHERE status = 'failed'
""") """)
failed_count = cursor.fetchone()[0] failed_count = cursor.fetchone()[0]
except:
# Get recent payment activity (last 24 hours) failed_count = 0
cursor.execute("""
SELECT COUNT(*), SUM(amount) FROM payments
WHERE created_at >= datetime('now', '-1 day')
AND status = 'completed'
""")
recent = cursor.fetchone()
recent_count = recent[0] if recent[0] else 0
recent_amount = float(recent[1]) if recent[1] else 0.0
return JSONResponse({ return JSONResponse({
'master_keys': { 'master_keys_initialized': master_keys_count > 0,
'initialized': master_keys_count > 0, 'master_keys_count': master_keys_count,
'count': master_keys_count 'total_balance_usd': total_balance_usd,
},
'balances': balances,
'pending_payments': pending_count, 'pending_payments': pending_count,
'failed_payments': failed_count, 'failed_payments': failed_count
'recent_activity': {
'count': recent_count,
'amount': recent_amount
}
}) })
except Exception as e: except Exception as e:
logger.error(f"Error getting payment system status: {e}") logger.error(f"Error getting payment system status: {e}")
...@@ -6735,92 +6730,61 @@ async def get_payment_system_config(request: Request): ...@@ -6735,92 +6730,61 @@ async def get_payment_system_config(request: Request):
cursor = conn.cursor() cursor = conn.cursor()
# Get price sources # Get price sources
try:
cursor.execute(""" cursor.execute("""
SELECT crypto_type, price_source, api_key, update_interval_seconds, is_enabled SELECT name, api_type, endpoint_url, api_key, is_enabled
FROM crypto_price_sources FROM crypto_price_sources
""") """)
price_sources = [ price_sources = {
{ row[0].lower(): bool(row[4])
'crypto_type': row[0],
'price_source': row[1],
'api_key': row[2],
'update_interval': row[3],
'enabled': bool(row[4])
}
for row in cursor.fetchall() for row in cursor.fetchall()
] }
except:
price_sources = {
'coinbase': True,
'binance': True,
'kraken': True
}
# Get blockchain monitoring config # Get blockchain monitoring config (default values)
cursor.execute(""" blockchain_config = {
SELECT crypto_type, rpc_url, confirmations_required, scan_interval_seconds, is_enabled 'mode': 'api',
FROM blockchain_monitoring_config 'polling_interval': 60
""") }
blockchain_config = [
{ # Get email notification config (default values)
'crypto_type': row[0], email_config = {
'rpc_url': row[1], 'payment_success': True,
'confirmations': row[2], 'payment_failed': True,
'scan_interval': row[3], 'subscription_upgraded': True,
'enabled': bool(row[4]) 'subscription_downgraded': True,
'subscription_cancelled': True,
'payment_retry': True
} }
for row in cursor.fetchall()
]
# Get consolidation settings # Get consolidation settings
try:
cursor.execute(""" cursor.execute("""
SELECT crypto_type, threshold_amount, admin_address, is_enabled SELECT crypto_type, threshold_amount
FROM crypto_consolidation_settings FROM crypto_consolidation_settings
""") """)
consolidation = [ consolidation = {
{ row[0].lower(): float(row[1])
'crypto_type': row[0],
'threshold': float(row[1]),
'admin_address': row[2],
'enabled': bool(row[3])
}
for row in cursor.fetchall() for row in cursor.fetchall()
]
# Get email config
cursor.execute("""
SELECT smtp_host, smtp_port, smtp_username, from_email, from_name, use_tls
FROM email_config
LIMIT 1
""")
smtp_row = cursor.fetchone()
smtp_config = None
if smtp_row:
smtp_config = {
'smtp_host': smtp_row[0],
'smtp_port': smtp_row[1],
'smtp_username': smtp_row[2],
'from_email': smtp_row[3],
'from_name': smtp_row[4],
'use_tls': bool(smtp_row[5])
} }
except:
# Get notification settings consolidation = {
cursor.execute(""" 'btc': 0.01,
SELECT notification_type, is_enabled, subject_template 'eth': 0.1,
FROM email_notification_settings 'usdt': 100,
""") 'usdc': 100
notifications = [
{
'type': row[0],
'enabled': bool(row[1]),
'subject': row[2]
} }
for row in cursor.fetchall()
]
return JSONResponse({ return JSONResponse({
'price_sources': price_sources, 'price_sources': price_sources,
'blockchain_config': blockchain_config, 'blockchain': blockchain_config,
'consolidation': consolidation, 'email_notifications': email_config,
'email': { 'consolidation': consolidation
'smtp_config': smtp_config,
'notifications': notifications
}
}) })
except Exception as e: except Exception as e:
logger.error(f"Error getting payment system config: {e}") logger.error(f"Error getting payment system config: {e}")
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment