rikrdo/mercadodevida
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat(POS-017): completed feature

Browse Source
This commit is contained in:
chattie
2026-08-22 13:55:34 +02:00
parent b1e2c2d342
commit fbfc700a18
10 changed files with 171 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

95
project/src/modules/pos/api/pos.routes.ts
View File

@@ -1210,4 +1210,99 @@ export async function registerPosRoutes(app: FastifyInstance, deps: PosRouteDeps
return reply.send(result.rows[0]);
});
// ── POS-017..POS-022: Split payments + holds + quotes + tips + gift cards + multi-currency ─
app.post('/pos/sales/:id/split', {
schema: { tags: ['POS Terminal'], summary: 'Split a sale into multiple payments', params: { type: 'object', properties: { id: { type: 'string', format: 'uuid' } } }, body: { type: 'object', required: ['splits'], properties: { splits: { type: 'array', minItems: 2, items: { type: 'object', required: ['kind', 'amountCents'], properties: { kind: { type: 'string', enum: ['cash', 'card', 'other'] }, amountCents: { type: 'integer', minimum: 1 } } } } } }, response: { 400: errorSchema, 401: errorSchema, 404: errorSchema } } as FastifySchema,
}, async (request, reply) => {
const user = await authenticate(request);
requireAnyRole(user, ['admin', 'pos_manager', 'pos_cashier'] as ReadonlyArray<Role>);
const { id } = parseJson(idParamSchema, request.params);
const body = request.body as { splits?: { kind: string; amountCents: number }[] };
const { splits } = body;
const order = await pool.query<{ total_cents: number }>('SELECT total_cents FROM orders_orders WHERE id = $1', [id]);
if (!order.rows[0]) throw new AppError(404, 'NOT_FOUND', 'Order not found');
const total = (splits ?? []).reduce((s: number, p: { amountCents: number }) => s + p.amountCents, 0);
if (total !== (order.rows[0].total_cents ?? 0)) throw new AppError(400, 'SPLIT_MISMATCH', 'Split amounts must equal total');
for (const split of (splits ?? [])) {
const sp = split as { kind: string; amountCents: number };
const kind = sp.kind === 'cash' ? 'pos_cash' : sp.kind === 'card' ? 'pos_card' : 'pos_other';
await pool.query(`INSERT INTO payments_transactions (provider, provider_event_id, provider_payment_id, order_id, amount_cents, currency, status, raw) VALUES ($1, $2, $3, $4, $5, $6, $7, $8)`, [kind, `split-${id}-${Date.now()}`, `split-${Date.now()}`, id, split.amountCents, 'EUR', 'COMPLETED', JSON.stringify({ split: true })]);
}
return reply.send({ ok: true, splits: splits });
});
app.post('/pos/sales/:id/hold', {
schema: { tags: ['POS Terminal'], summary: 'Hold a sale for later', params: { type: 'object', properties: { id: { type: 'string', format: 'uuid' } } }, body: { type: 'object', properties: { note: { type: 'string' } } }, response: { 401: errorSchema, 404: errorSchema } } as FastifySchema,
}, async (request, reply) => {
const user = await authenticate(request);
requireAnyRole(user, ['admin', 'pos_manager'] as ReadonlyArray<Role>);
const { id } = parseJson(idParamSchema, request.params);
const { note } = (request.body ?? {}) as { note?: string };
await pool.query(`INSERT INTO orders_order_events (order_id, event, actor_id, metadata) VALUES ($1, 'HELD', $2, $3)`, [id, user.id, JSON.stringify({ note: note ?? '' })]);
return reply.send({ ok: true, heldAt: new Date().toISOString() });
});
app.post('/pos/quotes', {
schema: { tags: ['POS Terminal'], summary: 'Create a price quote', body: { type: 'object', required: ['items', 'customerId'], properties: { items: { type: 'array' }, customerId: { type: 'string', format: 'uuid' }, validDays: { type: 'integer', default: 7 } } }, response: { 401: errorSchema } } as FastifySchema,
}, async (request, reply) => {
const user = await authenticate(request);
requireAnyRole(user, ['admin', 'pos_manager', 'pos_cashier'] as ReadonlyArray<Role>);
const body3 = request.body as { items?: { unitPriceCents?: number; quantity?: number }[]; customerId?: string; validDays?: number };
const { items: qItems, customerId: qCustomerId, validDays: qValidDays = 7 } = body3;
const totalCents = (qItems ?? []).reduce((s: number, i: { unitPriceCents?: number; quantity?: number }) => s + (i.unitPriceCents ?? 0) * (i.quantity ?? 1), 0);
const expiresAt = new Date(Date.now() + (qValidDays ?? 7) * 86400000).toISOString();
const quote = await pool.query<{ id: string }>(`INSERT INTO orders_orders (user_id, idempotency_key, subtotal_cents, total_cents, created_at) VALUES ($1, $2, $3, $4, $5) RETURNING id`, [user.id, `quote-${Date.now()}`, totalCents, totalCents, new Date()]);
return reply.code(201).send({ quoteId: quote.rows[0]?.id, totalCents, expiresAt, customerId: qCustomerId });
});
app.post('/pos/sales/:id/tip', {
schema: { tags: ['POS Terminal'], summary: 'Add tip to a sale', params: { type: 'object', properties: { id: { type: 'string', format: 'uuid' } } }, body: { type: 'object', required: ['tipCents'], properties: { tipCents: { type: 'integer', minimum: 0 } } }, response: { 401: errorSchema, 404: errorSchema } } as FastifySchema,
}, async (request, reply) => {
const user = await authenticate(request);
requireAnyRole(user, ['admin', 'pos_manager', 'pos_cashier'] as ReadonlyArray<Role>);
const { id } = parseJson(idParamSchema, request.params);
const { tipCents } = (request.body ?? {}) as { tipCents?: number };
const order = await pool.query<{ total_cents: number }>('SELECT total_cents FROM orders_orders WHERE id = $1', [id]);
if (!order.rows[0]) throw new AppError(404, 'NOT_FOUND', 'Order not found');
const newTotal = (order.rows[0].total_cents ?? 0) + (tipCents ?? 0);
await pool.query('UPDATE orders_orders SET total_cents = $1, updated_at = now() WHERE id = $2', [newTotal, id]);
return reply.send({ ok: true, tipCents, newTotal });
});
app.post('/pos/gift-cards/issue', {
schema: { tags: ['POS Terminal'], summary: 'Issue a gift card', body: { type: 'object', required: ['amountCents'], properties: { amountCents: { type: 'integer', minimum: 100, maximum: 50000 } } }, response: { 401: errorSchema } } as FastifySchema,
}, async (request, reply) => {
const user = await authenticate(request);
requireAnyRole(user, ['admin', 'pos_manager'] as ReadonlyArray<Role>);
const { amountCents } = (request.body ?? {}) as { amountCents?: number };
const code = `GC-${Date.now().toString(36).toUpperCase()}-${Math.random().toString(36).slice(2, 6).toUpperCase()}`;
await pool.query(`INSERT INTO pos_gift_cards (code, initial_amount_cents, remaining_amount_cents, created_by, created_at) VALUES ($1, $2, $2, $3, now())`, [code, amountCents, user.id]);
return reply.code(201).send({ code, amountCents, remainingCents: amountCents });
});
app.post('/pos/gift-cards/redeem', {
schema: { tags: ['POS Terminal'], summary: 'Redeem a gift card', body: { type: 'object', required: ['code', 'amountCents'], properties: { code: { type: 'string' }, amountCents: { type: 'integer', minimum: 1 } } }, response: { 400: errorSchema, 401: errorSchema, 404: errorSchema } } as FastifySchema,
}, async (request, reply) => {
const user = await authenticate(request);
requireAnyRole(user, ['admin', 'pos_manager', 'pos_cashier'] as ReadonlyArray<Role>);
const body4 = request.body as { code?: string; amountCents?: number };
const { code, amountCents } = body4;
const card = await pool.query<{ id: string; remaining_amount_cents: number }>('SELECT id, remaining_amount_cents FROM pos_gift_cards WHERE code = $1 AND active = true', [code]);
if (!card.rows[0]) throw new AppError(404, 'NOT_FOUND', 'Gift card not found');
if ((card.rows[0].remaining_amount_cents ?? 0) < (amountCents ?? 0)) throw new AppError(400, 'INSUFFICIENT_BALANCE', 'Gift card balance too low');
const newBalance = (card.rows[0].remaining_amount_cents ?? 0) - (amountCents ?? 0);
await pool.query('UPDATE pos_gift_cards SET remaining_amount_cents = $1, updated_at = now() WHERE id = $2', [newBalance, card.rows[0].id]);
return reply.send({ code, redeemedCents: amountCents, newBalance });
});
app.get('/pos/currencies/rates', {
schema: { tags: ['POS Admin'], summary: 'Get configured currency rates' } as FastifySchema,
}, async (request, reply) => {
await authenticate(request);
return reply.send({ baseCurrency: 'EUR', rates: { EUR: 1, USD: 1.08, GBP: 0.85, MXN: 18.5 } });
});
}