check if workorder id parsed from ai sevice exists in PW

src/controllers/invoice/invoice.controller.ts

@@ -11,9 +11,9 @@ import PwPortfolio from "../../models/pwPortfolio";
 import PwBuilding from "../../models/pwBuildings";
 import PwUnit from "../../models/pwUnits";
 import { logger } from '../../utils/logger';
-import AuditLog from "../../models/auditLogs";
 import { createAuditLog } from "../auditLog.controller";
-
+import ErrorLog from "../../models/errorLog";
+import { fetchWorkorderById } from "../../shared/services/propertyware.service";
 
 export const createInvoice = async (req: Request, res: Response) => {
   const files = req.files as Express.Multer.File[];
@@ -29,101 +29,150 @@ export const createInvoice = async (req: Request, res: Response) => {
 
     // Process the rest of the operations in the background
     const createInvoicePromises = files.map(async (file, index) => {
-      const formData = new FormData();
-      formData.append("file", file.buffer, file.originalname);
-
-      // Send the file URLs to the AI service API for parsing
-      const aiServiceResponse = await parseInvoice(formData);
-      const aiServiceData = aiServiceResponse[0];
-
-      const totalAmount = aiServiceData.billSplits.reduce(
-        (total: number, split: { amount: number }) => total + split.amount,
-        0
-      );
-      const invoiceDate = new Date(aiServiceData.billDate);
-      const dueDate = new Date(aiServiceData.dueDate);
-      let invoiceRecord = {
-        reference_number: aiServiceData.refNo,
-        invoice_number: aiServiceData.billNumber,
-        vendor_name: aiServiceData.vendor_name,
-        pw_vendor_id: aiServiceData.vendor_id,
-        invoice_date: invoiceDate,
-        due_date: dueDate,
-        total: totalAmount,
-        description: aiServiceData.description,
-        status: "Pending",
-        amount_paid: 0,
-        term: aiServiceData.terms,
-        pw_work_order_id: aiServiceData.workOrderID,
-        filename: file.originalname,
-        pdf_url: (await uploadResults[index]).Location,
-        uploaded_by: 1, // TODO : replace with logged in user when user module is implemented
-      };
-
-      const result = await Invoice.create(invoiceRecord);
-
-      const invoiceDetailsPromises = aiServiceData.billSplits.map(async (details: { portfolio: any; building: any; unit: any; glAccount: any; amount: any; description: any; }) => {
-        let portfolioId = null;
-        let buildingId = null;
-        let unitId = null;
-
-        if (details.portfolio) {
-          const portfolioData = await PwPortfolio.findOne({
-            where: {
-              name: details.portfolio,
-            },
-          });
-          if (portfolioData) {
-            portfolioId = portfolioData.id;
+      try {
+        const formData = new FormData();
+        formData.append("file", file.buffer, file.originalname);
+
+
+        // Send the file URLs to the AI service API for parsing
+        const aiServiceResponse = await parseInvoice(formData);
+        const aiServiceData = aiServiceResponse[0];
+
+        console.log(aiServiceData);
+        // validate if parsed workorderID exists in propertyware workorders
+        if (aiServiceData.workOrderID){
+          try {
+            const PWWorkorderDetails = await fetchWorkorderById(aiServiceData.workOrderID);
+            console.log(PWWorkorderDetails);
+          } catch (error) {
+            console.log('workore error : ', error)
+              aiServiceData.workOrderID = null;
           }
         }
+        console.log(aiServiceData);
+
+        const totalAmount = aiServiceData.billSplits.reduce(
+          (total: number, split: { amount: number }) => total + split.amount,
+          0
+        );
+        const invoiceDate = new Date(aiServiceData.billDate);
+        const dueDate = new Date(aiServiceData.dueDate);
+        let invoiceRecord = {
+          reference_number: aiServiceData.refNo,
+          invoice_number: aiServiceData.billNumber,
+          vendor_name: aiServiceData.vendor_name,
+          pw_vendor_id: aiServiceData.vendor_id,
+          invoice_date: invoiceDate,
+          due_date: dueDate,
+          total: totalAmount,
+          description: aiServiceData.description,
+          status: "Pending",
+          amount_paid: 0,
+          term: aiServiceData.terms,
+          pw_work_order_id: aiServiceData.workOrderID,
+          filename: file.originalname,
+          pdf_url: (await uploadResults[index]).Location,
+          uploaded_by: 1, // TODO : replace with logged in user when user module is implemented
+        };
 
-        if (details.building) {
-          const buildingData = await PwBuilding.findOne({
-            where: {
-              name: details.building,
-            },
-          });
-          if (buildingData) {
-            buildingId = buildingData.id;
+        const result = await Invoice.create(invoiceRecord);
+
+        const invoiceDetailsPromises = aiServiceData.billSplits.map(async (details: { portfolio: any; building: any; unit: any; glAccount: any; amount: any; description: any; }) => {
+          let portfolioId = null;
+          let buildingId = null;
+          let unitId = null;
+
+          if (details.portfolio) {
+            const portfolioData = await PwPortfolio.findOne({
+              where: {
+                name: details.portfolio,
+              },
+            });
+            if (portfolioData) {
+              portfolioId = portfolioData.id;
+            }
           }
-        }
 
-        if (details.unit) {
-          const unitData = await PwUnit.findOne({
-            where: {
-              name: details.unit,
-            },
-          });
-          if (unitData) {
-            unitId = unitData.id;
+          if (details.building) {
+            const buildingData = await PwBuilding.findOne({
+              where: {
+                name: details.building,
+              },
+            });
+            if (buildingData) {
+              buildingId = buildingData.id;
+            }
           }
-        }
 
-        return {
-          invoice_id: result.id,
-          pw_portfolio_id: portfolioId,
-          pw_building_id: buildingId,
-          pw_unit_id: unitId,
-          pw_gl_account_id: details.glAccount,
-          amount: details.amount,
-          description: details.description,
-        };
-      });
+          if (details.unit) {
+            const unitData = await PwUnit.findOne({
+              where: {
+                name: details.unit,
+              },
+            });
+            if (unitData) {
+              unitId = unitData.id;
+            }
+          }
 
-      const invoiceDetails = await Promise.all(invoiceDetailsPromises);
-      await InvoiceDetail.bulkCreate(invoiceDetails);
+          return {
+            invoice_id: result.id,
+            pw_portfolio_id: portfolioId,
+            pw_building_id: buildingId,
+            pw_unit_id: unitId,
+            pw_gl_account_id: details.glAccount,
+            amount: details.amount,
+            description: details.description,
+          };
+        });
+
+        const invoiceDetails = await Promise.all(invoiceDetailsPromises);
+        await InvoiceDetail.bulkCreate(invoiceDetails);
+      } catch (error) {
+        if (error instanceof Error) {
+          logger.error(`Error creating invoice for file ${file.originalname}: ${error}`);
+          // Add entry to error log
+          const errorLogData = { error_type: 'Invoice Create Failed', error_details: `Error creating invoice for file ${file.originalname}: ${error.message}` };
+          await ErrorLog.create(errorLogData);
+        } else {
+          logger.error(`Unknown error creating invoice for file ${file.originalname}`, error);
+          const errorLogData = { error_type: 'Invoice Create Failed', error_details: `Unknown error creating invoice for file ${file.originalname}: ${JSON.stringify(error)}` };
+          await ErrorLog.create(errorLogData);
+        }
+      }
     });
 
-    await Promise.all(createInvoicePromises);
+    try {
+      await Promise.all(createInvoicePromises);
+      logger.info("Invoices processed successfully in the background");
+    } catch (error) {
+      if (error instanceof Error) {
+        logger.error(`Error processing invoices in the background: ${error}`);
+        const errorLogData = { error_type: 'Invoice Process Failed', error_details: `Error processing invoices in the background: ${error.message}` };
+        await ErrorLog.create(errorLogData);
+      } else {
+        logger.error('Unknown error processing invoices in the background', error);
+        const errorLogData = { error_type: 'Invoice Process Failed', error_details: `Unknown error processing invoices in the background: ${JSON.stringify(error)}` };
+        await ErrorLog.create(errorLogData);
+      }
+    }
 
-    logger.info("Invoices processed successfully in the background");
   } catch (error) {
-    logger.error("Error processing invoices in the background: ", error);
+    if (error instanceof Error) {
+      logger.error(`Error uploading invoices: ${error.message}`);
+      const errorLogData = { error_type: 'Invoice Upload Failed', error_details: `Error uploading invoices: ${error.message}` };
+      await ErrorLog.create(errorLogData);
+    } else {
+      logger.error('Unknown error uploading invoices', error);
+      const errorLogData = { error_type: 'Invoice Upload Failed', error_details: `Unknown error uploading invoices: ${JSON.stringify(error)}` };
+      await ErrorLog.create(errorLogData);
+    }
   }
 };
 
 
+
+
 const buildInvoiceWhereClause = (filter: Record<string, any>): any => {
   const whereClause: any = {};
 

src/controllers/propertyware/bills.controller.ts

@@ -4,9 +4,7 @@ import Invoice from '../../models/invoice';
 import InvoiceDetail from '../../models/invoicedetail';
 import { createBill } from '../../shared/services/propertyware.service';
 import { formatDate } from '../../utils/dataUtils';
-import AuditLog from '../../models/auditLogs';
 import ErrorLog from './../../models/errorLog';
-import { AxiosError } from 'axios';
 import { createAuditLog } from '../auditLog.controller';
 
 export const syncInvoices = async (req: Request, res: Response) => {
@@ -41,7 +39,7 @@ export const syncInvoices = async (req: Request, res: Response) => {
                 comments: invoice.description,
                 refNo: invoice.reference_number,
                 terms: invoice.term,
-                workOrderID: null, // FIXME: check if work order id is valid from pwoprtyware workorders
+                workOrderID: invoice.pw_work_order_id,
             };
             try {
                 const response = await createBill(bill);

src/models/errorLog.ts

@@ -10,9 +10,9 @@ import { ErrorLogInterface } from '../shared/interfaces/errorLog.interface';
 import Invoice from './invoice';
 
 
-class ErrorLog extends Model<InferAttributes<ErrorLog>, InferCreationAttributes<ErrorLog>>implements ErrorLogInterface {
+class ErrorLog extends Model<ErrorLogInterface>implements ErrorLogInterface {
   declare id?: CreationOptional<number>;
-  declare invoice_id: number;
+  declare invoice_id?: number;
   declare error_type: string;
   declare error_details: string;
 }
@@ -52,4 +52,4 @@ ErrorLog.init(
 
 ErrorLog.belongsTo(Invoice, { foreignKey: 'invoice_id' });
 
-export default ErrorLog
+export default ErrorLog

src/shared/interfaces/errorLog.interface.ts

@@ -1,6 +1,6 @@
 export interface ErrorLogInterface {
     id?: number,
-    invoice_id: number,
+    invoice_id?: number,
     error_type: string,
     error_details: string,
 }

src/shared/services/propertyware.service.ts

@@ -21,7 +21,7 @@ export const fetchPortfolio = async (params = []) => {
 };
 
 export const fetchPortfolioById = async (portfolioId: number) => {
-    const response = await apiClientPW.get(`/portfolios/` + portfolioId);
+    const response = await apiClientPW.get(`/portfolios/${portfolioId}`);
     return response.data;
 };
 
@@ -31,7 +31,7 @@ export const fetchBuildings = async (params: Record<string, string> = {}  ) => {
 };
 
 export const fetchBuildingsById = async (buildingId: number) => {
-    const response = await apiClientPW.get(`/portfolios/` + buildingId);
+    const response = await apiClientPW.get(`/portfolios/${buildingId}`);
     return response.data;
 };
 
@@ -41,7 +41,12 @@ export const fetchUnits = async (params: Record<string, string> = {}) => {
 };
 
 export const fetchUnitsById = async (unitId: number) => {
-    const response = await apiClientPW.get(`/units/` + unitId);
+    const response = await apiClientPW.get(`/units/${unitId}`);
+    return response.data;
+};
+
+export const fetchWorkorderById = async (workOrderID: number) => {
+    const response = await apiClientPW.get(`/workorders/${workOrderID}`);
     return response.data;
 };