Merge branch 'main' of http://172.35.0.216:3000/simplifique/Vendaweb-api

.gitea/workflows/deploy-api.yaml

@@ -1,7 +1,7 @@
 name: Build (develop) / Promote (main)
 on:
   push:
-    branches: [main, develop, homolog]
+    branches: [main]
 
 jobs:
   build-and-push-deploy:
@@ -12,109 +12,30 @@ jobs:
         with:
           fetch-depth: 0
 
-      - name: Free disk space
+      - name: Build and Push
         run: |
-          df -h
+          REGISTRY="172.35.0.216:3000"
-          sudo rm -rf /usr/share/dotnet /usr/local/lib/android /opt/ghc || true
+          IMAGE_NAME="$REGISTRY/simplifique/vendaweb-api"
-          sudo apt-get clean || true
+          SHA_TAG=$(echo ${{ gitea.sha }} | cut -c1-7)
-          docker system prune -af --volumes || true
+
-          df -h          
+          echo "${{ secrets.K8S }}" | docker login "$REGISTRY" -u "${{ gitea.actor }}" --password-stdin
-      - name: Build (develop) / Promote (main)
+
-        env:
+          docker build -t "$IMAGE_NAME:$SHA_TAG" -t "$IMAGE_NAME:latest" .
-          REGISTRY: harbor.jurunense.com
+          docker push "$IMAGE_NAME:$SHA_TAG"
-          DEV_PROJECT: vendaweb-dev
+          docker push "$IMAGE_NAME:latest"
-          PROD_PROJECT: vendaweb-prod
+
-          IMAGE_REPO: vendaweb-api
+      - name: Update Manifest and Push to Git
-          PROMOTE_LEGACY: 'false'
-          HARBOR_USERNAME: ${{ secrets.HARBOR_USERNAME }}
-          HARBOR_PASSWORD: ${{ secrets.HARBOR_PASSWORD }}
-          HARBOR_DEV_USERNAME: ${{ secrets.HARBOR_DEV_USERNAME }}
-          HARBOR_DEV_PASSWORD: ${{ secrets.HARBOR_DEV_PASSWORD }}
-          HARBOR_PROD_USERNAME: ${{ secrets.HARBOR_PROD_USERNAME }}
-          HARBOR_PROD_PASSWORD: ${{ secrets.HARBOR_PROD_PASSWORD }}
-          HARBOR_LEGACY_USERNAME: ${{ secrets.HARBOR_LEGACY_USERNAME }}
-          HARBOR_LEGACY_PASSWORD: ${{ secrets.HARBOR_LEGACY_PASSWORD }}
         run: |
-          set -euo pipefail
+          SHA_TAG=$(echo ${{ gitea.sha }} | cut -c1-7)
+          IMAGE_NAME="172.35.0.216:3000/simplifique/vendaweb-api"
 
-          BRANCH="${GITHUB_REF_NAME:-${GITEA_REF_NAME:-}}"
+          MANIFEST_FILE="k8s/overlays/prod/deployment-image-digest-patch.yaml"
-          if [ -z "$BRANCH" ] && [ -n "${GITHUB_REF:-}" ]; then
-            BRANCH="${GITHUB_REF#refs/heads/}"
-          fi
 
-          DEV_IMAGE="$REGISTRY/$DEV_PROJECT/$IMAGE_REPO"
+          sed -i "s|image: $IMAGE_NAME:.*|image: $IMAGE_NAME:$SHA_TAG|g" "$MANIFEST_FILE"
-          PROD_IMAGE="$REGISTRY/$PROD_PROJECT/$IMAGE_REPO"
-          LEGACY_IMAGE="$REGISTRY/library/$IMAGE_REPO"
 
-          DEV_USER="${HARBOR_DEV_USERNAME:-$HARBOR_USERNAME}"
+          git config user.name "Gitea Action"
-          DEV_PASS="${HARBOR_DEV_PASSWORD:-$HARBOR_PASSWORD}"
+          git config user.email "actions@simplifiquehc.com.br"
-          PROD_USER="${HARBOR_PROD_USERNAME:-$HARBOR_USERNAME}"
-          PROD_PASS="${HARBOR_PROD_PASSWORD:-$HARBOR_PASSWORD}"
-          LEGACY_USER="${HARBOR_LEGACY_USERNAME:-$PROD_USER}"
-          LEGACY_PASS="${HARBOR_LEGACY_PASSWORD:-$PROD_PASS}"
 
-          if [ "$BRANCH" = "develop" ]; then
+          git add "$MANIFEST_FILE"
-            TAG=$(echo ${{ gitea.sha }} | cut -c1-7)
+          git commit -m "chore: update image tag to $SHA_TAG [skip ci]"
-
+          git push origin main
-            echo "$DEV_PASS" | docker login "$REGISTRY" -u "$DEV_USER" --password-stdin
-            docker build -t "$DEV_IMAGE:$TAG" -f ./Dockerfile .
-            docker push "$DEV_IMAGE:$TAG"
-            docker tag "$DEV_IMAGE:$TAG" "$DEV_IMAGE:develop"
-            docker push "$DEV_IMAGE:develop"
-            exit 0
-          fi
-
-          if [ "$BRANCH" = "main" ]; then
-            sudo apt-get update -y
-            sudo apt-get install -y skopeo
-
-            if [ -z "${DEV_USER:-}" ] || [ -z "${DEV_PASS:-}" ]; then
-              echo "Missing Harbor DEV credentials (HARBOR_DEV_USERNAME/HARBOR_DEV_PASSWORD or HARBOR_USERNAME/HARBOR_PASSWORD)." >&2
-              exit 1
-            fi
-            if [ -z "${PROD_USER:-}" ] || [ -z "${PROD_PASS:-}" ]; then
-              echo "Missing Harbor PROD credentials (HARBOR_PROD_USERNAME/HARBOR_PROD_PASSWORD or HARBOR_USERNAME/HARBOR_PASSWORD)." >&2
-              exit 1
-            fi
-
-            # Merge commit: HEAD has 2 parents; HEAD^2 is the merged branch tip.
-            PARENTS="$(git rev-list --parents -n 1 HEAD)"
-            set -- $PARENTS
-            SOURCE_SHA="${3:-${1:-}}"
-            if [ -z "$SOURCE_SHA" ]; then
-              SOURCE_SHA="${{ gitea.sha }}"
-            fi
-            TAG="$(echo "$SOURCE_SHA" | cut -c1-7)"
-
-            # Promote the exact artifact built on develop into prod (no rebuild).
-            skopeo inspect --creds "$DEV_USER:$DEV_PASS" "docker://$DEV_IMAGE:$TAG" >/dev/null
-
-            # Validate destination repository exists and auth works.
-            # Using list-tags avoids assuming a specific tag exists.
-            skopeo list-tags --creds "$PROD_USER:$PROD_PASS" "docker://$PROD_IMAGE" >/dev/null
-
-            skopeo copy --all \
-              --src-creds "$DEV_USER:$DEV_PASS" \
-              --dest-creds "$PROD_USER:$PROD_PASS" \
-              "docker://$DEV_IMAGE:$TAG" \
-              "docker://$PROD_IMAGE:$TAG"
-
-            # Optional: keep legacy tags working during migration.
-            if [ "${PROMOTE_LEGACY:-false}" = "true" ]; then
-              skopeo copy --all \
-                --src-creds "$DEV_USER:$DEV_PASS" \
-                --dest-creds "$LEGACY_USER:$LEGACY_PASS" \
-                "docker://$DEV_IMAGE:$TAG" \
-                "docker://$LEGACY_IMAGE:$TAG"
-              skopeo copy --all \
-                --src-creds "$DEV_USER:$DEV_PASS" \
-                --dest-creds "$LEGACY_USER:$LEGACY_PASS" \
-                "docker://$DEV_IMAGE:$TAG" \
-                "docker://$LEGACY_IMAGE:latest"
-            fi
-
-            exit 0
-          fi
-
-          echo "Unsupported branch: $BRANCH" >&2
-          exit 1          

Dockerfile

@@ -1,39 +1,55 @@
-# Estágio 1: Build
+ARG NODE_VERSION=16.20
-FROM node:16-bullseye-slim AS builder
+ARG DEBIAN_VARIANT=bullseye
+
+FROM node:${NODE_VERSION}-${DEBIAN_VARIANT} AS builder
 
 WORKDIR /app
-COPY package*.json ./
-RUN npm install --legacy-peer-deps
-COPY . .
-RUN npm run build
 
-FROM node:16-bullseye-slim
+ARG INSTANTCLIENT_ZIP_URL=https://download.oracle.com/otn_software/linux/instantclient/instantclient-basiclite-linuxx64.zip
-# Instalar dependências do Oracle 
+RUN apt-get update \
-RUN apt-get update && apt-get install -y \
+  && apt-get install -y --no-install-recommends ca-certificates wget unzip libaio1 libnsl2 \
-    libaio1 \
+  && rm -rf /var/lib/apt/lists/* \
-    unzip \
+  && mkdir -p /opt/oracle \
-    wget \
+  && wget -q "${INSTANTCLIENT_ZIP_URL}" -O /opt/oracle/instantclient.zip \
-    && mkdir -p /opt/oracle
+  && unzip -q /opt/oracle/instantclient.zip -d /opt/oracle \
+  && rm /opt/oracle/instantclient.zip \
+  && rm -f /opt/oracle/instantclient_*/ojdbc*.jar \
+           /opt/oracle/instantclient_*/ucp*.jar \
+           /opt/oracle/instantclient_*/xstreams.jar \
+           /opt/oracle/instantclient_*/adrci \
+           /opt/oracle/instantclient_*/genezi \
+           /opt/oracle/instantclient_*/uidrvci \
+  && ln -s "$(ls -d /opt/oracle/instantclient_* | head -n 1)" /opt/oracle/instantclient
 
