Function batch_check_subscription

src/web/routes/payment.py:3265–3322

批量检测账号订阅状态

(request: BatchCheckSubscriptionRequest)

@router.post("/accounts/batch-check-subscription")
def batch_check_subscription(request: BatchCheckSubscriptionRequest):
    """批量检测账号订阅状态"""
    explicit_proxy = _normalize_proxy_value(request.proxy)

    results = {"success_count": 0, "failed_count": 0, "details": []}

    with get_db() as db:
        ids = resolve_account_ids(
            db, request.ids, request.select_all,
            request.status_filter, request.email_service_filter, request.search_filter
        )
        for account_id in ids:
            account = db.query(Account).filter(Account.id == account_id).first()
            if not account:
                results["failed_count"] += 1
                results["details"].append(
                    {"id": account_id, "email": None, "success": False, "error": "账号不存在"}
                )
                continue

            try:
                runtime_proxy = _resolve_runtime_proxy(explicit_proxy, account)
                detail, refreshed = _check_subscription_detail_with_retry(
                    db=db,
                    account=account,
                    proxy=runtime_proxy,
                    allow_token_refresh=True,
                )
                status = str(detail.get("status") or "free").lower()
                confidence = str(detail.get("confidence") or "low").lower()

                if status in ("plus", "team"):
                    account.subscription_type = status
                    account.subscription_at = utcnow_naive()
                elif status == "free" and confidence == "high":
                    account.subscription_type = None
                    account.subscription_at = None

                db.commit()
                results["success_count"] += 1
                results["details"].append(
                    {
                        "id": account_id,
                        "email": account.email,
                        "success": True,
                        "subscription_type": status,
                        "confidence": confidence,
                        "source": detail.get("source"),
                        "token_refreshed": refreshed,
                    }
                )
            except Exception as e:
                results["failed_count"] += 1
                results["details"].append(
                    {"id": account_id, "email": account.email, "success": False, "error": str(e)}
                )

    return results