teste2

.gitea/workflows/deploy-api.yaml

@@ -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 }}"

.gitignore

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

.vscode/extensions.json

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

Dockerfile

@@ -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 \
+RUN wget https://download.oracle.com/otn_software/linux/instantclient/instantclient-basic-linuxx64.zip -O /opt/oracle/client.zip && \
-    apt-transport-https \
+    unzip /opt/oracle/client.zip -d /opt/oracle && \
-    ca-certificates \
+    rm /opt/oracle/client.zip && \
-    libaio1 \
+    ln -s /opt/oracle/instantclient_* /opt/oracle/instantclient
-    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
-
 
+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 ./
+EXPOSE 8068
-
-
-RUN npm install  --legacy-peer-deps
-
-COPY . .
-
-
 CMD ["npm", "run", "start:prod"]

docker-compose.yml

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

src/app.controller.ts

@@ -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 ' };
 }
 
 }

src/configs/typeorm.config.ts

@@ -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',
+  host: "10.1.1.241",
-  username: 'SEVEN',
+  username: "teste",
-  password: 'USR54SEV',
+  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',
+  type: "oracle",
-  host: '10.1.1.241',
+  host: "10.1.1.241",
-  username: 'SEVEN',
+  username: "teste",
-  password: 'USR54SEV',
+  password: "teste",
   port: 1521,
-  serviceName: 'WINT',
+  sid: "BDTESTE",
   synchronize: false,
   logging: false,
   entities: [__dirname + '/../**/*.entity.{js,ts}'],
-};
+}
+

src/domain/entity/tables/estprevendac.entity.ts

@@ -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;
-
 }

src/domain/models/cart-update.model.ts

@@ -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,
-    ) { }
-}

src/main.ts

@@ -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();

src/sales/customer/customer.service.ts

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

src/sales/sales/sales.service.ts

@@ -1,28 +1,29 @@
-import { HttpException, HttpStatus, Inject, Injectable } from '@nestjs/common';
+import { Injectable, HttpException, HttpStatus, Inject, CACHE_MANAGER } 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 { 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(
+  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,) {
@@ -366,88 +367,88 @@ export class SalesService {
         pageSize: number,
         pageNumber: number,
         urlDepartment: string
-    ): Promise<any> {
+      ): Promise<any> {
         const cacheKey =
-            'searchByDepartment:' +
+          'searchByDepartment:' +
-            store +
+          store +
-            '_' +
+          '_' +
-            pageSize +
+          pageSize +
-            '_' +
+          '_' +
-            pageNumber +
+          pageNumber +
-            '_' +
+          '_' +
-            urlDepartment;
+          urlDepartment;
         const lockKey = 'lock:' + cacheKey;
         const lockTimeout = 30; // lock expira em 30 segundos
       
         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) {
-            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);
+          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 {
-                if (pageSize === 0) pageSize = 50;
+              await this.redisClient.set(cacheKey, JSON.stringify(products), 'EX', 3600);
-                if (pageNumber === 0) pageNumber = 1;
+            } catch (cacheErr) {
-                const offSet = (pageNumber - 1) * pageSize;
+              console.error('Erro ao salvar o resultado no cache (searchByDepartment):', cacheErr?.message || cacheErr);
-
-                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);
-                }
             }
+      
+            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...');
+          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);
         }
-    }
+      }
       
       
       
@@ -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
-                                FROM ESVESTOQUEVENDA, PCFILIAL, PCEST
                             WHERE ESVESTOQUEVENDA.CODPROD = ${id}
                               AND ESVESTOQUEVENDA.CODFILIAL = PCFILIAL.CODIGO
-                              AND ESVESTOQUEVENDA.CODFILIAL = PCEST.CODFILIAL
+                            ORDER BY TO_NUMBER(ESVESTOQUEVENDA.CODFILIAL) `;
-                              AND ESVESTOQUEVENDA.CODPROD = PCEST.CODPROD
-                            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);
+          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) {
-            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);
+          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 {
-                const departments = await queryRunner.manager
+              await this.redisClient.set(cacheKey, JSON.stringify(departments), 'EX', 3600);
-                    .getRepository(Esvdepartamento)
+            } catch (cacheErr) {
-                    .createQueryBuilder('Esvdepartamento')
+              console.error('Erro ao armazenar dados no Redis:', cacheErr);
-                    .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);
-                }
             }
+      
+            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...');
+          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));
-    }
+      }
       
       
     
@@ -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);
+        let cityId = await this.customerService.findCity(dataDeliveryTax.ibgeCode);
-        /*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) {
@@ -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`;

src/sales/shopping/shopping.controller.ts

@@ -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,
+    async getLotProduct( @Req() request, @Param('productId') productId: number,
-        @Param('customerId') customerId: 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 {
     }
 
 
-}
+ }

src/sales/shopping/shopping.service.ts

@@ -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();

tsconfig.json

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