Compare commits
2 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 964616beec | |||
| 326784e18c |
@ -5,258 +5,258 @@ BEGIN
|
|||||||
SET XACT_ABORT ON; -- auto-rollback on most errors
|
SET XACT_ABORT ON; -- auto-rollback on most errors
|
||||||
|
|
||||||
BEGIN TRY
|
BEGIN TRY
|
||||||
BEGIN TRAN; -- start transaction
|
BEGIN TRAN; -- start transaction
|
||||||
--------------------------------------------------------------------------------
|
--------------------------------------------------------------------------------
|
||||||
-- Reset target tables
|
-- Reset target tables
|
||||||
--------------------------------------------------------------------------------
|
--------------------------------------------------------------------------------
|
||||||
--DROP TABLE IF EXISTS pricing.lastpricedetail;
|
--DROP TABLE IF EXISTS pricing.lastpricedetail;
|
||||||
DELETE FROM pricing.lastpricedetail;
|
DELETE FROM pricing.lastpricedetail;
|
||||||
DROP TABLE IF EXISTS #flagged;
|
DROP TABLE IF EXISTS #flagged;
|
||||||
|
|
||||||
--------------------------------------------------------------------------------
|
--------------------------------------------------------------------------------
|
||||||
-- Stage 1: Load cleaned input rows
|
-- Stage 1: Load cleaned input rows
|
||||||
-- Filters out irrelevant quotes/orders and calculates unit prices
|
-- Filters out irrelevant quotes/orders and calculates unit prices
|
||||||
--------------------------------------------------------------------------------
|
--------------------------------------------------------------------------------
|
||||||
WITH base AS (
|
WITH base AS (
|
||||||
SELECT
|
SELECT
|
||||||
o."Customer" AS customer,
|
o."Customer" AS customer,
|
||||||
o."Part Group" AS partgroup,
|
o."Part Group" AS partgroup,
|
||||||
RTRIM(i.V1DS) AS dataseg,
|
RTRIM(i.V1DS) AS dataseg,
|
||||||
o."Data Source" AS version,
|
o."Data Source" AS version,
|
||||||
o."Part Code" AS part,
|
o."Part Code" AS part,
|
||||||
o."Units" AS qty,
|
o."Units" AS qty,
|
||||||
CASE
|
CASE
|
||||||
WHEN o."Units" = 0 THEN NULL
|
WHEN o."Units" = 0 THEN NULL
|
||||||
ELSE ROUND(o.[Value USD] / NULLIF(o."Units", 0), 5)
|
ELSE ROUND(o.[Value USD] / NULLIF(o."Units", 0), 5)
|
||||||
END AS price,
|
END AS price,
|
||||||
o.[Order Date] AS odate,
|
o.[Order Date] AS odate,
|
||||||
o.[Order Number] AS ordnum,
|
o.[Order Number] AS ordnum,
|
||||||
o.[Quote Number] AS quoten
|
o.[Quote Number] AS quoten
|
||||||
FROM
|
FROM
|
||||||
fanalysis.rlarp.osm_stack_pretty o
|
fanalysis.rlarp.osm_stack_pretty o
|
||||||
INNER JOIN CMSInterfaceIn.[CMS.CUSLG].ITEMM i
|
INNER JOIN CMSInterfaceIn.[CMS.CUSLG].ITEMM i
|
||||||
ON i.item = o.[Part Code]
|
ON i.item = o.[Part Code]
|
||||||
WHERE
|
WHERE
|
||||||
o.[Data Source] IN ('Actual', 'Quotes')
|
o.[Data Source] IN ('Actual', 'Quotes')
|
||||||
AND o."Customer" IS NOT NULL
|
AND o."Customer" IS NOT NULL
|
||||||
AND o."Financial Statement Line" = '41010'
|
AND o."Financial Statement Line" = '41010'
|
||||||
AND o."Order Status" <> 'CANCELLED'
|
AND o."Order Status" <> 'CANCELLED'
|
||||||
AND o."Units" > 0
|
AND o."Units" > 0
|
||||||
AND o."Part Group" <> ''
|
AND o."Part Group" <> ''
|
||||||
-- Optional filter for testing
|
-- Optional filter for testing
|
||||||
-- AND o."Customer" = 'ESBENSHADES GREENHOUSE'
|
-- AND o."Customer" = 'ESBENSHADES GREENHOUSE'
|
||||||
),
|
),
|
||||||
--------------------------------------------------------------------------------
|
--------------------------------------------------------------------------------
|
||||||
-- Stage 2: Rank each row based on recency and volume rules
|
-- Stage 2: Rank each row based on recency and volume rules
|
||||||
-- Flags include:
|
-- Flags include:
|
||||||
-- - rn_mrs: most recent sale
|
-- - rn_mrs: most recent sale
|
||||||
-- - rn_mrq: most recent quote
|
-- - rn_mrq: most recent quote
|
||||||
-- - rn_lvs: largest sale in last year
|
-- - rn_lvs: largest sale in last year
|
||||||
-- - rn_lvq: largest quote in last year
|
-- - rn_lvq: largest quote in last year
|
||||||
-- - rn_dss: most recent sale per dataseg
|
-- - rn_dss: most recent sale per dataseg
|
||||||
-- - rn_dsq: most recent quote per dataseg
|
-- - rn_dsq: most recent quote per dataseg
|
||||||
--------------------------------------------------------------------------------
|
--------------------------------------------------------------------------------
|
||||||
ranked AS (
|
ranked AS (
|
||||||
SELECT
|
SELECT
|
||||||
b.*
|
b.*
|
||||||
-- Most recent sale (Actuals only)
|
-- Most recent sale (Actuals only)
|
||||||
,CASE WHEN b.version = 'Actual' THEN
|
,CASE WHEN b.version = 'Actual' THEN
|
||||||
ROW_NUMBER() OVER (
|
ROW_NUMBER() OVER (
|
||||||
PARTITION BY b.customer, b.partgroup
|
PARTITION BY b.customer, b.partgroup
|
||||||
ORDER BY b.odate DESC
|
ORDER BY b.odate DESC
|
||||||
)
|
)
|
||||||
END AS rn_mrs
|
END AS rn_mrs
|
||||||
-- Most recent quote (Quotes only)
|
-- Most recent quote (Quotes only)
|
||||||
,CASE WHEN b.version = 'Quotes' THEN
|
,CASE WHEN b.version = 'Quotes' THEN
|
||||||
ROW_NUMBER() OVER (
|
ROW_NUMBER() OVER (
|
||||||
PARTITION BY b.customer, b.partgroup
|
PARTITION BY b.customer, b.partgroup
|
||||||
ORDER BY b.odate DESC
|
ORDER BY b.odate DESC
|
||||||
)
|
)
|
||||||
END AS rn_mrq
|
END AS rn_mrq
|
||||||
-- Largest volume sale (Actuals only; last 12 months prioritized)
|
-- Largest volume sale (Actuals only; last 12 months prioritized)
|
||||||
,CASE WHEN b.version = 'Actual' THEN
|
,CASE WHEN b.version = 'Actual' THEN
|
||||||
ROW_NUMBER() OVER (
|
ROW_NUMBER() OVER (
|
||||||
PARTITION BY b.customer, b.partgroup
|
PARTITION BY b.customer, b.partgroup
|
||||||
ORDER BY
|
ORDER BY
|
||||||
CASE WHEN b.version = 'Actual' AND b.odate >= DATEADD(YEAR, -1, GETDATE()) THEN 1 ELSE 0 END DESC,
|
CASE WHEN b.version = 'Actual' AND b.odate >= DATEADD(YEAR, -1, GETDATE()) THEN 1 ELSE 0 END DESC,
|
||||||
b.qty DESC
|
b.qty DESC
|
||||||
)
|
)
|
||||||
END AS rn_lvs
|
END AS rn_lvs
|
||||||
-- Largest volume quote (Quotes only; last 12 months prioritized)
|
-- Largest volume quote (Quotes only; last 12 months prioritized)
|
||||||
,CASE WHEN b.version = 'Quotes' THEN
|
,CASE WHEN b.version = 'Quotes' THEN
|
||||||
ROW_NUMBER() OVER (
|
ROW_NUMBER() OVER (
|
||||||
PARTITION BY b.customer, b.partgroup
|
PARTITION BY b.customer, b.partgroup
|
||||||
ORDER BY
|
ORDER BY
|
||||||
CASE WHEN b.version = 'Quotes' AND b.odate >= DATEADD(YEAR, -1, GETDATE()) THEN 1 ELSE 0 END DESC,
|
CASE WHEN b.version = 'Quotes' AND b.odate >= DATEADD(YEAR, -1, GETDATE()) THEN 1 ELSE 0 END DESC,
|
||||||
b.qty DESC
|
b.qty DESC
|
||||||
)
|
)
|
||||||
END AS rn_lvq
|
END AS rn_lvq
|
||||||
,CASE WHEN b.version = 'Actual' THEN
|
,CASE WHEN b.version = 'Actual' THEN
|
||||||
ROW_NUMBER() OVER (
|
ROW_NUMBER() OVER (
|
||||||
PARTITION BY b.customer, b.partgroup, b.dataseg, b.version
|
PARTITION BY b.customer, b.partgroup, b.dataseg, b.version
|
||||||
ORDER BY b.odate DESC
|
ORDER BY b.odate DESC
|
||||||
)
|
)
|
||||||
END AS rn_dss
|
END AS rn_dss
|
||||||
,CASE WHEN b.version = 'Quotes' THEN
|
,CASE WHEN b.version = 'Quotes' THEN
|
||||||
ROW_NUMBER() OVER (
|
ROW_NUMBER() OVER (
|
||||||
PARTITION BY b.customer, b.partgroup, b.dataseg, b.version
|
PARTITION BY b.customer, b.partgroup, b.dataseg, b.version
|
||||||
ORDER BY b.odate DESC
|
ORDER BY b.odate DESC
|
||||||
)
|
)
|
||||||
END AS rn_dsq
|
END AS rn_dsq
|
||||||
FROM base b
|
FROM base b
|
||||||
)
|
)
|
||||||
--------------------------------------------------------------------------------
|
--------------------------------------------------------------------------------
|
||||||
-- Stage 2.5: Save only rows that meet any of the above criteria
|
-- Stage 2.5: Save only rows that meet any of the above criteria
|
||||||
-- and annotate each with global-level flag (mrs, mrq, lvs, lvq)
|
-- and annotate each with global-level flag (mrs, mrq, lvs, lvq)
|
||||||
--------------------------------------------------------------------------------
|
--------------------------------------------------------------------------------
|
||||||
SELECT
|
SELECT
|
||||||
*,
|
*,
|
||||||
CASE WHEN rn_mrs = 1 THEN 'mrs' END AS f1,
|
CASE WHEN rn_mrs = 1 THEN 'mrs' END AS f1,
|
||||||
CASE WHEN rn_mrq = 1 THEN 'mrq' END AS f2,
|
CASE WHEN rn_mrq = 1 THEN 'mrq' END AS f2,
|
||||||
CASE WHEN rn_lvs = 1 THEN 'lvs' END AS f3,
|
CASE WHEN rn_lvs = 1 THEN 'lvs' END AS f3,
|
||||||
CASE WHEN rn_lvq = 1 THEN 'lvq' END AS f4,
|
CASE WHEN rn_lvq = 1 THEN 'lvq' END AS f4,
|
||||||
CASE WHEN rn_dss = 1 AND version = 'Actual' THEN 'dss' END AS f5,
|
CASE WHEN rn_dss = 1 AND version = 'Actual' THEN 'dss' END AS f5,
|
||||||
CASE WHEN rn_dsq = 1 AND version = 'Quotes' THEN 'dsq' END AS f6
|
CASE WHEN rn_dsq = 1 AND version = 'Quotes' THEN 'dsq' END AS f6
|
||||||
INTO #flagged
|
INTO #flagged
|
||||||
FROM ranked
|
FROM ranked
|
||||||
WHERE
|
WHERE
|
||||||
rn_mrs = 1
|
rn_mrs = 1
|
||||||
OR rn_mrq = 1
|
OR rn_mrq = 1
|
||||||
OR rn_lvs = 1
|
OR rn_lvs = 1
|
||||||
OR rn_lvq = 1
|
OR rn_lvq = 1
|
||||||
OR (rn_dss = 1 AND version = 'Actual')
|
OR (rn_dss = 1 AND version = 'Actual')
|
||||||
OR (rn_dsq = 1 AND version = 'Quotes');
|
OR (rn_dsq = 1 AND version = 'Quotes');
|
||||||
|
|
||||||
CREATE NONCLUSTERED INDEX ix_flagged_lookup
|
CREATE NONCLUSTERED INDEX ix_flagged_lookup
|
||||||
ON #flagged(customer, partgroup, dataseg, version, part, qty, price, odate, ordnum, quoten);
|
ON #flagged(customer, partgroup, dataseg, version, part, qty, price, odate, ordnum, quoten);
|
||||||
|
|
||||||
--------------------------------------------------------------------------------
|
--------------------------------------------------------------------------------
|
||||||
-- Stage 3: Build JSON from flagged rows
|
-- Stage 3: Build JSON from flagged rows
|
||||||
--------------------------------------------------------------------------------
|
--------------------------------------------------------------------------------
|
||||||
|
|
||||||
-- Step 3.1: Explode all flags from the #flagged table
|
-- Step 3.1: Explode all flags from the #flagged table
|
||||||
WITH exploded_flags AS (
|
WITH exploded_flags AS (
|
||||||
SELECT
|
SELECT
|
||||||
customer, partgroup, part, dataseg, version, qty, price, odate, ordnum, quoten,
|
customer, partgroup, part, dataseg, version, qty, price, odate, ordnum, quoten,
|
||||||
flag
|
flag
|
||||||
FROM #flagged
|
FROM #flagged
|
||||||
CROSS APPLY (VALUES (f1), (f2), (f3), (f4), (f5), (f6)) AS f(flag)
|
CROSS APPLY (VALUES (f1), (f2), (f3), (f4), (f5), (f6)) AS f(flag)
|
||||||
WHERE flag IS NOT NULL
|
WHERE flag IS NOT NULL
|
||||||
)
|
)
|
||||||
--SELECT * FROM exploded_flags
|
--SELECT * FROM exploded_flags
|
||||||
-- Step 3.2: Serialize each row into its JSON snippet
|
-- Step 3.2: Serialize each row into its JSON snippet
|
||||||
-- Carry odate and version for deduplication in seg_pieces
|
-- Carry odate and version for deduplication in seg_pieces
|
||||||
,serialized_flags AS (
|
,serialized_flags AS (
|
||||||
SELECT
|
SELECT
|
||||||
customer,
|
customer,
|
||||||
partgroup,
|
partgroup,
|
||||||
dataseg,
|
dataseg,
|
||||||
flag,
|
flag,
|
||||||
odate,
|
odate,
|
||||||
version,
|
version,
|
||||||
CONCAT(
|
CONCAT(
|
||||||
'"', flag, '":',
|
'"', flag, '":',
|
||||||
JSON_QUERY((
|
JSON_QUERY((
|
||||||
SELECT
|
SELECT
|
||||||
version,
|
version,
|
||||||
dataseg AS datasegment,
|
dataseg AS datasegment,
|
||||||
part,
|
part,
|
||||||
qty,
|
qty,
|
||||||
price,
|
price,
|
||||||
odate,
|
odate,
|
||||||
ordnum,
|
ordnum,
|
||||||
quoten,
|
quoten,
|
||||||
flag
|
flag
|
||||||
FOR JSON PATH, WITHOUT_ARRAY_WRAPPER
|
FOR JSON PATH, WITHOUT_ARRAY_WRAPPER
|
||||||
))
|
))
|
||||||
) AS json_piece
|
) AS json_piece
|
||||||
FROM exploded_flags
|
FROM exploded_flags
|
||||||
)
|
)
|
||||||
--SELECT * FROM serialized_flags
|
--SELECT * FROM serialized_flags
|
||||||
-- Step 3.3: Collect all global-level flags (mrs, mrq, lvs, lvq)
|
-- Step 3.3: Collect all global-level flags (mrs, mrq, lvs, lvq)
|
||||||
,flag_json AS (
|
,flag_json AS (
|
||||||
SELECT
|
SELECT
|
||||||
customer,
|
customer,
|
||||||
partgroup,
|
partgroup,
|
||||||
STRING_AGG(json_piece, ',') AS json_block
|
STRING_AGG(json_piece, ',') AS json_block
|
||||||
FROM serialized_flags
|
FROM serialized_flags
|
||||||
WHERE flag IN ('mrs', 'mrq', 'lvs', 'lvq')
|
WHERE flag IN ('mrs', 'mrq', 'lvs', 'lvq')
|
||||||
GROUP BY customer, partgroup
|
GROUP BY customer, partgroup
|
||||||
)
|
)
|
||||||
--SELECT * FROM flag_json
|
--SELECT * FROM flag_json
|
||||||
-- Step 3.4: Nest dss/dsq under each dataseg
|
-- Step 3.4: Nest dss/dsq under each dataseg
|
||||||
-- Only keep the most recent dss/dsq per dataseg/version (prevents duplicate keys)
|
-- Only keep the most recent dss/dsq per dataseg/version (prevents duplicate keys)
|
||||||
,seg_pieces AS (
|
,seg_pieces AS (
|
||||||
SELECT
|
SELECT
|
||||||
customer,
|
customer,
|
||||||
partgroup,
|
partgroup,
|
||||||
dataseg,
|
dataseg,
|
||||||
STRING_AGG(json_piece, ',') AS inner_json
|
STRING_AGG(json_piece, ',') AS inner_json
|
||||||
FROM (
|
FROM (
|
||||||
SELECT sf.*
|
SELECT sf.*
|
||||||
FROM (
|
FROM (
|
||||||
SELECT *,
|
SELECT *,
|
||||||
ROW_NUMBER() OVER (
|
ROW_NUMBER() OVER (
|
||||||
PARTITION BY customer, partgroup, dataseg, flag
|
PARTITION BY customer, partgroup, dataseg, flag
|
||||||
ORDER BY odate DESC,
|
ORDER BY odate DESC,
|
||||||
CASE WHEN version = 'Actual' THEN 1 ELSE 0 END DESC
|
CASE WHEN version = 'Actual' THEN 1 ELSE 0 END DESC
|
||||||
) AS rn
|
) AS rn
|
||||||
FROM serialized_flags
|
FROM serialized_flags
|
||||||
WHERE flag IN ('dss', 'dsq')
|
WHERE flag IN ('dss', 'dsq')
|
||||||
) sf
|
) sf
|
||||||
WHERE sf.rn = 1
|
WHERE sf.rn = 1
|
||||||
) deduped
|
) deduped
|
||||||
GROUP BY customer, partgroup, dataseg
|
GROUP BY customer, partgroup, dataseg
|
||||||
)
|
)
|
||||||
--SELECT * FROM seg_pieces
|
--SELECT * FROM seg_pieces
|
||||||
-- Step 3.5: Wrap the inner_json under dataseg key
|
-- Step 3.5: Wrap the inner_json under dataseg key
|
||||||
,wrapped_segs AS (
|
,wrapped_segs AS (
|
||||||
SELECT
|
SELECT
|
||||||
customer,
|
customer,
|
||||||
partgroup,
|
partgroup,
|
||||||
CONCAT(
|
CONCAT(
|
||||||
'"', dataseg, '": {', inner_json, '}'
|
'"', dataseg, '": {', inner_json, '}'
|
||||||
) AS json_piece
|
) AS json_piece
|
||||||
FROM seg_pieces
|
FROM seg_pieces
|
||||||
)
|
)
|
||||||
-- Step 3.6: Aggregate all dataseg entries into one JSON block per customer/partgroup
|
-- Step 3.6: Aggregate all dataseg entries into one JSON block per customer/partgroup
|
||||||
,seg_json AS (
|
,seg_json AS (
|
||||||
SELECT
|
SELECT
|
||||||
customer,
|
customer,
|
||||||
partgroup,
|
partgroup,
|
||||||
STRING_AGG(json_piece, ',') AS json_block
|
STRING_AGG(json_piece, ',') AS json_block
|
||||||
FROM wrapped_segs
|
FROM wrapped_segs
|
||||||
GROUP BY customer, partgroup
|
GROUP BY customer, partgroup
|
||||||
)
|
)
|
||||||
--SELECT * FROM seg_json
|
--SELECT * FROM seg_json
|
||||||
--------------------------------------------------------------------------------
|
--------------------------------------------------------------------------------
|
||||||
-- Stage 4: Merge flags and segment blocks into a single JSON object
|
-- Stage 4: Merge flags and segment blocks into a single JSON object
|
||||||
-- Write final pricing history to pricing.lastpricedetail
|
-- Write final pricing history to pricing.lastpricedetail
|
||||||
--------------------------------------------------------------------------------
|
--------------------------------------------------------------------------------
|
||||||
INSERT INTO
|
INSERT INTO
|
||||||
pricing.lastpricedetail
|
pricing.lastpricedetail
|
||||||
SELECT
|
SELECT
|
||||||
COALESCE(f.customer, s.customer) AS customer,
|
COALESCE(f.customer, s.customer) AS customer,
|
||||||
COALESCE(f.partgroup, s.partgroup) AS partgroup,
|
COALESCE(f.partgroup, s.partgroup) AS partgroup,
|
||||||
CONCAT(
|
CONCAT(
|
||||||
'{',
|
'{',
|
||||||
COALESCE(f.json_block, ''),
|
COALESCE(f.json_block, ''),
|
||||||
CASE
|
CASE
|
||||||
WHEN f.json_block IS NOT NULL AND s.json_block IS NOT NULL THEN ','
|
WHEN f.json_block IS NOT NULL AND s.json_block IS NOT NULL THEN ','
|
||||||
ELSE ''
|
ELSE ''
|
||||||
END,
|
END,
|
||||||
COALESCE(s.json_block, ''),
|
COALESCE(s.json_block, ''),
|
||||||
'}'
|
'}'
|
||||||
) AS part_stats
|
) AS part_stats
|
||||||
FROM flag_json f
|
FROM flag_json f
|
||||||
FULL OUTER JOIN seg_json s
|
FULL OUTER JOIN seg_json s
|
||||||
ON f.customer = s.customer AND f.partgroup = s.partgroup;
|
ON f.customer = s.customer AND f.partgroup = s.partgroup;
|
||||||
|
|
||||||
--------------------------------------------------------------------------------
|
--------------------------------------------------------------------------------
|
||||||
-- Commit if everything succeeded
|
-- Commit if everything succeeded
|
||||||
--------------------------------------------------------------------------------
|
--------------------------------------------------------------------------------
|
||||||
COMMIT TRAN;
|
COMMIT TRAN;
|
||||||
END TRY
|
END TRY
|
||||||
BEGIN CATCH
|
BEGIN CATCH
|
||||||
-- Ensure transaction is rolled back
|
-- Ensure transaction is rolled back
|
||||||
IF XACT_STATE() <> 0
|
IF XACT_STATE() <> 0
|
||||||
|
|||||||
@ -2,204 +2,225 @@ CREATE OR ALTER PROCEDURE pricing.rebuild_pricelist
|
|||||||
AS
|
AS
|
||||||
BEGIN
|
BEGIN
|
||||||
SET NOCOUNT ON;
|
SET NOCOUNT ON;
|
||||||
|
SET XACT_ABORT ON; -- auto-rollback on most errors
|
||||||
|
|
||||||
DROP TABLE pricing.pricelist_ranged;
|
BEGIN TRY
|
||||||
|
BEGIN TRAN;
|
||||||
|
|
||||||
CREATE TABLE pricing.pricelist_ranged (
|
DROP TABLE pricing.pricelist_ranged;
|
||||||
jcplcd varchar(5) COLLATE SQL_Latin1_General_CP1_CI_AS NOT NULL,
|
|
||||||
jcpart varchar(20) COLLATE SQL_Latin1_General_CP1_CI_AS NOT NULL,
|
CREATE TABLE pricing.pricelist_ranged (
|
||||||
jcunit varchar(3) COLLATE SQL_Latin1_General_CP1_CI_AS NOT NULL,
|
jcplcd varchar(5) COLLATE SQL_Latin1_General_CP1_CI_AS NOT NULL,
|
||||||
jcvoll numeric(12,5) NOT NULL,
|
jcpart varchar(20) COLLATE SQL_Latin1_General_CP1_CI_AS NOT NULL,
|
||||||
jcpric numeric(12,5) NOT NULL,
|
jcunit varchar(3) COLLATE SQL_Latin1_General_CP1_CI_AS NOT NULL,
|
||||||
vb_from float NULL,
|
jcvoll numeric(12,5) NOT NULL,
|
||||||
vb_to float NULL,
|
jcpric numeric(12,5) NOT NULL,
|
||||||
price float NOT NULL
|
vb_from float NULL,
|
||||||
);
|
vb_to float NULL,
|
||||||
|
price float NOT NULL
|
||||||
|
);
|
||||||
|
|
||||||
|
CREATE NONCLUSTERED INDEX pricelist_ranged_idx ON PRICING.pricelist_ranged ( jcpart ASC , jcplcd ASC , vb_from ASC , vb_to ASC ) ;
|
||||||
|
|
||||||
|
--XXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXX
|
||||||
|
-----------------------------------------------------------traverse unit of measure graph-----------------------------------------------------------------------
|
||||||
|
--XXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXX
|
||||||
|
-------------setup table to hold target conversions---------------------
|
||||||
|
|
||||||
|
|
||||||
|
SELECT DISTINCT
|
||||||
|
jcpart partn
|
||||||
|
,jcunit fu
|
||||||
|
,'PC' tu
|
||||||
|
,cast(null as numeric) factor
|
||||||
|
INTO
|
||||||
|
#anchor
|
||||||
|
FROM
|
||||||
|
cmsinterfacein.lgdat.iprcc
|
||||||
|
WHERE
|
||||||
|
1=1;
|
||||||
|
|
||||||
|
--SELECT * FROM #anchor
|
||||||
|
|
||||||
|
-------pre-build punit stacked on itself with the columns flipped so you can go either direction per join---------
|
||||||
|
SELECT
|
||||||
|
*
|
||||||
|
INTO
|
||||||
|
#g
|
||||||
|
FROM
|
||||||
|
(
|
||||||
|
SELECT
|
||||||
|
IHPART IHPART,
|
||||||
|
rtrim(IHUNT1) IHUNT1,
|
||||||
|
rtrim(IHUNT2) IHUNT2,
|
||||||
|
IHCNV1 IHCNV1,
|
||||||
|
IHCNV2 IHCNV2
|
||||||
|
FROM
|
||||||
|
CMSInterfaceIN.LGDAT.PUNIT pu
|
||||||
|
--only deal with parts in the anchor table or the &&global parts
|
||||||
|
INNER JOIN (
|
||||||
|
SELECT DISTINCT partn FROM #anchor
|
||||||
|
) items ON
|
||||||
|
items.partn = pu.ihpart
|
||||||
|
OR pu.ihpart = '&&GLOBAL'
|
||||||
|
UNION
|
||||||
|
SELECT
|
||||||
|
IHPART IHPART,
|
||||||
|
rtrim(IHUNT2) IHUNT1,
|
||||||
|
rtrim(IHUNT1) IHUNT2,
|
||||||
|
IHCNV2 IHCNV1,
|
||||||
|
IHCNV1 IHCNV2
|
||||||
|
FROM
|
||||||
|
CMSInterfaceIN.LGDAT.PUNIT pu
|
||||||
|
--only deal with parts in the anchor table or the &&global parts
|
||||||
|
INNER JOIN (
|
||||||
|
SELECT DISTINCT partn FROM #anchor
|
||||||
|
) items ON
|
||||||
|
items.partn = pu.ihpart
|
||||||
|
OR pu.ihpart = '&&GLOBAL'
|
||||||
|
) x ;
|
||||||
|
|
||||||
|
CREATE INDEX g_idx on #g(ihpart,ihunt1);
|
||||||
|
|
||||||
|
WITH
|
||||||
|
--------do the expansion on all paths until the target uom is matched----------------------------------------------
|
||||||
|
--(complains about types not matching between anchor and recursion, explicitly just casting everything)
|
||||||
|
uom (partn, partx, lvl, mastf, mastt, xf, xt, factor, xfactor, xnum, xden, id, uom_list) AS
|
||||||
|
(
|
||||||
|
SELECT
|
||||||
|
cast(partn as varchar(20)) --partn
|
||||||
|
,cast(partn as varchar(20)) --partx
|
||||||
|
,cast(0 as int) --lvl
|
||||||
|
,fu --mastf
|
||||||
|
,tu --mastt
|
||||||
|
,cast(fu as varchar(3)) --xf
|
||||||
|
,cast(fu as varchar(3)) --xt
|
||||||
|
,CAST(1 AS FLOAT) --factor
|
||||||
|
,CAST(1 AS FLOAT) --xfactor
|
||||||
|
,CAST(1 AS FLOAT) --xnum
|
||||||
|
,CAST(1 AS FLOAT) --xden
|
||||||
|
,format(row_number() over (ORDER BY partn),'000000')
|
||||||
|
,cast(trim(fu) as varchar(max))
|
||||||
|
FROM
|
||||||
|
#anchor
|
||||||
|
UNION ALL
|
||||||
|
SELECT
|
||||||
|
cast(uom.partn as varchar(20)) --partn
|
||||||
|
,cast(ihpart as varchar(20)) --partx
|
||||||
|
,CAST(uom.lvl + 1 AS INT) --lvl
|
||||||
|
,uom.mastf --mastf
|
||||||
|
,uom.mastt --mastt
|
||||||
|
,cast(p.ihunt1 as varchar(3)) --xf
|
||||||
|
,cast(p.ihunt2 as varchar(3)) --xt
|
||||||
|
,CAST(p.ihcnv2/p.ihcnv1 AS FLOAT) --factor
|
||||||
|
,CAST(p.ihcnv2/p.ihcnv1 AS FLOAT) * uom.xfactor --xfactor
|
||||||
|
,p.ihcnv2 * uom.xnum --xnum
|
||||||
|
,p.ihcnv1 * uom.xden --xden
|
||||||
|
,uom.id + '.' + format(row_number() over (PARTITION BY uom.id ORDER BY partn),'00')
|
||||||
|
,uom.uom_list + '.' + trim(p.ihunt2)
|
||||||
|
FROM
|
||||||
|
uom
|
||||||
|
INNER JOIN #g p ON
|
||||||
|
p.ihpart IN (uom.partn,'&&GLOBAL')
|
||||||
|
AND p.ihunt1 = uom.xt
|
||||||
|
WHERE
|
||||||
|
1=1
|
||||||
|
--AND p.ihunt2 not in ('BD','BG','BU','BX','CA','CS','PA','PL','SL','C','K','DOZ','PR')
|
||||||
|
AND p.ihunt1 <> uom.mastt
|
||||||
|
--prevent recursion: newest joined UOM can't be in the history
|
||||||
|
AND charindex(p.ihunt2,uom.uom_list) = 0
|
||||||
|
)
|
||||||
|
--SELECT COUNT(*) FROM UOM
|
||||||
|
--------------uom is going to have multiple rows per requested conversion, need to use row_number to pick the best row------------------------------
|
||||||
|
,sorted AS (
|
||||||
|
SELECT
|
||||||
|
partn, mastf from_uom, xt to_uom, xfactor factor, lvl steps, row_number() OVER (PARTITION BY partn, mastf, mastt ORDER BY lvl ASC, factor ASC) rn
|
||||||
|
FROM
|
||||||
|
uom
|
||||||
|
WHERE
|
||||||
|
xt = mastt
|
||||||
|
)
|
||||||
|
SELECT * INTO #uom FROM sorted WHERE rn = 1;
|
||||||
|
--so far so good
|
||||||
|
|
||||||
|
drop table #anchor;
|
||||||
|
drop table #g;
|
||||||
|
|
||||||
|
TRUNCATE TABLE pricing.pricelist_ranged;
|
||||||
|
|
||||||
|
WITH
|
||||||
|
conv AS (
|
||||||
|
SELECT
|
||||||
|
p.jcplcd,
|
||||||
|
p.jcpart,
|
||||||
|
p.jcunit,
|
||||||
|
p.jcvoll,
|
||||||
|
p.jcpric,
|
||||||
|
u.factor,
|
||||||
|
-- Normalize volume and price to PC
|
||||||
|
p.jcvoll * u.factor AS vol_pc,
|
||||||
|
p.jcpric / u.factor AS price_pc
|
||||||
|
FROM
|
||||||
|
cmsinterfacein.lgdat.iprcc p
|
||||||
|
INNER JOIN #uom u
|
||||||
|
ON u.partn = p.jcpart
|
||||||
|
AND u.from_uom = p.jcunit
|
||||||
|
AND u.to_uom = 'PC'
|
||||||
|
),
|
||||||
|
sorted AS (
|
||||||
|
SELECT
|
||||||
|
c.*,
|
||||||
|
ROW_NUMBER() OVER (PARTITION BY c.jcplcd, c.jcpart ORDER BY vol_pc ASC) AS rn
|
||||||
|
FROM conv c
|
||||||
|
),
|
||||||
|
ranged AS (
|
||||||
|
SELECT
|
||||||
|
curr.jcplcd,
|
||||||
|
curr.jcpart,
|
||||||
|
curr.jcunit,
|
||||||
|
curr.jcvoll,
|
||||||
|
curr.jcpric,
|
||||||
|
curr.vol_pc,
|
||||||
|
curr.price_pc,
|
||||||
|
curr.vol_pc AS vb_from,
|
||||||
|
COALESCE(next.vol_pc, 9999999.0) AS vb_to
|
||||||
|
FROM
|
||||||
|
sorted curr
|
||||||
|
LEFT JOIN sorted next
|
||||||
|
ON curr.jcplcd = next.jcplcd
|
||||||
|
AND curr.jcpart = next.jcpart
|
||||||
|
AND curr.rn + 1 = next.rn
|
||||||
|
)
|
||||||
|
INSERT INTO
|
||||||
|
pricing.pricelist_ranged
|
||||||
|
SELECT
|
||||||
|
RTRIM(jcplcd) jcplcd,
|
||||||
|
RTRIM(jcpart) jcpart,
|
||||||
|
jcunit,
|
||||||
|
jcvoll,
|
||||||
|
jcpric,
|
||||||
|
vb_from,
|
||||||
|
vb_to,
|
||||||
|
price_pc AS price
|
||||||
|
FROM
|
||||||
|
ranged;
|
||||||
|
|
||||||
|
--CREATE INDEX pricelist_ranged_idx ON pricing.pricelist_ranged(jcpart, jcplcd, vb_from, vb_to);
|
||||||
|
|
||||||
|
COMMIT TRAN;
|
||||||
|
END TRY
|
||||||
|
BEGIN CATCH
|
||||||
|
-- Ensure transaction is rolled back
|
||||||
|
IF XACT_STATE() <> 0
|
||||||
|
BEGIN
|
||||||
|
ROLLBACK TRAN;
|
||||||
|
END
|
||||||
|
|
||||||
CREATE NONCLUSTERED INDEX pricelist_ranged_idx ON PRICING.pricelist_ranged ( jcpart ASC , jcplcd ASC , vb_from ASC , vb_to ASC ) ;
|
IF OBJECT_ID('tempdb..#anchor') IS NOT NULL DROP TABLE #anchor;
|
||||||
|
IF OBJECT_ID('tempdb..#g') IS NOT NULL DROP TABLE #g;
|
||||||
|
IF OBJECT_ID('tempdb..#uom') IS NOT NULL DROP TABLE #uom;
|
||||||
|
|
||||||
--XXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXX
|
-- Re-throw original error
|
||||||
-----------------------------------------------------------traverse unit of measure graph-----------------------------------------------------------------------
|
THROW;
|
||||||
--XXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXX
|
END CATCH;
|
||||||
-------------setup table to hold target conversions---------------------
|
|
||||||
|
|
||||||
|
|
||||||
SELECT DISTINCT
|
|
||||||
jcpart partn
|
|
||||||
,jcunit fu
|
|
||||||
,'PC' tu
|
|
||||||
,cast(null as numeric) factor
|
|
||||||
INTO
|
|
||||||
#anchor
|
|
||||||
FROM
|
|
||||||
cmsinterfacein.lgdat.iprcc
|
|
||||||
WHERE
|
|
||||||
1=1;
|
|
||||||
|
|
||||||
--SELECT * FROM #anchor
|
|
||||||
|
|
||||||
-------pre-build punit stacked on itself with the columns flipped so you can go either direction per join---------
|
|
||||||
SELECT
|
|
||||||
*
|
|
||||||
INTO
|
|
||||||
#g
|
|
||||||
FROM
|
|
||||||
(
|
|
||||||
SELECT
|
|
||||||
IHPART IHPART,
|
|
||||||
rtrim(IHUNT1) IHUNT1,
|
|
||||||
rtrim(IHUNT2) IHUNT2,
|
|
||||||
IHCNV1 IHCNV1,
|
|
||||||
IHCNV2 IHCNV2
|
|
||||||
FROM
|
|
||||||
CMSInterfaceIN.LGDAT.PUNIT pu
|
|
||||||
--only deal with parts in the anchor table or the &&global parts
|
|
||||||
INNER JOIN (
|
|
||||||
SELECT DISTINCT partn FROM #anchor
|
|
||||||
) items ON
|
|
||||||
items.partn = pu.ihpart
|
|
||||||
OR pu.ihpart = '&&GLOBAL'
|
|
||||||
UNION
|
|
||||||
SELECT
|
|
||||||
IHPART IHPART,
|
|
||||||
rtrim(IHUNT2) IHUNT1,
|
|
||||||
rtrim(IHUNT1) IHUNT2,
|
|
||||||
IHCNV2 IHCNV1,
|
|
||||||
IHCNV1 IHCNV2
|
|
||||||
FROM
|
|
||||||
CMSInterfaceIN.LGDAT.PUNIT pu
|
|
||||||
--only deal with parts in the anchor table or the &&global parts
|
|
||||||
INNER JOIN (
|
|
||||||
SELECT DISTINCT partn FROM #anchor
|
|
||||||
) items ON
|
|
||||||
items.partn = pu.ihpart
|
|
||||||
OR pu.ihpart = '&&GLOBAL'
|
|
||||||
) x ;
|
|
||||||
|
|
||||||
CREATE INDEX g_idx on #g(ihpart,ihunt1);
|
|
||||||
|
|
||||||
WITH
|
|
||||||
--------do the expansion on all paths until the target uom is matched----------------------------------------------
|
|
||||||
--(complains about types not matching between anchor and recursion, explicitly just casting everything)
|
|
||||||
uom (partn, partx, lvl, mastf, mastt, xf, xt, factor, xfactor, xnum, xden, id, uom_list) AS
|
|
||||||
(
|
|
||||||
SELECT
|
|
||||||
cast(partn as varchar(20)) --partn
|
|
||||||
,cast(partn as varchar(20)) --partx
|
|
||||||
,cast(0 as int) --lvl
|
|
||||||
,fu --mastf
|
|
||||||
,tu --mastt
|
|
||||||
,cast(fu as varchar(3)) --xf
|
|
||||||
,cast(fu as varchar(3)) --xt
|
|
||||||
,CAST(1 AS FLOAT) --factor
|
|
||||||
,CAST(1 AS FLOAT) --xfactor
|
|
||||||
,CAST(1 AS FLOAT) --xnum
|
|
||||||
,CAST(1 AS FLOAT) --xden
|
|
||||||
,format(row_number() over (ORDER BY partn),'000000')
|
|
||||||
,cast(trim(fu) as varchar(max))
|
|
||||||
FROM
|
|
||||||
#anchor
|
|
||||||
UNION ALL
|
|
||||||
SELECT
|
|
||||||
cast(uom.partn as varchar(20)) --partn
|
|
||||||
,cast(ihpart as varchar(20)) --partx
|
|
||||||
,CAST(uom.lvl + 1 AS INT) --lvl
|
|
||||||
,uom.mastf --mastf
|
|
||||||
,uom.mastt --mastt
|
|
||||||
,cast(p.ihunt1 as varchar(3)) --xf
|
|
||||||
,cast(p.ihunt2 as varchar(3)) --xt
|
|
||||||
,CAST(p.ihcnv2/p.ihcnv1 AS FLOAT) --factor
|
|
||||||
,CAST(p.ihcnv2/p.ihcnv1 AS FLOAT) * uom.xfactor --xfactor
|
|
||||||
,p.ihcnv2 * uom.xnum --xnum
|
|
||||||
,p.ihcnv1 * uom.xden --xden
|
|
||||||
,uom.id + '.' + format(row_number() over (PARTITION BY uom.id ORDER BY partn),'00')
|
|
||||||
,uom.uom_list + '.' + trim(p.ihunt2)
|
|
||||||
FROM
|
|
||||||
uom
|
|
||||||
INNER JOIN #g p ON
|
|
||||||
p.ihpart IN (uom.partn,'&&GLOBAL')
|
|
||||||
AND p.ihunt1 = uom.xt
|
|
||||||
WHERE
|
|
||||||
1=1
|
|
||||||
--AND p.ihunt2 not in ('BD','BG','BU','BX','CA','CS','PA','PL','SL','C','K','DOZ','PR')
|
|
||||||
AND p.ihunt1 <> uom.mastt
|
|
||||||
--prevent recursion: newest joined UOM can't be in the history
|
|
||||||
AND charindex(p.ihunt2,uom.uom_list) = 0
|
|
||||||
)
|
|
||||||
--SELECT COUNT(*) FROM UOM
|
|
||||||
--------------uom is going to have multiple rows per requested conversion, need to use row_number to pick the best row------------------------------
|
|
||||||
,sorted AS (
|
|
||||||
SELECT
|
|
||||||
partn, mastf from_uom, xt to_uom, xfactor factor, lvl steps, row_number() OVER (PARTITION BY partn, mastf, mastt ORDER BY lvl ASC, factor ASC) rn
|
|
||||||
FROM
|
|
||||||
uom
|
|
||||||
WHERE
|
|
||||||
xt = mastt
|
|
||||||
)
|
|
||||||
SELECT * INTO #uom FROM sorted WHERE rn = 1;
|
|
||||||
--so far so good
|
|
||||||
|
|
||||||
drop table #anchor;
|
|
||||||
drop table #g;
|
|
||||||
|
|
||||||
TRUNCATE TABLE pricing.pricelist_ranged;
|
|
||||||
|
|
||||||
WITH
|
|
||||||
conv AS (
|
|
||||||
SELECT
|
|
||||||
p.jcplcd,
|
|
||||||
p.jcpart,
|
|
||||||
p.jcunit,
|
|
||||||
p.jcvoll,
|
|
||||||
p.jcpric,
|
|
||||||
u.factor,
|
|
||||||
-- Normalize volume and price to PC
|
|
||||||
p.jcvoll * u.factor AS vol_pc,
|
|
||||||
p.jcpric / u.factor AS price_pc
|
|
||||||
FROM
|
|
||||||
cmsinterfacein.lgdat.iprcc p
|
|
||||||
INNER JOIN #uom u
|
|
||||||
ON u.partn = p.jcpart
|
|
||||||
AND u.from_uom = p.jcunit
|
|
||||||
AND u.to_uom = 'PC'
|
|
||||||
),
|
|
||||||
sorted AS (
|
|
||||||
SELECT
|
|
||||||
c.*,
|
|
||||||
ROW_NUMBER() OVER (PARTITION BY c.jcplcd, c.jcpart ORDER BY vol_pc ASC) AS rn
|
|
||||||
FROM conv c
|
|
||||||
),
|
|
||||||
ranged AS (
|
|
||||||
SELECT
|
|
||||||
curr.jcplcd,
|
|
||||||
curr.jcpart,
|
|
||||||
curr.jcunit,
|
|
||||||
curr.jcvoll,
|
|
||||||
curr.jcpric,
|
|
||||||
curr.vol_pc,
|
|
||||||
curr.price_pc,
|
|
||||||
curr.vol_pc AS vb_from,
|
|
||||||
COALESCE(next.vol_pc, 9999999.0) AS vb_to
|
|
||||||
FROM
|
|
||||||
sorted curr
|
|
||||||
LEFT JOIN sorted next
|
|
||||||
ON curr.jcplcd = next.jcplcd
|
|
||||||
AND curr.jcpart = next.jcpart
|
|
||||||
AND curr.rn + 1 = next.rn
|
|
||||||
)
|
|
||||||
INSERT INTO
|
|
||||||
pricing.pricelist_ranged
|
|
||||||
SELECT
|
|
||||||
RTRIM(jcplcd) jcplcd,
|
|
||||||
RTRIM(jcpart) jcpart,
|
|
||||||
jcunit,
|
|
||||||
jcvoll,
|
|
||||||
jcpric,
|
|
||||||
vb_from,
|
|
||||||
vb_to,
|
|
||||||
price_pc AS price
|
|
||||||
FROM
|
|
||||||
ranged;
|
|
||||||
|
|
||||||
--CREATE INDEX pricelist_ranged_idx ON pricing.pricelist_ranged(jcpart, jcplcd, vb_from, vb_to);
|
|
||||||
END;
|
END;
|
||||||
@ -1,28 +1,42 @@
|
|||||||
CREATE OR ALTER PROCEDURE pricing.rebuild_targets
|
CREATE OR ALTER PROCEDURE pricing.rebuild_targets
|
||||||
AS
|
AS
|
||||||
BEGIN
|
BEGIN
|
||||||
SET NOCOUNT ON;
|
SET NOCOUNT ON;
|
||||||
|
SET XACT_ABORT ON; -- auto-rollback on most runtime errors
|
||||||
|
|
||||||
DELETE FROM pricing.target_prices;
|
BEGIN TRY
|
||||||
|
BEGIN TRAN;
|
||||||
|
|
||||||
INSERT INTO
|
DELETE FROM pricing.target_prices;
|
||||||
pricing.target_prices
|
|
||||||
SELECT
|
INSERT INTO
|
||||||
stlc,
|
pricing.target_prices
|
||||||
ds,
|
SELECT
|
||||||
chan,
|
stlc,
|
||||||
tier,
|
ds,
|
||||||
vol,
|
chan,
|
||||||
-- Extract lower bound: text between '[' and ','
|
tier,
|
||||||
TRY_CAST(SUBSTRING(vol, 2, CHARINDEX(',', vol) - 2) AS INT) AS lower_bound,
|
vol,
|
||||||
-- Extract upper bound: text between ',' and ')'
|
-- Extract lower bound: text between '[' and ','
|
||||||
CASE
|
TRY_CAST(SUBSTRING(vol, 2, CHARINDEX(',', vol) - 2) AS INT) AS lower_bound,
|
||||||
WHEN RIGHT(vol, 2) = ',)' THEN NULL
|
-- Extract upper bound: text between ',' and ')'
|
||||||
ELSE TRY_CAST(SUBSTRING(vol, CHARINDEX(',', vol) + 1, LEN(vol) - CHARINDEX(',', vol) - 1) AS INT)
|
CASE
|
||||||
END AS upper_bound,
|
WHEN RIGHT(vol, 2) = ',)' THEN NULL
|
||||||
price,
|
ELSE TRY_CAST(SUBSTRING(vol, CHARINDEX(',', vol) + 1, LEN(vol) - CHARINDEX(',', vol) - 1) AS INT)
|
||||||
math
|
END AS upper_bound,
|
||||||
FROM
|
price,
|
||||||
usmidsap02.ubm.pricequote.target_prices_view;
|
math
|
||||||
|
FROM
|
||||||
|
usmidsap02.ubm.pricequote.target_prices_view;
|
||||||
|
|
||||||
END;
|
COMMIT TRAN;
|
||||||
|
|
||||||
|
END TRY
|
||||||
|
BEGIN CATCH
|
||||||
|
IF XACT_STATE() <> 0
|
||||||
|
ROLLBACK TRAN;
|
||||||
|
|
||||||
|
-- Rethrow original error
|
||||||
|
THROW;
|
||||||
|
END CATCH;
|
||||||
|
END
|
||||||
|
|||||||
66
rebuild/sync_external.ms.sql
Normal file
66
rebuild/sync_external.ms.sql
Normal file
@ -0,0 +1,66 @@
|
|||||||
|
CREATE OR ALTER PROCEDURE pricing.sync_external
|
||||||
|
AS
|
||||||
|
BEGIN
|
||||||
|
SET NOCOUNT ON;
|
||||||
|
SET XACT_ABORT ON; -- causes runtime errors to auto-rollback
|
||||||
|
|
||||||
|
BEGIN TRY
|
||||||
|
|
||||||
|
BEGIN TRAN;
|
||||||
|
-- Refresh pricing.ffcret
|
||||||
|
TRUNCATE TABLE pricing.ffcret;
|
||||||
|
INSERT INTO pricing.ffcret
|
||||||
|
SELECT *
|
||||||
|
FROM fanalysis.rlarp.ffcret;
|
||||||
|
|
||||||
|
-- Refresh pricing.ffterr
|
||||||
|
TRUNCATE TABLE pricing.ffterr;
|
||||||
|
INSERT INTO pricing.ffterr
|
||||||
|
SELECT *
|
||||||
|
FROM fanalysis.rlarp.ffterr;
|
||||||
|
|
||||||
|
-- Refresh pricing.gld
|
||||||
|
TRUNCATE TABLE pricing.gld;
|
||||||
|
INSERT INTO pricing.gld
|
||||||
|
SELECT *
|
||||||
|
FROM fanalysis.rlarp.gld;
|
||||||
|
|
||||||
|
-- Refresh pricing.qrh
|
||||||
|
TRUNCATE TABLE pricing.qrh;
|
||||||
|
INSERT INTO pricing.qrh
|
||||||
|
SELECT *
|
||||||
|
FROM fanalysis.rlarp.qrh;
|
||||||
|
|
||||||
|
-- Refresh pricing.sach
|
||||||
|
TRUNCATE TABLE pricing.sach;
|
||||||
|
INSERT INTO pricing.sach
|
||||||
|
SELECT *
|
||||||
|
FROM fanalysis.lgdat.sach;
|
||||||
|
|
||||||
|
COMMIT TRAN;
|
||||||
|
|
||||||
|
-- rebuild last price
|
||||||
|
EXEC pricing.rebuild_lastprice;
|
||||||
|
|
||||||
|
-- rebuild ranged price list
|
||||||
|
EXEC pricing.rebuild_pricelist;
|
||||||
|
|
||||||
|
-- rebuild target prices
|
||||||
|
EXEC pricing.rebuild_targets;
|
||||||
|
|
||||||
|
END TRY
|
||||||
|
|
||||||
|
BEGIN CATCH
|
||||||
|
-- Rollback if any error
|
||||||
|
IF XACT_STATE() <> 0
|
||||||
|
ROLLBACK TRAN;
|
||||||
|
|
||||||
|
-- rethrow original error with context
|
||||||
|
DECLARE @ErrMsg NVARCHAR(4000) = ERROR_MESSAGE();
|
||||||
|
DECLARE @ErrSec NVARCHAR(200) = ERROR_SEVERITY();
|
||||||
|
DECLARE @ErrState INT = ERROR_STATE();
|
||||||
|
RAISERROR('refresh_pricing_tables failed: %s', 16, 1, @ErrMsg);
|
||||||
|
THROW; -- rethrow original error for callers to handle
|
||||||
|
END CATCH;
|
||||||
|
|
||||||
|
END
|
||||||
Loading…
Reference in New Issue
Block a user