From e5dc346b969042cc476f1531c0085369712e8082 Mon Sep 17 00:00:00 2001 From: Joelbrit0 Date: Thu, 29 Jan 2026 19:54:41 -0300 Subject: [PATCH] fix: persist shipping fee and refresh k8s docs --- KUBERNETES.md | 76 --------------- k8s/README.md | 156 ++++++++++++++++++++++++++++++ src/app.controller.ts | 2 +- src/main.ts | 19 ++-- src/sales/order/order.service.ts | 157 ++++++++++++++++--------------- 5 files changed, 248 insertions(+), 162 deletions(-) delete mode 100644 KUBERNETES.md create mode 100644 k8s/README.md diff --git a/KUBERNETES.md b/KUBERNETES.md deleted file mode 100644 index 80892a2..0000000 --- a/KUBERNETES.md +++ /dev/null @@ -1,76 +0,0 @@ -# Documentação do Kubernetes - -Este documento descreve a infraestrutura e configuração do Kubernetes para o projeto **Vendaweb-api**, utilizando uma abordagem GitOps com ArgoCD e Kustomize. - -## Estrutura de Diretórios e Arquivos - -A configuração do Kubernetes está localizada no diretório `k8s/` e segue uma estrutura organizada para facilitar a manutenção e escalabilidade: - -``` -k8s/ -├── argocd/ # Configurações do ArgoCD -│ └── application-prod.yaml # Definição da Application para o ambiente de produção -├── base/ # Recursos base do Kubernetes (Kustomize Base) -│ ├── configmap.yaml # ConfigMap base -│ ├── deployment.yaml # Deployment base da aplicação -│ ├── kustomization.yaml # Arquivo principal do Kustomize Base -│ ├── secret.yaml # Secret base -│ └── service.yaml # Service base -└── overlays/ # Sobrescritas para diferentes ambientes (Kustomize Overlays) - └── prod/ # Ambiente de produção - ├── application-prod.yaml - ├── deployment-image-digest-patch.yaml - ├── kustomization.yaml - └── service-patch.yaml -``` - -## Recursos Base (`k8s/base`) - -O diretório `base` contém as definições padrão dos recursos que são comuns a todos os ambientes. - -### Deployment (`deployment.yaml`) - -- **Nome**: `vendaweb-api` -- **Replicas**: 3 (Base) / 15 (Produção via overlay) -- **Imagem**: `git.simplifiquehc.com.br/simplifique/vendaweb-api:` -- **Porta do Container**: 8067 -- **Resources**: - - Requests: CPU 100m, Memory 256Mi - - Limits: CPU 500m, Memory 512Mi -- **Probes**: Liveness, Readiness e Startup probes configurados no endpoint `/v1/health`. -- **Environment**: Configurações carregadas via ConfigMap e Secret. - -### Service (`service.yaml`) - -- **Tipo**: ClusterIP -- **Porta**: 8065 (TCP) - -## Ambientes (`k8s/overlays`) - -### Produção (`k8s/overlays/prod`) - -A sobreposição de produção personaliza a configuração base para o ambiente produtivo. - -- **Namespace**: `vendaweb-prod` -- **Patches**: Aplica modificações específicas (ex: tag da imagem, NodePort do service, replicas) via `kustomization.yaml`. - -## Deploy com ArgoCD (`k8s/argocd`) - -O deploy é gerenciado pelo ArgoCD, que sincroniza o estado do cluster com o repositório Git. - -### Application (`application-prod.yaml`) - -- **Nome**: `vendaweb-api-prod` -- **Namespace do ArgoCD**: `argocd` -- **Origem (Source)**: - - Repositório: `https://git.simplifiquehc.com.br/simplifique/Vendaweb-api.git` - - Revisão: `main` - - Path: `k8s/overlays/prod` (Aponta para o overlay de produção) -- **Destino (Destination)**: - - Cluster: `https://kubernetes.default.svc` - - Namespace: `vendaweb-prod` -- **Sync Policy**: Automatizado com `selfHeal` ativado e criação automática de namespace. - ---- - -**Observação**: Certifique-se de que as credenciais do Harbor (`imagePullSecrets`) estejam corretamente configuradas no namespace de destino para permitir o pull da imagem. diff --git a/k8s/README.md b/k8s/README.md new file mode 100644 index 0000000..20469bc --- /dev/null +++ b/k8s/README.md @@ -0,0 +1,156 @@ +# Kubernetes Infra (k8s) - vendaweb-api + +Este diretorio contem os manifests Kubernetes do `vendaweb-api` usando Kustomize (base + overlays). + +## Visao geral + +- App: `vendaweb-api` (Deployment + Service) +- Porta HTTP do container/Service: `8067` +- Healthcheck usado pelos probes: `GET /v1/health` +- Config via `ConfigMap` + `Secret` (injetados com `envFrom`) +- Overlay prod: + - Namespace: `vendaweb-prod` + - Service: `NodePort` (porta externa `30001`) + - Replicas: `15` + +## Estrutura + +- `k8s/base/` + - `deployment.yaml`: deployment padrao (replicas 3), porta 8067, probes `/v1/health`, `imagePullSecrets: gitea-auth` + - `service.yaml`: `ClusterIP` expondo 8067 + - `configmap.yaml`: variaveis nao sensiveis (ex.: Redis/DB host/port) + - `secret.yaml`: variaveis sensiveis (ex.: usuario/senha do DB) + - `kustomization.yaml`: agrega os recursos do base + +- `k8s/overlays/prod/` + - `kustomization.yaml`: aplica patches e define `namespace: vendaweb-prod` + - `service-patch.yaml`: muda Service para `NodePort` e fixa `nodePort: 30001` + - `deployment-prod-patch.yaml`: ajusta `replicas: 15` + - `deployment-image-digest-patch.yaml`: sobrescreve a `image:` do container + +- `k8s/argocd/application-prod.yaml` + - Aplica o overlay `k8s/overlays/prod` via Argo CD + - Sync automatizado com `selfHeal` e `prune` + +## Portas e acesso + +- Dentro do cluster: Service `vendaweb-api:8067` +- Overlay prod (NodePort): porta externa `30001` (mapeia para `8067`) + +Notas: + +- O processo Node/Nest escuta em `8067` (ver `src/main.ts`). +- A variavel `PORT` em `.env` nao e usada pelo bootstrap atual; o k8s esta configurado para 8067. + +## Deploy com kubectl/kustomize + +Gerar o YAML final (sem aplicar): + +```bash +kubectl kustomize k8s/overlays/prod +``` + +Aplicar o overlay prod: + +```bash +kubectl apply -k k8s/overlays/prod +``` + +Validar o que sera aplicado (dry-run): + +```bash +kubectl apply -k k8s/overlays/prod --dry-run=server +``` + +Ver diffs (se seu kubectl suportar): + +```bash +kubectl diff -k k8s/overlays/prod +``` + +## Argo CD (prod) + +O Argo CD esta configurado em `k8s/argocd/application-prod.yaml` para: + +- `path: k8s/overlays/prod` +- `targetRevision: main` +- `destination.namespace: vendaweb-prod` (com `CreateNamespace=true`) + +Se voce esta usando Argo CD, o fluxo recomendado e: + +- atualizar manifests no Git (overlay prod) +- deixar o Argo CD sincronizar automaticamente + +## Configuracao (ConfigMap/Secret) + +- `k8s/base/configmap.yaml` (`vendaweb-api-config`) + - `REDIS_HOST`, `REDIS_PORT`, `DB_HOST`, `DB_PORT`, `DB_SERVICE_NAME` +- `k8s/base/secret.yaml` (`vendaweb-api-secrets`) + - `DB_USERNAME`, `DB_PASSWORD` + +Importante: + +- O `Secret` esta em `stringData` no repositorio (texto puro). Para ambiente real, prefira um gerenciador de segredos (ExternalSecrets, SOPS, Vault etc.) e nao commite credenciais. + +## Imagem e pipeline + +O workflow `.gitea/workflows/deploy-api.yaml`: + +- builda e publica `git.simplifiquehc.com.br/simplifique/vendaweb-api:` e `:latest` +- atualiza `k8s/overlays/prod/deployment-image-digest-patch.yaml` para apontar para o tag do commit + +Isso e pensado para o Argo CD detectar a alteracao no Git e aplicar. + +## Comandos uteis (day-2) + +Assumindo namespace `vendaweb-prod`: + +```bash +kubectl -n vendaweb-prod get all +kubectl -n vendaweb-prod get pods -l app=vendaweb-api -o wide +kubectl -n vendaweb-prod describe deploy/vendaweb-api +kubectl -n vendaweb-prod describe pod -l app=vendaweb-api +``` + +Logs: + +```bash +kubectl -n vendaweb-prod logs deploy/vendaweb-api --tail=200 +kubectl -n vendaweb-prod logs -l app=vendaweb-api --tail=200 --all-containers +kubectl -n vendaweb-prod logs -l app=vendaweb-api -f +``` + +Rollout: + +```bash +kubectl -n vendaweb-prod rollout status deploy/vendaweb-api +kubectl -n vendaweb-prod rollout history deploy/vendaweb-api +kubectl -n vendaweb-prod rollout restart deploy/vendaweb-api +``` + +Exec/Debug: + +```bash +kubectl -n vendaweb-prod exec -it deploy/vendaweb-api -- sh +kubectl -n vendaweb-prod port-forward svc/vendaweb-api 8067:8067 +``` + +## Troubleshooting rapido + +- `ImagePullBackOff`: + - conferir `imagePullSecrets: gitea-auth` no namespace (`kubectl -n vendaweb-prod get secret gitea-auth`) + - conferir o valor de `image:` no overlay prod + +- `CrashLoopBackOff`: + - ver logs do pod e eventos (`kubectl -n vendaweb-prod describe pod ...`) + - validar variaveis do `ConfigMap`/`Secret` + +- Probes falhando: + - garantir que a rota `/v1/health` responde 200 e que a app esta ouvindo em `8067` + +## Mudancas comuns + +- Alterar porta externa (NodePort): `k8s/overlays/prod/service-patch.yaml` +- Alterar replicas em prod: `k8s/overlays/prod/deployment-prod-patch.yaml` +- Alterar imagem/tag em prod: `k8s/overlays/prod/deployment-image-digest-patch.yaml` +- Alterar envs: `k8s/base/configmap.yaml` e `k8s/base/secret.yaml` diff --git a/src/app.controller.ts b/src/app.controller.ts index 5ec75ab..1902f02 100644 --- a/src/app.controller.ts +++ b/src/app.controller.ts @@ -14,7 +14,7 @@ export class AppController { @Get('health') @ApiOperation({ summary: 'Health check' }) healthCheck() { - return { status: 'SIMPLIFIQUE HOME CENTER 202' }; + return { status: 'SIMPLIFIQUE HOME CENTER 2026' }; } } diff --git a/src/main.ts b/src/main.ts index 4f9ba01..e448676 100644 --- a/src/main.ts +++ b/src/main.ts @@ -6,20 +6,25 @@ import 'reflect-metadata'; import { CustomLoggerService } from './services/custom-logger.service'; async function bootstrap() { - const app = await NestFactory.create(AppModule, { cors: true, logger: new CustomLoggerService()}); + const app = await NestFactory.create(AppModule, { + cors: true, + logger: new CustomLoggerService(), + }); app.enableCors(); app.use(compression()); const options = new DocumentBuilder() .setTitle('API Venda web') - .setDescription(`API criada para realizar todo processo da venda assistida, como criação de oraçamento de venda, pedido de venda + .setDescription( + `API criada para realizar todo processo da venda assistida, como criação de oraçamento de venda, pedido de venda cadastro de novos clientes, novos endereços. A API também fornece dados para o portal de parceiros como a manutenção - do cadastro de parceiros, consulta de venda de movimentação e pagamentos, e fechamento das comissões dos parceiros.`) - .setVersion("2023.1.2") - .addTag("VendaWeb") - .addTag("Auth") + do cadastro de parceiros, consulta de venda de movimentação e pagamentos, e fechamento das comissões dos parceiros.`, + ) + .setVersion('2023.1.2') + .addTag('VendaWeb') + .addTag('Auth') .build(); const document = SwaggerModule.createDocument(app, options); - SwaggerModule.setup("docs", app, document); + SwaggerModule.setup('docs', app, document); await app.listen(8067); } bootstrap(); diff --git a/src/sales/order/order.service.ts b/src/sales/order/order.service.ts index 2bb3a10..019fda8 100644 --- a/src/sales/order/order.service.ts +++ b/src/sales/order/order.service.ts @@ -1,5 +1,5 @@ /* eslint-disable @typescript-eslint/camelcase */ -import { HttpException, HttpStatus, Injectable,Inject } from '@nestjs/common'; +import { HttpException, HttpStatus, Injectable, Inject } from '@nestjs/common'; import { ShoppingItens } from 'src/domain/entity/tables/estprevendai.entity'; import { Sale } from 'src/domain/entity/tables/estvenda.entity'; import { Pcpedctemp } from 'src/domain/entity/tables/pcpedctemp.entity'; @@ -527,6 +527,7 @@ export class OrderService { preOrder.esc_ajustarfinanceiro = "N"; preOrder.esc_obternsu = "N"; preOrder.esc_vloutrasdespweb = 0; + preOrder.vloutrasdesp = cart.shippingValue; preOrder.pedidopagoecommerce = "S"; preOrder.numpedmktplace = ""; preOrder.numitens = cart.itens.length; @@ -538,7 +539,7 @@ export class OrderService { //Dados do cliente preOrder.codcli = cart.idCustomer; - preOrder.codpraca = (cart.shippingPriority == "M" && cart.idStorePlace != null ) ? cart.idStorePlace : customer.codpraca; + preOrder.codpraca = (cart.shippingPriority == "M" && cart.idStorePlace != null) ? cart.idStorePlace : customer.codpraca; preOrder.fretedespacho = customer.fretedespacho; preOrder.codfornecfrete = cart.carrierId; @@ -586,7 +587,7 @@ export class OrderService { itemOrder.codfilialretira = item.idStock; itemOrder.tipoentrega = (item.deliveryMethod == 'RA') ? "RP" : item.deliveryMethod; itemOrder.rp_imediata = (item.deliveryMethod == 'RA') ? "S" : "N"; - if ( item.deliveryMethod == 'RA') { + if (item.deliveryMethod == 'RA') { preOrder.dtentrega = new Date(); } itemOrder.ptabela = Number.parseFloat(listPrice); @@ -619,7 +620,7 @@ export class OrderService { itemOrder.codfilialretira = item.idStock; itemOrder.tipoentrega = (item.deliveryMethod == 'RA') ? "RP" : item.deliveryMethod; itemOrder.rp_imediata = (item.deliveryMethod == 'RA') ? "S" : "N"; - if ( item.deliveryMethod == 'RA') { + if (item.deliveryMethod == 'RA') { preOrder.dtentrega = new Date(); } itemOrder.ptabela = item.listPrice; @@ -643,34 +644,34 @@ export class OrderService { //#endregion - if (cart.shippingValue > 0) { - const itemOrder = new Pcpeditemp(); - itemOrder.tipointegracao = "W"; - itemOrder.integradora = 10; - itemOrder.numpedrca = idPreOrder; - itemOrder.numpedweb = idPreOrder; - itemOrder.codcli = cart.idCustomer; - itemOrder.codusur = idSellerPreorder; //cart.idSeller; - itemOrder.numseq = numeroSeq; - itemOrder.codprod = 48500; - itemOrder.codauxiliar = 48500; - itemOrder.codfilialretira = '12'; - itemOrder.tipoentrega = 'EF'; - itemOrder.ptabela = Number.parseFloat(cart.shippingValue.toString()); - itemOrder.pvenda = Number.parseFloat(cart.shippingValue.toString()); - itemOrder.qt = 1; - itemOrder.data = new Date(); + // if (cart.shippingValue > 0) { + // const itemOrder = new Pcpeditemp(); + // itemOrder.tipointegracao = "W"; + // itemOrder.integradora = 10; + // itemOrder.numpedrca = idPreOrder; + // itemOrder.numpedweb = idPreOrder; + // itemOrder.codcli = cart.idCustomer; + // itemOrder.codusur = idSellerPreorder; //cart.idSeller; + // itemOrder.numseq = numeroSeq; + // itemOrder.codprod = 48500; + // itemOrder.codauxiliar = 48500; + // itemOrder.codfilialretira = '12'; + // itemOrder.tipoentrega = 'EF'; + // itemOrder.ptabela = Number.parseFloat(cart.shippingValue.toString()); + // itemOrder.pvenda = Number.parseFloat(cart.shippingValue.toString()); + // itemOrder.qt = 1; + // itemOrder.data = new Date(); - await queryRunner.manager - .createQueryBuilder() - .insert() - .into(Pcpeditemp) - .values(itemOrder) - .execute(); + // await queryRunner.manager + // .createQueryBuilder() + // .insert() + // .into(Pcpeditemp) + // .values(itemOrder) + // .execute(); - numeroSeq = numeroSeq + 1; - } + // numeroSeq = numeroSeq + 1; + // } // execute some operations on this transaction: await queryRunner.manager @@ -690,7 +691,7 @@ export class OrderService { await queryRunner.release(); await connection.close(); } - + } @@ -745,7 +746,7 @@ export class OrderService { let sql = 'SELECT NVL(PROXNUMPEDWEB,0) as "proxnumpedweb" FROM PCUSUARI ' + ' WHERE PCUSUARI.CODUSUR = :1 FOR UPDATE'; const seller = await queryRunner.query(sql, [idSeller]); - + const idOrder = seller[0].proxnumpedweb; console.log(idOrder); @@ -757,7 +758,7 @@ export class OrderService { ' WHERE PCUSUARI.CODUSUR = :1'; await queryRunner.query(sql, [idSeller]); - + await queryRunner.commitTransaction(); return idOrder; @@ -820,7 +821,7 @@ export class OrderService { ` ,PCCLIENT.CLIENTE as "customerName" ` + ` ,PCPEDC.VLATEND as "orderValue" ` + ` ,PCPEDC.NUMITENS as "itens" ` + - ` ,CASE WHEN ( SELECT COUNT(1) FROM ESTPIX WHERE ESTPIX.NUMPED = PCPEDC.NUMPED ) > 0 THEN 'S' ELSE 'N' END as "pixCreate" ` + + ` ,CASE WHEN ( SELECT COUNT(1) FROM ESTPIX WHERE ESTPIX.NUMPED = PCPEDC.NUMPED ) > 0 THEN 'S' ELSE 'N' END as "pixCreate" ` + ` FROM PCPEDC, PCCLIENT ` + ` WHERE PCPEDC.CODCLI = PCCLIENT.CODCLI ` + ` AND PCPEDC.CONDVENDA IN (1,7) ` + @@ -867,7 +868,7 @@ export class OrderService { } } - + async getItensOrder(idOrder: number) { const connection = new Connection(connectionOptions); @@ -1064,7 +1065,7 @@ export class OrderService { async getProductsOrder(store: string, initialDate: Date, finalDate: Date, document: string, name: string, sellerId: number, idOrder: string, typeFilterProduct: string, productText: string - ) { + ) { const sql = `SELECT PCPEDC.DATA as "date" ,PCPEDC.NUMPED as "orderId" @@ -1103,53 +1104,53 @@ export class OrderService { let sqlWhere = ''; if (store != null && store != '' && store != '99') { - sqlWhere += ` AND PCPEDC.CODFILIAL = '${store}' `; - } - if (document != null && document != '') { - sqlWhere += ` AND REGEXP_REPLACE(PCCLIENT.CGCENT, '[^0-9]', '') = REGEXP_REPLACE('${document}', '[^0-9]', '')`; - } - if (name != null && name != '') { - sqlWhere += ` AND PCCLIENT.CLIENTE LIKE '${name.replace('@', '%')}'||'%'`; - } - if (sellerId > 0) { - sqlWhere += ` AND PCPEDC.CODUSUR = ${sellerId} `; - } - if (idOrder.trim() != null && idOrder.trim() != '') { - sqlWhere += ` AND PCPEDC.NUMPED = ${idOrder} `; - } + sqlWhere += ` AND PCPEDC.CODFILIAL = '${store}' `; + } + if (document != null && document != '') { + sqlWhere += ` AND REGEXP_REPLACE(PCCLIENT.CGCENT, '[^0-9]', '') = REGEXP_REPLACE('${document}', '[^0-9]', '')`; + } + if (name != null && name != '') { + sqlWhere += ` AND PCCLIENT.CLIENTE LIKE '${name.replace('@', '%')}'||'%'`; + } + if (sellerId > 0) { + sqlWhere += ` AND PCPEDC.CODUSUR = ${sellerId} `; + } + if (idOrder.trim() != null && idOrder.trim() != '') { + sqlWhere += ` AND PCPEDC.NUMPED = ${idOrder} `; + } - if ( typeFilterProduct != '') { - switch (typeFilterProduct) { - case 'ID': - sqlWhere += ` AND PCPEDI.CODPROD = ${productText} `; - break; - case 'EAN': - sqlWhere += ` AND PCPRODUT.CODAUXILIAR = ${productText} `; - break; - case 'TEXT': - sqlWhere += ` AND PCPRODUT.DESCRICAO LIKE '${productText}%' `; - break; - case 'PARTNER': - sqlWhere += ` AND PCPRODUT.CODFAB like '${productText}%'`; - break; - default: break; - } + if (typeFilterProduct != '') { + switch (typeFilterProduct) { + case 'ID': + sqlWhere += ` AND PCPEDI.CODPROD = ${productText} `; + break; + case 'EAN': + sqlWhere += ` AND PCPRODUT.CODAUXILIAR = ${productText} `; + break; + case 'TEXT': + sqlWhere += ` AND PCPRODUT.DESCRICAO LIKE '${productText}%' `; + break; + case 'PARTNER': + sqlWhere += ` AND PCPRODUT.CODFAB like '${productText}%'`; + break; + default: break; } + } - //tratamento de data// - const startDate = new Date(initialDate); - let day = startDate.getDate(); - let month = ("00" + (startDate.getMonth() + 1)).slice(-2); - let year = startDate.getFullYear(); - const startFormat = day + "/" + month + "/" + year; - const endDate = new Date(finalDate); - day = endDate.getDate(); - month = ("00" + (endDate.getMonth() + 1)).slice(-2); - year = endDate.getFullYear(); - const endFormat = day + "/" + month + "/" + year; + //tratamento de data// + const startDate = new Date(initialDate); + let day = startDate.getDate(); + let month = ("00" + (startDate.getMonth() + 1)).slice(-2); + let year = startDate.getFullYear(); + const startFormat = day + "/" + month + "/" + year; + const endDate = new Date(finalDate); + day = endDate.getDate(); + month = ("00" + (endDate.getMonth() + 1)).slice(-2); + year = endDate.getFullYear(); + const endFormat = day + "/" + month + "/" + year; + + sqlWhere += ` AND PCPEDI.DATA BETWEEN TO_DATE('${startFormat}', 'DD/MM/YYYY') AND TO_DATE('${endFormat}', 'DD/MM/YYYY') `; - sqlWhere += ` AND PCPEDI.DATA BETWEEN TO_DATE('${startFormat}', 'DD/MM/YYYY') AND TO_DATE('${endFormat}', 'DD/MM/YYYY') `; - const connection = new Connection(connectionOptions); await connection.connect();