Compare commits

...

2 Commits

Author SHA1 Message Date
af5e4d202b bring func up to speed 2025-08-07 23:35:09 -04:00
4602db59bb move files 2025-08-07 23:23:40 -04:00
3 changed files with 282 additions and 403 deletions

View File

@ -1,76 +0,0 @@
DELETE FROM pricing.price_queue;
INSERT INTO pricing.price_queue (bill, ship, part, stlc, v1ds, vol) SELECT 'GRIF0001','GRIF0001','XNS0T1G3G18B096','XNS0T1G3','v1:L..PLT..',9600;
SELECT * FROM pricing.price_queue
EXEC pricing.process_queue
EXEC pricing.single_price_call
@bill = 'GRIF0001',
@ship = 'GRIF0001',
@part = 'XNS0T1G3G18B096',
@v1ds = 'v1:B..PLT..',
@vol = 9600;
SELECT * FROM pricing.pick
SELECT * FROM FAnalysis.PRICING.lastpricedetail l OUTER apply pricing.pick_last_price_from_hist_json (part_stats,'v1:B..PLT..') x WHERE customer = 'GRIFFIN' AND partgroup = 'XNS0T1G3'
SELECT
*
FROM pricing.single_price_call_fn(
'GRIF0001',
'GRIF0001',
'XNS0T1G3G18B096',
'XNS0T1G3',
'v1:B..PLT..',
9600
) f
SELECT * INTO #result FROM pricing.price_queue WHERE 0=1
INSERT INTO #result
EXEC pricing.single_price_call_nowrite
@bill = 'GRIF0001',
@ship = 'JRSG0001',
@part = 'XNS0T1G3G18B096',
@stlc = 'XNS0T1G3',
@v1ds = 'v1:T..PLT..',
@vol = 19200;
SELECT * FROM #RESULT
SELECT
q.qid,
q.qrn,
q.qcustomer,
q.part,
q.v1ds,
q.units_each,
q.price,
q.targetp,
q.lastsalesprice,
q.finalrecommendedprice,
q.lowerpricelimit,
q.upperpricelimit,
q.curstdus,
p.price guidance,
p.expl
FROM
rlarp.live_quotes q
OUTER APPLY pricing.single_price_call_fn(
q.billto
,q.shipto
,q.part
,substring(q.part,1,8)
,q.v1ds
,q.units_each
) p
WHERE
qstat LIKE 'Submitted%'

View File

@ -1,52 +0,0 @@
SELECT * FROM
pricequote.single_price_call(
'GRIF0001' ,
'GRIF0001' ,
'XNS0T1G3G18B096' ,
'v1:B..PLT..',
9600
)
SELECT pricing FROM rlarp.osm_stack l WHERE l.customer ='CROS-B-CREST FARM' AND partgroup = 'STG04250'
SELECT * FROM pricequote.lastpricedetail l LEFT JOIN lateral pricequote.pick_last_price_from_hist (part_stats,'v1:B..PLT..') x ON TRUE WHERE customer = 'GRIFFIN' AND partgroup = 'XNS0T1G3'
CALL pricequote.process_queue()
REFRESH MATERIALIZED VIEW rlarp.osm_stack_pretty;
SELECT
q.qid,
q.qrn,
-- q.qcustomer,
q.partbuilt,
i.pricegroup,
q.v1ds,
q.units_each,
q.targetp,
q.lastsalesprice,
-- q.finalrecommendedprice,
-- q.lowerpricelimit,
-- q.upperpricelimit,
q.curstdus,
q.price,
p.guidance_price guidance,
p.expl
FROM
pricequote.live_quotes q
LEFT OUTER JOIN "CMS.CUSLG".itemm i ON
i.item = q.part
LEFT JOIN LATERAL pricequote.single_price_call(
q.billto
,q.shipto
,q.part
,q.v1ds
,q.units_each
) p ON TRUE
WHERE
-- qstat LIKE 'Submitted%'
qid = 111832 --AND q.qrn = 1
ORDER BY
qrn ASC

View File

