new_targets/price_queue_test.pg.sql

@@ -1,8 +1,9 @@
- SELECT jsonb_pretty(expl) FROM 
+ SELECT * FROM 
  pricequote.single_price_call(
-                        'GRIF0001' ,
+                        'CYGR0002' ,
-                        'GRIF0001' ,
+                        'CYGR0002' ,
-                        'XNS0T1G3G18B096' ,
+                        'SVP03002G18C800' ,
+                        'SVP03000',
                         'v1:B..PLT..',
                         100000
                 )
@@ -47,4 +48,4 @@ WHERE
 --	qstat LIKE 'Submitted%'
 	qid = 111832 --AND q.qrn = 1
 ORDER BY 
-	qrn ASC
+	qrn ASC

new_targets/procs/single_price_call.pg.sql

@@ -1,9 +1,10 @@
--- DROP FUNCTION IF EXISTS pricequote.single_price_call() CASCADE;
+DROP FUNCTION IF EXISTS pricequote.single_price_call;
 
 CREATE OR REPLACE FUNCTION pricequote.single_price_call(
     _bill TEXT,
     _ship TEXT,
     _part TEXT,
+    _stlc TEXT,
     _v1ds TEXT,
     _vol NUMERIC
 )
@@ -19,24 +20,15 @@ RETURNS TABLE (
     tier TEXT,
     pltq NUMERIC,
     plevel TEXT,
-    partgroup TEXT,
+--    hist JSONB,
-    -- history JSONB,
     last_price NUMERIC,
-    last_qty NUMERIC,
-    last_dataseg TEXT,
     last_date DATE,
     last_order TEXT,
     last_quote TEXT,
-    last_source TEXT,
     tprice NUMERIC,
-    tmath JSONB,
-    volume_range TEXT,
-    listprice NUMERIC,
-    listcode TEXT,
     guidance_price NUMERIC,
     guidance_reason TEXT,
-    expl JSONB,
+    expl JSONB
-    ui_json JSONB
 ) AS $$
 DECLARE
     _pltq NUMERIC;
@@ -44,83 +36,78 @@ DECLARE
     _tier TEXT;
     _cust TEXT;
     _plevel TEXT;
-    _partgroup TEXT;
-    _stlc TEXT;
     _tprice NUMERIC;
-    _tmath JSONB;
-    _volume_range TEXT;
-    _list_price NUMERIC;
-    _list_code TEXT;
-    _guidance_price NUMERIC;
-    _guidance_reason TEXT;
-    _hist JSONB := '{}'::jsonb;
-    -- Last sale/quote/volume/segment fields
-    _mrs JSONB; 
-    _mrq JSONB;
-    _lvs JSONB;
-    _lvq JSONB;
-    _dss JSONB;
-    _dsq JSONB;
-
-    -- Precedence chain
     _last_price NUMERIC;
-    _last_qty NUMERIC;
-    _last_dataseg TEXT;
     _last_date DATE;
     _last_order TEXT;
     _last_quote TEXT;
-    _last_source TEXT;
+    _list_price NUMERIC;
+    _list_code TEXT;
+    _hist JSONB := '{}'::jsonb;
     _expl JSONB := '{}'::jsonb;
-    _ui_json JSONB := '{}'::jsonb;
+	_this JSONB := '{}'::jsonb;
+    _guidance_price NUMERIC;
+    _guidance_reason TEXT;
+	_partgroup TEXT;
 BEGIN
     ------------------------------------------------------------------
     -- Step 1: Resolve customer metadata
     ------------------------------------------------------------------
