#8641 - sync workorders from json url, remove sync from PW api

.env.example

@@ -36,4 +36,5 @@ SMTP_SENDER_EMAIL=
 FRONTEND_URL=
 
 CRON_SCHEDULE="0 0 * * *"
-SYNC_INVOICES=true
+SYNC_INVOICES=true
+PW_FETCH_ALL_WORKORDERS=

src/config/app.config.ts

@@ -23,3 +23,10 @@ export const SMTP_CONFIG = {
   SECURE: process.env.SMTP_SECURE,
   SENDER: process.env.SMTP_SENDER_EMAIL,
 };
+
+
+export const PW_CONFIG= {
+  PW_FETCH_ALL_UNITS:process.env.PW_FETCH_ALL_UNITS || '',
+  PW_FETCH_ALL_WORKORDERS:process.env.PW_FETCH_ALL_WORKORDERS || '',
+  PW_FETCH_LATEST_WORKORDERS:process.env.PW_FETCH_LATEST_WORKORDERS || ''
+};

src/controllers/propertyware/workorders.controller.ts

@@ -1,6 +1,6 @@
 import { Request, Response } from 'express';
 import { logger } from '../../utils/logger';
-import { syncWorkOrderDataService } from '../../shared/services/workorder.service';
+import { syncWorkOrderDataFromJsonService, syncWorkOrderDataService } from '../../shared/services/workorder.service';
 import PwWorkOrders from '../../models/pwWorkOrders';
 
 export const fetchWorkorders = async (req: Request, res: Response) => {
@@ -27,9 +27,10 @@ export const fetchWorkorders = async (req: Request, res: Response) => {
 
 export const syncWorkOrders = async (req: Request, res: Response) => {
     try {
-        const result = await syncWorkOrderDataService();
+        const syncAll = true;
+        const result = await syncWorkOrderDataFromJsonService(syncAll);
         res.status(200).send(result);
     } catch (error) {
         res.status(500).send((error as Error).message);
     }
-};
+};

src/shared/interfaces/pwWorkOrdersInterface.ts

@@ -8,4 +8,17 @@ export interface PwWorkOrdersInterface {
     unit_id: number;
     status: string;
     assigned_vendors: string[];
-}
+}
+
+export interface Column {
+    index: string;
+    dataType: string;
+    label: string;
+  }
+  
+export interface DataStructure {
+    totalCount: number;
+    columns: Column[];
+    records: any[];
+  }
+  

src/shared/services/cronJobs.ts

@@ -2,7 +2,7 @@ import cron from 'node-cron';
 import { logger } from '../../utils/logger';
 import { syncInvoicesService } from './bills.service';
 import { syncUnitsDataFromUrlService } from './units.service';
-import { syncWorkOrderDataService } from './workorder.service';
+import { syncWorkOrderDataFromJsonService } from './workorder.service';
 
 const CRON_SCHEDULE = process.env.CRON_SCHEDULE || '0 0 * * *';
 const SYNC_INVOICES = process.env.SYNC_INVOICES;
