[deliver #187584937] buyer track order status

README.md

@@ -71,6 +71,7 @@ Our e-commerce web application server, developed by Team Ninjas, facilitates smo
 - Submit a seller request
 - Buyer track order status Endpoint
 - Admin update order status EndPoint 
+- Buyer get order history Endpoint
 
 ## TABLE OF API ENDPOINTS SPECIFICATION AND DESCRIPTION
 
@@ -122,8 +123,9 @@ Our e-commerce web application server, developed by Team Ninjas, facilitates smo
 | 44  | PUT    | /api/user/user-mark-notification/:id                  | 200 OK      | private | user mark notification              |
 | 45  | POST   | /api/shop/buyer-review-product/:id                    | 200 OK      | private | Buyer Create review                 |
 | 46  | POST   | /api/user/user-submit-seller-request                  | 200 OK      | private | Submit a seller request             |
-| 46  | POST   | /api/cart/user-get-order-status/           | 200 OK      | private | user get order status               |
-| 47  |  PUT   | /api/cart/admin-update-order-status/:id    | 200 OK      | private | admin update order status           |
+| 47  | GET    | /api/cart/user-get-order-status/:id        | 200 OK      | private | user get order status               |
+| 48  | GET    | /api/cart/buyer-get-order-history          | 200 OK      | private | buyer get order history              |
+| 49  |  PUT   | /api/cart/admin-update-order-status/:id    | 200 OK      | private | admin update order status           | 
 
 
 ## INSTALLATION

package.json

@@ -46,7 +46,6 @@
       "src/services/stripe.ts",
       "src/services/cronJob.ts",
       "src/helpers/passwordExpiryNotifications.ts"
-
     ],
     "reporter": [
       "html",
@@ -135,4 +134,4 @@
     "eslint-plugin-import": "^2.29.1",
     "lint-staged": "^15.2.2"
   }
-}
+}

src/databases/migrations/20240604150804-create-orders.ts

@@ -46,6 +46,14 @@ export = {
         type: DataTypes.STRING,
         allowNull: false
       },
