import { and, eq, isNull, or, sql } from "drizzle-orm"; import { lancamentos } from "@/db/schema"; import { ACCOUNT_AUTO_INVOICE_NOTE_PREFIX, INITIAL_BALANCE_NOTE, } from "@/lib/contas/constants"; import { toNumber } from "@/lib/dashboard/common"; import { db } from "@/lib/db"; import { getAdminPagadorId } from "@/lib/pagadores/get-admin-id"; export type PaymentConditionSummary = { condition: string; amount: number; percentage: number; transactions: number; }; export type PaymentConditionsData = { conditions: PaymentConditionSummary[]; }; export async function fetchPaymentConditions( userId: string, period: string, ): Promise { const adminPagadorId = await getAdminPagadorId(userId); if (!adminPagadorId) { return { conditions: [] }; } const rows = await db .select({ condition: lancamentos.condition, totalAmount: sql`coalesce(sum(${lancamentos.amount}), 0)`, transactions: sql`count(${lancamentos.id})`, }) .from(lancamentos) .where( and( eq(lancamentos.userId, userId), eq(lancamentos.period, period), eq(lancamentos.transactionType, "Despesa"), eq(lancamentos.pagadorId, adminPagadorId), or( isNull(lancamentos.note), and( sql`${lancamentos.note} != ${INITIAL_BALANCE_NOTE}`, sql`${lancamentos.note} NOT LIKE ${`${ACCOUNT_AUTO_INVOICE_NOTE_PREFIX}%`}`, ), ), ), ) .groupBy(lancamentos.condition); const summaries = rows.map((row) => { const totalAmount = Math.abs(toNumber(row.totalAmount)); const transactions = Number(row.transactions ?? 0); return { condition: row.condition, amount: totalAmount, transactions, }; }); const overallTotal = summaries.reduce((acc, item) => acc + item.amount, 0); const conditions = summaries .map((item) => ({ condition: item.condition, amount: item.amount, transactions: item.transactions, percentage: overallTotal > 0 ? Number(((item.amount / overallTotal) * 100).toFixed(2)) : 0, })) .sort((a, b) => b.amount - a.amount); return { conditions, }; }