From af5e4d202bd95f549892b32f1c09653ca40e7945 Mon Sep 17 00:00:00 2001 From: Paul Trowbridge Date: Thu, 7 Aug 2025 23:35:09 -0400 Subject: [PATCH] bring func up to speed --- .../procs/single_price_call_func.ms.sql | 557 +++++++++--------- 1 file changed, 282 insertions(+), 275 deletions(-) diff --git a/new_targets/procs/single_price_call_func.ms.sql b/new_targets/procs/single_price_call_func.ms.sql index 5fa676a..1187fe6 100644 --- a/new_targets/procs/single_price_call_func.ms.sql +++ b/new_targets/procs/single_price_call_func.ms.sql @@ -1,228 +1,230 @@ -DROP FUNCTION pricing.single_price_call_fn; +DROP FUNCTION IF EXISTS pricing.single_price_call_fn; +GO CREATE FUNCTION pricing.single_price_call_fn ( - @bill VARCHAR(100), - @ship VARCHAR(100), - @part VARCHAR(100), - @v1ds VARCHAR(100), - @vol NUMERIC(18,6) + @bill VARCHAR(100), + @ship VARCHAR(100), + @part VARCHAR(100), + @v1ds VARCHAR(100), + @vol NUMERIC(18,6) ) RETURNS @queue TABLE ( - bill VARCHAR(100), - ship VARCHAR(100), - part VARCHAR(100), - stlc VARCHAR(100), - v1ds VARCHAR(100), - vol NUMERIC(18,6), - chan VARCHAR(50), - cust VARCHAR(100), - tier VARCHAR(50), - pltq NUMERIC(18,6), - volume_range TEXT, - plevel NVARCHAR(20), - listprice NUMERIC(20,5), - listcode VARCHAR(10), - hist NVARCHAR(MAX), - last_price NUMERIC(20,5), - last_date DATE, - last_order NVARCHAR(10), - last_quote NVARCHAR(10), - tprice NUMERIC(20,5), - guidance_price NUMERIC(20,5), - guidance_reason NVARCHAR(MAX), - expl NVARCHAR(MAX), - ui_json NVARCHAR(MAX) + bill VARCHAR(100), + ship VARCHAR(100), + part VARCHAR(100), + stlc VARCHAR(100), + v1ds VARCHAR(100), + vol NUMERIC(18,6), + chan VARCHAR(50), + cust VARCHAR(100), + tier VARCHAR(50), + pltq NUMERIC(18,6), + volume_range TEXT, + plevel NVARCHAR(20), + listprice NUMERIC(20,5), + listcode VARCHAR(10), + hist NVARCHAR(MAX), + last_price NUMERIC(20,5), + last_date DATE, + last_order NVARCHAR(10), + last_quote NVARCHAR(10), + tprice NUMERIC(20,5), + tmath NVARCHAR(MAX), + guidance_price NUMERIC(20,5), + guidance_reason NVARCHAR(MAX), + expl NVARCHAR(MAX), + ui_json NVARCHAR(MAX), + partgroup VARCHAR(100) ) AS BEGIN - -------------------------------------------------------------------------------- - -- Step 1: Seed the queue with input row - -------------------------------------------------------------------------------- - INSERT INTO @queue (bill, ship, part, v1ds, vol, expl) - VALUES (@bill, @ship, @part, @v1ds, @vol, '{}'); + -------------------------------------------------------------------------------- + -- Step 1: Seed the queue with input row + -------------------------------------------------------------------------------- + INSERT INTO @queue (bill, ship, part, v1ds, vol, expl) + VALUES (@bill, @ship, @part, @v1ds, @vol, '{}'); - -------------------------------------------------------------------------------- - -- Step 2: Enrich with channel, tier, customer, pack quantity, and price level - -------------------------------------------------------------------------------- - UPDATE q - SET - chan = - CASE SUBSTRING(bc.cclass, 2, 3) - WHEN 'DIS' THEN - CASE SUBSTRING(sc.cclass, 2, 3) - WHEN 'DIS' THEN 'WHS' - ELSE 'DRP' - END - ELSE 'DIR' - END, - tier = - CASE SUBSTRING(bc.cclass, 2, 3) - WHEN 'DIR' THEN bc.tier - ELSE ISNULL(sc.tier, bc.tier) - END, - cust = - CASE SUBSTRING(bc.cclass, 2, 3) - WHEN 'DIS' THEN - CASE SUBSTRING(sc.cclass, 2, 3) - WHEN 'DIS' THEN bc.dba - ELSE sc.dba - END - ELSE q.bill - END, - pltq = i.mpck, - plevel = - CASE SUBSTRING(bc.cclass, 2, 3) - WHEN 'DIS' THEN - CASE SUBSTRING(sc.cclass, 2, 3) - WHEN 'DIS' THEN sc.plevel - ELSE bc.plevel - END - ELSE bc.plevel - END, - stlc = substring(q.part,1,8) - FROM @queue q - LEFT JOIN rlarp.cust bc ON bc.code = q.bill - LEFT JOIN rlarp.cust sc ON sc.code = q.ship - LEFT JOIN CMSInterfaceIn.[CMS.CUSLG].itemm i ON i.item = q.part; + -------------------------------------------------------------------------------- + -- Step 2: Enrich with channel, tier, customer, pack quantity, and price level + -------------------------------------------------------------------------------- + UPDATE q + SET + chan = + CASE SUBSTRING(bc.cclass, 2, 3) + WHEN 'DIS' THEN + CASE SUBSTRING(sc.cclass, 2, 3) + WHEN 'DIS' THEN 'WHS' + ELSE 'DRP' + END + ELSE 'DIR' + END, + tier = + CASE SUBSTRING(bc.cclass, 2, 3) + WHEN 'DIR' THEN bc.tier + ELSE ISNULL(sc.tier, bc.tier) + END, + cust = + CASE SUBSTRING(bc.cclass, 2, 3) + WHEN 'DIS' THEN + CASE SUBSTRING(sc.cclass, 2, 3) + WHEN 'DIS' THEN bc.dba + ELSE sc.dba + END + ELSE q.bill + END, + pltq = i.mpck, + plevel = + CASE SUBSTRING(bc.cclass, 2, 3) + WHEN 'DIS' THEN + CASE SUBSTRING(sc.cclass, 2, 3) + WHEN 'DIS' THEN sc.plevel + ELSE bc.plevel + END + ELSE bc.plevel + END, + stlc = substring(q.part,1,8), + partgroup = i.partgroup + FROM @queue q + LEFT JOIN rlarp.cust bc ON bc.code = q.bill + LEFT JOIN rlarp.cust sc ON sc.code = q.ship + LEFT JOIN CMSInterfaceIn.[CMS.CUSLG].itemm i ON i.item = q.part; - -------------------------------------------------------------------------------- - -- Step 3: Apply target price and embed metadata as JSON - -------------------------------------------------------------------------------- - UPDATE q - SET - tprice = tp.price, - expl = ( - SELECT - 'target price' AS [source], - tp.price AS [target_price], - FLOOR(q.vol / NULLIF(q.pltq, 0)) AS [calculated_pallets], - CAST(ROUND(q.vol / NULLIF(q.pltq, 0), 5) AS NUMERIC(20,5)) AS [exact_pallets], - CONCAT(tp.lower_bound, '-', ISNULL(CAST(tp.upper_bound AS VARCHAR), '∞')) AS [volume_range], - q.cust AS [customer], - q.chan AS [channel], - TRIM(q.tier) AS [tier], - JSON_QUERY(tp.math) AS [target_math] - FOR JSON PATH, WITHOUT_ARRAY_WRAPPER - ), - volume_range = CONCAT(tp.lower_bound, '-', ISNULL(CAST(tp.upper_bound AS VARCHAR), '∞')) - FROM @queue q - INNER JOIN pricing.target_prices tp ON - q.stlc = tp.stlc - AND q.v1ds = tp.ds - AND q.chan = tp.chan - AND q.tier = tp.tier - AND FLOOR(q.vol / NULLIF(q.pltq, 0)) >= tp.lower_bound - AND ( - tp.upper_bound IS NULL OR FLOOR(q.vol / NULLIF(q.pltq, 0)) < tp.upper_bound - ); + -------------------------------------------------------------------------------- + -- Step 3: Apply target price and embed metadata as JSON + -------------------------------------------------------------------------------- + UPDATE q + SET + tprice = tp.price + ,tmath = JSON_QUERY(tp.math) + ,volume_range = CONCAT(tp.lower_bound, '-', ISNULL(CAST(tp.upper_bound AS VARCHAR), '∞')) + FROM @queue q + INNER JOIN pricing.target_prices tp ON + q.stlc = tp.stlc + AND q.v1ds = tp.ds + AND q.chan = tp.chan + AND q.tier = tp.tier + AND FLOOR(q.vol / NULLIF(q.pltq, 0)) >= tp.lower_bound + AND ( + tp.upper_bound IS NULL OR FLOOR(q.vol / NULLIF(q.pltq, 0)) < tp.upper_bound + ); - -------------------------------------------------------------------------------- - -- Step 4: Pull last sale data and embed in columns and JSON - -------------------------------------------------------------------------------- - UPDATE q - SET - hist = JSON_MODIFY('{}', '$.full_history', JSON_QUERY(lp.part_stats)), - last_price = j.price, - last_date = j.odate, - last_order = j.ordnum, - last_quote = j.quoten, - expl = JSON_MODIFY( - JSON_MODIFY( - JSON_MODIFY( - JSON_MODIFY( - ISNULL(q.expl, '{}'), - '$.last_price', j.price - ), - '$.last_date', CONVERT(NVARCHAR(10), j.odate, 23) - ), - '$.last_order', j.ordnum - ), - '$.last_quote', j.quoten - ) - FROM @queue q - JOIN pricing.lastprice lp - ON lp.customer = q.cust - AND lp.mold = SUBSTRING(q.part, 1, 8) - OUTER APPLY ( - SELECT TOP 1 * - FROM OPENJSON(lp.part_stats) AS p - OUTER APPLY OPENJSON(p.value) - WITH ( - qty NUMERIC(20,5), - price NUMERIC(20,5), - odate DATE, - ordnum INT, - quoten INT - ) AS j - WHERE p.[key] COLLATE SQL_Latin1_General_CP1_CI_AS = q.part - ORDER BY j.odate DESC - ) AS j; + -------------------------------------------------------------------------------- + -- Step 4: Pull last sale data and embed in columns and JSON + -------------------------------------------------------------------------------- + UPDATE q + SET + hist = lp.part_stats + FROM @queue q + JOIN pricing.lastpricedetail lp + ON lp.customer = q.cust AND lp.partgroup = q.partgroup; + + -------------------------------------------------------------------------------- + -- Step 4b.1: Populate composite fields from precedence chain using JSON-based helper + -------------------------------------------------------------------------------- + -- Use new helper to select best last price, source, and date directly from JSON + UPDATE q + SET + last_price = b.price, + last_source = b.source, + last_date = b.odate, + last_qty = b.qty, + last_dataseg = b.dataseg, + last_order = b.ord, + last_quote = b.quote + FROM @queue q + CROSS APPLY ( + SELECT TOP 1 price, source, odate, qty, dataseg, ord, quote + FROM pricing.pick_last_price_from_hist_json(q.hist, q.v1ds) + ) b; + + -------------------------------------------------------------------------------- + -- Step 4b.2: Build JSON explanation object from populated columns + -------------------------------------------------------------------------------- + UPDATE q + SET expl = ( + SELECT + q.last_price AS last_price, + q.last_qty AS last_qty, + q.last_dataseg AS last_dataseg, + q.last_source AS last_source, + FORMAT(q.last_date, 'yyyy-MM-dd') AS last_date, + q.tprice AS [target_price], + JSON_QUERY(q.tmath) AS [target_math], + FLOOR(q.vol / NULLIF(q.pltq, 0)) AS [calculated_pallets], + CAST(ROUND(q.vol / NULLIF(q.pltq, 0), 5) AS NUMERIC(20,5)) AS [exact_pallets], + q.cust AS [customer], + q.chan AS [channel], + TRIM(q.tier) AS [tier] + -- JSON_QUERY(hist) AS [history] + FOR JSON PATH, WITHOUT_ARRAY_WRAPPER + ) + FROM @queue q; - -------------------------------------------------------------------------------- - -- Step 5: Add list price info from external pricelist - -------------------------------------------------------------------------------- - WITH ranked_prices AS ( - SELECT - q.bill, q.ship, q.part, q.stlc, q.v1ds, q.vol, - CAST(p.price AS NUMERIC(20,5)) AS price, - p.jcplcd, - ROW_NUMBER() OVER ( - PARTITION BY q.bill, q.ship, q.part, q.stlc, q.v1ds, q.vol - ORDER BY p.price ASC - ) AS rn - FROM @queue q - INNER JOIN CMSInterfaceIn."CMS.CUSLG".IPRCBHC i - ON TRIM(i.jbplvl) = TRIM(q.plevel) - AND CAST(GETDATE() AS DATE) BETWEEN i.jbfdat AND i.jbtdat - INNER JOIN pricing.pricelist_ranged p - ON p.jcplcd = TRIM(i.jbplcd) - AND p.jcpart = q.part - AND q.vol >= p.vb_from - AND (p.vb_to IS NULL OR q.vol < p.vb_to) - ) - UPDATE q - SET expl = JSON_MODIFY( - JSON_MODIFY( - ISNULL(q.expl, '{}'), - '$.list_price', rp.price - ), - '$.list_code', rp.jcplcd - ) - ,listcode = rp.jcplcd - ,listprice = rp.price - FROM @queue q - JOIN ranked_prices rp - ON q.bill = rp.bill - AND q.ship = rp.ship - AND q.part = rp.part - AND q.stlc = rp.stlc - AND q.v1ds = rp.v1ds - AND q.vol = rp.vol - AND rp.rn = 1; - + -------------------------------------------------------------------------------- + -- Step 5: Add list price info from external pricelist + -------------------------------------------------------------------------------- + WITH ranked_prices AS ( + SELECT + q.bill, q.ship, q.part, q.stlc, q.v1ds, q.vol, + CAST(p.price AS NUMERIC(20,5)) AS price, + p.jcplcd, + ROW_NUMBER() OVER ( + PARTITION BY q.bill, q.ship, q.part, q.stlc, q.v1ds, q.vol + ORDER BY p.price ASC + ) AS rn + FROM @queue q + INNER JOIN CMSInterfaceIn."CMS.CUSLG".IPRCBHC i + ON TRIM(i.jbplvl) = TRIM(q.plevel) + AND CAST(GETDATE() AS DATE) BETWEEN i.jbfdat AND i.jbtdat + INNER JOIN pricing.pricelist_ranged p + ON p.jcplcd = TRIM(i.jbplcd) + AND p.jcpart = q.part + AND q.vol >= p.vb_from + AND (p.vb_to IS NULL OR q.vol < p.vb_to) + ) + UPDATE q + SET expl = JSON_MODIFY( + JSON_MODIFY( + ISNULL(q.expl, '{}'), + '$.list_price', rp.price + ), + '$.list_code', rp.jcplcd + ) + ,listcode = rp.jcplcd + ,listprice = rp.price + FROM @queue q + JOIN ranked_prices rp + ON q.bill = rp.bill + AND q.ship = rp.ship + AND q.part = rp.part + AND q.stlc = rp.stlc + AND q.v1ds = rp.v1ds + AND q.vol = rp.vol + AND rp.rn = 1; + -------------------------------------------------------------------------------- -- Step 6: Compute guidance price and logic, and embed in JSON -------------------------------------------------------------------------------- UPDATE q SET - guidance_price = g.guidance_price, - guidance_reason = g.guidance_reason, - expl = JSON_MODIFY( - JSON_MODIFY( - ISNULL(q.expl, '{}'), - '$.guidance_reason', - g.guidance_reason - ), - '$.guidance_price', - g.guidance_price - ) + guidance_price = g.guidance_price, + guidance_reason = g.guidance_reason, + expl = JSON_MODIFY( + JSON_MODIFY( + ISNULL(q.expl, '{}'), + '$.guidance_reason', + g.guidance_reason + ), + '$.guidance_price', + g.guidance_price + ) FROM @queue q CROSS APPLY pricing.guidance_logic( - CAST(JSON_VALUE(q.expl, '$.target_price') AS NUMERIC(20,5)), - CAST(JSON_VALUE(q.expl, '$.last_price') AS NUMERIC(20,5)), - CAST(JSON_VALUE(q.expl, '$.list_price') AS NUMERIC(20,5)), - CAST(JSON_VALUE(q.expl, '$.last_date') AS DATE) + CAST(JSON_VALUE(q.expl, '$.target_price') AS NUMERIC(20,5)), + CAST(JSON_VALUE(q.expl, '$.last_price') AS NUMERIC(20,5)), + CAST(JSON_VALUE(q.expl, '$.list_price') AS NUMERIC(20,5)), + CAST(last_date AS DATE) ) g; -------------------------------------------------------------------------------- @@ -230,79 +232,84 @@ BEGIN -------------------------------------------------------------------------------- UPDATE q SET ui_json = ( - SELECT - panel.label, - JSON_QUERY(panel.details) AS details - FROM ( - -- History Panel - SELECT - 'History' AS label, - ( - SELECT - 'Last Sale: ' + CAST(q.last_date AS varchar(10)) AS label, - q.last_price AS value, - 'currency' AS type, - 'Ord# ' + q.last_order AS note - FOR JSON PATH - ) AS details + SELECT + ( + SELECT + panel.label, + JSON_QUERY(panel.details) AS details + FROM ( + -- History Panel + SELECT + 'History' AS label, + ( + SELECT + 'Last Price' AS label, + q.last_price AS value, + 'currency' AS type, + CONCAT( + 'Source: ', ISNULL(q.last_source, 'N/A'), + ' | Date: ', ISNULL(CONVERT(varchar(10), q.last_date, 120), 'N/A'), + ' | Order: ', ISNULL(q.last_order, 'N/A'), + ' | Quote: ', ISNULL(q.last_quote, 'N/A'), + ' | Dataseg: ', ISNULL(q.last_dataseg, 'N/A'), + ' | Qty: ', ISNULL(CAST(q.last_qty AS varchar(32)), 'N/A') + ) AS note + FOR JSON PATH, WITHOUT_ARRAY_WRAPPER + ) AS details - UNION ALL + UNION ALL - -- List Panel - SELECT - 'List' AS label, - ( - SELECT - 'List:' + q.listcode AS label, - q.listprice AS value, - 'currency' AS type, - q.plevel AS note - FOR JSON PATH - ) - - UNION ALL + -- List Panel + SELECT + 'List' AS label, + ( + SELECT + 'List:' + q.listcode AS label, + q.listprice AS value, + 'currency' AS type, + q.plevel AS note + FOR JSON PATH + ) - -- Target Support Panel - SELECT - 'Target Support' AS label, - ( - SELECT - -- parse each item in target_math - RTRIM(SUBSTRING(value,1,18)) label, - TRY_CAST(SUBSTRING(value,23,7) AS NUMERIC(20,5)) + CASE SUBSTRING(value,19,1) WHEN '+' THEN 0 ELSE -1 END AS value, - CASE SUBSTRING(value,19,1) WHEN '+' THEN 'currency' ELSE 'percentage' END AS type, - SUBSTRING(value,19,1) AS note - FROM OPENJSON(q.expl, '$.target_math') - WITH (value NVARCHAR(MAX) '$') - FOR JSON PATH - ) AS details + UNION ALL - UNION ALL + -- Target Support Panel + SELECT + 'Target Support' AS label, + ( + SELECT + RTRIM(SUBSTRING(value,1,18)) AS label, + TRY_CAST(SUBSTRING(value,23,7) AS NUMERIC(20,5)) + + CASE SUBSTRING(value,19,1) WHEN '+' THEN 0 ELSE -1 END AS value, + CASE SUBSTRING(value,19,1) WHEN '+' THEN 'currency' ELSE 'percentage' END AS type, + CASE SUBSTRING(value,19,1) WHEN '+' THEN 'Price' ELSE 'Premium' END AS note + FROM OPENJSON(q.expl, '$.target_math') + WITH (value NVARCHAR(MAX) '$') + FOR JSON PATH + ) AS details - -- Guidance Panel - SELECT - 'Guidance' AS label, - ( - SELECT - 'Last Price Capped' AS label, - q.guidance_price AS value, - 'currency' AS type, - CONCAT( - 'Last price ', q.last_price, - ' capped at ', - ROUND((q.last_price - q.guidance_price) / NULLIF(q.last_price, 0) * 100, 2), - '%' - ) AS note - FOR JSON PATH - ) - ) AS panel - FOR JSON PATH, ROOT('details') + UNION ALL + + -- Guidance Panel + SELECT + 'Guidance' AS label, + ( + SELECT + 'Price' AS label, + q.guidance_price AS value, + 'currency' AS type, + q.guidance_reason AS note + FOR JSON PATH + ) + ) AS panel + FOR JSON PATH + ) AS details, + JSON_QUERY(q.expl) AS data -- 👈 adds the full expl content as a JSON object + FOR JSON PATH, WITHOUT_ARRAY_WRAPPER -- 👈 make it a single JSON object ) FROM @queue q; - - - -------------------------------------------------------------------------------- - -- Final: Return the enriched result row - -------------------------------------------------------------------------------- - RETURN; -END; + -------------------------------------------------------------------------------- + -- Final: Return the enriched result row + -------------------------------------------------------------------------------- + RETURN; +END; \ No newline at end of file