-    SELECT
+	SELECT
-        i.mpck,
+	    i.mpck,
-        CASE SUBSTRING(bc.cclass, 2, 3)
+	    CASE SUBSTRING(bc.cclass, 2, 3)
-            WHEN 'DIS' THEN 
+	        WHEN 'DIS' THEN 
-                CASE SUBSTRING(sc.cclass, 2, 3)
+	            CASE SUBSTRING(sc.cclass, 2, 3)
-                    WHEN 'DIS' THEN 'WHS'
+	                WHEN 'DIS' THEN 'WHS'
-                    ELSE 'DRP'
+	                ELSE 'DRP'
-                END
+	            END
-            ELSE 'DIR'
+	        ELSE 'DIR'
-        END,
+	    END,
-        CASE SUBSTRING(bc.cclass, 2, 3)
+	    CASE SUBSTRING(bc.cclass, 2, 3)
-            WHEN 'DIR' THEN bc.tier
+	        WHEN 'DIR' THEN bc.tier
-            ELSE COALESCE(sc.tier, bc.tier)
+	        ELSE COALESCE(sc.tier, bc.tier)
-        END,
+	    END,
-        CASE SUBSTRING(bc.cclass, 2, 3)
+	    CASE SUBSTRING(bc.cclass, 2, 3)
-            WHEN 'DIS' THEN 
+	        WHEN 'DIS' THEN 
-                CASE SUBSTRING(sc.cclass, 2, 3)
+	            CASE SUBSTRING(sc.cclass, 2, 3)
-                    WHEN 'DIS' THEN bc.dba
+	                WHEN 'DIS' THEN bc.dba
-                    ELSE sc.dba
+	                ELSE sc.dba
-                END
+	            END
-            ELSE bc.dba
+	        ELSE bc.dba
-        END,
+	    END,
-        CASE SUBSTRING(bc.cclass, 2, 3)
+	    CASE SUBSTRING(bc.cclass, 2, 3)
-            WHEN 'DIS' THEN 
+	        WHEN 'DIS' THEN 
-                CASE SUBSTRING(sc.cclass, 2, 3)
+	            CASE SUBSTRING(sc.cclass, 2, 3)
-                    WHEN 'DIS' THEN sc.plevel
+	                WHEN 'DIS' THEN sc.plevel
-                    ELSE bc.plevel
+	                ELSE bc.plevel
-                END
+	            END
-            ELSE bc.plevel
+	        ELSE bc.plevel
-        END,
+	    END,
-        i.partgroup,
+		i.partgroup
-        substring(_part,1,8)
+	INTO _pltq, _chan, _tier, _cust, _plevel, _partgroup
-    INTO _pltq, _chan, _tier, _cust, _plevel, _partgroup, _stlc
+	FROM rlarp.cust bc
-    FROM rlarp.cust bc
+	LEFT JOIN rlarp.cust sc ON sc.code = _ship
-    LEFT JOIN rlarp.cust sc ON sc.code = _ship
+	LEFT JOIN "CMS.CUSLG".itemm i ON i.item = _part
-    LEFT JOIN "CMS.CUSLG".itemm i ON i.item = _part
+	WHERE bc.code = _bill;
-    WHERE bc.code = _bill;
+
+	-- RAISE NOTICE 'Step 1: %', _expl;
 
     ------------------------------------------------------------------
     -- Step 2: Target price logic
     ------------------------------------------------------------------
     SELECT tp.price,
-           to_json(tp.math),
+           jsonb_build_object(
-           tp.vol::text
+               'source', 'target price',
-    INTO _tprice, _tmath, _volume_range
+               'target_price', tp.price,
+               'calculated_pallets', FLOOR(_vol / NULLIF(_pltq, 0)),
+               'exact_pallets', ROUND(_vol / NULLIF(_pltq, 0), 5),
+               'volume range', tp.vol::TEXT,
+               'customer', _cust,
+               'channel', _chan,
+               'tier', TRIM(_tier),
+               'target math', tp.math
+           )
+    INTO _tprice, _this
     FROM pricequote.target_prices tp
     WHERE tp.stlc = _stlc
       AND tp.ds = _v1ds
@@ -128,178 +115,82 @@ BEGIN
       AND tp.tier = _tier
       AND FLOOR(_vol / NULLIF(_pltq, 0))::int <@ tp.vol;
 
+	IF _this IS NOT NULL THEN
+	    _expl := _expl || _this;
+	END IF;
+
+	-- RAISE NOTICE 'Step 2: %', _expl;
+
     ------------------------------------------------------------------
-    -- Step 3: Last sale/quote/volume/segment data
+    -- Step 3: Last sale data
     ------------------------------------------------------------------
-    SELECT
+    SELECT 
-        lp.part_stats
+        (lp.dataseg_stats -> _v1ds) ->> 'price',
-    INTO
+        (lp.dataseg_stats -> _v1ds) ->> 'odate',
-        _hist
+        (lp.dataseg_stats -> _v1ds) ->> 'ordnum',
-    FROM pricequote.lastpricedetail lp
+        (lp.dataseg_stats -> _v1ds) ->> 'quoten',
+        lp.dataseg_stats
+    INTO 
+        _last_price, _last_date, _last_order, _last_quote, _hist
+    FROM pricequote.lastprice lp
     WHERE lp.customer = _cust
       AND lp.partgroup = _partgroup;
 
