Compare commits

..

No commits in common. "ccb91c87d433b3854823d07d919231d50dccad02" and "3cb885c336763871db7d271e6fcd856c5c493adc" have entirely different histories.

View File

@ -1,53 +1,26 @@
DROP FUNCTION pricing.single_price_call_fn; CREATE OR ALTER FUNCTION pricing.single_price_call_fn (
CREATE FUNCTION pricing.single_price_call_fn (
@bill VARCHAR(100), @bill VARCHAR(100),
@ship VARCHAR(100), @ship VARCHAR(100),
@part VARCHAR(100), @part VARCHAR(100),
@stlc VARCHAR(100),
@v1ds VARCHAR(100), @v1ds VARCHAR(100),
@vol NUMERIC(18, 6) @vol NUMERIC(18, 6)
) )
RETURNS @queue TABLE ( RETURNS 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)
)
AS AS
BEGIN RETURN (
WITH queue AS (
-------------------------------------------------------------------------------- SELECT
-- Step 1: Seed the queue with input row @bill AS bill,
-------------------------------------------------------------------------------- @ship AS ship,
INSERT INTO @queue (bill, ship, part, v1ds, vol, expl) @part AS part,
VALUES (@bill, @ship, @part, @v1ds, @vol, '{}'); @stlc AS stlc,
@v1ds AS v1ds,
-------------------------------------------------------------------------------- @vol AS vol
-- Step 2: Enrich with channel, tier, customer, pack quantity, and price level ),
-------------------------------------------------------------------------------- enriched AS (
UPDATE q SELECT
SET q.*,
chan =
CASE SUBSTRING(bc.cclass, 2, 3) CASE SUBSTRING(bc.cclass, 2, 3)
WHEN 'DIS' THEN WHEN 'DIS' THEN
CASE SUBSTRING(sc.cclass, 2, 3) CASE SUBSTRING(sc.cclass, 2, 3)
@ -55,13 +28,11 @@ BEGIN
ELSE 'DRP' ELSE 'DRP'
END END
ELSE 'DIR' ELSE 'DIR'
END, END AS chan,
tier =
CASE SUBSTRING(bc.cclass, 2, 3) CASE SUBSTRING(bc.cclass, 2, 3)
WHEN 'DIR' THEN bc.tier WHEN 'DIR' THEN bc.tier
ELSE ISNULL(sc.tier, bc.tier) ELSE ISNULL(sc.tier, bc.tier)
END, END AS tier,
cust =
CASE SUBSTRING(bc.cclass, 2, 3) CASE SUBSTRING(bc.cclass, 2, 3)
WHEN 'DIS' THEN WHEN 'DIS' THEN
CASE SUBSTRING(sc.cclass, 2, 3) CASE SUBSTRING(sc.cclass, 2, 3)
@ -69,9 +40,8 @@ BEGIN
ELSE sc.dba ELSE sc.dba
END END
ELSE q.bill ELSE q.bill
END, END AS cust,
pltq = i.mpck, i.mpck AS pltq,
plevel =
CASE SUBSTRING(bc.cclass, 2, 3) CASE SUBSTRING(bc.cclass, 2, 3)
WHEN 'DIS' THEN WHEN 'DIS' THEN
CASE SUBSTRING(sc.cclass, 2, 3) CASE SUBSTRING(sc.cclass, 2, 3)
@ -79,74 +49,24 @@ BEGIN
ELSE bc.plevel ELSE bc.plevel
END END
ELSE bc.plevel ELSE bc.plevel
END, END AS plevel
stlc = substring(q.part,1,8) FROM
FROM @queue q queue q
LEFT JOIN rlarp.cust bc ON bc.code = q.bill LEFT JOIN rlarp.cust bc ON bc.code = q.bill
LEFT JOIN rlarp.cust sc ON sc.code = q.ship LEFT JOIN rlarp.cust sc ON sc.code = q.ship
LEFT JOIN CMSInterfaceIn.[CMS.CUSLG].itemm i ON i.item = q.part; 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), '')) hist AS (
FROM @queue q SELECT TOP 1
INNER JOIN pricing.target_prices tp ON e.part,
q.stlc = tp.stlc j.qty,
AND q.v1ds = tp.ds j.price AS last_price,
AND q.chan = tp.chan j.odate AS last_date,
AND q.tier = tp.tier j.ordnum AS last_order,
AND FLOOR(q.vol / NULLIF(q.pltq, 0)) >= tp.lower_bound j.quoten AS last_quote,
AND ( JSON_QUERY(lp.part_stats) AS full_history
tp.upper_bound IS NULL OR FLOOR(q.vol / NULLIF(q.pltq, 0)) < tp.upper_bound FROM pricing.lastprice lp
); OUTER APPLY OPENJSON(lp.part_stats) AS p
--------------------------------------------------------------------------------
-- 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) OUTER APPLY OPENJSON(p.value)
WITH ( WITH (
qty NUMERIC(20, 5), qty NUMERIC(20, 5),
@ -155,154 +75,90 @@ BEGIN
ordnum INT, ordnum INT,
quoten INT quoten INT
) AS j ) AS j
WHERE p.[key] COLLATE SQL_Latin1_General_CP1_CI_AS = q.part INNER JOIN enriched e ON
lp.customer = e.cust AND
lp.mold = SUBSTRING(e.part, 1, 8)
WHERE
p.[key] COLLATE SQL_Latin1_General_CP1_CI_AS = e.part
ORDER BY j.odate DESC ORDER BY j.odate DESC
) AS j; ),
list_price_cte AS (
-------------------------------------------------------------------------------- SELECT *,
-- Step 5: Add list price info from external pricelist ROW_NUMBER() OVER (PARTITION BY e.part ORDER BY p.price ASC) AS rn
-------------------------------------------------------------------------------- FROM enriched e
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 INNER JOIN CMSInterfaceIn."CMS.CUSLG".IPRCBHC i
ON TRIM(i.jbplvl) = TRIM(q.plevel) ON TRIM(i.jbplvl) = TRIM(e.plevel)
AND CAST(GETDATE() AS DATE) BETWEEN i.jbfdat AND i.jbtdat AND CAST(GETDATE() AS DATE) BETWEEN i.jbfdat AND i.jbtdat
INNER JOIN pricing.pricelist_ranged p INNER JOIN pricing.pricelist_ranged p
ON p.jcplcd = TRIM(i.jbplcd) ON p.jcplcd = TRIM(i.jbplcd)
AND p.jcpart = q.part AND p.jcpart = e.part
AND q.vol >= p.vb_from AND e.vol >= p.vb_from
AND (p.vb_to IS NULL OR q.vol < p.vb_to) AND (p.vb_to IS NULL OR e.vol < p.vb_to)
)
UPDATE q
SET expl = JSON_MODIFY(
JSON_MODIFY(
ISNULL(q.expl, '{}'),
'$.list_price', rp.price
), ),
'$.list_code', rp.jcplcd FINAL AS (
) SELECT
,listcode = rp.jcplcd e.part,
,listprice = rp.price tp.price,
FROM @queue q e.plevel,
JOIN ranked_prices rp h.full_history,
ON q.bill = rp.bill h.last_price,
AND q.ship = rp.ship h.last_date,
AND q.part = rp.part h.last_order,
AND q.stlc = rp.stlc h.last_quote,
AND q.v1ds = rp.v1ds lp.price AS list_price,
AND q.vol = rp.vol lp.jcplcd AS list_code,
AND rp.rn = 1; g.guidance_price,
g.guidance_reason,
-------------------------------------------------------------------------------- (
-- Step 6: Compute guidance price and logic, and embed in JSON SELECT
-------------------------------------------------------------------------------- 'target price' AS source,
UPDATE q tp.price AS target_price,
SET h.last_price,
guidance_price = g.guidance_price, FORMAT(h.last_date, 'yyyy-MM-dd') AS last_date,
guidance_reason = g.guidance_reason, h.last_order,
expl = JSON_MODIFY( h.last_quote,
JSON_MODIFY( lp.price AS list_price,
ISNULL(q.expl, '{}'), lp.jcplcd AS list_code,
'$.guidance_reason', FLOOR(e.vol / NULLIF(e.pltq, 0)) AS calculated_pallets,
CAST(e.vol / NULLIF(e.pltq, 0) AS NUMERIC(20,5)) AS exact_pallets,
CONCAT(tp.lower_bound, '-', ISNULL(CAST(tp.upper_bound AS VARCHAR), '')) AS [volume range],
e.cust AS customer,
e.chan AS channel,
RTRIM(e.tier) AS tier,
JSON_QUERY(tp.math) AS [target math],
-- JSON_QUERY(h.full_history) AS [price history],
g.guidance_price,
g.guidance_reason g.guidance_reason
), FOR JSON PATH, WITHOUT_ARRAY_WRAPPER
'$.guidance_price', ) AS expl
g.guidance_price FROM enriched e
) INNER JOIN pricing.target_prices tp ON
FROM @queue q e.stlc = tp.stlc AND
e.v1ds = tp.ds AND
e.chan = tp.chan AND
RTRIM(e.tier) = RTRIM(tp.tier) AND
FLOOR(e.vol / NULLIF(e.pltq, 0)) >= tp.lower_bound AND
(tp.upper_bound IS NULL OR FLOOR(e.vol / NULLIF(e.pltq, 0)) < tp.upper_bound)
LEFT JOIN hist h ON h.part = e.part
LEFT JOIN list_price_cte lp ON lp.part = e.part AND lp.rn = 1
CROSS APPLY pricing.guidance_logic( CROSS APPLY pricing.guidance_logic(
CAST(JSON_VALUE(q.expl, '$.target_price') AS NUMERIC(20,5)), tp.price,
CAST(JSON_VALUE(q.expl, '$.last_price') AS NUMERIC(20,5)), h.last_price,
CAST(JSON_VALUE(q.expl, '$.list_price') AS NUMERIC(20,5)), lp.price
CAST(JSON_VALUE(q.expl, '$.last_date') AS DATE) ) g
) g;
--------------------------------------------------------------------------------
-- Step 7: Clean up for UI
--------------------------------------------------------------------------------
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
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
-- Target Support Panel
SELECT SELECT
'Target Support' AS label, part,
( price AS target_price,
SELECT plevel,
-- parse each item in target_math last_price,
RTRIM(SUBSTRING(value,1,18)) label, last_date,
TRY_CAST(SUBSTRING(value,23,7) AS NUMERIC(20,5)) + CASE SUBSTRING(value,19,1) WHEN '+' THEN 0 ELSE -1 END AS value, last_order,
CASE SUBSTRING(value,19,1) WHEN '+' THEN 'currency' ELSE 'percentage' END AS type, last_quote,
SUBSTRING(value,19,1) AS note list_price,
FROM OPENJSON(q.expl, '$.target_math') list_code,
WITH (value NVARCHAR(MAX) '$') guidance_price,
FOR JSON PATH guidance_reason,
) AS details expl
FROM FINAL
UNION ALL );
-- 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')
)
FROM @queue q;
--------------------------------------------------------------------------------
-- Final: Return the enriched result row
--------------------------------------------------------------------------------
RETURN;
END;