Merged in release/2025-02-28 (pull request #2125)
release/2025-02-28 Approved-by: Patrick Fic
This commit is contained in:
@@ -25,10 +25,6 @@ async function OpenSearchUpdateHandler(req, res) {
|
|||||||
|
|
||||||
switch (req.body.table.name) {
|
switch (req.body.table.name) {
|
||||||
case "jobs":
|
case "jobs":
|
||||||
logger.log("os-handler-jobs", "DEBUG", req.user.email, null, {
|
|
||||||
jobid: req.body.event.data.new.id,
|
|
||||||
bodyshopid: req.body.event.data.new.shopid
|
|
||||||
});
|
|
||||||
document = pick(req.body.event.data.new, [
|
document = pick(req.body.event.data.new, [
|
||||||
"id",
|
"id",
|
||||||
"bodyshopid",
|
"bodyshopid",
|
||||||
@@ -53,10 +49,6 @@ async function OpenSearchUpdateHandler(req, res) {
|
|||||||
document.bodyshopid = req.body.event.data.new.shopid;
|
document.bodyshopid = req.body.event.data.new.shopid;
|
||||||
break;
|
break;
|
||||||
case "vehicles":
|
case "vehicles":
|
||||||
logger.log("os-handler-vehicles", "DEBUG", req.user.email, null, {
|
|
||||||
vehicleid: req.body.event.data.new.id,
|
|
||||||
bodyshopid: req.body.event.data.new.shopid
|
|
||||||
});
|
|
||||||
document = pick(req.body.event.data.new, [
|
document = pick(req.body.event.data.new, [
|
||||||
"id",
|
"id",
|
||||||
"v_model_yr",
|
"v_model_yr",
|
||||||
@@ -69,10 +61,6 @@ async function OpenSearchUpdateHandler(req, res) {
|
|||||||
document.bodyshopid = req.body.event.data.new.shopid;
|
document.bodyshopid = req.body.event.data.new.shopid;
|
||||||
break;
|
break;
|
||||||
case "owners":
|
case "owners":
|
||||||
logger.log("os-handler-owners", "DEBUG", req.user.email, null, {
|
|
||||||
ownerid: req.body.event.data.new.id,
|
|
||||||
bodyshopid: req.body.event.data.new.shopid
|
|
||||||
});
|
|
||||||
document = pick(req.body.event.data.new, ["id", "ownr_fn", "ownr_ln", "ownr_co_nm", "ownr_ph1", "ownr_ph2"]);
|
document = pick(req.body.event.data.new, ["id", "ownr_fn", "ownr_ln", "ownr_co_nm", "ownr_ph1", "ownr_ph2"]);
|
||||||
document.bodyshopid = req.body.event.data.new.shopid;
|
document.bodyshopid = req.body.event.data.new.shopid;
|
||||||
break;
|
break;
|
||||||
@@ -108,11 +96,6 @@ async function OpenSearchUpdateHandler(req, res) {
|
|||||||
...bill.bills_by_pk,
|
...bill.bills_by_pk,
|
||||||
bodyshopid: bill.bills_by_pk.job.shopid
|
bodyshopid: bill.bills_by_pk.job.shopid
|
||||||
};
|
};
|
||||||
|
|
||||||
logger.log("os-handler-bills", "DEBUG", req.user.email, null, {
|
|
||||||
billid: req.body.event.data.new.id,
|
|
||||||
bodyshopid: bill.bills_by_pk.job.shopid
|
|
||||||
});
|
|
||||||
break;
|
break;
|
||||||
case "payments":
|
case "payments":
|
||||||
//Query to get the job and RO number
|
//Query to get the job and RO number
|
||||||
@@ -157,10 +140,6 @@ async function OpenSearchUpdateHandler(req, res) {
|
|||||||
...payment.payments_by_pk,
|
...payment.payments_by_pk,
|
||||||
bodyshopid: payment.payments_by_pk.job.shopid
|
bodyshopid: payment.payments_by_pk.job.shopid
|
||||||
};
|
};
|
||||||
logger.log("os-handler-payments", "DEBUG", req.user.email, null, {
|
|
||||||
paymentid: req.body.event.data.new.id,
|
|
||||||
bodyshopid: payment.payments_by_pk.job.shopid
|
|
||||||
});
|
|
||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
const payload = {
|
const payload = {
|
||||||
@@ -169,6 +148,13 @@ async function OpenSearchUpdateHandler(req, res) {
|
|||||||
body: document
|
body: document
|
||||||
};
|
};
|
||||||
|
|
||||||
|
logger.log("os-handler", "DEBUG", req.user.email, null, {
|
||||||
|
id: req.body.event.data.new.id,
|
||||||
|
index: req.body.table.name,
|
||||||
|
bodyshopid: payload.body.bodyshopid
|
||||||
|
// body: document
|
||||||
|
});
|
||||||
|
|
||||||
const response = await osClient.index(payload);
|
const response = await osClient.index(payload);
|
||||||
//console.log(response.body);
|
//console.log(response.body);
|
||||||
res.status(200).json(response.body);
|
res.status(200).json(response.body);
|
||||||
|
|||||||
Reference in New Issue
Block a user