Compare commits

..

36 Commits

Author SHA1 Message Date
Felipe Batista 15d8fecf42 teste2
Deploy NestJS API / build-and-push-deploy (push) Successful in 41s Details
2026-01-10 11:52:42 -03:00
Felipe Batista c5f284023a teste
Deploy NestJS API / build-and-push-deploy (push) Has been cancelled Details
2026-01-10 11:49:31 -03:00
joelson df466ddaba fix: update server port from 8065 to 8068
Deploy NestJS API / build-and-push-deploy (push) Successful in 4m29s Details
2026-01-09 09:27:19 -03:00
joelson 6360675ebf teste
Deploy NestJS API / build-and-push-deploy (push) Successful in 4m41s Details
2026-01-08 19:41:28 -03:00
joelson cedcb43939 :ajuste na porta para 8065
Deploy NestJS API / build-and-push-deploy (push) Successful in 4m33s Details
2026-01-08 19:03:00 -03:00
joelson b330910fbf feat: ajustado a entidade cliente
Deploy NestJS API / build-and-push-deploy (push) Successful in 3m44s Details
2026-01-08 18:53:59 -03:00
joelson 94f9208ee4 Refactor code structure for improved readability and maintainability
Deploy NestJS API / build-and-push-deploy (push) Failing after 1m34s Details
2026-01-08 18:43:22 -03:00
joelson 4e926909b8 fix: update health check status message to 'TESTE COM ALESSANDRO'
Deploy NestJS API / build-and-push-deploy (push) Successful in 3m40s Details
2026-01-06 12:26:43 -03:00
joelson 70e88913f5 refactor: simplify image tagging and pushing in deployment workflow
Deploy NestJS API / build-and-push-deploy (push) Successful in 2m8s Details
2026-01-06 12:23:33 -03:00
joelson 217329adef Merge branch 'main' of https://git.jurunense.com/joelson/vendaweb-api
Deploy NestJS API / build-and-push-deploy (push) Has been cancelled Details
2026-01-06 12:22:29 -03:00
joelson f55d0da72d refactor: update port mappings to 8068, enhance deployment configurations, and modify health check response 2026-01-06 12:20:43 -03:00
JuruSysadmin 2b91449137 fix: update health check status message to 'JURUNENSE HOME CENTER BR V2'
Deploy NestJS API / build-and-push-deploy (push) Successful in 2m42s Details
2026-01-06 11:18:19 -03:00
JuruSysadmin 95850ea39b fix: update health check status message to 'JURUNENSE HOME CENTER BR'
Deploy NestJS API / build-and-push-deploy (push) Successful in 2m48s Details
2026-01-06 11:07:03 -03:00
JuruSysadmin 1760934db3 fix: update health check response status message to 'JURUNENSE HOME CENTER'
Deploy NestJS API / build-and-push-deploy (push) Successful in 2m42s Details
2026-01-06 10:59:26 -03:00
JuruSysadmin 7b2f13ab91 fix: update health check status response to ':ok 4'
Deploy NestJS API / build-and-push-deploy (push) Successful in 2m51s Details
2026-01-06 10:52:49 -03:00
joelson f66fd4271f :ok
Deploy NestJS API / build-and-push-deploy (push) Successful in 2m45s Details
2026-01-05 15:50:31 -03:00
joelson c60eabd804 feat: Configure host-mode port mapping and a stop-first deployment strategy with rollback, removing local build.
Deploy NestJS API / build-and-push-deploy (push) Successful in 3m1s Details
2026-01-05 15:39:49 -03:00
joelson 9176d65606 refactor: Update workflow name, SHA source, Docker image tagging, and Portainer webhook notification.
Deploy NestJS API / build-and-push-deploy (push) Successful in 30s Details
2026-01-05 15:23:32 -03:00
joelson 1fa2938128 fix: remove accidental '7' character from WEBHOOK_URL secret definition in deploy workflow 2026-01-05 15:11:25 -03:00
joelson efc7d738a9 refactor: streamline Docker build/push and add webhook secret validation to deployment workflow.
Deploy vendaweb-api / build-and-push-deploy (push) Successful in 29s Details
2026-01-05 15:09:22 -03:00
joelson bf246e2882 chore: update API startup console log message
Deploy vendaweb-api / build-and-push-deploy (push) Successful in 1m2s Details
2026-01-05 14:56:17 -03:00
joelson fb724067c8 style: adjust whitespace in getVersion method
Deploy vendaweb-api / build-and-push-deploy (push) Successful in 3m14s Details
2026-01-05 14:50:27 -03:00
joelson e9c7d8d282 chore: Update health check endpoint status message.
Deploy vendaweb-api / build-and-push-deploy (push) Successful in 3m7s Details
2026-01-05 14:43:23 -03:00
joelson a92fa77e37 feat: Configure `vendaweb-api` service to build locally and connect to an external `juru-network`.
Deploy vendaweb-api / build-and-push-deploy (push) Successful in 3m39s Details
2026-01-05 14:34:15 -03:00
joelson e6fd33a22e fix: remove unused networks section from docker-compose.yml
Deploy vendaweb-api / build-and-push-deploy (push) Successful in 30s Details
2026-01-05 14:23:33 -03:00
joelson c75f8ed9f4 fix: comment out networks section in docker-compose.yml
Deploy vendaweb-api / build-and-push-deploy (push) Successful in 32s Details
2026-01-05 14:21:22 -03:00
joelson b034330e34 fix: add console log to indicate API is running on port 8066
Deploy vendaweb-api / build-and-push-deploy (push) Successful in 2m44s Details
2026-01-05 14:05:40 -03:00
joelson 61cdae600c fix: ensure server listens on all network interfaces in main.ts 2026-01-05 14:05:14 -03:00
joelson 6fe94a4a7c refactor: clean up Dockerfile by removing unnecessary comments and consolidating commands
Deploy vendaweb-api / build-and-push-deploy (push) Successful in 2m46s Details
2026-01-05 14:00:11 -03:00
joelson 0084a162f7 fix: correct port mapping in docker-compose.yml for vendaweb-api
Deploy vendaweb-api / build-and-push-deploy (push) Successful in 46s Details
2026-01-05 13:55:49 -03:00
joelson d5fa17151f fix: update Dockerfile CMD and change server port in main.ts
Deploy vendaweb-api / build-and-push-deploy (push) Successful in 50s Details
2026-01-05 13:29:57 -03:00
joelson 937b3f37ab fix: update vendaweb-api configuration in docker-compose.yml 2026-01-05 13:29:49 -03:00
joelson 7022d491ce feat: add deployment workflow for vendaweb-api
Deploy vendaweb-api / build-and-push-deploy (push) Failing after 1m19s Details
2026-01-05 12:12:54 -03:00
joelson c4e8996a22 feat: add deployment workflow for vendaweb-api 2026-01-05 12:00:48 -03:00
juru 757d547755 chore: ignora pastas de dados e arquivos sensiveis 2026-01-05 11:46:41 -03:00
juru 79fb04fdb5 first commit 2026-01-05 11:45:17 -03:00
18 changed files with 10795 additions and 8778 deletions

