live_quote_mv.pg.sql

@@ -0,0 +1,70 @@
+
+set work_mem TO '4GB';
+
+DROP TABLE IF EXISTS rlarp.live_quotes_review_mv;
+CREATE TABLE rlarp.live_quotes_review_mv AS 
+WITH 
+lq AS MATERIALIZED (
+    SELECT 
+        lq.*
+        ,substring(lq.part,1,8) mold
+    FROM 
+        pricequote.live_quotes lq
+)
+,lqg AS (
+    SELECT 
+        lq.*
+        ,pricing->'product'->>'mold' part_group
+        ,substring(pricing->'customer'->>'chan',1,1) qchan
+        ,pricing->'customer'->>'cust' qcust
+        ,pricing->'product'->>'itemrel' item_fit
+        ,(pricing->'product'->>'pltq')::numeric pltq
+        ,(pricing->'guidance'->'finalPrice'->>'Price')::numeric guidance
+        ,pricing->'guidance'->'finalPrice'->>'Reason' reason
+        ,(pricing->'product'->>'cstd_usd_ina')::numeric fstd_usd
+        ,(pricing->'guidance'->>'ltp')::numeric ltp
+        ,(pricing->'guidance'->>'optimization')::numeric optimization
+        ,(pricing->'guidance'->>'inflationFactor')::numeric inflation
+        ,jsonb_pretty(pricing) pricing
+    FROM 
+        lq
+        LEFT JOIN LATERAL rlarp.guidance_r1(
+            rlarp.get_guidance_dseg(lq.billto,lq.shipto,substring(lq.part,1,8),lq.v1ds,lq.units_each,2024)
+        ) pricing ON TRUE
+    WHERE
+        lq.qstat ~ 'Submitted'
+)
+,hist AS (
+    SELECT 
+        g.*
+        ,gset.chan
+        --,gset.mold moldh
+        ,gset.v1ds v1dsh
+        ,gset.cust
+        ,gset.vers
+        ,je.k
+        ,seas.*
+    FROM
+        lqg g 
+        LEFT OUTER JOIN rlarp.price_pool_dev p ON
+            p.gset @> jsonb_build_object('mold',g.part_group)
+            AND p.gset ? 'cust'
+            AND p.gset ? 'v1ds'
+        LEFT JOIN LATERAL jsonb_to_record(p.gset) AS gset(
+             chan text
+            ,mold text
+            ,v1ds text
+            ,v0ds text
+            ,cust text
+            ,vers text
+            --,nurs text
+            --,ghse text
+        ) ON TRUE
+        LEFT JOIN LATERAL jsonb_each(p.season) je(k,v) on true
+        LEFT JOIN Lateral jsonb_to_record(je.v) as seas(
+        	units numeric
+        	,sales_usd numeric
+        	,price_usd numeric
+        ) ON TRUE
+)
+SELECT * FROM hist;

sql/consume_pricepool.pg.sql

@@ -10,7 +10,7 @@ SELECT
     ,je.k
     ,seas.*
 FROM 
