114 lines
3.8 KiB
Python
114 lines
3.8 KiB
Python
from flask import Blueprint, jsonify
|
|
from datetime import datetime, timedelta
|
|
from ..db import get_db_connection, release_db_connection
|
|
from ..middleware import token_required
|
|
|
|
dashboard_blueprint = Blueprint('dashboard', __name__)
|
|
|
|
@dashboard_blueprint.route('/dashboard/stats', methods=['GET'])
|
|
@token_required
|
|
def get_stats(user_info):
|
|
company_id = user_info['company_id']
|
|
conn = get_db_connection()
|
|
cur = conn.cursor()
|
|
|
|
# 1. Total cases
|
|
cur.execute("SELECT COUNT(*) FROM cases WHERE user_id = %s", (company_id,))
|
|
total_cases = cur.fetchone()[0]
|
|
|
|
# 2. Cases by status
|
|
cur.execute("SELECT status, COUNT(*) FROM cases WHERE user_id = %s GROUP BY status", (company_id,))
|
|
status_rows = cur.fetchall()
|
|
cases_by_status = {row[0]: row[1] for row in status_rows}
|
|
|
|
# 3. Total active integrations
|
|
cur.execute("SELECT COUNT(*) FROM credentials WHERE user_id = %s", (company_id,))
|
|
total_integrations = cur.fetchone()[0]
|
|
|
|
# 4. List of connected platforms
|
|
cur.execute("SELECT platform FROM credentials WHERE user_id = %s", (company_id,))
|
|
platforms = [row[0] for row in cur.fetchall()]
|
|
|
|
# 5. Recent activity (last 5 cases)
|
|
cur.execute("SELECT id, platform, violator_article, status, created_at FROM cases WHERE user_id = %s ORDER BY created_at DESC LIMIT 5", (company_id,))
|
|
recent_rows = cur.fetchall()
|
|
recent_activity = [
|
|
{
|
|
"id": r[0],
|
|
"platform": r[1],
|
|
"article": r[2],
|
|
"status": r[3],
|
|
"date": r[4].isoformat() if r[4] else None
|
|
} for r in recent_rows
|
|
]
|
|
|
|
# 6. Trend data (last 7 days)
|
|
trend = []
|
|
for i in range(6, -1, -1):
|
|
day = (datetime.utcnow() - timedelta(days=i)).date()
|
|
cur.execute("SELECT COUNT(*) FROM cases WHERE user_id = %s AND created_at::date = %s", (company_id, day))
|
|
count = cur.fetchone()[0]
|
|
trend.append({
|
|
"date": day.strftime('%d.%m'),
|
|
"count": count
|
|
})
|
|
|
|
# 5. Multi-account stores summary
|
|
cur.execute("SELECT id, platform, name FROM credentials WHERE user_id = %s", (company_id,))
|
|
stores_rows = cur.fetchall()
|
|
stores = []
|
|
total_sales = 0
|
|
|
|
for s in stores_rows:
|
|
import random
|
|
daily_sales = random.randint(5000, 50000)
|
|
total_sales += daily_sales
|
|
|
|
# Моделируем остатки (Inventory)
|
|
current_stock = random.randint(10, 500)
|
|
sales_velocity = random.randint(5, 40) # шт в день
|
|
days_left = current_stock // sales_velocity if sales_velocity > 0 else 999
|
|
|
|
stores.append({
|
|
"id": s[0],
|
|
"platform": s[1],
|
|
"name": s[2],
|
|
"status": "active",
|
|
"daily_sales": daily_sales,
|
|
"stock": current_stock,
|
|
"velocity": sales_velocity,
|
|
"days_left": days_left
|
|
})
|
|
|
|
release_db_connection(conn)
|
|
|
|
return jsonify({
|
|
"total_cases": total_cases,
|
|
"cases_by_status": cases_by_status,
|
|
"total_integrations": total_integrations,
|
|
"total_sales": total_sales,
|
|
"platforms": platforms,
|
|
"recent_activity": recent_activity,
|
|
"trend": trend,
|
|
"stores": stores
|
|
})
|
|
|
|
@dashboard_blueprint.route('/dashboard/logs', methods=['GET'])
|
|
@token_required
|
|
def get_logs(user_info):
|
|
company_id = user_info['company_id']
|
|
conn = get_db_connection()
|
|
cur = conn.cursor()
|
|
cur.execute("SELECT action, details, created_at FROM audit_log WHERE user_id = %s ORDER BY created_at DESC LIMIT 20", (company_id,))
|
|
rows = cur.fetchall()
|
|
release_db_connection(conn)
|
|
|
|
logs = [
|
|
{
|
|
"action": r[0],
|
|
"details": r[1],
|
|
"date": r[2].isoformat() if r[2] else None
|
|
} for r in rows
|
|
]
|
|
return jsonify(logs)
|