From fa6931a5bb70d88093a47d71222d8b7653b81bf9 Mon Sep 17 00:00:00 2001 From: Rafael Lopes Date: Fri, 23 Jan 2026 09:03:42 -0300 Subject: [PATCH] FIX: Ajustado status de completed para uso correto do banco de dados --- src/infra/cron/observer.cron.js | 2 +- src/infra/db/repositories/hubglpi/watchdog.repository.js | 5 ++--- src/infra/db/repositories/hubsoft/tickets.repository.js | 4 ---- src/modules/watchdog/services/notifyAdmins.service.js | 2 +- 4 files changed, 4 insertions(+), 9 deletions(-) diff --git a/src/infra/cron/observer.cron.js b/src/infra/cron/observer.cron.js index b4fdf05..a90567f 100644 --- a/src/infra/cron/observer.cron.js +++ b/src/infra/cron/observer.cron.js @@ -6,7 +6,7 @@ const runWatchdog = require('../../modules/watchdog/job/job') logInfo('[CRON] 🐶 Watchdog cron iniciado') -cron.schedule('*/30 * * * *', async () => { +cron.schedule('*/5 * * * *', async () => { logInfo('[CRON] 🐶 Watchdog executando verificação') try { diff --git a/src/infra/db/repositories/hubglpi/watchdog.repository.js b/src/infra/db/repositories/hubglpi/watchdog.repository.js index 50c829b..4ffff5f 100644 --- a/src/infra/db/repositories/hubglpi/watchdog.repository.js +++ b/src/infra/db/repositories/hubglpi/watchdog.repository.js @@ -137,7 +137,7 @@ async function markNotificationsAsCompleted(hubsoftTicketIds, type = 'func') { if (ids.length === 0) return; - const status = buildStatus('completed', type); + const status = buildStatus('end', type); const query = ` INSERT INTO watchdog_notifications (ticket_id, notified_at, status) SELECT @@ -153,12 +153,11 @@ async function markNotificationsAsCompleted(hubsoftTicketIds, type = 'func') { try { await db.query(query, [ids, status]); } catch (error) { - logError('[WATCHDOG][REPOSITORY] Erro ao marcar notificaÇÎÇæÇÎÇÝes como concluido', error); + logError('[WATCHDOG][REPOSITORY] Erro ao marcar notificação como concluido', error); throw error; } } - async function getPendingTicketsForNotification(type = 'func') { const status = buildStatus('pending', type); const query = ` diff --git a/src/infra/db/repositories/hubsoft/tickets.repository.js b/src/infra/db/repositories/hubsoft/tickets.repository.js index a30a72d..d69c4ee 100644 --- a/src/infra/db/repositories/hubsoft/tickets.repository.js +++ b/src/infra/db/repositories/hubsoft/tickets.repository.js @@ -117,10 +117,6 @@ async function getTicketsClosedSince(thresholdDate) { } ] } - - - - const mundialeUserId = process.env.HUBSOFT_MUNDIALE_USER_ID; if (!mundialeUserId) { diff --git a/src/modules/watchdog/services/notifyAdmins.service.js b/src/modules/watchdog/services/notifyAdmins.service.js index 9dd42b5..3c198cc 100644 --- a/src/modules/watchdog/services/notifyAdmins.service.js +++ b/src/modules/watchdog/services/notifyAdmins.service.js @@ -21,7 +21,7 @@ async function notifyAdmins({ sinceMinutes = 30 } = {}) { continue } - const isUpdated = await repository.checkTicketIsUpdated(glpiTicketId, sinceMinutes) + const isUpdated = await repository.checkTicketIsUpdated(glpiTicketId, sinceMinutes) if (isUpdated) { logInfo(`[WATCHDOG] [ADM] Chamado ${hubsoftTicketId} atualizado no GLPI. Encerrando fluxo.`) await repository.markNotificationAsCompleted(hubsoftTicketId, 'func')