Создай свой SaaS и зарабатывай на подписках

╔══════════════════════════════════════════════════════════════════════════╗
║                         SAAS ARCHITECTURE                                 ║
╚══════════════════════════════════════════════════════════════════════════╝

                     ┌─────────────────────────────────┐
                     │         КЛИЕНТЫ (Tenants)       │
                     │   👤 Company A  👤 Company B    │
                     │   👤 Company C  👤 Company D    │
                     └────────────────┬────────────────┘
                                      │
                                      ▼
                     ┌─────────────────────────────────┐
                     │        CDN / Load Balancer      │
                     │         (CloudFlare, AWS)       │
                     └────────────────┬────────────────┘
                                      │
              ┌──────────────────────┴──────────────────────┐
              │                                             │
              ▼                                             ▼
     ┌─────────────────┐                       ┌─────────────────┐
     │    Frontend     │                       │    Backend API  │
     │   React/Vue/    │                       │   FastAPI/      │
     │   Next.js       │                       │   Django/Node   │
     └─────────────────┘                       └────────┬────────┘
                                                         │
              ┌──────────────────────┬──────────────────┴─────────────┐
              │                      │                                │
              ▼                      ▼                                ▼
     ┌─────────────────┐   ┌─────────────────┐      ┌─────────────────┐
     │    Database     │   │     Redis       │      │   File Storage  │
     │   PostgreSQL    │   │   (Cache/Queue) │      │   (S3/Spaces)   │
     └─────────────────┘   └─────────────────┘      └─────────────────┘
              │
              │  tenant_id в каждой записи
              ▼
     ┌─────────────────────────────────────────────────────────┐
     │                    DATABASE SCHEMA                       │
     │  ┌─────────────┐  ┌─────────────┐  ┌─────────────┐      │
     │  │  tenants    │  │   users     │  │  projects   │      │
     │  │  ─────────  │  │  ─────────  │  │  ─────────  │      │
     │  │  id         │  │  id         │  │  id         │      │
     │  │  name       │  │  tenant_id◄─┼──┼─ tenant_id  │      │
     │  │  plan       │  │  email      │  │  name       │      │
     │  │  created_at │  │  role       │  │  data       │      │
     │  └─────────────┘  └─────────────┘  └─────────────┘      │
     └─────────────────────────────────────────────────────────┘

┌──────────────────────────────────────────────────────────────────────────┐
│                        ВНЕШНИЕ СЕРВИСЫ                                    │
├──────────────────────────────────────────────────────────────────────────┤
│  💳 Stripe      — биллинг, подписки, платежи                           │
│  📧 SendGrid    — транзакционные email                                 │
│  🔐 Auth0       — аутентификация (опционально)                         │
│  📊 Mixpanel    — аналитика                                            │
│  🐛 Sentry      — мониторинг ошибок                                     │
└──────────────────────────────────────────────────────────────────────────┘

import stripe
from fastapi import APIRouter, HTTPException

stripe.api_key = "sk_test_..."

router = APIRouter()

# ═══════════════════════════════════════════════════════════════
#                    СОЗДАНИЕ ПОДПИСКИ
# ═══════════════════════════════════════════════════════════════

@router.post("/create-checkout-session")
async def create_checkout_session(plan: str, tenant_id: str):
    """Создать сессию оплаты Stripe"""

    # Цены создаются в Dashboard Stripe
    prices = {
        "starter": "price_starter123",
        "professional": "price_pro456",
        "business": "price_biz789",
    }

    if plan not in prices:
        raise HTTPException(400, "Invalid plan")

    session = stripe.checkout.Session.create(
        mode="subscription",
        payment_method_types=["card"],
        line_items=[{
            "price": prices[plan],
            "quantity": 1,
        }],
        success_url="https://app.example.com/success?session_id={CHECKOUT_SESSION_ID}",
        cancel_url="https://app.example.com/pricing",
        metadata={
            "tenant_id": tenant_id,  # Важно! Связываем с нашим клиентом
        },
        subscription_data={
            "trial_period_days": 14,  # 14 дней бесплатно
        }
    )

    return {"checkout_url": session.url}

# ═══════════════════════════════════════════════════════════════
#                    WEBHOOK ОТ STRIPE
# ═══════════════════════════════════════════════════════════════

@router.post("/webhook")
async def stripe_webhook(request: Request):
    """Обработка событий от Stripe"""

    payload = await request.body()
    sig_header = request.headers.get("stripe-signature")

    try:
        event = stripe.Webhook.construct_event(
            payload, sig_header, "whsec_..."
        )
    except ValueError:
        raise HTTPException(400, "Invalid payload")

    # Обрабатываем разные события
    if event["type"] == "checkout.session.completed":
        session = event["data"]["object"]
        tenant_id = session["metadata"]["tenant_id"]

        # Активируем подписку в нашей БД
        await activate_subscription(tenant_id, session["subscription"])
        print(f"✅ Subscription activated for {tenant_id}")

    elif event["type"] == "invoice.payment_failed":
        # Оплата не прошла — уведомляем клиента
        await send_payment_failed_email(...)

    elif event["type"] == "customer.subscription.deleted":
        # Подписка отменена
        await deactivate_subscription(...)

    return {"status": "ok"}

# ═══════════════════════════════════════════════════════════════
#                    ПОРТАЛ КЛИЕНТА
# ═══════════════════════════════════════════════════════════════

@router.post("/customer-portal")
async def create_portal_session(tenant_id: str):
    """Ссылка на портал управления подпиской"""

    # Получаем stripe_customer_id из нашей БД
    tenant = await get_tenant(tenant_id)

    session = stripe.billing_portal.Session.create(
        customer=tenant.stripe_customer_id,
        return_url="https://app.example.com/settings",
    )

    return {"portal_url": session.url}

from sqlalchemy import Column, String, DateTime, Enum, ForeignKey
from sqlalchemy.orm import relationship
import enum

class PlanType(enum.Enum):
    FREE = "free"
    STARTER = "starter"
    PROFESSIONAL = "professional"
    BUSINESS = "business"
    ENTERPRISE = "enterprise"

class SubscriptionStatus(enum.Enum):
    TRIALING = "trialing"      # Пробный период
    ACTIVE = "active"          # Активная подписка
    PAST_DUE = "past_due"      # Просрочена оплата
    CANCELED = "canceled"      # Отменена
    UNPAID = "unpaid"          # Не оплачена

class Tenant(Base):
    """Клиент (компания) — один tenant"""
    __tablename__ = "tenants"

    id = Column(String, primary_key=True)
    name = Column(String, nullable=False)
    slug = Column(String, unique=True)  # company.yourapp.com

    # Stripe
    stripe_customer_id = Column(String, unique=True)
    stripe_subscription_id = Column(String)

    # Подписка
    plan = Column(Enum(PlanType), default=PlanType.FREE)
    subscription_status = Column(Enum(SubscriptionStatus))
    trial_ends_at = Column(DateTime)
    current_period_end = Column(DateTime)

    # Лимиты по плану
    max_users = Column(Integer, default=1)
    max_projects = Column(Integer, default=5)

    # Отношения
    users = relationship("User", back_populates="tenant")
    created_at = Column(DateTime, default=datetime.utcnow)

class User(Base):
    """Пользователь внутри tenant'а"""
    __tablename__ = "users"

    id = Column(String, primary_key=True)
    tenant_id = Column(String, ForeignKey("tenants.id"), nullable=False)
    email = Column(String, nullable=False)
    role = Column(String, default="member")  # owner, admin, member

    tenant = relationship("Tenant", back_populates="users")