增加后台支付列表，修改前台有问题也能支付成功，增加支付日志

video-gen-api/app/api/v1/admin.py

@@ -440,6 +440,123 @@ async def batch_update_payment_configs(
     return {"ok": True}
 
 
+@router.get("/payment-stats")
+async def get_payment_stats(
+    admin: User = Depends(get_admin_user),
+    db: AsyncSession = Depends(get_db),
+):
+    """Return payment statistics for admin dashboard."""
+    from sqlalchemy import func
+
+    # Status breakdown
+    status_result = await db.execute(
+        select(
+            PaymentOrder.status,
+            func.count().label("count"),
+            func.coalesce(func.sum(PaymentOrder.amount), 0).label("amount"),
+        ).group_by(PaymentOrder.status)
+    )
+    by_status = {}
+    for row in status_result.all():
+        by_status[row.status] = {"count": row.count, "amount": float(row.amount)}
+
+    # Today's stats
+    today_start = datetime.now().replace(hour=0, minute=0, second=0, microsecond=0)
+    today_result = await db.execute(
+        select(
+            func.count().label("paid_count"),
+            func.coalesce(func.sum(PaymentOrder.amount), 0).label("paid_amount"),
+        ).where(
+            PaymentOrder.status == "paid",
+            PaymentOrder.paid_at >= today_start,
+        )
+    )
+    today_row = today_result.one()
+
+    # Recent 50 orders
+    recent_result = await db.execute(
+        select(PaymentOrder)
+        .order_by(PaymentOrder.created_at.desc())
+        .limit(50)
+    )
+    recent = recent_result.scalars().all()
+
+    return {
+        "by_status": by_status,
+        "today": {
+            "paid_count": today_row.paid_count,
+            "paid_amount": float(today_row.paid_amount),
+        },
+        "recent": [
+            {
+                "id": o.id,
+                "order_no": o.order_no,
+                "user_id": o.user_id,
+                "amount": o.amount,
+                "credits": o.credits,
+                "payment_method": o.payment_method,
+                "status": o.status,
+                "trade_no": o.trade_no,
+                "paid_at": o.paid_at.isoformat() if o.paid_at else None,
+                "created_at": o.created_at.isoformat() if o.created_at else None,
+            }
+            for o in recent
+        ],
+    }
+
+
+@router.get("/payment-orders")
+async def get_admin_payment_orders(
+    method: str | None = None,
+    status: str | None = None,
+    page: int = 1,
+    page_size: int = 20,
+    admin: User = Depends(get_admin_user),
+    db: AsyncSession = Depends(get_db),
+):
+    """Return paginated payment orders for admin."""
+    query = select(PaymentOrder)
+    if method:
+        query = query.where(PaymentOrder.payment_method == method)
+    if status:
+        query = query.where(PaymentOrder.status == status)
+
+    # Count total
+    count_result = await db.execute(
+        select(func.count()).select_from(query.subquery())
+    )
+    total = count_result.scalar() or 0
+
+    # Paginated results
+    result = await db.execute(
+        query.order_by(PaymentOrder.created_at.desc())
+        .offset((page - 1) * page_size)
+        .limit(page_size)
+    )
+    orders = result.scalars().all()
+
+    return {
+        "total": total,
+        "page": page,
+        "page_size": page_size,
+        "items": [
+            {
+                "id": o.id,
+                "order_no": o.order_no,
+                "user_id": o.user_id,
+                "amount": o.amount,
+                "credits": o.credits,
+                "payment_method": o.payment_method,
+                "status": o.status,
+                "trade_no": o.trade_no,
+                "paid_at": o.paid_at.isoformat() if o.paid_at else None,
+                "created_at": o.created_at.isoformat() if o.created_at else None,
+            }
+            for o in orders
+        ],
+    }
+
+
 @router.put("/payment-configs/{config_id}")
 async def update_payment_config(
     config_id: str,
@@ -1250,3 +1367,76 @@ async def admin_generate_video(
             await db.flush()
 
     return {"message": "ok", "record_id": record_id}
+
+
+# ── Payment Stats ────────────────────────────────────────
+
+@router.get("/payment-stats")
+async def get_payment_stats(
+    admin: User = Depends(get_admin_user),
+    db: AsyncSession = Depends(get_db),
+):
+    """Payment statistics for admin dashboard."""
+    from app.models.payment_order import PaymentOrder
+    from datetime import datetime
+
+    # Count and revenue by status
+    rows = (await db.execute(
+        select(
+            PaymentOrder.status,
+            PaymentOrder.payment_method,
+            func.count(PaymentOrder.id).label("count"),
+            func.coalesce(func.sum(PaymentOrder.amount), 0).label("total_amount"),
+        ).group_by(PaymentOrder.status, PaymentOrder.payment_method)
+    )).all()
+
+    by_status: dict[str, dict] = {}
+    for r in rows:
+        s = r.status
+        if s not in by_status:
+            by_status[s] = {"count": 0, "amount": 0.0}
+        by_status[s]["count"] += r.count
+        by_status[s]["amount"] += float(r.total_amount)
+
+    # Recent orders (last 50)
+    recent = (await db.execute(
+        select(PaymentOrder)
+        .order_by(PaymentOrder.created_at.desc())
+        .limit(50)
+    )).scalars().all()
+
+    # Today stats
+    today_start = datetime.now().replace(hour=0, minute=0, second=0, microsecond=0)
+    today_paid = (await db.execute(
+        select(
+            func.count(PaymentOrder.id),
+            func.coalesce(func.sum(PaymentOrder.amount), 0),
+        ).where(
+            PaymentOrder.status == "paid",
+            PaymentOrder.paid_at >= today_start,
+        )
+    )).first()
+    today_count, today_amount = (today_paid or (0, 0))
+
+    return {
+        "by_status": by_status,
+        "today": {
+            "paid_count": int(today_count or 0),
+            "paid_amount": float(today_amount or 0),
+        },
+        "recent": [
+            {
+                "id": o.id,
+                "order_no": o.order_no,
+                "user_id": o.user_id,
+                "amount": o.amount,
+                "credits": o.credits,
+                "payment_method": o.payment_method,
+                "status": o.status,
+                "trade_no": o.trade_no,
+                "created_at": _iso(o.created_at),
+                "paid_at": _iso(o.paid_at),
+            }
+            for o in recent
+        ],
+    }