View File

@ -0,0 +1,30 @@
name: Deploy NestJS API
on: [push]
jobs:
build-and-push-deploy:
runs-on: ubuntu-latest
steps:
- name: Checkout
uses: actions/checkout@v3
- name: Login no Harbor
run: |
echo "${{ secrets.HARBOR_PASSWORD }}" | docker login 10.1.1.124:8082 -u ${{ secrets.HARBOR_USERNAME }} --password-stdin
- name: Build e Push
run: |
# Usando o short SHA para uma tag mais limpa
TAG=$(echo ${{ gitea.sha }} | cut -c1-7)
IMAGE_NAME="10.1.1.124:8082/library/vendaweb-api"
docker build -t $IMAGE_NAME:$TAG .
docker tag $IMAGE_NAME:$TAG $IMAGE_NAME:latest
docker push $IMAGE_NAME:$TAG
docker push $IMAGE_NAME:latest
- name: Notificar Portainer via Webhook
run: |
# O segredo PORTAINER_WEBHOOK_VENDAWEBAPI deve conter a URL completa gerada na Stack
curl -f -X POST "${{ secrets.PORTAINER_WEBHOOK_VENDAWEBAPI }}"

2
.gitignore vendored
View File

@ -33,3 +33,5 @@ lerna-debug.log*
!.vscode/launch.json
!.vscode/extensions.json
postgres-data/
.env

View File

@ -1,5 +0,0 @@
{
"recommendations": [
"cweijan.dbclient-jdbc"
]
}

View File

@ -1,32 +1,24 @@
FROM node:16
FROM node:16-bullseye-slim AS builder
WORKDIR /app
COPY package*.json ./
RUN npm install --legacy-peer-deps
COPY . .
RUN npm run build
FROM node:16-bullseye-slim
RUN apt-get update && apt-get install -y libaio1 unzip wget && mkdir -p /opt/oracle
RUN apt-get update && apt-get install -y \
apt-transport-https \
ca-certificates \
libaio1 \
unzip \
wget \
libc6 \
libncurses5 && \
mkdir -p /opt/oracle && \
wget https://download.oracle.com/otn_software/linux/instantclient/instantclient-basic-linuxx64.zip -O /opt/oracle/instantclient-basic-linuxx64.zip && \
unzip /opt/oracle/instantclient-basic-linuxx64.zip -d /opt/oracle && \
rm /opt/oracle/instantclient-basic-linuxx64.zip && \
ln -s /opt/oracle/instantclient_* /opt/oracle/instantclient && \
echo "/opt/oracle/instantclient" > /etc/ld.so.conf.d/oracle-instantclient.conf && \
ldconfig
RUN wget https://download.oracle.com/otn_software/linux/instantclient/instantclient-basic-linuxx64.zip -O /opt/oracle/client.zip && \
unzip /opt/oracle/client.zip -d /opt/oracle && \
rm /opt/oracle/client.zip && \
ln -s /opt/oracle/instantclient_* /opt/oracle/instantclient
ENV LD_LIBRARY_PATH=/opt/oracle/instantclient
WORKDIR /app
COPY --from=builder /app/dist ./dist
COPY --from=builder /app/package*.json ./
COPY --from=builder /app/node_modules ./node_modules
COPY package*.json ./
RUN npm install --legacy-peer-deps
COPY . .
EXPOSE 8068
CMD ["npm", "run", "start:prod"]

