Compare commits
No commits in common. "ccb91c87d433b3854823d07d919231d50dccad02" and "3cb885c336763871db7d271e6fcd856c5c493adc" have entirely different histories.
ccb91c87d4
...
3cb885c336
@ -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;
|
|
||||||
|
Loading…
Reference in New Issue
Block a user