feat(web+api): redesign ClientsPage/OrdersPage e corrige dados empresa 9001
Web — ClientsPage: - Redesign completo: métricas reais via usePortfolioStats (4 queries count), donut Chart.js com totais reais, tabela sem ellipsis, coluna Cliente com nome fantasia/razão/CNPJ completos, drawer de detalhes e análise comercial, cards mobile, filtros de status/busca em tempo real. - Dados reais: substitui mock por useClientList/useClientDetail/useClientOrders; remove tipos fictícios (prospect/lead, cidade, totalComprado). Web — OrdersPage: - Métricas reais via useOrderStats (contagens por situa, não da página atual). - Coluna Cliente sem truncamento (minWidth: 240). - Cabeçalho, filtros e layout alinhados ao padrão da ClientsPage. API — orders.service.ts: - Normalização situa SIG→SAR: SIG usa 5=Cancelado; SAR usa 3=Cancelado. sigToSar(5→3) no mapper; sarToSig(3→5) no filtro SQL. API — clients.service.ts: - dt_ultima_compra corrigida: JOIN duplo (vw_pedidos_erp + sar.pedidos) com GREATEST() — clientes com histórico ERP mas sem pedido SAR deixam de aparecer todos como Inativo. - Filtro de activityStatus movido para SQL — total e paginação corretos. - findOne() atualizado com o mesmo JOIN duplo. Infra — .env: - DEV_EMPRESA_ID: 1 → 9001 — API aponta para dados reais da empresa SIG. Ex: pedido nº 141022 passa de R$1.765,48 para R$2.454,90. Docs — sarweb_views.sql: - Documenta as views reais em schema sar; remove schema sarweb inexistente. Co-Authored-By: Claude Sonnet 4.6 (1M context) <noreply@anthropic.com>
This commit is contained in:
@@ -13,6 +13,7 @@ import type { WorkspaceClsStore } from '../workspace/workspace.types';
|
||||
const ALERT_DAYS = 30;
|
||||
const INACTIVE_DAYS = 60;
|
||||
|
||||
// Usado apenas por findOne (já tem dt_ultima_compra calculado pelo SQL)
|
||||
function activityStatus(dtUltimaCompra: Date | null): ActivityStatus {
|
||||
if (!dtUltimaCompra) return 'inactive';
|
||||
const days = Math.floor((Date.now() - dtUltimaCompra.getTime()) / 86_400_000);
|
||||
@@ -51,6 +52,34 @@ interface ClientRow {
|
||||
dt_atual: string | null;
|
||||
}
|
||||
|
||||
// SQL compartilhado: dois subqueries que calculam a data do último pedido
|
||||
// considerando TANTO pedidos ERP (vw_pedidos_erp) QUANTO pedidos SAR (tabela pedidos).
|
||||
// vw_pedidos_erp: situa SIG 5=Cancelado (excluir); pedidos SAR: situa 3=Cancelado (excluir).
|
||||
const PEDIDOS_JOINS = `
|
||||
LEFT JOIN (
|
||||
SELECT id_cliente, id_empresa, MAX(dt_pedido) AS dt_max
|
||||
FROM vw_pedidos_erp
|
||||
WHERE situa NOT IN (5)
|
||||
GROUP BY id_cliente, id_empresa
|
||||
) erp_ped ON erp_ped.id_cliente = c.id_cliente AND erp_ped.id_empresa = c.id_empresa
|
||||
LEFT JOIN (
|
||||
SELECT id_cliente, id_empresa, MAX(dt_pedido) AS dt_max
|
||||
FROM pedidos
|
||||
WHERE situa != 3
|
||||
GROUP BY id_cliente, id_empresa
|
||||
) sar_ped ON sar_ped.id_cliente = c.id_cliente AND sar_ped.id_empresa = c.id_empresa
|
||||
`;
|
||||
|
||||
// Expressão SQL que calcula o activity_status a partir das datas dos dois joins.
|
||||
const ACTIVITY_CASE = (alias_erp = 'erp_ped', alias_sar = 'sar_ped') => `
|
||||
CASE
|
||||
WHEN GREATEST(${alias_erp}.dt_max, ${alias_sar}.dt_max) IS NULL THEN 'inactive'
|
||||
WHEN (CURRENT_DATE - GREATEST(${alias_erp}.dt_max, ${alias_sar}.dt_max)::date) >= ${INACTIVE_DAYS} THEN 'inactive'
|
||||
WHEN (CURRENT_DATE - GREATEST(${alias_erp}.dt_max, ${alias_sar}.dt_max)::date) >= ${ALERT_DAYS} THEN 'alert'
|
||||
ELSE 'active'
|
||||
END
|
||||
`;
|
||||
|
||||
@Injectable()
|
||||
export class ClientsService {
|
||||
constructor(private readonly cls: ClsService<WorkspaceClsStore>) {}
|
||||
@@ -72,56 +101,59 @@ export class ClientsService {
|
||||
? `AND (c.nome ILIKE '%${escSql(q)}%' OR c.cgcpf LIKE '%${escSql(q)}%')`
|
||||
: '';
|
||||
|
||||
const rows = await prisma.$queryRawUnsafe<ClientRow[]>(`
|
||||
SELECT
|
||||
c.id_cliente,
|
||||
c.id_empresa,
|
||||
c.nome,
|
||||
c.razao,
|
||||
c.cgcpf,
|
||||
c.email,
|
||||
c.telefone,
|
||||
c.cod_vendedor,
|
||||
c.limite_credito::text,
|
||||
c.ativo,
|
||||
c.pessoa,
|
||||
c.inscricao_estadual,
|
||||
c.endereco,
|
||||
c.num_endereco,
|
||||
c.bairro,
|
||||
c.cep,
|
||||
c.ddd,
|
||||
c.obs,
|
||||
c.cod_pauta,
|
||||
c.dt_cadastro::text,
|
||||
c.dt_atual::text,
|
||||
MAX(p.dt_pedido) AS dt_ultima_compra
|
||||
FROM vw_clientes c
|
||||
LEFT JOIN pedidos p ON p.id_cliente = c.id_cliente AND p.id_empresa = c.id_empresa AND p.situa != 3
|
||||
WHERE c.id_empresa = ${idEmpresa}
|
||||
AND c.ativo = 1
|
||||
${vendedorFilter}
|
||||
${searchFilter}
|
||||
GROUP BY
|
||||
c.id_cliente, c.id_empresa, c.nome, c.razao, c.cgcpf, c.email,
|
||||
c.telefone, c.cod_vendedor, c.limite_credito, c.ativo, c.pessoa,
|
||||
c.inscricao_estadual, c.endereco, c.num_endereco, c.bairro, c.cep,
|
||||
c.ddd, c.obs, c.cod_pauta, c.dt_cadastro, c.dt_atual
|
||||
ORDER BY c.nome
|
||||
LIMIT ${limit} OFFSET ${offset}
|
||||
`);
|
||||
// Filtro de status calculado em SQL — evita paginação quebrada do filtro pós-SQL
|
||||
const statusFilter = status ? `AND ${ACTIVITY_CASE()} = '${status}'` : '';
|
||||
|
||||
const totalRows = await prisma.$queryRawUnsafe<[{ count: string }]>(`
|
||||
SELECT COUNT(*)::text AS count
|
||||
FROM vw_clientes c
|
||||
const baseWhere = `
|
||||
WHERE c.id_empresa = ${idEmpresa}
|
||||
AND c.ativo = 1
|
||||
${vendedorFilter}
|
||||
${searchFilter}
|
||||
`);
|
||||
${statusFilter}
|
||||
`;
|
||||
|
||||
const [rows, totalRows] = await Promise.all([
|
||||
prisma.$queryRawUnsafe<ClientRow[]>(`
|
||||
SELECT
|
||||
c.id_cliente,
|
||||
c.id_empresa,
|
||||
c.nome,
|
||||
c.razao,
|
||||
c.cgcpf,
|
||||
c.email,
|
||||
c.telefone,
|
||||
c.cod_vendedor,
|
||||
c.limite_credito::text,
|
||||
c.ativo,
|
||||
c.pessoa,
|
||||
c.inscricao_estadual,
|
||||
c.endereco,
|
||||
c.num_endereco,
|
||||
c.bairro,
|
||||
c.cep,
|
||||
c.ddd,
|
||||
c.obs,
|
||||
c.cod_pauta,
|
||||
c.dt_cadastro::text,
|
||||
c.dt_atual::text,
|
||||
GREATEST(erp_ped.dt_max, sar_ped.dt_max) AS dt_ultima_compra
|
||||
FROM vw_clientes c
|
||||
${PEDIDOS_JOINS}
|
||||
${baseWhere}
|
||||
ORDER BY c.nome
|
||||
LIMIT ${limit} OFFSET ${offset}
|
||||
`),
|
||||
prisma.$queryRawUnsafe<[{ count: string }]>(`
|
||||
SELECT COUNT(*)::text AS count
|
||||
FROM vw_clientes c
|
||||
${PEDIDOS_JOINS}
|
||||
${baseWhere}
|
||||
`),
|
||||
]);
|
||||
|
||||
const total = parseInt(totalRows[0]?.count ?? '0', 10);
|
||||
|
||||
let mapped: ClientSummary[] = rows.map((r) => ({
|
||||
const mapped: ClientSummary[] = rows.map((r) => ({
|
||||
idCliente: Number(r.id_cliente),
|
||||
idEmpresa: Number(r.id_empresa),
|
||||
nome: r.nome,
|
||||
@@ -135,8 +167,6 @@ export class ClientsService {
|
||||
dtUltimaCompra: r.dt_ultima_compra?.toISOString() ?? null,
|
||||
}));
|
||||
|
||||
if (status) mapped = mapped.filter((c) => c.activityStatus === status);
|
||||
|
||||
return { data: mapped, total, page, limit };
|
||||
}
|
||||
|
||||
@@ -152,14 +182,10 @@ export class ClientsService {
|
||||
c.ativo, c.pessoa, c.inscricao_estadual, c.endereco, c.num_endereco,
|
||||
c.bairro, c.cep, c.ddd, c.obs, c.cod_pauta,
|
||||
c.dt_cadastro::text, c.dt_atual::text,
|
||||
MAX(p.dt_pedido) AS dt_ultima_compra
|
||||
GREATEST(erp_ped.dt_max, sar_ped.dt_max) AS dt_ultima_compra
|
||||
FROM vw_clientes c
|
||||
LEFT JOIN pedidos p ON p.id_cliente = c.id_cliente AND p.id_empresa = c.id_empresa AND p.situa != 3
|
||||
${PEDIDOS_JOINS}
|
||||
WHERE c.id_empresa = ${idEmpresa} AND c.id_cliente = ${idCliente}
|
||||
GROUP BY c.id_cliente, c.id_empresa, c.nome, c.razao, c.cgcpf, c.email,
|
||||
c.telefone, c.cod_vendedor, c.limite_credito, c.ativo, c.pessoa,
|
||||
c.inscricao_estadual, c.endereco, c.num_endereco, c.bairro, c.cep,
|
||||
c.ddd, c.obs, c.cod_pauta, c.dt_cadastro, c.dt_atual
|
||||
LIMIT 1
|
||||
`);
|
||||
|
||||
|
||||
@@ -13,11 +13,23 @@ import type {
|
||||
import type { WorkspaceClsStore } from '../workspace/workspace.types';
|
||||
import { NotificationsService } from '../notifications/notifications.service';
|
||||
|
||||
// Situa: 1=Pendente Aprovação, 2=Aprovado, 3=Cancelado, 4=Faturado
|
||||
// Situa SAR: 1=Ag.Aprovação, 2=Aprovado, 3=Cancelado, 4=Faturado
|
||||
// Situa SIG: 1=Pendente, 2=Liberado, 5=Cancelado, 4=Faturado
|
||||
const SITUA_PENDENTE = 1;
|
||||
const SITUA_APROVADO = 2;
|
||||
const SITUA_CANCELADO = 3;
|
||||
|
||||
// Mapeia situa SIG → situa SAR para exibição correta no frontend.
|
||||
// SIG usa 5 para Cancelado; SAR usa 3. Demais valores coincidem.
|
||||
function sigToSar(sigSitua: number): number {
|
||||
return sigSitua === 5 ? 3 : sigSitua;
|
||||
}
|
||||
|
||||
// Mapeia situa SAR → situa SIG para usar nos filtros SQL contra vw_pedidos_erp.
|
||||
function sarToSig(sarSitua: number): number {
|
||||
return sarSitua === 3 ? 5 : sarSitua;
|
||||
}
|
||||
|
||||
function decimalToString(v: Prisma.Decimal | null | undefined): string {
|
||||
return v ? v.toString() : '0';
|
||||
}
|
||||
@@ -40,9 +52,14 @@ export class OrdersService {
|
||||
const { idCliente, situa, numPedSar, from, to, page, limit } = query;
|
||||
const offset = (page - 1) * limit;
|
||||
|
||||
// Filtro de vendedor: rep vê apenas seus pedidos
|
||||
const vendedorFilter = role === 'rep' ? `AND e.cod_vendedor = ${codVendedor}` : '';
|
||||
const clienteFilter = idCliente != null ? `AND e.id_cliente = ${idCliente}` : '';
|
||||
const situaFilter = situa != null ? `AND e.situa = ${situa}` : '';
|
||||
|
||||
// Converte situa SAR → SIG para filtrar corretamente contra vw_pedidos_erp
|
||||
const sigSitua = situa != null ? sarToSig(situa) : null;
|
||||
const situaFilter = sigSitua != null ? `AND e.situa = ${sigSitua}` : '';
|
||||
|
||||
const pedSarFilter = numPedSar ? `AND TRIM(e.num_ped_sar) ILIKE '%${numPedSar}%'` : '';
|
||||
const fromFilter = from ? `AND e.dt_pedido >= '${from}'` : '';
|
||||
const toFilter = to ? `AND e.dt_pedido <= '${to}'` : '';
|
||||
@@ -95,7 +112,8 @@ export class OrdersService {
|
||||
nomeCliente: o.nome_cliente ?? null,
|
||||
razaoCliente: o.razao_cliente ?? null,
|
||||
codVendedor: Number(o.cod_vendedor),
|
||||
situa: Number(o.situa),
|
||||
// Normaliza situa SIG → SAR para consistência com pedidos SAR
|
||||
situa: sigToSar(Number(o.situa)),
|
||||
statusDescr: o.status_descr,
|
||||
dtPedido: new Date(o.dt_pedido).toISOString(),
|
||||
total: o.total ?? '0',
|
||||
@@ -159,10 +177,8 @@ export class OrdersService {
|
||||
const limitMap = new Map(limitRows.map((r) => [r.codGrupo, Number(r.limitePerc)]));
|
||||
const getLimit = (codGrupo: number) => limitMap.get(codGrupo) ?? limitMap.get(0) ?? 5;
|
||||
|
||||
// Alçada global (codGrupo=0)
|
||||
const needsApproval = dto.descontoPerc > getLimit(0);
|
||||
|
||||
// Calcula totais dos itens
|
||||
const itemsData = dto.itens.map((it) => {
|
||||
const descontoValor =
|
||||
Math.round(it.qtd * it.precoUnitario * (it.descontoPerc / 100) * 100) / 100;
|
||||
@@ -241,7 +257,6 @@ export class OrdersService {
|
||||
return this.mapDetail(pedido);
|
||||
}
|
||||
|
||||
// Aprova pedido pendente. Supervisor pode ajustar descontoPerc global.
|
||||
async approve(id: string, dto: AprovarPedido): Promise<PedidoDetail> {
|
||||
const prisma = this.cls.get('prisma');
|
||||
if (!prisma) throw new Error('prisma não disponível no CLS');
|
||||
@@ -300,7 +315,6 @@ export class OrdersService {
|
||||
return this.mapDetail(final);
|
||||
}
|
||||
|
||||
// Recusa pedido — muda situa para 3 (Cancelado) com motivo.
|
||||
async reject(id: string, dto: RecusarPedido): Promise<PedidoDetail> {
|
||||
const prisma = this.cls.get('prisma');
|
||||
if (!prisma) throw new Error('prisma não disponível no CLS');
|
||||
|
||||
Reference in New Issue
Block a user