-    -- Extract top-level keys
+	_expl := _expl || jsonb_build_object(
-    _mrs := _hist -> 'mrs';
+	    'last_price', _last_price,
-    _mrq := _hist -> 'mrq';
+	    'last_date', _last_date,
-    _lvs := _hist -> 'lvs';
+	    'last_order', _last_order,
-    _lvq := _hist -> 'lvq';
+	    'last_quote', _last_quote
+--	     'full_history_________', _hist
+	);
 
-    -- Extract per-datasegment block matching the input v1ds
+	-- RAISE NOTICE 'Step 3: %', _expl;
-    _dss := (_hist -> _v1ds) -> 'dss';
-    _dsq := (_hist -> _v1ds) -> 'dsq';
-
-    -- Precedence chain for last_price, etc.
-    _last_price := COALESCE(
-        (_dsq->>'price')::numeric,
-        (_dss->>'price')::numeric,
-        (_mrq->>'price')::numeric,
-        (_mrs->>'price')::numeric
-    );
-    _last_qty := COALESCE(
-        (_dsq->>'qty')::numeric,
-        (_dss->>'qty')::numeric,
-        (_mrq->>'qty')::numeric,
-        (_mrs->>'qty')::numeric
-    );
-    _last_dataseg := COALESCE(
-        _dsq->>'datasegment',
-        _dss->>'datasegment',
-        _mrq->>'datasegment',
-        _mrs->>'datasegment'
-    );
-    _last_date := COALESCE(
-        (_dsq->>'odate')::date,
-        (_dss->>'odate')::date,
-        (_mrq->>'odate')::date,
-        (_mrs->>'odate')::date
-    );
-    _last_order := COALESCE(
-        _dsq->>'ordnum',
-        _dss->>'ordnum',
-        _mrq->>'ordnum',
-        _mrs->>'ordnum'
-    );
-    _last_quote := COALESCE(
-        _dsq->>'quoten',
-        _dss->>'quoten',
-        _mrq->>'quoten',
-        _mrs->>'quoten'
-    );
-    _last_source := CASE
-        WHEN _dsq->>'price' IS NOT NULL THEN 'dsq'
-        WHEN _dss->>'price' IS NOT NULL THEN 'dss'
-        WHEN _mrq->>'price' IS NOT NULL THEN 'mrq'
-        WHEN _mrs->>'price' IS NOT NULL THEN 'mrs'
-        ELSE NULL
-    END;
 
     ------------------------------------------------------------------
     -- Step 4: List price
     ------------------------------------------------------------------
     SELECT 
-        pr.price::numeric(20,5), pr.jcplcd
+		pr.price::numeric(20,5), pr.jcplcd
     INTO 
-        _list_price, _list_code
+		_list_price, _list_code
     FROM 
-        "CMS.CUSLG".IPRCBHC i
+		"CMS.CUSLG".IPRCBHC i
-        JOIN pricequote.pricelist_ranged pr
+	    JOIN pricequote.pricelist_ranged pr
-            ON pr.jcplcd = TRIM(i.jbplcd)
+	        ON pr.jcplcd = TRIM(i.jbplcd)
-           AND pr.jcpart = _part
+	       AND pr.jcpart = _part
-           AND _vol >= pr.vb_from
+	       AND _vol >= pr.vb_from
-           AND (_vol < pr.vb_to OR pr.vb_to IS NULL)
+	       AND _vol < pr.vb_to
     WHERE TRIM(i.jbplvl) = TRIM(_plevel)
       AND CURRENT_DATE BETWEEN i.jbfdat AND i.jbtdat
     ORDER BY pr.price ASC
     LIMIT 1;
 
-    ------------------------------------------------------------------
+	_expl := _expl || jsonb_build_object(
-    -- Step 5: Compute guidance price and embed it
+	    'list_price', _list_price,
-    ------------------------------------------------------------------
+	    'list_code', _list_code
-    SELECT 
+	);
-        gl.guidance_price, gl.guidance_reason
+
-    INTO 
+	-- RAISE NOTICE 'Step 4: %', _expl;
-        _guidance_price, _guidance_reason
-    FROM 
-        pricequote.guidance_logic(_tprice, _last_price, _list_price, _last_date) gl;
 
     ------------------------------------------------------------------
