From 66720c5b8be6b6e6c2bc3804a4abf0965e3af807 Mon Sep 17 00:00:00 2001 From: shancheas Date: Sat, 21 Dec 2024 05:20:25 +0700 Subject: [PATCH] feat: implement requiring call notification --- src/modules/queue/domain/queue-admin.orchestrator.ts | 11 +++++++---- 1 file changed, 7 insertions(+), 4 deletions(-) diff --git a/src/modules/queue/domain/queue-admin.orchestrator.ts b/src/modules/queue/domain/queue-admin.orchestrator.ts index 96d6214..b08c796 100644 --- a/src/modules/queue/domain/queue-admin.orchestrator.ts +++ b/src/modules/queue/domain/queue-admin.orchestrator.ts @@ -57,12 +57,16 @@ export class QueueAdminOrchestrator { for (const queueItem of itemMasters) { const queueTimes = await this.queueTimeFormula.items(queueItem.id); + const call_preparation = queueItem.call_preparation * 60 * 1000; if (!queueItem.use_notification) continue; for (const queueId in queueTimes) { const callTime = queueTimes[queueId]; - if (timeIsBefore(currentTime, callTime, queueItem.call_preparation)) { + if ( + queueItem.requiring_notification || + timeIsBefore(currentTime, callTime, queueItem.call_preparation) + ) { const queueTicket = await this.service.queueTicket(queueId); const payload: WhatsappQueue = { id: queueId, @@ -76,11 +80,10 @@ export class QueueAdminOrchestrator { console.log({ currentTime: toTime(currentTime), callTime: toTime(callTime), - last_notification: toTime(queueTicket.last_notification), - queueId, + lastNotification: toTime(queueTicket.last_notification), + code: queueTicket.code, }); - const call_preparation = queueItem.call_preparation * 60 * 1000; if (queueTicket.last_notification < currentTime - call_preparation) { await notification.queueProcess(payload); this.service.updateLastNotification(queueId, currentTime);