show invoice based on user role

src/controllers/invoice/invoice.controller.ts

@@ -12,7 +12,7 @@ import PwBuilding from "../../models/pwBuildings";
 import PwUnit from "../../models/pwUnits";
 import { logger } from '../../utils/logger';
 import ErrorLog from "../../models/errorLog";
-import { fetchWorkorderById } from "../../shared/services/propertyware.service";
+import { fetchBuildingPropertyManager, fetchWorkorderById } from "../../shared/services/propertyware.service";
 import { logInvoiceAction } from "../invoiceActivityLogs.controller";
 import InvoiceApproval from "../../models/invoiceApproval";
 import Role from "../../models/roles";
@@ -273,11 +273,13 @@ const buildInvoiceWhereClause = (filter: Record<string, any>): any => {
 };
 
 // Get All Invoices
-export const getAllInvoices = async (req: Request, res: Response): Promise<Response> => {
+export const getAllInvoices = async (req: AuthenticatedRequest, res: Response): Promise<Response> => {
   try {
     const { sort_by, sort_order, page, limit } = req.query;
     const filter = req.query.filter as Record<string, any>;
 
+    const roleData = await Role.findByPk(req.user?.role_id);
+
     const allowedSortColumns = [
       'id',
       'invoice_date',
@@ -311,29 +313,60 @@ export const getAllInvoices = async (req: Request, res: Response): Promise<Respo
       options.order = [['id', 'ASC']];
     }
 
-    const [invoices, totalInvoices] = await Promise.all([
-      Invoice.findAll({
-        ...options,
-        include: [
-          {
-            model: User,
-            as: 'uploadedBy',
-            attributes: { exclude: ['password'] }
-          },
-        ]
-      }),
-      Invoice.count({ where: whereClause }),
-    ]);
+    let invoices:any = await Invoice.findAll({
+      ...options,
+      include: [
+        {
+          model: User,
+          as: 'uploadedBy',
+          attributes: { exclude: ['password'] }
+        },
+        {
+          model: InvoiceDetail,
+          as: 'InvoiceDetails',
+        }
+      ]
+    });
+
+    if (roleData?.name === "Property Manager") {
+      const propertyManagerEmail = req?.user?.email;
+      invoices = await Promise.all(
+        invoices.map(async (invoice: any) => {
+          const invoiceDetails = invoice.InvoiceDetails || [];
+          for (const detail of invoiceDetails) {
+            if (detail.pw_building_id) {
+              const buildingManagers = await fetchBuildingPropertyManager(detail.pw_building_id);
+              if (buildingManagers.some((manager: any) => manager.email === propertyManagerEmail)) {
+                return invoice;
+              }
+            }
+          }
+          return null;
+        })
+      );
+      invoices = invoices.filter((invoice: any) => invoice !== null);
+    } else if (roleData?.name === "Accountant") {
+      invoices = invoices.filter((invoice: any) => {
+        const hasInvoiceDetails = invoice.InvoiceDetails && invoice.InvoiceDetails.length > 0;
+        return !hasInvoiceDetails;
+      });
+    }
+
+
+    const totalInvoices = invoices.length;
+
+    const paginatedInvoices = invoices.slice((currentPage - 1) * pageSize, currentPage * pageSize);
 
     const responseData = {
       page: currentPage,
       limit: pageSize,
       total: totalInvoices,
-      data: invoices
+      data: paginatedInvoices
     };
 
     return res.status(200).json(responseData);
   } catch (error) {
+    console.log("error-", error)
     logger.error("Error fetching invoices:", error);
     return res.status(500).json({ error: "Error fetching invoices" });
   }