diff --git a/src/components/SiteHeader.tsx b/src/components/SiteHeader.tsx
index 3d3f8f0..dd5b682 100644
--- a/src/components/SiteHeader.tsx
+++ b/src/components/SiteHeader.tsx
@@ -18,7 +18,11 @@ export async function SiteHeader() {
const isAdmin = u?.role === UserRole.ADMIN;
const isOwner = u?.role === UserRole.OWNER || isAdmin;
const isRentalProvider = u?.role === UserRole.RENTAL_PROVIDER || isAdmin;
- const rentalEnabled = await isPluginEnabled("gear-rental");
+ const isCeManager = u?.role === UserRole.CE_MANAGER || isAdmin;
+ const [rentalEnabled, ceEnabled] = await Promise.all([
+ isPluginEnabled("gear-rental"),
+ isPluginEnabled("ce-management"),
+ ]);
return (
@@ -72,6 +76,11 @@ export async function SiteHeader() {
Espace prestataire
) : null}
+ {isCeManager && ceEnabled ? (
+ {
+ if (role === UserRole.ADMIN) return true;
+ if (role !== UserRole.CE_MANAGER) return false;
+
+ const [carbet, user] = await Promise.all([
+ prisma.carbet.findUnique({
+ where: { id: carbetId },
+ select: {
+ ownerId: true,
+ organizations: { select: { organizationId: true } },
+ },
+ }),
+ prisma.user.findUnique({
+ where: { id: userId },
+ select: { organizationId: true },
+ }),
+ ]);
+ if (!carbet || !user?.organizationId) return false;
+ if (carbet.ownerId === userId) return true;
+ return carbet.organizations.some((m) => m.organizationId === user.organizationId);
+}
+
+/**
+ * Garantit que l'org du user est `approved=true`. Sinon redirige vers le dashboard
+ * /espace-ce qui affiche une bannière « En attente de validation ».
+ * Utiliser sur les pages qui doivent publier du contenu (créer carbet/item).
+ */
+export async function requireApprovedOrg() {
+ const org = await getCurrentCeOrganization();
+ if (!org || !org.approved) {
+ redirect("/espace-ce?pending=1");
+ }
+ return org;
+}
diff --git a/src/lib/ce-dashboard.ts b/src/lib/ce-dashboard.ts
new file mode 100644
index 0000000..c5edb40
--- /dev/null
+++ b/src/lib/ce-dashboard.ts
@@ -0,0 +1,90 @@
+import "server-only";
+
+import {
+ BookingStatus,
+ RentalBookingStatus,
+} from "@/generated/prisma/enums";
+import { prisma } from "@/lib/prisma";
+
+/**
+ * KPIs agrégés à l'échelle d'une organisation CE.
+ * - carbets : nombre de carbets co-gérés via OrganizationCarbetMembership
+ * - rentalItems : items des providers liés à l'org
+ * - bookings30d : bookings confirmées sur les carbets de l'org (30 derniers jours)
+ * - rentalBookings30d : RentalBooking confirmées sur les providers de l'org
+ * - revenue30d : somme des amounts (booking + rental) sur 30j
+ */
+export async function getCeOrgKpis(organizationId: string) {
+ const since = new Date(Date.now() - 30 * 86_400_000);
+
+ const [carbetsCount, providers, bookings30d, rentalBookings30d] = await Promise.all([
+ prisma.organizationCarbetMembership.count({ where: { organizationId } }),
+ prisma.rentalProvider.findMany({
+ where: { organizationId },
+ select: {
+ id: true,
+ approved: true,
+ active: true,
+ _count: { select: { items: true } },
+ },
+ }),
+ prisma.booking.findMany({
+ where: {
+ status: BookingStatus.CONFIRMED,
+ createdAt: { gte: since },
+ carbet: { organizations: { some: { organizationId } } },
+ },
+ select: { amount: true, currency: true },
+ }),
+ prisma.rentalBooking.findMany({
+ where: {
+ status: RentalBookingStatus.CONFIRMED,
+ createdAt: { gte: since },
+ provider: { organizationId },
+ },
+ select: { amount: true, currency: true },
+ }),
+ ]);
+
+ const itemsCount = providers.reduce((s, p) => s + p._count.items, 0);
+ const revenue30d = [
+ ...bookings30d.map((b) => Number(b.amount)),
+ ...rentalBookings30d.map((r) => Number(r.amount)),
+ ].reduce((s, n) => s + n, 0);
+
+ return {
+ carbetsCount,
+ providersCount: providers.length,
+ rentalItemsCount: itemsCount,
+ rentalProviderApproved: providers.every((p) => p.approved),
+ bookings30dCount: bookings30d.length,
+ rentalBookings30dCount: rentalBookings30d.length,
+ revenue30d,
+ };
+}
+
+/**
+ * Liste les carbets co-gérés par une org (joinés via membership).
+ */
+export async function listCeCarbets(organizationId: string) {
+ const memberships = await prisma.organizationCarbetMembership.findMany({
+ where: { organizationId },
+ orderBy: { addedAt: "desc" },
+ select: {
+ carbet: {
+ select: {
+ id: true,
+ slug: true,
+ title: true,
+ river: true,
+ status: true,
+ capacity: true,
+ nightlyPrice: true,
+ ownerId: true,
+ owner: { select: { firstName: true, lastName: true } },
+ },
+ },
+ },
+ });
+ return memberships.map((m) => m.carbet);
+}
diff --git a/src/lib/email.ts b/src/lib/email.ts
index 2e9f79a..070370f 100644
--- a/src/lib/email.ts
+++ b/src/lib/email.ts
@@ -186,6 +186,44 @@ export async function sendBookingConfirmed(
});
}
+export async function sendNewCeRequest(
+ orgName: string,
+ managerEmail: string,
+): Promise {
+ const adminEmail = process.env.ADMIN_NOTIFICATION_EMAIL ?? "contact@karbe.cosmolan.fr";
+ await sendEmail({
+ to: adminEmail,
+ subject: `Nouvelle demande CE — ${orgName}`,
+ html: wrap(
+ "Demande de Comité d'Entreprise à valider",
+ `Une organisation vient de s'inscrire en tant que Comité d'Entreprise.
+
+ Nom : ${orgName}
+ Email du manager : ${managerEmail}
+
+ Valider sur l'admin Karbé
+ Le CE_MANAGER peut accéder à son dashboard mais ne peut rien publier tant que Organization.approved=false.
`,
+ ),
+ });
+}
+
+export async function sendCeApproved(
+ to: string,
+ firstName: string,
+ orgName: string,
+): Promise {
+ await sendEmail({
+ to,
+ subject: `Votre CE « ${orgName} » est validé sur Karbé`,
+ html: wrap(
+ "Organisation validée",
+ `Bonjour ${firstName},
+ Votre Comité d'Entreprise ${orgName} vient d'être validé. Vous pouvez désormais publier vos carbets et activer la location de matériel pour vos membres et le public touriste.
+ Accéder à mon espace CE
`,
+ ),
+ });
+}
+
export async function sendNewRentalProviderRequest(
providerName: string,
userEmail: string,