IO-2848 UPDATE_JOB query

Signed-off-by: Allan Carr <allan.carr@thinkimex.com>

client/.env.development.promanager

@@ -1,7 +1,7 @@
 VITE_APP_GRAPHQL_ENDPOINT=https://db.dev.bodyshop.app/v1/graphql
 VITE_APP_GRAPHQL_ENDPOINT_WS=wss://db.dev.bodyshop.app/v1/graphql
 VITE_APP_GA_CODE=231099835
-VITE_APP_FIREBASE_CONFIG={  "apiKey": "AIzaSyAuLQR9SV5LsVxjU8wh9hvFLdhcAHU6cxE",  "authDomain": "rome-prod-1.firebaseapp.com",  "projectId": "rome-prod-1",  "storageBucket": "rome-prod-1.appspot.com",  "messagingSenderId": "147786367145",  "appId": "1:147786367145:web:9d4cba68071c3f29a8a9b8",  "measurementId": "G-G8Z9DRHTZS"}
+VITE_APP_FIREBASE_CONFIG={"apiKey":"AIzaSyDPLT8GiDHDR1R4nI66Qi0BY1aYviDPioc","authDomain":"imex-dev.firebaseapp.com","databaseURL":"https://imex-dev.firebaseio.com","projectId":"imex-dev","storageBucket":"imex-dev.appspot.com","messagingSenderId":"759548147434","appId":"1:759548147434:web:e8239868a48ceb36700993","measurementId":"G-K5XRBVVB4S"}
 VITE_APP_CLOUDINARY_ENDPOINT_API=https://api.cloudinary.com/v1_1/io-test
 VITE_APP_CLOUDINARY_ENDPOINT=https://res.cloudinary.com/io-test
 VITE_APP_CLOUDINARY_API_KEY=957865933348715

client/src/App/App.jsx

@@ -7,9 +7,7 @@ import { connect } from "react-redux";
 import { Route, Routes } from "react-router-dom";
 import { createStructuredSelector } from "reselect";
 import DocumentEditorContainer from "../components/document-editor/document-editor.container";
-import ErrorBoundary from "../components/error-boundary/error-boundary.component";
-
-//Component Imports
+import ErrorBoundary from "../components/error-boundary/error-boundary.component"; // Component Imports
 import LoadingSpinner from "../components/loading-spinner/loading-spinner.component";
 import DisclaimerPage from "../pages/disclaimer/disclaimer.page";
 import LandingPage from "../pages/landing/landing.page";
@@ -23,20 +21,21 @@ import "./App.styles.scss";
 import handleBeta from "../utils/betaHandler";
 import Eula from "../components/eula/eula.component";
 import InstanceRenderMgr from "../utils/instanceRenderMgr";
-import { ProductFruits } from "react-product-fruits";
+import ProductFruitsWrapper from "./ProductFruitsWrapper.jsx";
 
 const ResetPassword = lazy(() => import("../pages/reset-password/reset-password.component"));
 const ManagePage = lazy(() => import("../pages/manage/manage.page.container"));
 const SignInPage = lazy(() => import("../pages/sign-in/sign-in.page"));
-
 const CsiPage = lazy(() => import("../pages/csi/csi.container.page"));
 const MobilePaymentContainer = lazy(() => import("../pages/mobile-payment/mobile-payment.container"));
+
 const mapStateToProps = createStructuredSelector({
   currentUser: selectCurrentUser,
   online: selectOnline,
   bodyshop: selectBodyshop,
   currentEula: selectCurrentEula
 });
