IO-117 PBS WIP
This commit is contained in:
Patrick Fic
@@ -5,7 +5,6 @@ require("dotenv").config({
|
||||
`.env.${process.env.NODE_ENV || "development"}`
|
||||
),
|
||||
});
|
||||
const CdkBase = require("../web-sockets/web-socket");
|
||||
|
||||
const IMEX_PBS_USER = process.env.IMEX_PBS_USER,
|
||||
IMEX_PBS_PASSWORD = process.env.IMEX_PBS_PASSWORD;
|
||||
@@ -19,3 +18,13 @@ exports.PBS_CREDENTIALS = PBS_CREDENTIALS;
|
||||
// process.env.NODE_ENV === "production"
|
||||
// ? "https://3pa.dmotorworks.com"
|
||||
// : "https://uat-3pa.dmotorworks.com";
|
||||
|
||||
const pbsDomain = `https://partnerhub.pbsdealers.com/json/reply`;
|
||||
exports.PBS_ENDPOINTS = {
|
||||
AccountGet: `${pbsDomain}/AccountGet`,
|
||||
ContactGet: `${pbsDomain}/ContactGet`,
|
||||
VehicleGet: `${pbsDomain}/VehicleGet`,
|
||||
AccountingPostingChange: `${pbsDomain}/AccountingPostingChange`,
|
||||
ContactChange: `${pbsDomain}/ContactChange`,
|
||||
VehicleChange: `${pbsDomain}/VehicleChange`,
|
||||
};
|
||||
|
||||
@@ -6,16 +6,15 @@ require("dotenv").config({
|
||||
),
|
||||
});
|
||||
const GraphQLClient = require("graphql-request").GraphQLClient;
|
||||
const soap = require("soap");
|
||||
const axios = require("axios").default;
|
||||
const queries = require("../../graphql-client/queries");
|
||||
const CdkBase = require("../../web-sockets/web-socket");
|
||||
const { PBS_ENDPOINTS, PBS_CREDENTIALS } = require("./pbs-constants");
|
||||
|
||||
//const { CDK_CREDENTIALS, CheckCdkResponseForError } = require("./cdk-wsdl");
|
||||
//const CalcualteAllocations = require("./cdk-calculate-allocations").default;
|
||||
const CdkBase = require("../../web-sockets/web-socket");
|
||||
|
||||
const moment = require("moment");
|
||||
|
||||
exports.default = async function (socket, jobid) {
|
||||
exports.default = async function (socket, { txEnvelope, jobid }) {
|
||||
socket.logEvents = [];
|
||||
socket.recordid = jobid;
|
||||
|
||||
@@ -25,6 +24,18 @@ exports.default = async function (socket, jobid) {
|
||||
"DEBUG",
|
||||
`Received Job export request for id ${jobid}`
|
||||
);
|
||||
|
||||
const JobData = await QueryJobData(socket, jobid);
|
||||
socket.JobData = JobData;
|
||||
|
||||
//Upsert the contact information as per Wafaa's Email.
|
||||
CdkBase.createLogEvent(
|
||||
socket,
|
||||
"DEBUG",
|
||||
`Upserting contact information to DMS for ${socket.JobData.ownr_fn} ${socket.JobData.ownr_ln} ${socket.JobData.ownr_co_nm}`
|
||||
);
|
||||
const ownerRef = await UpsertContactData(socket);
|
||||
await UpsertVehicleData(socket, ownerRef.ReferenceId);
|
||||
} catch (error) {
|
||||
CdkBase.createLogEvent(
|
||||
socket,
|
||||
@@ -33,3 +44,277 @@ exports.default = async function (socket, jobid) {
|
||||
);
|
||||
}
|
||||
};
|
||||
|
||||
async function CheckForErrors(socket, response) {
|
||||
if (response.WasSuccessful) {
|
||||
return;
|
||||
} else {
|
||||
CdkBase.createLogEvent(
|
||||
socket,
|
||||
"ERROR",
|
||||
`Error received from DMS:. ${response.Message}`
|
||||
);
|
||||
CdkBase.createLogEvent(
|
||||
socket,
|
||||
"TRACE",
|
||||
`Error received from DMS:. ${JSON.stringify(response)}`
|
||||
);
|
||||
}
|
||||
}
|
||||
|
||||
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.QUERY_JOBS_FOR_PBS_EXPORT, { id: jobid });
|
||||
CdkBase.createLogEvent(
|
||||
socket,
|
||||
"TRACE",
|
||||
`Job data query result ${JSON.stringify(result, null, 2)}`
|
||||
);
|
||||
return result.jobs_by_pk;
|
||||
}
|
||||
|
||||
async function UpsertContactData(socket) {
|
||||
try {
|
||||
const { data: ContactChangeResponse } = await axios.post(
|
||||
PBS_ENDPOINTS.ContactChange,
|
||||
{
|
||||
ContactInfo: {
|
||||
// Id: socket.JobData.owner.id,
|
||||
ContactId: socket.JobData.owner.id,
|
||||
SerialNumber: socket.JobData.bodyshop.pbs_serialnumber,
|
||||
Code: socket.JobData.owner.accountingid,
|
||||
...(socket.JobData.ownr_co_nm
|
||||
? {
|
||||
//LastName: socket.JobData.ownr_ln,
|
||||
FirstName: socket.JobData.ownr_co_nm,
|
||||
IsBusiness: true,
|
||||
}
|
||||
: {
|
||||
LastName: socket.JobData.ownr_ln,
|
||||
FirstName: socket.JobData.ownr_fn,
|
||||
IsBusiness: false,
|
||||
}),
|
||||
|
||||
//Salutation: "String",
|
||||
//MiddleName: "String",
|
||||
//ContactName: "String",
|
||||
IsInactive: false,
|
||||
|
||||
//ApartmentNumber: "String",
|
||||
Address: socket.JobData.ownr_addr1,
|
||||
City: socket.JobData.ownr_city,
|
||||
//County: socket.JobData.ownr_addr1,
|
||||
State: socket.JobData.ownr_st,
|
||||
ZipCode: socket.JobData.ownr_zip,
|
||||
//BusinessPhone: "String",
|
||||
//BusinessPhoneExt: "String",
|
||||
HomePhone: socket.JobData.ownr_ph2,
|
||||
CellPhone: socket.JobData.ownr_ph1,
|
||||
//BusinessPhoneRawReverse: "String",
|
||||
//HomePhoneRawReverse: "String",
|
||||
//CellPhoneRawReverse: "String",
|
||||
//FaxNumber: "String",
|
||||
EmailAddress: socket.JobData.ownr_ea,
|
||||
//Notes: "String",
|
||||
//CriticalMemo: "String",
|
||||
//BirthDate: "0001-01-01T00:00:00.0000000Z",
|
||||
// Gender: "String",
|
||||
// DriverLicense: "String",
|
||||
//PreferredContactMethods: ["String"],
|
||||
// LastUpdate: "0001-01-01T00:00:00.0000000Z",
|
||||
// CustomFields: [{ Key: "String", Value: "String", Type: "String" }],
|
||||
// FleetType: "String",
|
||||
// CommunicationPreferences: {
|
||||
// Email: "String",
|
||||
// Phone: "String",
|
||||
// TextMessage: "String",
|
||||
// Letter: "String",
|
||||
// Preferred: "String",
|
||||
// },
|
||||
// SalesRepRef: "00000000000000000000000000000000",
|
||||
// Language: "String",
|
||||
// PayableAccount: "String",
|
||||
// ReceivableAccount: "String",
|
||||
// IsStatic: false,
|
||||
// PrimaryImageRef: "00000000000000000000000000000000",
|
||||
// PayableAccounts: [{ SerialNumber: "String", Account: "String" }],
|
||||
// ReceivableAccounts: [{ SerialNumber: "String", Account: "String" }],
|
||||
// ManufacturerLoyaltyNumber: "String",
|
||||
},
|
||||
IsAsynchronous: false,
|
||||
// UserRequest: "String",
|
||||
// UserRef: "00000000000000000000000000000000",
|
||||
},
|
||||
{ auth: PBS_CREDENTIALS }
|
||||
);
|
||||
CheckForErrors(socket, ContactChangeResponse);
|
||||
return ContactChangeResponse;
|
||||
} catch (error) {
|
||||
CdkBase.createLogEvent(
|
||||
socket,
|
||||
"ERROR",
|
||||
`Error in UpsertContactData - ${error}`
|
||||
);
|
||||
throw new Error(error);
|
||||
}
|
||||
}
|
||||
|
||||
async function UpsertVehicleData(socket, ownerRef) {
|
||||
try {
|
||||
const { data: VehicleChangeResponse } = await axios.post(
|
||||
PBS_ENDPOINTS.VehicleChange,
|
||||
{
|
||||
VehicleInfo: {
|
||||
//Id: "string/00000000-0000-0000-0000-000000000000",
|
||||
//VehicleId: "00000000000000000000000000000000",
|
||||
SerialNumber: socket.JobData.bodyshop.pbs_serialnumber,
|
||||
//StockNumber: "String",
|
||||
VIN: socket.JobData.v_vin,
|
||||
LicenseNumber: socket.JobData.plate_no,
|
||||
//FleetNumber: "String",
|
||||
//Status: "String",
|
||||
OwnerRef: ownerRef, // "00000000000000000000000000000000",
|
||||
//ModelNumber: "String",
|
||||
Make: socket.JobData.v_make_desc,
|
||||
Model: socket.JobData.v_model_desc,
|
||||
//Trim: "String",
|
||||
//VehicleType: "String",
|
||||
Year: socket.JobData.v_model_yr,
|
||||
Odometer: socket.JobData.kmin,
|
||||
ExteriorColor: {
|
||||
Code: socket.JobData.v_color,
|
||||
//Description: "String",
|
||||
},
|
||||
// InteriorColor: { Code: "String", Description: "String" },
|
||||
//Engine: "String",
|
||||
// Cylinders: "String",
|
||||
// Transmission: "String",
|
||||
// DriveWheel: "String",
|
||||
// Fuel: "String",
|
||||
// Weight: 0,
|
||||
// InServiceDate: "0001-01-01T00:00:00.0000000Z",
|
||||
// LastServiceDate: "0001-01-01T00:00:00.0000000Z",
|
||||
// LastServiceMileage: 0,
|
||||
// Lot: "String",
|
||||
// LotDescription: "String",
|
||||
// Category: "String",
|
||||
// Options: [
|
||||
// {
|
||||
// Group: "String",
|
||||
// Code: "String",
|
||||
// Description: "String",
|
||||
// AdditionalInfo: "String",
|
||||
// Price: 0,
|
||||
// Cost: 0,
|
||||
// Residual: 0,
|
||||
// },
|
||||
// ],
|
||||
// Refurbishments: [
|
||||
// {
|
||||
// ReferenceNumber: "String",
|
||||
// Description: "String",
|
||||
// Price: 0,
|
||||
// Cost: 0,
|
||||
// Date: "0001-01-01T00:00:00.0000000Z",
|
||||
// ApplicationModel: "String",
|
||||
// },
|
||||
// ],
|
||||
// Order: {
|
||||
// InvoiceNumber: "String",
|
||||
// Price: 0,
|
||||
// Status: "String",
|
||||
// Eta: "String",
|
||||
// EstimatedCost: 0,
|
||||
// OrderDate: "String",
|
||||
// StatusDate: "String",
|
||||
// IgnitionKeyCode: "String",
|
||||
// DoorKeyCode: "String",
|
||||
// Description: "String",
|
||||
// LocationStatus: "String",
|
||||
// LocationStatusDate: "0001-01-01T00:00:00.0000000Z",
|
||||
// },
|
||||
// MSR: 0,
|
||||
// BaseMSR: 0,
|
||||
// Retail: 0,
|
||||
// DateReceived: "0001-01-01T00:00:00.0000000Z",
|
||||
// InternetPrice: 0,
|
||||
// Lotpack: 0,
|
||||
// Holdback: 0,
|
||||
// InternetNotes: "String",
|
||||
// Notes: "String",
|
||||
// CriticalMemo: "String",
|
||||
// IsCertified: false,
|
||||
// LastSaleDate: "0001-01-01T00:00:00.0000000Z",
|
||||
// LastUpdate: "0001-01-01T00:00:00.0000000Z",
|
||||
// AppraisedValue: 0,
|
||||
// Warranties: [
|
||||
// {
|
||||
// Type: "String",
|
||||
// CompanyName: "String",
|
||||
// CoveragePlan: "String",
|
||||
// Description: "String",
|
||||
// Price: 0,
|
||||
// Cost: 0,
|
||||
// Term: "String",
|
||||
// Deductible: 0,
|
||||
// PolicyNumber: "String",
|
||||
// StartDate: "String",
|
||||
// StartMileage: 0,
|
||||
// ExpirationDate: "String",
|
||||
// ExpirationMileage: 0,
|
||||
// },
|
||||
// ],
|
||||
// Freight: 0,
|
||||
// Air: 0,
|
||||
// Inventory: 0,
|
||||
// IsInactive: false,
|
||||
// CustomFields: [{ Key: "String", Value: "String", Type: "String" }],
|
||||
// FloorPlanCode: "String",
|
||||
// FloorPlanAmount: 0,
|
||||
// Insurance: {
|
||||
// Company: "String",
|
||||
// Policy: "String",
|
||||
// ExpiryDate: "0001-01-01T00:00:00.0000000Z",
|
||||
// AgentName: "String",
|
||||
// AgentPhoneNumber: "String",
|
||||
// },
|
||||
// Body: "String",
|
||||
// ShortVIN: "String",
|
||||
// AdditionalDrivers: ["00000000000000000000000000000000"],
|
||||
// OrderDetails: { Distributor: "String" },
|
||||
// PrimaryImageRef: "00000000000000000000000000000000",
|
||||
// Hold: {
|
||||
// VehicleRef: "00000000000000000000000000000000",
|
||||
// HoldFrom: "0001-01-01T00:00:00.0000000Z",
|
||||
// HoldUntil: "0001-01-01T00:00:00.0000000Z",
|
||||
// UserRef: "00000000000000000000000000000000",
|
||||
// ContactRef: "00000000000000000000000000000000",
|
||||
// Comments: "String",
|
||||
// },
|
||||
// SeatingCapacity: "String",
|
||||
// DeliveryDate: "0001-01-01T00:00:00.0000000Z",
|
||||
// WarrantyExpiry: "0001-01-01T00:00:00.0000000Z",
|
||||
// IsConditionallySold: false,
|
||||
// SalesDivision: 0,
|
||||
// StyleRef: "String",
|
||||
},
|
||||
IsAsynchronous: false,
|
||||
// UserRequest: "String",
|
||||
// UserRef: "00000000000000000000000000000000",
|
||||
},
|
||||
{ auth: PBS_CREDENTIALS }
|
||||
);
|
||||
CheckForErrors(socket, VehicleChangeResponse);
|
||||
return VehicleChangeResponse;
|
||||
} catch (error) {
|
||||
CdkBase.createLogEvent(
|
||||
socket,
|
||||
"ERROR",
|
||||
`Error in UpsertVehicleData - ${error}`
|
||||
);
|
||||
throw new Error(error);
|
||||
}
|
||||
}
|
||||
|
||||
@@ -239,6 +239,94 @@ query QUERY_JOBS_FOR_CDK_EXPORT($id: uuid!) {
|
||||
}
|
||||
}
|
||||
|
||||
}
|
||||
`;
|
||||
|
||||
exports.QUERY_JOBS_FOR_PBS_EXPORT = `
|
||||
query QUERY_JOBS_FOR_PBS_EXPORT($id: uuid!) {
|
||||
jobs_by_pk(id: $id) {
|
||||
id
|
||||
job_totals
|
||||
date_invoiced
|
||||
ro_number
|
||||
clm_total
|
||||
clm_no
|
||||
invoice_allocation
|
||||
ownerid
|
||||
ownr_ln
|
||||
ownr_fn
|
||||
ownr_addr1
|
||||
ownr_addr2
|
||||
ownr_ph1
|
||||
ownr_ph2
|
||||
ownr_zip
|
||||
ownr_city
|
||||
ownr_ctry
|
||||
ownr_st
|
||||
ownr_ea
|
||||
ins_co_nm
|
||||
job_totals
|
||||
rate_la1
|
||||
rate_la2
|
||||
rate_la3
|
||||
rate_la4
|
||||
rate_laa
|
||||
rate_lab
|
||||
rate_lad
|
||||
rate_lae
|
||||
rate_laf
|
||||
rate_lag
|
||||
rate_lam
|
||||
rate_lar
|
||||
rate_las
|
||||
rate_lau
|
||||
rate_ma2s
|
||||
rate_ma2t
|
||||
rate_ma3s
|
||||
rate_mabl
|
||||
rate_macs
|
||||
rate_mahw
|
||||
rate_mapa
|
||||
rate_mash
|
||||
rate_matd
|
||||
class
|
||||
ca_bc_pvrt
|
||||
plate_no
|
||||
plate_st
|
||||
v_vin
|
||||
v_model_yr
|
||||
v_model_desc
|
||||
v_make_desc
|
||||
v_color
|
||||
ca_customer_gst
|
||||
bodyshop {
|
||||
id
|
||||
md_ro_statuses
|
||||
md_responsibility_centers
|
||||
accountingconfig
|
||||
pbs_serialnumber
|
||||
pbs_configuration
|
||||
}
|
||||
owner {
|
||||
id
|
||||
accountingid
|
||||
}
|
||||
joblines(where:{removed: {_eq:false}}) {
|
||||
id
|
||||
line_desc
|
||||
part_type
|
||||
act_price
|
||||
mod_lb_hrs
|
||||
mod_lbr_ty
|
||||
part_qty
|
||||
op_code_desc
|
||||
profitcenter_labor
|
||||
profitcenter_part
|
||||
db_ref
|
||||
prt_dsmk_p
|
||||
}
|
||||
}
|
||||
|
||||
}
|
||||
`;
|
||||
|
||||
|
||||
@@ -17,7 +17,7 @@ const CdkCalculateAllocations =
|
||||
require("../cdk/cdk-calculate-allocations").default;
|
||||
const { isArray } = require("lodash");
|
||||
const logger = require("../utils/logger");
|
||||
const PbsExportJob = require("../accounting/pbs/pbs-job-export");
|
||||
const PbsExportJob = require("../accounting/pbs/pbs-job-export").default;
|
||||
|
||||
io.use(function (socket, next) {
|
||||
try {
|
||||
@@ -99,6 +99,17 @@ io.on("connection", (socket) => {
|
||||
//END CDK
|
||||
|
||||
//PBS
|
||||
socket.on("pbs-calculate-allocations", async (jobid, callback) => {
|
||||
const allocations = await CdkCalculateAllocations(socket, jobid);
|
||||
createLogEvent(socket, "DEBUG", `Allocations calculated.`);
|
||||
createLogEvent(
|
||||
socket,
|
||||
"TRACE",
|
||||
`Allocations calculated. ${JSON.stringify(allocations, null, 2)}`
|
||||
);
|
||||
|
||||
callback(allocations);
|
||||
});
|
||||
socket.on("pbs-export-job", (jobid) => {
|
||||
PbsExportJob(socket, jobid);
|
||||
});
|
||||
|
||||
Reference in New Issue
Block a user