feat(#37): módulo de cartão de crédito com faturas mensais

- Migration 011: closing_day/due_day em accounts + tabela credit_bills - CreditBillService: cria/atualiza fatura corrente on-demand no GET /accounts - Widget FATURA ATUAL no dashboard com total e botão PAGAR - AccountsView: campos closing_day/due_day para contas credit + painel fatura - Dashboard: current_bills lista faturas não pagas de todos os cartões Co-Authored-By: Claude Sonnet 4.6 <[email protected]>
2026-05-27 15:12:53 -03:00
parent ee6cd9f37e
commit e3b3433703
17 changed files with 530 additions and 29 deletions
@@ -0,0 +1,103 @@
+package repository
+
+import (
+	"context"
+	"errors"
+
+	"github.com/jackc/pgx/v5"
+	"github.com/jackc/pgx/v5/pgxpool"
+
+	"financeiro-carvalho/internal/model"
+)
+
+type CreditBillRepository interface {
+	ListByAccount(ctx context.Context, accountID int) ([]model.CreditBill, error)
+	GetCurrent(ctx context.Context, accountID int) (*model.CreditBill, error)
+	Upsert(ctx context.Context, in model.CreditBillInput) (*model.CreditBill, error)
+	MarkPaid(ctx context.Context, id int, paymentAccountID *int) error
+}
+
+type creditBillRepo struct{ db *pgxpool.Pool }
+
+func NewCreditBillRepository(db *pgxpool.Pool) CreditBillRepository {
+	return &creditBillRepo{db: db}
+}
+
+func (r *creditBillRepo) ListByAccount(ctx context.Context, accountID int) ([]model.CreditBill, error) {
+	rows, err := r.db.Query(ctx, `
+		SELECT
+			cb.id, cb.account_id, a.name,
+			cb.period_start::text, cb.period_end::text, cb.due_date::text,
+			COALESCE(SUM(t.amount) FILTER (WHERE t.type = 'expense'), 0) AS total,
+			cb.paid, cb.paid_at::text, cb.payment_account_id
+		FROM credit_bills cb
+		JOIN accounts a ON a.id = cb.account_id
+		LEFT JOIN transactions t ON t.account_id = cb.account_id
+			AND t.date >= cb.period_start AND t.date <= cb.period_end
+			AND t.type = 'expense'
+		WHERE cb.account_id = $1
+		GROUP BY cb.id, a.name
+		ORDER BY cb.period_start DESC
+	`, accountID)
+	if err != nil {
+		return nil, err
+	}
+	defer rows.Close()
+	var out []model.CreditBill
+	for rows.Next() {
+		var b model.CreditBill
+		if err := rows.Scan(&b.ID, &b.AccountID, &b.AccountName, &b.PeriodStart, &b.PeriodEnd, &b.DueDate, &b.Total, &b.Paid, &b.PaidAt, &b.PaymentAccountID); err != nil {
+			return nil, err
+		}
+		out = append(out, b)
+	}
+	return out, rows.Err()
+}
+
+func (r *creditBillRepo) GetCurrent(ctx context.Context, accountID int) (*model.CreditBill, error) {
+	var b model.CreditBill
+	err := r.db.QueryRow(ctx, `
+		SELECT
+			cb.id, cb.account_id, a.name,
+			cb.period_start::text, cb.period_end::text, cb.due_date::text,
+			COALESCE(SUM(t.amount) FILTER (WHERE t.type = 'expense'), 0) AS total,
+			cb.paid, cb.paid_at::text, cb.payment_account_id
+		FROM credit_bills cb
+		JOIN accounts a ON a.id = cb.account_id
+		LEFT JOIN transactions t ON t.account_id = cb.account_id
+			AND t.date >= cb.period_start AND t.date <= cb.period_end
+			AND t.type = 'expense'
+		WHERE cb.account_id = $1 AND cb.paid = FALSE
+		GROUP BY cb.id, a.name
+		ORDER BY cb.period_start DESC
+		LIMIT 1
+	`, accountID).Scan(&b.ID, &b.AccountID, &b.AccountName, &b.PeriodStart, &b.PeriodEnd, &b.DueDate, &b.Total, &b.Paid, &b.PaidAt, &b.PaymentAccountID)
+	if errors.Is(err, pgx.ErrNoRows) {
+		return nil, nil
+	}
+	return &b, err
+}
+
+func (r *creditBillRepo) Upsert(ctx context.Context, in model.CreditBillInput) (*model.CreditBill, error) {
+	var b model.CreditBill
+	err := r.db.QueryRow(ctx, `
+		INSERT INTO credit_bills (account_id, period_start, period_end, due_date, payment_account_id)
+		VALUES ($1, $2, $3, $4, $5)
+		ON CONFLICT (account_id, period_start) DO UPDATE
+			SET period_end = EXCLUDED.period_end,
+			    due_date   = EXCLUDED.due_date,
+			    payment_account_id = EXCLUDED.payment_account_id
+		RETURNING id, account_id, period_start::text, period_end::text, due_date::text, paid, paid_at::text, payment_account_id
+	`, in.AccountID, in.PeriodStart, in.PeriodEnd, in.DueDate, in.PaymentAccountID).
+		Scan(&b.ID, &b.AccountID, &b.PeriodStart, &b.PeriodEnd, &b.DueDate, &b.Paid, &b.PaidAt, &b.PaymentAccountID)
+	return &b, err
+}
+
+func (r *creditBillRepo) MarkPaid(ctx context.Context, id int, paymentAccountID *int) error {
+	_, err := r.db.Exec(ctx, `
+		UPDATE credit_bills
+		SET paid = TRUE, paid_at = NOW(), payment_account_id = $2
+		WHERE id = $1
+	`, id, paymentAccountID)
+	return err
+}