create ranged price list in postgres

new_targets/scripts/make_hist.pg.sql

@@ -48,3 +48,5 @@ GROUP BY customer, partgroup
 )
 SELECT * FROM onerow --WHERE customer = 'ALTMAN PLANTS' AND partgroup = 'XPR15CS1'
 ) WITH DATA;
+
+SELECT * FROM pricequote.lastprice

new_targets/tables/pricelist_ranged.pg.sql

@@ -0,0 +1,98 @@
+DROP TABLE IF EXISTS uomc;
+
+CREATE TEMP TABLE uomc AS (
+WITH
+uom AS (
+    SELECT 
+        uom.p part
+        ,uom.f fu
+        ,uom.t tu
+        ,uom.nm/uom.dm conv
+    FROM 
+        (
+            SELECT 
+                jsonb_agg(row_to_json(d)::jsonb) jdoc 
+            FROM 
+                (
+                    select distinct 
+                        jcpart partn 
+                        , jcunit fu
+                        , 'PC' tu 
+                    from 
+                        lgdat.iprcc
+                    WHERE 
+                        jcpart <> ''
+                ) d
+        ) c 
+        JOIN LATERAL rlarp.uom_array(c.jdoc) uom ON TRUE
+)
+SELECT * FROM uom
+) WITH DATA;
+
+CREATE INDEX uom_idx ON uomc (part, fu, tu);
+
+
+-- Clear the output table
+TRUNCATE TABLE pricequote.pricelist_ranged;
+
+--DROP TABLE pricequote.pricelist_ranged;
+
+-- Compute normalized volume/price and ranges
+--CREATE TABLE pricequote.pricelist_ranged AS (
+WITH 
+conv AS (
+    SELECT
+        p.jcplcd,
+        p.jcpart,
+        p.jcunit,
+        p.jcvoll,
+        p.jcpric,
+        u.conv,
+        (p.jcvoll * u.conv) AS vol_pc,
+        (p.jcpric / NULLIF(u.conv, 0)) AS price_pc
+    FROM
+        lgdat.iprcc p
+        INNER JOIN uomc u 
+            ON u.part = p.jcpart
+            AND u.fu = p.jcunit 
+            AND u.tu = 'PC'
+),
+--SELECT * FROM conv LIMIT 1000
+sorted AS (
+    SELECT
+        *,
+        ROW_NUMBER() OVER (PARTITION BY jcplcd, jcpart ORDER BY vol_pc ASC) AS rn
+    FROM conv
+),
+ranged AS (
+    SELECT 
+        curr.jcplcd,
+        curr.jcpart,
+        curr.jcunit,
+        curr.jcvoll,
+        curr.jcpric,
+        curr.vol_pc,
+        curr.price_pc price,
+        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
+)
+--SELECT * FROM ranged
+INSERT INTO pricequote.pricelist_ranged (
+    jcplcd, jcpart, jcunit, jcvoll, jcpric, vb_from, vb_to, price
+)
+SELECT
+    jcplcd,
+    jcpart,
+    jcunit,
+    jcvoll,
+    jcpric,
+    vb_from,
+    vb_to,
+    price
+FROM ranged;