704f472729
Migration activity_events (uuid id, organization_id FK CASCADE, kind ENUM PG natif relance_sent/invoice_paid/invoice_imported/warning_drafted, at, label HTML léger, meta jsonb). Append-only — pas de mutation. Index (org, at).
Schema rules : kind typé en union + meta typé { invoiceId?, clientId?, planStepOrder? }.
Service activity_recorder.ts : recordActivity({orgId, kind, label, meta, trx?}). Branché dans :
- InvoicesController.markPaid → invoice_paid
- ImportBatchesController.validateDraft → invoice_imported
À venir : SendRelanceJob (relance_sent + warning_drafted) quand BullMQ sera là.
Service dashboard.ts :
- computeKpis(orgId) : 1 requête FILTER pour les counts par status + 1 requête pour les sommes paid this month / prev month / DSO. miseEnDemeurePending=0 et percentile=undefined V1 (placeholders honnêtes plutôt que faux chiffres).
- topLatePayers(orgId, 5) : INNER JOIN clients + agrégation count() par client_id, due_date < today + status actif.
Controller DashboardController :
- GET /dashboard/kpis : computeKpis
- GET /dashboard/activity : 20 derniers events de l'org, plus récent en tête
- GET /dashboard/top-late : top 5
Routes /api/v1/dashboard/* (auth requise).
Bruno : nouveau dossier 07-Dashboard avec 3 requêtes documentées.
Pour générer du contenu activity feed : encaisser une facture (Invoices → Mark paid) ou valider un draft (Imports → Validate). KPIs : créer des factures puis les marquer payées (paidAt rentre dans les sommes).
66 lines
1.8 KiB
TypeScript
66 lines
1.8 KiB
TypeScript
import ActivityEvent from '#models/activity_event'
|
|
import { computeKpis, topLatePayers } from '#services/dashboard'
|
|
import type { HttpContext } from '@adonisjs/core/http'
|
|
import { Exception } from '@adonisjs/core/exceptions'
|
|
|
|
const ACTIVITY_DEFAULT_LIMIT = 20
|
|
|
|
function requireOrgId(auth: HttpContext['auth']): string {
|
|
const user = auth.getUserOrFail()
|
|
if (!user.organizationId) {
|
|
throw new Exception('Aucune organisation rattachée', { status: 404, code: 'not_found' })
|
|
}
|
|
return user.organizationId
|
|
}
|
|
|
|
export default class DashboardController {
|
|
/**
|
|
* GET /dashboard/kpis
|
|
*
|
|
* Cf. service dashboard.ts — quelques metrics V1 sont placeholder
|
|
* (miseEnDemeurePending=0 tant que RelanceTask pas branché, percentile
|
|
* undefined tant que cohorte trop petite).
|
|
*/
|
|
async kpis({ auth, response }: HttpContext) {
|
|
const organizationId = requireOrgId(auth)
|
|
const data = await computeKpis(organizationId)
|
|
return response.json({ data })
|
|
}
|
|
|
|
/**
|
|
* GET /dashboard/activity
|
|
*
|
|
* Journal append-only. Limit 20 par défaut, plus récent en tête.
|
|
*/
|
|
async activity({ auth, response }: HttpContext) {
|
|
const organizationId = requireOrgId(auth)
|
|
|
|
const events = await ActivityEvent.query()
|
|
.where('organization_id', organizationId)
|
|
.orderBy('at', 'desc')
|
|
.limit(ACTIVITY_DEFAULT_LIMIT)
|
|
|
|
return response.json({
|
|
data: events.map((e) => ({
|
|
id: e.id,
|
|
kind: e.kind,
|
|
at: e.at.toISO()!,
|
|
label: e.label,
|
|
meta: e.meta,
|
|
})),
|
|
})
|
|
}
|
|
|
|
/**
|
|
* GET /dashboard/top-late
|
|
*
|
|
* Top 5 clients avec le plus de factures en retard (status actif +
|
|
* due_date dépassée).
|
|
*/
|
|
async topLate({ auth, response }: HttpContext) {
|
|
const organizationId = requireOrgId(auth)
|
|
const data = await topLatePayers(organizationId)
|
|
return response.json({ data })
|
|
}
|
|
}
|