.env.example

@@ -29,9 +29,6 @@ HUBSOFT_DATABASE_NAME=hubsoft
 HUBSOFT_DATABASE_USER=
 HUBSOFT_DATABASE_PASSWORD=
 HUBSOFT_MUNDIALE_USER_ID=248
-HUBSOFT_IMPLANTACAO_RESPONSAVEL_USER_IDS=142
-HUBSOFT_CANCELAMENTO_RESPONSAVEL_USER_IDS=142
-HUBSOFT_TITULARIDADE_RESPONSAVEL_USER_IDS=142
 
 # ==============================================================================
 # BANCO DE DADOS INTERMEDIÁRIO - HUBGLPI (PostgreSQL - Desenvolvimento)

.gitea/workflows/deploy-prod.yaml

@@ -1,26 +0,0 @@
-name: Deploy Production
-
-on:
-  push:
-    branches:
-      - main
-
-jobs:
-  deploy:
-    runs-on: vm-prod
-
-    steps:
-      - name: Deploy application
-        run: |
-          set -euo pipefail
-
-          cd /opt/HUBXGLPI
-
-          git fetch origin main
-          git checkout main
-          git pull --ff-only origin main
-
-          npm ci --omit=dev
-
-          pm2 reload ecosystem.config.js --env production || pm2 start ecosystem.config.js --env production
-          pm2 save

.gitignore

@@ -2,4 +2,3 @@ node_modules/
 logs/
 .env.development
 .env.production
-.idea/

src/infra/db/repositories/hubsoft/tickets.repository.js

