Compare commits
44 Commits
1bf75ed35c
...
main
| Author | SHA1 | Date | |
|---|---|---|---|
| c707d4a065 | |||
| 0b28379145 | |||
| ca43de8756 | |||
| bb21ca33e4 | |||
| 48d6e64ada | |||
| e0731db836 | |||
| d2265390bd | |||
| a34c7c415c | |||
| 4975d5547d | |||
| fa6f0e0f49 | |||
| c9335a27e5 | |||
| f2b629eaad | |||
| 3b8b079123 | |||
| 1270c04a2c | |||
|
|
ca892daffa | ||
| 8e09813741 | |||
| 4003aab9e0 | |||
|
|
6c1599fbaa | ||
|
|
2b9868bf6d | ||
| 90366c21e5 | |||
| bda9f0f13b | |||
| ce988e93b1 | |||
| 19d34ea672 | |||
| 91f3e857a0 | |||
| e2a008e9a9 | |||
| a3021a545c | |||
| 2ff13691b0 | |||
| f9ba12c43f | |||
| 699a9191e2 | |||
| d400a3febb | |||
| e1159acdf0 | |||
| dfd6c0ef8a | |||
| 7a9a40e859 | |||
| 395c6de2c6 | |||
|
|
6a2e16e503 | ||
|
|
615c4353b8 | ||
|
|
19e1317e3a | ||
|
|
f32a3fd40f | ||
|
|
b1aae3304b | ||
|
|
6dba6fb1a9 | ||
|
|
f5f4d58321 | ||
|
|
eb572913eb | ||
|
|
85012058e5 | ||
|
|
97d9a95208 |
13
.env
Normal file
13
.env
Normal file
@@ -0,0 +1,13 @@
|
||||
ORACLE_CLIENT_PATH='/usr/lib/oracle/21/client64/lib'
|
||||
|
||||
|
||||
###REDIS
|
||||
REDIS_HOST='172.35.0.217'
|
||||
REDIS_PORT='6379'
|
||||
|
||||
|
||||
####ORACLE
|
||||
PORT='8065'
|
||||
DB_USERNAME='simplifique'
|
||||
DB_PASSWORD='simplifique'
|
||||
DB_CONNECT_STRING='(DESCRIPTION=(ADDRESS=(PROTOCOL=TCP)(HOST=172.35.0.250)(PORT=1521))(CONNECT_DATA=(SERVER=DEDICATED)(SERVICE_NAME=ORCL)))'
|
||||
31
.gitea/workflows/deploy-api.yaml
Normal file
31
.gitea/workflows/deploy-api.yaml
Normal file
@@ -0,0 +1,31 @@
|
||||
name: Build (develop) / Promote (main)
|
||||
on:
|
||||
push:
|
||||
branches: [main, develop, homolog]
|
||||
|
||||
jobs:
|
||||
build-and-push-deploy:
|
||||
runs-on: ubuntu-latest
|
||||
steps:
|
||||
- name: Checkout
|
||||
uses: actions/checkout@v4
|
||||
with:
|
||||
fetch-depth: 0
|
||||
|
||||
- name: Push to Gitea Registry
|
||||
run: |
|
||||
# Define Image Name (removes https:// and converts to lowercase)
|
||||
IMAGE="git.simplifiquehc.com.br/${{ gitea.repository }}"
|
||||
IMAGE_LOWER=$(echo "$IMAGE" | tr '[:upper:]' '[:lower:]')
|
||||
|
||||
# Login to Gitea Registry (using the domain)
|
||||
echo "${{ secrets.K8S }}" | docker login git.simplifiquehc.com.br -u "${{ gitea.actor }}" --password-stdin
|
||||
|
||||
# Build and Push
|
||||
docker build -t "$IMAGE_LOWER:latest" .
|
||||
docker push "$IMAGE_LOWER:latest"
|
||||
|
||||
# Optional: Use SHA tag as well
|
||||
TAG=$(echo ${{ gitea.sha }} | cut -c1-7)
|
||||
docker tag "$IMAGE_LOWER:latest" "$IMAGE_LOWER:$TAG"
|
||||
docker push "$IMAGE_LOWER:$TAG"
|
||||
3
.gitignore
vendored
3
.gitignore
vendored
@@ -33,3 +33,6 @@ lerna-debug.log*
|
||||
!.vscode/launch.json
|
||||
!.vscode/extensions.json
|
||||
|
||||
# Environment variables
|
||||
.env
|
||||
|
||||
|
||||
45
Dockerfile
45
Dockerfile
@@ -1,32 +1,39 @@
|
||||
FROM node:16
|
||||
# Estágio 1: Build
|
||||
FROM node:16-bullseye-slim AS builder
|
||||
|
||||
WORKDIR /app
|
||||
COPY package*.json ./
|
||||
RUN npm install --legacy-peer-deps
|
||||
COPY . .
|
||||
RUN npm run build
|
||||
|
||||
FROM node:16-bullseye-slim
|
||||
# Instalar dependências do Oracle
|
||||
RUN apt-get update && apt-get install -y \
|
||||
apt-transport-https \
|
||||
ca-certificates \
|
||||
libaio1 \
|
||||
unzip \
|
||||
wget \
|
||||
libc6 \
|
||||
libncurses5 && \
|
||||
mkdir -p /opt/oracle && \
|
||||
wget https://download.oracle.com/otn_software/linux/instantclient/instantclient-basic-linuxx64.zip -O /opt/oracle/instantclient-basic-linuxx64.zip && \
|
||||
unzip /opt/oracle/instantclient-basic-linuxx64.zip -d /opt/oracle && \
|
||||
rm /opt/oracle/instantclient-basic-linuxx64.zip && \
|
||||
ln -s /opt/oracle/instantclient_* /opt/oracle/instantclient && \
|
||||
echo "/opt/oracle/instantclient" > /etc/ld.so.conf.d/oracle-instantclient.conf && \
|
||||
ldconfig
|
||||
&& mkdir -p /opt/oracle
|
||||
|
||||
# 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
|
||||
|
||||
WORKDIR /app
|
||||
|
||||
# Copiar apenas o necessário do estágio anterior
|
||||
COPY --from=builder /app/dist ./dist
|
||||
COPY --from=builder /app/package*.json ./
|
||||
COPY --from=builder /app/node_modules ./node_modules
|
||||
|
||||
COPY package*.json ./
|
||||
|
||||
|
||||
RUN npm install --legacy-peer-deps
|
||||
|
||||
COPY . .
|
||||
|
||||
# Variáveis de ambiente padrão para o driver oracledb
|
||||
ENV OCI_LIB_DIR=/opt/oracle/instantclient
|
||||
ENV OCI_INC_DIR=/opt/oracle/instantclient/sdk/include
|
||||
|
||||
CMD ["npm", "run", "start:prod"]
|
||||
76
KUBERNETES.md
Normal file
76
KUBERNETES.md
Normal file
@@ -0,0 +1,76 @@
|
||||
# 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.
|
||||
57
WORKFLOWS.md
Normal file
57
WORKFLOWS.md
Normal file
@@ -0,0 +1,57 @@
|
||||
# Documentação dos Workflows (Gitea Actions)
|
||||
|
||||
Este documento descreve os fluxos de trabalho de integração contínua (CI) e entrega contínua (CD) configurados no Gitea Actions para o projeto **Vendaweb-api**.
|
||||
|
||||
## Visão Geral
|
||||
|
||||
Os workflows estão definidos no diretório `.gitea/workflows/`. O principal workflow configurado é o deploy da API.
|
||||
|
||||
## Workflow: Deploy NestJS API
|
||||
|
||||
**Arquivo**: `.gitea/workflows/deploy-api.yaml`
|
||||
|
||||
### Gatilhos (Triggers)
|
||||
|
||||
Este workflow é acionado automaticamente no evento:
|
||||
|
||||
- `push`: Em qualquer branch (configuração atual `on: [push]`).
|
||||
|
||||
### Jobs
|
||||
|
||||
#### `build-and-push-deploy`
|
||||
|
||||
Este job é responsável por construir a imagem Docker e enviá-la para o registry privado (Harbor).
|
||||
|
||||
- **Ambiente de Execução**: `ubuntu-latest` (Runner)
|
||||
|
||||
#### Passos (Steps):
|
||||
|
||||
1. **Checkout**
|
||||
- Utiliza `actions/checkout@v3` para clonar o código fonte do repositório.
|
||||
|
||||
2. **Login no Harbor**
|
||||
- Realiza autenticação no registry Docker privado.
|
||||
- **Registry**: `172.35.0.216`
|
||||
- **Segredos Utilizados**:
|
||||
- `HARBOR_USERNAME`: Nome de usuário do Harbor.
|
||||
- `HARBOR_PASSWORD`: Senha do usuário do Harbor.
|
||||
|
||||
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`)
|
||||
- `172.35.0.216/library/vendaweb-api:latest`
|
||||
- Envia ambas as tags para o registry.
|
||||
|
||||
## 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:
|
||||
|
||||
| Secret | Descrição |
|
||||
| ----------------- | ------------------------------------------------------------- |
|
||||
| `HARBOR_USERNAME` | Usuário com permissão de push no projeto `library` do Harbor. |
|
||||
| `HARBOR_PASSWORD` | Senha ou token de acesso do usuário do Harbor. |
|
||||
|
||||
## Integração com Kubernetes
|
||||
|
||||
Após o push da imagem com a tag `latest` (e o SHA específico), o ArgoCD (configurado conforme `KUBERNETES.md`) detectará as mudanças se houver alteração nos manifestos ou se estiver configurado para pollar a imagem `latest` (dependendo da política de `imagePullPolicy` e configuração do ArgoCD Image Updater, se houver).
|
||||
@@ -1,14 +1,18 @@
|
||||
version: '3.8'
|
||||
|
||||
services:
|
||||
vendaweb:
|
||||
image: link70/vendaweb
|
||||
deploy:
|
||||
replicas: 20
|
||||
resources:
|
||||
limits:
|
||||
cpus: '0.5'
|
||||
memory: 512M
|
||||
vendaweb-api:
|
||||
image: 172.35.0.216/library/vendaweb-api:latest
|
||||
ports:
|
||||
- "8065:8065"
|
||||
restart: always
|
||||
networks:
|
||||
- simplifique-network
|
||||
deploy:
|
||||
replicas: 4
|
||||
update_config:
|
||||
order: start-first
|
||||
parallelism: 1
|
||||
|
||||
networks:
|
||||
simplifique-network:
|
||||
external: true
|
||||
19
k8s/argocd/application-prod.yaml
Normal file
19
k8s/argocd/application-prod.yaml
Normal file
@@ -0,0 +1,19 @@
|
||||
apiVersion: argoproj.io/v1alpha1
|
||||
kind: Application
|
||||
metadata:
|
||||
name: vendaweb-api-prod
|
||||
namespace: argocd
|
||||
spec:
|
||||
project: default
|
||||
source:
|
||||
repoURL: https://git.simplifiquehc.com.br/simplifique/Vendaweb-api.git
|
||||
targetRevision: main
|
||||
path: k8s/overlays/prod
|
||||
destination:
|
||||
server: https://kubernetes.default.svc
|
||||
namespace: vendaweb-api
|
||||
syncPolicy:
|
||||
automated:
|
||||
selfHeal: true
|
||||
syncOptions:
|
||||
- CreateNamespace=true
|
||||
10
k8s/base/configmap.yaml
Normal file
10
k8s/base/configmap.yaml
Normal file
@@ -0,0 +1,10 @@
|
||||
apiVersion: v1
|
||||
kind: ConfigMap
|
||||
metadata:
|
||||
name: vendaweb-api-config
|
||||
data:
|
||||
REDIS_HOST: '172.35.0.250'
|
||||
REDIS_PORT: '6379'
|
||||
DB_HOST: '172.35.0.250'
|
||||
DB_PORT: '1521'
|
||||
DB_SERVICE_NAME: 'ORCL'
|
||||
62
k8s/base/deployment.yaml
Normal file
62
k8s/base/deployment.yaml
Normal file
@@ -0,0 +1,62 @@
|
||||
apiVersion: apps/v1
|
||||
kind: Deployment
|
||||
metadata:
|
||||
name: vendaweb-api
|
||||
labels:
|
||||
app: vendaweb-api
|
||||
spec:
|
||||
replicas: 15
|
||||
selector:
|
||||
matchLabels:
|
||||
app: vendaweb-api
|
||||
template:
|
||||
metadata:
|
||||
labels:
|
||||
app: vendaweb-api
|
||||
spec:
|
||||
imagePullSecrets:
|
||||
- name: harbor-secret
|
||||
containers:
|
||||
- name: api
|
||||
image: git.simplifiquehc.com.br/simplifique/vendaweb-api:latest
|
||||
imagePullPolicy: IfNotPresent
|
||||
ports:
|
||||
- name: http
|
||||
containerPort: 8067
|
||||
protocol: TCP
|
||||
envFrom:
|
||||
- configMapRef:
|
||||
name: vendaweb-api-config
|
||||
- secretRef:
|
||||
name: vendaweb-api-secrets
|
||||
livenessProbe:
|
||||
httpGet:
|
||||
path: /v1/health
|
||||
port: http
|
||||
initialDelaySeconds: 20
|
||||
periodSeconds: 10
|
||||
timeoutSeconds: 2
|
||||
failureThreshold: 6
|
||||
readinessProbe:
|
||||
httpGet:
|
||||
path: /v1/health
|
||||
port: http
|
||||
initialDelaySeconds: 10
|
||||
periodSeconds: 10
|
||||
timeoutSeconds: 2
|
||||
failureThreshold: 6
|
||||
startupProbe:
|
||||
httpGet:
|
||||
path: /v1/health
|
||||
port: http
|
||||
initialDelaySeconds: 5
|
||||
periodSeconds: 5
|
||||
timeoutSeconds: 2
|
||||
failureThreshold: 24
|
||||
resources:
|
||||
requests:
|
||||
cpu: 100m
|
||||
memory: 256Mi
|
||||
limits:
|
||||
cpu: 500m
|
||||
memory: 512Mi
|
||||
7
k8s/base/kustomization.yaml
Normal file
7
k8s/base/kustomization.yaml
Normal file
@@ -0,0 +1,7 @@
|
||||
apiVersion: kustomize.config.k8s.io/v1beta1
|
||||
kind: Kustomization
|
||||
|
||||
resources:
|
||||
- deployment.yaml
|
||||
- service.yaml
|
||||
- configmap.yaml
|
||||
8
k8s/base/secret.yaml
Normal file
8
k8s/base/secret.yaml
Normal file
@@ -0,0 +1,8 @@
|
||||
apiVersion: v1
|
||||
kind: Secret
|
||||
metadata:
|
||||
name: vendaweb-api-secrets
|
||||
type: Opaque
|
||||
stringData:
|
||||
DB_USERNAME: 'simplifique'
|
||||
DB_PASSWORD: 'simplifique'
|
||||
15
k8s/base/service.yaml
Normal file
15
k8s/base/service.yaml
Normal file
@@ -0,0 +1,15 @@
|
||||
apiVersion: v1
|
||||
kind: Service
|
||||
metadata:
|
||||
name: vendaweb-api
|
||||
labels:
|
||||
app: vendaweb-api
|
||||
spec:
|
||||
type: ClusterIP
|
||||
selector:
|
||||
app: vendaweb-api
|
||||
ports:
|
||||
- name: http
|
||||
port: 8067
|
||||
targetPort: 8067
|
||||
protocol: TCP
|
||||
10
k8s/overlays/prod/deployment-image-digest-patch.yaml
Normal file
10
k8s/overlays/prod/deployment-image-digest-patch.yaml
Normal file
@@ -0,0 +1,10 @@
|
||||
apiVersion: apps/v1
|
||||
kind: Deployment
|
||||
metadata:
|
||||
name: vendaweb-api
|
||||
spec:
|
||||
template:
|
||||
spec:
|
||||
containers:
|
||||
- name: api
|
||||
image: 172.35.0.216/library/vendaweb-api@sha256:aac490fcb4ef7baa95f1df01fa50d2d44bdb4ed12b235e5dd89e1d7dc3cd0a3a
|
||||
10
k8s/overlays/prod/kustomization.yaml
Normal file
10
k8s/overlays/prod/kustomization.yaml
Normal file
@@ -0,0 +1,10 @@
|
||||
apiVersion: kustomize.config.k8s.io/v1beta1
|
||||
kind: Kustomization
|
||||
|
||||
namespace: vendaweb-prod
|
||||
|
||||
resources:
|
||||
- ../../base
|
||||
|
||||
patches:
|
||||
- path: service-patch.yaml
|
||||
11
k8s/overlays/prod/service-patch.yaml
Normal file
11
k8s/overlays/prod/service-patch.yaml
Normal file
@@ -0,0 +1,11 @@
|
||||
apiVersion: v1
|
||||
kind: Service
|
||||
metadata:
|
||||
name: vendaweb-api
|
||||
spec:
|
||||
type: NodePort
|
||||
ports:
|
||||
- name: http
|
||||
port: 8067
|
||||
targetPort: 8067
|
||||
nodePort: 30001
|
||||
@@ -93,7 +93,7 @@ export class UserService {
|
||||
' WHERE PCEMPR.CODFILIAL = PCFILIAL.CODIGO (+)' +
|
||||
' AND PCPARAMFILIAL.CODFILIAL = \'99\' ' +
|
||||
' AND PCPARAMFILIAL.NOME = \'CON_CODSETORGERENTELOJA\' ' +
|
||||
' AND PCEMPR.EMAIL = :username AND PCEMPR.SENHABD = CRYPT(:password, USUARIOBD)';
|
||||
' AND PCEMPR.USUARIOBD = :username AND PCEMPR.SENHABD = CRYPT(:password, USUARIOBD)';
|
||||
|
||||
const users = await queryRunner.manager
|
||||
.query(sql, [user.email, user.password]);
|
||||
@@ -142,7 +142,7 @@ export class UserService {
|
||||
.query(sqlDiasSemEntrega, [Number.parseInt(users[0].deliveryTime)]);
|
||||
|
||||
const days = Number.parseInt(deliveryDays2[0].days) +
|
||||
( noDeliveryDays.length > 0 ? Number.parseInt(noDeliveryDays[0].daysNoDelivery) : 0 );
|
||||
(noDeliveryDays.length > 0 ? Number.parseInt(noDeliveryDays[0].daysNoDelivery) : 0);
|
||||
|
||||
const userDb = users[0];
|
||||
console.log(userDb);
|
||||
|
||||
@@ -1,14 +1,20 @@
|
||||
import { Controller, Get } from '@nestjs/common';
|
||||
import { AppService } from './app.service';
|
||||
import { ApiExcludeEndpoint } from '@nestjs/swagger';
|
||||
import { ApiTags, ApiOperation } from '@nestjs/swagger';
|
||||
import { APP_VERSION } from './version';
|
||||
|
||||
@Controller()
|
||||
@ApiTags('Main')
|
||||
@Controller('v1')
|
||||
export class AppController {
|
||||
constructor(private readonly appService: AppService) {}
|
||||
|
||||
@Get()
|
||||
@ApiExcludeEndpoint()
|
||||
getHello(): string {
|
||||
return this.appService.getHello();
|
||||
@Get('version')
|
||||
@ApiOperation({ summary: 'Get App Version' })
|
||||
getVersion() {
|
||||
return { version: APP_VERSION };
|
||||
}
|
||||
|
||||
@Get('health')
|
||||
@ApiOperation({ summary: 'Health check' })
|
||||
healthCheck() {
|
||||
return { status: 'SIMPLIFIQUE HOME CENTER 2026' };
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
@@ -1,18 +1,17 @@
|
||||
import { TypeOrmModuleOptions } from '@nestjs/typeorm';
|
||||
import { ConnectionOptions } from 'typeorm';
|
||||
import 'dotenv/config';
|
||||
|
||||
export const typeOrmConfig: TypeOrmModuleOptions = {
|
||||
type: "oracle",
|
||||
// host: "192.168.100.40",
|
||||
// username: "LIVIA",
|
||||
// password: "LIVIA",
|
||||
host: "10.1.1.241",
|
||||
username: "SEVEN",
|
||||
password: "USR54SEV",
|
||||
// username: "API",
|
||||
// password: "E05H5KIEQV3YKDJR",
|
||||
host: "172.35.0.250",
|
||||
username: process.env.DB_USERNAME || "simplifique",
|
||||
password: process.env.DB_PASSWORD || "simplifique",
|
||||
connectString:
|
||||
process.env.DB_CONNECT_STRING ||
|
||||
'(DESCRIPTION=(ADDRESS=(PROTOCOL=TCP)(HOST=172.35.0.250)(PORT=1521))(CONNECT_DATA=(SERVER=DEDICATED)(SERVICE_NAME=ORCL)))',
|
||||
port: 1521,
|
||||
sid: "WINT",
|
||||
sid: "ORCL",
|
||||
synchronize: false,
|
||||
logging: false,
|
||||
entities: [__dirname + '/../**/*.entity.{js,ts}'],
|
||||
@@ -21,11 +20,14 @@ export const typeOrmConfig: TypeOrmModuleOptions = {
|
||||
|
||||
export const connectionOptions: ConnectionOptions = {
|
||||
type: "oracle",
|
||||
host: "10.1.1.241",
|
||||
username: "SEVEN",
|
||||
password: "USR54SEV",
|
||||
host: "172.35.0.250",
|
||||
username: process.env.DB_USERNAME || "simplifique",
|
||||
password: process.env.DB_PASSWORD || "simplifique",
|
||||
connectString:
|
||||
process.env.DB_CONNECT_STRING ||
|
||||
'(DESCRIPTION=(ADDRESS=(PROTOCOL=TCP)(HOST=172.35.0.250)(PORT=1521))(CONNECT_DATA=(SERVER=DEDICATED)(SERVICE_NAME=ORCL)))',
|
||||
port: 1521,
|
||||
sid: "WINT",
|
||||
sid: "ORCL",
|
||||
synchronize: false,
|
||||
logging: false,
|
||||
entities: [__dirname + '/../**/*.entity.{js,ts}'],
|
||||
|
||||
@@ -1622,8 +1622,8 @@ export class Pcclient {
|
||||
@Column({ name: 'CODCONDCOMERCIAL' })
|
||||
codcondcomercial: string;
|
||||
|
||||
@Column({ name: 'MEIOCOMUNICACAO' })
|
||||
meiocomunicacao: string;
|
||||
// @Column({ name: 'MEIOCOMUNICACAO' })
|
||||
// meiocomunicacao: string;
|
||||
|
||||
@Column({ name: 'CODGRUPOCOMERCIALMED' })
|
||||
codgrupocomercialmed: number;
|
||||
@@ -1637,6 +1637,9 @@ export class Pcclient {
|
||||
@Column({ name: 'CODSUBCATEGORIA' })
|
||||
codsubcategoria: number;
|
||||
|
||||
@Column({ name: 'TIPOENDERECO' })
|
||||
tipoendereco: string;
|
||||
|
||||
@OneToMany(() => Pcnfsaid, notas => notas.pcclient)
|
||||
notas: Pcnfsaid[];
|
||||
|
||||
|
||||
@@ -76,6 +76,9 @@ export class Pcclientendent {
|
||||
@Column({name: 'CODPAISRECEBEDOR'})
|
||||
codpaisrecebedor: number;
|
||||
|
||||
@Column({name: 'TIPOENDERECO'})
|
||||
tipoendereco: string;
|
||||
|
||||
@OneToMany(() => Pcpedc, pedidos => pedidos.pcclientendent)
|
||||
pedidos: Pcpedc[];
|
||||
|
||||
|
||||
@@ -23,5 +23,6 @@ export class Address {
|
||||
emailRecebedor: string;
|
||||
latitude: number;
|
||||
longitude: number;
|
||||
addressType?: string;
|
||||
|
||||
}
|
||||
@@ -19,14 +19,16 @@ export class Customer {
|
||||
public category: Category,
|
||||
public subCategory: SubCategory,
|
||||
public place: Place,
|
||||
public placeId: number,
|
||||
public sellerId: number,
|
||||
public ibgeCode: string,
|
||||
public birthdate: Date,
|
||||
public ramo: Ramo,
|
||||
public birthdate?: Date,
|
||||
public ramo?: Ramo,
|
||||
public communicate?: string,
|
||||
public idUser?: number,
|
||||
public latitude?: number,
|
||||
public longitude?: number,
|
||||
public addressType?: string,
|
||||
){}
|
||||
}
|
||||
|
||||
|
||||
@@ -16,10 +16,10 @@ async function bootstrap() {
|
||||
do cadastro de parceiros, consulta de venda de movimentação e pagamentos, e fechamento das comissões dos parceiros.`)
|
||||
.setVersion("2023.1.2")
|
||||
.addTag("VendaWeb")
|
||||
.addTag("Autenticação")
|
||||
.addTag("Auth")
|
||||
.build();
|
||||
const document = SwaggerModule.createDocument(app, options);
|
||||
SwaggerModule.setup("docs", app, document);
|
||||
await app.listen(8065);
|
||||
await app.listen(8067);
|
||||
}
|
||||
bootstrap();
|
||||
|
||||
@@ -234,6 +234,7 @@ export class PartnerService {
|
||||
null,
|
||||
null,
|
||||
data.place,
|
||||
data.place.id,
|
||||
data.sellerId,
|
||||
data.ibgeCode,
|
||||
null,
|
||||
|
||||
@@ -1,12 +1,23 @@
|
||||
import { Provider } from '@nestjs/common';
|
||||
|
||||
import Redis = require('ioredis');
|
||||
|
||||
|
||||
|
||||
export const redisProvider: Provider = {
|
||||
|
||||
provide: 'REDIS_CLIENT',
|
||||
|
||||
useFactory: () => {
|
||||
|
||||
return new Redis({
|
||||
host: '10.1.1.109',
|
||||
|
||||
host: '172.35.0.217',
|
||||
|
||||
port: 6379,
|
||||
|
||||
});
|
||||
|
||||
},
|
||||
|
||||
};
|
||||
@@ -37,6 +37,7 @@ export class AddressCustomerService {
|
||||
.addSelect('\"pcclientendent\".codpracaent', 'placeId')
|
||||
.addSelect('\"pcclientendent\".latitude', 'latitude')
|
||||
.addSelect('\"pcclientendent\".longitude', 'longitude')
|
||||
.addSelect('\"pcclientendent\".tipoendereco', 'addressType')
|
||||
.where("\"pcclientendent\".codcli = :idCustomer", { idCustomer })
|
||||
.getRawMany();
|
||||
return new ResultModel(true, null, addresses, null);
|
||||
@@ -79,6 +80,7 @@ export class AddressCustomerService {
|
||||
' ,pcclientendent.codpracaent as "placeId" ' +
|
||||
' ,pcclientendent.latitude as "latitude" ' +
|
||||
' ,pcclientendent.longitude as "longitude" ' +
|
||||
' ,pcclientendent.tipoendereco as "addressType" ' +
|
||||
' FROM pcclientendent ' +
|
||||
' WHERE pcclientendent.codcli = :idCustomer ' +
|
||||
' AND pcclientendent.codendentcli = :idAddress ';
|
||||
@@ -122,6 +124,7 @@ export class AddressCustomerService {
|
||||
' ,pcclientendent.codpracaent as "placeId" ' +
|
||||
' ,pcclientendent.latitude as "latitude" ' +
|
||||
' ,pcclientendent.longitude as "longitude" ' +
|
||||
' ,pcclientendent.tipoendereco as "addressType" ' +
|
||||
' FROM pcclientendent ' +
|
||||
' WHERE pcclientendent.codcli = :idCustomer ' +
|
||||
" AND REGEXP_REPLACE(pcclientendent.cepent, '[^0-9]', '') = REGEXP_REPLACE(:cepent, '[^0-9]', '')";
|
||||
@@ -183,6 +186,7 @@ export class AddressCustomerService {
|
||||
emailRecebedor: customer[0].email,
|
||||
latitude: ( data.latitude ) ? data.latitude.toString() : '0',
|
||||
longitude:( data.longitude ) ? data.longitude.toString() : '0',
|
||||
tipoendereco: data.addressType
|
||||
})
|
||||
.where("\"PCCLIENTENDENT\".codcli = :codcli and \"PCCLIENTENDENT\".codendentcli = :codendentcli",
|
||||
{ codcli: data.idCustomer, codendentcli: data.idAddress })
|
||||
@@ -250,6 +254,7 @@ export class AddressCustomerService {
|
||||
newPcclientendent.emailRecebedor = customer.email;
|
||||
newPcclientendent.latitude = ( data.latitude ) ? data.latitude.toString() : '0';
|
||||
newPcclientendent.longitude = ( data.longitude ) ? data.longitude.toString() : '0';
|
||||
newPcclientendent.tipoendereco = data.addressType;
|
||||
|
||||
await queryRunner.manager
|
||||
.createQueryBuilder()
|
||||
@@ -257,6 +262,7 @@ export class AddressCustomerService {
|
||||
.into(Pcclientendent)
|
||||
.values(newPcclientendent)
|
||||
.execute();
|
||||
|
||||
const newAddress: Address = {
|
||||
idCustomer: data.idCustomer,
|
||||
idAddress: id,
|
||||
@@ -282,6 +288,7 @@ export class AddressCustomerService {
|
||||
emailRecebedor: customer.email,
|
||||
latitude: data.latitude,
|
||||
longitude: data.longitude,
|
||||
addressType: data.addressType,
|
||||
}
|
||||
|
||||
return newAddress;
|
||||
|
||||
@@ -44,11 +44,12 @@ export class CustomerService {
|
||||
' ,pccidade.codibge as "ibgeCode" ' +
|
||||
' ,pcclient.dtnasc as "birthdate" ' +
|
||||
' ,pcclient.codatv1 as "ramoId" ' +
|
||||
' ,pcclient.meiocomunicacao as "communicate" ' +
|
||||
// ' ,pcclient.meiocomunicacao as "communicate" ' +
|
||||
' ,pcclient.latitude as "latitude" ' +
|
||||
' ,pcclient.longitude as "longitude" ' +
|
||||
' ,pcclient.codmunicipio as "ibgeCode" ' +
|
||||
' ,pcclient.codcidade as "cityId" ' +
|
||||
' ,pcclient.tipoendereco as "addressType" ' +
|
||||
' FROM pcclient, pccidade ' +
|
||||
' WHERE pcclient.codcidade = pccidade.codcidade (+)';
|
||||
let where = ` AND ( pcclient.cliente like '%'||'${auxName.replace('@', '%')}'||'%' OR ` +
|
||||
@@ -59,7 +60,18 @@ export class CustomerService {
|
||||
const pagination = ` OFFSET 0 ROWS FETCH NEXT 100 ROWS ONLY`;
|
||||
const customers = await queryRunner.manager
|
||||
.query(sql + where + orderBy + pagination) as Customer[];
|
||||
return customers;
|
||||
let customerList: Customer[] = [];
|
||||
for (let i = 0; i < customers.length; i++) {
|
||||
let customer = customers[i];
|
||||
const place = await queryRunner.query(`SELECT PCPRACA.CODPRACA as "placeId"
|
||||
,PCPRACA.PRACA as "name"
|
||||
FROM PCPRACA
|
||||
WHERE PCPRACA.CODPRACA = ${customer.placeId}`);
|
||||
|
||||
customer.place = place[0];
|
||||
customerList.push(customer);
|
||||
}
|
||||
return customerList;
|
||||
} catch (error) {
|
||||
console.log(error);
|
||||
throw error;
|
||||
@@ -90,18 +102,19 @@ export class CustomerService {
|
||||
' ,pcclient.telent as "phone" ' +
|
||||
' ,pcclient.telcelent as "cellPhone" ' +
|
||||
' ,pcclient.ieent as "numberState" ' +
|
||||
' ,pcclient.codcategoria as "categoryId" ' +
|
||||
' ,pcclient.codsubcategoria as "subCategoryId" ' +
|
||||
// ' ,pcclient.codcategoria as "categoryId" ' +
|
||||
// ' ,pcclient.codsubcategoria as "subCategoryId" ' +
|
||||
' ,pcclient.codpraca as "placeId" ' +
|
||||
' ,pcclient.codusur1 as "sellerId" ' +
|
||||
' ,pccidade.codibge as "ibgeCode" ' +
|
||||
' ,pcclient.dtnasc as "birthdate" ' +
|
||||
' ,pcclient.codatv1 as "ramoId" ' +
|
||||
' ,pcclient.meiocomunicacao as "communicate" ' +
|
||||
// ' ,pcclient.meiocomunicacao as "communicate" ' +
|
||||
' ,pcclient.latitude as "latitude" ' +
|
||||
' ,pcclient.longitude as "longitude" ' +
|
||||
' ,pcclient.codmunicipio as "ibgeCode" ' +
|
||||
' ,pcclient.codcidade as "cityId" ' +
|
||||
' ,pcclient.tipoendereco as "addressType" ' +
|
||||
' FROM pcclient, pccidade ' +
|
||||
' WHERE pcclient.codcidade = pccidade.codcidade (+)';
|
||||
const where = ` AND REGEXP_REPLACE(pcclient.cgcent, '[^0-9]', '') =REGEXP_REPLACE('${cpf}', '[^0-9]', '')`;
|
||||
@@ -145,16 +158,22 @@ export class CustomerService {
|
||||
' ,pccidade.codibge as "ibgeCode" ' +
|
||||
' ,pcclient.dtnasc as "birthdate" ' +
|
||||
' ,pcclient.codatv1 as "ramoId" ' +
|
||||
' ,pcclient.meiocomunicacao as "communicate" ' +
|
||||
//' ,pcclient.meiocomunicacao as "communicate" ' +
|
||||
' ,pcclient.latitude as "latitude" ' +
|
||||
' ,pcclient.longitude as "longitude" ' +
|
||||
' ,pcclient.codmunicipio as "ibgeCode" ' +
|
||||
' ,pcclient.codcidade as "cityId" ' +
|
||||
' ,pcclient.tipoendereco as "addressType" ' +
|
||||
' FROM pcclient, pccidade ' +
|
||||
' WHERE pcclient.codcidade = pccidade.codcidade (+)';
|
||||
const where = ` AND pcclient.codcli = ${idCustomer}`;
|
||||
const customer = await queryRunner.query(sql + where);
|
||||
return customer[0];
|
||||
const place = await queryRunner.query(`SELECT PCPRACA.CODPRACA as "placeId"
|
||||
,PCPRACA.PRACA as "name"
|
||||
FROM PCPRACA
|
||||
WHERE PCPRACA.CODPRACA = ${customer[0].placeId}`);
|
||||
|
||||
return { ...customer[0], place: place[0] };
|
||||
} catch (error) {
|
||||
console.log(error);
|
||||
throw error;
|
||||
@@ -216,6 +235,7 @@ export class CustomerService {
|
||||
.addSelect("\"pcclient\".longitude as \"longitude\"")
|
||||
.addSelect("\"pcclient\".codmunicipio as \"ibgeCode\"")
|
||||
.addSelect("\"pcclient\".codcidade as \"cityId\"")
|
||||
.addSelect("\"pcclient\".esc_tipoeclieente as \"addressType\"")
|
||||
.where(where)
|
||||
.andWhere("\"pcclient\".CODCLI NOT IN (2) AND \"pcclient\".DTEXCLUSAO IS NULL")
|
||||
.getRawMany();
|
||||
@@ -247,15 +267,15 @@ export class CustomerService {
|
||||
newCustomer.telcelent = customer.cellPhone;
|
||||
newCustomer.celularwhatsapp = customer.cellPhone;
|
||||
newCustomer.codusur1 = customer.sellerId;
|
||||
newCustomer.codatv1 = ( customer.ramo != null && customer.ramo.id > 0 ) ? customer.ramo.id : newCustomer.codatv1;
|
||||
newCustomer.codatv1 = (customer.ramo != null && customer.ramo.id > 0) ? customer.ramo.id : newCustomer.codatv1;
|
||||
//Endereço de entrega
|
||||
newCustomer.cepent = customer.zipCode;
|
||||
newCustomer.enderent = customer.address.toUpperCase();
|
||||
newCustomer.numeroent = customer.addressNumber;
|
||||
if ( customer.complement !== null && customer.complement.length > 80 ) {
|
||||
newCustomer.complementoent = customer.complement.substring(0, 80 ).toUpperCase();
|
||||
if (customer.complement !== null && customer.complement.length > 80) {
|
||||
newCustomer.complementoent = customer.complement.substring(0, 80).toUpperCase();
|
||||
} else {
|
||||
if ( customer.complement != null ) {
|
||||
if (customer.complement != null) {
|
||||
newCustomer.complementoent = customer.complement.toUpperCase();
|
||||
}
|
||||
}
|
||||
@@ -266,10 +286,10 @@ export class CustomerService {
|
||||
newCustomer.cepcom = customer.zipCode;
|
||||
newCustomer.endercom = customer.address.toUpperCase();
|
||||
newCustomer.numerocom = customer.addressNumber.toUpperCase();
|
||||
if ( customer.complement !== null && customer.complement.length > 80 ) {
|
||||
newCustomer.complementocom = customer.complement.substring(0, 80 ).toUpperCase();
|
||||
if (customer.complement !== null && customer.complement.length > 80) {
|
||||
newCustomer.complementocom = customer.complement.substring(0, 80).toUpperCase();
|
||||
} else {
|
||||
if ( customer.complement != null ) {
|
||||
if (customer.complement != null) {
|
||||
newCustomer.complementocom = customer.complement.toUpperCase();
|
||||
}
|
||||
}
|
||||
@@ -280,10 +300,10 @@ export class CustomerService {
|
||||
newCustomer.cepcob = customer.zipCode;
|
||||
newCustomer.endercob = customer.address.toUpperCase();
|
||||
newCustomer.numerocob = customer.addressNumber;
|
||||
if ( customer.complement !== null && customer.complement.length > 80 ) {
|
||||
newCustomer.complementocob = customer.complement.substring(0, 80 ).toUpperCase();
|
||||
if (customer.complement !== null && customer.complement.length > 80) {
|
||||
newCustomer.complementocob = customer.complement.substring(0, 80).toUpperCase();
|
||||
} else {
|
||||
if ( customer.complement ) {
|
||||
if (customer.complement) {
|
||||
newCustomer.complementocob = customer.complement.toUpperCase();
|
||||
}
|
||||
}
|
||||
@@ -297,13 +317,14 @@ export class CustomerService {
|
||||
newCustomer.codmunicipio = Number.parseInt(customer.ibgeCode);
|
||||
newCustomer.codcidadecom = newCustomer.codcidade;
|
||||
newCustomer.dtnasc = customer.birthdate;
|
||||
newCustomer.meiocomunicacao = customer.communicate;
|
||||
// newCustomer.meiocomunicacao = customer.communicate;
|
||||
newCustomer.codfunccad = customer.idUser;
|
||||
newCustomer.codfunccadastro = customer.idUser;
|
||||
newCustomer.codfuncultalter = customer.idUser;
|
||||
newCustomer.dtultalter = new Date();
|
||||
newCustomer.latitude = customer.latitude;
|
||||
newCustomer.longitude = customer.longitude;
|
||||
newCustomer.tipoendereco = customer.addressType;
|
||||
|
||||
const oldCustomer = await this.findCustomerByCpf(newCustomer.cgcent);
|
||||
if (oldCustomer) {
|
||||
@@ -320,8 +341,9 @@ export class CustomerService {
|
||||
city: customer.city, state: customer.state,
|
||||
allowMessage: customer.allowMessage, cellPhone: customer.cellPhone,
|
||||
category: customer.category, subCategory: customer.subCategory,
|
||||
place: customer.place, ramo: customer.ramo, meiocomunicacao: customer.communicate,
|
||||
latitude: customer.latitude, longitude: customer.longitude, ibgeCode: customer.ibgeCode
|
||||
place: customer.place, ramo: customer.ramo, /*meiocomunicacao: customer.communicate,*/
|
||||
latitude: customer.latitude, longitude: customer.longitude, ibgeCode: customer.ibgeCode,
|
||||
addressType: customer.addressType,
|
||||
};
|
||||
} else {
|
||||
const idCustomer = await this.generateIdCustomer();
|
||||
@@ -339,8 +361,9 @@ export class CustomerService {
|
||||
city: customer.city, state: customer.state,
|
||||
allowMessage: customer.allowMessage, cellPhone: customer.cellPhone,
|
||||
category: customer.category, subCategory: customer.subCategory,
|
||||
place: customer.place, meiocomunicacao: customer.communicate,
|
||||
ramo: customer.ramo, latitude: customer.latitude, longitude: customer.longitude, ibgeCode: customer.ibgeCode
|
||||
place: customer.place, /*meiocomunicacao: customer.communicate,*/
|
||||
ramo: customer.ramo, latitude: customer.latitude, longitude: customer.longitude,
|
||||
ibgeCode: customer.ibgeCode, addressType: customer.addressType,
|
||||
};
|
||||
}
|
||||
} catch (error) {
|
||||
@@ -355,7 +378,7 @@ export class CustomerService {
|
||||
await queryRunner.connect();
|
||||
await queryRunner.startTransaction();
|
||||
try {
|
||||
console.log("MEIO DE COMUNICACAO: " + client.meiocomunicacao);
|
||||
//console.log("MEIO DE COMUNICACAO: " + client.meiocomunicacao);
|
||||
await queryRunner.manager
|
||||
.createQueryBuilder()
|
||||
.update(Pcclient)
|
||||
@@ -396,11 +419,12 @@ export class CustomerService {
|
||||
codcidadecom: client.codcidade,
|
||||
dtnasc: client.dtnasc,
|
||||
codatv1: client.codatv1,
|
||||
meiocomunicacao: client.meiocomunicacao,
|
||||
// meiocomunicacao: client.meiocomunicacao,
|
||||
codfuncultalter: client.codfuncultalter,
|
||||
dtultalter: client.dtultalter,
|
||||
latitude: client.latitude,
|
||||
longitude: client.longitude,
|
||||
tipoendereco: client.tipoendereco
|
||||
})
|
||||
.where({ codcli: client.codcli })
|
||||
.execute();
|
||||
@@ -410,7 +434,7 @@ export class CustomerService {
|
||||
await queryRunner.rollbackTransaction();
|
||||
throw err;
|
||||
} finally {
|
||||
if ( queryRunner.isTransactionActive) {
|
||||
if (queryRunner.isTransactionActive) {
|
||||
await queryRunner.rollbackTransaction();
|
||||
}
|
||||
await queryRunner.release();
|
||||
@@ -542,14 +566,14 @@ export class CustomerService {
|
||||
|
||||
} catch (err) {
|
||||
// since we have errors let's rollback changes we made
|
||||
if ( queryRunner.isTransactionActive) {
|
||||
if (queryRunner.isTransactionActive) {
|
||||
await queryRunner.rollbackTransaction();
|
||||
}
|
||||
console.log(err);
|
||||
return -1;
|
||||
|
||||
} finally {
|
||||
if ( queryRunner.isTransactionActive) {
|
||||
if (queryRunner.isTransactionActive) {
|
||||
await queryRunner.rollbackTransaction();
|
||||
}
|
||||
// you need to release query runner which is manually created:
|
||||
@@ -579,7 +603,7 @@ export class CustomerService {
|
||||
console.log(err);
|
||||
throw err;
|
||||
} finally {
|
||||
if ( queryRunner.isTransactionActive) {
|
||||
if (queryRunner.isTransactionActive) {
|
||||
await queryRunner.rollbackTransaction();
|
||||
}
|
||||
await queryRunner.release();
|
||||
|
||||
@@ -176,6 +176,20 @@ export class SalesController {
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
@Get('product/simil/:id')
|
||||
@ApiOperation({ summary: 'Get products similar' })
|
||||
@ApiParam({ name: 'id', description: 'Product ID' })
|
||||
async getProductSimil(@Headers() headers, @Param('id') id: number) {
|
||||
try {
|
||||
const { store } = this.extractPaginationParams(headers);
|
||||
return await this.salesService.GetProductsSimil(store, id);
|
||||
} catch (e) {
|
||||
throw new HttpException(e.message, HttpStatus.BAD_REQUEST);
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
@Get('stock/:storeid/:id')
|
||||
@ApiOperation({ summary: 'Get product stock information' })
|
||||
@ApiParam({ name: 'storeid', description: 'Store ID' })
|
||||
|
||||
@@ -23,7 +23,7 @@ export class SalesService {
|
||||
constructor(
|
||||
@Inject('REDIS_CLIENT') private readonly redisClient: Redis.Redis,
|
||||
private readonly customerService: CustomerService
|
||||
) {}
|
||||
) { }
|
||||
|
||||
|
||||
async GetProducts2(store: string, pageSize: number, pageNumber: number, filter: FilterProduct = null,) {
|
||||
@@ -77,9 +77,11 @@ export class SalesService {
|
||||
esvlistaprodutos.LETRABASETINTOMETRICO as "letter",
|
||||
esvlistaprodutos.LINHATINTOMETRICO as "line",
|
||||
esvlistaprodutos.LITRAGEM as "can",
|
||||
esvlistaprodutos.QUANTIDADE_ESTOQUE_GERAL as "full_stock"
|
||||
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`;
|
||||
WHERE 1 = 1 `;
|
||||
|
||||
if (filter && filter.text.length > 0) {
|
||||
const description = filter.text.toUpperCase();
|
||||
@@ -127,6 +129,8 @@ export class SalesService {
|
||||
.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 })
|
||||
.andWhere("(\"esvlistaprodutos\".codfilial = :codfilial OR :codfilial = '99')", { codfilial: store })
|
||||
.andWhere("(\"esvlistaprodutos\".produto_com_reducao_preco = :produtoComReducaoPreco OR :produtoComReducaoPreco = 'N')",
|
||||
@@ -184,6 +188,8 @@ export class SalesService {
|
||||
.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')",
|
||||
@@ -260,6 +266,8 @@ export class SalesService {
|
||||
.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("esvlistaprodutos.brand in (" + xbrands + ")")
|
||||
.andWhere("\"esvlistaprodutos\".URLCATEGORIA LIKE :urlCategoria||'%'", { urlCategoria: filter.urlCategory })
|
||||
.andWhere("(\"esvlistaprodutos\".codfilial = :codfilial OR :codfilial = '99')", { codfilial: store })
|
||||
@@ -324,6 +332,8 @@ export class SalesService {
|
||||
.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("(\"esvlistaprodutos\".codfilial = :codfilial OR :codfilial = '99')", { codfilial: store })
|
||||
.andWhere("(\"esvlistaprodutos\".produto_com_reducao_preco = :produtoComReducaoPreco OR :produtoComReducaoPreco = 'N')",
|
||||
{ produtoComReducaoPreco: (filter.markdown.toString() == 'true') ? 'S' : 'N' })
|
||||
@@ -562,6 +572,8 @@ export class SalesService {
|
||||
.addSelect("\"esvlistaprodutos\".PRODUTO_EM_CAMPANHA", "compaing")
|
||||
.addSelect("\"esvlistaprodutos\".BASETINTOMETRICO", "base")
|
||||
.addSelect("\"esvlistaprodutos\".QUANTIDADE_ESTOQUE_GERAL", "full_stock")
|
||||
.addSelect("\"esvlistaprodutos\".TEM_PRODUTO_SIMILAR", "similar")
|
||||
.addSelect("\"esvlistaprodutos\".TIPO_CAMPANHA", "type_campaing")
|
||||
.where("esvlistaprodutos.idProduct = :id", { id: numbers })
|
||||
.andWhere("\"esvlistaprodutos\".codfilial = :codfilial OR :codfilial = '99'", { codfilial: store })
|
||||
.limit(pageSize)
|
||||
@@ -609,6 +621,8 @@ export class SalesService {
|
||||
.addSelect("\"esvlistaprodutos\".PRODUTO_EM_CAMPANHA", "compaing")
|
||||
.addSelect("\"esvlistaprodutos\".BASETINTOMETRICO", "base")
|
||||
.addSelect("\"esvlistaprodutos\".QUANTIDADE_ESTOQUE_GERAL", "full_stock")
|
||||
.addSelect("\"esvlistaprodutos\".TEM_PRODUTO_SIMILAR", "similar")
|
||||
.addSelect("\"esvlistaprodutos\".TIPO_CAMPANHA", "type_campaing")
|
||||
.where("esvlistaprodutos.CODAUXILIAR = :id", { id: numbers })
|
||||
.andWhere("(\"esvlistaprodutos\".codfilial = :codfilial OR :codfilial = '99')", { codfilial: store })
|
||||
.limit(pageSize)
|
||||
@@ -658,6 +672,8 @@ export class SalesService {
|
||||
.addSelect("\"esvlistaprodutos\".PRODUTO_EM_CAMPANHA", "compaing")
|
||||
.addSelect("\"esvlistaprodutos\".BASETINTOMETRICO", "base")
|
||||
.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 })
|
||||
.andWhere("\"esvlistaprodutos\".codfilial = :codfilial OR :codfilial = '99'", { codfilial: store })
|
||||
.limit(pageSize)
|
||||
@@ -704,6 +720,8 @@ export class SalesService {
|
||||
.addSelect("\"esvlistaprodutos\".PRODUTO_EM_CAMPANHA", "compaing")
|
||||
.addSelect("\"esvlistaprodutos\".BASETINTOMETRICO", "base")
|
||||
.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 })
|
||||
.limit(pageSize)
|
||||
@@ -773,6 +791,8 @@ export class SalesService {
|
||||
.addSelect("\"esvlistaprodutos\".PRODUTO_EM_CAMPANHA", "compaing")
|
||||
.addSelect("\"esvlistaprodutos\".BASETINTOMETRICO", "base")
|
||||
.addSelect("\"esvlistaprodutos\".QUANTIDADE_ESTOQUE_GERAL", "full_stock")
|
||||
.addSelect("\"esvlistaprodutos\".TEM_PRODUTO_SIMILAR", "similar")
|
||||
.addSelect("\"esvlistaprodutos\".TIPO_CAMPANHA", "type_campaing")
|
||||
.where("esvlistaprodutos.idProduct = :id", { id: id })
|
||||
.andWhere("\"esvlistaprodutos\".codfilial = :codfilial", { codfilial: store })
|
||||
.orderBy("REPLACE(\"esvlistaprodutos\".DESCRICAO,'#', '')", "ASC")
|
||||
@@ -834,6 +854,8 @@ export class SalesService {
|
||||
,esvlistaprodutos.PRODUTO_EM_CAMPANHA as "compaing"
|
||||
,esvlistaprodutos.BASETINTOMETRICO as "base"
|
||||
,esvlistaprodutos.QUANTIDADE_ESTOQUE_GERAL as "full_stock"
|
||||
,esvlistaprodutos.TEM_PRODUTO_SIMILAR as "similar"
|
||||
,esvlistaprodutos.TIPO_CAMPANHA as "type_campaing"
|
||||
FROM ESVLISTAPRODUTOS, ESTCOMPREJUNTO
|
||||
WHERE ESVLISTAPRODUTOS.CODPROD = ESTCOMPREJUNTO.CODPROD
|
||||
AND ESTCOMPREJUNTO.CODPRODVENDA = ${id}
|
||||
@@ -851,6 +873,68 @@ export class SalesService {
|
||||
}
|
||||
}
|
||||
|
||||
async GetProductsSimil(store: string, id: number) {
|
||||
const connectionDb = new Connection(connectionOptions);
|
||||
await connectionDb.connect();
|
||||
const queryRunner = connectionDb.createQueryRunner();
|
||||
await queryRunner.connect();
|
||||
try {
|
||||
const sql = `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.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.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.QUANTIDADE_ESTOQUE_GERAL as "full_stock"
|
||||
,esvlistaprodutos.TEM_PRODUTO_SIMILAR as "similar"
|
||||
,esvlistaprodutos.TIPO_CAMPANHA as "type_campaing"
|
||||
FROM ESVLISTAPRODUTOS, PCPRODSIMIL
|
||||
WHERE ESVLISTAPRODUTOS.CODPROD = PCPRODSIMIL.CODSIMIL
|
||||
AND PCPRODSIMIL.CODPROD = ${id}
|
||||
AND ESVLISTAPRODUTOS.CODFILIAL = '${store}'
|
||||
ORDER BY REPLACE(esvlistaprodutos.DESCRICAO,'#', '')`;
|
||||
let products: SalesProduct[] = await queryRunner.query(sql);
|
||||
|
||||
products = this.createListImages(products);
|
||||
return products;
|
||||
} catch (error) {
|
||||
throw error;
|
||||
} finally {
|
||||
await queryRunner.release();
|
||||
await connectionDb.close();
|
||||
}
|
||||
}
|
||||
|
||||
async GetStocks(storeId: string, id: number) {
|
||||
const connectionDb = new Connection(connectionOptions);
|
||||
await connectionDb.connect();
|
||||
@@ -1127,15 +1211,15 @@ export class SalesService {
|
||||
const lockKey = 'departments_lock';
|
||||
const lockTimeout = 30;
|
||||
|
||||
try {
|
||||
const cachedDepartments = await this.redisClient.get(cacheKey);
|
||||
if (cachedDepartments) {
|
||||
console.log('Buscando departamentos no Redis');
|
||||
return JSON.parse(cachedDepartments);
|
||||
}
|
||||
} catch (err) {
|
||||
console.error('Erro ao acessar o Redis (cache):', err);
|
||||
}
|
||||
// try {
|
||||
// const cachedDepartments = await this.redisClient.get(cacheKey);
|
||||
// if (cachedDepartments) {
|
||||
// console.log('Buscando departamentos no Redis');
|
||||
// return JSON.parse(cachedDepartments);
|
||||
// }
|
||||
// } catch (err) {
|
||||
// console.error('Erro ao acessar o Redis (cache):', err);
|
||||
// }
|
||||
const lockValue = Date.now() + lockTimeout * 1000 + 1;
|
||||
const acquiredLock = await this.redisClient.set(lockKey, lockValue, 'NX', 'EX', lockTimeout);
|
||||
|
||||
@@ -1150,7 +1234,7 @@ export class SalesService {
|
||||
.getRepository(Esvdepartamento)
|
||||
.createQueryBuilder('Esvdepartamento')
|
||||
.innerJoinAndSelect('Esvdepartamento.secoes', 'secoes')
|
||||
.innerJoinAndSelect('secoes.categorias', 'categorias')
|
||||
.leftJoinAndSelect('secoes.categorias', 'categorias')
|
||||
.where('"Esvdepartamento".tituloecommerce is not null')
|
||||
.orderBy('"Esvdepartamento".tituloecommerce, "secoes".tituloecommerce, "categorias".tituloecommerce')
|
||||
.getMany();
|
||||
@@ -1265,8 +1349,10 @@ export class SalesService {
|
||||
' ,esvlistaprodutos.LINHATINTOMETRICO "line" ' +
|
||||
' ,esvlistaprodutos.LITRAGEM "can" ' +
|
||||
' ,esvlistaprodutos.QUANTIDADE_ESTOQUE_GERAL "full_stock" ' +
|
||||
' ,esvlistaprodutos.TEM_PRODUTO_SIMILAR "similar" ' +
|
||||
' ,esvlistaprodutos.TIPO_CAMPANHA "type_campaing" ' +
|
||||
' FROM esvlistaprodutos ' +
|
||||
' WHERE 1 = 1';
|
||||
' WHERE 1 = 1 ';
|
||||
|
||||
let where = "";
|
||||
if (filter.text != null) {
|
||||
@@ -1362,7 +1448,7 @@ export class SalesService {
|
||||
const queryRunner = connectionDb.createQueryRunner();
|
||||
await queryRunner.connect();
|
||||
try {
|
||||
const sql = 'SELECT ESVCALCULOFRETE.CODTABELAFRETE as "id" ' +
|
||||
/*const sql = 'SELECT ESVCALCULOFRETE.CODTABELAFRETE as "id" ' +
|
||||
' ,ESVCALCULOFRETE.CODFILIAL as "store" ' +
|
||||
' ,ESVCALCULOFRETE.CODCIDADE as "cityId" ' +
|
||||
' ,PCCIDADE.NOMECIDADE as "cityName" ' +
|
||||
@@ -1376,7 +1462,22 @@ export class SalesService {
|
||||
' AND ESVCALCULOFRETE.CODCIDADE = PCCIDADE.CODCIDADE ' +
|
||||
' AND ESVCALCULOFRETE.CODCIDADE = :1 ' +
|
||||
' AND ESVCALCULOFRETE.IDCART = :2 ' +
|
||||
' ORDER BY VLFRETE';
|
||||
' ORDER BY VLFRETE';*/
|
||||
|
||||
const sql = `SELECT 0 as "id"
|
||||
,'1' as "store"
|
||||
,ESVCALCULOFRETE.CODCIDADE as "cityId"
|
||||
,PCCIDADE.NOMECIDADE as "cityName"
|
||||
,NULL as "carrierId"
|
||||
,'SIMPLIFIQUE HOMECENTER' as "carrierName"
|
||||
,0 as "minSale"
|
||||
,ESVCALCULOFRETE.VLFRETE as "deliveryValue"
|
||||
,NULL as "deliveryTime"
|
||||
FROM ESVCALCULOFRETE, PCCIDADE
|
||||
WHERE ESVCALCULOFRETE.CODCIDADE = PCCIDADE.CODCIDADE
|
||||
AND ESVCALCULOFRETE.CODCIDADE = :1
|
||||
AND ESVCALCULOFRETE.IDCART = :2
|
||||
ORDER BY VLFRETE`;
|
||||
|
||||
const deliveryTaxTable = await queryRunner.manager
|
||||
.query(sql, [cityId, cartId]);
|
||||
@@ -1428,7 +1529,22 @@ export class SalesService {
|
||||
const queryRunner = connectionDb.createQueryRunner();
|
||||
await queryRunner.connect();
|
||||
try {
|
||||
const sql = 'SELECT ESVCALCULOFRETE.CODTABELAFRETE as "id" ' +
|
||||
const sql = `SELECT 0 as "id"
|
||||
,'1' as "store"
|
||||
,ESVCALCULOFRETE.CODCIDADE as "cityId"
|
||||
,PCCIDADE.NOMECIDADE as "cityName"
|
||||
,NULL as "carrierId"
|
||||
,'SIMPLIFIQUE HOMECENTER' as "carrierName"
|
||||
,0 as "minSale"
|
||||
,ESVCALCULOFRETE.VLFRETE as "deliveryValue"
|
||||
,NULL as "deliveryTime"
|
||||
FROM ESVCALCULOFRETE, PCCIDADE
|
||||
WHERE ESVCALCULOFRETE.CODCIDADE = PCCIDADE.CODCIDADE
|
||||
AND ESVCALCULOFRETE.CODCIDADE = :1
|
||||
AND ESVCALCULOFRETE.IDCART = :2
|
||||
ORDER BY VLFRETE`;
|
||||
|
||||
/*const sql = 'SELECT ESVCALCULOFRETE.CODTABELAFRETE as "id" ' +
|
||||
' ,ESVCALCULOFRETE.CODFILIAL as "store" ' +
|
||||
' ,ESVCALCULOFRETE.CODCIDADE as "cityId" ' +
|
||||
' ,PCCIDADE.NOMECIDADE as "cityName" ' +
|
||||
@@ -1442,7 +1558,7 @@ export class SalesService {
|
||||
' AND ESVCALCULOFRETE.CODCIDADE = PCCIDADE.CODCIDADE ' +
|
||||
' AND ESVCALCULOFRETE.CODCIDADE = :1 ' +
|
||||
' AND ESVCALCULOFRETE.IDCART = :2 ' +
|
||||
' ORDER BY VLFRETE';
|
||||
' ORDER BY VLFRETE';*/
|
||||
|
||||
let deliveryTaxTable = await queryRunner.manager
|
||||
.query(sql, [dataDeliveryTax.cityId, dataDeliveryTax.cartId]);
|
||||
|
||||
1
src/version.ts
Normal file
1
src/version.ts
Normal file
@@ -0,0 +1 @@
|
||||
export const APP_VERSION = 'v1.1.0';
|
||||
Reference in New Issue
Block a user