@ -1,4 +1,5 @@
DROP FUNCTION pricing.single_price_call_fn; DROP FUNCTION IF EXISTS pricing.single_price_call_fn;
GO
CREATE FUNCTION pricing.single_price_call_fn ( CREATE FUNCTION pricing.single_price_call_fn (
@bill VARCHAR(100), @bill VARCHAR(100),
@ -28,10 +29,12 @@ RETURNS @queue TABLE (
last_order NVARCHAR(10), last_order NVARCHAR(10),
last_quote NVARCHAR(10), last_quote NVARCHAR(10),
tprice NUMERIC(20,5), tprice NUMERIC(20,5),
tmath NVARCHAR(MAX),
guidance_price NUMERIC(20,5), guidance_price NUMERIC(20,5),
guidance_reason NVARCHAR(MAX), guidance_reason NVARCHAR(MAX),
expl NVARCHAR(MAX), expl NVARCHAR(MAX),
ui_json NVARCHAR(MAX) ui_json NVARCHAR(MAX),
partgroup VARCHAR(100)
) )
AS AS
BEGIN BEGIN
@ -80,7 +83,8 @@ BEGIN
END END
ELSE bc.plevel ELSE bc.plevel
END, END,
stlc = substring(q.part,1,8) stlc = substring(q.part,1,8),
partgroup = i.partgroup
FROM @queue q FROM @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
@ -91,21 +95,9 @@ BEGIN
-------------------------------------------------------------------------------- --------------------------------------------------------------------------------
UPDATE q UPDATE q
SET SET
tprice = tp.price, tprice = tp.price
expl = ( ,tmath = JSON_QUERY(tp.math)
SELECT ,volume_range = CONCAT(tp.lower_bound, '-', ISNULL(CAST(tp.upper_bound AS VARCHAR), ''))
'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 FROM @queue q
INNER JOIN pricing.target_prices tp ON INNER JOIN pricing.target_prices tp ON
q.stlc = tp.stlc q.stlc = tp.stlc
@ -122,42 +114,52 @@ BEGIN
-------------------------------------------------------------------------------- --------------------------------------------------------------------------------
UPDATE q UPDATE q
SET SET
hist = JSON_MODIFY('{}', '$.full_history', JSON_QUERY(lp.part_stats)), hist = 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 FROM @queue q
JOIN pricing.lastprice lp JOIN pricing.lastpricedetail lp
ON lp.customer = q.cust ON lp.customer = q.cust AND lp.partgroup = q.partgroup;
AND lp.mold = SUBSTRING(q.part, 1, 8)
OUTER APPLY ( --------------------------------------------------------------------------------
SELECT TOP 1 * -- Step 4b.1: Populate composite fields from precedence chain using JSON-based helper
FROM OPENJSON(lp.part_stats) AS p --------------------------------------------------------------------------------
OUTER APPLY OPENJSON(p.value) -- Use new helper to select best last price, source, and date directly from JSON
WITH ( UPDATE q
qty NUMERIC(20,5), SET
price NUMERIC(20,5), last_price = b.price,
odate DATE, last_source = b.source,
ordnum INT, last_date = b.odate,
quoten INT last_qty = b.qty,
) AS j last_dataseg = b.dataseg,
WHERE p.[key] COLLATE SQL_Latin1_General_CP1_CI_AS = q.part last_order = b.ord,
ORDER BY j.odate DESC last_quote = b.quote
) AS j; 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 -- Step 5: Add list price info from external pricelist
@ -222,7 +224,7 @@ BEGIN
CAST(JSON_VALUE(q.expl, '$.target_price') AS NUMERIC(20,5)), 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, '$.last_price') AS NUMERIC(20,5)),
CAST(JSON_VALUE(q.expl, '$.list_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(last_date AS DATE)
) g; ) g;
-------------------------------------------------------------------------------- --------------------------------------------------------------------------------
@ -230,6 +232,8 @@ BEGIN
-------------------------------------------------------------------------------- --------------------------------------------------------------------------------
UPDATE q UPDATE q
SET ui_json = ( SET ui_json = (
SELECT
(
SELECT SELECT
panel.label, panel.label,
JSON_QUERY(panel.details) AS details JSON_QUERY(panel.details) AS details
@ -239,11 +243,18 @@ BEGIN
'History' AS label, 'History' AS label,
( (
SELECT SELECT
'Last Sale: ' + CAST(q.last_date AS varchar(10)) AS label, 'Last Price' AS label,
q.last_price AS value, q.last_price AS value,
'currency' AS type, 'currency' AS type,
'Ord# ' + q.last_order AS note CONCAT(
FOR JSON PATH '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 ) AS details
UNION ALL UNION ALL
@ -267,11 +278,11 @@ BEGIN
'Target Support' AS label, 'Target Support' AS label,
( (
SELECT SELECT
-- parse each item in target_math RTRIM(SUBSTRING(value,1,18)) AS label,
RTRIM(SUBSTRING(value,1,18)) label, TRY_CAST(SUBSTRING(value,23,7) AS NUMERIC(20,5))
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 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 'currency' ELSE 'percentage' END AS type,
SUBSTRING(value,19,1) AS note CASE SUBSTRING(value,19,1) WHEN '+' THEN 'Price' ELSE 'Premium' END AS note
FROM OPENJSON(q.expl, '$.target_math') FROM OPENJSON(q.expl, '$.target_math')
WITH (value NVARCHAR(MAX) '$') WITH (value NVARCHAR(MAX) '$')
FOR JSON PATH FOR JSON PATH
@ -284,23 +295,19 @@ BEGIN
'Guidance' AS label, 'Guidance' AS label,
( (
SELECT SELECT
'Last Price Capped' AS label, 'Price' AS label,
q.guidance_price AS value, q.guidance_price AS value,
'currency' AS type, 'currency' AS type,
CONCAT( q.guidance_reason AS note
'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 FOR JSON PATH
) )
) AS panel ) AS panel
FOR JSON PATH, ROOT('details') 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; FROM @queue q;
-------------------------------------------------------------------------------- --------------------------------------------------------------------------------
-- Final: Return the enriched result row -- Final: Return the enriched result row
-------------------------------------------------------------------------------- --------------------------------------------------------------------------------