PBS Improvements.
This commit is contained in:
@@ -65,7 +65,11 @@ exports.default = async function (socket, { txEnvelope, jobid }) {
|
|||||||
|
|
||||||
const JobData = await QueryJobData(socket, jobid);
|
const JobData = await QueryJobData(socket, jobid);
|
||||||
socket.JobData = JobData;
|
socket.JobData = JobData;
|
||||||
|
CdkBase.createLogEvent(
|
||||||
|
socket,
|
||||||
|
"DEBUG",
|
||||||
|
`Querying the DMS for the Vehicle Record.`
|
||||||
|
);
|
||||||
//Query for the Vehicle record to get the associated customer.
|
//Query for the Vehicle record to get the associated customer.
|
||||||
socket.DmsVeh = await QueryVehicleFromDms(socket);
|
socket.DmsVeh = await QueryVehicleFromDms(socket);
|
||||||
//Todo: Need to validate the lines and methods below.
|
//Todo: Need to validate the lines and methods below.
|
||||||
@@ -121,7 +125,11 @@ exports.PbsSelectedCustomer = async function PbsSelectedCustomer(
|
|||||||
);
|
);
|
||||||
await UpsertVehicleData(socket, ownerRef.ReferenceId);
|
await UpsertVehicleData(socket, ownerRef.ReferenceId);
|
||||||
CdkBase.createLogEvent(socket, "DEBUG", `Inserting account data.`);
|
CdkBase.createLogEvent(socket, "DEBUG", `Inserting account data.`);
|
||||||
|
CdkBase.createLogEvent(
|
||||||
|
socket,
|
||||||
|
"DEBUG",
|
||||||
|
`Inserting accounting posting data..`
|
||||||
|
);
|
||||||
await InsertAccountPostingData(socket);
|
await InsertAccountPostingData(socket);
|
||||||
|
|
||||||
CdkBase.createLogEvent(socket, "DEBUG", `Marking job as exported.`);
|
CdkBase.createLogEvent(socket, "DEBUG", `Marking job as exported.`);
|
||||||
|
|||||||
@@ -174,23 +174,22 @@ function createJsonEvent(socket, level, message, json) {
|
|||||||
level,
|
level,
|
||||||
message,
|
message,
|
||||||
});
|
});
|
||||||
|
|
||||||
logger.log("ws-log-event-json", level, socket.user.email, socket.recordid, {
|
|
||||||
wsmessage: message,
|
|
||||||
json
|
|
||||||
});
|
|
||||||
|
|
||||||
if (socket.logEvents && isArray(socket.logEvents)) {
|
|
||||||
socket.logEvents.push({
|
|
||||||
timestamp: new Date(),
|
|
||||||
level,
|
|
||||||
message,
|
|
||||||
});
|
|
||||||
}
|
|
||||||
// if (level === "ERROR") {
|
|
||||||
// throw new Error(message);
|
|
||||||
// }
|
|
||||||
}
|
}
|
||||||
|
logger.log("ws-log-event-json", level, socket.user.email, socket.recordid, {
|
||||||
|
wsmessage: message,
|
||||||
|
json,
|
||||||
|
});
|
||||||
|
|
||||||
|
if (socket.logEvents && isArray(socket.logEvents)) {
|
||||||
|
socket.logEvents.push({
|
||||||
|
timestamp: new Date(),
|
||||||
|
level,
|
||||||
|
message,
|
||||||
|
});
|
||||||
|
}
|
||||||
|
// if (level === "ERROR") {
|
||||||
|
// throw new Error(message);
|
||||||
|
// }
|
||||||
}
|
}
|
||||||
|
|
||||||
function createXmlEvent(socket, xml, message, isError = false) {
|
function createXmlEvent(socket, xml, message, isError = false) {
|
||||||
|
|||||||
Reference in New Issue
Block a user