-    -- Step 6: Build explanation JSON
+	-- Step 5: Compute guidance price and embed it
-    ------------------------------------------------------------------
+	------------------------------------------------------------------
-    _expl := jsonb_build_object(
+	
-        'last_price', _last_price,
+
-        'last_qty', _last_qty,
+    SELECT 
-        'last_dataseg', _last_dataseg,
+		gl.guidance_price, gl.guidance_reason
-        'last_source', _last_source,
+    INTO 
-        'last_date', _last_date,
+		_guidance_price, _guidance_reason
-        'last_order', _last_order,
+    FROM 
-        'last_quote', _last_quote,
+		pricequote.guidance_logic(_tprice, _last_price, _list_price, _last_date) gl;
-        'mrs', _mrs,
+	
-        'mrq', _mrq,
+    _expl := _expl || jsonb_build_object(
-        'lvs', _lvs,
-        'lvq', _lvq,
-        'dss', _dss,
-        'dsq', _dsq,
-        'target_price', _tprice,
-        'target_math', _tmath,
-        'calculated_pallets', FLOOR(_vol / NULLIF(_pltq, 0)),
-        'exact_pallets', ROUND(_vol / NULLIF(_pltq, 0), 5),
-        'customer', _cust,
-        'channel', _chan,
-        'tier', TRIM(_tier),
-        'list_price', _list_price,
-        'list_code', _list_code,
         'guidance_price', _guidance_price,
         'guidance_reason', _guidance_reason
     );
 
-    ------------------------------------------------------------------
+
-    -- Step 7: Build UI JSON (optional, similar to MSSQL)
+	-- RAISE NOTICE 'Step 5: %', _expl;
-    ------------------------------------------------------------------
-   _ui_json := jsonb_build_object(
-        'details', jsonb_build_array(
-            jsonb_build_object(
-                'label', 'History',
-                'details', jsonb_build_array(
-                    jsonb_build_object(
-                        'label', CASE WHEN _last_price IS NOT NULL THEN 'Last Sale: ' || _last_date ELSE 'No Recent' END,
-                        'value', COALESCE(_last_price,0),
-                        'type', 'currency',
-                        'note', CASE WHEN _last_price IS NOT NULL THEN _last_source || 
-                            CASE WHEN COALESCE(_last_order, '0') = '0' THEN ' Qt# ' || COALESCE(_last_quote, '') ELSE ' Ord# ' || COALESCE(_last_order, '') END
-                            ELSE NULL END
-                    )
-                )
-            ),
-            jsonb_build_object(
-                'label', 'List',
-                'details', jsonb_build_array(
-                    jsonb_build_object(
-                        'label', 'List:' || COALESCE(_list_code, ''),
-                        'value', _list_price,
-                        'type', 'currency',
-                        'note', _plevel
-                    )
-                )
-            ),
-            jsonb_build_object(
-                'label', 'Target Support',
-                'details', _tmath -- You may need to transform this to match the MSSQL panel
-            ),
-            jsonb_build_object(
-                'label', 'Guidance',
-                'details', jsonb_build_array(
-                    jsonb_build_object(
-                        'label', 'Price',
-                        'value', _guidance_price,
-                        'type', 'currency',
-                        'note', _guidance_reason
-                    )
-                )
-            )
-        ),
-        'data', _expl
-    );
 
     ------------------------------------------------------------------
     -- Final: Return row
@@ -307,12 +198,12 @@ BEGIN
     RETURN QUERY
     SELECT 
         _bill, _ship, _part, _stlc, _v1ds, _vol,
-        _chan, _cust, _tier, _pltq, _plevel, _partgroup,
+        _chan, _cust, _tier, _pltq, _plevel,
         -- _hist,
-        _last_price, _last_qty, _last_dataseg, _last_date, _last_order, _last_quote, _last_source,
+        _last_price, _last_date, _last_order, _last_quote,
-        _tprice, _tmath, _volume_range,
+        _tprice,
-        _list_price, _list_code,
+        _guidance_price,
-        _guidance_price, _guidance_reason,
+        _guidance_reason,
-        _expl, _ui_json;
+        _expl;
 END;
 $$ LANGUAGE plpgsql;

new_targets/tables/lastpricedetail.pg.sql

@@ -1,124 +0,0 @@
-CREATE TABLE pricequote.lastpricedetail AS
-WITH base AS (
-    SELECT
-        customer,
-        partgroup,
-        dataseg,
-        version,
-        qtyord AS qty,
-        ROUND(sales_usd/qty,5) AS price,
-        odate,
-        ordnum,
-        quoten
-    FROM rlarp.osm_stack
-    WHERE 
-        version IN ('Actual','Quotes')
-        AND customer IS NOT NULL
-        AND fs_line = '41010'
-        AND calc_status <> 'CANCELLED'
-        AND qty <> 0
-        AND partgroup <> ''
-        AND version IN ('Actual', 'Quotes')
-),
-ranked AS (
-    SELECT *,
-        ROW_NUMBER() OVER (
-            PARTITION BY customer, partgroup
-            ORDER BY CASE WHEN version = 'Actual' THEN odate END DESC
-        ) AS rn_mrs,
-        ROW_NUMBER() OVER (
-            PARTITION BY customer, partgroup
-            ORDER BY CASE WHEN version = 'Quotes' THEN odate END DESC
-        ) AS rn_mrq,
-        ROW_NUMBER() OVER (
-            PARTITION BY customer, partgroup
-            ORDER BY CASE WHEN version = 'Actual' AND odate >= (CURRENT_DATE - INTERVAL '1 year') THEN qty END DESC
-        ) AS rn_lvs,
-        ROW_NUMBER() OVER (
-            PARTITION BY customer, partgroup
-            ORDER BY CASE WHEN version = 'Quotes' AND odate >= (CURRENT_DATE - INTERVAL '1 year') THEN qty END DESC
-        ) AS rn_lvq,
-        ROW_NUMBER() OVER (
-            PARTITION BY customer, partgroup, dataseg, version
-            ORDER BY CASE WHEN version = 'Actual' THEN odate END DESC
-        ) AS rn_dss,
-        ROW_NUMBER() OVER (
-            PARTITION BY customer, partgroup, dataseg, version
-            ORDER BY CASE WHEN version = 'Quotes' THEN odate END DESC
-        ) AS rn_dsq
-    FROM base
-),
-flagged 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,
-        CASE WHEN rn_dss = 1 THEN 'dss' END AS f5,
-        CASE WHEN rn_dsq = 1 THEN 'dsq' END AS f6
-    FROM ranked
-    WHERE
-        rn_mrs = 1 OR rn_mrq = 1 OR rn_lvs = 1 OR rn_lvq = 1 OR rn_dss = 1 OR rn_dsq = 1
-),
-exploded_flags AS (
-    SELECT
-        customer, partgroup, dataseg, version, qty, price, odate, ordnum, quoten,
-        unnest(ARRAY[f1, f2, f3, f4, f5, f6]) AS flag
-    FROM flagged
-),
-serialized_flags AS (
-    SELECT
-        customer,
-        partgroup,
-        dataseg,
-        flag,
-        jsonb_build_object(
-            'version', version,
-            'datasegment', dataseg,
-            'qty', qty,
-            'price', price,
-            'odate', odate,
-            'ordnum', ordnum,
-            'quoten', quoten,
-            'flag', flag
-        ) AS json_piece
-    FROM exploded_flags
-    WHERE flag IS NOT NULL
-),
-flag_json AS (
-    SELECT
-        customer,
-        partgroup,
-        jsonb_object_agg(flag, json_piece) AS global_flags
-    FROM serialized_flags
-    WHERE flag IN ('mrs', 'mrq', 'lvs', 'lvq')
-    GROUP BY customer, partgroup
-),
-seg_pieces AS (
-    SELECT
-        customer,
-        partgroup,
-        dataseg,
-        jsonb_object_agg(flag, json_piece) AS seg_flags
-    FROM serialized_flags
-    WHERE flag IN ('dss', 'dsq')
-    GROUP BY customer, partgroup, dataseg
-),
-seg_json AS (
-    SELECT
-        customer,
-        partgroup,
-        jsonb_object_agg(dataseg, seg_flags) AS dataseg_block
-    FROM seg_pieces
-    GROUP BY customer, partgroup
-)
-SELECT
-    COALESCE(f.customer, s.customer) AS customer,
-    COALESCE(f.partgroup, s.partgroup) AS partgroup,
-    (COALESCE(f.global_flags, '{}'::jsonb) || COALESCE(s.dataseg_block, '{}'::jsonb)) AS part_stats
-FROM flag_json f
-FULL OUTER JOIN seg_json s
-    ON f.customer = s.customer AND f.partgroup = s.partgroup
-WITH DATA;
-
---SELECT * FROM pricequote.lastpricedetail;