add filter, sorting and pagination on list invoices

src/controllers/invoice/invoice.controller.ts

@@ -6,6 +6,7 @@ import FormData from "form-data";
 import Invoice from "../../models/invoice";
 import InvoiceDetail from "../../models/invoicedetail";
 import User from "../../models/users";
+import { FindOptions, Op } from "sequelize";
 
 export const createInvoice = async (req: Request, res: Response) => {
   const files = req.files as Express.Multer.File[];
@@ -81,20 +82,122 @@ export const createInvoice = async (req: Request, res: Response) => {
   }
 };
 
+const buildInvoiceWhereClause = (filter: Record<string, any>): any => {
+  const whereClause: any = {};
+
+  if (filter) {
+    if (filter.vendor_name) {
+      whereClause.vendor_name = { [Op.like]: `%${filter.vendor_name}%` };
+    }
+
+    if (filter.reference_number) {
+      whereClause.reference_number = { [Op.like]: `%${filter.reference_number}%` }; 
+    }
+
+    if (filter.invoice_date) {
+      const date = new Date(filter.invoice_date);
+      if (!isNaN(date.getTime())) {
+        whereClause.invoice_date = { [Op.eq]: date };
+      }
+    }
+
+    if (filter.uploaded_by) {
+      whereClause.uploaded_by = { [Op.eq]: filter.uploaded_by };
+    }
+
+    if (filter.due_date) {
+      const date = new Date(filter.due_date);
+      if (!isNaN(date.getTime())) {
+        whereClause.due_date = { [Op.eq]: date };
+      }
+    }
+
+    if (filter.payment_status) {
+      whereClause.payment_status = { [Op.eq]: filter.payment_status };
+    }
+
+    if (filter.status) {
+      whereClause.status = { [Op.eq]: filter.status };
+    }
+
+    if (filter.pw_work_order_id) {
+      whereClause.pw_work_order_id = { [Op.eq]: filter.pw_work_order_id };
+    }
+
+    if (filter.created_before) {
+      const beforeDate = new Date(filter.created_before);
+      if (!isNaN(beforeDate.getTime())) {
+        whereClause.created_at = { ...whereClause.created_at, [Op.lte]: beforeDate };
+      }
+    }
+
+    if (filter.created_after) {
+      const afterDate = new Date(filter.created_after);
+      if (!isNaN(afterDate.getTime())) {
+        whereClause.created_at = { ...whereClause.created_at, [Op.gte]: afterDate };
+      }
+    }
+  }
+
+  return whereClause;
+};
+
 // Get All Invoices
 export const getAllInvoices = async (req: Request, res: Response): Promise<Response> => {
   try {
-    const invoices = await Invoice.findAll({
+    const { sort_by, sort_order, page, limit } = req.query;
+    const filter = req.query.filter as Record<string, any>;
+
+    const allowedSortColumns = [
+        'id', 
+        'invoice_date', 
+        'total', 
+        'amount_paid', 
+        'due_date',
+        'pw_work_order_id',
+        'pw_vendor_id',
+        'uploaded_by',
+      ];
+
+    const whereClause = buildInvoiceWhereClause(filter);
+
+    const currentPage = parseInt(page as string) || 1;
+    const pageSize = parseInt(limit as string) || 10;
+
+    const options: FindOptions = {
+      where: whereClause,
+      limit: pageSize,
+      offset: (currentPage - 1) * pageSize,
+      order: []
+    };
+
+    if (sort_by && allowedSortColumns.includes(sort_by as string)) {
+      options.order = [[sort_by as string, sort_order === 'desc' ? 'DESC' : 'ASC']];
+    } else {
+      options.order = [['id', 'ASC']];
+    }
+
+    const [invoices, totalInvoices] = await Promise.all([
+      Invoice.findAll({...options,
         include: [
           { model: User, as: 'uploadedBy' }
         ]
-      });
+      }),
+      Invoice.count({ where: whereClause }),
+    ]);
+
+    const data = {
+      page: currentPage,
+      limit: pageSize,
+      total: totalInvoices,
+      invoices: invoices
+    };
 
     if (invoices.length === 0) {
       return res.status(404).json({ error: "No invoices found" });
     }
 
-    return res.status(200).json(invoices);
+    return res.status(200).json(data);
   } catch (error) {
     console.error("Error fetching invoices:", error);
     return res.status(500).json({ error: "Error fetching invoices" });