Implantação da função de controle de consolidaçoes pagas e pendentes

app/models/consolidacao.rb

@@ -30,6 +30,24 @@ class Consolidacao < ApplicationRecord
   scope :recentes,           -> { order(created_at: :desc) }
   scope :no_periodo, ->(i, f) { where('data_inicio >= ? AND data_fim <= ?', i, f) }
 
+  # ── Filtro por status de pagamento (derivado dos motoristas) ─
+  # pago_em NÃO-nulo conta como pago; COUNT(pago_em) ignora os NULL.
+  scope :pagamento_pago, -> {
+    where(id: ConsolidacaoMotorista.group(:consolidacao_id)
+                                   .having('COUNT(*) > 0 AND COUNT(*) = COUNT(pago_em)')
+                                   .select(:consolidacao_id))
+  }
+  scope :pagamento_pendente, -> {
+    where(id: ConsolidacaoMotorista.group(:consolidacao_id)
+                                   .having('COUNT(pago_em) = 0')
+                                   .select(:consolidacao_id))
+  }
+  scope :pagamento_parcial, -> {
+    where(id: ConsolidacaoMotorista.group(:consolidacao_id)
+                                   .having('COUNT(pago_em) > 0 AND COUNT(pago_em) < COUNT(*)')
+                                   .select(:consolidacao_id))
+  }
+
   # ── Métodos ─────────────────────────────────────────────────
 
   def arquivar!(user)
@@ -53,6 +71,26 @@ class Consolidacao < ApplicationRecord
     )
   end
 
+  # ── Pagamento (status derivado dos motoristas da consolidação) ──
+  # :pendente (nenhum pago) · :pago (todos pagos) · :parcial (alguns).
+  def status_pagamento
+    total = consolidacao_motoristas.count
+    return :pendente if total.zero?
+
+    pagos = consolidacao_motoristas.pagos.count
+    return :pendente if pagos.zero?
+
+    pagos >= total ? :pago : :parcial
+  end
+
+  def valor_pago
+    consolidacao_motoristas.pagos.sum(:valor_total)
+  end
+
+  def valor_pendente
+    consolidacao_motoristas.pendentes.sum(:valor_total)
+  end
+
   def finalizar!(user)
     return false unless todas_entregas_classificadas?
 

app/models/consolidacao_motorista.rb

@@ -5,6 +5,7 @@ class ConsolidacaoMotorista < ApplicationRecord
   self.table_name = 'consolidacao_motoristas'
 
   belongs_to :consolidacao
+  belongs_to :pagador, class_name: 'User', foreign_key: :pago_por, optional: true
   has_many   :consolidacao_entregas,
              ->(cm) { where(motorista_nome: cm.motorista_nome) },
              foreign_key: :consolidacao_id,
@@ -15,6 +16,22 @@ class ConsolidacaoMotorista < ApplicationRecord
 
   before_save :recalcular_valor
 
+  # ── Pagamento ───────────────────────────────────────────────
+  scope :pagos,     -> { where.not(pago_em: nil) }
+  scope :pendentes, -> { where(pago_em: nil) }
+
+  def pago?
+    pago_em.present?
+  end
+
+  def marcar_pago!(user, forma:)
+    update!(pago_em: Time.current, pago_por: user&.id, forma_pagamento: forma)
+  end
+
+  def cancelar_pagamento!(_user)
+    update!(pago_em: nil, pago_por: nil, forma_pagamento: nil)
+  end
+
   def recalcular_valor
     # Fonte única de verdade: o valor_aplicado capturado no momento da
     # classificação (igual ao ConsolidacaoEntregasController#recalcular_motorista).