eigen
/
pos-be
12
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 295 Wiki Activity

fix(SPG-1047): merge item queue with same item

pull/115/head
shancheas 2024-11-21 10:39:20 +07:00
parent 5e4401a974
commit ea25e0cae1
2 changed files with 23 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/modules/queue/data/services/ticket.service.ts
View File

@ -118,8 +118,12 @@ export class TicketDataService extends BaseDataService<QueueTicket> {
} }
async deleteQueue(transaction_id: string): Promise<void> { async deleteQueue(transaction_id: string): Promise<void> {
try {
const transactions = await this.transactions(transaction_id); const transactions = await this.transactions(transaction_id);
await this.order.remove(transactions); await this.order.remove(transactions);
} catch (error) {
console.log('transaction not found');
}
} }
async orderIds(order_id: string): Promise<string[]> { async orderIds(order_id: string): Promise<string[]> {

18
src/modules/queue/infrastructure/handlers/transaction.handler.ts
View File

@ -59,6 +59,7 @@ export class QueueTransactionHandler
.filter((item) => item.item.use_queue) .filter((item) => item.item.use_queue)
.map<QueueItem>((item) => { .map<QueueItem>((item) => {
return { return {
item_queue_id: item.item.item_queue_id,
item_id: item.item_id, item_id: item.item_id,
qty: item.qty, qty: item.qty,
}; };
@ -69,7 +70,7 @@ export class QueueTransactionHandler
customer_phone, customer_phone,
); );
const insertTickets = []; const insertTickets: QueueTicket[] = [];
if (customer_name && customer_phone && existTicket) { if (customer_name && customer_phone && existTicket) {
existTicket.items.push(...items); existTicket.items.push(...items);
await this.ticketService.updateQueueTicket(existTicket); await this.ticketService.updateQueueTicket(existTicket);
@ -90,18 +91,25 @@ export class QueueTransactionHandler
) { ) {
insertTickets.forEach((ticket) => { insertTickets.forEach((ticket) => {
const ticket_id = ticket.id; const ticket_id = ticket.id;
const items = {};
ticket.items.forEach((item) => { ticket.items.forEach((item) => {
const item_id = item.item_id; const item_id = item['item_queue_id'];
const currentItem = items[item_id];
// for (let i = 0; i < item.qty; i++) { if (currentItem) {
const payload = { currentItem.qty += item.qty;
}
items[item_id] = currentItem
? currentItem
: {
item_id, item_id,
ticket_id, ticket_id,
qty: item.qty, qty: item.qty,
}; };
});
Object.values(items).forEach((payload: any) => {
this.create(payload); this.create(payload);
// }
}); });
}); });
} }