+      shippingProcess: {
+        type: DataTypes.STRING,
+        allowNull: false
+      },
+      expectedDeliveryDate:{
+        type:DataTypes.DATE,
+        allowNull: false
+      },
       createdAt: {
         type: DataTypes.DATE,
         allowNull: false,

src/databases/models/carts.ts

@@ -26,7 +26,7 @@ class Carts extends Model<CartAttributes> implements CartAttributes {
     static associate() {
         Carts.belongsTo(Users, { foreignKey: "userId", as: "buyer" });
         Carts.hasMany(CartProducts, { foreignKey: "cartId", as: "cartProducts" });
-        Carts.hasMany(Orders,{foreignKey: "cartId", as: "order"})
+        Carts.hasMany(Orders,{foreignKey: "cartId", as: "orders"})
     }
 }
 

src/databases/models/orders.ts

@@ -14,6 +14,8 @@ export interface OrderAttributes {
     paymentMethodId: string;
     orderDate: Date;
     status: string;
+    shippingProcess: string;
+    expectedDeliveryDate: Date
     createdAt: Date;
     updatedAt: Date;
 }
@@ -26,6 +28,8 @@ class Orders extends Model<OrderAttributes> implements OrderAttributes {
     declare paymentMethodId: string;
     declare orderDate: Date;
     declare status: string;
+    declare shippingProcess: string;
+    declare expectedDeliveryDate: Date;
     declare createdAt: Date;
     declare updatedAt: Date;
 
@@ -68,6 +72,14 @@ Orders.init(
             type: new DataTypes.STRING,
             allowNull: false
         },
+        shippingProcess: {
+            type: DataTypes.STRING,
+            allowNull: false
+          },
+        expectedDeliveryDate:{
+            type:DataTypes.DATE,
+            allowNull: false
+        },
         createdAt: {
             field: "createdAt",
             type: DataTypes.DATE,

src/databases/seeders/20240604133044-orders.ts

@@ -22,6 +22,8 @@ module.exports = {
         paymentMethodId: 1,
         orderDate: new Date("2024-01-01"),
         status: "completed",
+        shippingProcess : "your order have been completed",
+        expectedDeliveryDate: new Date("2024-08-01"),
         createdAt: new Date(),
         updatedAt: new Date()
       },
@@ -42,6 +44,8 @@ module.exports = {
         paymentMethodId: 2,
         orderDate: new Date("2024-01-15"),
         status: "completed",
+        shippingProcess : "your order have reached Kigali in 30 minutes it will be reached to you",
+        expectedDeliveryDate: new Date("2024-08-05"),
         createdAt: new Date(),
         updatedAt: new Date()
       }

src/helpers/notifications.ts

@@ -83,13 +83,13 @@ eventEmitter.on("passwordExpiry", async ({ userId, message }) => {
   await saveAndEmitNotification(userId, message, "passwordExpiry");
 });
 
-eventEmitter.on('orderStatusUpdated', async (order) => {
+eventEmitter.on("orderStatusUpdated", async (order) => {
   const orderStatus = await fetchOrderWithCarts(order.id)
   const userId = orderStatus.carts.userId
-  const message = `The order that was created on ${order.orderDate} status has been updated to ${order.status}.`;
+  const message = order.shippingProcess;
   await userRepositories.addNotification(userId, message);
   await sendEmailOrderStatus(userId, message);
-  io.to(userId).emit('orderStatusUpdated', message)
+  io.to(userId).emit("orderStatusUpdated", message)
 });
 
 cron.schedule("0 0 * * *", async () => {

src/middlewares/validation.ts

@@ -893,6 +893,50 @@ const isSellerRequestExist = async (req: Request, res: Response, next: NextFunct
   }
 };
 
+const isOrderExist = async (req: Request, res:Response, next:NextFunction)=>{
+  try{
+    let order: any;
+    if (req.user.role === "buyer") {
+    if(req.params.id){
+      order = await cartRepositories.getOrderByOrderIdAndUserId(req.params.id, req.user.id)
+      if(!order){
+        return res.status(httpStatus.NOT_FOUND).json({
+          status: httpStatus.NOT_FOUND,
+          error: "order not found"
+        })
+      }
+    }else{
+        order = await cartRepositories.getOrdersByUserId(req.user.id)
+        if(!order.orders || order.orders.length === 0){
+          return res.status(httpStatus.NOT_FOUND).json({
+            status: httpStatus.NOT_FOUND,
+            error: "orders not found"
+          })
+        }
+      }
+
+    }
+      if(req.user.role === "admin"){
+        order = await cartRepositories.getOrderById(req.params.id)
+        if (!order) {
+          return res.status(httpStatus.NOT_FOUND).json({
+            status: httpStatus.NOT_FOUND,
+            error: "order Not Found",
+          });
+        }
+      }
+      (req as any).order = order
+      return next();
+    }
+    catch(error){
+      return res.status(httpStatus.INTERNAL_SERVER_ERROR).json({
+        status: httpStatus.INTERNAL_SERVER_ERROR,
+        error: error.message
+      })
+    }
+}
+
+
 export {
   validation,
   isUserExist,
@@ -924,5 +968,6 @@ export {
   isProductExistIntoWishList,
   isProductOrdered,
   isUserProfileComplete,
-  isSellerRequestExist
-};      
+  isSellerRequestExist,
+  isOrderExist
+};    

src/modules/cart/controller/cartControllers.ts

@@ -348,6 +348,56 @@ const paymentCanceled = (req: Request, res: Response) => {
   }
 };
 
+const buyerGetOrderStatus = async (req: ExtendRequest, res: Response) => {
+  try {
+    const order = req.order.shippingProcess
+    return res.status(httpStatus.OK).json({
+      message: "Order Status found successfully",
+      data: {order}
+    })
+
+  } catch (error) {
+    return res.status(httpStatus.INTERNAL_SERVER_ERROR).json({
+      status: httpStatus.INTERNAL_SERVER_ERROR,
+      error: error.message
+    })
+  }
+}
+
+const buyerGetOrders = async(req:ExtendRequest, res:Response)=>{
+  try{
+    const orders = req.order
+    return res.status(httpStatus.OK).json({
+      message: "Orders found successfully",
+      data: {orders}
+    })
+  }
+  catch(error){
+    return res.status(httpStatus.INTERNAL_SERVER_ERROR).json({
+      status: httpStatus.INTERNAL_SERVER_ERROR,
+      error: error.message
+    })
+  }
+}
+
+const adminUpdateOrderStatus = async (req: ExtendRequest, res: Response) => {
+  try {
+    const order = req.order
+    await cartRepositories.updateOrderStatus(req.params.id, req.body.status,req.body.shippingProcess);
+    eventEmitter.emit("orderStatusUpdated", order);
+    return res.status(httpStatus.OK).json({
+      message: "Status updated successfully!",
+      data: { order }
+    })
+  }catch(error){
+    return res.status(httpStatus.INTERNAL_SERVER_ERROR).json({
+      status: httpStatus.INTERNAL_SERVER_ERROR,
+      error: error.message
+    })
+  }
+
+}
+
 export {
   buyerGetCart,
   buyerGetCarts,
@@ -364,5 +414,6 @@ export {
   paymentCanceled,
   addProductToExistingCart,
   buyerGetOrderStatus,
+  buyerGetOrders,
   adminUpdateOrderStatus
 };

src/modules/cart/repositories/cartRepositories.ts

@@ -135,6 +135,47 @@ const saveOrder = async(lineItems: any, shopIds: any, productIds: any, session:
 return await db.Orders.create(order)
 }
 
+const getOrderByOrderIdAndUserId = async (orderId: string, userId: string) => {
+  return await db.Orders.findOne({
+    where: { id: orderId },
+    include: [
+      {
+        model: db.Carts,
+        as: "carts",
+        where: { userId: userId }
+      }
+    ]
+  })
+}
+
+const getOrderById = async (orderId: string) => {
+  return await db.Orders.findOne({ where: { id: orderId } })
+}
+
+const updateOrderStatus = async (orderId: string, status: string, shippingProcess: string) => {
+  return await db.Orders.update(
+    {
+      status: status,
+      shippingProcess: shippingProcess
+    },
+    { where: { id: orderId } }
+  );
+};
+const getOrdersByUserId = async (userId: string) => {
+  return await db.Carts.findOne(
+    {
+      where:
+        { userId: userId },
+      include: [
+        {
+          model: db.Orders,
+          as: "orders",
+        }
+      ]
+    });
+};
+
+
 export default {
   getCartsByUserId,
   getCartProductsByCartId,
@@ -154,5 +195,9 @@ export default {
   findCartProductByCartId,
   findCartIdbyUserId,
   findProductById,
-  saveOrder
+  saveOrder,
+  getOrderByOrderIdAndUserId,
+  getOrderById,
+  getOrdersByUserId,
+  updateOrderStatus
 };