322 lines
10 KiB
JavaScript
322 lines
10 KiB
JavaScript
const path = require("path");
|
|
require("dotenv").config({
|
|
path: path.resolve(
|
|
process.cwd(),
|
|
`.env.${process.env.NODE_ENV || "development"}`
|
|
),
|
|
});
|
|
const GraphQLClient = require("graphql-request").GraphQLClient;
|
|
|
|
const queries = require("../graphql-client/queries");
|
|
const CdkBase = require("../web-sockets/web-socket");
|
|
|
|
const Dinero = require("dinero.js");
|
|
const _ = require("lodash");
|
|
|
|
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 = {
|
|
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,
|
|
},
|
|
};
|
|
|
|
//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);
|
|
|
|
if (
|
|
(val.prt_dsmk_p && val.prt_dsmk_p !== 0) ||
|
|
((val.db_ref === "900511" || val.db_ref === "900510") &&
|
|
val.prt_dsmk_m &&
|
|
val.prt_dsmk_m !== 0)
|
|
) {
|
|
// console.log("Have a part discount", val);
|
|
DineroAmount = DineroAmount.add(
|
|
val.prt_dsmk_m && val.prt_dsmk_m !== 0
|
|
? Dinero({ amount: Math.round(val.prt_dsmk_m * 100) })
|
|
: DineroAmount.percentage(Math.abs(val.prt_dsmk_p || 0)).multiply(
|
|
val.prt_dsmk_p > 0 ? 1 : -1
|
|
)
|
|
);
|
|
}
|
|
|
|
acc[val.profitcenter_part] =
|
|
acc[val.profitcenter_part].add(DineroAmount);
|
|
}
|
|
if (val.profitcenter_labor) {
|
|
//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 costCenterHash = job.bills.reduce((bill_acc, bill_val) => {
|
|
bill_val.billlines.map((line_val) => {
|
|
if (!bill_acc[line_val.cost_center])
|
|
bill_acc[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[line_val.cost_center] =
|
|
bill_acc[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[ticket.cost_center])
|
|
costCenterHash[ticket.cost_center] = Dinero();
|
|
|
|
costCenterHash[ticket.cost_center] =
|
|
costCenterHash[ticket.cost_center].add(TicketTotal);
|
|
});
|
|
|
|
if (!hasMapaLine && job.job_totals.rates.mapa.total.amount > 0) {
|
|
// console.log("Adding MAPA Line Manually.");
|
|
const mapaAccountName =
|
|
bodyshop.md_responsibility_centers.defaults.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 =
|
|
bodyshop.md_responsibility_centers.defaults.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!!");
|
|
}
|
|
}
|
|
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 =
|
|
bodyshop.md_responsibility_centers.defaults.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 =
|
|
bodyshop.md_responsibility_centers.defaults.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 =
|
|
bodyshop.md_responsibility_centers.defaults.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!!");
|
|
}
|
|
}
|
|
|
|
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) => {
|
|
return { ...taxAllocations[key], tax: key };
|
|
}),
|
|
];
|
|
} catch (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}`);
|
|
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)}`
|
|
);
|
|
return result.jobs_by_pk;
|
|
}
|