create workorders migration with sync api

src/controllers/propertyware/workorders.controller.ts

@@ -2,6 +2,7 @@ import { Request, Response } from 'express';
 
 import { fetchAllWorkorders } from '../../shared/services/propertyware.service';
 import { logger } from '../../utils/logger';
+import PwWorkOrders from '../../models/pwWorkOrders';
 
 export const fetchWorkorders = async (req: Request, res: Response) => {
     try {
@@ -28,3 +29,45 @@ export const fetchWorkorders = async (req: Request, res: Response) => {
         res.status(500).json({ error: 'Error fetching Workorders' });
     }
 };
+
+
+export const syncWorkOrders = async (req: Request, res: Response) => {
+    try {
+        const workOrderData = await fetchAllWorkorders();
+
+        const workOrderResponseData = workOrderData.map((workOrder: {
+            id: number;
+            number: number;
+            location: string;
+            portfolioID: number;
+            buildingID: number;
+            unitID: number;
+            status: string;
+            assignedVendors: string[];
+        }) => ({
+            pw_id: workOrder.id,
+            number: workOrder.number,
+            location: workOrder.location,
+            portfolio_id: workOrder.portfolioID,
+            building_id: workOrder.buildingID,
+            unit_id: workOrder.unitID,
+            status: workOrder.status,
+            assignedVendors: workOrder.assignedVendors || [],
+        }));
+
+        try {
+            const createResult = await PwWorkOrders.bulkCreate(workOrderResponseData, {
+                updateOnDuplicate: ['number', 'location', 'portfolio_id', 'building_id', 'unit_id', 'status', 'assigned_vendors'],
+            });
+
+            res.end("Work orders synced successfully");
+        } catch (error) {
+            logger.error("Error inserting Work Orders: ", error);
+            res.status(500).end("Error inserting Work Orders");
+        }
+
+    } catch (error) {
+        logger.error("Error fetching Work Orders: ", error);
+        res.status(500).end("Error fetching Work Orders");
+    }
+};

src/db/migrations/20240927063731-create-pw-workorders-table.js

@@ -0,0 +1,59 @@
+'use strict';
+
+/** @type {import('sequelize-cli').Migration} */
+module.exports = {
+    async up(queryInterface, Sequelize) {
+        await queryInterface.createTable('pw_workorders', {
+            id: {
+                allowNull: false,
+                autoIncrement: true,
+                primaryKey: true,
+                type: Sequelize.INTEGER,
+            },
+            pw_id: {
+                allowNull: false,
+                type: Sequelize.BIGINT,
+            },
+            number: {
+                allowNull: false,
+                type: Sequelize.INTEGER,
+            },
+            location: {
+                allowNull: false,
+                type: Sequelize.STRING,
+            },
+            portfolio_id: {
+                allowNull: false,
+                type: Sequelize.BIGINT,
+            },
+            building_id: {
+                allowNull: false,
+                type: Sequelize.BIGINT,
+            },
+            unit_id: {
+                allowNull: false,
+                type: Sequelize.BIGINT,
+            },
+            status: {
+                allowNull: false,
+                type: Sequelize.STRING,
+            },
+            assigned_vendors: {
+                allowNull: true,
+                type: Sequelize.JSON,
+            },
+            created_at: {
+                allowNull: false,
+                type: Sequelize.DATE,
+            },
+            updated_at: {
+                allowNull: false,
+                type: Sequelize.DATE,
+            },
+        });
+    },
+
+    async down(queryInterface, Sequelize) {
+        await queryInterface.dropTable('pw_workorders');
+    }
+};

src/models/pwWorkOrders.ts

@@ -0,0 +1,74 @@
+import {
+    DataTypes,
+    Model,
+    CreationOptional
+} from 'sequelize';
+import { sequelize } from './index';
+import { PwWorkOrdersInterface } from '../shared/interfaces/pwWorkOrdersInterface';
+
+class PwWorkOrders extends Model<PwWorkOrdersInterface> implements PwWorkOrdersInterface
+{
+  declare id: CreationOptional<number>;
+  declare pw_id: number;
+  declare number: number;
+  declare location: string;
+  declare portfolio_id: number;
+  declare building_id: number;
+  declare unit_id: number;
+  declare status: string;
+  declare assigned_vendors: string[];
+}
+
+PwWorkOrders.init(
+  {
+    id: {
+      type: DataTypes.BIGINT.UNSIGNED,
+      autoIncrement: true,
+      primaryKey: true,
+      unique: true,
+    },
+    pw_id: {
+      type: DataTypes.BIGINT,
+      allowNull: false,
+    },
+    number: {
+      type: DataTypes.BIGINT,
+      allowNull: false,
+    },
+    location: {
+      type: DataTypes.STRING,
+      allowNull: false,
+    },
+    portfolio_id: {
+      type: DataTypes.BIGINT,
+      allowNull: false,
+    },
+    building_id: {
+      type: DataTypes.BIGINT,
+      allowNull: false,
+    },
+    unit_id: {
+      type: DataTypes.BIGINT,
+      allowNull: false,
+    },
+    status: {
+      type: DataTypes.STRING,
+      allowNull: false,
+    },
+    assigned_vendors: {
+      type: DataTypes.JSON,
+      allowNull: true,
+    },
+  },
+  {
+    sequelize,
+    tableName: 'pw_workorders',
+    underscored: true,
+    freezeTableName: true,
+    timestamps: true,
+    createdAt: 'created_at',
+    updatedAt: 'updated_at',
+  }
+);
+
+export default PwWorkOrders;

src/routes/propertyware.routes.ts

@@ -7,7 +7,7 @@ import { LocationLookup, syncUnitsData } from "../controllers/propertyware/units
 import { fetchVendorsData } from "../controllers/propertyware/vendors.controller";
 import { syncInvoices } from "../controllers/propertyware/bills.controller";
 import { jwtMiddleware } from '../middlewares/authMiddleware';
-import { fetchWorkorders } from "../controllers/propertyware/workorders.controller";
+import { fetchWorkorders, syncWorkOrders } from "../controllers/propertyware/workorders.controller";
 
 const pwRouter = express.Router();
 
@@ -68,6 +68,20 @@ pwRouter.get("/syncUnits", syncUnitsData);
  */
 pwRouter.get('/syncInvoices', syncInvoices);
 
+/**
+ * @swagger
+ * /api/pw/syncWorkOrders:
+ *   get:
+ *     summary: Sync WorkOrders data
+ *     tags: [Propertyware]
+ *     responses:
+ *       200:
+ *         description: WorkOrders data synced successfully
+ *       500:
+ *         description: Error syncing workOrders data
+ */
+pwRouter.get("/syncWorkOrders", syncWorkOrders);
+
 
 /**
  * @swagger

src/shared/interfaces/pwWorkOrdersInterface.ts

@@ -0,0 +1,11 @@
+export interface PwWorkOrdersInterface {
+    id: number;
+    pw_id: number;
+    number: number;
+    location: string;
+    portfolio_id: number;
+    building_id: number;
+    unit_id: number;
+    status: string;
+    assigned_vendors: string[];
+}