diff --git a/backend/routes/admin.py b/backend/routes/admin.py index c0ef2b7..47f363b 100644 --- a/backend/routes/admin.py +++ b/backend/routes/admin.py @@ -1137,13 +1137,28 @@ async def list_upgrade_requests(user=Depends(require_admin)): with db() as conn: rows = conn.execute(""" SELECT r.id, r.user_id, r.tier, r.message, r.created_at, r.fulfilled_at, - u.name, u.email, u.billing_address + u.name, u.email, u.billing_address, + u.is_founder, u.is_founder_pending, u.referred_by, + COALESCE((SELECT COUNT(*) FROM users WHERE referred_by=u.id), 0) AS referral_count FROM upgrade_requests r JOIN users u ON u.id = r.user_id ORDER BY r.fulfilled_at IS NOT NULL, r.created_at DESC LIMIT 100 """).fetchall() - return [dict(r) for r in rows] + result = [] + for r in rows: + d = dict(r) + d_info = _get_discount_info(conn, r["user_id"]) + d["discount_pct"] = d_info["discount_pct"] + d["discount_reason"] = d_info["reason"] + result.append(d) + return result + + +@router.get("/users/{user_id}/discount") +def get_user_discount(user_id: int, admin=Depends(require_admin)): + with db() as conn: + return _get_discount_info(conn, user_id) @router.post("/upgrade-requests/{req_id}/fulfill") @@ -1268,6 +1283,35 @@ async def fulfill_upgrade_request(req_id: int, user=Depends(require_admin)): return {"ok": True, "tier": req["tier"], "user": req["name"]} +def _get_discount_info(conn, user_id: int) -> dict: + """Berechnet Rabatt für einen User basierend auf Gründer-Status und Referrals.""" + row = conn.execute( + """SELECT u.is_founder, u.is_founder_pending, u.referred_by, + COALESCE((SELECT COUNT(*) FROM users WHERE referred_by=u.id), 0) AS referral_count + FROM users u WHERE u.id=?""", + (user_id,) + ).fetchone() + if not row: + return {"discount_pct": 0, "reason": None, "referral_count": 0} + + if row["is_founder"] or row["is_founder_pending"]: + return {"discount_pct": 100, "reason": "founder", "referral_count": row["referral_count"]} + + referred_by = row["referred_by"] or 0 + if referred_by > 0: + referrer = conn.execute( + "SELECT is_founder, is_founder_pending FROM users WHERE id=?", (referred_by,) + ).fetchone() + if referrer and (referrer["is_founder"] or referrer["is_founder_pending"]): + return {"discount_pct": 50, "reason": "referred_by_founder", "referral_count": row["referral_count"]} + + count = row["referral_count"] + for threshold, pct in [(50, 50), (20, 30), (10, 20)]: + if count >= threshold: + return {"discount_pct": pct, "reason": "referral", "referral_count": count} + return {"discount_pct": 0, "reason": None, "referral_count": count} + + async def _handle_upgrade_invoices(req: dict, new_tier_label: str): """Storniert offene Rechnungen des alten Tiers und legt neuen Entwurf an.""" from routes.invoices import _next_invoice_number @@ -1302,17 +1346,31 @@ async def _handle_upgrade_invoices(req: dict, new_tier_label: str): ).fetchone() billing_address = billing["billing_address"] if billing else None + disc_info = _get_discount_info(conn, req["user_id"]) + discount_pct = disc_info["discount_pct"] + discount_amt = round(price * discount_pct / 100, 2) + after_disc = round(price - discount_amt, 2) + + _AGB = "Jahresbeitrag gem. AGB. Bei vorzeitiger Kündigung keine anteilige Rückerstattung; Zugang bleibt bis Laufzeitende bestehen." + if disc_info["reason"] == "founder": + note = f"Gründer-Sonderkonditionen: {new_tier_label} kostenfrei als Dankeschön für deine Unterstützung als Gründer! {_AGB}" + elif disc_info["reason"] == "referred_by_founder": + note = f"Willkommen in der Gründer-Community! Als persönlich von einem Gründer eingeladenes Mitglied erhältst du dauerhaft {discount_pct}% Rabatt. {_AGB}" + elif disc_info["reason"] == "referral": + note = f"Herzlichen Dank für deine Unterstützung! Für {disc_info['referral_count']} geworbene Freunde erhältst du {discount_pct}% Rabatt. {_AGB}" + else: + note = f"{_AGB} (Upgrade von {req.get('old_tier','Standard')} auf {new_tier_label})" + inv_number = _next_invoice_number(conn) conn.execute(""" INSERT INTO invoices (invoice_number, user_id, recipient_name, recipient_email, recipient_address, description, service_period, amount_net, discount_pct, discount_amount, amount_after_discount, tax_rate, tax_amount, amount_gross, notes) - VALUES (?,?,?,?,?,?,?,?,0,0,?,0,0,?,?) + VALUES (?,?,?,?,?,?,?,?,?,?,?,0,0,?,?) """, ( inv_number, req["user_id"], req["name"], req["email"], billing_address, - description, period, price, price, price, - f"Jahresbeitrag gem. AGB. Bei vorzeitiger Kündigung keine anteilige Rückerstattung; Zugang bleibt bis Laufzeitende bestehen. (Upgrade von {req.get('old_tier','Standard')} auf {new_tier_label})", + description, period, price, discount_pct, discount_amt, after_disc, after_disc, note, )) invoice_id = conn.execute("SELECT last_insert_rowid()").fetchone()[0] conn.execute( diff --git a/backend/scheduler.py b/backend/scheduler.py index edb9963..19c293e 100644 --- a/backend/scheduler.py +++ b/backend/scheduler.py @@ -246,6 +246,49 @@ async def _create_renewal_invoice_draft(user: dict, expires: date, tier_label: s ).fetchone() billing_address = row["billing_address"] if row else None + # Rabatt berechnen (inline, da kein Admin-Import möglich) + disc_row = conn.execute( + """SELECT u.is_founder, u.is_founder_pending, u.referred_by, + COALESCE((SELECT COUNT(*) FROM users WHERE referred_by=u.id), 0) AS referral_count + FROM users u WHERE u.id=?""", + (user["id"],) + ).fetchone() + discount_pct = 0 + discount_reason = None + referral_count = 0 + if disc_row: + referral_count = disc_row["referral_count"] + if disc_row["is_founder"] or disc_row["is_founder_pending"]: + discount_pct = 100 + discount_reason = "founder" + elif (disc_row["referred_by"] or 0) > 0: + ref = conn.execute( + "SELECT is_founder, is_founder_pending FROM users WHERE id=?", + (disc_row["referred_by"],) + ).fetchone() + if ref and (ref["is_founder"] or ref["is_founder_pending"]): + discount_pct = 50 + discount_reason = "referred_by_founder" + if not discount_reason: + for thr, pct in [(50, 50), (20, 30), (10, 20)]: + if referral_count >= thr: + discount_pct = pct + discount_reason = "referral" + break + + discount_amt = round(price * discount_pct / 100, 2) + after_disc = round(price - discount_amt, 2) + + _AGB = "Jahresbeitrag gem. AGB. Bei vorzeitiger Kündigung keine anteilige Rückerstattung; Zugang bleibt bis Laufzeitende bestehen." + if discount_reason == "founder": + notes = f"Gründer-Sonderkonditionen: {tier_label} kostenfrei als Dankeschön für deine Unterstützung als Gründer! {_AGB} (Automatisch erstellt, Ablauf: {expires.strftime('%d.%m.%Y')})" + elif discount_reason == "referred_by_founder": + notes = f"Willkommen in der Gründer-Community! Als persönlich von einem Gründer eingeladenes Mitglied erhältst du dauerhaft {discount_pct}% Rabatt. {_AGB} (Automatisch erstellt, Ablauf: {expires.strftime('%d.%m.%Y')})" + elif discount_reason == "referral": + notes = f"Herzlichen Dank für deine Unterstützung! Für {referral_count} geworbene Freunde erhältst du {discount_pct}% Rabatt. {_AGB} (Automatisch erstellt, Ablauf: {expires.strftime('%d.%m.%Y')})" + else: + notes = f"{_AGB} (Automatisch erstellt, Ablauf: {expires.strftime('%d.%m.%Y')})" + invoice_number = _next_invoice_number(conn) description = f"{tier_label} Jahresabo (Verlängerung)" conn.execute(""" @@ -253,12 +296,11 @@ async def _create_renewal_invoice_draft(user: dict, expires: date, tier_label: s (invoice_number, user_id, recipient_name, recipient_email, recipient_address, description, service_period, amount_net, discount_pct, discount_amount, amount_after_discount, tax_rate, tax_amount, amount_gross, notes) - VALUES (?,?,?,?,?,?,?,?,0,0,?,0,0,?,?) + VALUES (?,?,?,?,?,?,?,?,?,?,?,0,0,?,?) """, ( invoice_number, user["id"], user["name"], user["email"], billing_address, description, period, - price, price, price, - f"Jahresbeitrag gem. AGB. Bei vorzeitiger Kündigung keine anteilige Rückerstattung; Zugang bleibt bis Laufzeitende bestehen. (Automatisch erstellt, Ablauf: {expires.strftime('%d.%m.%Y')})", + price, discount_pct, discount_amt, after_disc, after_disc, notes, )) conn.execute( "INSERT INTO invoice_items (invoice_id, description, quantity, unit_price, total) VALUES (?,?,1,?,?)", diff --git a/backend/static/js/pages/admin.js b/backend/static/js/pages/admin.js index 3a898ae..d3b5fe3 100644 --- a/backend/static/js/pages/admin.js +++ b/backend/static/js/pages/admin.js @@ -3531,8 +3531,14 @@ window.Page_admin = (() => {
${_esc(r.email)}
${tierBadge(r.tier)} + ${r.discount_pct > 0 ? ` + ${r.discount_pct}% Rabatt` : ''} ${r.created_at?.slice(0,10) || ''}
+ ${r.discount_reason === 'founder' ? `
Gründer — kostenfrei
` : ''} + ${r.discount_reason === 'referred_by_founder' ? `
Von Gründer eingeladen
` : ''} + ${r.discount_reason === 'referral' ? `
${r.referral_count} Freunde geworben
` : ''} ${r.message ? `
@@ -3544,6 +3550,9 @@ window.Page_admin = (() => {