IO-594 Create schedulable AH export.

server/data/autohouse.js

@@ -11,42 +11,109 @@ require("dotenv").config({
     `.env.${process.env.NODE_ENV || "development"}`
   ),
 });
+let Client = require("ssh2-sftp-client");
 
 const client = require("../graphql-client/graphql-client").client;
 const AHDineroFormat = "0.00";
 const AhDateFormat = "MMDDYYYY";
+
+const repairOpCodes = ["OP4", "OP9", "OP10"];
+const replaceOpCodes = ["OP2", "OP5", "OP11", "OP12"];
+
+const ftpSetup = {
+  host: process.env.AUTOHOUSE_HOST,
+  port: process.env.AUTOHOUSE_PORT,
+  username: process.env.AUTOHOUSE_USER,
+  password: process.env.AUTOHOUSE_PASSWORD,
+  //debug: console.log,
+};
+
 exports.default = async (req, res) => {
-  //Get Client Dataset.
-  const { jobs } = await client.request(queries.AUTOHOUSE_QUERY);
+  //Query for the List of Bodyshop Clients.
+  const { bodyshops } = await client.request(queries.GET_AUTOHOUSE_SHOPS);
 
-  const erroredJobs = [];
+  const allxmlsToUpload = [];
+  const allErrors = [];
 
-  const autoHouseObject = {
-    AutoHouseExport: {
-      RepairOrder: jobs.map((j) =>
-        CreateRepairOrderTag(j, (job, error) => {
-          erroredJobs.push({ job, error });
+  for (const bodyshop of bodyshops) {
+    const erroredJobs = [];
+    try {
+      const { jobs } = await client.request(queries.AUTOHOUSE_QUERY, {
+        bodyshopid: bodyshop.id,
+      });
+
+      const autoHouseObject = {
+        AutoHouseExport: {
+          RepairOrder: jobs.map((j) =>
+            CreateRepairOrderTag({ ...j, bodyshop }, function ({ job, error }) {
+              erroredJobs.push({ job: job, error: error.toString() });
+            })
+          ),
+        },
+      };
+
+      console.log(
+        "***Number of Failed jobs***: ",
+        erroredJobs.length,
+        JSON.stringify(erroredJobs.map((j) => j.job.ro_number))
+      );
+
+      var ret = builder
+        .create(autoHouseObject, {
+          version: "1.0",
+          encoding: "UTF-8",
         })
-      ),
-    },
-  };
+        .end({ pretty: true, allowEmptyTags: true });
 
-  console.log(
-    "***Number of Failed jobs***: ",
-    erroredJobs.length,
-    JSON.stringify(erroredJobs.map((x) => x.error))
-  );
-  var ret = builder
-    .create(autoHouseObject, {
-      version: "1.0",
-      encoding: "UTF-8",
-    })
-    .end({ pretty: true, allowEmptyTags: true });
+      allxmlsToUpload.push({
+        xml: ret,
+        filename: `IM_${bodyshop.imexshopid}_${moment().format(
+          "DDMMYYYY_HHMMSS"
+        )}.xml`,
+      });
+    } catch (error) {
+      //Error at the shop level.
+      allErrors.push({
+        bodyshopid: bodyshop.id,
+        imexshopid: bodyshop.imexshopid,
+        fatal: true,
+        errors: [error.toString()],
+      });
+    } finally {
+      allErrors.push({
+        bodyshopid: bodyshop.id,
+        imexshopid: bodyshop.imexshopid,
+        errors: erroredJobs,
+      });
+    }
+  }
 
-  //***TODO  Change filing naming when creating the cron job. IM_ShopInternalName_DDMMYYYY_HHMMSS.xml
-  res.type("application/xml");
-  //res.sendFile(ret);
-  res.send(ret);
+  let sftp = new Client();
+  try {
+    //Connect to the FTP and upload all.
+
+    await sftp.connect(ftpSetup);
+
+    for (const xmlObj of allxmlsToUpload) {
+      console.log("Uploading", xmlObj.filename);
+      const uploadResult = await sftp.put(
+        Buffer.from(xmlObj.xml),
+        `/${xmlObj.filename}`
+      );
+      console.log(
+        "🚀  ~ file: autohouse.js  ~ line 94  ~ uploadResult",
+        uploadResult
+      );
+    }
+
+    //***TODO  Change filing naming when creating the cron job. IM_ShopInternalName_DDMMYYYY_HHMMSS.xml
+  } catch (error) {
+    console.log("Error when connecting to FTP", error);
+  } finally {
+    sftp.end();
+  }
+
+  res.sendStatus(200);
 };
 
 const CreateRepairOrderTag = (job, errorCallback) => {
@@ -410,7 +477,7 @@ const CreateRepairOrderTag = (job, errorCallback) => {
     return ret;
   } catch (error) {
     console.log("Error calculating job", error);
-    errorCallback(job, error);
+    errorCallback({ job, error });
   }
 };
 
@@ -611,6 +678,3 @@ const generateNullDetailLine = () => {
     EstimateAmount: null,
   };
 };
-
-const repairOpCodes = ["OP4", "OP9", "OP10"];
-const replaceOpCodes = ["OP2", "OP5", "OP11", "OP12"];

server/graphql-client/queries.js

@@ -357,8 +357,8 @@ exports.QUERY_EMPLOYEE_PIN = `query QUERY_EMPLOYEE_PIN($shopId: uuid!, $employee
   }
 }`;
 
-exports.AUTOHOUSE_QUERY = `query AUTOHOUSE_EXPORT($start: timestamptz) {
-  jobs(where: {_and: [{updated_at: {_gt: $start}}, {bodyshop: {autohouseid: {_is_null: false}}}]}) {
+exports.AUTOHOUSE_QUERY = `query AUTOHOUSE_EXPORT($start: timestamptz, $bodyshopid: uuid!) {
+  jobs(where: {_and: [{updated_at: {_gt: $start}}, {shopid: {_eq: $bodyshopid}}]}) {
     id
     ro_number
     status
@@ -433,10 +433,10 @@ exports.AUTOHOUSE_QUERY = `query AUTOHOUSE_EXPORT($start: timestamptz) {
       md_ro_statuses
       md_order_statuses
       autohouseid
-           md_responsibility_centers
-        jc_hourly_rates
+      md_responsibility_centers
+      jc_hourly_rates
     }
-    joblines (where:{removed: {_eq:false}}){
+    joblines(where: {removed: {_eq: false}}) {
       id
       line_no
       status
@@ -452,40 +452,40 @@ exports.AUTOHOUSE_QUERY = `query AUTOHOUSE_EXPORT($start: timestamptz) {
       part_type
       oem_partno
       lbr_op
-       profitcenter_part
-        profitcenter_labor
-              billlines (order_by:{bill:{date:desc_nulls_last}}) {
+      profitcenter_part
+      profitcenter_labor
+      billlines(order_by: {bill: {date: desc_nulls_last}}) {
         actual_cost
         actual_price
         quantity
         bill {
-          vendor{
+          vendor {
             name
           }
           invoice_number
         }
       }
-
-    }      bills {
-        id
-        federal_tax_rate
-        local_tax_rate
-        state_tax_rate
-        is_credit_memo
-        billlines {
-          actual_cost
-          cost_center
-          id
-          quantity
-        }
-      }
-      timetickets {
-        id
-        rate
+    }
+    bills {
+      id
+      federal_tax_rate
+      local_tax_rate
+      state_tax_rate
+      is_credit_memo
+      billlines {
+        actual_cost
         cost_center
-        actualhrs
-        productivehrs
+        id
+        quantity
       }
+    }
+    timetickets {
+      id
+      rate
+      cost_center
+      actualhrs
+      productivehrs
+    }
     area_of_damage
     employee_prep_rel {
       first_name
@@ -507,6 +507,7 @@ exports.AUTOHOUSE_QUERY = `query AUTOHOUSE_EXPORT($start: timestamptz) {
     }
   }
 }
+
 `;
 
 exports.UPDATE_JOB = `
@@ -906,3 +907,24 @@ exports.INSERT_IOEVENT = ` mutation INSERT_IOEVENT($event: ioevents_insert_input
   }
 }
 `;
+
+exports.GET_AUTOHOUSE_SHOPS = `query GET_AUTOHOUSE_SHOPS {
+  bodyshops(where: {autohouseid: {_is_null: false}}){
+
+         id
+      shopname
+      address1
+      city
+      state
+      zip_post
+      country
+      phone
+      md_ro_statuses
+      md_order_statuses
+      autohouseid
+      md_responsibility_centers
+      jc_hourly_rates
+      imexshopid
+  }
+}
+`;