diff --git a/src/server.js b/src/server.js index cf4c34e..798696b 100644 --- a/src/server.js +++ b/src/server.js @@ -8,6 +8,8 @@ const { logInfo, logError } = require('./utils/logger.js'); const app = createApp(); +let isCronRunning = false; // Variável de controle para evitar sobreposição + const PORT = process.env.PORT || 3000; app.listen(PORT, () => { @@ -16,12 +18,20 @@ app.listen(PORT, () => { // Agenda a tarefa para rodar a cada 5 minutos. logInfo('⏰ Agendando cron job para processar atendimentos a cada 5 minutos.'); cron.schedule('*/5 * * * *', async () => { + if (isCronRunning) { + logInfo('CRON: Tentativa de início, mas o processo anterior ainda está em execução. Pulando esta rodada.'); + return; + } + + isCronRunning = true; logInfo('CRON: Iniciando processamento de atendimentos...'); try { await processaAtendimentos(); logInfo('CRON: Processamento de atendimentos concluído com sucesso.'); } catch (error) { logError('CRON: Erro durante o processamento de atendimentos.', error); + } finally { + isCronRunning = false; // Garante que a trava seja liberada, mesmo em caso de erro } }); });