build new last price
This commit is contained in:
parent
f013c5ccc2
commit
0bdf7afca2
280
new_targets/history.json
Normal file
280
new_targets/history.json
Normal file
@ -0,0 +1,280 @@
|
||||
{
|
||||
"v1:B..CSE..": [
|
||||
{
|
||||
"version": "Actual",
|
||||
"part": "XNS0T1G2G18C140",
|
||||
"qty": 8960.00,
|
||||
"price": 0.092910,
|
||||
"odate": "2016-02-10",
|
||||
"ordnum": 784718,
|
||||
"quoten": 28971,
|
||||
"flags": []
|
||||
},
|
||||
{
|
||||
"version": "Quotes",
|
||||
"part": "XNS0T1G2G18C140",
|
||||
"qty": 9100.00,
|
||||
"price": 0.092910,
|
||||
"odate": "2016-02-10",
|
||||
"ordnum": 0,
|
||||
"quoten": 29543,
|
||||
"flags": []
|
||||
}
|
||||
],
|
||||
"v1:T..CSE..": [
|
||||
{
|
||||
"version": "Quotes",
|
||||
"part": "XNS0T1G2X03C140",
|
||||
"qty": 6020.00,
|
||||
"price": 0.092910,
|
||||
"odate": "2016-02-10",
|
||||
"ordnum": 0,
|
||||
"quoten": 29543,
|
||||
"flags": []
|
||||
},
|
||||
{
|
||||
"version": "Actual",
|
||||
"part": "XNS0T1G2X03C140",
|
||||
"qty": 6020.00,
|
||||
"price": 0.092910,
|
||||
"odate": "2016-02-09",
|
||||
"ordnum": 784655,
|
||||
"flags": []
|
||||
}
|
||||
],
|
||||
"v1:B..PLT..": [
|
||||
{
|
||||
"version": "Actual",
|
||||
"part": "XNS0T1G3G18B096",
|
||||
"qty": 9600.00,
|
||||
"price": 0.126130,
|
||||
"odate": "2024-10-31",
|
||||
"ordnum": 992442,
|
||||
"quoten": 79774,
|
||||
"flags": [
|
||||
"most_recent_sale",
|
||||
"largest_volume_sale"
|
||||
]
|
||||
},
|
||||
{
|
||||
"version": "Quotes",
|
||||
"part": "XNS0T1G3G18B096",
|
||||
"qty": 38400.00,
|
||||
"price": 0.126130,
|
||||
"odate": "2024-10-29",
|
||||
"ordnum": 0,
|
||||
"quoten": 79774,
|
||||
"flags": [
|
||||
"most_recent_quote",
|
||||
"largest_volume_quote"
|
||||
]
|
||||
},
|
||||
{
|
||||
"version": "Actual",
|
||||
"part": "XNS0T1G3G18B096",
|
||||
"qty": 9600.00,
|
||||
"price": 0.126130,
|
||||
"odate": "2024-08-02",
|
||||
"ordnum": 985899,
|
||||
"flags": []
|
||||
},
|
||||
{
|
||||
"version": "Actual",
|
||||
"part": "XNS0T1G3G18B096",
|
||||
"qty": 38400.00,
|
||||
"price": 0.128250,
|
||||
"odate": "2023-12-04",
|
||||
"ordnum": 969894,
|
||||
"quoten": 75273,
|
||||
"flags": []
|
||||
},
|
||||
{
|
||||
"version": "Quotes",
|
||||
"part": "XNS0T1G3G18B096",
|
||||
"qty": 38400.00,
|
||||
"price": 0.128250,
|
||||
"odate": "2023-12-04",
|
||||
"ordnum": 0,
|
||||
"quoten": 75273,
|
||||
"flags": []
|
||||
},
|
||||
{
|
||||
"version": "Quotes",
|
||||
"part": "XNS0T1G3G18B096",
|
||||
"qty": 19200.00,
|
||||
"price": 0.135000,
|
||||
"odate": "2023-02-13",
|
||||
"ordnum": 0,
|
||||
"quoten": 73602,
|
||||
"flags": []
|
||||
},
|
||||
{
|
||||
"version": "Quotes",
|
||||
"part": "XNS0T1G3G18B096",
|
||||
"qty": 38400.00,
|
||||
"price": 0.145020,
|
||||
"odate": "2022-01-26",
|
||||
"ordnum": 0,
|
||||
"quoten": 69130,
|
||||
"flags": []
|
||||
},
|
||||
{
|
||||
"version": "Actual",
|
||||
"part": "XNS0T1G3G18B096",
|
||||
"qty": 28800.00,
|
||||
"price": 0.125480,
|
||||
"odate": "2021-07-16",
|
||||
"ordnum": 922664,
|
||||
"quoten": 64686,
|
||||
"flags": []
|
||||
},
|
||||
{
|
||||
"version": "Quotes",
|
||||
"part": "XNS0T1G3G18B096",
|
||||
"qty": 38400.00,
|
||||
"price": 0.125480,
|
||||
"odate": "2021-07-08",
|
||||
"ordnum": 0,
|
||||
"quoten": 64686,
|
||||
"flags": []
|
||||
},
|
||||
{
|
||||
"version": "Actual",
|
||||
"part": "XNS0T1G3G18B096",
|
||||
"qty": 38400.00,
|
||||
"price": 0.100390,
|
||||
"odate": "2020-11-12",
|
||||
"ordnum": 905400,
|
||||
"flags": []
|
||||
},
|
||||
{
|
||||
"version": "Quotes",
|
||||
"part": "XNS0T1G3G18B096",
|
||||
"qty": 38400.00,
|
||||
"price": 0.100390,
|
||||
"odate": "2020-08-13",
|
||||
"ordnum": 0,
|
||||
"quoten": 58215,
|
||||
"flags": []
|
||||
},
|
||||
{
|
||||
"version": "Quotes",
|
||||
"part": "XNS0T1G3G18B096",
|
||||
"qty": 28800.00,
|
||||
"price": 0.100390,
|
||||
"odate": "2020-06-11",
|
||||
"ordnum": 0,
|
||||
"quoten": 57254,
|
||||
"flags": []
|
||||
},
|
||||
{
|
||||
"version": "Actual",
|
||||
"part": "XNS0T1G3G18B096",
|
||||
"qty": 28800.00,
|
||||
"price": 0.100390,
|
||||
"odate": "2020-06-10",
|
||||
"ordnum": 890715,
|
||||
"quoten": 57254,
|
||||
"flags": []
|
||||
},
|
||||
{
|
||||
"version": "Actual",
|
||||
"part": "XNS0T1G3G18B096",
|
||||
"qty": 28800.00,
|
||||
"price": 0.098910,
|
||||
"odate": "2019-07-23",
|
||||
"ordnum": 870300,
|
||||
"quoten": 51460,
|
||||
"flags": []
|
||||
},
|
||||
{
|
||||
"version": "Quotes",
|
||||
"part": "XNS0T1G3G18B096",
|
||||
"qty": 28800.00,
|
||||
"price": 0.098910,
|
||||
"odate": "2019-07-18",
|
||||
"ordnum": 0,
|
||||
"quoten": 51460,
|
||||
"flags": []
|
||||
},
|
||||
{
|
||||
"version": "Actual",
|
||||
"part": "XNS0T1G3G18B096",
|
||||
"qty": 19200.00,
|
||||
"price": 0.095290,
|
||||
"odate": "2018-10-09",
|
||||
"ordnum": 853112,
|
||||
"quoten": 44775,
|
||||
"flags": []
|
||||
},
|
||||
{
|
||||
"version": "Actual",
|
||||
"part": "XNS0T1G3G18B096",
|
||||
"qty": 9600.00,
|
||||
"price": 0.095290,
|
||||
"odate": "2018-10-09",
|
||||
"ordnum": 853112,
|
||||
"quoten": 44775,
|
||||
"flags": []
|
||||
},
|
||||
{
|
||||
"version": "Quotes",
|
||||
"part": "XNS0T1G3G18B096",
|
||||
"qty": 9600.00,
|
||||
"price": 0.095290,
|
||||
"odate": "2018-08-21",
|
||||
"ordnum": 0,
|
||||
"quoten": 44775,
|
||||
"flags": []
|
||||
},
|
||||
{
|
||||
"version": "Quotes",
|
||||
"part": "XNS0T1G3G18B096",
|
||||
"qty": 38400.00,
|
||||
"price": 0.094160,
|
||||
"odate": "2017-10-13",
|
||||
"ordnum": 0,
|
||||
"quoten": 38844,
|
||||
"flags": []
|
||||
},
|
||||
{
|
||||
"version": "Actual",
|
||||
"part": "XNS0T1G2G18B079",
|
||||
"qty": 47790.00,
|
||||
"price": 0.092910,
|
||||
"odate": "2016-06-10",
|
||||
"ordnum": 794232,
|
||||
"flags": []
|
||||
},
|
||||
{
|
||||
"version": "Quotes",
|
||||
"part": "XNS0T1G2G18B079",
|
||||
"qty": 47790.00,
|
||||
"price": 0.092910,
|
||||
"odate": "2016-02-10",
|
||||
"ordnum": 0,
|
||||
"quoten": 29543,
|
||||
"flags": []
|
||||
},
|
||||
{
|
||||
"version": "Quotes",
|
||||
"part": "XNS0T1G2G18B079",
|
||||
"qty": 47790.00,
|
||||
"price": 0.091200,
|
||||
"odate": "2015-12-17",
|
||||
"ordnum": 0,
|
||||
"quoten": 28971,
|
||||
"flags": []
|
||||
},
|
||||
{
|
||||
"version": "Quotes",
|
||||
"part": "XNS0T1G2G18B079",
|
||||
"qty": 47790.00,
|
||||
"price": 0.091200,
|
||||
"odate": "2015-09-21",
|
||||
"ordnum": 0,
|
||||
"quoten": 27873,
|
||||
"flags": []
|
||||
}
|
||||
]
|
||||
}
|
||||
227
new_targets/tables/lastpricedetail.ms.sql
Normal file
227
new_targets/tables/lastpricedetail.ms.sql
Normal file
@ -0,0 +1,227 @@
|
||||
--------------------------------------------------------------------------------
|
||||
-- Clear old data
|
||||
--------------------------------------------------------------------------------
|
||||
DROP TABLE IF EXISTS pricing.lastpricedetail;
|
||||
DELETE FROM pricing.lastpricedetail;
|
||||
DROP TABLE IF EXISTS #flagged;
|
||||
|
||||
--------------------------------------------------------------------------------
|
||||
-- Base cleaned input
|
||||
--------------------------------------------------------------------------------
|
||||
WITH base AS (
|
||||
SELECT
|
||||
o."Customer" AS customer,
|
||||
o."Part Group" AS partgroup,
|
||||
RTRIM(i.V1DS) AS dataseg,
|
||||
o."Data Source" AS version,
|
||||
o."Part Code" AS part,
|
||||
o."Units" AS qty,
|
||||
CASE
|
||||
WHEN o."Units" = 0 THEN NULL
|
||||
ELSE ROUND(o.[Value USD] / NULLIF(o."Units", 0), 5)
|
||||
END AS price,
|
||||
o.[Order Date] AS odate,
|
||||
o.[Order Number] AS ordnum,
|
||||
o.[Quote Number] AS quoten
|
||||
FROM
|
||||
rlarp.osm_stack_pretty o
|
||||
INNER JOIN CMSInterfaceIn.[CMS.CUSLG].ITEMM i
|
||||
ON i.item = o.[Part Code]
|
||||
WHERE
|
||||
o.[Data Source] IN ('Actual', 'Quotes')
|
||||
AND o."Customer" IS NOT NULL
|
||||
AND o."Financial Statement Line" = '41010'
|
||||
AND o."Order Status" <> 'CANCELLED'
|
||||
AND o."Units" > 0
|
||||
AND o."Part Group" <> ''
|
||||
-- AND o."Customer" = 'ESBENSHADES GREENHOUSE'
|
||||
),
|
||||
--------------------------------------------------------------------------------
|
||||
-- Rank rows for recency and volume
|
||||
--------------------------------------------------------------------------------
|
||||
ranked AS (
|
||||
SELECT
|
||||
b.*
|
||||
-- most recent sale
|
||||
,ROW_NUMBER() OVER (
|
||||
PARTITION BY b.customer, b.partgroup
|
||||
ORDER BY CASE WHEN b.version = 'Actual' THEN b.odate ELSE NULL END DESC
|
||||
) AS rn_mrs
|
||||
-- most recent quote
|
||||
,ROW_NUMBER() OVER (
|
||||
PARTITION BY b.customer, b.partgroup
|
||||
ORDER BY CASE WHEN b.version = 'Quotes' THEN b.odate ELSE NULL END DESC
|
||||
) AS rn_mrq
|
||||
-- largest volume sale
|
||||
,ROW_NUMBER() OVER (
|
||||
PARTITION BY b.customer, b.partgroup
|
||||
ORDER BY CASE
|
||||
WHEN b.version = 'Actual' AND b.odate >= DATEADD(YEAR, -1, GETDATE())
|
||||
THEN b.qty ELSE NULL
|
||||
END DESC
|
||||
) AS rn_lvs
|
||||
-- largest volume quote
|
||||
,ROW_NUMBER() OVER (
|
||||
PARTITION BY b.customer, b.partgroup
|
||||
ORDER BY CASE
|
||||
WHEN b.version = 'Quotes' AND b.odate >= DATEADD(YEAR, -1, GETDATE())
|
||||
THEN b.qty ELSE NULL
|
||||
END DESC
|
||||
) AS rn_lvq
|
||||
-- most recent sale for data segment
|
||||
,ROW_NUMBER() OVER (
|
||||
PARTITION BY b.customer, b.partgroup, b.dataseg, b.version
|
||||
ORDER BY CASE WHEN b.version = 'Actual' THEN b.odate ELSE NULL END DESC
|
||||
) AS rn_dss
|
||||
-- most recent quote for data segment
|
||||
,ROW_NUMBER() OVER (
|
||||
PARTITION BY b.customer, b.partgroup, b.dataseg, b.version
|
||||
ORDER BY CASE WHEN b.version = 'Quotes' THEN b.odate ELSE NULL END DESC
|
||||
) AS rn_dsq
|
||||
FROM base b
|
||||
)
|
||||
SELECT * INTO #flagged FROM ranked
|
||||
WHERE
|
||||
1=1
|
||||
-- AND partgroup = 'XNS0T1G3'
|
||||
AND (
|
||||
rn_mrs = 1
|
||||
OR rn_mrq = 1
|
||||
OR rn_lvs = 1
|
||||
OR rn_lvq = 1
|
||||
OR rn_dss = 1
|
||||
OR rn_dsq = 1
|
||||
)
|
||||
|
||||
CREATE NONCLUSTERED INDEX ix_flagged_lookup
|
||||
ON #flagged(customer, partgroup, dataseg, version, part, qty, price, odate, ordnum, quoten);
|
||||
|
||||
--SELECT * FROM #flagged WHERE customer LIKE 'ESBENSHADE%' AND partgroup = 'XNS0T1G3'
|
||||
|
||||
--------------------------------------------------------------------------------
|
||||
-- Assumes you already have #flagged built from ranked rows
|
||||
-- with columns: customer, partgroup, dataseg, version, part, qty, price, odate, ordnum, quoten,
|
||||
-- and rank columns: rn_mrs, rn_mrq, rn_lvs, rn_lvq, rn_dss, rn_dsq
|
||||
--------------------------------------------------------------------------------
|
||||
|
||||
-- Step 1: Flatten flag-based records
|
||||
WITH exploded AS (
|
||||
SELECT *,
|
||||
CASE WHEN rn_mrs = 1 THEN 'mrs' END AS f1,
|
||||
CASE WHEN rn_mrq = 1 THEN 'mrq' END AS f2,
|
||||
CASE WHEN rn_lvs = 1 THEN 'lvs' END AS f3,
|
||||
CASE WHEN rn_lvq = 1 THEN 'lvq' END AS f4
|
||||
FROM #flagged
|
||||
-- WHERE customer LIKE 'ESBENSHADE%' AND partgroup = 'XNS0T1G3'
|
||||
)
|
||||
,flags AS (
|
||||
SELECT
|
||||
customer, partgroup, dataseg, version, part, qty, price, odate, ordnum, quoten,
|
||||
flag
|
||||
FROM exploded
|
||||
CROSS APPLY (VALUES (f1), (f2), (f3), (f4)) AS f(flag)
|
||||
WHERE flag IS NOT NULL
|
||||
)
|
||||
--SELECT * FROM flags
|
||||
-- Step 2: JSON object for each flag (mrs/mrq/lvs/lvq)
|
||||
,serialized_flags AS (
|
||||
SELECT
|
||||
customer,
|
||||
partgroup,
|
||||
flag,
|
||||
CONCAT(
|
||||
'"', flag, '":',
|
||||
JSON_QUERY((
|
||||
SELECT
|
||||
version,
|
||||
dataseg AS datasegment,
|
||||
part,
|
||||
qty,
|
||||
price,
|
||||
odate,
|
||||
ordnum,
|
||||
quoten,
|
||||
flag
|
||||
FOR JSON PATH, WITHOUT_ARRAY_WRAPPER
|
||||
))
|
||||
) AS json_piece
|
||||
FROM flags
|
||||
)
|
||||
,flag_json AS (
|
||||
SELECT
|
||||
customer,
|
||||
partgroup,
|
||||
STRING_AGG(json_piece, ',') AS json_block
|
||||
FROM serialized_flags
|
||||
GROUP BY customer, partgroup
|
||||
)
|
||||
--SELECT * FROM flag_json
|
||||
-- Step 3: One row per (customer, partgroup, dataseg) — most recent
|
||||
,seg_rows AS (
|
||||
SELECT *
|
||||
FROM (
|
||||
SELECT *,
|
||||
ROW_NUMBER() OVER (
|
||||
PARTITION BY customer, partgroup, dataseg
|
||||
ORDER BY odate DESC
|
||||
) AS rk
|
||||
FROM #flagged
|
||||
-- WHERE customer LIKE 'ESBENSHADE%' AND partgroup = 'XNS0T1G3'
|
||||
) x
|
||||
WHERE rk = 1
|
||||
)
|
||||
--SELECT * FROM seg_rows
|
||||
-- Step 4: JSON object for each dataseg
|
||||
, serialized_segs AS (
|
||||
SELECT
|
||||
customer,
|
||||
partgroup,
|
||||
dataseg,
|
||||
CONCAT(
|
||||
'"', dataseg, '":',
|
||||
JSON_QUERY((
|
||||
SELECT
|
||||
version,
|
||||
dataseg AS datasegment,
|
||||
part,
|
||||
qty,
|
||||
price,
|
||||
odate,
|
||||
ordnum,
|
||||
quoten
|
||||
FOR JSON PATH, WITHOUT_ARRAY_WRAPPER
|
||||
))
|
||||
) AS json_piece
|
||||
FROM seg_rows
|
||||
),
|
||||
seg_json AS (
|
||||
SELECT
|
||||
customer,
|
||||
partgroup,
|
||||
STRING_AGG(json_piece, ',') AS json_block
|
||||
FROM serialized_segs
|
||||
GROUP BY customer, partgroup
|
||||
)
|
||||
--SELECT * FROM seg_json
|
||||
-- Step 5: Merge into final JSON per (customer, partgroup)
|
||||
SELECT
|
||||
COALESCE(f.customer, s.customer) AS customer,
|
||||
COALESCE(f.partgroup, s.partgroup) AS partgroup,
|
||||
CONCAT(
|
||||
'{',
|
||||
COALESCE(f.json_block, ''),
|
||||
CASE
|
||||
WHEN f.json_block IS NOT NULL AND s.json_block IS NOT NULL THEN ','
|
||||
ELSE ''
|
||||
END,
|
||||
COALESCE(s.json_block, ''),
|
||||
'}'
|
||||
) AS part_stats
|
||||
INTO #final_json
|
||||
FROM flag_json f
|
||||
FULL OUTER JOIN seg_json s
|
||||
ON f.customer = s.customer AND f.partgroup = s.partgroup;
|
||||
-- Final output
|
||||
|
||||
SELECT * FROM #FINAL_JSON WHERE customer = 'GRIFFIN' AND partgroup = 'XNS0T1G3'
|
||||
|
||||
Loading…
Reference in New Issue
Block a user