+
 const mapDispatchToProps = (dispatch) => ({
   checkUserSession: () => dispatch(checkUserSession()),
   setOnline: (isOnline) => dispatch(setOnline(isOnline))
@@ -60,11 +59,11 @@ export function App({ bodyshop, checkUserSession, currentUser, online, setOnline
 
   // Associate event listeners, memoize to prevent multiple listeners being added
   useEffect(() => {
-    const offlineListener = (e) => {
+    const offlineListener = () => {
       setOnline(false);
     };
 
-    const onlineListener = (e) => {
+    const onlineListener = () => {
       setOnline(true);
     };
 
@@ -98,7 +97,7 @@ export function App({ bodyshop, checkUserSession, currentUser, online, setOnline
           InstanceRenderMgr({
             imex: "gvfvfw/bodyshopapp",
             rome: "rome-online/rome-online",
-            promanager: "" //TODO:AIO Add in log rocket for promanager instances.
+            promanager: "" // TODO: AIO Add in log rocket for promanager instances.
           })
         );
       }
@@ -111,24 +110,20 @@ export function App({ bodyshop, checkUserSession, currentUser, online, setOnline
 
   handleBeta();
 
-  if (!online)
+  if (!online) {
     return (
       <Result
         status="warning"
         title={t("general.labels.nointernet")}
         subTitle={t("general.labels.nointernet_sub")}
         extra={
-          <Button
-            type="primary"
-            onClick={() => {
-              window.location.reload();
-            }}
-          >
+          <Button type="primary" onClick={() => window.location.reload()}>
             {t("general.actions.refresh")}
           </Button>
         }
       />
     );
+  }
 
   if (currentEula && !currentUser.eulaIsAccepted) {
     return <Eula />;
@@ -147,18 +142,13 @@ export function App({ bodyshop, checkUserSession, currentUser, online, setOnline
         />
       }
     >
-      <ProductFruits
+      <ProductFruitsWrapper
+        currentUser={currentUser}
         workspaceCode={InstanceRenderMgr({
           imex: null,
           rome: "9BkbEseqNqxw8jUH",
           promanager: "aoJoEifvezYI0Z0P"
         })}
-        debug
-        language="en"
-        user={{
-          email: currentUser.email,
-          username: currentUser.email
-        }}
       />
 
       <Routes>

client/src/App/ProductFruitsWrapper.jsx

@@ -0,0 +1,32 @@
+import React from "react";
+import { ProductFruits } from "react-product-fruits";
+import PropTypes from "prop-types";
+
+const ProductFruitsWrapper = React.memo(({ currentUser, workspaceCode }) => {
+  return (
+    workspaceCode &&
+    currentUser?.authorized === true &&
+    currentUser?.email && (
+      <ProductFruits
+        lifeCycle="unmount"
+        workspaceCode={workspaceCode}
+        debug
+        language="en"
+        user={{
+          email: currentUser.email,
+          username: currentUser.email
+        }}
+      />
+    )
+  );
+});
+
+export default ProductFruitsWrapper;
+
+ProductFruitsWrapper.propTypes = {
+  currentUser: PropTypes.shape({
+    authorized: PropTypes.bool,
+    email: PropTypes.string
+  }).isRequired,
+  workspaceCode: PropTypes.string.isRequired
+};

client/src/components/dms-post-form/dms-post-form.component.jsx

@@ -14,7 +14,6 @@ import {
   Typography
 } from "antd";
 import Dinero from "dinero.js";
-import dayjs from "../../utils/day";
 import React from "react";
 import { useTranslation } from "react-i18next";
 import { connect } from "react-redux";
@@ -22,6 +21,7 @@ import { createStructuredSelector } from "reselect";
 import { determineDmsType } from "../../pages/dms/dms.container";
 import { selectBodyshop } from "../../redux/user/user.selectors";
 import i18n from "../../translations/i18n";
+import dayjs from "../../utils/day";
 import DmsCdkMakes from "../dms-cdk-makes/dms-cdk-makes.component";
 import DmsCdkMakesRefetch from "../dms-cdk-makes/dms-cdk-makes.refetch.component";
 import FormDatePicker from "../form-date-picker/form-date-picker.component";
@@ -89,7 +89,7 @@ export function DmsPostForm({ bodyshop, socket, job, logsRef }) {
             job.area_of_damage && job.area_of_damage.impact1
               ? " " +
                 t("jobs.labels.dms.damageto", {
-                  area_of_damage: (job.area_of_damage && job.area_of_damage.impact1) || "UNKNOWN"
+                  area_of_damage: (job.area_of_damage && job.area_of_damage.impact1.padStart(2, "0")) || "UNKNOWN"
                 })
               : ""
           }`.slice(0, 239),

client/src/components/job-close-ro-guard/job-close-ro-guard.container.jsx

@@ -1,6 +1,6 @@
-import React, { useCallback, useState } from "react";
 import { LockOutlined } from "@ant-design/icons";
 import { Badge, Card, Col, Collapse, Form, Input, Row, Space, Tooltip } from "antd";
+import React, { useCallback, useState } from "react";
 import { useTranslation } from "react-i18next";
 import { connect } from "react-redux";
 import { createStructuredSelector } from "reselect";
@@ -12,9 +12,9 @@ import JobCloseRoGuardBills from "./job-close-ro-guard.bills";
 import JobCloseRoGuardPpd from "./job-close-ro-guard.ppd";
 import JobCloseRoGuardProfit from "./job-close-ro-guard.profit";
 import "./job-close-ro-guard.styles.scss";
-import JobCloseRoGuardSublet from "./job-close-ro-guard.sublet";
-import JobCloseRoGuardTtLifecycle from "./job-close-ro-guard.tt-lifecycle";
+// import JobCloseRoGuardSublet from "./job-close-ro-guard.sublet";
 import InstanceRenderManager from "../../utils/instanceRenderMgr";
+import JobCloseRoGuardTtLifecycle from "./job-close-ro-guard.tt-lifecycle";
 
 const mapStateToProps = createStructuredSelector({
   //currentUser: selectCurrentUser

client/src/components/job-detail-cards/job-detail-cards.damage.component.jsx

@@ -1,14 +1,21 @@
 import React from "react";
 import { useTranslation } from "react-i18next";
-import CardTemplate from "./job-detail-cards.template.component";
 import Car from "../job-damage-visual/job-damage-visual.component";
+import CardTemplate from "./job-detail-cards.template.component";
 
 export default function JobDetailCardsDamageComponent({ loading, data }) {
   const { t } = useTranslation();
   const { area_of_damage } = data;
   return (
     <CardTemplate loading={loading} title={t("jobs.labels.cards.damage")}>
-      {area_of_damage ? <Car dmg1={area_of_damage.impact1} dmg2={area_of_damage.impact2} /> : t("jobs.errors.nodamage")}
+      {area_of_damage ? (
+        <Car
+          dmg1={area_of_damage.impact1 && area_of_damage.impact1.padStart(2, "0")}
+          dmg2={area_of_damage.impact2 && area_of_damage.impact2.padStart(2, "0")}
+        />
+      ) : (
+        t("jobs.errors.nodamage")
+      )}
     </CardTemplate>
   );
 }

client/src/components/job-detail-cards/job-detail-cards.parts.component.jsx

@@ -26,6 +26,16 @@ export function JobDetailCardsPartsComponent({ loading, data, jobRO }) {
   const { t } = useTranslation();
   const { joblines_status } = data;
 
+  const filteredJobLines = data.joblines.filter(
+    (j) =>
+      j.part_type !== null &&
+      j.part_type !== "PAE" &&
+      j.part_type !== "PAS" &&
+      j.part_type !== "PASL" &&
+      j.part_qty !== 0 &&
+      j.act_price !== 0
+  );
+//TODO: Correct jobline_statuses view by including the part_qty !== 0 and act_price !== 0
   const columns = [
     {
       title: t("joblines.fields.line_desc"),
@@ -95,7 +105,7 @@ export function JobDetailCardsPartsComponent({ loading, data, jobRO }) {
     <div>
       <CardTemplate loading={loading} title={t("jobs.labels.cards.parts")}>
         <PartsStatusPie joblines_status={joblines_status} />
-        <Table key="id" columns={columns} dataSource={data ? data.joblines : []} />
+        <Table key="id" columns={columns} dataSource={filteredJobLines ? filteredJobLines : []} />
       </CardTemplate>
     </div>
   );

client/src/components/jobs-detail-general/jobs-detail-general.component.jsx

@@ -189,7 +189,10 @@ export function JobsDetailGeneral({ bodyshop, jobRO, job, form }) {
         </Col>
         <Col {...lossColDamage}>
           {job.area_of_damage ? (
-            <Car dmg1={job.area_of_damage.impact1} dmg2={job.area_of_damage.impact2} />
+            <Car
+              dmg1={job.area_of_damage.impact1 && job.area_of_damage.impact1.padStart(2, "0")}
+              dmg2={job.area_of_damage.impact2 && job.area_of_damage.impact2.padStart(2, "0")}
+            />
           ) : (
             t("jobs.errors.nodamage")
           )}

client/src/components/shop-employees/shop-employees-list.component.jsx

@@ -63,7 +63,7 @@ export default function ShopEmployeesListComponent({ loading, employees }) {
           value: false
         }
       ],
-      onFilter: (value, record) => value === record.flate_rate,
+      onFilter: (value, record) => value === record.flat_rate,
       render: (text, record) =>
         record.flat_rate ? t("employees.labels.flat_rate") : t("employees.labels.straight_time")
     },

client/src/graphql/jobs.queries.js

@@ -905,7 +905,7 @@ export const QUERY_JOB_CARD_DETAILS = gql`
       }
 
       joblines(
-        where: { removed: { _eq: false }, part_type: { _is_null: false, _nin: ["PAE", "PAS", "PASL"] } }
+        where: { removed: { _eq: false } }
         order_by: { line_no: asc }
       ) {
         id
@@ -1149,6 +1149,7 @@ export const UPDATE_JOB = gql`
         suspended
         queued_for_parts
         scheduled_completion
+        scheduled_delivery
         actual_in
         date_repairstarted
         date_void

client/src/translations/en_us/common.json

@@ -647,7 +647,10 @@
 						"payers": "Payers"
 					},
 					"cdk_dealerid": "CDK Dealer ID",
+          "costsmapping": "Costs Mapping",
+          "dms_allocations": "DMS Allocations",
 					"pbs_serialnumber": "PBS Serial Number",
+          "profitsmapping": "Profits Mapping",
 					"title": "DMS"
 				},
 				"emaillater": "Email Later",
@@ -2917,7 +2920,8 @@
 				"parts_not_recieved_vendor": "Parts Not Received by Vendor",
 				"parts_received_not_scheduled": "Parts Received for Jobs Not Scheduled",
 				"payments_by_date": "Payments by Date",
-				"payments_by_date_type": "Payments by Date and Type",
+        "payments_by_date_payment": "Payments by Date and Payment Type",
+				"payments_by_date_type": "Payments by Date and Customer Type",
 				"production_by_category": "Production by Category",
 				"production_by_category_one": "Production filtered by Category",
 				"production_by_csr": "Production by CSR",

client/src/translations/es/common.json

@@ -647,7 +647,10 @@
 						"payers": ""
 					},
 					"cdk_dealerid": "",
+          "costsmapping": "",
+          "dms_allocations": "",
 					"pbs_serialnumber": "",
+          "profitsmapping": "",
 					"title": ""
 				},
 				"emaillater": "",
@@ -2917,6 +2920,7 @@
 				"parts_not_recieved_vendor": "",
 				"parts_received_not_scheduled": "",
 				"payments_by_date": "",
+        "payments_by_date_payment": "",
 				"payments_by_date_type": "",
 				"production_by_category": "",
 				"production_by_category_one": "",

client/src/translations/fr/common.json

@@ -647,7 +647,10 @@
 						"payers": ""
 					},
 					"cdk_dealerid": "",
+          "costsmapping": "",
+          "dms_allocations": "",
 					"pbs_serialnumber": "",
+          "profitsmapping": "",
 					"title": ""
 				},
 				"emaillater": "",
@@ -2917,6 +2920,7 @@
 				"parts_not_recieved_vendor": "",
 				"parts_received_not_scheduled": "",
 				"payments_by_date": "",
+        "payments_by_date_payment": "",
 				"payments_by_date_type": "",
 				"production_by_category": "",
 				"production_by_category_one": "",

client/src/utils/TemplateConstants.js

@@ -1194,6 +1194,17 @@ export const TemplateList = (type, context) => {
             },
             group: "customers"
           },
+          payments_by_date_payment: {
+            title: i18n.t("reportcenter.templates.payments_by_date_payment"),
+            subject: i18n.t("reportcenter.templates.payments_by_date_payment"),
+            key: "payments_by_date_payment",
+            disabled: false,
+            rangeFilter: {
+              object: i18n.t("reportcenter.labels.objects.payments"),
+              field: i18n.t("payments.fields.date")
+            },
+            group: "customers"
+          },
           schedule: {
             title: i18n.t("reportcenter.templates.schedule"),
             subject: i18n.t("reportcenter.templates.schedule"),

hasura/migrations/1720712957502_run_sql_migration/down.sql

@@ -0,0 +1,10 @@
+-- Could not auto-generate a down migration.
+-- Please write an appropriate down migration for the SQL below:
+-- CREATE OR REPLACE VIEW "public"."joblines_status" AS
+--  SELECT j.jobid,
+--     j.status,
+--     count(1) AS count,
+--     j.part_type
+--    FROM joblines j
+--   WHERE ((j.part_type IS NOT NULL) AND (j.part_type <> 'PAE'::text) AND (j.part_type <> 'PAS'::text) AND (j.part_type <> 'PASL'::text) AND (j.part_qty <> 0) AND (j.act_price <> 0) AND (j.removed IS FALSE))
+--   GROUP BY j.jobid, j.status, j.part_type;

hasura/migrations/1720712957502_run_sql_migration/up.sql

@@ -0,0 +1,8 @@
+CREATE OR REPLACE VIEW "public"."joblines_status" AS 
+ SELECT j.jobid,
+    j.status,
+    count(1) AS count,
+    j.part_type
+   FROM joblines j
+  WHERE ((j.part_type IS NOT NULL) AND (j.part_type <> 'PAE'::text) AND (j.part_type <> 'PAS'::text) AND (j.part_type <> 'PASL'::text) AND (j.part_qty <> 0) AND (j.act_price <> 0) AND (j.removed IS FALSE))
+  GROUP BY j.jobid, j.status, j.part_type;

hasura/migrations/1720713022389_run_sql_migration/down.sql

@@ -0,0 +1,10 @@
+-- Could not auto-generate a down migration.
+-- Please write an appropriate down migration for the SQL below:
+-- CREATE OR REPLACE VIEW "public"."joblines_status" AS
+--  SELECT j.jobid,
+--     j.status,
+--     count(1) AS count,
+--     j.part_type
+--    FROM joblines j
+--   WHERE ((j.part_type IS NOT NULL) AND (j.part_type <> 'PAE'::text) AND (j.part_type <> 'PAS'::text) AND (j.part_type <> 'PASL'::text) AND (j.part_qty <> (0)::numeric) AND (j.act_price <> (0)::numeric) AND (j.removed IS FALSE))
+--   GROUP BY j.jobid, j.status, j.part_type;

hasura/migrations/1720713022389_run_sql_migration/up.sql

@@ -0,0 +1,8 @@
+CREATE OR REPLACE VIEW "public"."joblines_status" AS 
+ SELECT j.jobid,
+    j.status,
+    count(1) AS count,
+    j.part_type
+   FROM joblines j
+  WHERE ((j.part_type IS NOT NULL) AND (j.part_type <> 'PAE'::text) AND (j.part_type <> 'PAS'::text) AND (j.part_type <> 'PASL'::text) AND (j.part_qty <> (0)::numeric) AND (j.act_price <> (0)::numeric) AND (j.removed IS FALSE))
+  GROUP BY j.jobid, j.status, j.part_type;

server/accounting/qb-receivables-lines.js

@@ -632,7 +632,7 @@ exports.default = function ({ bodyshop, jobs_by_pk, qbo = false, items, taxCodes
       }
     }
 
-    //QB USA with GST
+    //QB USA with GST and PST
     //This was required for the No. 1 Collision Group.
     if (
       bodyshop.accountingconfig &&
@@ -651,6 +651,17 @@ exports.default = function ({ bodyshop, jobs_by_pk, qbo = false, items, taxCodes
           Qty: 1
         }
       });
+      InvoiceLineAdd.push({
+        DetailType: "SalesItemLineDetail",
+        Amount: Dinero(jobs_by_pk.job_totals.totals.state_tax).toFormat(DineroQbFormat),
+        SalesItemLineDetail: {
+          ...(jobs_by_pk.class ? { ClassRef: { value: classes[jobs_by_pk.class] } } : {}),
+          ItemRef: {
+            value: items[bodyshop.md_responsibility_centers.taxes.state.accountitem]
+          },
+          Qty: 1
+        }
+      });
     }
   } else {
     //Handle insurance profile adjustments

server/cdk/cdk-calculate-allocations.js

@@ -16,403 +16,402 @@ const { DiscountNotAlreadyCounted } = InstanceManager({
   promanager: "USE_ROME"
 });
 
+exports.defaultRoute = async function (req, res) {
+  try {
+    CdkBase.createLogEvent(req, "DEBUG", `Received request to calculate allocations for ${req.body.jobid}`);
+    const jobData = await QueryJobData(req, req.BearerToken, req.body.jobid);
+    return res.status(200).json({ data: calculateAllocations(req, jobData) });
+  } catch (error) {
+    console.log(error);
+    CdkBase.createLogEvent(req, "ERROR", `Error encountered in CdkCalculateAllocations. ${error}`);
+    res.status(500).json({ error: `Error encountered in CdkCalculateAllocations. ${error}` });
+  }
+};
+
 exports.default = async function (socket, jobid) {
   try {
-    CdkBase.createLogEvent(socket, "DEBUG", `Received request to calculate allocations for ${jobid}`);
-    const job = await QueryJobData(socket, jobid);
-    const { bodyshop } = job;
-
-    const taxAllocations = InstanceManager({
-      executeFunction: true,
-      deubg: true,
-      args: [],
-      imex: () => ({
-        local: {
-          center: bodyshop.md_responsibility_centers.taxes.local.name,
-          sale: Dinero(job.job_totals.totals.local_tax),
-          cost: Dinero(),
-          profitCenter: bodyshop.md_responsibility_centers.taxes.local,
-          costCenter: bodyshop.md_responsibility_centers.taxes.local
-        },
-        state: {
-          center: bodyshop.md_responsibility_centers.taxes.state.name,
-          sale: Dinero(job.job_totals.totals.state_tax),
-          cost: Dinero(),
-          profitCenter: bodyshop.md_responsibility_centers.taxes.state,
-          costCenter: bodyshop.md_responsibility_centers.taxes.state
-        },
-        federal: {
-          center: bodyshop.md_responsibility_centers.taxes.federal.name,
-          sale: Dinero(job.job_totals.totals.federal_tax),
-          cost: Dinero(),
-          profitCenter: bodyshop.md_responsibility_centers.taxes.federal,
-          costCenter: bodyshop.md_responsibility_centers.taxes.federal
-        }
-      }),
-      rome: () => ({
-        tax_ty1: {
-          center: bodyshop.md_responsibility_centers.taxes[`tax_ty1`].name,
-          sale: Dinero(job.job_totals.totals.us_sales_tax_breakdown[`ty1Tax`]),
-          cost: Dinero(),
-          profitCenter: bodyshop.md_responsibility_centers.taxes[`tax_ty1`],
-          costCenter: bodyshop.md_responsibility_centers.taxes[`tax_ty1`]
-        },
-        tax_ty2: {
-          center: bodyshop.md_responsibility_centers.taxes[`tax_ty2`].name,
-          sale: Dinero(job.job_totals.totals.us_sales_tax_breakdown[`ty2Tax`]),
-          cost: Dinero(),
-          profitCenter: bodyshop.md_responsibility_centers.taxes[`tax_ty2`],
-          costCenter: bodyshop.md_responsibility_centers.taxes[`tax_ty2`]
-        },
-        tax_ty3: {
-          center: bodyshop.md_responsibility_centers.taxes[`tax_ty3`].name,
-          sale: Dinero(job.job_totals.totals.us_sales_tax_breakdown[`ty3Tax`]),
-          cost: Dinero(),
-          profitCenter: bodyshop.md_responsibility_centers.taxes[`tax_ty3`],
-          costCenter: bodyshop.md_responsibility_centers.taxes[`tax_ty3`]
-        },
-        tax_ty4: {
-          center: bodyshop.md_responsibility_centers.taxes[`tax_ty4`].name,
-          sale: Dinero(job.job_totals.totals.us_sales_tax_breakdown[`ty4Tax`]),
-          cost: Dinero(),
-          profitCenter: bodyshop.md_responsibility_centers.taxes[`tax_ty4`],
-          costCenter: bodyshop.md_responsibility_centers.taxes[`tax_ty4`]
-        },
-        tax_ty5: {
-          center: bodyshop.md_responsibility_centers.taxes[`tax_ty5`].name,
-          sale: Dinero(job.job_totals.totals.us_sales_tax_breakdown[`ty5Tax`]),
-          cost: Dinero(),
-          profitCenter: bodyshop.md_responsibility_centers.taxes[`tax_ty5`],
-          costCenter: bodyshop.md_responsibility_centers.taxes[`tax_ty5`]
-        }
-      })
-    });
-
-    //Determine if there are MAPA and MASH lines already on the estimate.
-    //If there are, don't do anything extra (mitchell estimate)
-    //Otherwise, calculate them and add them to the default MAPA and MASH centers.
-    let hasMapaLine = false;
-    let hasMashLine = false;
-
-    const profitCenterHash = job.joblines.reduce((acc, val) => {
-      //Check the Parts Assignment
-      if (val.db_ref === "936008") {
-        //If either of these DB REFs change, they also need to change in job-totals/job-costing calculations.
-        hasMapaLine = true;
-      }
-      if (val.db_ref === "936007") {
-        hasMashLine = true;
-      }
-
-      if (val.profitcenter_part) {
-        if (!acc[val.profitcenter_part]) acc[val.profitcenter_part] = Dinero();
-
-        let DineroAmount = Dinero({
-          amount: Math.round(val.act_price * 100)
-        }).multiply(val.part_qty || 1);
-
-        DineroAmount = DineroAmount.add(
-          ((val.prt_dsmk_m && val.prt_dsmk_m !== 0) || (val.prt_dsmk_p && val.prt_dsmk_p !== 0)) &&
-            DiscountNotAlreadyCounted(val, job.joblines)
-            ? val.prt_dsmk_m
-              ? Dinero({ amount: Math.round(val.prt_dsmk_m * 100) })
-              : Dinero({
-                  amount: Math.round(val.act_price * 100)
-                })
-                  .multiply(val.part_qty || 0)
-                  .percentage(Math.abs(val.prt_dsmk_p || 0))
-                  .multiply(val.prt_dsmk_p > 0 ? 1 : -1)
-            : Dinero()
-        );
-
-        acc[val.profitcenter_part] = acc[val.profitcenter_part].add(DineroAmount);
-      }
-      if (val.profitcenter_labor && val.mod_lbr_ty) {
-        //Check the Labor Assignment.
-
-        if (!acc[val.profitcenter_labor]) acc[val.profitcenter_labor] = Dinero();
-
-        acc[val.profitcenter_labor] = acc[val.profitcenter_labor].add(
-          Dinero({
-            amount: Math.round(job[`rate_${val.mod_lbr_ty.toLowerCase()}`] * 100)
-          }).multiply(val.mod_lb_hrs)
-        );
-      }
-      return acc;
-    }, {});
-
-    const selectedDmsAllocationConfig = bodyshop.md_responsibility_centers.dms_defaults.find(
-      (d) => d.name === job.dms_allocation
-    );
-    CdkBase.createLogEvent(
-      socket,
-      "DEBUG",
-      `Using DMS Allocation ${selectedDmsAllocationConfig && selectedDmsAllocationConfig.name} for cost export.`
-    );
-
-    let costCenterHash = {};
-    //Check whether to skip this if PBS and using AP module.
-    const disablebillwip = !!bodyshop?.pbs_configuration?.disablebillwip;
-
-    if (!disablebillwip) {
-      costCenterHash = job.bills.reduce((bill_acc, bill_val) => {
-        bill_val.billlines.map((line_val) => {
-          if (!bill_acc[selectedDmsAllocationConfig.costs[line_val.cost_center]])
-            bill_acc[selectedDmsAllocationConfig.costs[line_val.cost_center]] = Dinero();
-
-          let lineDinero = Dinero({
-            amount: Math.round((line_val.actual_cost || 0) * 100)
-          })
-            .multiply(line_val.quantity)
-            .multiply(bill_val.is_credit_memo ? -1 : 1);
-
-          bill_acc[selectedDmsAllocationConfig.costs[line_val.cost_center]] =
-            bill_acc[selectedDmsAllocationConfig.costs[line_val.cost_center]].add(lineDinero);
-          return null;
-        });
-        return bill_acc;
-      }, {});
-    }
-
-    job.timetickets.forEach((ticket) => {
-      //Get the total amount of the ticket.
-      let TicketTotal = Dinero({
-        amount: Math.round(
-          ticket.rate *
-            (ticket.employee && ticket.employee.flat_rate ? ticket.productivehrs || 0 : ticket.actualhrs || 0) *
-            100
-        )
-      });
-      //Add it to the right cost center.
-      if (!costCenterHash[selectedDmsAllocationConfig.costs[ticket.ciecacode]])
-        costCenterHash[selectedDmsAllocationConfig.costs[ticket.ciecacode]] = Dinero();
-
-      costCenterHash[selectedDmsAllocationConfig.costs[ticket.ciecacode]] =
-        costCenterHash[selectedDmsAllocationConfig.costs[ticket.ciecacode]].add(TicketTotal);
-    });
-
-    if (!hasMapaLine && job.job_totals.rates.mapa.total.amount > 0) {
-      // console.log("Adding MAPA Line Manually.");
-      const mapaAccountName = selectedDmsAllocationConfig.profits.MAPA;
-
-      const mapaAccount = bodyshop.md_responsibility_centers.profits.find((c) => c.name === mapaAccountName);
-
-      if (mapaAccount) {
-        if (!profitCenterHash[mapaAccountName]) profitCenterHash[mapaAccountName] = Dinero();
-
-        profitCenterHash[mapaAccountName] = profitCenterHash[mapaAccountName].add(
-          Dinero(job.job_totals.rates.mapa.total)
-        );
-      } else {
-        //console.log("NO MAPA ACCOUNT FOUND!!");
-      }
-    }
-
-    if (!hasMashLine && job.job_totals.rates.mash.total.amount > 0) {
-      // console.log("Adding MASH Line Manually.");
-
-      const mashAccountName = selectedDmsAllocationConfig.profits.MASH;
-
-      const mashAccount = bodyshop.md_responsibility_centers.profits.find((c) => c.name === mashAccountName);
-
-      if (mashAccount) {
-        if (!profitCenterHash[mashAccountName]) profitCenterHash[mashAccountName] = Dinero();
-
-        profitCenterHash[mashAccountName] = profitCenterHash[mashAccountName].add(
-          Dinero(job.job_totals.rates.mash.total)
-        );
-      } else {
-        //  console.log("NO MASH ACCOUNT FOUND!!");
-      }
-    }
-    console.log(
-      Number.isInteger(bodyshop?.cdk_configuration?.sendmaterialscosting),
-      typeof Number.isInteger(bodyshop?.cdk_configuration?.sendmaterialscosting)
-    );
-    if (!!bodyshop?.cdk_configuration?.sendmaterialscosting) {
-      //Manually send the percentage of the costing.
-
-      //Paint Mat
-      const mapaAccountName = selectedDmsAllocationConfig.costs.MAPA;
-      const mapaAccount = bodyshop.md_responsibility_centers.costs.find((c) => c.name === mapaAccountName);
-      if (mapaAccount) {
-        if (!costCenterHash[mapaAccountName])
-          costCenterHash[mapaAccountName] = Dinero();
-        if (job.bodyshop.use_paint_scale_data === true) {
-          if (job.mixdata.length > 0) {
-            costCenterHash[mapaAccountName] = costCenterHash[
-              mapaAccountName
-            ].add(
-              Dinero({
-                amount: Math.round(
-                  ((job.mixdata[0] && job.mixdata[0].totalliquidcost) || 0) *
-                    100
-                ),
-              })
-            );
-          } else {
-            costCenterHash[mapaAccountName] = costCenterHash[
-              mapaAccountName
-            ].add(
-              Dinero(job.job_totals.rates.mapa.total).percentage(
-                bodyshop?.cdk_configuration?.sendmaterialscosting
-              )
-            );
-          }
-        } else {
-          costCenterHash[mapaAccountName] = costCenterHash[mapaAccountName].add(
-            Dinero(job.job_totals.rates.mapa.total).percentage(
-              bodyshop?.cdk_configuration?.sendmaterialscosting
-            )
-          );
-        }
-      } else {
-        //console.log("NO MAPA ACCOUNT FOUND!!");
-      }
-
-      //Shop Mat
-      const mashAccountName = selectedDmsAllocationConfig.costs.MASH;
-      const mashAccount = bodyshop.md_responsibility_centers.costs.find((c) => c.name === mashAccountName);
-      if (mashAccount) {
-        if (!costCenterHash[mashAccountName]) costCenterHash[mashAccountName] = Dinero();
-        costCenterHash[mashAccountName] = costCenterHash[mashAccountName].add(
-          Dinero(job.job_totals.rates.mash.total).percentage(bodyshop?.cdk_configuration?.sendmaterialscosting)
-        );
-      } else {
-        //  console.log("NO MASH ACCOUNT FOUND!!");
-      }
-    }
-
-    const { ca_bc_pvrt } = job;
-    if (ca_bc_pvrt) {
-      // const pvrtAccount = bodyshop.md_responsibility_centers.profits.find(
-      //   (c) => c.name === mashAccountName
-      // );
-
-      taxAllocations.state.sale = taxAllocations.state.sale.add(
-        Dinero({ amount: Math.round((ca_bc_pvrt || 0) * 100) })
-      );
-    }
-
-    if (job.towing_payable && job.towing_payable !== 0) {
-      const towAccountName = selectedDmsAllocationConfig.profits.TOW;
-
-      const towAccount = bodyshop.md_responsibility_centers.profits.find((c) => c.name === towAccountName);
-
-      if (towAccount) {
-        if (!profitCenterHash[towAccountName]) profitCenterHash[towAccountName] = Dinero();
-
-        profitCenterHash[towAccountName] = profitCenterHash[towAccountName].add(
-          Dinero({
-            amount: Math.round((job.towing_payable || 0) * 100)
-          })
-        );
-      } else {
-        //  console.log("NO MASH ACCOUNT FOUND!!");
-      }
-    }
-    if (job.storage_payable && job.storage_payable !== 0) {
-      const storageAccountName = selectedDmsAllocationConfig.profits.TOW;
-
-      const towAccount = bodyshop.md_responsibility_centers.profits.find((c) => c.name === storageAccountName);
-
-      if (towAccount) {
-        if (!profitCenterHash[storageAccountName]) profitCenterHash[storageAccountName] = Dinero();
-
-        profitCenterHash[storageAccountName] = profitCenterHash[storageAccountName].add(
-          Dinero({
-            amount: Math.round((job.storage_payable || 0) * 100)
-          })
-        );
-      } else {
-        //  console.log("NO MASH ACCOUNT FOUND!!");
-      }
-    }
-
-    if (job.adjustment_bottom_line && job.adjustment_bottom_line !== 0) {
-      const otherAccountName = selectedDmsAllocationConfig.profits.PAO;
-
-      const otherAccount = bodyshop.md_responsibility_centers.profits.find((c) => c.name === otherAccountName);
-
-      if (otherAccount) {
-        if (!profitCenterHash[otherAccountName]) profitCenterHash[otherAccountName] = Dinero();
-
-        profitCenterHash[otherAccountName] = profitCenterHash[otherAccountName].add(
-          Dinero({
-            amount: Math.round((job.adjustment_bottom_line || 0) * 100)
-          })
-        );
-      } else {
-        //  console.log("NO MASH ACCOUNT FOUND!!");
-      }
-    }
-    if (InstanceManager({ rome: true })) {
-      //profile level adjustments
-      Object.keys(job.job_totals.parts.adjustments).forEach((key) => {
-        const accountName = selectedDmsAllocationConfig.profits[key];
-
-        const otherAccount = bodyshop.md_responsibility_centers.profits.find((c) => c.name === accountName);
-
-        if (otherAccount) {
-          if (!profitCenterHash[accountName]) profitCenterHash[accountName] = Dinero();
-
-          profitCenterHash[accountName] = profitCenterHash[accountName].add(
-            Dinero(job.job_totals.parts.adjustments[key])
-          );
-        } else {
-          CdkBase.createLogEvent(
-            socket,
-            "ERROR",
-            `Error encountered in CdkCalculateAllocations. Unable to find adjustment account. ${error}`
-          );
-        }
-      });
-    }
-
-    const jobAllocations = _.union(Object.keys(profitCenterHash), Object.keys(costCenterHash)).map((key) => {
-      const profitCenter = bodyshop.md_responsibility_centers.profits.find((c) => c.name === key);
-      const costCenter = bodyshop.md_responsibility_centers.costs.find((c) => c.name === key);
-
-      return {
-        center: key,
-        sale: profitCenterHash[key] ? profitCenterHash[key] : Dinero(),
-        cost: costCenterHash[key] ? costCenterHash[key] : Dinero(),
-        profitCenter,
-        costCenter
-      };
-    });
-
-    return [
-      ...jobAllocations,
-      ...Object.keys(taxAllocations)
-        .filter((key) => taxAllocations[key].sale.getAmount() > 0 || taxAllocations[key].cost.getAmount() > 0)
-        .map((key) => {
-          if (
-            key === "federal" &&
-            selectedDmsAllocationConfig.gst_override &&
-            selectedDmsAllocationConfig.gst_override !== ""
-          ) {
-            const ret = { ...taxAllocations[key], tax: key };
-            ret.costCenter.dms_acctnumber = selectedDmsAllocationConfig.gst_override;
-            ret.profitCenter.dms_acctnumber = selectedDmsAllocationConfig.gst_override;
-            return ret;
-          } else {
-            return { ...taxAllocations[key], tax: key };
-          }
-        })
-    ];
+    const jobData = await QueryJobData(socket, "Bearer " + socket.handshake.auth.token, jobid);
+    return calculateAllocations(socket, jobData);
   } catch (error) {
     console.log(error);
     CdkBase.createLogEvent(socket, "ERROR", `Error encountered in CdkCalculateAllocations. ${error}`);
   }
 };
 
-async function QueryJobData(socket, jobid) {
-  CdkBase.createLogEvent(socket, "DEBUG", `Querying job data for id ${jobid}`);
+async function QueryJobData(connectionData, token, jobid) {
+  CdkBase.createLogEvent(connectionData, "DEBUG", `Querying job data for id ${jobid}`);
   const client = new GraphQLClient(process.env.GRAPHQL_ENDPOINT, {});
-  const result = await client
-    .setHeaders({ Authorization: `Bearer ${socket.handshake.auth.token}` })
-    .request(queries.GET_CDK_ALLOCATIONS, { id: jobid });
-  CdkBase.createLogEvent(socket, "TRACE", `Job data query result ${JSON.stringify(result, null, 2)}`);
+  const result = await client.setHeaders({ Authorization: token }).request(queries.GET_CDK_ALLOCATIONS, { id: jobid });
+  CdkBase.createLogEvent(connectionData, "TRACE", `Job data query result ${JSON.stringify(result, null, 2)}`);
   return result.jobs_by_pk;
 }
+
+function calculateAllocations(connectionData, job) {
+  const { bodyshop } = job;
+
+  const taxAllocations = InstanceManager({
+    executeFunction: true,
+    deubg: true,
+    args: [],
+    imex: () => ({
+      local: {
+        center: bodyshop.md_responsibility_centers.taxes.local.name,
+        sale: Dinero(job.job_totals.totals.local_tax),
+        cost: Dinero(),
+        profitCenter: bodyshop.md_responsibility_centers.taxes.local,
+        costCenter: bodyshop.md_responsibility_centers.taxes.local
+      },
+      state: {
+        center: bodyshop.md_responsibility_centers.taxes.state.name,
+        sale: Dinero(job.job_totals.totals.state_tax),
+        cost: Dinero(),
+        profitCenter: bodyshop.md_responsibility_centers.taxes.state,
+        costCenter: bodyshop.md_responsibility_centers.taxes.state
+      },
+      federal: {
+        center: bodyshop.md_responsibility_centers.taxes.federal.name,
+        sale: Dinero(job.job_totals.totals.federal_tax),
+        cost: Dinero(),
+        profitCenter: bodyshop.md_responsibility_centers.taxes.federal,
+        costCenter: bodyshop.md_responsibility_centers.taxes.federal
+      }
+    }),
+    rome: () => ({
+      tax_ty1: {
+        center: bodyshop.md_responsibility_centers.taxes[`tax_ty1`].name,
+        sale: Dinero(job.job_totals.totals.us_sales_tax_breakdown[`ty1Tax`]),
+        cost: Dinero(),
+        profitCenter: bodyshop.md_responsibility_centers.taxes[`tax_ty1`],
+        costCenter: bodyshop.md_responsibility_centers.taxes[`tax_ty1`]
+      },
+      tax_ty2: {
+        center: bodyshop.md_responsibility_centers.taxes[`tax_ty2`].name,
+        sale: Dinero(job.job_totals.totals.us_sales_tax_breakdown[`ty2Tax`]),
+        cost: Dinero(),
+        profitCenter: bodyshop.md_responsibility_centers.taxes[`tax_ty2`],
+        costCenter: bodyshop.md_responsibility_centers.taxes[`tax_ty2`]
+      },
+      tax_ty3: {
+        center: bodyshop.md_responsibility_centers.taxes[`tax_ty3`].name,
+        sale: Dinero(job.job_totals.totals.us_sales_tax_breakdown[`ty3Tax`]),
+        cost: Dinero(),
+        profitCenter: bodyshop.md_responsibility_centers.taxes[`tax_ty3`],
+        costCenter: bodyshop.md_responsibility_centers.taxes[`tax_ty3`]
+      },
+      tax_ty4: {
+        center: bodyshop.md_responsibility_centers.taxes[`tax_ty4`].name,
+        sale: Dinero(job.job_totals.totals.us_sales_tax_breakdown[`ty4Tax`]),
+        cost: Dinero(),
+        profitCenter: bodyshop.md_responsibility_centers.taxes[`tax_ty4`],
+        costCenter: bodyshop.md_responsibility_centers.taxes[`tax_ty4`]
+      },
+      tax_ty5: {
+        center: bodyshop.md_responsibility_centers.taxes[`tax_ty5`].name,
+        sale: Dinero(job.job_totals.totals.us_sales_tax_breakdown[`ty5Tax`]),
+        cost: Dinero(),
+        profitCenter: bodyshop.md_responsibility_centers.taxes[`tax_ty5`],
+        costCenter: bodyshop.md_responsibility_centers.taxes[`tax_ty5`]
+      }
+    })
+  });
+
+  //Determine if there are MAPA and MASH lines already on the estimate.
+  //If there are, don't do anything extra (mitchell estimate)
+  //Otherwise, calculate them and add them to the default MAPA and MASH centers.
+  let hasMapaLine = false;
+  let hasMashLine = false;
+
+  const profitCenterHash = job.joblines.reduce((acc, val) => {
+    //Check the Parts Assignment
+    if (val.db_ref === "936008") {
+      //If either of these DB REFs change, they also need to change in job-totals/job-costing calculations.
+      hasMapaLine = true;
+    }
+    if (val.db_ref === "936007") {
+      hasMashLine = true;
+    }
+
+    if (val.profitcenter_part) {
+      if (!acc[val.profitcenter_part]) acc[val.profitcenter_part] = Dinero();
+
+      let DineroAmount = Dinero({
+        amount: Math.round(val.act_price * 100)
+      }).multiply(val.part_qty || 1);
+
+      DineroAmount = DineroAmount.add(
+        ((val.prt_dsmk_m && val.prt_dsmk_m !== 0) || (val.prt_dsmk_p && val.prt_dsmk_p !== 0)) &&
+          DiscountNotAlreadyCounted(val, job.joblines)
+          ? val.prt_dsmk_m
+            ? Dinero({ amount: Math.round(val.prt_dsmk_m * 100) })
+            : Dinero({
+                amount: Math.round(val.act_price * 100)
+              })
+                .multiply(val.part_qty || 0)
+                .percentage(Math.abs(val.prt_dsmk_p || 0))
+                .multiply(val.prt_dsmk_p > 0 ? 1 : -1)
+          : Dinero()
+      );
+
+      acc[val.profitcenter_part] = acc[val.profitcenter_part].add(DineroAmount);
+    }
+    if (val.profitcenter_labor && val.mod_lbr_ty) {
+      //Check the Labor Assignment.
+
+      if (!acc[val.profitcenter_labor]) acc[val.profitcenter_labor] = Dinero();
+
+      acc[val.profitcenter_labor] = acc[val.profitcenter_labor].add(
+        Dinero({
+          amount: Math.round(job[`rate_${val.mod_lbr_ty.toLowerCase()}`] * 100)
+        }).multiply(val.mod_lb_hrs)
+      );
+    }
+    return acc;
+  }, {});
+
+  const selectedDmsAllocationConfig = bodyshop.md_responsibility_centers.dms_defaults.find(
+    (d) => d.name === job.dms_allocation
+  );
+  CdkBase.createLogEvent(
+    connectionData,
+    "DEBUG",
+    `Using DMS Allocation ${selectedDmsAllocationConfig && selectedDmsAllocationConfig.name} for cost export.`
+  );
+
+  let costCenterHash = {};
+  //Check whether to skip this if PBS and using AP module.
+  const disablebillwip = !!bodyshop?.pbs_configuration?.disablebillwip;
+
+  if (!disablebillwip) {
+    costCenterHash = job.bills.reduce((bill_acc, bill_val) => {
+      bill_val.billlines.map((line_val) => {
+        if (!bill_acc[selectedDmsAllocationConfig.costs[line_val.cost_center]])
+          bill_acc[selectedDmsAllocationConfig.costs[line_val.cost_center]] = Dinero();
+
+        let lineDinero = Dinero({
+          amount: Math.round((line_val.actual_cost || 0) * 100)
+        })
+          .multiply(line_val.quantity)
+          .multiply(bill_val.is_credit_memo ? -1 : 1);
+
+        bill_acc[selectedDmsAllocationConfig.costs[line_val.cost_center]] =
+          bill_acc[selectedDmsAllocationConfig.costs[line_val.cost_center]].add(lineDinero);
+        return null;
+      });
+      return bill_acc;
+    }, {});
+  }
+
+  job.timetickets.forEach((ticket) => {
+    //Get the total amount of the ticket.
+    let TicketTotal = Dinero({
+      amount: Math.round(
+        ticket.rate *
+          (ticket.employee && ticket.employee.flat_rate ? ticket.productivehrs || 0 : ticket.actualhrs || 0) *
+          100
+      )
+    });
+    //Add it to the right cost center.
+    if (!costCenterHash[selectedDmsAllocationConfig.costs[ticket.ciecacode]])
+      costCenterHash[selectedDmsAllocationConfig.costs[ticket.ciecacode]] = Dinero();
+
+    costCenterHash[selectedDmsAllocationConfig.costs[ticket.ciecacode]] =
+      costCenterHash[selectedDmsAllocationConfig.costs[ticket.ciecacode]].add(TicketTotal);
+  });
+
+  if (!hasMapaLine && job.job_totals.rates.mapa.total.amount > 0) {
+    // console.log("Adding MAPA Line Manually.");
+    const mapaAccountName = selectedDmsAllocationConfig.profits.MAPA;
+
+    const mapaAccount = bodyshop.md_responsibility_centers.profits.find((c) => c.name === mapaAccountName);
+
+    if (mapaAccount) {
+      if (!profitCenterHash[mapaAccountName]) profitCenterHash[mapaAccountName] = Dinero();
+
+      profitCenterHash[mapaAccountName] = profitCenterHash[mapaAccountName].add(
+        Dinero(job.job_totals.rates.mapa.total)
+      );
+    } else {
+      //console.log("NO MAPA ACCOUNT FOUND!!");
+    }
+  }
+
+  if (!hasMashLine && job.job_totals.rates.mash.total.amount > 0) {
+    // console.log("Adding MASH Line Manually.");
+
+    const mashAccountName = selectedDmsAllocationConfig.profits.MASH;
+
+    const mashAccount = bodyshop.md_responsibility_centers.profits.find((c) => c.name === mashAccountName);
+
+    if (mashAccount) {
+      if (!profitCenterHash[mashAccountName]) profitCenterHash[mashAccountName] = Dinero();
+
+      profitCenterHash[mashAccountName] = profitCenterHash[mashAccountName].add(
+        Dinero(job.job_totals.rates.mash.total)
+      );
+    } else {
+      //  console.log("NO MASH ACCOUNT FOUND!!");
+    }
+  }
+  // console.log(
+  //   Number.isInteger(bodyshop?.cdk_configuration?.sendmaterialscosting),
+  //   typeof Number.isInteger(bodyshop?.cdk_configuration?.sendmaterialscosting)
+  // );
+  if (!!bodyshop?.cdk_configuration?.sendmaterialscosting) {
+    //Manually send the percentage of the costing.
+
+    //Paint Mat
+    const mapaAccountName = selectedDmsAllocationConfig.costs.MAPA;
+    const mapaAccount = bodyshop.md_responsibility_centers.costs.find((c) => c.name === mapaAccountName);
+    if (mapaAccount) {
+      if (!costCenterHash[mapaAccountName]) costCenterHash[mapaAccountName] = Dinero();
+      if (job.bodyshop.use_paint_scale_data === true) {
+        if (job.mixdata.length > 0) {
+          costCenterHash[mapaAccountName] = costCenterHash[mapaAccountName].add(
+            Dinero({
+              amount: Math.round(((job.mixdata[0] && job.mixdata[0].totalliquidcost) || 0) * 100)
+            })
+          );
+        } else {
+          costCenterHash[mapaAccountName] = costCenterHash[mapaAccountName].add(
+            Dinero(job.job_totals.rates.mapa.total).percentage(bodyshop?.cdk_configuration?.sendmaterialscosting)
+          );
+        }
+      } else {
+        costCenterHash[mapaAccountName] = costCenterHash[mapaAccountName].add(
+          Dinero(job.job_totals.rates.mapa.total).percentage(bodyshop?.cdk_configuration?.sendmaterialscosting)
+        );
+      }
+    } else {
+      //console.log("NO MAPA ACCOUNT FOUND!!");
+    }
+
+    //Shop Mat
+    const mashAccountName = selectedDmsAllocationConfig.costs.MASH;
+    const mashAccount = bodyshop.md_responsibility_centers.costs.find((c) => c.name === mashAccountName);
+    if (mashAccount) {
+      if (!costCenterHash[mashAccountName]) costCenterHash[mashAccountName] = Dinero();
+      costCenterHash[mashAccountName] = costCenterHash[mashAccountName].add(
+        Dinero(job.job_totals.rates.mash.total).percentage(bodyshop?.cdk_configuration?.sendmaterialscosting)
+      );
+    } else {
+      //  console.log("NO MASH ACCOUNT FOUND!!");
+    }
+  }
+
+  const { ca_bc_pvrt } = job;
+  if (ca_bc_pvrt) {
+    // const pvrtAccount = bodyshop.md_responsibility_centers.profits.find(
+    //   (c) => c.name === mashAccountName
+    // );
+
+    taxAllocations.state.sale = taxAllocations.state.sale.add(Dinero({ amount: Math.round((ca_bc_pvrt || 0) * 100) }));
+  }
+
+  if (job.towing_payable && job.towing_payable !== 0) {
+    const towAccountName = selectedDmsAllocationConfig.profits.TOW;
+
+    const towAccount = bodyshop.md_responsibility_centers.profits.find((c) => c.name === towAccountName);
+
+    if (towAccount) {
+      if (!profitCenterHash[towAccountName]) profitCenterHash[towAccountName] = Dinero();
+
+      profitCenterHash[towAccountName] = profitCenterHash[towAccountName].add(
+        Dinero({
+          amount: Math.round((job.towing_payable || 0) * 100)
+        })
+      );
+    } else {
+      //  console.log("NO MASH ACCOUNT FOUND!!");
+    }
+  }
+  if (job.storage_payable && job.storage_payable !== 0) {
+    const storageAccountName = selectedDmsAllocationConfig.profits.TOW;
+
+    const towAccount = bodyshop.md_responsibility_centers.profits.find((c) => c.name === storageAccountName);
+
+    if (towAccount) {
+      if (!profitCenterHash[storageAccountName]) profitCenterHash[storageAccountName] = Dinero();
+
+      profitCenterHash[storageAccountName] = profitCenterHash[storageAccountName].add(
+        Dinero({
+          amount: Math.round((job.storage_payable || 0) * 100)
+        })
+      );
+    } else {
+      //  console.log("NO MASH ACCOUNT FOUND!!");
+    }
+  }
+
+  if (job.adjustment_bottom_line && job.adjustment_bottom_line !== 0) {
+    const otherAccountName = selectedDmsAllocationConfig.profits.PAO;
+
+    const otherAccount = bodyshop.md_responsibility_centers.profits.find((c) => c.name === otherAccountName);
+
+    if (otherAccount) {
+      if (!profitCenterHash[otherAccountName]) profitCenterHash[otherAccountName] = Dinero();
+
+      profitCenterHash[otherAccountName] = profitCenterHash[otherAccountName].add(
+        Dinero({
+          amount: Math.round((job.adjustment_bottom_line || 0) * 100)
+        })
+      );
+    } else {
+      //  console.log("NO MASH ACCOUNT FOUND!!");
+    }
+  }
+  if (InstanceManager({ rome: true })) {
+    //profile level adjustments
+    Object.keys(job.job_totals.parts.adjustments).forEach((key) => {
+      const accountName = selectedDmsAllocationConfig.profits[key];
+
+      const otherAccount = bodyshop.md_responsibility_centers.profits.find((c) => c.name === accountName);
+
+      if (otherAccount) {
+        if (!profitCenterHash[accountName]) profitCenterHash[accountName] = Dinero();
+
+        profitCenterHash[accountName] = profitCenterHash[accountName].add(
+          Dinero(job.job_totals.parts.adjustments[key])
+        );
+      } else {
+        CdkBase.createLogEvent(
+          connectionData,
+          "ERROR",
+          `Error encountered in CdkCalculateAllocations. Unable to find adjustment account. ${error}`
+        );
+      }
+    });
+  }
+
+  const jobAllocations = _.union(Object.keys(profitCenterHash), Object.keys(costCenterHash)).map((key) => {
+    const profitCenter = bodyshop.md_responsibility_centers.profits.find((c) => c.name === key);
+    const costCenter = bodyshop.md_responsibility_centers.costs.find((c) => c.name === key);
+
+    return {
+      center: key,
+      sale: profitCenterHash[key] ? profitCenterHash[key] : Dinero(),
+      cost: costCenterHash[key] ? costCenterHash[key] : Dinero(),
+      profitCenter,
+      costCenter
+    };
+  });
+
+  return [
+    ...jobAllocations,
+    ...Object.keys(taxAllocations)
+      .filter((key) => taxAllocations[key].sale.getAmount() > 0 || taxAllocations[key].cost.getAmount() > 0)
+      .map((key) => {
+        if (
+          key === "federal" &&
+          selectedDmsAllocationConfig.gst_override &&
+          selectedDmsAllocationConfig.gst_override !== ""
+        ) {
+          const ret = { ...taxAllocations[key], tax: key };
+          ret.costCenter.dms_acctnumber = selectedDmsAllocationConfig.gst_override;
+          ret.profitCenter.dms_acctnumber = selectedDmsAllocationConfig.gst_override;
+          return ret;
+        } else {
+          return { ...taxAllocations[key], tax: key };
+        }
+      })
+  ];
+}

server/data/kaizen.js

@@ -244,6 +244,7 @@ const CreateRepairOrderTag = (job, errorCallback) => {
       },
       InsuranceCompany: job.ins_co_nm || "",
       Claim: job.clm_no || "",
+      DMSAllocation: job.dms_allocation || "",
       Contacts: {
         CSR: job.employee_csr_rel
           ? `${
@@ -643,7 +644,8 @@ const CreateJobLines = (joblines) => {
       part_qty: jobline.part_qty,
       part_price: jobline.act_price,
       labor_type: jobline.mod_lbr_ty,
-      labor_hours: jobline.mod_lb_hrs
+      labor_hours: jobline.mod_lb_hrs,
+      labor_sale: jobline.lbr_amt
     });
   });
   return repairLines;
@@ -660,7 +662,10 @@ const CreateTimeTickets = (timetickets) => {
         .trim(),
       productive_hrs: ticket.productivehrs,
       actual_hrs: ticket.actualhrs,
-      cost_center: ticket.cost_center
+      cost_center: ticket.cost_center,
+      flat_rate: ticket.flat_rate,
+      rate: ticket.rate,
+      ticket_cost: ticket.flat_rate ? ticket.rate * ticket.productive_hrs : ticket.rate * ticket.actual_hrs
     });
   });
   return timeTickets;

server/graphql-client/queries.js

@@ -1139,6 +1139,7 @@ exports.KAIZEN_QUERY = `query KAIZEN_EXPORT($start: timestamptz, $bodyshopid: uu
     date_open
     date_repairstarted
     date_void
+    dms_allocation
     employee_body_rel {
       first_name
       last_name
@@ -1184,6 +1185,7 @@ exports.KAIZEN_QUERY = `query KAIZEN_EXPORT($start: timestamptz, $bodyshopid: uu
       }
       db_price
       id
+      lbr_amt
       lbr_op
       line_desc
       line_ind

server/routes/cdkRoutes.js

@@ -1,11 +1,13 @@
 const express = require("express");
 const router = express.Router();
 const cdkGetMake = require("../cdk/cdk-get-makes");
+const cdkCalculateAllocations = require("../cdk/cdk-calculate-allocations");
 const validateFirebaseIdTokenMiddleware = require("../middleware/validateFirebaseIdTokenMiddleware");
 const withUserGraphQLClientMiddleware = require("../middleware/withUserGraphQLClientMiddleware");
 
 router.use(validateFirebaseIdTokenMiddleware);
 
 router.post("/getvehicles", withUserGraphQLClientMiddleware, cdkGetMake.default);
+router.post("/calculate-allocations", withUserGraphQLClientMiddleware, cdkCalculateAllocations.defaultRoute);
 
 module.exports = router;