cetae audit logs on invoice update and sync to pw

src/controllers/invoice/invoice.controller.ts

@@ -10,9 +10,8 @@ import { FindOptions, Op } from "sequelize";
 import PwPortfolio from "../../models/pwPortfolio";
 import PwBuilding from "../../models/pwBuildings";
 import PwUnit from "../../models/pwUnits";
-import { fetchGLAccountById } from "../../shared/services/propertyware.service";
-import { formatDate } from "../../utils/dataUtils";
 import { logger } from '../../utils/logger';
+import AuditLog from "../../models/auditLogs";
 
 
 export const createInvoice = async (req: Request, res: Response) => {
@@ -24,7 +23,7 @@ export const createInvoice = async (req: Request, res: Response) => {
 
   try {
     const uploadResults = await uploadInvoice(files);
-    
+
     res.status(201).json({ message: "Files uploaded successfully, processing invoices in the background" });
 
     // Process the rest of the operations in the background
@@ -133,7 +132,7 @@ const buildInvoiceWhereClause = (filter: Record<string, any>): any => {
     }
 
     if (filter.reference_number) {
-      whereClause.reference_number = { [Op.like]: `%${filter.reference_number}%` }; 
+      whereClause.reference_number = { [Op.like]: `%${filter.reference_number}%` };
     }
 
     if (filter.invoice_date) {
@@ -191,16 +190,16 @@ export const getAllInvoices = async (req: Request, res: Response): Promise<Respo
     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',
-        'created_at'
-      ];
+      'id',
+      'invoice_date',
+      'total',
+      'amount_paid',
+      'due_date',
+      'pw_work_order_id',
+      'pw_vendor_id',
+      'uploaded_by',
+      'created_at'
+    ];
 
     const whereClause = buildInvoiceWhereClause(filter);
 
@@ -221,7 +220,8 @@ export const getAllInvoices = async (req: Request, res: Response): Promise<Respo
     }
 
     const [invoices, totalInvoices] = await Promise.all([
-      Invoice.findAll({...options,
+      Invoice.findAll({
+        ...options,
         include: [
           { model: User, 
             as: 'uploadedBy',
@@ -250,38 +250,52 @@ export const getAllInvoices = async (req: Request, res: Response): Promise<Respo
   }
 };
 
-
-
 export const getInvoiceById = async (req: Request, res: Response): Promise<Response> => {
   try {
     const { id } = req.params;
-    const invoice = await Invoice.findOne({ where : {id: id}, include: [
-      { model: InvoiceDetail }
-    ]});
+    const invoice = await Invoice.findOne({
+      where: { id: id }, include: [
+        { model: InvoiceDetail }
+      ]
+    });
 
     if (!invoice) {
       return res.status(404).json({ error: "Invoice not found" });
     }
-    
+
     const invoiceDetailsPromises = invoice.InvoiceDetails.map(async (invoiceDetails) => {
-     
+
       return {
         amount: invoiceDetails.amount,
         expenseAccount: invoiceDetails.pw_gl_account_id,
-        location: {portfolioId : invoiceDetails.pw_portfolio_id, buildingId: invoiceDetails.pw_building_id, unitId: invoiceDetails.pw_unit_id},
+        location: { portfolioId: invoiceDetails.pw_portfolio_id, buildingId: invoiceDetails.pw_building_id, unitId: invoiceDetails.pw_unit_id },
         description: invoiceDetails.description || ''
       };
     });
-    
+
     const billSplit = await Promise.all(invoiceDetailsPromises);
-    
-    return res.status(200).json({invoice: invoice.dataValues, billSplit : billSplit });
+
+    return res.status(200).json({ invoice: invoice.dataValues, billSplit: billSplit });
   } catch (error) {
     logger.error("Error fetching invoice:", error);
     return res.status(500).json({ error: "Error fetching invoice details" });
   }
 };
 
+function getUpdatedFields(original: any, updated: any): string {
+  const changes: string[] = [];
+  const skipKeys = ['InvoiceDetails', 'created_at', 'updated_at','deleted_at'];
+  for (const key in original) {
+    if (skipKeys.includes(key))
+      continue;
+    console.log(original[key] !== updated[key], key, original[key], updated[key] );
+    if (original[key] !== updated[key]) {
+      changes.push(`${key}: ${original[key]} -> ${updated[key]}`);
+    }
+  }
+  return changes.join(', ');
+}
+
 
 export const updateInvoice = async (req: Request, res: Response): Promise<Response> => {
   const { id } = req.params;
@@ -313,8 +327,18 @@ export const updateInvoice = async (req: Request, res: Response): Promise<Respon
       uploaded_by: invoice.uploaded_by,
     };
 
+    const originalInvoiceData = { ...existingInvoice.dataValues };
     const invoiceUpdate = await existingInvoice.update(updatedInvoiceData);
 
+    const updatedFields = getUpdatedFields(originalInvoiceData, invoiceUpdate.dataValues);
+    const auditLogData = {
+      invoice_id: invoice.id,
+      action_by: 1, // replace with the actual user ID performing the action
+      action: 'Update Invoice',
+      details: updatedFields
+    };
+
+    await AuditLog.create(auditLogData);
     // Delete existing InvoiceDetails
     await InvoiceDetail.destroy({ where: { invoice_id: id } });
 

src/controllers/propertyware/bills.controller.ts

@@ -24,7 +24,7 @@ export const syncInvoices = async (req: Request, res: Response) => {
         // Map the invoices to the bill request format
         invoices.forEach(async (invoice) => {
             const bill = {
-                billDate: formatDate(invoice.invoice_date), // FIXME: format invoice date 
+                billDate: formatDate(invoice.invoice_date),
                 billSplits: invoice.InvoiceDetails.map(detail => ({
                     amount: detail.amount as number,
                     glAccountID: detail.pw_gl_account_id,
@@ -34,24 +34,22 @@ export const syncInvoices = async (req: Request, res: Response) => {
                     paid: false,
                     unitID: detail.pw_unit_id
                 })),
-                dueDate: invoice.due_date ? formatDate(invoice.due_date) : null, // FIXME: format due date 
+                dueDate: invoice.due_date ? formatDate(invoice.due_date) : null, 
                 vendorID: invoice.pw_vendor_id?.toString(),
                 billNumber: invoice.invoice_number,
                 comments: invoice.description,
                 refNo: invoice.reference_number,
                 terms: invoice.term,
-                workOrderID: invoice.pw_work_order_id, // FIXME: check if work order id is valid from pwoprtyware workorders
+                workOrderID: null, // FIXME: check if work order id is valid from pwoprtyware workorders
             };
             try {
                 const response = await createBill(bill);
                 console.log(response.id);
 
                 // add audit log for Update Invoice
-                // add entry to error log
-                const auditLogData = { invoice_id: invoice.id as number, action_by: 1, action: 'Invoice sync to PW', details: `sync Successfull. PW invoice id : ${response.id}`};
-                await AuditLog.create(auditLogData);
                 
-                // add audit log
+                const auditLogData = { invoice_id: invoice.id as number, action_by: 1, action: 'Invoice sync to PW', details: `Bill for invoice ${bill.refNo} synced successfully. PW invoice id : ${response.id}`};
+                await AuditLog.create(auditLogData);
 
                 logger.info(`Bill for invoice ${bill.refNo} synced successfully`);
             } catch (error) {