View File

@ -1,14 +1,18 @@
version: '3.8'
services:
vendaweb:
image: link70/vendaweb
deploy:
replicas: 20
resources:
limits:
cpus: '0.5'
memory: 512M
vendaweb-api:
image: 10.1.1.124:8082/library/vendaweb-api:latest
ports:
- "8065:8065"
restart: always
- "8068:8068"
networks:
- simplifique-network
deploy:
replicas: 4
update_config:
order: start-first
parallelism: 1
networks:
simplifique-network:
external: true

16599
package-lock.json generated

File diff suppressed because it is too large Load Diff

View File

@ -1,5 +1,5 @@
import { Controller, Get } from '@nestjs/common';
import { ApiTags, ApiOperation } from '@nestjs/swagger';
import { ApiOperation, ApiTags } from '@nestjs/swagger';
import { APP_VERSION } from './version';
@ApiTags('Main')
@ -8,13 +8,13 @@ export class AppController {
@Get('version')
@ApiOperation({ summary: 'Get App Version' })
getVersion() {
return { version: APP_VERSION };
return { version: APP_VERSION };
}
@Get('health')
@Get('health')
@ApiOperation({ summary: 'Health check' })
healthCheck() {
return { status: 'ok' };
return { status: 'TESTE COM Felipe2 ' };
}
}

View File

@ -2,17 +2,17 @@ import { TypeOrmModuleOptions } from '@nestjs/typeorm';
import { ConnectionOptions } from 'typeorm';
export const typeOrmConfig: TypeOrmModuleOptions = {
type: 'oracle',
type: "oracle",
// host: "192.168.100.40",
// username: "LIVIA",
// password: "LIVIA",
host: '10.1.1.241',
username: 'SEVEN',
password: 'USR54SEV',
host: "10.1.1.241",
username: "teste",
password: "teste",
// username: "API",
// password: "E05H5KIEQV3YKDJR",
port: 1521,
serviceName: 'WINT',
sid: "BDTESTE",
synchronize: false,
logging: false,
entities: [__dirname + '/../**/*.entity.{js,ts}'],
@ -20,13 +20,14 @@ export const typeOrmConfig: TypeOrmModuleOptions = {
};
export const connectionOptions: ConnectionOptions = {
type: 'oracle',
host: '10.1.1.241',
username: 'SEVEN',
password: 'USR54SEV',
type: "oracle",
host: "10.1.1.241",
username: "teste",
password: "teste",
port: 1521,
serviceName: 'WINT',
sid: "BDTESTE",
synchronize: false,
logging: false,
entities: [__dirname + '/../**/*.entity.{js,ts}'],
};
}

View File

@ -36,7 +36,7 @@ export class Shopping {
@Column({ name: 'VLDESCONTO' })
vldesconto: number;
@Column({ name: 'VLCUSTOFIN' })
@Column({name: 'VLCUSTOFIN'})
vlcustofin: number;
@Column({ name: 'CODFUNCAUTOR' })
@ -60,7 +60,4 @@ export class Shopping {
@Column({ name: 'CODTABELAFRETE' })
codtabelafrete: number;
@Column({ name: 'CODPRACA' })
codpraca: number;
}

View File

@ -1,24 +0,0 @@
export class CartUpdate {
constructor(
public id: string,
public idCustomer: number,
public idAddress: number,
public saleStore: string,
public userId: number,
public idSeller: number,
public idProfessional: number,
public idPaymentPlan: number,
public idBilling: string,
public shippingValue: number,
public scheduleDelivery: boolean,
public shippingDate: Date,
public shippingPriority: string,
public idStorePlace: number,
public notation1: string,
public notation2: string,
public deliveryNote1: string,
public deliveryNote2: string,
public deliveryNote3: string,
public carrierId: number,
) { }
}

View File

@ -20,6 +20,6 @@ async function bootstrap() {
.build();
const document = SwaggerModule.createDocument(app, options);
SwaggerModule.setup("docs", app, document);
await app.listen(8065);
}
await app.listen(8068, '0.0.0.0');}
console.log('API rodando na porta 8065 test 4');
bootstrap();

