Compare commits
3 Commits
83a1fd78be
...
main
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
23c91d7434 | ||
|
|
1538657c3b | ||
|
|
5483040fcd |
@@ -25,7 +25,7 @@ describe('AuthService - logout', () => {
|
|||||||
jest.clearAllMocks();
|
jest.clearAllMocks();
|
||||||
});
|
});
|
||||||
|
|
||||||
describe('logout - Testes que expõem problemas', () => {
|
describe('logout - Tests that expose problems', () => {
|
||||||
/**
|
/**
|
||||||
* NOTA: Estes testes identificam problemas no método logout.
|
* NOTA: Estes testes identificam problemas no método logout.
|
||||||
*
|
*
|
||||||
@@ -40,7 +40,7 @@ describe('AuthService - logout', () => {
|
|||||||
* 8. Não sanitiza entrada
|
* 8. Não sanitiza entrada
|
||||||
*/
|
*/
|
||||||
|
|
||||||
it('deve rejeitar token vazio', async () => {
|
it('should reject empty token', async () => {
|
||||||
await expect(context.service.logout('')).rejects.toThrow(
|
await expect(context.service.logout('')).rejects.toThrow(
|
||||||
'Token não pode estar vazio',
|
'Token não pode estar vazio',
|
||||||
);
|
);
|
||||||
@@ -51,7 +51,7 @@ describe('AuthService - logout', () => {
|
|||||||
).not.toHaveBeenCalled();
|
).not.toHaveBeenCalled();
|
||||||
});
|
});
|
||||||
|
|
||||||
it('deve rejeitar token null', async () => {
|
it('should reject null token', async () => {
|
||||||
await expect(context.service.logout(null as any)).rejects.toThrow(
|
await expect(context.service.logout(null as any)).rejects.toThrow(
|
||||||
'Token não pode estar vazio',
|
'Token não pode estar vazio',
|
||||||
);
|
);
|
||||||
@@ -62,7 +62,7 @@ describe('AuthService - logout', () => {
|
|||||||
).not.toHaveBeenCalled();
|
).not.toHaveBeenCalled();
|
||||||
});
|
});
|
||||||
|
|
||||||
it('deve rejeitar token undefined', async () => {
|
it('should reject undefined token', async () => {
|
||||||
await expect(context.service.logout(undefined as any)).rejects.toThrow(
|
await expect(context.service.logout(undefined as any)).rejects.toThrow(
|
||||||
'Token não pode estar vazio',
|
'Token não pode estar vazio',
|
||||||
);
|
);
|
||||||
@@ -73,7 +73,7 @@ describe('AuthService - logout', () => {
|
|||||||
).not.toHaveBeenCalled();
|
).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(
|
await expect(context.service.logout(' ')).rejects.toThrow(
|
||||||
'Token não pode estar vazio',
|
'Token não pode estar vazio',
|
||||||
);
|
);
|
||||||
@@ -84,7 +84,7 @@ describe('AuthService - logout', () => {
|
|||||||
).not.toHaveBeenCalled();
|
).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);
|
const hugeToken = 'a'.repeat(100000);
|
||||||
|
|
||||||
await expect(context.service.logout(hugeToken)).rejects.toThrow(
|
await expect(context.service.logout(hugeToken)).rejects.toThrow(
|
||||||
@@ -97,7 +97,7 @@ describe('AuthService - logout', () => {
|
|||||||
).not.toHaveBeenCalled();
|
).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);
|
context.mockJwtService.decode.mockReturnValue(null);
|
||||||
|
|
||||||
await expect(context.service.logout('invalid.token')).rejects.toThrow(
|
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);
|
context.mockJwtService.decode.mockReturnValue({} as any);
|
||||||
|
|
||||||
await expect(context.service.logout('incomplete.token')).rejects.toThrow(
|
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);
|
context.mockTokenBlacklistService.isBlacklisted.mockResolvedValue(true);
|
||||||
|
|
||||||
await context.service.logout('already.blacklisted.token');
|
await context.service.logout('already.blacklisted.token');
|
||||||
@@ -123,7 +123,7 @@ describe('AuthService - logout', () => {
|
|||||||
).not.toHaveBeenCalled();
|
).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({
|
context.mockJwtService.decode.mockReturnValue({
|
||||||
id: 1,
|
id: 1,
|
||||||
sessionId: 'non-existent-session',
|
sessionId: 'non-existent-session',
|
||||||
@@ -138,7 +138,7 @@ describe('AuthService - logout', () => {
|
|||||||
).rejects.toThrow('Sessão não encontrada');
|
).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(() => {
|
context.mockJwtService.decode.mockImplementation(() => {
|
||||||
throw new Error('Token inválido');
|
throw new Error('Token inválido');
|
||||||
});
|
});
|
||||||
@@ -148,7 +148,7 @@ describe('AuthService - logout', () => {
|
|||||||
).rejects.toThrow('Token inválido ou não pode ser decodificado');
|
).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; --";
|
const maliciousToken = "'; DROP TABLE users; --";
|
||||||
|
|
||||||
await expect(context.service.logout(maliciousToken)).rejects.toThrow(
|
await expect(context.service.logout(maliciousToken)).rejects.toThrow(
|
||||||
@@ -158,7 +158,7 @@ describe('AuthService - logout', () => {
|
|||||||
expect(context.mockJwtService.decode).not.toHaveBeenCalled();
|
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({
|
context.mockJwtService.decode.mockReturnValue({
|
||||||
id: -1,
|
id: -1,
|
||||||
sessionId: 'session-123',
|
sessionId: 'session-123',
|
||||||
@@ -169,7 +169,7 @@ describe('AuthService - logout', () => {
|
|||||||
).rejects.toThrow('ID de usuário inválido no token');
|
).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({
|
context.mockJwtService.decode.mockReturnValue({
|
||||||
id: 1,
|
id: 1,
|
||||||
sessionId: '',
|
sessionId: '',
|
||||||
@@ -182,7 +182,7 @@ describe('AuthService - logout', () => {
|
|||||||
).not.toHaveBeenCalled();
|
).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({
|
context.mockJwtService.decode.mockReturnValue({
|
||||||
id: 1,
|
id: 1,
|
||||||
sessionId: 'session-123',
|
sessionId: 'session-123',
|
||||||
@@ -200,7 +200,7 @@ describe('AuthService - logout', () => {
|
|||||||
).toHaveBeenCalledWith('valid.token');
|
).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.isBlacklisted.mockResolvedValue(true);
|
||||||
context.mockTokenBlacklistService.addToBlacklist.mockRejectedValue(
|
context.mockTokenBlacklistService.addToBlacklist.mockRejectedValue(
|
||||||
new Error('Token já está na blacklist'),
|
new Error('Token já está na blacklist'),
|
||||||
@@ -213,7 +213,7 @@ describe('AuthService - logout', () => {
|
|||||||
).not.toHaveBeenCalled();
|
).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';
|
const invalidFormatToken = 'not.a.jwt.token';
|
||||||
|
|
||||||
await context.service.logout(invalidFormatToken);
|
await context.service.logout(invalidFormatToken);
|
||||||
@@ -221,7 +221,7 @@ describe('AuthService - logout', () => {
|
|||||||
expect(context.mockJwtService.decode).toHaveBeenCalled();
|
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.mockTokenBlacklistService.isBlacklisted.mockResolvedValue(false);
|
||||||
context.mockJwtService.decode.mockReturnValue({
|
context.mockJwtService.decode.mockReturnValue({
|
||||||
id: 1,
|
id: 1,
|
||||||
@@ -241,7 +241,7 @@ describe('AuthService - logout', () => {
|
|||||||
).toHaveBeenCalledTimes(3);
|
).toHaveBeenCalledTimes(3);
|
||||||
});
|
});
|
||||||
|
|
||||||
it('deve validar estrutura do payload decodificado', async () => {
|
it('should validate decoded payload structure', async () => {
|
||||||
context.mockJwtService.decode.mockReturnValue({
|
context.mockJwtService.decode.mockReturnValue({
|
||||||
invalidField: 'value',
|
invalidField: 'value',
|
||||||
} as any);
|
} as any);
|
||||||
@@ -258,7 +258,7 @@ describe('AuthService - logout', () => {
|
|||||||
).not.toHaveBeenCalled();
|
).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);
|
context.mockTokenBlacklistService.isBlacklisted.mockResolvedValue(false);
|
||||||
|
|
||||||
await context.service.logout('valid.token');
|
await context.service.logout('valid.token');
|
||||||
@@ -271,7 +271,7 @@ describe('AuthService - logout', () => {
|
|||||||
).toHaveBeenCalledTimes(1);
|
).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,
|
* Cenário: Race condition - token não estava na blacklist quando verificamos,
|
||||||
* mas foi adicionado por outra requisição antes de adicionarmos.
|
* mas foi adicionado por outra requisição antes de adicionarmos.
|
||||||
@@ -293,7 +293,7 @@ describe('AuthService - logout', () => {
|
|||||||
).toHaveBeenCalledWith('token.with.race.condition');
|
).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.
|
* Cenário: Falha ao adicionar token à blacklist por outro motivo.
|
||||||
* Problema: Pode falhar silenciosamente.
|
* Problema: Pode falhar silenciosamente.
|
||||||
@@ -318,7 +318,7 @@ describe('AuthService - logout', () => {
|
|||||||
).toHaveBeenCalledWith('token.with.blacklist.error');
|
).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.
|
* Cenário: Garantir ordem correta das chamadas.
|
||||||
* Problema: Pode adicionar sem verificar primeiro.
|
* Problema: Pode adicionar sem verificar primeiro.
|
||||||
|
|||||||
@@ -3,7 +3,6 @@ import { RedisClientToken } from '../../core/configs/cache/redis-client.adapter.
|
|||||||
import { IRedisClient } from '../../core/configs/cache/IRedisClient';
|
import { IRedisClient } from '../../core/configs/cache/IRedisClient';
|
||||||
import { JwtService } from '@nestjs/jwt';
|
import { JwtService } from '@nestjs/jwt';
|
||||||
import { JwtPayload } from '../models/jwt-payload.model';
|
import { JwtPayload } from '../models/jwt-payload.model';
|
||||||
import * as crypto from 'crypto';
|
|
||||||
|
|
||||||
@Injectable()
|
@Injectable()
|
||||||
export class TokenBlacklistService {
|
export class TokenBlacklistService {
|
||||||
@@ -65,6 +64,7 @@ export class TokenBlacklistService {
|
|||||||
}
|
}
|
||||||
|
|
||||||
private hashToken(token: string): string {
|
private hashToken(token: string): string {
|
||||||
|
const crypto = require('crypto');
|
||||||
return crypto
|
return crypto
|
||||||
.createHash('sha256')
|
.createHash('sha256')
|
||||||
.update(token)
|
.update(token)
|
||||||
|
|||||||
@@ -1,6 +1,6 @@
|
|||||||
import { Injectable, NotFoundException } from '@nestjs/common';
|
import { Injectable, NotFoundException } from '@nestjs/common';
|
||||||
import { UserRepository } from '../users/UserRepository';
|
import { UserRepository } from '../users/UserRepository';
|
||||||
import * as md5 from 'md5';
|
import md5 = require('md5');
|
||||||
|
|
||||||
@Injectable()
|
@Injectable()
|
||||||
export class ChangePasswordService {
|
export class ChangePasswordService {
|
||||||
|
|||||||
@@ -31,7 +31,7 @@ export class RequestSanitizerMiddleware implements NestMiddleware {
|
|||||||
|
|
||||||
private sanitizeString(str: string): string {
|
private sanitizeString(str: string): string {
|
||||||
// Remover tags HTML básicas
|
// Remover tags HTML básicas
|
||||||
str = str.replace(/<[^>]*>/g, '');
|
str = str.replace(/<(|\/|[^>\/bi]|\/[^>bi]|[^\/>][^>]+|\/[^>][^>]+)>/g, '');
|
||||||
|
|
||||||
// Remover scripts JavaScript
|
// Remover scripts JavaScript
|
||||||
str = str.replace(/javascript:/g, '');
|
str = str.replace(/javascript:/g, '');
|
||||||
|
|||||||
@@ -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);
|
|
||||||
});
|
|
||||||
});
|
|
||||||
});
|
|
||||||
|
|
||||||
@@ -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;
|
|
||||||
}
|
|
||||||
|
|
||||||
@@ -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;
|
|
||||||
}
|
|
||||||
|
|
||||||
@@ -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;
|
|
||||||
}
|
|
||||||
|
|
||||||
@@ -27,9 +27,6 @@ import { ProductDetailResponseDto } from './dto/product-detail-response.dto';
|
|||||||
import { RotinaA4QueryDto } from './dto/rotina-a4-query.dto';
|
import { RotinaA4QueryDto } from './dto/rotina-a4-query.dto';
|
||||||
import { RotinaA4ResponseDto } from './dto/rotina-a4-response.dto';
|
import { RotinaA4ResponseDto } from './dto/rotina-a4-response.dto';
|
||||||
import { UnifiedProductSearchDto } from './dto/unified-product-search.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()
|
//@ApiBearerAuth()
|
||||||
//@UseGuards(JwtAuthGuard)
|
//@UseGuards(JwtAuthGuard)
|
||||||
@@ -154,42 +151,4 @@ export class ProductsController {
|
|||||||
): Promise<ProductDetailResponseDto[]> {
|
): Promise<ProductDetailResponseDto[]> {
|
||||||
return this.productsService.unifiedProductSearch(query);
|
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);
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -9,9 +9,6 @@ import { ProductDetailResponseDto } from './dto/product-detail-response.dto';
|
|||||||
import { RotinaA4QueryDto } from './dto/rotina-a4-query.dto';
|
import { RotinaA4QueryDto } from './dto/rotina-a4-query.dto';
|
||||||
import { RotinaA4ResponseDto } from './dto/rotina-a4-response.dto';
|
import { RotinaA4ResponseDto } from './dto/rotina-a4-response.dto';
|
||||||
import { UnifiedProductSearchDto } from './dto/unified-product-search.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()
|
@Injectable()
|
||||||
export class ProductsService {
|
export class ProductsService {
|
||||||
@@ -325,6 +322,9 @@ export class ProductsService {
|
|||||||
}));
|
}));
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Busca unificada de produtos por nome, código de barras ou codprod
|
||||||
|
*/
|
||||||
async unifiedProductSearch(
|
async unifiedProductSearch(
|
||||||
query: UnifiedProductSearchDto,
|
query: UnifiedProductSearchDto,
|
||||||
): Promise<ProductDetailResponseDto[]> {
|
): Promise<ProductDetailResponseDto[]> {
|
||||||
@@ -548,239 +548,4 @@ export class ProductsService {
|
|||||||
|
|
||||||
return produto;
|
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,
|
|
||||||
}));
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user