OM-489: Módulo delivery completo (entregas, asignaciones, reseñas)

prisma/migrations/20260428223931_add_delivered_to_assignment_status/migration.sql

@@ -0,0 +1,2 @@
+-- AlterEnum
+ALTER TYPE "AssignmentStatus" ADD VALUE 'DELIVERED';

prisma/schema.prisma

@@ -398,6 +398,7 @@ enum AssignmentStatus {
   PENDING
   ACCEPTED
   REJECTED
+  DELIVERED
 }
 
 //------------------------------------PEDIDOS----------------------------------------

src/app.js

@@ -1,3 +1,4 @@
+//app.js
 import { validateEnv } from './config/env.config.js'
 validateEnv() // Si falta algo, el servidor no arranca
 import express from "express";
@@ -17,7 +18,8 @@ import userRoutes from "./modules/users/users/routes/users.routes.js";
 import addressRoutes from "./modules/users/addresses/routes/addresses.routes.js";
 import sessionRoutes from "./modules/session/routes/session.routes.js";
 import userProductReviewRoutes from "./modules/users/product-review/product-review.routes.js";
-import deliveryRoutes from "./modules/deliveries/delivery.routes.js";
+import deliveryRoutes from "./modules/delivery/delivery/delivery.routes.js";
+import assignmentRoutes from "./modules/delivery/delivery-assignments/delivery-assignments.routes.js";
 
 import productReportRoutes from "./modules/global/reports/product/product-report.routes.js";
 import reviewReportRoutes from "./modules/global/reports/review/review-report.routes.js";
@@ -89,9 +91,13 @@ app.use("/api/users", addressRoutes);
 app.use("/api/users", wishlistRoutes);
 app.use("/api/users", cartRoutes);
 app.use("/api/users", userOrderRouter);
-app.use("/api/deliveries", deliveryRoutes);
 app.use('/api/session', sessionRoutes);
 
+// Rutas de deliveries
+app.use("/api/deliveries", deliveryRoutes);
+app.use("/api/assignments", assignmentRoutes);
+
+
 // Rutas de pedidos
 app.use("/api/orders", orderRouter);
 

src/modules/delivery/delivery-assignments/delivery-assignments.controller.js

@@ -0,0 +1,166 @@
+//delivery.assignments.controller.js
+import { ZodError } from 'zod';
+import { createAssignmentSchema } from './delivery-assignments.validation.js';
+import {
+  createAssignmentService,
+  getAssignmentByIdService,
+  getOrderAssignmentsService,
+  getDeliveryAssignmentsService,
+  getDeliveryPendingAssignmentsService,
+  getAcceptedAssignmentService,
+  completeAssignmentService
+} from './delivery-assignments.service.js';
+
+// Crear asignación
+export const createAssignment = async (req, res) => {
+  try {
+    const validData = createAssignmentSchema.parse(req.body);
+    const result = await createAssignmentService(validData);
+    res.status(201).json(result);
+  } catch (error) {
+    if (error instanceof ZodError) {
+      return res.status(400).json({
+        error: { code: 400, message: "Datos inválidos", details: error.issues }
+      });
+    }
+    return res.status(error.status || 500).json({
+      error: { code: error.status || 500, message: error.message }
+    });
+  }
+};
+
+// Obtener asignación por ID
+export const getAssignmentById = async (req, res) => {
+  try {
+    const { id } = req.params;
+
+    const assignmentId = Number.parseInt(id, 10);
+    if (Number.isNaN(assignmentId)) {
+      return res.status(400).json({
+        error: { code: 400, message: "ID inválido" }
+      });
+    }
+
+    const result = await getAssignmentByIdService(assignmentId);
+    res.json(result);
+  } catch (error) {
+    return res.status(error.status || 500).json({
+      error: { code: error.status || 500, message: error.message }
+    });
+  }
+};
+
+// Obtener asignaciones de un pedido
+export const getOrderAssignments = async (req, res) => {
+  try {
+    const { orderId } = req.params;
+
+    const orderIdNum = Number.parseInt(orderId, 10);
+    if (Number.isNaN(orderIdNum)) {
+      return res.status(400).json({
+        error: { code: 400, message: "ID inválido" }
+      });
+    }
+
+    const result = await getOrderAssignmentsService(orderIdNum);
+    res.json(result);
+  } catch (error) {
+    return res.status(error.status || 500).json({
+      error: { code: error.status || 500, message: error.message }
+    });
+  }
+};
+
+// Obtener asignaciones de un delivery
+export const getDeliveryAssignments = async (req, res) => {
+  try {
+    const { deliveryId } = req.params;
+    const { status } = req.query;
+
+    const deliveryIdNum = Number.parseInt(deliveryId, 10);
+    if (Number.isNaN(deliveryIdNum)) {
+      return res.status(400).json({
+        error: { code: 400, message: "ID inválido" }
+      });
+    }
+
+    // Validar status contra enum
+    const validStatuses = ["PENDING", "ACCEPTED", "REJECTED", "DELIVERED"];
+    if (status && !validStatuses.includes(status)) {
+      return res.status(400).json({
+        error: { code: 400, message: `Status inválido. Debe ser uno de: ${validStatuses.join(", ")}` }
+      });
+    }
+
+    const result = await getDeliveryAssignmentsService(deliveryIdNum, status || null);
+    res.json(result);
+  } catch (error) {
+    return res.status(error.status || 500).json({
+      error: { code: error.status || 500, message: error.message }
+    });
+  }
+};
+
+// Obtener asignaciones PENDING de un delivery
+export const getDeliveryPendingAssignments = async (req, res) => {
+  try {
+    const { deliveryId } = req.params;
+
+    const deliveryIdNum = Number.parseInt(deliveryId, 10);
+    if (Number.isNaN(deliveryIdNum)) {
+      return res.status(400).json({
+        error: { code: 400, message: "ID inválido" }
+      });
+    }
+
+    const result = await getDeliveryPendingAssignmentsService(deliveryIdNum);
+    res.json(result);
+  } catch (error) {
+    return res.status(error.status || 500).json({
+      error: { code: error.status || 500, message: error.message }
+    });
+  }
+};
+
+// Obtener la asignación aceptada de un pedido
+export const getAcceptedAssignment = async (req, res) => {
+  try {
+    const { orderId } = req.params;
+
+    const orderIdNum = Number.parseInt(orderId, 10);
+    if (Number.isNaN(orderIdNum)) {
+      return res.status(400).json({
+        error: { code: 400, message: "ID inválido" }
+      });
+    }
+
+    const result = await getAcceptedAssignmentService(orderIdNum);
+    res.json(result);
+  } catch (error) {
+    return res.status(error.status || 500).json({
+      error: { code: error.status || 500, message: error.message }
+    });
+  }
+};
+
+// Completar asignación (marcar como entregado)
+export const completeAssignment = async (req, res) => {
+  try {
+    const { id } = req.params;
+
+    const assignmentId = Number.parseInt(id, 10);
+    if (Number.isNaN(assignmentId)) {
+      return res.status(400).json({
+        error: { code: 400, message: "ID inválido" }
+      });
+    }
+
+    // Pasar id_user autenticado al service
+    const result = await completeAssignmentService(assignmentId, req.user.id_user);
+    res.json(result);
+  } catch (error) {
+    return res.status(error.status || 500).json({
+      error: { code: error.status || 500, message: error.message }
+    });
+  }
+};