View File

@ -360,8 +360,9 @@ export class CustomerService {
newCustomer.longitude = customer.longitude;
newCustomer.tipoendereco = customer.addressType;
const oldCustomer = await this.findCustomerByCpf(newCustomer.cgcent);
if (oldCustomer) {
const oldCustomers = await this.findCustomerByCpf(newCustomer.cgcent);
if (oldCustomers && oldCustomers.length > 0) {
const oldCustomer = oldCustomers[0];
console.log('Cliente localizado: ' + oldCustomer.customerId);
newCustomer.codcli = oldCustomer.customerId;
await this.updateCustomer(newCustomer);

File diff suppressed because it is too large Load Diff

View File

@ -1,28 +1,29 @@
import { HttpException, HttpStatus, Inject, Injectable } from '@nestjs/common';
import { Connection } from 'typeorm';
import { connectionOptions } from '../../configs/typeorm.config';
import { Estavisoestoque } from '../../domain/entity/tables/estavisoestoque.entity';
import { Estruptura } from '../../domain/entity/tables/estruptura.entity';
import { Injectable, HttpException, HttpStatus, Inject, CACHE_MANAGER } from '@nestjs/common';
import { Pcclient } from '../../domain/entity/tables/pcclient.entity';
import { Esvanalisevendarca } from '../../domain/entity/views/esvanalisevendarca.entity';
import { Esvdepartamento } from '../../domain/entity/views/esvdepartamento.entity';
import { Esvparcelamentovenda } from '../../domain/entity/views/esvparcelamentovenda.entity';
import { SalesProduct } from '../../domain/entity/views/esvprodutosvenda.entity';
import { Esvsecao } from '../../domain/entity/views/esvsecao.entity';
import { Connection, getConnection } from 'typeorm';
import { Esvsituacaopedido } from '../../domain/entity/views/esvsituacaopedido.entity';
import { Stock } from '../../domain/entity/views/esvestoquevenda.entity';
import { FilterProduct } from '../../domain/models/filter-product.model';
import { Notify } from '../../domain/models/notify.model';
import { Estavisoestoque } from '../../domain/entity/tables/estavisoestoque.entity';
import { Esvparcelamentovenda } from '../../domain/entity/views/esvparcelamentovenda.entity';
import { Rupture } from '../../domain/models/rupture.model';
import { Estruptura } from '../../domain/entity/tables/estruptura.entity';
import { Esvsecao } from '../../domain/entity/views/esvsecao.entity';
import { Esvdepartamento } from '../../domain/entity/views/esvdepartamento.entity';
import { Esvanalisevendarca } from '../../domain/entity/views/esvanalisevendarca.entity';
import { connectionOptions } from '../../configs/typeorm.config';
import { CustomerService } from '../customer/customer.service';
import Redis = require('ioredis');
@Injectable()
export class SalesService {
constructor(
@Inject('REDIS_CLIENT') private readonly redisClient: Redis.Redis,
private readonly customerService: CustomerService
) { }
constructor(
@Inject('REDIS_CLIENT') private readonly redisClient: Redis.Redis,
private readonly customerService: CustomerService
) {}
async GetProducts2(store: string, pageSize: number, pageNumber: number, filter: FilterProduct = null,) {
@ -366,88 +367,88 @@ export class SalesService {
pageSize: number,
pageNumber: number,
urlDepartment: string
): Promise<any> {
): Promise<any> {
const cacheKey =
'searchByDepartment:' +
store +
'_' +
pageSize +
'_' +
pageNumber +
'_' +
urlDepartment;
'searchByDepartment:' +
store +
'_' +
pageSize +
'_' +
pageNumber +
'_' +
urlDepartment;
const lockKey = 'lock:' + cacheKey;
const lockTimeout = 30; // lock expira em 30 segundos
try {
const cachedResult = await this.redisClient.get(cacheKey);
if (cachedResult) {
console.log('Retornando resultado do cache (searchByDepartment)');
return JSON.parse(cachedResult);
}
const cachedResult = await this.redisClient.get(cacheKey);
if (cachedResult) {
console.log('Retornando resultado do cache (searchByDepartment)');
return JSON.parse(cachedResult);
}
} catch (err) {
console.error('Erro ao acessar o Redis no searchByDepartment:', err?.message || err);
console.error('Erro ao acessar o Redis no searchByDepartment:', err?.message || err);
}
const lockValue = Date.now() + lockTimeout * 1000 + 1;
let acquiredLock: string | null = null;
try {
acquiredLock = await this.redisClient.set(lockKey, lockValue, 'NX', 'EX', lockTimeout);
acquiredLock = await this.redisClient.set(lockKey, lockValue, 'NX', 'EX', lockTimeout);
} catch (err) {
console.error('Erro ao adquirir lock no Redis (searchByDepartment):', err?.message || err);
console.error('Erro ao adquirir lock no Redis (searchByDepartment):', err?.message || err);
}
if (acquiredLock === 'OK') {
const connectionDb = new Connection(connectionOptions);
await connectionDb.connect();
const queryRunner = connectionDb.createQueryRunner();
await queryRunner.connect();
const connectionDb = new Connection(connectionOptions);
await connectionDb.connect();
const queryRunner = connectionDb.createQueryRunner();
await queryRunner.connect();
try {
if (pageSize === 0) pageSize = 50;
if (pageNumber === 0) pageNumber = 1;
const offSet = (pageNumber - 1) * pageSize;
let products = await queryRunner.manager
.getRepository(SalesProduct)
.createQueryBuilder('esvlistaprodutos')
.where('"esvlistaprodutos".urldepartamento = :urlDepartment', { urlDepartment })
.andWhere('("esvlistaprodutos".codfilial = :codfilial OR :codfilial = \'99\')', { codfilial: store })
.limit(pageSize)
.offset(offSet)
.orderBy('"esvlistaprodutos".DESCRICAO', 'ASC')
.getMany();
products = this.createListImages(products);
try {
if (pageSize === 0) pageSize = 50;
if (pageNumber === 0) pageNumber = 1;
const offSet = (pageNumber - 1) * pageSize;
let products = await queryRunner.manager
.getRepository(SalesProduct)
.createQueryBuilder('esvlistaprodutos')
.where('"esvlistaprodutos".urldepartamento = :urlDepartment', { urlDepartment })
.andWhere('("esvlistaprodutos".codfilial = :codfilial OR :codfilial = \'99\')', { codfilial: store })
.limit(pageSize)
.offset(offSet)
.orderBy('"esvlistaprodutos".DESCRICAO', 'ASC')
.getMany();
products = this.createListImages(products);
try {
await this.redisClient.set(cacheKey, JSON.stringify(products), 'EX', 3600);
} catch (cacheErr) {
console.error('Erro ao salvar o resultado no cache (searchByDepartment):', cacheErr?.message || cacheErr);
}
return products;
} catch (error) {
console.error('Erro ao executar a query no searchByDepartment:', error?.message || error);
throw error;
} finally {
await queryRunner.release();
await connectionDb.close();
try {
const currentLockValue = await this.redisClient.get(lockKey);
if (currentLockValue === lockValue.toString()) {
await this.redisClient.del(lockKey);
}
} catch (lockErr) {
console.error('Erro ao liberar o lock do Redis (searchByDepartment):', lockErr?.message || lockErr);
}
await this.redisClient.set(cacheKey, JSON.stringify(products), 'EX', 3600);
} catch (cacheErr) {
console.error('Erro ao salvar o resultado no cache (searchByDepartment):', cacheErr?.message || cacheErr);
}
return products;
} catch (error) {
console.error('Erro ao executar a query no searchByDepartment:', error?.message || error);
throw error;
} finally {
await queryRunner.release();
await connectionDb.close();
try {
const currentLockValue = await this.redisClient.get(lockKey);
if (currentLockValue === lockValue.toString()) {
await this.redisClient.del(lockKey);
}
} catch (lockErr) {
console.error('Erro ao liberar o lock do Redis (searchByDepartment):', lockErr?.message || lockErr);
}
}
} else {
console.log('Lock não adquirido (searchByDepartment), aguardando e tentando novamente...');
await this.sleep(1000);
return this.searchByDepartment(store, pageSize, pageNumber, urlDepartment);
console.log('Lock não adquirido (searchByDepartment), aguardando e tentando novamente...');
await this.sleep(1000);
return this.searchByDepartment(store, pageSize, pageNumber, urlDepartment);
}
}
}
@ -953,13 +954,10 @@ export class SalesService {
WHERE PCFILIALRETIRA.CODFILIALVENDA = '${storeId}'
AND PCFILIALRETIRA.CODFILIALRETIRA = ESVESTOQUEVENDA.CODFILIAL ) > 0 THEN 1
ELSE 0 END ) as "allowDelivery"
, NVL(PCEST.QTEXPOSICAO,0) as "exhibition"
FROM ESVESTOQUEVENDA, PCFILIAL, PCEST
FROM ESVESTOQUEVENDA, PCFILIAL
WHERE ESVESTOQUEVENDA.CODPROD = ${id}
AND ESVESTOQUEVENDA.CODFILIAL = PCFILIAL.CODIGO
AND ESVESTOQUEVENDA.CODFILIAL = PCEST.CODFILIAL
AND ESVESTOQUEVENDA.CODPROD = PCEST.CODPROD
ORDER BY TO_NUMBER(ESVESTOQUEVENDA.CODFILIAL)`;
ORDER BY TO_NUMBER(ESVESTOQUEVENDA.CODFILIAL) `;
const stock = await queryRunner.query(sql);
@ -1214,66 +1212,66 @@ export class SalesService {
const lockTimeout = 30;
try {
const cachedDepartments = await this.redisClient.get(cacheKey);
if (cachedDepartments) {
console.log('Buscando departamentos no Redis');
return JSON.parse(cachedDepartments);
}
const cachedDepartments = await this.redisClient.get(cacheKey);
if (cachedDepartments) {
console.log('Buscando departamentos no Redis');
return JSON.parse(cachedDepartments);
}
} catch (err) {
console.error('Erro ao acessar o Redis (cache):', err);
console.error('Erro ao acessar o Redis (cache):', err);
}
const lockValue = Date.now() + lockTimeout * 1000 + 1;
const lockValue = Date.now() + lockTimeout * 1000 + 1;
const acquiredLock = await this.redisClient.set(lockKey, lockValue, 'NX', 'EX', lockTimeout);
if (acquiredLock === 'OK') {
const connectionDb = new Connection(connectionOptions);
await connectionDb.connect();
const queryRunner = connectionDb.createQueryRunner();
await queryRunner.connect();
const connectionDb = new Connection(connectionOptions);
await connectionDb.connect();
const queryRunner = connectionDb.createQueryRunner();
await queryRunner.connect();
try {
const departments = await queryRunner.manager
.getRepository(Esvdepartamento)
.createQueryBuilder('Esvdepartamento')
.innerJoinAndSelect('Esvdepartamento.secoes', 'secoes')
.innerJoinAndSelect('secoes.categorias', 'categorias')
.where('"Esvdepartamento".tituloecommerce is not null')
.orderBy('"Esvdepartamento".tituloecommerce, "secoes".tituloecommerce, "categorias".tituloecommerce')
.getMany();
try {
const departments = await queryRunner.manager
.getRepository(Esvdepartamento)
.createQueryBuilder('Esvdepartamento')
.innerJoinAndSelect('Esvdepartamento.secoes', 'secoes')
.innerJoinAndSelect('secoes.categorias', 'categorias')
.where('"Esvdepartamento".tituloecommerce is not null')
.orderBy('"Esvdepartamento".tituloecommerce, "secoes".tituloecommerce, "categorias".tituloecommerce')
.getMany();
try {
await this.redisClient.set(cacheKey, JSON.stringify(departments), 'EX', 3600);
} catch (cacheErr) {
console.error('Erro ao armazenar dados no Redis:', cacheErr);
}
return departments;
} catch (dbErr) {
console.error('Erro na consulta ao banco de dados:', dbErr);
throw dbErr;
} finally {
await queryRunner.release();
await connectionDb.close();
// Libera o lock somente se ainda for o proprietário
try {
const currentLockValue = await this.redisClient.get(lockKey);
if (currentLockValue === lockValue.toString()) {
await this.redisClient.del(lockKey);
}
} catch (lockErr) {
console.error('Erro ao liberar o lock do Redis:', lockErr);
}
await this.redisClient.set(cacheKey, JSON.stringify(departments), 'EX', 3600);
} catch (cacheErr) {
console.error('Erro ao armazenar dados no Redis:', cacheErr);
}
return departments;
} catch (dbErr) {
console.error('Erro na consulta ao banco de dados:', dbErr);
throw dbErr;
} finally {
await queryRunner.release();
await connectionDb.close();
// Libera o lock somente se ainda for o proprietário
try {
const currentLockValue = await this.redisClient.get(lockKey);
if (currentLockValue === lockValue.toString()) {
await this.redisClient.del(lockKey);
}
} catch (lockErr) {
console.error('Erro ao liberar o lock do Redis:', lockErr);
}
}
} else {
console.log('Lock não adquirido, aguardando a liberação...');
await this.sleep(1000); // aguarda 1 segundo
return this.getDepartments();
console.log('Lock não adquirido, aguardando a liberação...');
await this.sleep(1000); // aguarda 1 segundo
return this.getDepartments();
}
}
private sleep(ms: number): Promise<void> {
}
private sleep(ms: number): Promise<void> {
return new Promise(resolve => setTimeout(resolve, ms));
}
}
@ -1470,7 +1468,6 @@ export class SalesService {
.query(sql, [cityId, cartId]);
return deliveryTaxTable;
} catch (err) {
console.log(err);
throw err;
} finally {
await queryRunner.release();
@ -1491,7 +1488,7 @@ export class SalesService {
WHERE ID = '${cartId}'`;
await queryRunner.manager
.query(sql);
.query(sql);
await queryRunner.commitTransaction();
} catch (err) {
await queryRunner.rollbackTransaction();
@ -1505,20 +1502,8 @@ export class SalesService {
}
async calculateDeliveryTaxOrder(dataDeliveryTax: any) {
console.log("json dataDeliveryTax", dataDeliveryTax);
/*const dataDeliveryTax = {
cartId: cartId,
cityId: cityId,
ibgeCode: ibgeCode,
priorityDelivery: priorityDelivery,
};*/
let cityId = await this.customerService.findCity(dataDeliveryTax.ibgeCode);
let cityId = 0;
if (dataDeliveryTax.ibgeCode) {
cityId = await this.customerService.findCity(dataDeliveryTax.ibgeCode);
} else {
cityId = dataDeliveryTax.cityId;
}
await this.updatePriorityDelivery(dataDeliveryTax.cartId, dataDeliveryTax.priorityDelivery);
if (cityId == 0) {
@ -1596,7 +1581,7 @@ export class SalesService {
await queryRunner.connect();
try {
const sql = `SELECT ESF_CALCULAR_PRAZO_ENTREGA_PROGRAMADA(TO_DATE('${saleDate}', 'DD-MM-YYYY'), ${invoiceStoreId}, ${placeId}, '${cartId}') AS "days" FROM DUAL`;
// const sql = `SELECT ESF_CALCULAR_PRAZO_ENTREGA(TO_DATE('${saleDate}', 'DD-MM-YYYY')) AS "days" FROM DUAL`;
// const sql = `SELECT ESF_CALCULAR_PRAZO_ENTREGA(TO_DATE('${saleDate}', 'DD-MM-YYYY')) AS "days" FROM DUAL`;
const timeDays = await queryRunner.query(sql);
const sqlRetiraPosterior = `SELECT ( PROXIMO_DIA_UTIL(TO_DATE('${saleDate}', 'DD-MM-YYYY'), '4') - TRUNC(SYSDATE) ) AS "days" FROM DUAL`;

View File

@ -6,17 +6,15 @@ import { OrderDiscount } from 'src/domain/models/order-discount.model';
import { OrderTaxDelivery } from 'src/domain/models/order-taxdelivery.model';
import { LogOrder } from 'src/domain/models/log-order.model';
import { ApiTags } from '@nestjs/swagger';
import { Cart } from 'src/domain/models/cart.model';
import { CartUpdate } from 'src/domain/models/cart-update.model';
@ApiTags('Shopping')
@Controller('api/v1/shopping')
export class ShoppingController {
constructor(private shoppingService: ShoppingService) { }
constructor(private shoppingService: ShoppingService){}
@Get('cart/:id')
async getCart(@Param('id') id: string) {
async getCart(@Param('id') id: string){
try {
const cart = await this.shoppingService.GetItensCart(id);
if (cart == null || cart.length == 0)
@ -29,10 +27,10 @@ export class ShoppingController {
}
@Get(':id')
async getPreVenda(@Param('id') id: string) {
async getPreVenda(@Param('id') id: string ){
try {
const cart = await this.shoppingService.getShopping(id);
if (cart == null)
if (cart == null )
throw new HttpException("Carrinho de compras não encontrado", HttpStatus.NOT_FOUND);
return cart;
} catch (error) {
@ -43,13 +41,13 @@ export class ShoppingController {
@Get('cart/:idcart/item/:idProduct/tipoentrega/:deliveryType')
async getItemCart(@Req() request, @Param('idCart') idCart: string,
@Param('idProduct') idProduct: string, @Param('deliveryType') deliveryType: string) {
@Param('idProduct') idProduct: string, @Param('deliveryType') deliveryType: string){
let store = '99';
try {
if (request.headers['x-store'])
store = request.headers['x-store'];
const cart = await this.shoppingService.getItemCart(idCart, idProduct, store, deliveryType);
if (cart == null)
if (cart == null )
throw new HttpException("Item não foi encontrado no carrinho de compras.", HttpStatus.NOT_FOUND);
return cart;
} catch (error) {
@ -59,8 +57,8 @@ export class ShoppingController {
}
@Get('cart/lot/:productId/:customerId')
async getLotProduct(@Req() request, @Param('productId') productId: number,
@Param('customerId') customerId: number) {
async getLotProduct( @Req() request, @Param('productId') productId: number,
@Param('customerId') customerId: number ) {
let store = '99';
try {
if (request.headers['x-store'])
@ -75,7 +73,7 @@ export class ShoppingController {
@Post('item')
async createItemShopping(@Body() item: ShoppingItem) {
async createItemShopping(@Body() item: ShoppingItem){
console.log('createItemShopping')
try {
return await this.shoppingService.createItemCart(item);
@ -84,21 +82,8 @@ export class ShoppingController {
}
}
@Put('cart')
async updateCart(@Body() cart: CartUpdate) {
try {
if (cart.id == null) {
throw new HttpException('Cart sem Id informado, faça a inclusão do item no carrinho.', HttpStatus.BAD_REQUEST);
}
const updateCart = await this.shoppingService.updateShopping(cart);
return updateCart;
} catch (error) {
throw new HttpException(error.message, HttpStatus.BAD_REQUEST);
}
}
@Post('log')
async logOrderShopping(@Body() logOrder: LogOrder) {
async logOrderShopping(@Body() logOrder: LogOrder){
try {
console.log('logOrderShopping')
return await this.shoppingService.createLogShopping(logOrder);
@ -108,10 +93,10 @@ export class ShoppingController {
}
@Put('item')
async updateQuantityItem(@Body() item: ShoppingItem) {
async updateQuantityItem(@Body() item: ShoppingItem){
console.log(item);
try {
if (item.id == null) {
if (item.id == null){
throw new HttpException('Item sem Id informado, faça a inclusão do item no carrinho.', HttpStatus.BAD_REQUEST);
}
const itemCreate = await this.shoppingService.updateItem(item);
@ -122,10 +107,10 @@ export class ShoppingController {
}
@Put('item/discount')
async updatePriceItem(@Body() item: ShoppingItem) {
async updatePriceItem(@Body() item: ShoppingItem){
console.log(item);
try {
if (item.id == null) {
if (item.id == null){
throw new HttpException('Item sem Id informado, faça a inclusão do item no carrinho.', HttpStatus.BAD_REQUEST);
}
const itemCreate = await this.shoppingService.updatePrice(item);
@ -157,7 +142,7 @@ export class ShoppingController {
}
@Delete('item/delete/:id')
async deleteItem(@Param('id') id: string) {
async deleteItem(@Param('id') id: string){
try {
await this.shoppingService.deleteItem(id);
return new ResultModel(true, 'Item excluído com sucesso!', id, null,);
@ -180,4 +165,4 @@ export class ShoppingController {
}
}
}

View File

@ -8,8 +8,6 @@ import { Shopping } from 'src/domain/entity/tables/estprevendac.entity';
import { OrderTaxDelivery } from 'src/domain/models/order-taxdelivery.model';
import { connectionOptions } from 'src/configs/typeorm.config';
import { LogOrder } from 'src/domain/models/log-order.model';
import { Cart } from 'src/domain/models/cart.model';
import { CartUpdate } from 'src/domain/models/cart-update.model';
@Injectable()
export class ShoppingService {
@ -169,7 +167,7 @@ export class ShoppingService {
AND E.CODFILIAL = '${itemShopping.stockStore}'`);
let quantityStock = 0;
if (dataStockItem.length > 0) {
if ( dataStockItem.length > 0 ) {
quantityStock = dataStockItem[0].quantityStock;
}
@ -301,58 +299,6 @@ export class ShoppingService {
}
async updateShopping(cart: CartUpdate) {
const connectionDb = new Connection(connectionOptions);
await connectionDb.connect();
const queryRunner = connectionDb.createQueryRunner();
await queryRunner.connect();
await queryRunner.startTransaction();
try {
const sqlUpdate = `UPDATE ESTPREVENDAC SET
CODFILIAL = :1,
CODUSUR = :2,
CODCLI = :3,
CODENDENTCLI = :4,
VLPEDIDO = :5,
VLDESCONTO = :6,
VLTAXAENTREGA = :7,
TIPOPRIORIDADEENTREGA = :8
WHERE ID = :9
`;
const total = await queryRunner.query('SELECT SUM(ESTPREVENDAI.PTABELA * ESTPREVENDAI.QT) as "vltabela" ' +
' ,SUM(ESTPREVENDAI.PVENDA * ESTPREVENDAI.QT) as "vlatend" ' +
' ,SUM(ESTPREVENDAI.VLDESCONTO * ESTPREVENDAI.QT) as "vldesconto" ' +
' ,SUM(PCPRODUT.PESOBRUTO * ESTPREVENDAI.QT) as "totpeso" ' +
' FROM ESTPREVENDAI, PCPRODUT ' +
' WHERE ESTPREVENDAI.CODPROD = PCPRODUT.CODPROD ' +
' AND ESTPREVENDAI.IDCART = :1', [cart.id]);
await queryRunner.query(sqlUpdate, [
cart.saleStore,
cart.userId,
cart.idCustomer,
cart.idAddress,
total[0].vlatend,
total[0].vldesconto,
cart.shippingValue,
cart.shippingPriority,
cart.id
]);
await queryRunner.commitTransaction();
return cart;
} catch (error) {
await queryRunner.rollbackTransaction();
throw error;
} finally {
await queryRunner.release();
await connectionDb.close();
}
}
async updateTotalShopping(idCart: string) {
const connection = new Connection(connectionOptions);
await connection.connect();

View File

@ -13,9 +13,7 @@
"paths": {
"src/*": ["./src/*"]
},
"incremental": true,
"skipLibCheck": true,
"strict": false
"incremental": true
},
"exclude": ["node_modules", "dist"]
}