@@ -6,7 +6,6 @@ const { logError } = require('../../../../shared/utils/logger.js')
 async function getTicketsByTipo({
   tipoAtendimento,
   usuarioAbertura = null,
-  usuariosResponsaveisIds = null,
   watermark = null
 }) {
   try {
@@ -82,23 +81,6 @@ async function getTicketsByTipo({
       params.push(usuarioAbertura);
     }
 
-    const responsibleUserIds = normalizeUserIds(usuariosResponsaveisIds);
-
-    if (responsibleUserIds.length) {
-      const responsibleIdsParam = paramIndex++;
-
-      query += `
-        AND EXISTS (
-          SELECT 1
-          FROM atendimento_usuario_responsavel AS aur
-          WHERE aur.id_atendimento = a.id_atendimento
-            AND aur.id_usuario = ANY($${responsibleIdsParam}::int[])
-        )
-      `;
-
-      params.push(responsibleUserIds);
-    }
-
     if (watermark) {
       query += ` AND a.data_cadastro > $${paramIndex++}`;
       params.push(watermark);
@@ -113,12 +95,6 @@ async function getTicketsByTipo({
   }
 }
 
-function normalizeUserIds(values) {
-  return (values || [])
-    .map(value => Number(value))
-    .filter(Number.isInteger);
-}
-
 async function getTicketsClosedSince(thresholdDate) {
   try {
 

src/modules/tickets/repositories/ticket.repository.js

@@ -41,10 +41,6 @@ async function getMundialeTickets(watermark) {
 async function getImplantacaoTickets(watermark) {
   return hubsoftTicketsRepo.getTicketsByTipo({
     tipoAtendimento: TYPES.IMPLANTACAO,
-    usuariosResponsaveisIds: parseCsvNumberEnv(
-      process.env.HUBSOFT_IMPLANTACAO_RESPONSAVEL_USER_IDS,
-      [142]
-    ),
     watermark
   });
 }
@@ -52,10 +48,6 @@ async function getImplantacaoTickets(watermark) {
 async function getCancelamentoTickets(watermark) {
   return hubsoftTicketsRepo.getTicketsByTipo({
     tipoAtendimento: TYPES.CANCELAMENTO,
-    usuariosResponsaveisIds: parseCsvNumberEnv(
-      process.env.HUBSOFT_CANCELAMENTO_RESPONSAVEL_USER_IDS,
-      [142]
-    ),
     watermark
   });
 }
@@ -70,10 +62,6 @@ async function getSacTickets(watermark) {
 async function getTrocaTTickets(watermark) {
   return hubsoftTicketsRepo.getTicketsByTipo({
     tipoAtendimento: TYPES.TITULARIDADE,
-    usuariosResponsaveisIds: parseCsvNumberEnv(
-      process.env.HUBSOFT_TITULARIDADE_RESPONSAVEL_USER_IDS,
-      [142]
-    ),
     watermark
   });
 }
@@ -142,17 +130,6 @@ async function sendHubglpiMessage(hubId, message) {
   });
 }
 
-function parseCsvNumberEnv(value, fallback = []) {
-  if (!value) return fallback;
-
-  const parsed = value
-    .split(',')
-    .map(item => Number(item.trim()))
-    .filter(Number.isInteger);
-
-  return parsed.length ? parsed : fallback;
-}
-
 
 module.exports = {
   // watermark

src/modules/tickets/services/resolveTicketEntity.service.js

@@ -5,7 +5,7 @@ const repository = require('../repositories/ticket.repository.js')
 async function resolveEntityId(ticketData) {
 
   const entityByService = await repository.getEntitiesByService(
-    ticketData.codigo_cliente,
+    ticketData.codigo_clasiente,
     ticketData.codigo_servico
   );
 

src/modules/tickets/useCases/syncTickets.usecase.js

@@ -22,31 +22,31 @@ async function syncTicketsUseCase() {
   const mundiale = await mundialeService.fetchNew(waterMark)
   logInfo(`[USECASE] ${mundiale.length} tickets Mundiale encontrados`)
 
-  const implantacao = await implantacaoService.fetchNew(waterMark)
-  logInfo(`[USECASE] ${implantacao.length} tickets Implantacao encontrados`)
+  //const implantacao = await implantacaoService.fetchNew(waterMark)
+  //logInfo(`[USECASE] ${implantacao.length} tickets Implantação encontrados`)
 
-  const cancelamento = await cancelamentoService.fetchNew(waterMark)
-  logInfo(`[USECASE] ${cancelamento.length} tickets Cancelamento encontrados`)
+  //const cancelamento = await cancelamentoService.fetchNew(waterMark)
+  //logInfo(`[USECASE] ${cancelamento.length} tickets Cancelamento encontrados`)
 
   //const sac = await sacService.fetchNew(waterMark) //TODO
   //logInfo(`[USECASE] ${sac.length} tickets SAC encontrados`) 
 
-  const trocaTitularidade = await trocaTitularidadeService.fetchNew(waterMark)
-  logInfo(`[USECASE] ${trocaTitularidade.length} tickets Troca de Titularidade encontrados`)
+  //const trocaTitularidade = await trocaTitularidadeService.fetchNew(waterMark) //TODO
+  //logInfo(`[USECASE] ${trocaTitularidade.length} tickets Troca de Titularidade encontrados`)
 
 
   await mundialeService.saveHubGlpi(mundiale)
-  await implantacaoService.saveHubGlpi(implantacao)
-  await cancelamentoService.saveHubGlpi(cancelamento)
+  //await implantacaoService.saveHubGlpi(implantacao)
+  //await cancelamentoService.saveHubGlpi(cancelamento)
   //await sacService.saveHubGlpi(sac) //TODO
-  await trocaTitularidadeService.saveHubGlpi(trocaTitularidade) 
+  //await trocaTitularidadeService.saveHubGlpi(trocaTitularidade) 
 
   const allFetchedTickets = [
     ...mundiale,
-    ...implantacao,
-    ...cancelamento,
+    //...implantacao,
+    //...cancelamento,
     //...sac,
-    ...trocaTitularidade
+    //...trocaTitularidade
   ]
 
   const newWaterMark = resolveNewWatermark(allFetchedTickets, waterMark)
@@ -83,10 +83,10 @@ async function syncTicketsUseCase() {
 function resolveTicketService(type) {
   const map = {
     MUNDIALE: mundialeService,
-    IMPLANTACAO: implantacaoService,
-    CANCELAMENTO: cancelamentoService,
+    //IMPLANTACAO: implantacaoService,
+    //CANCELAMENTO: cancelamentoService,
     //SAC: sacService, //TODO
-    TITULARIDADE: trocaTitularidadeService 
+    //TITULARIDADE: trocaTitularidadeService 
   }
 
   return map[type]