simplifique/Vendaweb-api
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Ajustes para simplifique
All checks were successful
Deploy NestJS API / build-and-push-deploy (push) Successful in 2m9s
Details

Browse Source
This commit is contained in:
Luis Eduardo Estevao
2026-01-12 16:19:11 -03:00
parent 2b9868bf6d
commit 6c1599fbaa
4 changed files with 211 additions and 211 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/Auth/services/user.service.ts
View File

@@ -93,7 +93,7 @@ export class UserService {
' WHERE PCEMPR.CODFILIAL = PCFILIAL.CODIGO (+)' + ' WHERE PCEMPR.CODFILIAL = PCFILIAL.CODIGO (+)' +
' AND PCPARAMFILIAL.CODFILIAL = \'99\' ' + ' AND PCPARAMFILIAL.CODFILIAL = \'99\' ' +
' AND PCPARAMFILIAL.NOME = \'CON_CODSETORGERENTELOJA\' ' + ' AND PCPARAMFILIAL.NOME = \'CON_CODSETORGERENTELOJA\' ' +
' AND PCEMPR.EMAIL = :username AND PCEMPR.SENHABD = CRYPT(:password, USUARIOBD)'; ' AND PCEMPR.USUARIOBD = :username AND PCEMPR.SENHABD = CRYPT(:password, USUARIOBD)';
const users = await queryRunner.manager const users = await queryRunner.manager
.query(sql, [user.email, user.password]); .query(sql, [user.email, user.password]);
@@ -142,7 +142,7 @@ export class UserService {
.query(sqlDiasSemEntrega, [Number.parseInt(users[0].deliveryTime)]); .query(sqlDiasSemEntrega, [Number.parseInt(users[0].deliveryTime)]);
const days = Number.parseInt(deliveryDays2[0].days) + const days = Number.parseInt(deliveryDays2[0].days) +
( noDeliveryDays.length > 0 ? Number.parseInt(noDeliveryDays[0].daysNoDelivery) : 0 ); (noDeliveryDays.length > 0 ? Number.parseInt(noDeliveryDays[0].daysNoDelivery) : 0);
const userDb = users[0]; const userDb = users[0];
console.log(userDb); console.log(userDb);

6
src/domain/entity/tables/pcclient.entity.ts
View File

@@ -1355,7 +1355,7 @@ export class Pcclient {
@Column({ name: 'ORGAOPUBMUNICIPAL' }) @Column({ name: 'ORGAOPUBMUNICIPAL' })
orgaopubmunicipal: string; orgaopubmunicipal: string;
@Column({ name: 'CODCIDADECOM' }) @Column({ name: 'CODCIDADECOM' })
codcidadecom: number; codcidadecom: number;
@Column({ name: 'CODPROMOCAOMED' }) @Column({ name: 'CODPROMOCAOMED' })
@@ -1622,8 +1622,8 @@ export class Pcclient {
@Column({ name: 'CODCONDCOMERCIAL' }) @Column({ name: 'CODCONDCOMERCIAL' })
codcondcomercial: string; codcondcomercial: string;
@Column({ name: 'MEIOCOMUNICACAO' }) // @Column({ name: 'MEIOCOMUNICACAO' })
meiocomunicacao: string; // meiocomunicacao: string;
@Column({ name: 'CODGRUPOCOMERCIALMED' }) @Column({ name: 'CODGRUPOCOMERCIALMED' })
codgrupocomercialmed: number; codgrupocomercialmed: number;

60
src/sales/customer/customer.service.ts
View File

@@ -44,7 +44,7 @@ export class CustomerService {
' ,pccidade.codibge as "ibgeCode" ' + ' ,pccidade.codibge as "ibgeCode" ' +
' ,pcclient.dtnasc as "birthdate" ' + ' ,pcclient.dtnasc as "birthdate" ' +
' ,pcclient.codatv1 as "ramoId" ' + ' ,pcclient.codatv1 as "ramoId" ' +
' ,pcclient.meiocomunicacao as "communicate" ' + // ' ,pcclient.meiocomunicacao as "communicate" ' +
' ,pcclient.latitude as "latitude" ' + ' ,pcclient.latitude as "latitude" ' +
' ,pcclient.longitude as "longitude" ' + ' ,pcclient.longitude as "longitude" ' +
' ,pcclient.codmunicipio as "ibgeCode" ' + ' ,pcclient.codmunicipio as "ibgeCode" ' +
@@ -102,14 +102,14 @@ export class CustomerService {
' ,pcclient.telent as "phone" ' + ' ,pcclient.telent as "phone" ' +
' ,pcclient.telcelent as "cellPhone" ' + ' ,pcclient.telcelent as "cellPhone" ' +
' ,pcclient.ieent as "numberState" ' + ' ,pcclient.ieent as "numberState" ' +
' ,pcclient.codcategoria as "categoryId" ' + // ' ,pcclient.codcategoria as "categoryId" ' +
' ,pcclient.codsubcategoria as "subCategoryId" ' + // ' ,pcclient.codsubcategoria as "subCategoryId" ' +
' ,pcclient.codpraca as "placeId" ' + ' ,pcclient.codpraca as "placeId" ' +
' ,pcclient.codusur1 as "sellerId" ' + ' ,pcclient.codusur1 as "sellerId" ' +
' ,pccidade.codibge as "ibgeCode" ' + ' ,pccidade.codibge as "ibgeCode" ' +
' ,pcclient.dtnasc as "birthdate" ' + ' ,pcclient.dtnasc as "birthdate" ' +
' ,pcclient.codatv1 as "ramoId" ' + ' ,pcclient.codatv1 as "ramoId" ' +
' ,pcclient.meiocomunicacao as "communicate" ' + // ' ,pcclient.meiocomunicacao as "communicate" ' +
' ,pcclient.latitude as "latitude" ' + ' ,pcclient.latitude as "latitude" ' +
' ,pcclient.longitude as "longitude" ' + ' ,pcclient.longitude as "longitude" ' +
' ,pcclient.codmunicipio as "ibgeCode" ' + ' ,pcclient.codmunicipio as "ibgeCode" ' +
@@ -158,7 +158,7 @@ export class CustomerService {
' ,pccidade.codibge as "ibgeCode" ' + ' ,pccidade.codibge as "ibgeCode" ' +
' ,pcclient.dtnasc as "birthdate" ' + ' ,pcclient.dtnasc as "birthdate" ' +
' ,pcclient.codatv1 as "ramoId" ' + ' ,pcclient.codatv1 as "ramoId" ' +
' ,pcclient.meiocomunicacao as "communicate" ' + //' ,pcclient.meiocomunicacao as "communicate" ' +
' ,pcclient.latitude as "latitude" ' + ' ,pcclient.latitude as "latitude" ' +
' ,pcclient.longitude as "longitude" ' + ' ,pcclient.longitude as "longitude" ' +
' ,pcclient.codmunicipio as "ibgeCode" ' + ' ,pcclient.codmunicipio as "ibgeCode" ' +
@@ -173,7 +173,7 @@ export class CustomerService {
FROM PCPRACA FROM PCPRACA
WHERE PCPRACA.CODPRACA = ${customer[0].placeId}`); WHERE PCPRACA.CODPRACA = ${customer[0].placeId}`);
return {...customer[0], place: place[0]}; return { ...customer[0], place: place[0] };
} catch (error) { } catch (error) {
console.log(error); console.log(error);
throw error; throw error;
@@ -267,16 +267,16 @@ export class CustomerService {
newCustomer.telcelent = customer.cellPhone; newCustomer.telcelent = customer.cellPhone;
newCustomer.celularwhatsapp = customer.cellPhone; newCustomer.celularwhatsapp = customer.cellPhone;
newCustomer.codusur1 = customer.sellerId; newCustomer.codusur1 = customer.sellerId;
newCustomer.codatv1 = ( customer.ramo != null && customer.ramo.id > 0 ) ? customer.ramo.id : newCustomer.codatv1; newCustomer.codatv1 = (customer.ramo != null && customer.ramo.id > 0) ? customer.ramo.id : newCustomer.codatv1;
//Endereço de entrega //Endereço de entrega
newCustomer.cepent = customer.zipCode; newCustomer.cepent = customer.zipCode;
newCustomer.enderent = customer.address.toUpperCase(); newCustomer.enderent = customer.address.toUpperCase();
newCustomer.numeroent = customer.addressNumber; newCustomer.numeroent = customer.addressNumber;
if ( customer.complement !== null && customer.complement.length > 80 ) { if (customer.complement !== null && customer.complement.length > 80) {
newCustomer.complementoent = customer.complement.substring(0, 80 ).toUpperCase(); newCustomer.complementoent = customer.complement.substring(0, 80).toUpperCase();
} else { } else {
if ( customer.complement != null ) { if (customer.complement != null) {
newCustomer.complementoent = customer.complement.toUpperCase(); newCustomer.complementoent = customer.complement.toUpperCase();
} }
} }
newCustomer.bairroent = customer.neighborhood.toUpperCase(); newCustomer.bairroent = customer.neighborhood.toUpperCase();
@@ -286,10 +286,10 @@ export class CustomerService {
newCustomer.cepcom = customer.zipCode; newCustomer.cepcom = customer.zipCode;
newCustomer.endercom = customer.address.toUpperCase(); newCustomer.endercom = customer.address.toUpperCase();
newCustomer.numerocom = customer.addressNumber.toUpperCase(); newCustomer.numerocom = customer.addressNumber.toUpperCase();
if ( customer.complement !== null && customer.complement.length > 80 ) { if (customer.complement !== null && customer.complement.length > 80) {
newCustomer.complementocom = customer.complement.substring(0, 80 ).toUpperCase(); newCustomer.complementocom = customer.complement.substring(0, 80).toUpperCase();
} else { } else {
if ( customer.complement != null ) { if (customer.complement != null) {
newCustomer.complementocom = customer.complement.toUpperCase(); newCustomer.complementocom = customer.complement.toUpperCase();
} }
} }
@@ -300,10 +300,10 @@ export class CustomerService {
newCustomer.cepcob = customer.zipCode; newCustomer.cepcob = customer.zipCode;
newCustomer.endercob = customer.address.toUpperCase(); newCustomer.endercob = customer.address.toUpperCase();
newCustomer.numerocob = customer.addressNumber; newCustomer.numerocob = customer.addressNumber;
if ( customer.complement !== null && customer.complement.length > 80 ) { if (customer.complement !== null && customer.complement.length > 80) {
newCustomer.complementocob = customer.complement.substring(0, 80 ).toUpperCase(); newCustomer.complementocob = customer.complement.substring(0, 80).toUpperCase();
} else { } else {
if ( customer.complement ) { if (customer.complement) {
newCustomer.complementocob = customer.complement.toUpperCase(); newCustomer.complementocob = customer.complement.toUpperCase();
} }
} }
@@ -317,7 +317,7 @@ export class CustomerService {
newCustomer.codmunicipio = Number.parseInt(customer.ibgeCode); newCustomer.codmunicipio = Number.parseInt(customer.ibgeCode);
newCustomer.codcidadecom = newCustomer.codcidade; newCustomer.codcidadecom = newCustomer.codcidade;
newCustomer.dtnasc = customer.birthdate; newCustomer.dtnasc = customer.birthdate;
newCustomer.meiocomunicacao = customer.communicate; // newCustomer.meiocomunicacao = customer.communicate;
newCustomer.codfunccad = customer.idUser; newCustomer.codfunccad = customer.idUser;
newCustomer.codfunccadastro = customer.idUser; newCustomer.codfunccadastro = customer.idUser;
newCustomer.codfuncultalter = customer.idUser; newCustomer.codfuncultalter = customer.idUser;
@@ -341,7 +341,7 @@ export class CustomerService {
city: customer.city, state: customer.state, city: customer.city, state: customer.state,
allowMessage: customer.allowMessage, cellPhone: customer.cellPhone, allowMessage: customer.allowMessage, cellPhone: customer.cellPhone,
category: customer.category, subCategory: customer.subCategory, category: customer.category, subCategory: customer.subCategory,
place: customer.place, ramo: customer.ramo, meiocomunicacao: customer.communicate, place: customer.place, ramo: customer.ramo, /*meiocomunicacao: customer.communicate,*/
latitude: customer.latitude, longitude: customer.longitude, ibgeCode: customer.ibgeCode, latitude: customer.latitude, longitude: customer.longitude, ibgeCode: customer.ibgeCode,
addressType: customer.addressType, addressType: customer.addressType,
}; };
@@ -361,7 +361,7 @@ export class CustomerService {
city: customer.city, state: customer.state, city: customer.city, state: customer.state,
allowMessage: customer.allowMessage, cellPhone: customer.cellPhone, allowMessage: customer.allowMessage, cellPhone: customer.cellPhone,
category: customer.category, subCategory: customer.subCategory, category: customer.category, subCategory: customer.subCategory,
place: customer.place, meiocomunicacao: customer.communicate, place: customer.place, /*meiocomunicacao: customer.communicate,*/
ramo: customer.ramo, latitude: customer.latitude, longitude: customer.longitude, ramo: customer.ramo, latitude: customer.latitude, longitude: customer.longitude,
ibgeCode: customer.ibgeCode, addressType: customer.addressType, ibgeCode: customer.ibgeCode, addressType: customer.addressType,
}; };
@@ -378,7 +378,7 @@ export class CustomerService {
await queryRunner.connect(); await queryRunner.connect();
await queryRunner.startTransaction(); await queryRunner.startTransaction();
try { try {
console.log("MEIO DE COMUNICACAO: " + client.meiocomunicacao); //console.log("MEIO DE COMUNICACAO: " + client.meiocomunicacao);
await queryRunner.manager await queryRunner.manager
.createQueryBuilder() .createQueryBuilder()
.update(Pcclient) .update(Pcclient)
@@ -419,7 +419,7 @@ export class CustomerService {
codcidadecom: client.codcidade, codcidadecom: client.codcidade,
dtnasc: client.dtnasc, dtnasc: client.dtnasc,
codatv1: client.codatv1, codatv1: client.codatv1,
meiocomunicacao: client.meiocomunicacao, // meiocomunicacao: client.meiocomunicacao,
codfuncultalter: client.codfuncultalter, codfuncultalter: client.codfuncultalter,
dtultalter: client.dtultalter, dtultalter: client.dtultalter,
latitude: client.latitude, latitude: client.latitude,
@@ -434,7 +434,7 @@ export class CustomerService {
await queryRunner.rollbackTransaction(); await queryRunner.rollbackTransaction();
throw err; throw err;
} finally { } finally {
if ( queryRunner.isTransactionActive) { if (queryRunner.isTransactionActive) {
await queryRunner.rollbackTransaction(); await queryRunner.rollbackTransaction();
} }
await queryRunner.release(); await queryRunner.release();
@@ -533,12 +533,12 @@ export class CustomerService {
const queryRunner = connection.createQueryRunner(); const queryRunner = connection.createQueryRunner();
try { try {
await connection.connect(); await connection.connect();
await queryRunner.connect(); await queryRunner.connect();
// lets now open a new transaction: // lets now open a new transaction:
await queryRunner.startTransaction(); await queryRunner.startTransaction();
let sql = `SELECT PROXNUMCLI as "proxnumcli" FROM PCCONSUM WHERE 1 = 1 FOR UPDATE`; let sql = `SELECT PROXNUMCLI as "proxnumcli" FROM PCCONSUM WHERE 1 = 1 FOR UPDATE`;
@@ -566,14 +566,14 @@ export class CustomerService {
} catch (err) { } catch (err) {
// since we have errors let's rollback changes we made // since we have errors let's rollback changes we made
if ( queryRunner.isTransactionActive) { if (queryRunner.isTransactionActive) {
await queryRunner.rollbackTransaction(); await queryRunner.rollbackTransaction();
} }
console.log(err); console.log(err);
return -1; return -1;
} finally { } finally {
if ( queryRunner.isTransactionActive) { if (queryRunner.isTransactionActive) {
await queryRunner.rollbackTransaction(); await queryRunner.rollbackTransaction();
} }
// you need to release query runner which is manually created: // you need to release query runner which is manually created:
@@ -603,7 +603,7 @@ export class CustomerService {
console.log(err); console.log(err);
throw err; throw err;
} finally { } finally {
if ( queryRunner.isTransactionActive) { if (queryRunner.isTransactionActive) {
await queryRunner.rollbackTransaction(); await queryRunner.rollbackTransaction();
} }
await queryRunner.release(); await queryRunner.release();

234
src/sales/sales/sales.service.ts
View File

@@ -20,10 +20,10 @@ import Redis = require('ioredis');
@Injectable() @Injectable()
export class SalesService { export class SalesService {
constructor( constructor(
@Inject('REDIS_CLIENT') private readonly redisClient: Redis.Redis, @Inject('REDIS_CLIENT') private readonly redisClient: Redis.Redis,
private readonly customerService: CustomerService private readonly customerService: CustomerService
) {} ) { }
async GetProducts2(store: string, pageSize: number, pageNumber: number, filter: FilterProduct = null,) { async GetProducts2(store: string, pageSize: number, pageNumber: number, filter: FilterProduct = null,) {
@@ -367,88 +367,88 @@ export class SalesService {
pageSize: number, pageSize: number,
pageNumber: number, pageNumber: number,
urlDepartment: string urlDepartment: string
): Promise<any> { ): Promise<any> {
const cacheKey = const cacheKey =
'searchByDepartment:' + 'searchByDepartment:' +
store + store +
'_' + '_' +
pageSize + pageSize +
'_' + '_' +
pageNumber + pageNumber +
'_' + '_' +
urlDepartment; urlDepartment;
const lockKey = 'lock:' + cacheKey; const lockKey = 'lock:' + cacheKey;
const lockTimeout = 30; // lock expira em 30 segundos const lockTimeout = 30; // lock expira em 30 segundos
try { try {
const cachedResult = await this.redisClient.get(cacheKey); const cachedResult = await this.redisClient.get(cacheKey);
if (cachedResult) { if (cachedResult) {
console.log('Retornando resultado do cache (searchByDepartment)'); console.log('Retornando resultado do cache (searchByDepartment)');
return JSON.parse(cachedResult); return JSON.parse(cachedResult);
} }
} catch (err) { } 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; const lockValue = Date.now() + lockTimeout * 1000 + 1;
let acquiredLock: string | null = null; let acquiredLock: string | null = null;
try { try {
acquiredLock = await this.redisClient.set(lockKey, lockValue, 'NX', 'EX', lockTimeout); acquiredLock = await this.redisClient.set(lockKey, lockValue, 'NX', 'EX', lockTimeout);
} catch (err) { } 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') { if (acquiredLock === 'OK') {
const connectionDb = new Connection(connectionOptions); const connectionDb = new Connection(connectionOptions);
await connectionDb.connect(); await connectionDb.connect();
const queryRunner = connectionDb.createQueryRunner(); const queryRunner = connectionDb.createQueryRunner();
await queryRunner.connect(); 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 { try {
await this.redisClient.set(cacheKey, JSON.stringify(products), 'EX', 3600); if (pageSize === 0) pageSize = 50;
} catch (cacheErr) { if (pageNumber === 0) pageNumber = 1;
console.error('Erro ao salvar o resultado no cache (searchByDepartment):', cacheErr?.message || cacheErr); const offSet = (pageNumber - 1) * pageSize;
}
return products; let products = await queryRunner.manager
} catch (error) { .getRepository(SalesProduct)
console.error('Erro ao executar a query no searchByDepartment:', error?.message || error); .createQueryBuilder('esvlistaprodutos')
throw error; .where('"esvlistaprodutos".urldepartamento = :urlDepartment', { urlDepartment })
} finally { .andWhere('("esvlistaprodutos".codfilial = :codfilial OR :codfilial = \'99\')', { codfilial: store })
await queryRunner.release(); .limit(pageSize)
await connectionDb.close(); .offset(offSet)
.orderBy('"esvlistaprodutos".DESCRICAO', 'ASC')
.getMany();
try { products = this.createListImages(products);
const currentLockValue = await this.redisClient.get(lockKey);
if (currentLockValue === lockValue.toString()) { try {
await this.redisClient.del(lockKey); await this.redisClient.set(cacheKey, JSON.stringify(products), 'EX', 3600);
} } catch (cacheErr) {
} catch (lockErr) { console.error('Erro ao salvar o resultado no cache (searchByDepartment):', cacheErr?.message || cacheErr);
console.error('Erro ao liberar o lock do Redis (searchByDepartment):', lockErr?.message || lockErr); }
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 { } else {
console.log('Lock não adquirido (searchByDepartment), aguardando e tentando novamente...'); console.log('Lock não adquirido (searchByDepartment), aguardando e tentando novamente...');
await this.sleep(1000); await this.sleep(1000);
return this.searchByDepartment(store, pageSize, pageNumber, urlDepartment); return this.searchByDepartment(store, pageSize, pageNumber, urlDepartment);
} }
} }
@@ -1211,67 +1211,67 @@ export class SalesService {
const lockKey = 'departments_lock'; const lockKey = 'departments_lock';
const lockTimeout = 30; const lockTimeout = 30;
try { // try {
const cachedDepartments = await this.redisClient.get(cacheKey); // const cachedDepartments = await this.redisClient.get(cacheKey);
if (cachedDepartments) { // if (cachedDepartments) {
console.log('Buscando departamentos no Redis'); // console.log('Buscando departamentos no Redis');
return JSON.parse(cachedDepartments); // return JSON.parse(cachedDepartments);
} // }
} catch (err) { // } 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); const acquiredLock = await this.redisClient.set(lockKey, lockValue, 'NX', 'EX', lockTimeout);
if (acquiredLock === 'OK') { if (acquiredLock === 'OK') {
const connectionDb = new Connection(connectionOptions); const connectionDb = new Connection(connectionOptions);
await connectionDb.connect(); await connectionDb.connect();
const queryRunner = connectionDb.createQueryRunner(); const queryRunner = connectionDb.createQueryRunner();
await queryRunner.connect(); 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 { try {
await this.redisClient.set(cacheKey, JSON.stringify(departments), 'EX', 3600); const departments = await queryRunner.manager
} catch (cacheErr) { .getRepository(Esvdepartamento)
console.error('Erro ao armazenar dados no Redis:', cacheErr); .createQueryBuilder('Esvdepartamento')
} .innerJoinAndSelect('Esvdepartamento.secoes', 'secoes')
.leftJoinAndSelect('secoes.categorias', 'categorias')
.where('"Esvdepartamento".tituloecommerce is not null')
.orderBy('"Esvdepartamento".tituloecommerce, "secoes".tituloecommerce, "categorias".tituloecommerce')
.getMany();
return departments; try {
} catch (dbErr) { await this.redisClient.set(cacheKey, JSON.stringify(departments), 'EX', 3600);
console.error('Erro na consulta ao banco de dados:', dbErr); } catch (cacheErr) {
throw dbErr; console.error('Erro ao armazenar dados no Redis:', cacheErr);
} finally { }
await queryRunner.release();
await connectionDb.close();
// Libera o lock somente se ainda for o proprietário return departments;
try { } catch (dbErr) {
const currentLockValue = await this.redisClient.get(lockKey); console.error('Erro na consulta ao banco de dados:', dbErr);
if (currentLockValue === lockValue.toString()) { throw dbErr;
await this.redisClient.del(lockKey); } finally {
} await queryRunner.release();
} catch (lockErr) { await connectionDb.close();
console.error('Erro ao liberar o lock do Redis:', lockErr);
// 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 { } else {
console.log('Lock não adquirido, aguardando a liberação...'); console.log('Lock não adquirido, aguardando a liberação...');
await this.sleep(1000); // aguarda 1 segundo await this.sleep(1000); // aguarda 1 segundo
return this.getDepartments(); return this.getDepartments();
} }
} }
private sleep(ms: number): Promise<void> { private sleep(ms: number): Promise<void> {
return new Promise(resolve => setTimeout(resolve, ms)); return new Promise(resolve => setTimeout(resolve, ms));
} }
@@ -1488,7 +1488,7 @@ export class SalesService {
WHERE ID = '${cartId}'`; WHERE ID = '${cartId}'`;
await queryRunner.manager await queryRunner.manager
.query(sql); .query(sql);
await queryRunner.commitTransaction(); await queryRunner.commitTransaction();
} catch (err) { } catch (err) {
await queryRunner.rollbackTransaction(); await queryRunner.rollbackTransaction();
@@ -1580,7 +1580,7 @@ export class SalesService {
await queryRunner.connect(); await queryRunner.connect();
try { 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_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 timeDays = await queryRunner.query(sql);
const sqlRetiraPosterior = `SELECT ( PROXIMO_DIA_UTIL(TO_DATE('${saleDate}', 'DD-MM-YYYY'), '4') - TRUNC(SYSDATE) ) AS "days" FROM DUAL`; const sqlRetiraPosterior = `SELECT ( PROXIMO_DIA_UTIL(TO_DATE('${saleDate}', 'DD-MM-YYYY'), '4') - TRUNC(SYSDATE) ) AS "days" FROM DUAL`;