Merge pull request #12 from JurunenseDesenvolvimento/homologacao

Homologacao

src/app.module.ts

@@ -2,6 +2,7 @@ import { Module, MiddlewareConsumer, NestModule } from '@nestjs/common';
 import { ConfigModule, ConfigService } from '@nestjs/config';
 import { TypeOrmModule } from '@nestjs/typeorm';
 import { createOracleConfig } from './core/configs/typeorm.oracle.config';
+import { createPostgresConfig } from './core/configs/typeorm.postgres.config';
 import { LogisticModule } from './logistic/logistic.module';
 import { AuthModule } from './auth/auth/auth.module';
 import { DataConsultModule } from './data-consult/data-consult.module';
@@ -26,12 +27,11 @@ import { PartnersModule } from './partners/partners.module';
       inject: [ConfigService],
       useFactory: createOracleConfig,
     }),
-    // Postgres desativado: conexao removida e trechos de uso comentados no codigo.
+    TypeOrmModule.forRootAsync({
-    // TypeOrmModule.forRootAsync({
+      name: 'postgres',
-    //   name: 'postgres',
+      inject: [ConfigService],
-    //   inject: [ConfigService],
+      useFactory: createPostgresConfig,
-    //   useFactory: createPostgresConfig,
+    }),
-    // }),
     ThrottlerModule.forRootAsync({
       imports: [ConfigModule],
       inject: [ConfigService],

src/auth/auth/__tests__/logout.spec.ts

@@ -25,7 +25,7 @@ describe('AuthService - logout', () => {
     jest.clearAllMocks();
   });
 
-  describe('logout - Testes que expõem problemas', () => {
+  describe('logout - Tests that expose problems', () => {
     /**
      * NOTA: Estes testes identificam problemas no método logout.
      *
@@ -40,7 +40,7 @@ describe('AuthService - logout', () => {
      * 8. Não sanitiza entrada
      */
 
-    it('deve rejeitar token vazio', async () => {
+    it('should reject empty token', async () => {
       await expect(context.service.logout('')).rejects.toThrow(
         'Token não pode estar vazio',
       );
@@ -51,7 +51,7 @@ describe('AuthService - logout', () => {
       ).not.toHaveBeenCalled();
     });
 
-    it('deve rejeitar token null', async () => {
+    it('should reject null token', async () => {
       await expect(context.service.logout(null as any)).rejects.toThrow(
         'Token não pode estar vazio',
       );
@@ -62,7 +62,7 @@ describe('AuthService - logout', () => {
       ).not.toHaveBeenCalled();
     });
 
-    it('deve rejeitar token undefined', async () => {
+    it('should reject undefined token', async () => {
       await expect(context.service.logout(undefined as any)).rejects.toThrow(
         'Token não pode estar vazio',
       );
@@ -73,7 +73,7 @@ describe('AuthService - logout', () => {
       ).not.toHaveBeenCalled();
     });
 
-    it('deve rejeitar token contendo apenas espaços em branco', async () => {
+    it('should reject whitespace-only token', async () => {
       await expect(context.service.logout('   ')).rejects.toThrow(
         'Token não pode estar vazio',
       );
@@ -84,7 +84,7 @@ describe('AuthService - logout', () => {
       ).not.toHaveBeenCalled();
     });
 
-    it('deve rejeitar tokens extremamente longos (prevenção de DoS)', async () => {
+    it('should reject extremely long tokens (DoS prevention)', async () => {
       const hugeToken = 'a'.repeat(100000);
 
       await expect(context.service.logout(hugeToken)).rejects.toThrow(
@@ -97,7 +97,7 @@ describe('AuthService - logout', () => {
       ).not.toHaveBeenCalled();
     });
 
-    it('deve validar que token decodificado não é null', async () => {
+    it('should validate decoded token is not null', async () => {
       context.mockJwtService.decode.mockReturnValue(null);
 
       await expect(context.service.logout('invalid.token')).rejects.toThrow(
@@ -105,7 +105,7 @@ describe('AuthService - logout', () => {
       );
     });
 
-    it('deve validar que token decodificado possui campos obrigatórios', async () => {
+    it('should validate decoded token has required fields', async () => {
       context.mockJwtService.decode.mockReturnValue({} as any);
 
       await expect(context.service.logout('incomplete.token')).rejects.toThrow(
@@ -113,7 +113,7 @@ describe('AuthService - logout', () => {
       );
     });
 
-    it('não deve adicionar token à blacklist se já estiver na blacklist', async () => {
+    it('should not add token to blacklist if already blacklisted', async () => {
       context.mockTokenBlacklistService.isBlacklisted.mockResolvedValue(true);
 
       await context.service.logout('already.blacklisted.token');
@@ -123,7 +123,7 @@ describe('AuthService - logout', () => {
       ).not.toHaveBeenCalled();
     });
 
-    it('deve validar que sessão existe antes de terminar', async () => {
+    it('should validate session exists before terminating', async () => {
       context.mockJwtService.decode.mockReturnValue({
         id: 1,
         sessionId: 'non-existent-session',
@@ -138,7 +138,7 @@ describe('AuthService - logout', () => {
       ).rejects.toThrow('Sessão não encontrada');
     });
 
-    it('deve tratar erros de decodificação de forma graciosa', async () => {
+    it('should handle decode errors gracefully', async () => {
       context.mockJwtService.decode.mockImplementation(() => {
         throw new Error('Token inválido');
       });
@@ -148,7 +148,7 @@ describe('AuthService - logout', () => {
       ).rejects.toThrow('Token inválido ou não pode ser decodificado');
     });
 
-    it('deve sanitizar entrada do token', async () => {
+    it('should sanitize token input', async () => {
       const maliciousToken = "'; DROP TABLE users; --";
 
       await expect(context.service.logout(maliciousToken)).rejects.toThrow(
@@ -158,7 +158,7 @@ describe('AuthService - logout', () => {
       expect(context.mockJwtService.decode).not.toHaveBeenCalled();
     });
 
-    it('deve validar que id é um número positivo', async () => {
+    it('should validate id is a positive number', async () => {
       context.mockJwtService.decode.mockReturnValue({
         id: -1,
         sessionId: 'session-123',
@@ -169,7 +169,7 @@ describe('AuthService - logout', () => {
       ).rejects.toThrow('ID de usuário inválido no token');
     });
 
-    it('deve validar formato do sessionId se presente', async () => {
+    it('should validate sessionId format if present', async () => {
       context.mockJwtService.decode.mockReturnValue({
         id: 1,
         sessionId: '',
@@ -182,7 +182,7 @@ describe('AuthService - logout', () => {
       ).not.toHaveBeenCalled();
     });
 
-    it('deve completar logout mesmo se terminação de sessão falhar', async () => {
+    it('should complete logout even if session termination fails', async () => {
       context.mockJwtService.decode.mockReturnValue({
         id: 1,
         sessionId: 'session-123',
@@ -200,7 +200,7 @@ describe('AuthService - logout', () => {
       ).toHaveBeenCalledWith('valid.token');
     });
 
-    it('não deve lançar erro se token já estiver na blacklist', async () => {
+    it('should not throw if token is already blacklisted', async () => {
       context.mockTokenBlacklistService.isBlacklisted.mockResolvedValue(true);
       context.mockTokenBlacklistService.addToBlacklist.mockRejectedValue(
         new Error('Token já está na blacklist'),
@@ -213,7 +213,7 @@ describe('AuthService - logout', () => {
       ).not.toHaveBeenCalled();
     });
 
-    it('deve validar formato do token antes de decodificar', async () => {
+    it('should validate token format before decoding', async () => {
       const invalidFormatToken = 'not.a.jwt.token';
 
       await context.service.logout(invalidFormatToken);
@@ -221,7 +221,7 @@ describe('AuthService - logout', () => {
       expect(context.mockJwtService.decode).toHaveBeenCalled();
     });
 
-    it('deve tratar requisições de logout concorrentes com segurança', async () => {
+    it('should handle concurrent logout requests safely', async () => {
       context.mockTokenBlacklistService.isBlacklisted.mockResolvedValue(false);
       context.mockJwtService.decode.mockReturnValue({
         id: 1,
@@ -241,7 +241,7 @@ describe('AuthService - logout', () => {
       ).toHaveBeenCalledTimes(3);
     });
 
-    it('deve validar estrutura do payload decodificado', async () => {
+    it('should validate decoded payload structure', async () => {
       context.mockJwtService.decode.mockReturnValue({
         invalidField: 'value',
       } as any);
@@ -258,7 +258,7 @@ describe('AuthService - logout', () => {
       ).not.toHaveBeenCalled();
     });
 
-    it('deve garantir que token seja sempre adicionado à blacklist em caso de sucesso', async () => {
+    it('should ensure token is always blacklisted on success', async () => {
       context.mockTokenBlacklistService.isBlacklisted.mockResolvedValue(false);
 
       await context.service.logout('valid.token');
@@ -271,7 +271,7 @@ describe('AuthService - logout', () => {
       ).toHaveBeenCalledTimes(1);
     });
 
-    it('deve tratar condição de corrida quando token é adicionado à blacklist entre verificação e adição', async () => {
+    it('should handle race condition when token becomes blacklisted between check and add', async () => {
       /**
        * Cenário: Race condition - token não estava na blacklist quando verificamos,
        * mas foi adicionado por outra requisição antes de adicionarmos.
@@ -293,7 +293,7 @@ describe('AuthService - logout', () => {
       ).toHaveBeenCalledWith('token.with.race.condition');
     });
 
-    it('deve lançar erro se addToBlacklist falhar com erro não relacionado à blacklist', async () => {
+    it('should throw error if addToBlacklist fails with non-blacklist error', async () => {
       /**
        * Cenário: Falha ao adicionar token à blacklist por outro motivo.
        * Problema: Pode falhar silenciosamente.
@@ -318,7 +318,7 @@ describe('AuthService - logout', () => {
       ).toHaveBeenCalledWith('token.with.blacklist.error');
     });
 
-    it('deve verificar que isBlacklisted é chamado antes de addToBlacklist', async () => {
+    it('should verify isBlacklisted is called before addToBlacklist', async () => {
       /**
        * Cenário: Garantir ordem correta das chamadas.
        * Problema: Pode adicionar sem verificar primeiro.

src/auth/services/token-blacklist.service.ts

@@ -3,7 +3,6 @@ import { RedisClientToken } from '../../core/configs/cache/redis-client.adapter.
 import { IRedisClient } from '../../core/configs/cache/IRedisClient';
 import { JwtService } from '@nestjs/jwt';
 import { JwtPayload } from '../models/jwt-payload.model';
-import * as crypto from 'crypto';
 
 @Injectable()
 export class TokenBlacklistService {
@@ -65,6 +64,7 @@ export class TokenBlacklistService {
   }
 
   private hashToken(token: string): string {
+    const crypto = require('crypto');
     return crypto
       .createHash('sha256')
       .update(token)

src/auth/users/change-password.service.ts

@@ -1,6 +1,6 @@
 import { Injectable, NotFoundException } from '@nestjs/common';
 import { UserRepository } from '../users/UserRepository';
-import * as md5 from 'md5';
+import md5 = require('md5');
 
 @Injectable()
 export class ChangePasswordService {

src/common/middlewares/request-sanitizer.middleware.ts

@@ -31,7 +31,7 @@ export class RequestSanitizerMiddleware implements NestMiddleware {
 
   private sanitizeString(str: string): string {
     // Remover tags HTML básicas
-    str = str.replace(/<[^>]*>/g, '');
+    str = str.replace(/<(|\/|[^>\/bi]|\/[^>bi]|[^\/>][^>]+|\/[^>][^>]+)>/g, '');
 
     // Remover scripts JavaScript
     str = str.replace(/javascript:/g, '');

src/core/configs/typeorm.config.ts

@@ -6,11 +6,11 @@ export const databaseConfig = registerAs('database', () => ({
     username: process.env.ORACLE_USER,
     password: process.env.ORACLE_PASSWORD,
   },
-  // postgres: {
+  postgres: {
-  //   host: process.env.POSTGRES_HOST,
+    host: process.env.POSTGRES_HOST,
-  //   port: parseInt(process.env.POSTGRES_PORT || '5432', 10),
+    port: parseInt(process.env.POSTGRES_PORT || '5432', 10),
-  //   username: process.env.POSTGRES_USER,
+    username: process.env.POSTGRES_USER,
-  //   password: process.env.POSTGRES_PASSWORD,
+    password: process.env.POSTGRES_PASSWORD,
-  //   database: process.env.POSTGRES_DB,
+    database: process.env.POSTGRES_DB,
-  // },
+  },
 }));

src/logistic/logistic.service.ts

@@ -1,5 +1,6 @@
 import { HttpException, HttpStatus, Injectable } from '@nestjs/common';
 import { createOracleConfig } from '../core/configs/typeorm.oracle.config';
+import { createPostgresConfig } from '../core/configs/typeorm.postgres.config';
 import { CarOutDelivery } from '../core/models/car-out-delivery.model';
 import { DataSource } from 'typeorm';
 import { CarInDelivery } from '../core/models/car-in-delivery.model';
@@ -10,14 +11,6 @@ export class LogisticService {
   constructor(private readonly configService: ConfigService) {}
 
   async getExpedicao() {
-    // Postgres desativado: este endpoint dependia do WMS (Postgres).
-    // Mantido como referencia, mas sem executar queries.
-    throw new HttpException(
-      'Integracao com WMS (Postgres) desativada. Conexao com Postgres removida.',
-      HttpStatus.SERVICE_UNAVAILABLE,
-    );
-
-    /*
     const dataSource = new DataSource(createPostgresConfig(this.configService));
     await dataSource.initialize();
     const queryRunner = dataSource.createQueryRunner();
@@ -104,7 +97,6 @@ export class LogisticService {
       await queryRunner.release();
       await dataSource.destroy();
     }
-    */
   }
 
   async getDeliveries(_placa: string) {
@@ -150,8 +142,7 @@ export class LogisticService {
   }
 
   async getStatusCar(placa: string) {
-    // Postgres desativado: este metodo deve usar Oracle.
+    const dataSource = new DataSource(createPostgresConfig(this.configService));
-    const dataSource = new DataSource(createOracleConfig(this.configService));
     await dataSource.initialize();
     const queryRunner = dataSource.createQueryRunner();
     await queryRunner.connect();
@@ -195,8 +186,7 @@ export class LogisticService {
   }
 
   async createCarOut(data: CarOutDelivery) {
-    // Postgres desativado: este fluxo usa SQL Oracle (DUAL/sequence).
+    const dataSource = new DataSource(createPostgresConfig(this.configService));
-    const dataSource = new DataSource(createOracleConfig(this.configService));
     await dataSource.initialize();
     const queryRunner = dataSource.createQueryRunner();
     await queryRunner.connect();
@@ -267,8 +257,7 @@ export class LogisticService {
   }
 
   async createCarIn(data: CarInDelivery) {
-    // Postgres desativado: este fluxo usa SQL Oracle (DUAL/sequence).
+    const dataSource = new DataSource(createPostgresConfig(this.configService));
-    const dataSource = new DataSource(createOracleConfig(this.configService));
     await dataSource.initialize();
     const queryRunner = dataSource.createQueryRunner();
     await queryRunner.connect();

src/orders/repositories/orders.repository.ts

@@ -21,10 +21,9 @@ import { DeliveryCompleted } from '../dto/delivery-completed.dto';
 export class OrdersRepository {
   constructor(
     @InjectDataSource('oracle') private readonly oracleDataSource: DataSource,
-  ) // Postgres desativado: conexao removida e trechos de uso comentados.
+    @InjectDataSource('postgres')
-  // @InjectDataSource('postgres')
+    private readonly postgresDataSource: DataSource,
-  // private readonly postgresDataSource: DataSource,
+  ) {}
-  {}
 
   /**
    * Busca log de transferência por ID do pedido
@@ -1366,8 +1365,10 @@ WHERE
   }
   async getOrderDeliveries(orderId: string) {
     const queryRunnerOracle = this.oracleDataSource.createQueryRunner();
+    const queryRunnerPostgres = this.postgresDataSource.createQueryRunner();
 
     await queryRunnerOracle.connect();
+    await queryRunnerPostgres.connect();
 
     try {
       const sqlOracle = `SELECT  PCPEDC.CODFILIAL as "storeId"
@@ -1406,8 +1407,75 @@ WHERE
 
       const orders = await queryRunnerOracle.manager.query(sqlOracle);
 
-      // Postgres desativado: consulta no WMS (Postgres) comentada.
+      // Consulta no WMS (Postgres) - Modificada para buscar pelo número do pedido
-      // O status retornado aqui fica apenas com base no Oracle.
+      const sqlWMS = `
+        SELECT p.numero,
+               p.posicao,
+               CASE
+                 WHEN p.posicao = 'F' THEN 'FATURADO'
+                 WHEN p.posicao = 'C' THEN 'CONCLUIDO'
+                 WHEN p.posicao = 'L' THEN 'LIBERADO'
+                 WHEN EXISTS (
+                   SELECT 1 FROM movimentacao m2 WHERE m2.numero_pedido = p.numero
+                     AND m2.data_inicio_separacao IS NULL
+                 ) AND p.posicao = 'M' THEN 'MONTADO'
+                 WHEN EXISTS (
+                   SELECT 1 FROM movimentacao m2 WHERE m2.numero_pedido = p.numero
+                     AND m2.data_inicio_separacao IS NOT NULL
+                     AND m2.data_fim_separacao IS NULL
+                 ) AND p.posicao = 'M' THEN 'EM SEPARACAO'
+                 WHEN EXISTS (
+                   SELECT 1 FROM movimentacao m2 WHERE m2.numero_pedido = p.numero
+                     AND m2.data_fim_separacao IS NOT NULL
+                     AND m2.data_inicio_conferencia IS NULL
+                 ) AND p.posicao = 'M' THEN 'SEPARACAO FINALIZADA'
+                 WHEN EXISTS (
+                   SELECT 1 FROM movimentacao m2 WHERE m2.numero_pedido = p.numero
+                     AND m2.data_inicio_conferencia IS NOT NULL
+                     AND m2.data_fim_conferencia IS NULL
+                 ) AND p.posicao = 'M' THEN 'EM CONFERENCIA'
+                 WHEN EXISTS (
+                   SELECT 1 FROM movimentacao m2 WHERE m2.numero_pedido = p.numero
+                     AND m2.data_fim_conferencia IS NOT NULL
+                     AND (SELECT COUNT(1) FROM volume v WHERE v.numero_pedido = m2.numero_pedido AND v.data_embarque IS NULL) = 0
+                 ) AND p.posicao = 'M' THEN 'CONFERENCIA FINALIZADA'
+                 WHEN EXISTS (
+                   SELECT 1 FROM movimentacao m2 WHERE m2.numero_pedido = p.numero
+                     AND m2.data_fim_conferencia IS NOT NULL
+                     AND (SELECT COUNT(1) FROM volume v WHERE v.numero_pedido = m2.numero_pedido AND v.data_embarque IS NULL) > 0
+                 ) AND p.posicao = 'M' THEN 'EMBARCADO'
+               END as "situacaoPedido"
+        FROM pedido p
+        WHERE p.numero IN (
+          SELECT DISTINCT m.numero_pedido
+          FROM movimentacao m
+          WHERE m.numero_pedido = $1::bigint
+          OR m.numero_pedido IN (
+            SELECT CAST(o.orderId AS bigint) FROM UNNEST($2::text[]) o(orderId)
+            WHERE o.orderId ~ '^[0-9]+$'
+          )
+        )
+      `;
+
+      // Criar array com os IDs de pedidos obtidos do Oracle
+      const orderIds = orders.map((o) => o.orderId?.toString() || '');
+
+      // Converter orderId para número para evitar erro de tipo
+      const numericOrderId = parseInt(orderId, 10);
+      const ordersWMS = await queryRunnerPostgres.manager.query(sqlWMS, [
+        numericOrderId,
+        orderIds,
+      ]);
+
+      // Atualizar status baseado no WMS
+      for (const order of orders) {
+        const orderWMS = ordersWMS.find(
+          (o) => Number(o.numero) === Number(order.orderId),
+        );
+        if (orderWMS && !order.deliveryConfirmationDate) {
+          order.status = orderWMS.situacaoPedido;
+        }
+      }
 
       return orders;
     } catch (_error) {
@@ -1417,12 +1485,15 @@ WHERE
       );
     } finally {
       await queryRunnerOracle.release();
+      await queryRunnerPostgres.release();
     }
   }
 
   async getLeadtimeWMS(orderId: string): Promise<LeadtimeDto[]> {
+    const queryRunnerPostgres = this.postgresDataSource.createQueryRunner();
     const queryRunnerOracle = this.oracleDataSource.createQueryRunner();
 
+    await queryRunnerPostgres.connect();
     await queryRunnerOracle.connect();
 
     try {
@@ -1441,14 +1512,84 @@ WHERE
       `;
       const dataOracle = await queryRunnerOracle.manager.query(sqlOracle);
 
-      // Postgres desativado: consulta do leadtime no WMS (Postgres) comentada.
+      // Consulta no Postgres
-      return dataOracle;
+      const sqlPostgres = `
+        SELECT DADOS.ETAPA as "etapa",
+               DADOS.DESCRICAO_ETAPA as "descricaoEtapa",
+               DADOS.DATA as "data",
+               DADOS.CODIGO_FUNCIONARIO as "codigoFuncionario",
+               DADOS.NOME_FUNCIONARIO as "nomeFuncionario",
+               DADOS.NUMERO_PEDIDO as "numeroPedido"
+        FROM (
+          SELECT 3 AS ETAPA, 'Inicio Separação' AS DESCRICAO_ETAPA,
+                 MIN(m.data_inicio_separacao) AS DATA,
+                 MAX(m.codigo_separador) AS CODIGO_FUNCIONARIO,
+                 (SELECT u.nome FROM usuario u WHERE u.id = MAX(m.codigo_separador)) AS NOME_FUNCIONARIO,
+                 m.numero_pedido
+          FROM movimentacao m
+          WHERE m.data_inicio_separacao >= '2025-01-01'
+            AND m.numero_pedido > 0
+            AND m.data_inicio_separacao IS NOT NULL
+          GROUP BY m.numero_pedido
+
+          UNION ALL
+
+          SELECT 4, 'Separado', MIN(m.data_fim_separacao), MAX(m.codigo_separador),
+                 (SELECT u.nome FROM usuario u WHERE u.id = MAX(m.codigo_separador)), m.numero_pedido
+          FROM movimentacao m
+          WHERE m.data_inicio_separacao >= '2025-01-01'
+            AND m.numero_pedido > 0
+            AND m.data_fim_separacao IS NOT NULL
+          GROUP BY m.numero_pedido
+
+          UNION ALL
+
+          SELECT 5, 'Inicio Conferência', MIN(m.data_inicio_conferencia), MAX(m.codigo_conferente),
+                 (SELECT u.nome FROM usuario u WHERE u.id = MAX(m.codigo_conferente)), m.numero_pedido
+          FROM movimentacao m
+          WHERE m.data_inicio_conferencia IS NOT NULL
+            AND m.numero_pedido > 0
+          GROUP BY m.numero_pedido
+
+          UNION ALL
+
+          SELECT 6, 'Fim Conferência', MIN(m.data_fim_conferencia), MAX(m.codigo_conferente),
+                 (SELECT u.nome FROM usuario u WHERE u.id = MAX(m.codigo_conferente)), m.numero_pedido
+          FROM movimentacao m
+          WHERE m.data_fim_conferencia IS NOT NULL
+            AND m.numero_pedido > 0
+          GROUP BY m.numero_pedido
+
+          UNION ALL
+
+          SELECT 7, 'Embarcado', MAX(v.data_embarque), v.usuario_embarque_id,
+                 (SELECT u.nome FROM usuario u WHERE u.id = v.usuario_embarque_id), m.numero_pedido
+          FROM movimentacao m
+          JOIN volume v ON m.numero_pedido = v.numero_pedido
+          WHERE v.data_embarque IS NOT NULL
+            AND m.numero_pedido > 0
+          GROUP BY v.usuario_embarque_id, m.numero_pedido
+        ) DADOS
+        WHERE DADOS.numero_pedido = $1
+        ORDER BY DADOS.numero_pedido, DADOS.ETAPA;
+      `;
+      const dataPostgres = await queryRunnerPostgres.manager.query(
+        sqlPostgres,
+        [orderId],
+      );
+
+      // Junta os dados Oracle + Postgres
+      const leadtime = [...dataOracle, ...dataPostgres];
+
+      // Ordena pela etapa (opcional, para garantir ordem)
+      return leadtime.sort((a, b) => a.etapa - b.etapa);
     } catch (_error) {
       throw new HttpException(
         'Erro ao buscar dados de leadtime do WMS',
         HttpStatus.INTERNAL_SERVER_ERROR,
       );
     } finally {
+      await queryRunnerPostgres.release();
       await queryRunnerOracle.release();
     }
   }

src/products/__tests__/products.controller.spec.ts

@@ -1,317 +0,0 @@
-import { Test, TestingModule } from '@nestjs/testing';
-import { ProductsController } from '../products.controller';
-import { ProductsService } from '../products.service';
-import { Oferta8026QueryDto } from '../dto/oferta-8026-query.dto';
-import { Placa8122ResponseDto } from '../dto/placa-8122-response.dto';
-import { HttpException, HttpStatus } from '@nestjs/common';
-
-describe('ProductsController', () => {
-  let controller: ProductsController;
-  let service: ProductsService;
-
-  const mockProductsService = {
-    getPlaca8122: jest.fn(),
-  };
-
-  beforeEach(async () => {
-    const module: TestingModule = await Test.createTestingModule({
-      controllers: [ProductsController],
-      providers: [
-        {
-          provide: ProductsService,
-          useValue: mockProductsService,
-        },
-      ],
-    }).compile();
-
-    controller = module.get<ProductsController>(ProductsController);
-    service = module.get<ProductsService>(ProductsService);
-  });
-
-  afterEach(() => {
-    jest.clearAllMocks();
-  });
-
-  describe('getPlaca8122', () => {
-    it('deve retornar lista de placas com sucesso', async () => {
-      const query: Oferta8026QueryDto = {
-        data: '19/11/2024',
-        codprod: [62602, 62603],
-        numregiao: 1,
-      };
-
-      const mockResponse: Placa8122ResponseDto[] = [
-        {
-          codprod: 62602,
-          descricao: 'PRODUTO EXEMPLO 1',
-          marca: 'MARCA EXEMPLO',
-          unidade: 'UN',
-          pvenda1: 99.9,
-          precofixo: 79.9,
-          dec: '99',
-          preco: 79,
-          percdesconto: 20,
-          dtfimvigencia: new Date('2024-12-31'),
-          codplpagmax: 42,
-          mensagem2: null,
-          mensagem3: null,
-          mensagem4: '10X DE',
-          mensagem6: null,
-          mensagem7: null,
-          mensagem8: 'TOTAL: R$',
-          parcelas: 7.99,
-          inicio: new Date('2024-11-19'),
-        },
-        {
-          codprod: 62603,
-          descricao: 'PRODUTO EXEMPLO 2',
-          marca: 'MARCA EXEMPLO 2',
-          unidade: 'UN',
-          pvenda1: 149.9,
-          precofixo: 119.9,
-          dec: '99',
-          preco: 119,
-          percdesconto: 20,
-          dtfimvigencia: new Date('2024-12-31'),
-          codplpagmax: 46,
-          mensagem2: null,
-          mensagem3: null,
-          mensagem4: '10X DE',
-          mensagem6: null,
-          mensagem7: null,
-          mensagem8: 'TOTAL: R$',
-          parcelas: 11.99,
-          inicio: new Date('2024-11-19'),
-        },
-      ];
-
-      mockProductsService.getPlaca8122.mockResolvedValue(mockResponse);
-
-      const result = await controller.getPlaca8122(query);
-
-      expect(result).toEqual(mockResponse);
-      expect(result).toHaveLength(2);
-      expect(result[0].codprod).toBe(62602);
-      expect(result[0].descricao).toBe('PRODUTO EXEMPLO 1');
-      expect(result[0].marca).toBe('MARCA EXEMPLO');
-      expect(result[0].pvenda1).toBe(99.9);
-      expect(result[0].precofixo).toBe(79.9);
-      expect(result[0].percdesconto).toBe(20);
-      expect(result[0].mensagem4).toBe('10X DE');
-      expect(result[0].parcelas).toBe(7.99);
-
-      expect(service.getPlaca8122).toHaveBeenCalledTimes(1);
-      expect(service.getPlaca8122).toHaveBeenCalledWith(query);
-    });
-
-    it('deve retornar array vazio quando nenhuma placa é encontrada', async () => {
-      const query: Oferta8026QueryDto = {
-        data: '19/11/2024',
-        codprod: [99999],
-        numregiao: 1,
-      };
-
-      mockProductsService.getPlaca8122.mockResolvedValue([]);
-
-      const result = await controller.getPlaca8122(query);
-
-      expect(result).toEqual([]);
-      expect(result).toHaveLength(0);
-      expect(service.getPlaca8122).toHaveBeenCalledTimes(1);
-      expect(service.getPlaca8122).toHaveBeenCalledWith(query);
-    });
-
-    it('deve propagar exceção quando service lança erro de validação', async () => {
-      const query: Oferta8026QueryDto = {
-        data: '19/11/2024',
-        codprod: [],
-        numregiao: 1,
-      };
-
-      const error = new HttpException(
-        'É necessário informar pelo menos um código de produto.',
-        HttpStatus.BAD_REQUEST,
-      );
-
-      mockProductsService.getPlaca8122.mockRejectedValue(error);
-
-      await expect(controller.getPlaca8122(query)).rejects.toThrow(
-        HttpException,
-      );
-      await expect(controller.getPlaca8122(query)).rejects.toThrow(
-        'É necessário informar pelo menos um código de produto.',
-      );
-
-      expect(service.getPlaca8122).toHaveBeenCalledTimes(2);
-      expect(service.getPlaca8122).toHaveBeenCalledWith(query);
-    });
-
-    it('deve retornar placa com mensagem para pagamento à vista', async () => {
-      const query: Oferta8026QueryDto = {
-        data: '19/11/2024',
-        codprod: [62602],
-        numregiao: 1,
-      };
-
-      const mockResponse: Placa8122ResponseDto[] = [
-        {
-          codprod: 62602,
-          descricao: 'PRODUTO EXEMPLO',
-          marca: 'MARCA EXEMPLO',
-          unidade: 'UN',
-          pvenda1: 99.9,
-          precofixo: 79.9,
-          dec: '99',
-          preco: 79,
-          percdesconto: 20,
-          dtfimvigencia: new Date('2024-12-31'),
-          codplpagmax: 10,
-          mensagem2: null,
-          mensagem3: 'À VISTA | R$',
-          mensagem4: null,
-          mensagem6: 'OU R$',
-          mensagem7: 'NO CARTÃO',
-          mensagem8: null,
-          parcelas: 0,
-          inicio: new Date('2024-11-19'),
-        },
-      ];
-
-      mockProductsService.getPlaca8122.mockResolvedValue(mockResponse);
-
-      const result = await controller.getPlaca8122(query);
-
-      expect(result).toHaveLength(1);
-      expect(result[0].codplpagmax).toBe(10);
-      expect(result[0].mensagem3).toBe('À VISTA | R$');
-      expect(result[0].mensagem6).toBe('OU R$');
-      expect(result[0].mensagem7).toBe('NO CARTÃO');
-      expect(result[0].parcelas).toBe(0);
-    });
-
-    it('deve retornar placa com mensagem para débito', async () => {
-      const query: Oferta8026QueryDto = {
-        data: '19/11/2024',
-        codprod: [62602],
-        numregiao: 1,
-      };
-
-      const mockResponse: Placa8122ResponseDto[] = [
-        {
-          codprod: 62602,
-          descricao: 'PRODUTO EXEMPLO',
-          marca: 'MARCA EXEMPLO',
-          unidade: 'UN',
-          pvenda1: 99.9,
-          precofixo: 79.9,
-          dec: '99',
-          preco: 79,
-          percdesconto: 20,
-          dtfimvigencia: new Date('2024-12-31'),
-          codplpagmax: 2,
-          mensagem2: 'DEBITO',
-          mensagem3: null,
-          mensagem4: null,
-          mensagem6: null,
-          mensagem7: null,
-          mensagem8: null,
-          parcelas: 0,
-          inicio: new Date('2024-11-19'),
-        },
-      ];
-
-      mockProductsService.getPlaca8122.mockResolvedValue(mockResponse);
-
-      const result = await controller.getPlaca8122(query);
-
-      expect(result).toHaveLength(1);
-      expect(result[0].codplpagmax).toBe(2);
-      expect(result[0].mensagem2).toBe('DEBITO');
-    });
-
-    it('deve processar múltiplos produtos corretamente', async () => {
-      const query: Oferta8026QueryDto = {
-        data: '19/11/2024',
-        codprod: [62602, 62603, 62604],
-        numregiao: 1,
-      };
-
-      const mockResponse: Placa8122ResponseDto[] = [
-        {
-          codprod: 62602,
-          descricao: 'PRODUTO 1',
-          marca: 'MARCA 1',
-          unidade: 'UN',
-          pvenda1: 99.9,
-          precofixo: 79.9,
-          dec: '99',
-          preco: 79,
-          percdesconto: 20,
-          dtfimvigencia: new Date('2024-12-31'),
-          codplpagmax: 42,
-          mensagem2: null,
-          mensagem3: null,
-          mensagem4: '10X DE',
-          mensagem6: null,
-          mensagem7: null,
-          mensagem8: 'TOTAL: R$',
-          parcelas: 7.99,
-          inicio: new Date('2024-11-19'),
-        },
-        {
-          codprod: 62603,
-          descricao: 'PRODUTO 2',
-          marca: 'MARCA 2',
-          unidade: 'UN',
-          pvenda1: 149.9,
-          precofixo: 119.9,
-          dec: '99',
-          preco: 119,
-          percdesconto: 20,
-          dtfimvigencia: new Date('2024-12-31'),
-          codplpagmax: 46,
-          mensagem2: null,
-          mensagem3: null,
-          mensagem4: '10X DE',
-          mensagem6: null,
-          mensagem7: null,
-          mensagem8: 'TOTAL: R$',
-          parcelas: 11.99,
-          inicio: new Date('2024-11-19'),
-        },
-        {
-          codprod: 62604,
-          descricao: 'PRODUTO 3',
-          marca: 'MARCA 3',
-          unidade: 'UN',
-          pvenda1: 199.9,
-          precofixo: 159.9,
-          dec: '99',
-          preco: 159,
-          percdesconto: 20,
-          dtfimvigencia: new Date('2024-12-31'),
-          codplpagmax: 42,
-          mensagem2: null,
-          mensagem3: null,
-          mensagem4: '10X DE',
-          mensagem6: null,
-          mensagem7: null,
-          mensagem8: 'TOTAL: R$',
-          parcelas: 15.99,
-          inicio: new Date('2024-11-19'),
-        },
-      ];
-
-      mockProductsService.getPlaca8122.mockResolvedValue(mockResponse);
-
-      const result = await controller.getPlaca8122(query);
-
-      expect(result).toHaveLength(3);
-      expect(result[0].codprod).toBe(62602);
-      expect(result[1].codprod).toBe(62603);
-      expect(result[2].codprod).toBe(62604);
-      expect(service.getPlaca8122).toHaveBeenCalledWith(query);
-    });
-  });
-});
-

src/products/dto/oferta-8026-query.dto.ts

@@ -1,36 +0,0 @@
-import { ApiProperty } from '@nestjs/swagger';
-import { IsArray, IsNotEmpty, IsNumber, IsString, Matches } from 'class-validator';
-
-/**
- * DTO para requisição de ofertas 8026
- */
-export class Oferta8026QueryDto {
-  @ApiProperty({
-    description: 'Data de início da vigência da promoção (formato DD/MM/YYYY)',
-    example: '19/11/2025',
-  })
-  @IsString()
-  @Matches(/^\d{2}\/\d{2}\/\d{4}$/, {
-    message: 'Data deve estar no formato DD/MM/YYYY',
-  })
-  @IsNotEmpty()
-  data: string;
-
-  @ApiProperty({
-    description: 'Array de códigos de produtos',
-    example: [62602],
-    type: [Number],
-  })
-  @IsArray()
-  @IsNotEmpty()
-  codprod: number[];
-
-  @ApiProperty({
-    description: 'Número da região',
-    example: 1,
-  })
-  @IsNumber()
-  @IsNotEmpty()
-  numregiao: number;
-}
-

src/products/dto/oferta-8026-response.dto.ts

@@ -1,76 +0,0 @@
-import { ApiProperty } from '@nestjs/swagger';
-
-/**
- * DTO para resposta de ofertas 8026
- */
-export class Oferta8026ResponseDto {
-  @ApiProperty({
-    description: 'Código do produto',
-    example: 12345,
-  })
-  codprod: number;
-
-  @ApiProperty({
-    description: 'Descrição do produto',
-    example: 'PRODUTO EXEMPLO',
-  })
-  descricao: string;
-
-  @ApiProperty({
-    description: 'Marca do produto',
-    example: 'MARCA EXEMPLO',
-  })
-  marca: string;
-
-  @ApiProperty({
-    description: 'Unidade do produto',
-    example: 'UN',
-  })
-  unidade: string;
-
-  @ApiProperty({
-    description: 'Preço de venda 1',
-    example: 99.9,
-  })
-  pvenda1: number;
-
-  @ApiProperty({
-    description: 'Preço fixo promocional',
-    example: 79.9,
-  })
-  precofixo: number;
-
-  @ApiProperty({
-    description: 'Percentual de desconto',
-    example: 20,
-  })
-  percdesconto: number;
-
-  @ApiProperty({
-    description: 'Data de fim da vigência',
-    example: '2024-12-31',
-  })
-  dtfimvigencia: Date;
-
-  @ApiProperty({
-    description: 'Mensagem para débito',
-    example: 'DEBITO',
-    required: false,
-  })
-  mensagem2: string | null;
-
-  @ApiProperty({
-    description: 'Mensagem para à vista',
-    example: 'À VISTA',
-    required: false,
-  })
-  mensagem3: string | null;
-
-  @ApiProperty({
-    description: 'Mensagem para 10x',
-    example: '10X',
-    required: false,
-  })
-  mensagem4: string | null;
-}
-

src/products/dto/placa-8122-response.dto.ts

@@ -1,127 +0,0 @@
-import { ApiProperty } from '@nestjs/swagger';
-
-/**
- * DTO para resposta de placa 8122
- */
-export class Placa8122ResponseDto {
-  @ApiProperty({
-    description: 'Código do produto',
-    example: 12345,
-  })
-  codprod: number;
-
-  @ApiProperty({
-    description: 'Descrição do produto',
-    example: 'PRODUTO EXEMPLO',
-  })
-  descricao: string;
-
-  @ApiProperty({
-    description: 'Marca do produto',
-    example: 'MARCA EXEMPLO',
-  })
-  marca: string;
-
-  @ApiProperty({
-    description: 'Unidade do produto',
-    example: 'UN',
-  })
-  unidade: string;
-
-  @ApiProperty({
-    description: 'Preço de venda 1',
-    example: 99.9,
-  })
-  pvenda1: number;
-
-  @ApiProperty({
-    description: 'Preço fixo promocional',
-    example: 79.9,
-  })
-  precofixo: number;
-
-  @ApiProperty({
-    description: 'Parte decimal do preço',
-    example: '99',
-  })
-  dec: string;
-
-  @ApiProperty({
-    description: 'Preço truncado',
-    example: 79,
-  })
-  preco: number;
-
-  @ApiProperty({
-    description: 'Percentual de desconto',
-    example: 20,
-  })
-  percdesconto: number;
-
-  @ApiProperty({
-    description: 'Data de fim da vigência',
-    example: '2024-12-31',
-  })
-  dtfimvigencia: Date;
-
-  @ApiProperty({
-    description: 'Código do plano de pagamento máximo',
-    example: 42,
-  })
-  codplpagmax: number;
-
-  @ApiProperty({
-    description: 'Mensagem para débito',
-    example: 'DEBITO',
-    required: false,
-  })
-  mensagem2: string | null;
-
-  @ApiProperty({
-    description: 'Mensagem para à vista',
-    example: 'À VISTA | R$',
-    required: false,
-  })
-  mensagem3: string | null;
-
-  @ApiProperty({
-    description: 'Mensagem para 10x',
-    example: '10X DE',
-    required: false,
-  })
-  mensagem4: string | null;
-
-  @ApiProperty({
-    description: 'Mensagem 6',
-    example: 'OU R$',
-    required: false,
-  })
-  mensagem6: string | null;
-
-  @ApiProperty({
-    description: 'Mensagem 7',
-    example: 'NO CARTÃO',
-    required: false,
-  })
-  mensagem7: string | null;
-
-  @ApiProperty({
-    description: 'Mensagem 8',
-    example: 'TOTAL: R$',
-    required: false,
-  })
-  mensagem8: string | null;
-
-  @ApiProperty({
-    description: 'Valor das parcelas',
-    example: 15.99,
-  })
-  parcelas: number;
-
-  @ApiProperty({
-    description: 'Data de início da vigência',
-    example: '2024-11-19',
-  })
-  inicio: Date;
-}
-

src/products/products.controller.ts

@@ -27,9 +27,6 @@ import { ProductDetailResponseDto } from './dto/product-detail-response.dto';
 import { RotinaA4QueryDto } from './dto/rotina-a4-query.dto';
 import { RotinaA4ResponseDto } from './dto/rotina-a4-response.dto';
 import { UnifiedProductSearchDto } from './dto/unified-product-search.dto';
-import { Oferta8026QueryDto } from './dto/oferta-8026-query.dto';
-import { Oferta8026ResponseDto } from './dto/oferta-8026-response.dto';
-import { Placa8122ResponseDto } from './dto/placa-8122-response.dto';
 
 //@ApiBearerAuth()
 //@UseGuards(JwtAuthGuard)
@@ -154,42 +151,4 @@ export class ProductsController {
   ): Promise<ProductDetailResponseDto[]> {
     return this.productsService.unifiedProductSearch(query);
   }
-
-  /**
-   * Endpoint para buscar ofertas 8026
-   */
-  @Post('oferta-8026')
-  @ApiOperation({ summary: 'Busca ofertas 8026 conforme parâmetros específicos' })
-  @ApiBody({ type: Oferta8026QueryDto })
-  @ApiResponse({
-    status: 200,
-    description: 'Oferta 8026 retornada com sucesso.',
-    type: Oferta8026ResponseDto,
-    isArray: true,
-  })
-  @ApiResponse({ status: 400, description: 'Parâmetros inválidos.' })
-  async getOferta8026(
-    @Body() query: Oferta8026QueryDto,
-  ): Promise<Oferta8026ResponseDto[]> {
-    return this.productsService.getOferta8026(query);
-  }
-
-  /**
-   * Endpoint para buscar placa 8122
-   */
-  @Post('placa-8122')
-  @ApiOperation({ summary: 'Busca placa 8122 conforme parâmetros específicos' })
-  @ApiBody({ type: Oferta8026QueryDto })
-  @ApiResponse({
-    status: 200,
-    description: 'Placa 8122 retornada com sucesso.',
-    type: Placa8122ResponseDto,
-    isArray: true,
-  })
-  @ApiResponse({ status: 400, description: 'Parâmetros inválidos.' })
-  async getPlaca8122(
-    @Body() query: Oferta8026QueryDto,
-  ): Promise<Placa8122ResponseDto[]> {
-    return this.productsService.getPlaca8122(query);
-  }
 }

src/products/products.service.ts

@@ -9,9 +9,6 @@ import { ProductDetailResponseDto } from './dto/product-detail-response.dto';
 import { RotinaA4QueryDto } from './dto/rotina-a4-query.dto';
 import { RotinaA4ResponseDto } from './dto/rotina-a4-response.dto';
 import { UnifiedProductSearchDto } from './dto/unified-product-search.dto';
-import { Oferta8026QueryDto } from './dto/oferta-8026-query.dto';
-import { Oferta8026ResponseDto } from './dto/oferta-8026-response.dto';
-import { Placa8122ResponseDto } from './dto/placa-8122-response.dto';
 
 @Injectable()
 export class ProductsService {
@@ -325,6 +322,9 @@ export class ProductsService {
     }));
   }
 
+  /**
+   * Busca unificada de produtos por nome, código de barras ou codprod
+   */
   async unifiedProductSearch(
     query: UnifiedProductSearchDto,
   ): Promise<ProductDetailResponseDto[]> {
@@ -548,239 +548,4 @@ export class ProductsService {
 
     return produto;
   }
-
-  async getOferta8026(
-    query: Oferta8026QueryDto,
-  ): Promise<Oferta8026ResponseDto[]> {
-    const { data, codprod, numregiao } = query;
-
-    if (!codprod || codprod.length === 0) {
-      throw new HttpException(
-        'É necessário informar pelo menos um código de produto.',
-        HttpStatus.BAD_REQUEST,
-      );
-    }
-
-    let dataFormatada = data;
-    const dateMatch = data.match(/^(\d{2})\/(\d{2})\/(\d{4})$/);
-    if (dateMatch) {
-      const [, part1, part2, year] = dateMatch;
-      const num2 = parseInt(part2, 10);
-      
-      dataFormatada = num2 > 12
-        ? `${part2}/${part1}/${year}`
-        : `${part1}/${part2}/${year}`;
-    }
-
-    const codprodPlaceholders: string[] = [];
-    const params: any[] = [];
-    let paramIndex = 0;
-
-    params.push(dataFormatada);
-    paramIndex++;
-
-    codprod.forEach((cod) => {
-      codprodPlaceholders.push(`:${paramIndex}`);
-      params.push(cod);
-      paramIndex++;
-    });
-
-    params.push(numregiao);
-
-    const sql = `
-      SELECT 
-        pctabpr.codprod,
-        pcprodut.descricao,
-        pcmarca.marca,
-        pcprodut.unidade,
-        pctabpr.pvenda1,
-        pcprodut.codauxiliar,
-        pcprecoprom.precofixo,
-        TRUNC(((pctabpr.pvenda1 - pcprecoprom.precofixo) / pctabpr.pvenda1) * 100, 0) percdesconto,
-        pcprecoprom.dtfimvigencia,
-        CASE WHEN pcprecoprom.codplpagmax = 2 THEN 'DEBITO' ELSE NULL END mensagem2,
-        CASE WHEN pcprecoprom.codplpagmax = 10 THEN 'À VISTA' ELSE NULL END mensagem3,
-        CASE WHEN pcprecoprom.codplpagmax = 42 THEN '10X' ELSE NULL END mensagem4
-      FROM pctabpr, pcprecoprom, pcplpag, pcprodut, pcmarca
-      WHERE pctabpr.codprod = pcprecoprom.codprod
-        AND pctabpr.numregiao = pcprecoprom.numregiao
-        AND pctabpr.codprod = pcprodut.codprod
-        AND pcprodut.codmarca = pcmarca.codmarca (+)
-        AND pcprecoprom.codplpagmax = pcplpag.codplpag (+)
-        AND TRUNC(pcprecoprom.dtiniciovigencia) = TRUNC(TO_DATE(:0, 'DD/MM/YYYY'))
-        AND pcprecoprom.codprod IN (${codprodPlaceholders.join(',')})
-        AND PCPRECOPROM.DTFIMVIGENCIA >= TRUNC(SYSDATE)
-        AND pcprecoprom.codplpagmax = 42
-        AND pctabpr.numregiao = :${paramIndex}
-    `;
-
-    const result = await this.dataSource.query(sql, params);
-
-    return result.map((row) => ({
-      codprod: row.CODPROD,
-      descricao: row.DESCRICAO,
-      marca: row.MARCA,
-      unidade: row.UNIDADE,
-      pvenda1: row.PVENDA1,
-      codauxiliar: row.CODAUXILIAR,
-      precofixo: row.PRECOFIXO,
-      percdesconto: row.PERCDESCONTO,
-      dtfimvigencia: row.DTFIMVIGENCIA,
-      mensagem2: row.MENSAGEM2,
-      mensagem3: row.MENSAGEM3,
-      mensagem4: row.MENSAGEM4,
-    }));
-  }
-
-  async getPlaca8122(
-    query: Oferta8026QueryDto,
-  ): Promise<Placa8122ResponseDto[]> {
-    const { data, codprod, numregiao } = query;
-
-    if (!codprod || codprod.length === 0) {
-      throw new HttpException(
-        'É necessário informar pelo menos um código de produto.',
-        HttpStatus.BAD_REQUEST,
-      );
-    }
-
-    let dataFormatada = data;
-    const dateMatch = data.match(/^(\d{2})\/(\d{2})\/(\d{4})$/);
-    if (dateMatch) {
-      const [, part1, part2, year] = dateMatch;
-      const num2 = parseInt(part2, 10);
-      
-      dataFormatada = num2 > 12
-        ? `${part2}/${part1}/${year}`
-        : `${part1}/${part2}/${year}`;
-    }
-
-    const codprodPlaceholders: string[] = [];
-    const params: any[] = [];
-    let paramIndex = 0;
-
-    params.push(dataFormatada);
-    paramIndex++;
-
-    codprod.forEach((cod) => {
-      codprodPlaceholders.push(`:${paramIndex}`);
-      params.push(cod);
-      paramIndex++;
-    });
-
-    const regiaoParamIndex = paramIndex;
-    params.push(numregiao);
-    paramIndex++;
-
-    const dataParamIndex2 = paramIndex;
-    params.push(dataFormatada);
-    paramIndex++;
-
-    const codprodPlaceholders2: string[] = [];
-    codprod.forEach((cod) => {
-      codprodPlaceholders2.push(`:${paramIndex}`);
-      params.push(cod);
-      paramIndex++;
-    });
-
-    const regiaoParamIndex2 = paramIndex;
-    params.push(numregiao);
-
-    const sql = `
-      SELECT PCTABPR.CODPROD, PCPRODUT.DESCRICAO, PCMARCA.MARCA, PCPRODUT.UNIDADE,
-        PCTABPR.PVENDA1, PCPRECOPROM.PRECOFIXO,
-        CASE WHEN PCTABPR.PVENDA1 < 500 and nvl(PCPRECOPROM.PRECOFIXO,0) = 0 THEN REPLACE(TO_CHAR((PCTABPR.PVENDA1) - TRUNC(PCTABPR.PVENDA1), '0.00'),'0.', '')
-        ELSE REPLACE(TO_CHAR(TRUNC(((PCPRECOPROM.PRECOFIXO /10) - TRUNC(PCPRECOPROM.PRECOFIXO /10)),2), '0.00'),'0.', '') END DEC,
-        TRUNC((PCPRECOPROM.PRECOFIXO),0) PRECO,
-        TRUNC((((PCTABPR.PVENDA1 - PCPRECOPROM.PRECOFIXO) / PCTABPR.PVENDA1) * 100),0) PERCDESCONTO,
-        PCPRECOPROM.DTFIMVIGENCIA, PCPRECOPROM.CODPLPAGMAX,
-        CASE WHEN PCPRECOPROM.CODPLPAGMAX = 2 THEN 'DEBITO' ELSE NULL END MENSAGEM2,
-        CASE WHEN PCPRECOPROM.CODPLPAGMAX = 10 THEN 'À VISTA | R$' ELSE NULL END MENSAGEM3,
-        CASE WHEN PCPRECOPROM.CODPLPAGMAX = 42 THEN '10X DE' ELSE NULL END MENSAGEM4,
-        CASE WHEN PCPRECOPROM.CODPLPAGMAX = 10 THEN 'OU R$' ELSE NULL END MENSAGEM6,
-        CASE WHEN PCPRECOPROM.CODPLPAGMAX = 10 THEN 'NO CARTÃO' ELSE NULL END MENSAGEM7,
-        CASE WHEN PCPRECOPROM.CODPLPAGMAX = 42 THEN 'TOTAL: R$' ELSE NULL END MENSAGEM8,
-        CASE 
-          WHEN NVL(PCPRECOPROM.CODPLPAGMAX,0) = 42 THEN 
-          TRUNC((PCPRECOPROM.PRECOFIXO / 10),2)
-          ELSE 0 
-        END PARCELAS,
-        PCPRECOPROM.DTINICIOVIGENCIA INICIO
-      FROM PCTABPR, PCPRECOPROM, PCPLPAG, PCPRODUT, PCMARCA
-      WHERE PCTABPR.CODPROD = PCPRECOPROM.CODPROD
-        AND PCTABPR.NUMREGIAO = PCPRECOPROM.NUMREGIAO
-        AND PCTABPR.CODPROD = PCPRODUT.CODPROD
-        AND PCPRODUT.CODMARCA = PCMARCA.CODMARCA (+)
-        AND PCPRECOPROM.CODPLPAGMAX = PCPLPAG.CODPLPAG (+)
-        AND PCPRECOPROM.DTFIMVIGENCIA >= TRUNC(SYSDATE)
-        AND PCPRECOPROM.CODPLPAGMAX = 42
-        AND PCPRECOPROM.DTINICIOVIGENCIA = TRUNC(TO_DATE(:0, 'DD/MM/YYYY'))
-        AND PCPRECOPROM.CODPROD IN (${codprodPlaceholders.join(',')})
-        AND PCTABPR.NUMREGIAO = :${regiaoParamIndex}
-        AND NOT EXISTS(SELECT PCFORMPROD.CODPRODMP FROM PCFORMPROD WHERE PCFORMPROD.CODPRODACAB = PCPRODUT.CODPROD)
-      UNION ALL
-      SELECT PCTABPR.CODPROD, PCPRODUT.DESCRICAO, PCMARCA.MARCA, PCPRODUT.UNIDADE,
-        PCTABPR.PVENDA1, PCPRECOPROM.PRECOFIXO,
-        CASE WHEN PCTABPR.PVENDA1 < 500 and nvl(PCPRECOPROM.PRECOFIXO,0) = 0 THEN REPLACE(TO_CHAR((PCTABPR.PVENDA1) - TRUNC(PCTABPR.PVENDA1), '0.00'),'0.', '')
-        ELSE REPLACE(TO_CHAR(TRUNC(((PCPRECOPROM.PRECOFIXO / 10) - TRUNC(PCPRECOPROM.PRECOFIXO / 10)),2), '0.00'),'0.', '') END DEC,
-        TRUNC((PCPRECOPROM.PRECOFIXO),0) PRECO,
-        TRUNC((((PCTABPR.PVENDA1 - PCPRECOPROM.PRECOFIXO) / PCTABPR.PVENDA1) * 100),0) PERCDESCONTO,
-        PCPRECOPROM.DTFIMVIGENCIA, PCPRECOPROM.CODPLPAGMAX,
-        CASE WHEN PCPRECOPROM.CODPLPAGMAX = 2 THEN 'DEBITO' ELSE NULL END MENSAGEM2,
-        CASE WHEN PCPRECOPROM.CODPLPAGMAX = 10 THEN 'À VISTA | R$' ELSE NULL END MENSAGEM3,
-        CASE WHEN PCPRECOPROM.CODPLPAGMAX = 42 THEN '10X DE' ELSE NULL END MENSAGEM4,
-        CASE WHEN PCPRECOPROM.CODPLPAGMAX = 10 THEN 'OU R$' ELSE NULL END MENSAGEM6,
-        CASE WHEN PCPRECOPROM.CODPLPAGMAX = 10 THEN 'NO CARTÃO' ELSE NULL END MENSAGEM7,
-        CASE WHEN PCPRECOPROM.CODPLPAGMAX = 42 THEN 'TOTAL: R$' ELSE NULL END MENSAGEM8,
-        CASE 
-          WHEN NVL(PCPRECOPROM.CODPLPAGMAX,0) = 42 THEN 
-          TRUNC((PCPRECOPROM.PRECOFIXO / 10),2)
-          ELSE 0 
-        END PARCELAS,
-        PCPRECOPROM.INICIO
-      FROM PCTABPR,
-        (SELECT PCFORMPROD.CODPRODACAB, PROMOCAO.DTINICIOVIGENCIA INICIO, PROMOCAO.DTINICIOVIGENCIA, PROMOCAO.NUMREGIAO, PROMOCAO.CODPLPAGMAX, SUM(NVL(PROMOCAO.PRECOFIXO, TABELA.PVENDA1) * PCFORMPROD.QTPRODMP) PRECOFIXO,
-          PROMOCAO.DTFIMVIGENCIA
-        FROM PCFORMPROD, PCPRECOPROM PROMOCAO, PCTABPR TABELA
-        WHERE PROMOCAO.CODPLPAGMAX = 42
-          AND PROMOCAO.DTINICIOVIGENCIA = TRUNC(TO_DATE(:${dataParamIndex2}, 'DD/MM/YYYY'))
-          AND PCFORMPROD.CODPRODMP = PROMOCAO.CODPROD
-          AND PCFORMPROD.CODPRODMP = TABELA.CODPROD
-          AND TABELA.NUMREGIAO = PROMOCAO.NUMREGIAO
-        GROUP BY PCFORMPROD.CODPRODACAB, PROMOCAO.NUMREGIAO, PROMOCAO.CODPLPAGMAX, PROMOCAO.DTFIMVIGENCIA, PROMOCAO.DTINICIOVIGENCIA) PCPRECOPROM, PCPLPAG, PCPRODUT, PCMARCA
-      WHERE PCTABPR.CODPROD = PCPRECOPROM.CODPRODACAB (+)
-        AND PCTABPR.NUMREGIAO = PCPRECOPROM.NUMREGIAO (+)
-        AND PCTABPR.CODPROD = PCPRODUT.CODPROD
-        AND PCPRODUT.CODMARCA = PCMARCA.CODMARCA (+)
-        AND PCPRECOPROM.DTFIMVIGENCIA >= TRUNC(SYSDATE)
-        AND PCPLPAG.CODPLPAG = 42
-        AND PCPRODUT.CODPROD IN (${codprodPlaceholders2.join(',')})
-        AND PCTABPR.NUMREGIAO = :${regiaoParamIndex2}
-        AND EXISTS(SELECT PCFORMPROD.CODPRODMP FROM PCFORMPROD WHERE PCFORMPROD.CODPRODACAB = PCPRODUT.CODPROD)
-    `;
-
-    const result = await this.dataSource.query(sql, params);
-
-    return result.map((row) => ({
-      codprod: row.CODPROD,
-      descricao: row.DESCRICAO,
-      marca: row.MARCA,
-      unidade: row.UNIDADE,
-      pvenda1: row.PVENDA1,
-      precofixo: row.PRECOFIXO,
-      dec: row.DEC,
-      preco: row.PRECO,
-      percdesconto: row.PERCDESCONTO,
-      dtfimvigencia: row.DTFIMVIGENCIA,
-      codplpagmax: row.CODPLPAGMAX,
-      mensagem2: row.MENSAGEM2,
-      mensagem3: row.MENSAGEM3,
-      mensagem4: row.MENSAGEM4,
-      mensagem6: row.MENSAGEM6,
-      mensagem7: row.MENSAGEM7,
-      mensagem8: row.MENSAGEM8,
-      parcelas: row.PARCELAS,
-      inicio: row.INICIO,
-    }));
-  }
 }