feat/painel-cliente #2
|
|
@ -36,7 +36,7 @@ export class Shopping {
|
|||
@Column({ name: 'VLDESCONTO' })
|
||||
vldesconto: number;
|
||||
|
||||
@Column({name: 'VLCUSTOFIN'})
|
||||
@Column({ name: 'VLCUSTOFIN' })
|
||||
vlcustofin: number;
|
||||
|
||||
@Column({ name: 'CODFUNCAUTOR' })
|
||||
|
|
@ -60,4 +60,7 @@ export class Shopping {
|
|||
@Column({ name: 'CODTABELAFRETE' })
|
||||
codtabelafrete: number;
|
||||
|
||||
@Column({ name: 'CODPRACA' })
|
||||
codpraca: number;
|
||||
|
||||
}
|
||||
|
|
|
|||
|
|
@ -0,0 +1,24 @@
|
|||
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,
|
||||
) { }
|
||||
}
|
||||
|
|
@ -20,10 +20,10 @@ 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,) {
|
||||
|
|
@ -367,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();
|
||||
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);
|
||||
|
||||
const connectionDb = new Connection(connectionOptions);
|
||||
await connectionDb.connect();
|
||||
const queryRunner = connectionDb.createQueryRunner();
|
||||
await queryRunner.connect();
|
||||
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);
|
||||
}
|
||||
if (pageSize === 0) pageSize = 50;
|
||||
if (pageNumber === 0) pageNumber = 1;
|
||||
const offSet = (pageNumber - 1) * pageSize;
|
||||
|
||||
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();
|
||||
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();
|
||||
|
||||
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);
|
||||
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);
|
||||
}
|
||||
}
|
||||
}
|
||||
} 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);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
|
||||
|
|
@ -1212,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();
|
||||
|
||||
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();
|
||||
const connectionDb = new Connection(connectionOptions);
|
||||
await connectionDb.connect();
|
||||
const queryRunner = connectionDb.createQueryRunner();
|
||||
await queryRunner.connect();
|
||||
|
||||
try {
|
||||
await this.redisClient.set(cacheKey, JSON.stringify(departments), 'EX', 3600);
|
||||
} catch (cacheErr) {
|
||||
console.error('Erro ao armazenar dados no Redis:', cacheErr);
|
||||
}
|
||||
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();
|
||||
|
||||
return departments;
|
||||
} catch (dbErr) {
|
||||
console.error('Erro na consulta ao banco de dados:', dbErr);
|
||||
throw dbErr;
|
||||
} finally {
|
||||
await queryRunner.release();
|
||||
await connectionDb.close();
|
||||
try {
|
||||
await this.redisClient.set(cacheKey, JSON.stringify(departments), 'EX', 3600);
|
||||
} catch (cacheErr) {
|
||||
console.error('Erro ao armazenar dados no Redis:', cacheErr);
|
||||
}
|
||||
|
||||
// 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);
|
||||
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));
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
|
||||
|
|
@ -1468,6 +1468,7 @@ export class SalesService {
|
|||
.query(sql, [cityId, cartId]);
|
||||
return deliveryTaxTable;
|
||||
} catch (err) {
|
||||
console.log(err);
|
||||
throw err;
|
||||
} finally {
|
||||
await queryRunner.release();
|
||||
|
|
@ -1488,7 +1489,7 @@ export class SalesService {
|
|||
WHERE ID = '${cartId}'`;
|
||||
|
||||
await queryRunner.manager
|
||||
.query(sql);
|
||||
.query(sql);
|
||||
await queryRunner.commitTransaction();
|
||||
} catch (err) {
|
||||
await queryRunner.rollbackTransaction();
|
||||
|
|
@ -1502,7 +1503,20 @@ export class SalesService {
|
|||
}
|
||||
|
||||
async calculateDeliveryTaxOrder(dataDeliveryTax: any) {
|
||||
let cityId = await this.customerService.findCity(dataDeliveryTax.ibgeCode);
|
||||
console.log("json dataDeliveryTax", dataDeliveryTax);
|
||||
/*const dataDeliveryTax = {
|
||||
cartId: cartId,
|
||||
cityId: cityId,
|
||||
ibgeCode: ibgeCode,
|
||||
priorityDelivery: priorityDelivery,
|
||||
};*/
|
||||
|
||||
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) {
|
||||
|
|
@ -1580,7 +1594,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`;
|
||||
|
|
|
|||
|
|
@ -6,15 +6,17 @@ 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)
|
||||
|
|
@ -27,10 +29,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) {
|
||||
|
|
@ -41,13 +43,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) {
|
||||
|
|
@ -57,8 +59,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'])
|
||||
|
|
@ -73,7 +75,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);
|
||||
|
|
@ -82,8 +84,21 @@ 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);
|
||||
|
|
@ -93,10 +108,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);
|
||||
|
|
@ -107,10 +122,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);
|
||||
|
|
@ -142,7 +157,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,);
|
||||
|
|
@ -165,4 +180,4 @@ export class ShoppingController {
|
|||
}
|
||||
|
||||
|
||||
}
|
||||
}
|
||||
|
|
|
|||
|
|
@ -8,6 +8,8 @@ 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 {
|
||||
|
|
@ -167,7 +169,7 @@ export class ShoppingService {
|
|||
AND E.CODFILIAL = '${itemShopping.stockStore}'`);
|
||||
|
||||
let quantityStock = 0;
|
||||
if ( dataStockItem.length > 0 ) {
|
||||
if (dataStockItem.length > 0) {
|
||||
quantityStock = dataStockItem[0].quantityStock;
|
||||
}
|
||||
|
||||
|
|
@ -299,6 +301,58 @@ 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();
|
||||
|
|
|
|||
Loading…
Reference in New Issue