@@ -28,7 +28,7 @@ export const setupCronJobs = () => {
             await syncUnitsDataFromUrlService();
             logger.info('Scheduled properties sync completed successfully');
 
-            await syncWorkOrderDataService();
+            await syncWorkOrderDataFromJsonService();
             logger.info('Scheduled work order sync completed successfully');
             
             if (SYNC_INVOICES === "true") {

src/shared/services/propertyware.service.ts

@@ -1,3 +1,5 @@
+import { Column, DataStructure } from "shared/interfaces/pwWorkOrdersInterface";
+import { PW_CONFIG } from "../../config/app.config";
 import { apiClientPW } from "./api.service";
 import axios from 'axios';
 
@@ -81,9 +83,23 @@ export const fetchAllWorkorders = async () => {
 };
 
 
-export const fetchUnitsJson = async (params: Record<string, string> = {}) => {
-    const url = 'https://app.propertyware.com/pw/00a/3861938176/JSON?2kTLuin&shardKey=6848514';
-    const response = await axios.get(url);
+export const fetchUnitsJson = async () => {
+    const response = await axios.get(PW_CONFIG.PW_FETCH_ALL_UNITS);
     return response.data;
 };
 
+export const fetchAllWorkordersJson = async () => {
+    const response = await axios.get(PW_CONFIG.PW_FETCH_ALL_WORKORDERS);
+    return response.data;
+};
+
+export const fetchLatestWorkordersJson = async () => {
+    const response = await axios.get(PW_CONFIG.PW_FETCH_LATEST_WORKORDERS);
+    return response.data;
+};
+
+export const getIndexByLabel = (data: Column[], label: string): number | undefined => {
+    const column = data.find((col) => col.label === label);
+    return column ? parseInt(column.index) : undefined;
+  };
+  

src/shared/services/units.service.ts

@@ -46,10 +46,10 @@ export const syncUnitsDataFromUrlService = async (): Promise<string> => {
             });
 
             unitsBulkData.push({
-                pw_id: record['8'],  // Unit ID Number
+                pw_id: record['9'],  // Unit Entity ID
                 name: record['1'],   // Unit Name
                 pw_portfolio_id: record['10'], // Portfolio ID
-                pw_building_id: record['7'], // Building ID
+                pw_building_id: record['7'], // Building ID Number
             });
         }
 

src/shared/services/workorder.service.ts

@@ -1,6 +1,7 @@
-import { fetchAllWorkorders, } from './propertyware.service';
+import { fetchAllWorkorders, fetchAllWorkordersJson, fetchLatestWorkordersJson, getIndexByLabel } from './propertyware.service';
 import { logger } from '../../utils/logger';
 import PwWorkOrders from '../../models/pwWorkOrders';
+import PwUnit from '../../models/pwUnits';
 
 export const syncWorkOrderDataService = async (): Promise<string> => {
     try {
@@ -35,4 +36,63 @@ export const syncWorkOrderDataService = async (): Promise<string> => {
         logger.error("Error syncing Work order: ", error);
         throw new Error("Error syncing Work order");
     }
-};
+};
+
+export const syncWorkOrderDataFromJsonService = async (syncAll = false): Promise<string> => {
+    try {
+        let workOrderData;
+        if (syncAll) {
+            workOrderData = await fetchAllWorkordersJson();
+        } else {
+            workOrderData = await fetchLatestWorkordersJson();
+        }
+        const indexes = {
+            pw_id: getIndexByLabel(workOrderData.columns, "WO Entity ID"),
+            number:getIndexByLabel(workOrderData.columns, "WO#"),
+            portfolio: getIndexByLabel(workOrderData.columns, "Portfolio"),
+            building: getIndexByLabel(workOrderData.columns, "Building"),
+            unit: getIndexByLabel(workOrderData.columns, "Unit"),
+            buildingID: getIndexByLabel(workOrderData.columns, "Building ID"),
+            unitID: getIndexByLabel(workOrderData.columns, "Unit ID"),
+            status: getIndexByLabel(workOrderData.columns, "Status"),
+            assignedVendors: getIndexByLabel(workOrderData.columns, "Vendors"),
+        };
+        const workOrderResponseData: any[] = [];
+
+        for (const record of workOrderData.records) {
+            const portfolioData = await PwUnit.findOne({
+                where: {
+                  pw_id: record[indexes.unitID as number], 
+                },
+                attributes: ['pw_portfolio_id'], 
+              });
+          
+            const portfolio_id= portfolioData ? portfolioData.getDataValue('pw_portfolio_id') : null;
+            workOrderResponseData.push({
+                pw_id: record[indexes.pw_id as number],
+                number: extractWorkOrderNumber(record[indexes.number as number]),
+                portfolio_id: portfolio_id,
+                building_id: record[indexes.buildingID as number],
+                unit_id: record[indexes.unitID as number],
+                location: record[indexes.portfolio as number] + " " + record[indexes.building as number] + " " + record[indexes.unit as number],
+                status: record[indexes.status as number],
+                assigned_vendors: record[indexes.assignedVendors as number] || []
+            });
+        }
+        await PwWorkOrders.bulkCreate(workOrderResponseData, {
+            updateOnDuplicate: ['number', 'location', 'portfolio_id', 'building_id', 'unit_id', 'status', 'assigned_vendors'],
+        });
+
+        logger.info("Total " + workOrderResponseData.length + "Work orders synced successfully");
+        return "Total " + workOrderResponseData.length + "Work orders synced successfully";
+    } catch (error) {
+        console.log(error);
+        logger.error("Error syncing Work order: ", error);
+        throw new Error("Error syncing Work order");
+    }
+};
+
+const extractWorkOrderNumber = (workOrder: string): string | null => {
+    const match = workOrder.match(/#(\d+)/); // Matches "#" followed by one or more digits
+    return match ? match[1] : null;
+}