diff --git a/src/modules/queue/data/services/queue.service.ts b/src/modules/queue/data/services/queue.service.ts index d7d2506..048f18c 100644 --- a/src/modules/queue/data/services/queue.service.ts +++ b/src/modules/queue/data/services/queue.service.ts @@ -41,10 +41,14 @@ export class QueueDataService extends BaseReadService { const queues = await this.repo.find({ where: { item_queue_id, + status: 'waiting', }, }); - for (const queue of queues) { + queueTimes[queues[0].id] = now; // first queue will be now + + for (let i = 1; i < queues.length; i++) { + const queue = queues[i]; // duration will be total qty multiple by average const duration = queue.qty * average;