fix: persist shipping fee and refresh k8s docs
All checks were successful
Build (develop) / Promote (main) / build-and-push-deploy (push) Successful in 1m14s
All checks were successful
Build (develop) / Promote (main) / build-and-push-deploy (push) Successful in 1m14s
This commit is contained in:
@@ -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:<sha>`
|
|
||||||
- **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.
|
|
||||||
156
k8s/README.md
Normal file
156
k8s/README.md
Normal file
@@ -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`
|
||||||
@@ -14,7 +14,7 @@ export class AppController {
|
|||||||
@Get('health')
|
@Get('health')
|
||||||
@ApiOperation({ summary: 'Health check' })
|
@ApiOperation({ summary: 'Health check' })
|
||||||
healthCheck() {
|
healthCheck() {
|
||||||
return { status: 'SIMPLIFIQUE HOME CENTER 202' };
|
return { status: 'SIMPLIFIQUE HOME CENTER 2026' };
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|||||||
19
src/main.ts
19
src/main.ts
@@ -6,20 +6,25 @@ import 'reflect-metadata';
|
|||||||
import { CustomLoggerService } from './services/custom-logger.service';
|
import { CustomLoggerService } from './services/custom-logger.service';
|
||||||
|
|
||||||
async function bootstrap() {
|
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.enableCors();
|
||||||
app.use(compression());
|
app.use(compression());
|
||||||
const options = new DocumentBuilder()
|
const options = new DocumentBuilder()
|
||||||
.setTitle('API Venda web')
|
.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
|
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();
|
.build();
|
||||||
const document = SwaggerModule.createDocument(app, options);
|
const document = SwaggerModule.createDocument(app, options);
|
||||||
SwaggerModule.setup("docs", app, document);
|
SwaggerModule.setup('docs', app, document);
|
||||||
await app.listen(8067);
|
await app.listen(8067);
|
||||||
}
|
}
|
||||||
bootstrap();
|
bootstrap();
|
||||||
|
|||||||
@@ -1,5 +1,5 @@
|
|||||||
/* eslint-disable @typescript-eslint/camelcase */
|
/* 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 { ShoppingItens } from 'src/domain/entity/tables/estprevendai.entity';
|
||||||
import { Sale } from 'src/domain/entity/tables/estvenda.entity';
|
import { Sale } from 'src/domain/entity/tables/estvenda.entity';
|
||||||
import { Pcpedctemp } from 'src/domain/entity/tables/pcpedctemp.entity';
|
import { Pcpedctemp } from 'src/domain/entity/tables/pcpedctemp.entity';
|
||||||
@@ -527,6 +527,7 @@ export class OrderService {
|
|||||||
preOrder.esc_ajustarfinanceiro = "N";
|
preOrder.esc_ajustarfinanceiro = "N";
|
||||||
preOrder.esc_obternsu = "N";
|
preOrder.esc_obternsu = "N";
|
||||||
preOrder.esc_vloutrasdespweb = 0;
|
preOrder.esc_vloutrasdespweb = 0;
|
||||||
|
preOrder.vloutrasdesp = cart.shippingValue;
|
||||||
preOrder.pedidopagoecommerce = "S";
|
preOrder.pedidopagoecommerce = "S";
|
||||||
preOrder.numpedmktplace = "";
|
preOrder.numpedmktplace = "";
|
||||||
preOrder.numitens = cart.itens.length;
|
preOrder.numitens = cart.itens.length;
|
||||||
@@ -538,7 +539,7 @@ export class OrderService {
|
|||||||
|
|
||||||
//Dados do cliente
|
//Dados do cliente
|
||||||
preOrder.codcli = cart.idCustomer;
|
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.fretedespacho = customer.fretedespacho;
|
||||||
preOrder.codfornecfrete = cart.carrierId;
|
preOrder.codfornecfrete = cart.carrierId;
|
||||||
|
|
||||||
@@ -586,7 +587,7 @@ export class OrderService {
|
|||||||
itemOrder.codfilialretira = item.idStock;
|
itemOrder.codfilialretira = item.idStock;
|
||||||
itemOrder.tipoentrega = (item.deliveryMethod == 'RA') ? "RP" : item.deliveryMethod;
|
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') {
|
if (item.deliveryMethod == 'RA') {
|
||||||
preOrder.dtentrega = new Date();
|
preOrder.dtentrega = new Date();
|
||||||
}
|
}
|
||||||
itemOrder.ptabela = Number.parseFloat(listPrice);
|
itemOrder.ptabela = Number.parseFloat(listPrice);
|
||||||
@@ -619,7 +620,7 @@ export class OrderService {
|
|||||||
itemOrder.codfilialretira = item.idStock;
|
itemOrder.codfilialretira = item.idStock;
|
||||||
itemOrder.tipoentrega = (item.deliveryMethod == 'RA') ? "RP" : item.deliveryMethod;
|
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') {
|
if (item.deliveryMethod == 'RA') {
|
||||||
preOrder.dtentrega = new Date();
|
preOrder.dtentrega = new Date();
|
||||||
}
|
}
|
||||||
itemOrder.ptabela = item.listPrice;
|
itemOrder.ptabela = item.listPrice;
|
||||||
@@ -643,34 +644,34 @@ export class OrderService {
|
|||||||
|
|
||||||
//#endregion
|
//#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:
|
// execute some operations on this transaction:
|
||||||
await queryRunner.manager
|
await queryRunner.manager
|
||||||
@@ -690,7 +691,7 @@ export class OrderService {
|
|||||||
await queryRunner.release();
|
await queryRunner.release();
|
||||||
await connection.close();
|
await connection.close();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -745,7 +746,7 @@ export class OrderService {
|
|||||||
let sql = 'SELECT NVL(PROXNUMPEDWEB,0) as "proxnumpedweb" FROM PCUSUARI ' +
|
let sql = 'SELECT NVL(PROXNUMPEDWEB,0) as "proxnumpedweb" FROM PCUSUARI ' +
|
||||||
' WHERE PCUSUARI.CODUSUR = :1 FOR UPDATE';
|
' WHERE PCUSUARI.CODUSUR = :1 FOR UPDATE';
|
||||||
const seller = await queryRunner.query(sql, [idSeller]);
|
const seller = await queryRunner.query(sql, [idSeller]);
|
||||||
|
|
||||||
const idOrder = seller[0].proxnumpedweb;
|
const idOrder = seller[0].proxnumpedweb;
|
||||||
console.log(idOrder);
|
console.log(idOrder);
|
||||||
|
|
||||||
@@ -757,7 +758,7 @@ export class OrderService {
|
|||||||
' WHERE PCUSUARI.CODUSUR = :1';
|
' WHERE PCUSUARI.CODUSUR = :1';
|
||||||
await queryRunner.query(sql, [idSeller]);
|
await queryRunner.query(sql, [idSeller]);
|
||||||
|
|
||||||
|
|
||||||
await queryRunner.commitTransaction();
|
await queryRunner.commitTransaction();
|
||||||
return idOrder;
|
return idOrder;
|
||||||
|
|
||||||
@@ -820,7 +821,7 @@ export class OrderService {
|
|||||||
` ,PCCLIENT.CLIENTE as "customerName" ` +
|
` ,PCCLIENT.CLIENTE as "customerName" ` +
|
||||||
` ,PCPEDC.VLATEND as "orderValue" ` +
|
` ,PCPEDC.VLATEND as "orderValue" ` +
|
||||||
` ,PCPEDC.NUMITENS as "itens" ` +
|
` ,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 ` +
|
` FROM PCPEDC, PCCLIENT ` +
|
||||||
` WHERE PCPEDC.CODCLI = PCCLIENT.CODCLI ` +
|
` WHERE PCPEDC.CODCLI = PCCLIENT.CODCLI ` +
|
||||||
` AND PCPEDC.CONDVENDA IN (1,7) ` +
|
` AND PCPEDC.CONDVENDA IN (1,7) ` +
|
||||||
@@ -867,7 +868,7 @@ export class OrderService {
|
|||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
async getItensOrder(idOrder: number) {
|
async getItensOrder(idOrder: number) {
|
||||||
const connection = new Connection(connectionOptions);
|
const connection = new Connection(connectionOptions);
|
||||||
@@ -1064,7 +1065,7 @@ export class OrderService {
|
|||||||
async getProductsOrder(store: string, initialDate: Date, finalDate: Date,
|
async getProductsOrder(store: string, initialDate: Date, finalDate: Date,
|
||||||
document: string, name: string, sellerId: number, idOrder: string,
|
document: string, name: string, sellerId: number, idOrder: string,
|
||||||
typeFilterProduct: string, productText: string
|
typeFilterProduct: string, productText: string
|
||||||
) {
|
) {
|
||||||
|
|
||||||
const sql = `SELECT PCPEDC.DATA as "date"
|
const sql = `SELECT PCPEDC.DATA as "date"
|
||||||
,PCPEDC.NUMPED as "orderId"
|
,PCPEDC.NUMPED as "orderId"
|
||||||
@@ -1103,53 +1104,53 @@ export class OrderService {
|
|||||||
|
|
||||||
let sqlWhere = '';
|
let sqlWhere = '';
|
||||||
if (store != null && store != '' && store != '99') {
|
if (store != null && store != '' && store != '99') {
|
||||||
sqlWhere += ` AND PCPEDC.CODFILIAL = '${store}' `;
|
sqlWhere += ` AND PCPEDC.CODFILIAL = '${store}' `;
|
||||||
}
|
}
|
||||||
if (document != null && document != '') {
|
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]', '')`;
|
||||||
}
|
}
|
||||||
if (name != null && name != '') {
|
if (name != null && name != '') {
|
||||||
sqlWhere += ` AND PCCLIENT.CLIENTE LIKE '${name.replace('@', '%')}'||'%'`;
|
sqlWhere += ` AND PCCLIENT.CLIENTE LIKE '${name.replace('@', '%')}'||'%'`;
|
||||||
}
|
}
|
||||||
if (sellerId > 0) {
|
if (sellerId > 0) {
|
||||||
sqlWhere += ` AND PCPEDC.CODUSUR = ${sellerId} `;
|
sqlWhere += ` AND PCPEDC.CODUSUR = ${sellerId} `;
|
||||||
}
|
}
|
||||||
if (idOrder.trim() != null && idOrder.trim() != '') {
|
if (idOrder.trim() != null && idOrder.trim() != '') {
|
||||||
sqlWhere += ` AND PCPEDC.NUMPED = ${idOrder} `;
|
sqlWhere += ` AND PCPEDC.NUMPED = ${idOrder} `;
|
||||||
}
|
}
|
||||||
|
|
||||||
if ( typeFilterProduct != '') {
|
if (typeFilterProduct != '') {
|
||||||
switch (typeFilterProduct) {
|
switch (typeFilterProduct) {
|
||||||
case 'ID':
|
case 'ID':
|
||||||
sqlWhere += ` AND PCPEDI.CODPROD = ${productText} `;
|
sqlWhere += ` AND PCPEDI.CODPROD = ${productText} `;
|
||||||
break;
|
break;
|
||||||
case 'EAN':
|
case 'EAN':
|
||||||
sqlWhere += ` AND PCPRODUT.CODAUXILIAR = ${productText} `;
|
sqlWhere += ` AND PCPRODUT.CODAUXILIAR = ${productText} `;
|
||||||
break;
|
break;
|
||||||
case 'TEXT':
|
case 'TEXT':
|
||||||
sqlWhere += ` AND PCPRODUT.DESCRICAO LIKE '${productText}%' `;
|
sqlWhere += ` AND PCPRODUT.DESCRICAO LIKE '${productText}%' `;
|
||||||
break;
|
break;
|
||||||
case 'PARTNER':
|
case 'PARTNER':
|
||||||
sqlWhere += ` AND PCPRODUT.CODFAB like '${productText}%'`;
|
sqlWhere += ` AND PCPRODUT.CODFAB like '${productText}%'`;
|
||||||
break;
|
break;
|
||||||
default: break;
|
default: break;
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
}
|
||||||
|
|
||||||
//tratamento de data//
|
//tratamento de data//
|
||||||
const startDate = new Date(initialDate);
|
const startDate = new Date(initialDate);
|
||||||
let day = startDate.getDate();
|
let day = startDate.getDate();
|
||||||
let month = ("00" + (startDate.getMonth() + 1)).slice(-2);
|
let month = ("00" + (startDate.getMonth() + 1)).slice(-2);
|
||||||
let year = startDate.getFullYear();
|
let year = startDate.getFullYear();
|
||||||
const startFormat = day + "/" + month + "/" + year;
|
const startFormat = day + "/" + month + "/" + year;
|
||||||
const endDate = new Date(finalDate);
|
const endDate = new Date(finalDate);
|
||||||
day = endDate.getDate();
|
day = endDate.getDate();
|
||||||
month = ("00" + (endDate.getMonth() + 1)).slice(-2);
|
month = ("00" + (endDate.getMonth() + 1)).slice(-2);
|
||||||
year = endDate.getFullYear();
|
year = endDate.getFullYear();
|
||||||
const endFormat = day + "/" + month + "/" + year;
|
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);
|
const connection = new Connection(connectionOptions);
|
||||||
await connection.connect();
|
await connection.connect();
|
||||||
|
|||||||
Reference in New Issue
Block a user