-# Instalar Oracle Instant Client
-RUN wget https://download.oracle.com/otn_software/linux/instantclient/instantclient-basic-linuxx64.zip -O /opt/oracle/client.zip && \
-    unzip /opt/oracle/client.zip -d /opt/oracle && \
-    rm /opt/oracle/client.zip && \
-    ln -s /opt/oracle/instantclient_* /opt/oracle/instantclient
-
-# Configurar o sistema para encontrar as bibliotecas do Oracle
 ENV LD_LIBRARY_PATH=/opt/oracle/instantclient
-RUN echo "/opt/oracle/instantclient" > /etc/ld.so.conf.d/oracle-instantclient.conf && ldconfig
+ENV PATH=/opt/oracle/instantclient:$PATH
+
+COPY package*.json ./
+ENV NPM_CONFIG_LEGACY_PEER_DEPS=true
+RUN npm ci
+
+COPY . .
+RUN npm run build \
+  && npm prune --omit=dev --legacy-peer-deps \
+  && npm cache clean --force
+
+FROM node:${NODE_VERSION}-${DEBIAN_VARIANT}-slim AS runtime
 
 WORKDIR /app
 
-# Copiar apenas o necessário do estágio anterior
+ENV NODE_ENV=production
-COPY --from=builder /app/dist ./dist
+ENV LD_LIBRARY_PATH=/opt/oracle/instantclient
+ENV PATH=/opt/oracle/instantclient:$PATH
+
+RUN apt-get update \
+  && apt-get install -y --no-install-recommends libaio1 libnsl2 \
+  && rm -rf /var/lib/apt/lists/*
+
+COPY --from=builder /opt/oracle /opt/oracle
 COPY --from=builder /app/package*.json ./
 COPY --from=builder /app/node_modules ./node_modules
+COPY --from=builder /app/dist ./dist
 
-# Variáveis de ambiente padrão para o driver oracledb
+EXPOSE 8065
-ENV OCI_LIB_DIR=/opt/oracle/instantclient
-ENV OCI_INC_DIR=/opt/oracle/instantclient/sdk/include
 
-CMD ["npm", "run", "start:prod"]
+CMD ["node", "dist/main"]

KUBERNETES.md

@@ -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**: 15 (Configuração base)
-- **Imagem**: `172.35.0.216/library/vendaweb-api:latest`
-- **Porta do Container**: 8065
-- **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: digest da imagem, configurações específicas de serviço) 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-api` (Nota: O patch define `vendaweb-prod`, verifique a consistência)
-- **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.

WORKFLOWS.md

@@ -14,7 +14,7 @@ Os workflows estão definidos no diretório `.gitea/workflows/`. O principal wor
 
 Este workflow é acionado automaticamente no evento:
 
-- `push`: Em qualquer branch (configuração atual `on: [push]`).
+- `push`: Na branch `main`.
 
 ### Jobs
 
@@ -39,10 +39,13 @@ Este job é responsável por construir a imagem Docker e enviá-la para o regist
 3. **Build e Push**
    - Constrói a imagem Docker da aplicação.
    - Tags geradas:
-     - `172.35.0.216/library/vendaweb-api:$TAG` (onde `$TAG` é o SHA do commit do Gitea `gitea.sha`)
+     - `git.simplifiquehc.com.br/simplifique/vendaweb-api:$TAG` (onde `$TAG` é o SHA curto do commit)
-     - `172.35.0.216/library/vendaweb-api:latest`
+     - `git.simplifiquehc.com.br/simplifique/vendaweb-api:latest`
    - Envia ambas as tags para o registry.
 
+4. **Atualizar Manifest e Push no Git**
+   - Atualiza `k8s/overlays/prod/deployment-image-digest-patch.yaml` para apontar para a tag `$TAG`.
+
 ## Variáveis e Segredos (Secrets)
 
 Para que o workflow funcione corretamente, as seguintes secrets devem estar configuradas nas configurações do repositório no Gitea:

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:<sha7>` 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`

k8s/argocd/application-prod.yaml

@@ -6,14 +6,22 @@ metadata:
 spec:
   project: default
   source:
-    repoURL: https://git.simplifiquehc.com.br/simplifique/Vendaweb-api.git
+    repoURL: http://172.35.0.216:3000/simplifique/Vendaweb-api.git
     targetRevision: main
     path: k8s/overlays/prod
   destination:
     server: https://kubernetes.default.svc
-    namespace: vendaweb-api
+    namespace: vendaweb-prod
   syncPolicy:
     automated:
       selfHeal: true
+      prune: true
+    retry:
+      limit: 2
+      backoff:
+        duration: 5s
+        factor: 2
+        maxDuration: 3m
     syncOptions:
       - CreateNamespace=true
+      - PruneLast=true

k8s/base/deployment.yaml

@@ -5,7 +5,15 @@ metadata:
   labels:
     app: vendaweb-api
 spec:
-  replicas: 15
+  replicas: 3
+  revisionHistoryLimit: 5
+  minReadySeconds: 10
+  progressDeadlineSeconds: 600
+  strategy:
+    type: RollingUpdate
+    rollingUpdate:
+      maxSurge: 1
+      maxUnavailable: 0
   selector:
     matchLabels:
       app: vendaweb-api
@@ -15,10 +23,11 @@ spec:
         app: vendaweb-api
     spec:
       imagePullSecrets:
-        - name: harbor-secret
+        - name: gitea-auth
+      terminationGracePeriodSeconds: 30
       containers:
         - name: api
-          image: 172.35.0.216/library/vendaweb-api:latest
+          image: 172.35.0.216:3000/simplifique/vendaweb-api:589fa29
           imagePullPolicy: IfNotPresent
           ports:
             - name: http

k8s/overlays/prod/deployment-image-digest-patch.yaml

@@ -7,4 +7,4 @@ spec:
     spec:
       containers:
         - name: api
-          image: 172.35.0.216/library/vendaweb-api@sha256:aac490fcb4ef7baa95f1df01fa50d2d44bdb4ed12b235e5dd89e1d7dc3cd0a3a
+          image: 172.35.0.216:3000/simplifique/vendaweb-api:5279ae9

k8s/overlays/prod/deployment-prod-patch.yaml

@@ -0,0 +1,6 @@
+apiVersion: apps/v1
+kind: Deployment
+metadata:
+  name: vendaweb-api
+spec:
+  replicas: 2

k8s/overlays/prod/hpa.yaml

@@ -0,0 +1,18 @@
+apiVersion: autoscaling/v2
+kind: HorizontalPodAutoscaler
+metadata:
+  name: vendaweb-api
+spec:
+  scaleTargetRef:
+    apiVersion: apps/v1
+    kind: Deployment
+    name: vendaweb-api
+  minReplicas: 2
+  maxReplicas: 15
+  metrics:
+    - type: Resource
+      resource:
+        name: cpu
+        target:
+          type: Utilization
+          averageUtilization: 70

k8s/overlays/prod/kustomization.yaml

@@ -5,7 +5,9 @@ namespace: vendaweb-prod
 
 resources:
   - ../../base
+  - hpa.yaml
 
 patches:
-  - path: deployment-image-digest-patch.yaml
   - path: service-patch.yaml
+  - path: deployment-prod-patch.yaml
+  - path: deployment-image-digest-patch.yaml

k8s/overlays/prod/service-patch.yaml

@@ -8,4 +8,4 @@ spec:
     - name: http
       port: 8067
       targetPort: 8067
-      nodePort: 30001
+      nodePort: 32619

package-lock.json

@@ -20,7 +20,7 @@
         "@types/cache-manager": "^3.4.3",
         "cache-manager": "^3.6.3",
         "cache-manager-redis-store": "^3.0.1",
-        "compression": "^1.7.4",
+        "compression": "^1.8.1",
         "crc": "^4.3.2",
         "fs": "0.0.1-security",
         "guid-typescript": "^1.0.9",
@@ -4181,16 +4181,17 @@
       }
     },
     "node_modules/compression": {
-      "version": "1.7.4",
+      "version": "1.8.1",
-      "resolved": "https://registry.npmjs.org/compression/-/compression-1.7.4.tgz",
+      "resolved": "https://registry.npmjs.org/compression/-/compression-1.8.1.tgz",
-      "integrity": "sha512-jaSIDzP9pZVS4ZfQ+TzvtiWhdpFhE2RDHz8QJkpX9SIpLq88VueF5jJw6t+6CUQcAoA6t+x89MLrWAqpfDE8iQ==",
+      "integrity": "sha512-9mAqGPHLakhCLeNyxPkK4xVo746zQ/czLH1Ky+vkitMnWfWZps8r0qXuwhwizagCRttsL4lfG4pIOvaWLpAP0w==",
+      "license": "MIT",
       "dependencies": {
-        "accepts": "~1.3.5",
+        "bytes": "3.1.2",
-        "bytes": "3.0.0",
+        "compressible": "~2.0.18",
-        "compressible": "~2.0.16",
         "debug": "2.6.9",
-        "on-headers": "~1.0.2",
+        "negotiator": "~0.6.4",
-        "safe-buffer": "5.1.2",
+        "on-headers": "~1.1.0",
+        "safe-buffer": "5.2.1",
         "vary": "~1.1.2"
       },
       "engines": {
@@ -4198,17 +4199,22 @@
       }
     },
     "node_modules/compression/node_modules/bytes": {
-      "version": "3.0.0",
+      "version": "3.1.2",
-      "resolved": "https://registry.npmjs.org/bytes/-/bytes-3.0.0.tgz",
+      "resolved": "https://registry.npmjs.org/bytes/-/bytes-3.1.2.tgz",
-      "integrity": "sha1-0ygVQE1olpn4Wk6k+odV3ROpYEg=",
+      "integrity": "sha512-/Nf7TyzTx6S3yRJObOAV7956r8cr2+Oj8AC5dt8wSP3BQAoeX58NoHyCU8P8zGkNXStjTSi6fzO6F0pBdcYbEg==",
+      "license": "MIT",
       "engines": {
         "node": ">= 0.8"
       }
     },
-    "node_modules/compression/node_modules/safe-buffer": {
+    "node_modules/compression/node_modules/negotiator": {
-      "version": "5.1.2",
+      "version": "0.6.4",
-      "resolved": "https://registry.npmjs.org/safe-buffer/-/safe-buffer-5.1.2.tgz",
+      "resolved": "https://registry.npmjs.org/negotiator/-/negotiator-0.6.4.tgz",
-      "integrity": "sha512-Gd2UZBJDkXlY7GbJxfsE8/nvKkUEU1G38c1siN6QP6a9PT9MmHB8GnpscSmMJSoF8LOIrt8ud/wPtojys4G6+g=="
+      "integrity": "sha512-myRT3DiWPHqho5PrJaIRyaMv2kgYf0mUVgBNOYMuCH5Ki1yEiQaf/ZJuQ62nvpc44wL5WDbTX7yGJi1Neevw8w==",
+      "license": "MIT",
+      "engines": {
+        "node": ">= 0.6"
+      }
     },
     "node_modules/concat-map": {
       "version": "0.0.1",
@@ -9810,9 +9816,10 @@
       }
     },
     "node_modules/on-headers": {
-      "version": "1.0.2",
+      "version": "1.1.0",
-      "resolved": "https://registry.npmjs.org/on-headers/-/on-headers-1.0.2.tgz",
+      "resolved": "https://registry.npmjs.org/on-headers/-/on-headers-1.1.0.tgz",
-      "integrity": "sha512-pZAE+FJLoyITytdqK0U5s+FIpjN0JP3OzFi/u8Rx+EV5/W+JTWGXG8xFzevE7AjBfDqHv/8vL8qQsIhHnqRkrA==",
+      "integrity": "sha512-737ZY3yNnXy37FHkQxPzt4UZ2UWPWiCZWLvFZ4fu5cueciegX0zGPnrlY6bwRg4FdQOe9YU8MkmJwGhoMybl8A==",
+      "license": "MIT",
       "engines": {
         "node": ">= 0.8"
       }

package.json

@@ -32,7 +32,7 @@
     "@types/cache-manager": "^3.4.3",
     "cache-manager": "^3.6.3",
     "cache-manager-redis-store": "^3.0.1",
-    "compression": "^1.7.4",
+    "compression": "^1.8.1",
     "crc": "^4.3.2",
     "fs": "0.0.1-security",
     "guid-typescript": "^1.0.9",

src/app.controller.ts

@@ -14,7 +14,7 @@ export class AppController {
   @Get('health')
   @ApiOperation({ summary: 'Health check' })
   healthCheck() {
-    return { status: 'SIMPLIFIQUE HOME CENTER 2026' };
+    return { status: 'NOVA VERSAO 2026' };
   }
 
 }

src/backoffice/lists/lists.controller.ts

@@ -44,9 +44,9 @@ export class ListsController {
     /**
     * Consulta tabela de plano de pagamento para pedido de venda
     */
