diff --git a/server/integrations/partsManagement/partsManagementVehicleDamageEstimateAddRq.js b/server/integrations/partsManagement/partsManagementVehicleDamageEstimateAddRq.js index 4ffe37546..2eadc17ee 100644 --- a/server/integrations/partsManagement/partsManagementVehicleDamageEstimateAddRq.js +++ b/server/integrations/partsManagement/partsManagementVehicleDamageEstimateAddRq.js @@ -16,20 +16,6 @@ const INSERT_JOB_WITH_LINES = ` } `; -const INSERT_PARTS_ORDERS = ` - mutation InsertPartsOrders($po: [parts_orders_insert_input!]!) { - insert_parts_orders(objects: $po) { - returning { id order_number } - } - } -`; - -/** - * Handles incoming VehicleDamageEstimateAddRq XML, - * parses every known field (including estimator, adjuster, - * repair facility), nests Vehicle and JobLines inserts, - * then any PartsOrders (grouped per SupplierRefNum). - */ const partsManagementVehicleDamageEstimateAddRq = async (req, res) => { const { logger } = req; const xml = req.body; @@ -91,10 +77,7 @@ const partsManagementVehicleDamageEstimateAddRq = async (req, res) => { const clm_total = parseFloat(ci.Cieca_ttl || 0); // ── ADMIN / OWNER INFO ────────────────────────────────────────────────────── - const admin = rq.AdminInfo || {}; - - // Owner - const ownerParty = admin.Owner?.Party || {}; + const ownerParty = rq.AdminInfo?.Owner?.Party || {}; const ownr_fn = ownerParty.PersonInfo?.PersonName?.FirstName || null; const ownr_ln = ownerParty.PersonInfo?.PersonName?.LastName || null; const ownr_co_nm = ownerParty.OrgInfo?.CompanyName || null; @@ -123,135 +106,32 @@ const partsManagementVehicleDamageEstimateAddRq = async (req, res) => { }); const preferred_contact = ownerParty.PreferredContactMethod || null; - // Estimator → map to est_… fields - const estParty = admin.Estimator?.Party || {}; - const est_fn = estParty.PersonInfo?.PersonName?.FirstName || null; - const est_ln = estParty.PersonInfo?.PersonName?.LastName || null; - const est_aff = admin.Estimator?.Affiliation || null; - const estComms = estParty.ContactInfo?.Communications - ? Array.isArray(estParty.ContactInfo.Communications) - ? estParty.ContactInfo.Communications - : [estParty.ContactInfo.Communications] - : []; - const est_ea = estComms.find((c) => c.CommQualifier === "EM")?.CommEmail || null; - - // Adjuster → map to agt_… fields - const adjParty = admin.Adjuster?.Party || {}; - const agt_ct_fn = adjParty.PersonInfo?.PersonName?.FirstName || null; - const agt_ct_ln = adjParty.PersonInfo?.PersonName?.LastName || null; - const adjComms = adjParty.ContactInfo?.Communications - ? Array.isArray(adjParty.ContactInfo.Communications) - ? adjParty.ContactInfo.Communications - : [adjParty.ContactInfo.Communications] - : []; - const agt_ct_ph = adjComms.find((c) => c.CommQualifier === "CP")?.CommPhone || null; - const agt_ea = adjComms.find((c) => c.CommQualifier === "EM")?.CommEmail || null; - - // Repair Facility → map to servicing_dealer, servicing_dealer_contact - const rfParty = admin.RepairFacility?.Party || {}; - const servicing_dealer = rfParty.OrgInfo?.CompanyName || null; - const rfAdr = rfParty.OrgInfo?.Communications?.Address || {}; - const servicing_dealer_addr1 = rfAdr.Address1 || null; - const servicing_dealer_city = rfAdr.City || null; - const servicing_dealer_st = rfAdr.StateProvince || null; - // const servicing_dealer_zip = rfAdr.PostalCode || null; - // const servicing_dealer_ctry = rfAdr.Country || null; - const rfComms = rfParty.ContactInfo?.Communications - ? Array.isArray(rfParty.ContactInfo.Communications) - ? rfParty.ContactInfo.Communications - : [rfParty.ContactInfo.Communications] - : []; - const servicing_dealer_contact = - rfComms.find((c) => c.CommQualifier === "WP")?.CommPhone || - rfComms.find((c) => c.CommQualifier === "FX")?.CommPhone || - null; - // ── VEHICLE INFO (nested relationship) ────────────────────────────────────── - const vin = rq.VehicleInfo?.VINInfo?.VINNum || null; - const plate_no = rq.VehicleInfo?.License?.LicensePlateNum || null; - const plate_st = rq.VehicleInfo?.License?.LicensePlateStateProvince || null; const desc = rq.VehicleInfo?.VehicleDesc || {}; - const v_model_yr = desc.ModelYear || null; - const v_make_desc = desc.MakeDesc || null; - const v_model_desc = desc.ModelName || null; - const v_color = rq.VehicleInfo?.Paint?.Exterior?.ColorName || null; - const body_style = desc.BodyStyle || null; - const engine_desc = desc.EngineDesc || null; - const production_date = desc.ProductionDate || null; - const v_options = desc.SubModelDesc || null; - const v_type = desc.FuelType || null; - const driveable = rq.VehicleInfo?.Condition?.DrivableInd === "Y"; - const vehicleData = { shopid: shopId, - // vin, - plate_no, - plate_st - // year: v_model_yr, - // make: v_make_desc - // model: v_model_desc - // color: v_color, - // bstyle: body_style, - // engine: engine_desc - // prod_dt: production_date, - // options: v_options, - // type: v_type, - // condition: driveable + plate_no: rq.VehicleInfo?.License?.LicensePlateNum || null, + plate_st: rq.VehicleInfo?.License?.LicensePlateStateProvince || null }; - // ── PROFILE & RATES ───────────────────────────────────────────────────────── - const rateInfos = rq.ProfileInfo?.RateInfo - ? Array.isArray(rq.ProfileInfo.RateInfo) - ? rq.ProfileInfo.RateInfo - : [rq.ProfileInfo.RateInfo] - : []; - const rates = {}, - rateTier = {}, - materialCalc = {}; - rateInfos.forEach((r) => { - if (!r.RateType) return; - const t = r.RateType.toLowerCase(); - if (r.Rate) rates[`rate_${t}`] = parseFloat(r.Rate) || 0; - if (r.RateTierInfo) { - const tiers = Array.isArray(r.RateTierInfo) ? r.RateTierInfo : [r.RateTierInfo]; - rateTier[t] = tiers.map((ti) => ({ - tier: ti.TierNum, - pct: parseFloat(ti.Percentage) || 0 - })); - } - if (r.MaterialCalcSettings) { - materialCalc[t] = r.MaterialCalcSettings; - } - }); - // ── DAMAGE LINES → joblinesData ──────────────────────────────────────────── const damageLines = Array.isArray(rq.DamageLineInfo) ? rq.DamageLineInfo : [rq.DamageLineInfo]; const joblinesData = damageLines.map((line) => ({ line_no: parseInt(line.LineNum, 10), unq_seq: parseInt(line.UniqueSequenceNum, 10), - manual_line: line.ManualLineInd === "1", - // automated_entry: line.AutomatedEntry === "1", - // desc_judgment_ind: line.DescJudgmentInd === "1", status: line.LineStatusCode || null, line_desc: line.LineDesc || null, - // parts + // parts (only fields for jobline table) part_type: line.PartInfo?.PartType || null, part_qty: parseInt(line.PartInfo?.Quantity || 0, 10), db_price: parseFloat(line.PartInfo?.PartPrice || 0), act_price: parseFloat(line.PartInfo?.PartPrice || 0), oem_partno: line.PartInfo?.OEMPartNum || null, - - // non-OEM → not persisted at jobline level - - // after_market_usage: line.PartInfo?.AfterMarketUsage || null, - // certification_type: line.PartInfo?.CertificationType || null, - // certification_type: line.PartInfo?.CertificationType || null, tax_part: line.PartInfo?.TaxableInd === "1", glass_flag: line.PartInfo?.GlassPartInd === "1", price_j: line.PriceJudgmentInd === "1", price_inc: line.PriceInclInd === "1", - // order_by_application_ind: String(line.PartInfo?.OrderByApplicationInd).toLowerCase() === "true", // labor mod_lbr_ty: line.LaborInfo?.LaborType || null, @@ -259,7 +139,6 @@ const partsManagementVehicleDamageEstimateAddRq = async (req, res) => { lbr_op: line.LaborInfo?.LaborOperation || null, lbr_amt: parseFloat(line.LaborInfo?.LaborAmt || 0), - // parent_line_no: line.ParentLineNum ? parseInt(line.ParentLineNum, 10) : null, notes: line.LineMemo || null })); @@ -267,13 +146,11 @@ const partsManagementVehicleDamageEstimateAddRq = async (req, res) => { const jobInput = { shopid: shopId, ro_number: RefClaimNum, - clm_no, status, clm_total, policy_no, ded_amt, - comment, date_exported, asgn_no, @@ -297,34 +174,13 @@ const partsManagementVehicleDamageEstimateAddRq = async (req, res) => { ownr_ea, // preferred_contact, - // est_co_id: est_aff, - est_ct_fn: est_fn, - est_ct_ln: est_ln, - est_ea, - - agt_ct_fn, - agt_ct_ln, - agt_ct_ph, - agt_ea, - - servicing_dealer, - // servicing_dealer_addr1, - // servicing_dealer_city, - // servicing_dealer_st, - // servicing_dealer_zip, - // servicing_dealer_ctry, - servicing_dealer_contact, - - // ...rates, + // nest vehicle & joblines + vehicle: { data: vehicleData }, + joblines: { data: joblinesData }, production_vars: { - documentVersions, - rateTier, - materialCalc - }, - - vehicle: { data: vehicleData }, - joblines: { data: joblinesData } + documentVersions + } }; logger.log("parts-insert-job", "debug", null, null, { jobInput }); @@ -332,69 +188,18 @@ const partsManagementVehicleDamageEstimateAddRq = async (req, res) => { const jobId = newJob.id; logger.log("parts-job-created", "info", jobId, null); - // ── BUILD & INSERT PARTS ORDERS ──────────────────────────────────────────── + /* + // ── PARTS ORDERS ───────────────────────────────────────────────────────── + // The integration no longer requires parts_orders, + // all related logic is commented out. + const seqToId = newJob.joblines.reduce((map, ln) => { map[ln.unq_seq] = ln.id; return map; }, {}); - const currentDate = new Date().toISOString().slice(0, 10); - // TODO: we should not need to capture the order status from the XML, - const defaultStatus = process.env.DEFAULT_PARTS_ORDER_STATUS || ""; - - // TODO: This will be the username of the bodyshop user used for the integration. - const userEmail = req.headers["x-hasura-user-id"] || "system@example.com"; - - // group by vendor - const poGroups = {}; - damageLines.forEach((line) => { - const pt = line.PartInfo?.PartType; - const qty = parseInt(line.PartInfo?.Quantity || 0, 10); - if (["PAN", "PAC", "PAM", "PAA"].includes(pt) && qty > 0) { - // TODO: We should not need to capture the vendor ID from the XML - const vid = line.PartInfo?.NonOEM?.SupplierRefNum || process.env.DEFAULT_VENDOR_ID || null; - (poGroups[vid] = poGroups[vid] || []).push({ - line, - unq_seq: parseInt(line.UniqueSequenceNum, 10) - }); - } - }); - - const partsOrders = Object.entries(poGroups).map(([vendorid, entries]) => ({ - jobid: jobId, - vendorid, - order_number: `${entries[0].line.LineNum}`, - order_date: currentDate, - orderedby: "XML-API", - user_email: userEmail, - status: defaultStatus, - parts_order_lines: { - data: entries.map(({ line, unq_seq }) => { - const pi = line.PartInfo || {}; - const nonOEM = pi.NonOEM || {}; - return { - job_line_id: seqToId[unq_seq], - line_desc: line.LineDesc || null, - oem_partno: pi.OEMPartNum || null, - db_price: parseFloat(pi.PartPrice || 0), - act_price: parseFloat(pi.PartPrice || 0), - line_remarks: line.LineMemo || null, - quantity: parseInt(pi.Quantity || 1, 10), - part_type: pi.PartType || null, - cost: nonOEM.NonOEMPartPrice ? parseFloat(nonOEM.NonOEMPartPrice) : null, - cm_received: null - }; - }) - } - })); - - if (partsOrders.length) { - logger.log("parts-insert-orders", "debug", null, null, { - partsOrders - }); - await client.request(INSERT_PARTS_ORDERS, { po: partsOrders }); - logger.log("parts-orders-created", "info", jobId, null); - } + // ... grouping logic and mutation calls removed ... + */ return res.status(200).json({ success: true, jobId }); } catch (err) {