-    rlarp.price_pool p
+    rlarp.price_pool_dev p
     LEFT JOIN LATERAL jsonb_to_record(p.gset) AS gset(
          chan text
         ,mold text

sql/get_hist.pg.sql

@@ -18,7 +18,7 @@ sort AS (
         ,stats.*
         ,season
     FROM 
-        rlarp.price_pool p
+        rlarp.price_pool_dev p
         JOIN LATERAL jsonb_to_record(gset) AS gset(
              chan text
             ,mold text

sql/get_hist_debug.pg.sql

@@ -11,7 +11,7 @@ sel AS (select 'v1:T..PLT..' _v1ds, 'KAWAHARA NURSERY' _cust, 'AZE10001' _mold,
         ,stats.*
         ,season
     FROM 
-        rlarp.price_pool p
+        rlarp.price_pool_dev p
         CROSS JOIN sel
         JOIN LATERAL jsonb_to_record(gset) AS gset(
              chan text

sql/gethist.sql

@@ -25,7 +25,7 @@ BEGIN
             stats,
             (SELECT doc FROM getj) AS gdoc
         FROM 
-            rlarp.price_pool p
+            rlarp.price_pool_dev p
         WHERE  
             gset @> jsonb_build_object(
                 'mold', (SELECT doc->>'mold' FROM getj),

sql/gethist_table.pg.sql

@@ -10,7 +10,7 @@ sel AS (select 'v1:P.P.PLT..' _v1ds, 'ALTMAN PLANTS' _cust, 'TFR001G0' _mold, 'D
         ,row_number() OVER (PARTITION BY p.agglevel ORDER BY avgunits DESC) rn
         ,stats.*
     FROM 
-        rlarp.price_pool p
+        rlarp.price_pool_dev p
         CROSS JOIN sel
         JOIN LATERAL jsonb_to_record(gset) AS gset(
              chan text

sql/live_quote_nohist.pg.sql

@@ -0,0 +1,69 @@
+DROP TABLE IF EXISTS rlarp.live_quotes_nohist;
+
+CREATE TABLE rlarp.live_quotes_nohist AS 
+WITH 
+lq AS MATERIALIZED (
+    SELECT 
+        lq.*
+        ,substring(lq.part,1,8) mold
+    FROM 
+        pricequote.live_quotes lq
+)
+,lqg AS (
+    SELECT 
+        lq.*
+        ,pricing->'product'->>'mold' part_group
+        ,substring(pricing->'customer'->>'chan',1,1) qchan
+        ,pricing->'customer'->>'cust' qcust
+        ,pricing->'product'->>'itemrel' item_fit
+        ,(pricing->'product'->>'pltq')::numeric pltq
+        ,(pricing->'guidance'->'finalPrice'->>'Price')::numeric guidance
+        ,pricing->'guidance'->'finalPrice'->>'Reason' reason
+        ,(pricing->'product'->>'cstd_usd_ina')::numeric fstd_usd
+        ,(pricing->'guidance'->>'ltp')::numeric ltp
+        ,(pricing->'guidance'->>'optimization')::numeric optimization
+        ,(pricing->'guidance'->>'inflationFactor')::numeric inflation
+        ,jsonb_pretty(pricing) pricing
+    FROM 
+        lq
+        LEFT JOIN LATERAL rlarp.guidance_r1(
+            rlarp.get_guidance_dseg(lq.billto,lq.shipto,substring(lq.part,1,8),lq.v1ds,lq.units_each,2024)
+        ) pricing ON TRUE
+    WHERE
+        TRUE
+        --lq.qstat ~ 'Submitted'
+)
+--,hist AS (
+--    SELECT 
+--        g.*
+--        ,gset.chan
+--        --,gset.mold moldh
+--        ,gset.v1ds v1dsh
+--        ,gset.cust
+--        ,gset.vers
+--        ,je.k
+--        ,seas.*
+--    FROM
+--        lqg g 
+--        LEFT OUTER JOIN rlarp.price_pool_dev p ON
+--            p.gset @> jsonb_build_object('mold',g.part_group)
+--            AND p.gset ? 'cust'
+--            AND p.gset ? 'v1ds'
+--        LEFT JOIN LATERAL jsonb_to_record(p.gset) AS gset(
+--             chan text
+--            ,mold text
+--            ,v1ds text
+--            ,v0ds text
+--            ,cust text
+--            ,vers text
+--            --,nurs text
+--            --,ghse text
+--        ) ON TRUE
+--        LEFT JOIN LATERAL jsonb_each(p.season) je(k,v) on true
+--        LEFT JOIN Lateral jsonb_to_record(je.v) as seas(
+--        	units numeric
+--        	,sales_usd numeric
+--        	,price_usd numeric
+--        ) ON TRUE
+--)
+SELECT * FROM lqg;

sql/live_quotes_review.pg.sql

@@ -46,7 +46,7 @@ lq AS MATERIALIZED (
         ,seas.*
     FROM
         lqg g 
-        LEFT OUTER JOIN rlarp.price_pool p ON
+        LEFT OUTER JOIN rlarp.price_pool_dev p ON
             p.gset @> jsonb_build_object('mold',g.part_group)
             AND p.gset ? 'cust'
             AND p.gset ? 'v1ds'

sql/livequotes_dev.pg.sql

@@ -0,0 +1,59 @@
+WITH 
+lq AS MATERIALIZED (
+    SELECT 
+        lq.*
+        ,substring(lq.part,1,8) mold
+    FROM 
+        pricequote.live_quotes lq
+)
+,lqg AS (
+    SELECT 
+        lq.*
+        ,m.part_group
+        ,(pricing->'guidance'->'finalPrice'->>'Price')::numeric guidance
+        ,pricing->'guidance'->'finalPrice'->>'Reason' reason
+        ,jsonb_pretty(pricing) pricing
+    FROM 
+        lq
+        JOIN LATERAL rlarp.guidance_r1(
+            rlarp.get_guidance_dseg(lq.billto,lq.shipto,substring(lq.part,1,8),lq.v1ds,lq.units_each,2024)
+        ) pricing ON TRUE
+        LEFT OUTER JOIN rlarp.molds m ON
+            m.stlc = lq.mold
+    WHERE
+        lq.qstat ~ 'Submitted'
+)
+,hist AS (
+    SELECT 
+        g.*
+        ,gset.chan
+        --,gset.mold moldh
+        ,gset.v1ds v1dsh
+        ,gset.cust
+        ,gset.vers
+        ,je.k
+        ,seas.*
+    FROM
+        lqg g 
+        LEFT OUTER JOIN rlarp.price_pool_dev p ON
+            p.gset @> jsonb_build_object('mold',g.part_group)
+            AND p.gset ? 'cust'
+            AND p.gset ? 'v1ds'
+        LEFT JOIN LATERAL jsonb_to_record(p.gset) AS gset(
+             chan text
+            ,mold text
+            ,v1ds text
+            ,v0ds text
+            ,cust text
+            ,vers text
+            --,nurs text
+            --,ghse text
+        ) ON TRUE
+        LEFT JOIN LATERAL jsonb_each(p.season) je(k,v) on true
+        LEFT JOIN Lateral jsonb_to_record(je.v) as seas(
+        	units numeric
+        	,sales_usd numeric
+        	,price_usd numeric
+        ) ON TRUE
+)
+SELECT * FROM hist WHERE qid = 73059

sql/price_pool.sql

@@ -3,6 +3,7 @@
 --$func$
 --BEGIN;
 DROP MATERIALIZED VIEW IF EXISTS rlarp.price_pool CASCADE;
+--CREATE TABLE IF NOT EXISTS rlarp.price_pool_dev AS (
 CREATE MATERIALIZED VIEW rlarp.price_pool AS (
     WITH
     agg AS (
@@ -11,13 +12,13 @@ CREATE MATERIALIZED VIEW rlarp.price_pool AS (
         ,substring(o.version,1,1) version
         ,o.chanwide
         ,o.nursery_region
-        ,o.greenhouse_region
+        ,c.greenhouse_region
-        ,o.partgroup baseitem
+        ,m.part_group baseitem
-        ,o.majgd
+        ,m.majg
-        ,o.assc
+        ,m.assc
-        ,o.coltierd
+        ,i.coltier
-        ,o.dataseg v1dataseg
+        ,'v1:' || rtrim(COALESCE(i.coltier, ''))|| '.' || rtrim(substring(COALESCE(i.branding, ''), 1, 1))|| '.' || rtrim(COALESCE(i.uomp, ''))|| '.' || rtrim(COALESCE(i.suffix, ''))|| '.' || rtrim(COALESCE(i.accs_ps, '')) v1dataseg
-        ,o.v0dataseg v0dataseg
+        ,_ds.dataseg v0dataseg
         ,o.oseas oseas
         ,round(sum(o.qty),0) units
         ,round(sum(o.sales_usd),0) sales_usd
@@ -25,43 +26,52 @@ CREATE MATERIALIZED VIEW rlarp.price_pool AS (
         ,count(DISTINCT o.ordnum) ordcount
     FROM
         rlarp.osm_stack o
+        INNER JOIN "CMS.CUSLG".itemm i ON
+            i.item = o.part
+        LEFT OUTER JOIN rlarp.molds m ON
+            m.stlc = i.stlc
+        LEFT OUTER JOIN _ds ON
+            _ds.colgrp = o.colgrp
+            AND _ds.brand = substring(i.branding,1,1)
         LEFT OUTER JOIN pricequote.market_setavgprice tp ON
                 tp.season = (SELECT ssyr FROM rlarp.gld where drange @> current_date)
             AND tp.country = 'ALL'
             AND tp.geo  = 'ALL'
             AND tp.region  = 'ALL'
-            AND tp.mold = o.stlc
+            AND tp.mold = i.stlc
             AND tp.chan = 'DISTRIB DROP SHIP'
-            AND tp.data_segment = o.dataseg
+            AND tp.data_segment = 'v1:' || rtrim(COALESCE(i.coltier, ''))|| '.' || rtrim(substring(COALESCE(i.branding, ''), 1, 1))|| '.' || rtrim(COALESCE(i.uomp, ''))|| '.' || rtrim(COALESCE(i.suffix, ''))|| '.' || rtrim(COALESCE(i.accs_ps, ''))    
         LEFT OUTER JOIN pricequote.market_setavgprice tq ON
                 tq.season = (SELECT ssyr FROM rlarp.gld where drange @> current_date)
             AND tq.country = 'ALL'
             AND tq.geo  = 'ALL'
             AND tq.region  = 'ALL'
-            AND tq.mold = o.stlc
+            AND tq.mold = i.stlc
             AND tq.chan = 'DISTRIB DROP SHIP'
-            AND tq.data_segment = o.v0dataseg
+            AND tq.data_segment = _ds.dataseg
+        LEFT OUTER JOIN rlarp.cust c ON
+            c.code = CASE o.chan WHEN 'DIR' THEN o.bill_cust ELSE o.ship_cust END
     WHERE
         o.version IN ('Actual','Quotes')
         AND o.oseas >= 2015
-        AND o.mingd <> 'B52'
+        AND o.dsm <> 'PW'
         --AND o.part like 'SQL035%'
         --AND o.calc_status <> 'CANCELED'
-        AND o.fs_line = '41010'
+        --AND o.fs_line = '41010'
         --AND o.dsm <> 'PW'
-        --AND i.coltierd <> 'C'
+        --AND i.coltier <> 'C'
     GROUP BY
          o.customer
         ,substring(o.version,1,1)
         ,o.chanwide
         ,o.nursery_region
-        ,o.greenhouse_region
+        ,c.greenhouse_region
-        ,o.partgroup
+        ,m.part_group
-        ,o.majgd
+        ,m.majg
-        ,o.assc
+        ,m.assc
-        ,o.coltierd
+        ,i.coltier
-        ,o.dataseg
+        ,'v1:' || rtrim(COALESCE(i.coltier, ''))|| '.' || rtrim(substring(COALESCE(i.branding, ''), 1, 1))|| '.' || rtrim(COALESCE(i.uomp, ''))|| '.' || rtrim(COALESCE(i.suffix, ''))|| '.' || rtrim(COALESCE(i.accs_ps, ''))
-        ,o.v0dataseg
+        ,_ds.dataseg
         ,o.oseas
     HAVING
         round(sum(o.qty),0) > 0
@@ -72,13 +82,13 @@ CREATE MATERIALIZED VIEW rlarp.price_pool AS (
         ,substring(o.version,1,1) version
         ,o.chanwide
         ,o.nursery_region
-        ,o.greenhouse_region
+        ,c.greenhouse_region
-        ,o.partgroup baseitem
+        ,m.part_group baseitem
-        ,o.majgd
+        ,m.majg
-        ,o.assc
+        ,m.assc
-        ,o.coltierd
+        ,i.coltier
-        ,o.dataseg v1dataseg
+        ,'v1:' || rtrim(COALESCE(i.coltier, ''))|| '.' || rtrim(substring(COALESCE(i.branding, ''), 1, 1))|| '.' || rtrim(COALESCE(i.uomp, ''))|| '.' || rtrim(COALESCE(i.suffix, ''))|| '.' || rtrim(COALESCE(i.accs_ps, '')) v1dataseg
-        ,o.v0dataseg v0dataseg
+        ,_ds.dataseg v0dataseg
         ,0 oseas
         ,round(sum(o.qty),0) units
         ,round(sum(o.sales_usd),0) sales_usd
@@ -86,43 +96,52 @@ CREATE MATERIALIZED VIEW rlarp.price_pool AS (
         ,count(DISTINCT o.ordnum) ordcount
     FROM
         rlarp.osm_stack o
+        INNER JOIN "CMS.CUSLG".itemm i ON
+            i.item = o.part
+        LEFT OUTER JOIN rlarp.molds m ON
+            m.stlc = i.stlc
+        LEFT OUTER JOIN _ds ON
+            _ds.colgrp = o.colgrp
+            AND _ds.brand = substring(i.branding,1,1)
         LEFT OUTER JOIN pricequote.market_setavgprice tp ON
                 tp.season = (SELECT ssyr FROM rlarp.gld where drange @> current_date)
             AND tp.country = 'ALL'
             AND tp.geo  = 'ALL'
             AND tp.region  = 'ALL'
-            AND tp.mold = o.stlc
+            AND tp.mold = i.stlc
             AND tp.chan = 'DISTRIB DROP SHIP'
-            AND tp.data_segment = o.dataseg
+            AND tp.data_segment = 'v1:' || rtrim(COALESCE(i.coltier, ''))|| '.' || rtrim(substring(COALESCE(i.branding, ''), 1, 1))|| '.' || rtrim(COALESCE(i.uomp, ''))|| '.' || rtrim(COALESCE(i.suffix, ''))|| '.' || rtrim(COALESCE(i.accs_ps, ''))    
         LEFT OUTER JOIN pricequote.market_setavgprice tq ON
                 tq.season = (SELECT ssyr FROM rlarp.gld where drange @> current_date)
             AND tq.country = 'ALL'
             AND tq.geo  = 'ALL'
             AND tq.region  = 'ALL'
-            AND tq.mold = o.stlc
+            AND tq.mold = i.stlc
             AND tq.chan = 'DISTRIB DROP SHIP'
-            AND tq.data_segment = o.v0dataseg
+            AND tq.data_segment = _ds.dataseg
+        LEFT OUTER JOIN rlarp.cust c ON
+            c.code = CASE o.chan WHEN 'DIR' THEN o.bill_cust ELSE o.ship_cust END
     WHERE
         o.version IN ('Actual','Quotes')
         AND o.odate >= current_date - '4 months'::interval
-        AND o.mingd <> 'B52'
+        AND o.dsm <> 'PW'
         --AND o.part like 'SQL035%'
         --AND o.calc_status <> 'CANCELED'
         --AND o.fs_line = '41010'
         --AND o.dsm <> 'PW'
-        --AND i.coltierd <> 'C'
+        --AND i.coltier <> 'C'
     GROUP BY
          o.customer
         ,substring(o.version,1,1)
         ,o.chanwide
         ,o.nursery_region
-        ,o.greenhouse_region
+        ,c.greenhouse_region
-        ,o.partgroup
+        ,m.part_group
-        ,o.majgd
+        ,m.majg
-        ,o.assc
+        ,m.assc
-        ,o.coltierd
+        ,i.coltier
-        ,o.dataseg
+        ,'v1:' || rtrim(COALESCE(i.coltier, ''))|| '.' || rtrim(substring(COALESCE(i.branding, ''), 1, 1))|| '.' || rtrim(COALESCE(i.uomp, ''))|| '.' || rtrim(COALESCE(i.suffix, ''))|| '.' || rtrim(COALESCE(i.accs_ps, ''))
-        ,o.v0dataseg
+        ,_ds.dataseg
         ,o.oseas
     HAVING
         round(sum(o.qty),0) > 0
@@ -148,7 +167,7 @@ CREATE MATERIALIZED VIEW rlarp.price_pool AS (
             ,sum(sales_usd)                           sales_usd 
             ,round(sum(sales_usd   )/sum(units),5)    price_usd
             ,round(sum(target_price)/sum(units) FILTER (WHERE COALESCE(target_price,0) <> 0 ),5)    target_price
-            ,jsonb_agg(DISTINCT coltierd)    coltierd
+            ,jsonb_agg(DISTINCT coltier)    coltier
             ,count(DISTINCT customer) custcount
             ,sum(ordcount) ordcount
         FROM

sql/quote_review.pg.sql

@@ -3,7 +3,6 @@
 DROP VIEW IF EXISTS rlarp.quote_review;
 CREATE VIEW rlarp.quote_review AS 
 WITH 
----------------------get quote lines from SQL Server---------------------
 lq AS MATERIALIZED (
     SELECT 
         lq.*
@@ -11,9 +10,8 @@ lq AS MATERIALIZED (
     FROM 
         pricequote.live_quotes lq
     WHERE 
-        qstat LIKE '%Submitted%'
+        qstat LIKE 'Submitted%'
 )
----------------------guidance logic---------------------------------------
 ,lqg AS (
     SELECT 
         lq.qid
@@ -69,9 +67,9 @@ lq AS MATERIALIZED (
                 -- if more than a pallet use the target price 
                 ELSE CASE WHEN units_each >=  8*mpck THEN (lq.upperpricelimit + lq.lowerpricelimit) / 2
                 -- if more than a pallet use the target price 
-                ELSE CASE WHEN units_each >=  2*mpck THEN lq.upperpricelimit
+                ELSE CASE WHEN units_each >=  4*mpck THEN lq.upperpricelimit
                 -- if more than a pallet use the target price 
-                ELSE  lq.upperpricelimit * 1.05
+                ELSE  lq.upperpricelimit * 1.15
                 END END END
             ELSE
                 CASE WHEN i.pricegroup ~ '(Hanger|Dish)' THEN
@@ -94,9 +92,6 @@ lq AS MATERIALIZED (
                     END END END
                 END
         END guidance
-        ,pl.price pricelist
-        ,pl.listcode
-        ,row_number() OVER (PARTITION BY qid, qline ORDER BY pl.price ASC) bestprice
         -- ,(pricing->'guidance'->>'ltp')::numeric ltp
         -- ,(pricing->'guidance'->>'optimization')::numeric optimization
         -- ,(pricing->'guidance'->>'inflationFactor')::numeric inflation
@@ -105,23 +100,9 @@ lq AS MATERIALIZED (
         lq
         LEFT OUTER JOIN "CMS.CUSLG".itemm i ON 
             i.item = lq.part
-        LEFT OUTER JOIN rlarp.cust bc ON   
-            bc.code = lq.billto
-        LEFT OUTER JOIN rlarp.cust sc ON   
-            sc.code = lq.shipto
-        LEFT OUTER JOIN rlarp.plcore_fullcode_ranged pl ON 
-            pl.item = lq.part 
-            AND jsonb_build_array(pl.listcode) <@ (COALESCE(sc.lists,bc.lists))
-            AND (
-                lq.units_each >= pl.vb_f
-                AND lq.units_each < pl.vb_t
-            )
     WHERE
         lq.qstat ~ 'Submitted'
 )
--- SELECT * FROM lqg where bestprice <> 1
--- SELECT * FROM lqg WHERE qid = 109352
----------------------------link in sales history----------------------------------------------
 ,hist AS (
     SELECT 
         g.*
@@ -154,7 +135,5 @@ lq AS MATERIALIZED (
         	,sales_usd numeric
         	,price_usd numeric
         ) ON TRUE
-    WHERE 
-        COALESCE(g.bestprice,1) = 1
 )
 SELECT * FROM hist --WHERE qid = 108655