-    @Get('paymentplan/:billindid')
+    @Get('paymentplan/:billindid/:customerId')
-        async getPaymentPlan(@Param('billindid') billingId: string) {
+    async getPaymentPlan(@Param('billindid') billingId: string, @Param('customerId') customerId: string) {
-        return this.listsServices.GetPaymentPlan(billingId);
+        return this.listsServices.GetPaymentPlan(billingId, customerId);
     }
 
     /**

src/backoffice/lists/lists.service.ts

@@ -102,20 +102,24 @@ export class ListsService {
         }
     }
 
-    async GetPaymentPlan(billingId: string){
+    async GetPaymentPlan(billingId: string, clientId: string) {
         const connection = new Connection(connectionOptions);
         await connection.connect();
         const queryRunner = connection.createQueryRunner();
         await queryRunner.connect();
         try {
-            const sql = '  SELECT PCPLPAG.CODPLPAG as "codplpag", PCPLPAG.DESCRICAO as "descricao",  ' +
+            const sql = `SELECT PCPLPAG.CODPLPAG as "codplpag", PCPLPAG.DESCRICAO as "descricao",  
-                        '         NVL(PCPLPAG.NUMDIAS,0) as "numdias" ' +
+                                NVL(PCPLPAG.NUMDIAS,0) as "numdias" 
-                        '    FROM PCPLPAG  ' +     
+                           FROM PCPLPAG, PCCLIENT, PCPLPAG PLANO_CLI   
-                        '    WHERE EXISTS(SELECT PCCOBPLPAG.CODCOB FROM PCCOBPLPAG ' +
+                          WHERE PCCLIENT.CODCLI = :CODCLI
-                        '                  WHERE PCCOBPLPAG.CODPLPAG = PCPLPAG.CODPLPAG ' + 
+                            AND PCCLIENT.CODPLPAG = PLANO_CLI.CODPLPAG (+)
-                        '                   AND PCCOBPLPAG.CODCOB = :CODCOB ) '
+                            AND PCPLPAG.NUMDIAS <= NVL(PLANO_CLI.NUMDIAS,9999) 
-                        '  ORDER BY PCPAG.DESCRICAO ';
+                            AND EXISTS(SELECT PCCOBPLPAG.CODCOB FROM PCCOBPLPAG 
-            const paymentPlans = await queryRunner.query(sql, [billingId]);
+                                                    WHERE PCCOBPLPAG.CODPLPAG = PCPLPAG.CODPLPAG 
+                                                                AND PCCOBPLPAG.CODCOB = :CODCOB ) 
+                          ORDER BY PCPLPAG.DESCRICAO`;
+
+            const paymentPlans = await queryRunner.query(sql, [clientId, billingId]);
             return paymentPlans;
         } catch (error) {
             throw error;
@@ -135,7 +139,7 @@ export class ListsService {
                 '   FROM PCCOB ' +
                 '  WHERE NVL(PCCOB.enviacobrancafv, \'N\') = \'S\'  ' +
                 '               AND ( ( NOT EXISTS(SELECT PCCOBCLI.CODCOB FROM PCCOBCLI WHERE PCCOBCLI.CODCLI = :CODCLI  ) AND  ' +
-                        '                   ( PCCOB.NIVELVENDA <= ( SELECT C.NIVELVENDA FROM PCCLIENT, PCCOB C ' +
+                '                   ( PCCOB.NIVELVENDA >= ( SELECT C.NIVELVENDA FROM PCCLIENT, PCCOB C ' +
                 '                                            WHERE PCCLIENT.CODCLI = :CODCLI AND PCCLIENT.CODCOB = C.CODCOB ) ) ) OR ' +
                 '                      EXISTS(SELECT PCCOBCLI.CODCOB FROM PCCOBCLI WHERE PCCOBCLI.CODCLI = :CODCLI AND PCCOBCLI.CODCOB = PCCOB.CODCOB ) ) ' +
                 ' ORDER BY PCCOB.CODCOB';

src/delivery/services/shipping.service.ts

@@ -169,13 +169,13 @@ export class ShippingService {
       const sql = `SELECT PCDIASUTEIS.DATA               as "dateDelivery",
                           NVL (PCDIASUTEIS.DIAROTA, 'N') as "delivery",
                           CASE WHEN NVL (PCDIASUTEIS.DIAROTA, 'N') = 'N' THEN 0 
-                             ELSE (PARAMFILIAL.OBTERCOMONUMBER ('CAPACIDADE_LOGISTICA', 12)) END as "deliverySize",
+                             ELSE (PARAMFILIAL.OBTERCOMONUMBER ('CAPACIDADE_LOGISTICA', 1)) END as "deliverySize",
                           ROUND ( (NVL (VENDAS.TOTPESO, 0) / 1000), 3)               as "saleWeigth",
                           CASE WHEN NVL (PCDIASUTEIS.DIAROTA, 'N') = 'N' THEN 0 
                             ELSE ROUND (
                               GREATEST (
                                     (  (  PARAMFILIAL.OBTERCOMONUMBER ('CAPACIDADE_LOGISTICA',
-                                                                        12)
+                                                                        1)
                                         * 1000)
                                       - NVL (VENDAS.TOTPESO, 0))
                                   / 1000,
@@ -186,7 +186,9 @@ export class ShippingService {
                               FROM PCPEDC
                             WHERE     PCPEDC.POSICAO IN ('L', 'M')
                                   AND PCPEDC.CONDVENDA = 8
-                                  AND PCPEDC.CODFILIAL IN (12, 13, 4, 6)
+                                  AND EXISTS(SELECT 1 FROM PCPEDI 
+                                                WHERE PCPEDI.NUMPED = PCPEDC.NUMPED 
+                                                    AND PCPEDI.CODFILIALRETIRA IN (1) )
                                   AND EXISTS
                                           (SELECT TV7.NUMPED
                                               FROM PCPEDC TV7
@@ -194,15 +196,15 @@ export class ShippingService {
                                                   AND TV7.POSICAO = 'F')
                                   AND PCPEDC.DTENTREGA >= TRUNC (SYSDATE) + 3
                           GROUP BY PCPEDC.DTENTREGA) VENDAS
-                  WHERE PCDIASUTEIS.CODFILIAL = 12 AND PCDIASUTEIS.DATA BETWEEN TRUNC (SYSDATE) + 3 AND TRUNC(SYSDATE) + 20 --AND NVL(PCDIASUTEIS.DIAROTA,'N') = 'S'
+                  WHERE PCDIASUTEIS.CODFILIAL = 1 AND PCDIASUTEIS.DATA BETWEEN TRUNC (SYSDATE) + 3 AND TRUNC(SYSDATE) + 20 --AND NVL(PCDIASUTEIS.DIAROTA,'N') = 'S'
                         AND PCDIASUTEIS.DATA = VENDAS.DTENTREGA(+)
                 ORDER BY PCDIASUTEIS.DATA `;
 
       const data = await queryRunner.query(sql);
 
       const sqlDeliveryDate = `SELECT TRUNC(SYSDATE) + esf_calcular_prazo_entrega_programada(TRUNC(SYSDATE), 
-                                              '12', 
+                                              '1', 
-                                            129, '', 0, 500) as "date"
+                                            169, '', 0, 500) as "date"
                                   FROM DUAL`;
       const dataDeliveryDate = await queryRunner.query(sqlDeliveryDate);
 

src/domain/entity/tables/pccidade.entity.ts

@@ -26,9 +26,6 @@ export class Pccidade {
     @Column({ name: 'CODMUNSIAFI' })
     codmunsiafi: number;
 
-    @Column({ name: 'DTMXSALTER' })
-    dtmxsalter: Date;
-    
     @Column({ name: 'LATITUDE' })
     latitude: string;
 

src/domain/entity/tables/pcorcavendai.entity.ts

@@ -89,7 +89,4 @@ export class Pcorcavendai {
     @Column({ name: 'AMBIENTE' })
     ambiente: string;
 
-    @Column({name: 'RETIRAPOSTERIOR_IMEDIATA'})
-    rp_imediata: string;
-    
 }

src/domain/entity/tables/pcpeditemp.entity.ts

@@ -162,8 +162,6 @@ codfilial: string;
     @Column({ name: 'CODCLIPARTILHA' })
     codclipartilha: number;
 
-@Column({name: 'RETIRAPOSTERIOR_IMEDIATA'})
-rp_imediata: string;
 
 }
 

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.`)
+                     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")
+    .setVersion('2023.1.2')
-    .addTag("Auth")
+    .addTag('VendaWeb')
+    .addTag('Auth')
     .build();
   const document = SwaggerModule.createDocument(app, options);
-  SwaggerModule.setup("docs", app, document);
+  SwaggerModule.setup('docs', app, document);
-  await app.listen(8066);
+  await app.listen(8067);
 }
 bootstrap();

src/sales/customer/customer.service.ts

@@ -469,9 +469,9 @@ export class CustomerService {
     async InitializeCustomer() {
         const cliente = new Pcclient();
         cliente.codusur1 = 1;
-        cliente.codplpag = 10;
+        cliente.codplpag = 18;
-        cliente.codpraca = 119;
+        cliente.codpraca = 169;
-        cliente.codcob = "D";
+        cliente.codcob = "CAR";
         cliente.dtcadastro = new Date();
         cliente.codcontab = "1";
         cliente.aceitavendafracao = "N";
@@ -502,7 +502,7 @@ export class CustomerService {
         cliente.tv10usacustoproduto = "N";
         cliente.inscestadual = "ISENTO";
         cliente.codpais = 1058; //Brasil 
-        cliente.observacao = "Importado do E-Commerce";
+        cliente.observacao = "Cadastrado Venda Web";
         cliente.aceitachterceiros = "S";
         cliente.agregarvalorstdescfin = "N";
         cliente.anvisa = "N";
@@ -523,6 +523,7 @@ export class CustomerService {
         cliente.fretedespacho = "0";
         cliente.aceitavendafracao = "S";
         cliente.validarmultiplovenda = "S";
+        cliente.isentotxentrega = "S";
 
         return cliente;
     }

src/sales/order/order.service.ts

@@ -165,8 +165,8 @@ export class OrderService {
                     `                  OR EXISTS(SELECT PCCOB.CODCOB FROM PCCOB ` +
                     `                                               WHERE PCCOB.CODCOB = PCPEDC.CODCOB ` +
                     `                                                 AND NVL(PCCOB.CARTAO,'N') = 'S') ) `;
-                await queryRunner.manager
+                //  await queryRunner.manager
-                    .query(sql, [order.numped]);
+                //      .query(sql, [order.numped]);
                 sql = `UPDATE PCPEDI SET POSICAO = 'L' WHERE NUMPED = :1 ` +
                     ` AND EXISTS( SELECT PCPEDC.NUMPED FROM PCPEDC ` +
                     `              WHERE PCPEDC.NUMPED = PCPEDI.NUMPED ` +
@@ -175,10 +175,10 @@ export class OrderService {
                     `                       OR EXISTS(SELECT PCCOB.CODCOB FROM PCCOB ` +
                     `                                  WHERE PCCOB.CODCOB = PCPEDC.CODCOB   ` +
                     `                                    AND NVL(PCCOB.CARTAO,'N') = 'S') ) )`;
-                await queryRunner.manager
+                //   await queryRunner.manager
-                    .query(sql, [order.numped]);
+                //       .query(sql, [order.numped]);
 
-                await this.updateStatusItem(queryRunner, order.numped);
+                //  await this.updateStatusItem(queryRunner, order.numped);
 
 
                 sql = ` UPDATE PCPEDC SET ` +
@@ -204,7 +204,7 @@ export class OrderService {
                     `    AND EXISTS(SELECT TV7.NUMPED FROM PCPEDC TV7 WHERE TV7.NUMPED = PCPEDC.NUMPEDENTFUT ` +
                     `                  AND TV7.POSICAO = 'L' )`;
 
-                await queryRunner.manager.query(sql, [order.numped]);
+                // await queryRunner.manager.query(sql, [order.numped]);
                 sql = ` UPDATE PCPEDC SET ` +
                     `                   POSICAO =  ( SELECT PCPEDI.POSICAO FROM PCPEDI WHERE PCPEDI.NUMPED = PCPEDC.NUMPED AND ROWNUM = 1 ) ` +
                     `                 , MOTIVOPOSICAO = NULL ` +
@@ -227,7 +227,7 @@ export class OrderService {
                     `    AND PCPEDC.NUMPEDENTFUT = :1 ` +
                     `    AND EXISTS(SELECT TV7.NUMPED FROM PCPEDC TV7 WHERE TV7.NUMPED = PCPEDC.NUMPEDENTFUT ` +
                     `                  AND TV7.POSICAO = 'L' )`;
-                await queryRunner.manager.query(sql, [order.numped]);
+                //   await queryRunner.manager.query(sql, [order.numped]);
 
                 // atualizar campos padrão para rotina 4116
                 sql = ` UPDATE PCPEDC SET ` +
@@ -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;
@@ -585,7 +586,7 @@ export class OrderService {
                         itemOrder.codauxiliar = componente.ean;
                         itemOrder.codfilialretira = item.idStock;
                         itemOrder.tipoentrega = (item.deliveryMethod == 'RA') ? "RP" : item.deliveryMethod;
-                        itemOrder.rp_imediata = (item.deliveryMethod == 'RA') ? "S" : "N";
+                        //  itemOrder.rp_imediata = (item.deliveryMethod == 'RA') ? "S" : "N";
                         if (item.deliveryMethod == 'RA') {
                             preOrder.dtentrega = new Date();
                         }
@@ -618,7 +619,7 @@ export class OrderService {
                     itemOrder.codauxiliar = item.ean;
                     itemOrder.codfilialretira = item.idStock;
                     itemOrder.tipoentrega = (item.deliveryMethod == 'RA') ? "RP" : item.deliveryMethod;
-                    itemOrder.rp_imediata = (item.deliveryMethod == 'RA') ? "S" : "N";
+                    //itemOrder.rp_imediata = (item.deliveryMethod == 'RA') ? "S" : "N";
                     if (item.deliveryMethod == 'RA') {
                         preOrder.dtentrega = new Date();
                     }
@@ -643,34 +644,34 @@ export class OrderService {
 
             //#endregion
 
-            if (cart.shippingValue > 0) {
+            // if (cart.shippingValue > 0) {
-                const itemOrder = new Pcpeditemp();
+            //     const itemOrder = new Pcpeditemp();
-                itemOrder.tipointegracao = "W";
+            //     itemOrder.tipointegracao = "W";
-                itemOrder.integradora = 10;
+            //     itemOrder.integradora = 10;
-                itemOrder.numpedrca = idPreOrder;
+            //     itemOrder.numpedrca = idPreOrder;
-                itemOrder.numpedweb = idPreOrder;
+            //     itemOrder.numpedweb = idPreOrder;
-                itemOrder.codcli = cart.idCustomer;
+            //     itemOrder.codcli = cart.idCustomer;
-                itemOrder.codusur = idSellerPreorder; //cart.idSeller;
+            //     itemOrder.codusur = idSellerPreorder; //cart.idSeller;
-                itemOrder.numseq = numeroSeq;
+            //     itemOrder.numseq = numeroSeq;
-                itemOrder.codprod = 48500;
+            //     itemOrder.codprod = 48500;
-                itemOrder.codauxiliar = 48500;
+            //     itemOrder.codauxiliar = 48500;
-                itemOrder.codfilialretira = '12';
+            //     itemOrder.codfilialretira = '12';
-                itemOrder.tipoentrega = 'EF';
+            //     itemOrder.tipoentrega = 'EF';
-                itemOrder.ptabela = Number.parseFloat(cart.shippingValue.toString());
+            //     itemOrder.ptabela = Number.parseFloat(cart.shippingValue.toString());
-                itemOrder.pvenda = Number.parseFloat(cart.shippingValue.toString());
+            //     itemOrder.pvenda = Number.parseFloat(cart.shippingValue.toString());
-                itemOrder.qt = 1;
+            //     itemOrder.qt = 1;
-                itemOrder.data = new Date();
+            //     itemOrder.data = new Date();
 
 
-                await queryRunner.manager
+            //     await queryRunner.manager
-                    .createQueryBuilder()
+            //         .createQueryBuilder()
-                    .insert()
+            //         .insert()
-                    .into(Pcpeditemp)
+            //         .into(Pcpeditemp)
-                    .values(itemOrder)
+            //         .values(itemOrder)
-                    .execute();
+            //         .execute();
 
-                numeroSeq = numeroSeq + 1;
+            //     numeroSeq = numeroSeq + 1;
-            }
+            // }
 
             // execute some operations on this transaction:
             await queryRunner.manager
@@ -825,12 +826,12 @@ export class OrderService {
                 ` WHERE PCPEDC.CODCLI = PCCLIENT.CODCLI ` +
                 `   AND PCPEDC.CONDVENDA IN (1,7) ` +
                 `   AND PCPEDC.DTCANCEL IS NULL AND PCPEDC.POSICAO NOT IN ('C') `;
-            `   AND PCPEDC.ROTINALANC = 'VENDAWEB' `;
+            `   AND EXISTS(SELECT 1 FROM ESTPREVENDAC WHERE ESTPREVENDAC.NUMPED = PCPEDC.NUMPED ) `; //PCPEDC.ROTINALANC = 'VENDAWEB' `;
             if (store != null && store != '') {
                 sqlWhere += ` AND PCPEDC.CODFILIAL = '${store}'  `;
             }
             if (document != null && document != '') {
-                sqlWhere += `   AND REGEXP_REPLACE(PCCLIENT.CGCENT, '[^0-9]', '') = REGEXP_REPLACE('${document}', '[^0-9]', '')`;
+                sqlWhere += `   AND ((REGEXP_REPLACE(PCCLIENT.CGCENT, '[^0-9]', '') = REGEXP_REPLACE('${document}', '[^0-9]', '') ) OR ( PCCLIENT.CODCLI = REGEXP_REPLACE('${document}', '[^0-9]', '')) )`;
             }
             if (name != null && name != '') {
                 sqlWhere += `   AND PCCLIENT.CLIENTE LIKE '${name.replace('@', '%')}'||'%'`;
@@ -953,7 +954,7 @@ export class OrderService {
             const partners = await this.listsService.GetPartners();
             const address = await this.addressCustomerService.getAddress(order[0].customerId, order[0].addressId);
             const billing = billinds.find(data => data.codcob === order[0].billindId);
-            const paymentPlans = await this.listsService.GetPaymentPlan(billing.codcob);
+            const paymentPlans = await this.listsService.GetPaymentPlan(billing.codcob, order[0].customerId);
             const paymentPlan = paymentPlans.find(data => data.codplpag === order[0].paymentPlanId);
             const partner = partners.find(data => data.id === order[0].partnerId);
 

src/sales/pre-order/pre-order.service.ts

@@ -120,7 +120,7 @@ export class PreOrderService {
                 itemPreOrder.pvenda1 = 0;
                 itemPreOrder.tipoentrega = item.deliveryMethod;
                 // eslint-disable-next-line @typescript-eslint/camelcase
-                itemPreOrder.rp_imediata = (item.deliveryMethod == "RA") ? "S" : "N";
+                // itemPreOrder.rp_imediata = (item.deliveryMethod == "RA") ? "S" : "N";
                 itemPreOrder.complemento = item.descriptionAux;
                 itemPreOrder.ambiente = item.environment;
 
@@ -137,52 +137,52 @@ export class PreOrderService {
                 numeroSeq = numeroSeq + 1;
             }
 
-            if (cart.shippingValue > 0) {
+            // if (cart.shippingValue > 0) {
-                const itemPreOrder = new Pcorcavendai();
+            //     const itemPreOrder = new Pcorcavendai();
-                itemPreOrder.numorca = preOrder.numorca;
+            //     itemPreOrder.numorca = preOrder.numorca;
-                itemPreOrder.data = this.formatDate(new Date());
+            //     itemPreOrder.data = this.formatDate(new Date());
-                itemPreOrder.codcli = cart.idCustomer;
+            //     itemPreOrder.codcli = cart.idCustomer;
-                itemPreOrder.codprod = 48500;
+            //     itemPreOrder.codprod = 48500;
-                itemPreOrder.codauxiliar = 48500;
+            //     itemPreOrder.codauxiliar = 48500;
-                itemPreOrder.codusur = ( idRca > 0 ) ? idRca : cart.idSeller;
+            //     itemPreOrder.codusur = (idRca > 0) ? idRca : cart.idSeller;
-                itemPreOrder.qt = 1;
+            //     itemPreOrder.qt = 1;
-                itemPreOrder.pvenda = Number.parseFloat(cart.shippingValue.toString());
+            //     itemPreOrder.pvenda = Number.parseFloat(cart.shippingValue.toString());
-                itemPreOrder.ptabela = Number.parseFloat(cart.shippingValue.toString());
+            //     itemPreOrder.ptabela = Number.parseFloat(cart.shippingValue.toString());
-                itemPreOrder.numcar = 0;
+            //     itemPreOrder.numcar = 0;
-                itemPreOrder.posicao = 'L';
+            //     itemPreOrder.posicao = 'L';
-                itemPreOrder.st = 0;
+            //     itemPreOrder.st = 0;
-                itemPreOrder.vlcustocont = 0;
+            //     itemPreOrder.vlcustocont = 0;
-                itemPreOrder.vlcustofin = 0;
+            //     itemPreOrder.vlcustofin = 0;
-                itemPreOrder.vlcustoreal = 0;
+            //     itemPreOrder.vlcustoreal = 0;
-                itemPreOrder.vlcustorep = 0;
+            //     itemPreOrder.vlcustorep = 0;
-                itemPreOrder.percom = 0;
+            //     itemPreOrder.percom = 0;
-                itemPreOrder.perdesc = 0;
+            //     itemPreOrder.perdesc = 0;
-                itemPreOrder.numseq = numeroSeq;
+            //     itemPreOrder.numseq = numeroSeq;
-                itemPreOrder.pvendabase = 0;
+            //     itemPreOrder.pvendabase = 0;
-                itemPreOrder.codst = await this.
+            //     itemPreOrder.codst = await this.
-                    sharedService.
+            //         sharedService.
-                    getTaxId(48500,
+            //         getTaxId(48500,
-                        cart.saleStore,
+            //             cart.saleStore,
-                        customer.estent);
+            //             customer.estent);
-                itemPreOrder.custofinest = 0;
+            //     itemPreOrder.custofinest = 0;
-                itemPreOrder.codauxiliar = 48500;
+            //     itemPreOrder.codauxiliar = 48500;
-                itemPreOrder.codfilialretira = cart.saleStore;
+            //     itemPreOrder.codfilialretira = cart.saleStore;
-                itemPreOrder.poriginal = 0;
+            //     itemPreOrder.poriginal = 0;
-                itemPreOrder.pvendabase = 0;
+            //     itemPreOrder.pvendabase = 0;
-                itemPreOrder.pvenda1 = 0;
+            //     itemPreOrder.pvenda1 = 0;
-                itemPreOrder.tipoentrega = 'EF';
+            //     itemPreOrder.tipoentrega = 'EF';
-                console.log('Processo 3');
+            //     console.log('Processo 3');
 
-                await queryRunner.manager
+            //     await queryRunner.manager
-                    .createQueryBuilder()
+            //         .createQueryBuilder()
-                    .insert()
+            //         .insert()
-                    .into(Pcorcavendai)
+            //         .into(Pcorcavendai)
-                    .values(itemPreOrder)
+            //         .values(itemPreOrder)
-                    .execute();
+            //         .execute();
-                console.log('Processo 4');
+            //     console.log('Processo 4');
 
-                numeroSeq = numeroSeq + 1;
+            //     numeroSeq = numeroSeq + 1;
-            }
+            // }
 
             //#region create PCORCAVENDAC
             console.log('Processo 5' + cart);
@@ -209,8 +209,8 @@ export class PreOrderService {
                 preOrder.codsupervisor = supervisor[0].codsupervisor;
             }
             preOrder.codemitente = cart.userId;
-            preOrder.vlfrete = cart.shippingValue;
+            preOrder.vlfrete = 0;
-            preOrder.vloutrasdesp = 0;
+            preOrder.vloutrasdesp = cart.shippingValue;
             preOrder.numitens = cart.itens.length;
             preOrder.obs1 = cart.notation1;
             preOrder.obs2 = cart.notation2;
@@ -425,7 +425,7 @@ export class PreOrderService {
             }
             // const address = await this.addressCustomerService.getAddress(preOrder[0].customerId, preOrder[0].addressId);
             const billing = billinds.find(data => data.codcob === preOrder[0].billindId);
-            const paymentPlans = await this.listsService.GetPaymentPlan((billing !== null && billing !== undefined) ? billing.codcob : '9999');
+            const paymentPlans = await this.listsService.GetPaymentPlan((billing !== null && billing !== undefined) ? billing.codcob : '9999', preOrder[0].customerId);
             const paymentPlan = paymentPlans.find(data => data.codplpag === preOrder[0].paymentPlanId);
             const partner = partners.find(data => data.id === preOrder[0].partnerId);
 

src/sales/sales/sales.service.ts

@@ -27,8 +27,39 @@ export class SalesService {
 
 
     async GetProducts2(store: string, pageSize: number, pageNumber: number, filter: FilterProduct = null,) {
-        const connectionDb = new Connection(connectionOptions);
+        const cacheKey = `GetProducts2:${store}:${pageSize}:${pageNumber}:${JSON.stringify(filter)}`;
-        await connectionDb.connect();
+        const lockKey = `lock:${cacheKey}`;
+        const lockTimeout = 30;
+
+        // Fase 1: Verificar cache Redis
+        try {
+            const cachedResult = await this.redisClient.get(cacheKey);
+            if (cachedResult) {
+                console.log('GetProducts2 - Retornando resultado do cache');
+                return JSON.parse(cachedResult);
+            }
+        } catch (err) {
+            console.error('Erro ao acessar o Redis no GetProducts2:', err?.message || err);
+        }
+
+        // Lock para evitar thundering herd
+        const lockValue = Date.now() + lockTimeout * 1000 + 1;
+        let acquiredLock: string | null = null;
+        try {
+            acquiredLock = await this.redisClient.set(lockKey, lockValue, 'NX', 'EX', lockTimeout);
+        } catch (err) {
+            console.error('Erro ao adquirir lock no Redis (GetProducts2):', err?.message || err);
+            acquiredLock = 'OK'; // Em caso de erro no Redis, prosseguir sem lock
+        }
+
+        if (acquiredLock !== 'OK') {
+            console.log('Lock não adquirido (GetProducts2), aguardando...');
+            await this.sleep(1000);
+            return this.GetProducts2(store, pageSize, pageNumber, filter);
+        }
+
+        // Fase 2: Reutilizar conexão via pool
+        const connectionDb = getConnection();
         const queryRunner = connectionDb.createQueryRunner();
         await queryRunner.connect();
         try {
@@ -38,55 +69,11 @@ export class SalesService {
                 pageNumber = 1;
             const offSet = (pageNumber - 1) * pageSize;
 
-            const sqlProduto = `SELECT 
-                                    esvlistaprodutos.CODPROD as "idProduct",
-                                    esvlistaprodutos.SEQ as "seq",
-                                    esvlistaprodutos.DESCRICAO as "smallDescription",
-                                    esvlistaprodutos.NOMEECOMMERCE as "title",
-                                    esvlistaprodutos.CODFAB as "idProvider",
-                                    esvlistaprodutos.CODAUXILIAR as "ean",
-                                    esvlistaprodutos.TIPOPRODUTO as "productType",
-                                    esvlistaprodutos.DADOSTECNICOS as "technicalData",
-                                    esvlistaprodutos.INFORMACOESTECNICAS as "description",
-                                    esvlistaprodutos.URLIMAGEM as "urlImage",
-                                    esvlistaprodutos.NOMEMARCA as "brand",
-                                    esvlistaprodutos.NOMEDEPARTAMENTO as "department",
-                                    esvlistaprodutos.NOMESECAO as "section",
-                                    esvlistaprodutos.NOMECATEGORIA as "category",
-                                    esvlistaprodutos.NOMEFORNECEDOR as "supplier",
-                                    esvlistaprodutos.CODIGOFILIAL as "store",
-                                    esvlistaprodutos.CLASSEVENDA as "saleAbc",
-                                    esvlistaprodutos.CLASSEESTOQUE as "stockAbc",
-                                    esvlistaprodutos.FORALINHA as "outLine",
-                                    esvlistaprodutos.PRECOVENDA as "listPrice",
-                                    esvlistaprodutos.PRECOPROMOCIONAL as "salePrice",
-                                    esvlistaprodutos.PRECOPROMOCIONAL as "salePromotion",
-                                    esvlistaprodutos.PRECOPROMOCIONAL_AVISTA as "salePromotion_cash",
-                                    esvlistaprodutos.PERCENTUALDESCONTO as "offPercent",
-                                    esvlistaprodutos.QTESTOQUE_DISPONIVEL as "stock",
-                                    esvlistaprodutos.QTCAIXAS as "boxStock",
-                                    esvlistaprodutos.ESTOQUE_DISP_LOJA as "store_stock",
-                                    esvlistaprodutos.ESTOQUE_DISP_CAIXA_LOJA as "store_boxStock",
-                                    esvlistaprodutos.MULTIPLO as "mutiple",
-                                    esvlistaprodutos.UNIDADE as "unity",
-                                    esvlistaprodutos.URLDEPARTAMENTO as "urlDepartment",
-                                    esvlistaprodutos.URLSECAO as "urlSection",
-                                    esvlistaprodutos.PRODUTO_COM_REDUCAO_PRECO as "downPrice",
-                                    esvlistaprodutos.PRODUTO_EM_CAMPANHA as "compaing",
-                                    esvlistaprodutos.BASETINTOMETRICO as "base",
-                                    esvlistaprodutos.LETRABASETINTOMETRICO as "letter",
-                                    esvlistaprodutos.LINHATINTOMETRICO as "line",
-                                    esvlistaprodutos.LITRAGEM as "can",
-                                    esvlistaprodutos.QUANTIDADE_ESTOQUE_GERAL as "full_stock",
-                                    esvlistaprodutos.TEM_PRODUTO_SIMILAR as "similar",
-                                    NVL(esvlistaprodutos.TIPO, 'SEM') as "type_campaing"
-                                FROM ESVLISTAPRODUTOS
-                                WHERE 1 = 1 `;
-
             if (filter && filter.text.length > 0) {
                 const description = filter.text.toUpperCase();
-                console.log('consultando por codigo de fabrica');
+                console.log('consultando por texto: ' + description);
 
+                // Fase 3: Query unificada - busca por CODFAB OU DESCRICAO em uma única query
                 let products = await queryRunner.manager
                     .getRepository(SalesProduct)
                     .createQueryBuilder('esvlistaprodutos')
@@ -97,8 +84,6 @@ export class SalesService {
                     .addSelect("\"esvlistaprodutos\".CODFAB", "idProvider")
                     .addSelect("\"esvlistaprodutos\".CODAUXILIAR", "ean")
                     .addSelect("\"esvlistaprodutos\".TIPOPRODUTO", "productType")
-                    .addSelect("\"esvlistaprodutos\".DADOSTECNICOS", "technicalData")
-                    .addSelect("\"esvlistaprodutos\".INFORMACOESTECNICAS", "description")
                     .addSelect("\"esvlistaprodutos\".URLIMAGEM", "urlImage")
                     .addSelect("\"esvlistaprodutos\".NOMEMARCA", "brand")
                     .addSelect("\"esvlistaprodutos\".NOMEDEPARTAMENTO", "department")
@@ -125,72 +110,13 @@ export class SalesService {
                     .addSelect("\"esvlistaprodutos\".PRODUTO_COM_REDUCAO_PRECO", "downPrice")
                     .addSelect("\"esvlistaprodutos\".PRODUTO_EM_CAMPANHA", "compaing")
                     .addSelect("\"esvlistaprodutos\".BASETINTOMETRICO", "base")
-                    .addSelect("\"esvlistaprodutos\".LETRATINTOMETRICO", "letter")
+                    .addSelect("\"esvlistaprodutos\".LETRABASETINTOMETRICO", "letter")
                     .addSelect("\"esvlistaprodutos\".LINHATINTOMETRICO", "line")
                     .addSelect("\"esvlistaprodutos\".LITRAGEM", "can")
                     .addSelect("\"esvlistaprodutos\".QUANTIDADE_ESTOQUE_GERAL", "full_stock")
                     .addSelect("\"esvlistaprodutos\".TEM_PRODUTO_SIMILAR", "similar")
                     .addSelect("\"esvlistaprodutos\".TIPO_CAMPANHA", "type_campaing")
-                    .where("UPPER(\"esvlistaprodutos\".CODFAB) LIKE '%'||REPLACE(:description, '@', '%')||'%'", { description })
+                    .where("(UPPER(\"esvlistaprodutos\".CODFAB) LIKE '%'||REPLACE(:description, '@', '%')||'%' OR UPPER(\"esvlistaprodutos\".descricao) LIKE '%'||REPLACE(:description, '@', '%')||'%')", { description })
-                    .andWhere("(\"esvlistaprodutos\".codfilial = :codfilial OR :codfilial = '99')", { codfilial: store })
-                    .andWhere("(\"esvlistaprodutos\".produto_com_reducao_preco = :produtoComReducaoPreco OR :produtoComReducaoPreco = 'N')",
-                        { produtoComReducaoPreco: (filter.markdown) ? 'S' : 'N' })
-                    .andWhere("(\"esvlistaprodutos\".produto_em_campanha = :campaign OR :campaign = 'N')",
-                        { campaign: (filter.campaign) ? 'I' : 'N' })
-                    .andWhere("(\"esvlistaprodutos\".produto_em_campanha = :oportunity OR :oportunity = 'N')",
-                        { oportunity: (filter.oportunity) ? 'O' : 'N' })
-                    .andWhere("(\"esvlistaprodutos\".produto_em_promocao = :produtoEmPromocao OR :produtoEmPromocao = 'N')",
-                        { produtoEmPromocao: (filter.promotion) ? 'S' : 'N' })
-                    .limit(pageSize)
-                    .offset(offSet)
-                    .orderBy("\"esvlistaprodutos\".DESCRICAO", "ASC")
-                    .getRawMany();
-                if (products.length == 0) {
-                    products = await queryRunner.manager
-                        .getRepository(SalesProduct)
-                        .createQueryBuilder('esvlistaprodutos')
-                        .select("\"esvlistaprodutos\".CODPROD", "idProduct")
-                        .addSelect("\"esvlistaprodutos\".SEQ", "seq")
-                        .addSelect("\"esvlistaprodutos\".DESCRICAO", "smallDescription")
-                        .addSelect("\"esvlistaprodutos\".NOMEECOMMERCE", "title")
-                        .addSelect("\"esvlistaprodutos\".CODFAB", "idProvider")
-                        .addSelect("\"esvlistaprodutos\".CODAUXILIAR", "ean")
-                        .addSelect("\"esvlistaprodutos\".TIPOPRODUTO", "productType")
-                        .addSelect("\"esvlistaprodutos\".DADOSTECNICOS", "technicalData")
-                        .addSelect("\"esvlistaprodutos\".INFORMACOESTECNICAS", "description")
-                        .addSelect("\"esvlistaprodutos\".URLIMAGEM", "urlImage")
-                        .addSelect("\"esvlistaprodutos\".NOMEMARCA", "brand")
-                        .addSelect("\"esvlistaprodutos\".NOMEDEPARTAMENTO", "department")
-                        .addSelect("\"esvlistaprodutos\".NOMESECAO", "section")
-                        .addSelect("\"esvlistaprodutos\".NOMECATEGORIA", "category")
-                        .addSelect("\"esvlistaprodutos\".NOMEFORNECEDOR", "supplier")
-                        .addSelect("\"esvlistaprodutos\".CODIGOFILIAL", "store")
-                        .addSelect("\"esvlistaprodutos\".CLASSEVENDA", "saleAbc")
-                        .addSelect("\"esvlistaprodutos\".CLASSEESTOQUE", "stockAbc")
-                        .addSelect("\"esvlistaprodutos\".FORALINHA", "outLine")
-                        .addSelect("\"esvlistaprodutos\".PRECOVENDA", "listPrice")
-                        .addSelect("\"esvlistaprodutos\".PRECOPROMOCIONAL", "salePrice")
-                        .addSelect("\"esvlistaprodutos\".PRECOPROMOCIONAL", "salePromotion")
-                        .addSelect("\"esvlistaprodutos\".PRECOPROMOCIONAL_AVISTA", "salePromotion_cash")
-                        .addSelect("\"esvlistaprodutos\".PERCENTUALDESCONTO", "offPercent")
-                        .addSelect("\"esvlistaprodutos\".QTESTOQUE_DISPONIVEL", "stock")
-                        .addSelect("\"esvlistaprodutos\".QTCAIXAS", "boxStock")
-                        .addSelect("\"esvlistaprodutos\".ESTOQUE_DISP_LOJA", "store_stock")
-                        .addSelect("\"esvlistaprodutos\".ESTOQUE_DISP_CAIXA_LOJA", "store_boxStock")
-                        .addSelect("\"esvlistaprodutos\".MULTIPLO", "mutiple")
-                        .addSelect("\"esvlistaprodutos\".UNIDADE", "unity")
-                        .addSelect("\"esvlistaprodutos\".URLDEPARTAMENTO", "urlDepartment")
-                        .addSelect("\"esvlistaprodutos\".URLSECAO", "urlSection")
-                        .addSelect("\"esvlistaprodutos\".PRODUTO_COM_REDUCAO_PRECO", "downPrice")
-                        .addSelect("\"esvlistaprodutos\".PRODUTO_EM_CAMPANHA", "compaing")
-                        .addSelect("\"esvlistaprodutos\".BASETINTOMETRICO", "base")
-                        .addSelect("\"esvlistaprodutos\".LETRATINTOMETRICO", "letter")
-                        .addSelect("\"esvlistaprodutos\".LINHATINTOMETRICO", "line")
-                        .addSelect("\"esvlistaprodutos\".LITRAGEM", "can")
-                        .addSelect("\"esvlistaprodutos\".QUANTIDADE_ESTOQUE_GERAL", "full_stock")
-                        .addSelect("\"esvlistaprodutos\".TEM_PRODUTO_SIMILAR", "similar")
-                        .addSelect("\"esvlistaprodutos\".TIPO_CAMPANHA", "type_campaing")
-                        .where("UPPER(\"esvlistaprodutos\".descricao) LIKE '%'||REPLACE(:description, '@', '%')||'%'", { description })
                     .andWhere("(\"esvlistaprodutos\".codfilial = :codfilial OR :codfilial = '99')", { codfilial: store })
                     .andWhere("(\"esvlistaprodutos\".produto_com_reducao_preco = :produtoComReducaoPreco OR :produtoComReducaoPreco = 'N')",
                         { produtoComReducaoPreco: (filter.markdown) ? 'S' : 'N' })
@@ -200,14 +126,13 @@ export class SalesService {
                         { oportunity: (filter.oportunity) ? 'O' : 'N' })
                     .andWhere("(\"esvlistaprodutos\".produto_em_promocao = :produtoEmPromocao OR :produtoEmPromocao = 'N')",
                         { produtoEmPromocao: (filter.promotion) ? 'S' : 'N' })
-                        .orderBy("\"esvlistaprodutos\".CLASSEVENDA")
                     .limit(pageSize)
                     .offset(offSet)
                     .orderBy("\"esvlistaprodutos\".DESCRICAO", "ASC")
                     .getRawMany();
-                }
                 products = this.createListImages(products);
                 console.log(products.length + ' produtos');
+                try { await this.redisClient.set(cacheKey, JSON.stringify(products), 'EX', 900); } catch (cacheErr) { console.error('Erro ao salvar cache GetProducts2:', cacheErr?.message || cacheErr); }
                 return products;
             }
 
@@ -234,8 +159,6 @@ export class SalesService {
                     .addSelect("\"esvlistaprodutos\".CODFAB", "idProvider")
                     .addSelect("\"esvlistaprodutos\".CODAUXILIAR", "ean")
                     .addSelect("\"esvlistaprodutos\".TIPOPRODUTO", "productType")
-                    .addSelect("\"esvlistaprodutos\".DADOSTECNICOS", "technicalData")
-                    .addSelect("\"esvlistaprodutos\".INFORMACOESTECNICAS", "description")
                     .addSelect("\"esvlistaprodutos\".URLIMAGEM", "urlImage")
                     .addSelect("\"esvlistaprodutos\".NOMEMARCA", "brand")
                     .addSelect("\"esvlistaprodutos\".NOMEDEPARTAMENTO", "department")
@@ -262,7 +185,7 @@ export class SalesService {
                     .addSelect("\"esvlistaprodutos\".PRODUTO_COM_REDUCAO_PRECO", "downPrice")
                     .addSelect("\"esvlistaprodutos\".PRODUTO_EM_CAMPANHA", "compaing")
                     .addSelect("\"esvlistaprodutos\".BASETINTOMETRICO", "base")
-                    .addSelect("\"esvlistaprodutos\".LETRATINTOMETRICO", "letter")
+                    .addSelect("\"esvlistaprodutos\".LETRABASETINTOMETRICO", "letter")
                     .addSelect("\"esvlistaprodutos\".LINHATINTOMETRICO", "line")
                     .addSelect("\"esvlistaprodutos\".LITRAGEM", "can")
                     .addSelect("\"esvlistaprodutos\".QUANTIDADE_ESTOQUE_GERAL", "full_stock")
@@ -285,6 +208,7 @@ export class SalesService {
                     .getRawMany();
                 products = this.createListImages(products);
                 console.log(products.length + ' produtos');
+                try { await this.redisClient.set(cacheKey, JSON.stringify(products), 'EX', 900); } catch (cacheErr) { console.error('Erro ao salvar cache GetProducts2:', cacheErr?.message || cacheErr); }
                 return products;
 
             } else {
@@ -300,8 +224,6 @@ export class SalesService {
                     .addSelect("\"esvlistaprodutos\".CODFAB", "idProvider")
                     .addSelect("\"esvlistaprodutos\".CODAUXILIAR", "ean")
                     .addSelect("\"esvlistaprodutos\".TIPOPRODUTO", "productType")
-                    .addSelect("\"esvlistaprodutos\".DADOSTECNICOS", "technicalData")
-                    .addSelect("\"esvlistaprodutos\".INFORMACOESTECNICAS", "description")
                     .addSelect("\"esvlistaprodutos\".URLIMAGEM", "urlImage")
                     .addSelect("\"esvlistaprodutos\".NOMEMARCA", "brand")
                     .addSelect("\"esvlistaprodutos\".NOMEDEPARTAMENTO", "department")
@@ -328,7 +250,7 @@ export class SalesService {
                     .addSelect("\"esvlistaprodutos\".PRODUTO_COM_REDUCAO_PRECO", "downPrice")
                     .addSelect("\"esvlistaprodutos\".PRODUTO_EM_CAMPANHA", "compaing")
                     .addSelect("\"esvlistaprodutos\".BASETINTOMETRICO", "base")
-                    .addSelect("\"esvlistaprodutos\".LETRATINTOMETRICO", "letter")
+                    .addSelect("\"esvlistaprodutos\".LETRABASETINTOMETRICO", "letter")
                     .addSelect("\"esvlistaprodutos\".LINHATINTOMETRICO", "line")
                     .addSelect("\"esvlistaprodutos\".LITRAGEM", "can")
                     .addSelect("\"esvlistaprodutos\".QUANTIDADE_ESTOQUE_GERAL", "full_stock")
@@ -349,6 +271,7 @@ export class SalesService {
                     .getRawMany();
                 products = this.createListImages(products);
                 console.log(products.length + ' produtos');
+                try { await this.redisClient.set(cacheKey, JSON.stringify(products), 'EX', 900); } catch (cacheErr) { console.error('Erro ao salvar cache GetProducts2:', cacheErr?.message || cacheErr); }
                 return products;
 
             }
@@ -357,7 +280,15 @@ export class SalesService {
             throw error;
         } finally {
             await queryRunner.release();
-            await connectionDb.close();
+            // Não fecha a conexão - reutilizada pelo pool
+            try {
+                const currentLockValue = await this.redisClient.get(lockKey);
+                if (currentLockValue === lockValue.toString()) {
+                    await this.redisClient.del(lockKey);
+                }
+            } catch (lockErr) {
+                console.error('Erro ao liberar lock Redis (GetProducts2):', lockErr?.message || lockErr);
+            }
         }
     }
 
@@ -957,6 +888,9 @@ export class SalesService {
                                 FROM ESVESTOQUEVENDA, PCFILIAL
                             WHERE ESVESTOQUEVENDA.CODPROD = ${id}
                               AND ESVESTOQUEVENDA.CODFILIAL = PCFILIAL.CODIGO
+                              AND EXISTS(SELECT 1 FROM PCFILIALRETIRA R
+                                           WHERE R.CODFILIALVENDA = '${storeId}'
+                                             AND R.CODFILIALRETIRA = ESVESTOQUEVENDA.CODFILIAL)                              
                             ORDER BY TO_NUMBER(ESVESTOQUEVENDA.CODFILIAL) `;
 
             const stock = await queryRunner.query(sql);
@@ -1111,17 +1045,18 @@ export class SalesService {
     }
 
     createListImages(products: SalesProduct[]): SalesProduct[] {
-        products.forEach(product => {
+        for (let i = 0; i < products.length; i++) {
+            const product = products[i];
             product.images = [];
-            if (product.urlImage != null) {
+            if (product.urlImage != null && product.urlImage.length > 0) {
-                let urlImage = product.urlImage;
+                product.images = product.urlImage
-                if (urlImage.indexOf(";") == -1) {
+                    .split(';')
-                    urlImage += ";";
+                    .map(img => img.trim())
+                    .filter(img => img.length > 0);
             }
-                const images = product.urlImage.split(";");
+            // Adiciona thumbnail para acesso rápido no frontend
-                product.images = images.map(i => i.trim());
+            (product as any).thumbnail = product.images.length > 0 ? product.images[0] : null;
         }
-        });
         return products;
     }
 
@@ -1412,8 +1347,7 @@ export class SalesService {
         const skipReg = ((pageNumber - 1) * pageSize);
         const pagination = ` OFFSET ${skipReg} ROWS FETCH NEXT ${pageSize} ROWS ONLY`;
 
-        const connectionDb = new Connection(connectionOptions);
+        const connectionDb = getConnection();
-        await connectionDb.connect();
         const queryRunner = connectionDb.createQueryRunner();
         await queryRunner.connect();
 
@@ -1422,7 +1356,7 @@ export class SalesService {
             products = this.createListImages(products);
             console.log("Total de produtos: " + products.length);
 
-            await this.redisClient.set(cacheKey, JSON.stringify(products), 'EX', 3600);
+            await this.redisClient.set(cacheKey, JSON.stringify(products), 'EX', 900);
 
             return products;
         } catch (err) {
@@ -1430,7 +1364,7 @@ export class SalesService {
             throw err;
         } finally {
             await queryRunner.release();
-            await connectionDb.close();
+            // Não fecha a conexão - reutilizada pelo pool
         }
     }
 
@@ -1521,7 +1455,7 @@ export class SalesService {
         await this.updatePriorityDelivery(dataDeliveryTax.cartId, dataDeliveryTax.priorityDelivery);
 
         if (cityId == 0) {
-            cityId = Number.parseInt(dataDeliveryTax.ibgeCode);
+            cityId = Number.parseInt(dataDeliveryTax.ibgeCode ?? dataDeliveryTax.cityId);
             // throw new HttpException('Cidade não localiza para cálculo da taxa de entrega', HttpStatus.BAD_REQUEST);
         }
         const connectionDb = new Connection(connectionOptions);
@@ -1613,7 +1547,7 @@ export class SalesService {
             // 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`;
+            const sqlRetiraPosterior = `SELECT ( PROXIMO_DIA_UTIL(TO_DATE('${saleDate}', 'DD-MM-YYYY'), '1') - TRUNC(SYSDATE) ) AS "days" FROM DUAL`;
             const timeDaysRetiraPosterior = await queryRunner.query(sqlRetiraPosterior);
 
             return { deliveryDays: timeDays[0].days, retiraPosteriorDays: timeDaysRetiraPosterior[0].days };

src/sales/shopping/shopping.controller.ts

@@ -6,6 +6,7 @@ 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';
 
 @ApiTags('Shopping')
 @Controller('api/v1/shopping')
@@ -39,6 +40,15 @@ export class ShoppingController {
         }
     }
 
+    @Put('cart')
+    async updateCart(@Body() cart: Cart) {
+        try {
+            return await this.shoppingService.updateShopping(cart);
+        } catch (error) {
+            throw new HttpException(error.message, HttpStatus.BAD_REQUEST);
+        }
+    }
+
     @Get('cart/:idcart/item/:idProduct/tipoentrega/:deliveryType')
     async getItemCart(@Req() request, @Param('idCart') idCart: string,
         @Param('idProduct') idProduct: string, @Param('deliveryType') deliveryType: string) {

src/sales/shopping/shopping.service.ts

@@ -8,6 +8,7 @@ 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';
 
 @Injectable()
 export class ShoppingService {
@@ -605,6 +606,39 @@ export class ShoppingService {
         }
     }
 
+    async updateShopping(shopping: any) {
+        const connection = new Connection(connectionOptions);
+        await connection.connect();
+        const queryRunner = connection.createQueryRunner();
+        await queryRunner.connect();
+        try {
+            console.log(JSON.stringify(shopping));
+            const sql = `UPDATE ESTPREVENDAC
+                            SET ESTPREVENDAC.CODCLI        = :codcli
+                                ,ESTPREVENDAC.codendentcli = :codendentcli
+                                ,ESTPREVENDAC.codplpag     = :codplpag
+                                ,ESTPREVENDAC.codcob       = :codcob
+                                ,ESTPREVENDAC.codfilial    = :codfilial
+                            WHERE ID = :id    `;
+
+            await queryRunner.query(sql, [
+                shopping.codcli,
+                shopping.codendentcli,
+                shopping.codplpag,
+                shopping.codcob,
+                shopping.saleStore,
+                shopping.id
+            ]);
+
+            return shopping;
+        } catch (error) {
+            throw error;
+        } finally {
+            await queryRunner.release();
+            await connection.close();
+        }
+    }
+
     async updatePriceShopping(idCart: string, idPaymentPlan: number) {
         const connection = new Connection(connectionOptions);
         await connection.connect();