Copy // src/repositories/order.repository.ts
import { database } from '@config/database';
import { Order, OrderItem, OrderStatus } from '@generated/order/v1/order';
import { logger } from '@config/logger';
export class OrderRepository {
async create(order: Omit<Order, 'id' | 'createdAt' | 'updatedAt'>): Promise<Order> {
const client = await database.getClient();
try {
await client.query('BEGIN');
// Insert order
const orderResult = await client.query<Order>(
`INSERT INTO orders (
user_id, status, shipping_address,
subtotal, tax, shipping_cost, total
)
VALUES ($1, $2, $3, $4, $5, $6, $7)
RETURNING *`,
[
order.userId,
order.status,
JSON.stringify(order.shippingAddress),
order.subtotal,
order.tax,
order.shippingCost,
order.total,
]
);
const createdOrder = orderResult.rows[0];
// Insert order items
if (order.items && order.items.length > 0) {
const itemValues = order.items.map((item, index) => {
const offset = index * 6;
return `($${offset + 1}, $${offset + 2}, $${offset + 3}, $${offset + 4}, $${offset + 5}, $${offset + 6})`;
}).join(', ');
const itemParams = order.items.flatMap(item => [
createdOrder.id,
item.productId,
item.productName,
item.quantity,
item.unitPrice,
item.totalPrice,
]);
await client.query(
`INSERT INTO order_items (
order_id, product_id, product_name,
quantity, unit_price, total_price
)
VALUES ${itemValues}`,
itemParams
);
}
await client.query('COMMIT');
logger.info('Order created', { orderId: createdOrder.id });
return this.findById(createdOrder.id) as Promise<Order>;
} catch (error) {
await client.query('ROLLBACK');
logger.error('Failed to create order', { error });
throw error;
} finally {
client.release();
}
}
async findById(id: string): Promise<Order | null> {
const result = await database.query<Order>(
`SELECT o.*,
json_agg(
json_build_object(
'id', oi.id,
'product_id', oi.product_id,
'product_name', oi.product_name,
'quantity', oi.quantity,
'unit_price', oi.unit_price,
'total_price', oi.total_price
)
) as items
FROM orders o
LEFT JOIN order_items oi ON o.id = oi.order_id
WHERE o.id = $1
GROUP BY o.id`,
[id]
);
return result.length > 0 ? result[0] : null;
}
async findByUserId(
userId: string,
options: {
status?: OrderStatus;
limit?: number;
offset?: number;
} = {}
): Promise<{ orders: Order[]; total: number }> {
const { status, limit = 10, offset = 0 } = options;
let query = `
SELECT o.*,
json_agg(
json_build_object(
'id', oi.id,
'product_id', oi.product_id,
'product_name', oi.product_name,
'quantity', oi.quantity,
'unit_price', oi.unit_price,
'total_price', oi.total_price
)
) as items
FROM orders o
LEFT JOIN order_items oi ON o.id = oi.order_id
WHERE o.user_id = $1
`;
const params: any[] = [userId];
if (status) {
query += ` AND o.status = $${params.length + 1}`;
params.push(status);
}
query += ` GROUP BY o.id ORDER BY o.created_at DESC LIMIT $${params.length + 1} OFFSET $${params.length + 2}`;
params.push(limit, offset);
const [orders, countResult] = await Promise.all([
database.query<Order>(query, params),
database.query<{ count: number }>(
`SELECT COUNT(*) FROM orders WHERE user_id = $1${status ? ' AND status = $2' : ''}`,
status ? [userId, status] : [userId]
),
]);
return {
orders,
total: parseInt(countResult[0]?.count?.toString() || '0'),
};
}
async updateStatus(id: string, status: OrderStatus): Promise<Order | null> {
await database.query(
'UPDATE orders SET status = $1, updated_at = NOW() WHERE id = $2',
[status, id]
);
logger.info('Order status updated', { orderId: id, status });
return this.findById(id);
}
async cancel(id: string): Promise<Order | null> {
await database.query(
'UPDATE orders SET status = $1, updated_at = NOW() WHERE id = $2',
[OrderStatus.ORDER_STATUS_CANCELLED, id]
);
logger.info('Order cancelled', { orderId: id });
return this.findById(id);
}
} 