add notes and create an adjustment based on a percentage for lines where not all is pullforward

build/build_pullforward.sql

@@ -21,9 +21,10 @@ tdr AS (
         DATERANGE('2021-06-01','2022-06-01','[)') prange
         -----------explicitly call out overlap period------------------------
         -----------anythign in this period has to net out to match actuals---
-        ,DATERANGE('2021-06-01','2021-07-29','[]') overlap
+        ,DATERANGE('2021-06-01','2021-07-31','[]') overlap
         ,jsonb_build_array('plan','diff') iter
 )
+------actual orders according to whatever is in the forecast, has to be defined as 'plan' and 'diff'--------
 ,booked AS materialized(
     SELECT
         billto_group
@@ -41,6 +42,8 @@ tdr AS (
         ,shipto_group
         ,part_group
 )
+--SELECT * FROM booked
+------------plan units according to the 'plan' iteration of the current forecast----------------------------
 ,planned AS (
     SELECT
          p.billto_group
@@ -71,6 +74,8 @@ tdr AS (
         ,p.ship_date
         ,b.units
 )
+--SELECT * FROM planned LIMIT 100
+-------flag rows by preparing a rolling total in this step------------------
 ,plan_ranked AS (
     SELECT
          p.billto_group
@@ -88,7 +93,8 @@ tdr AS (
     FROM
         planned p
 )
----flag any rows where 
+--SELECT * FROM plan_ranked
+---flag future budget where up to the extent that actuals are larger than budget, but not more------
 ,eval AS (
     SELECT
          p.billto_group
@@ -103,12 +109,20 @@ tdr AS (
         ,p.net_units_tot
         ,p.net_units
         --,p.booked
-        ,plan_rolling <= (p.net_units_tot - p.plan_units_tot + plan_units) flag
+        -----total current units less plan total units is the excess
+        -----if the current row contributes to the excess, flag it
+        -----the last row will likely pull out too much, it will need split probably
+        ,(plan_rolling - plan_units) <= (p.net_units_tot - p.plan_units_tot) flag
+        ,-(p.net_units_tot - p.plan_units_tot) max_possible_reduction
+        ,-CASE 
+            WHEN plan_rolling <= (p.net_units_tot - p.plan_units_tot) THEN plan_units
+            WHEN plan_rolling > (p.net_units_tot - p.plan_units_tot) AND (plan_rolling - plan_units) <= (p.net_units_tot - p.plan_units_tot) THEN (p.net_units_tot - p.plan_units_tot) - (plan_rolling - plan_units)
+        END qty
         --,CASE WHEN (p.plan_units_agg - p.plan_units) > p.booked AND p.plan_units_agg <= p.booked * 2 THEN true ELSE false END remove
     FROM
         plan_ranked p
 )
---select * from eval limit 10000
+--SELECT * FROM eval LIMIT 10000
 ----------------create a log entry--------------------
 ,log AS (
     INSERT INTO
@@ -152,11 +166,12 @@ tdr AS (
         ,o.r_rate          
         ,o.c_currency      
         ,o.c_rate          
-        ,round(-sum(o.units    ),2) units
+        -----only keep the percentage of the current row determined by the last step--------
-        ,round(-sum(o.value_loc),2) value_loc
+        ,round(-sum(o.units    ),2)*(-e.qty/e.plan_units) units
-        ,round(-sum(o.value_usd),2) value_usd
+        ,round(-sum(o.value_loc),2)*(-e.qty/e.plan_units) value_loc
-        ,round(-sum(o.cost_loc ),2) cost_loc
+        ,round(-sum(o.value_usd),2)*(-e.qty/e.plan_units) value_usd
-        ,round(-sum(o.cost_usd ),2) cost_usd
+        ,round(-sum(o.cost_loc ),2)*(-e.qty/e.plan_units) cost_loc
+        ,round(-sum(o.cost_usd ),2)*(-e.qty/e.plan_units) cost_usd
         ,o.calc_status   
         ,o.flag          
         ,o.order_date    

build/build_rolling.sql

@@ -16,19 +16,19 @@ DROP TABLE IF EXISTS tdr;
 CREATE TEMP TABLE tdr AS (
     SELECT
         -----------actuals into baseline-------------------------------------
-         DATERANGE('2020-06-01','2021-07-29','[]') arange
+         DATERANGE('2020-06-01','2021-07-31','[]') arange
         -----------plan into baseline----------------------------------------
         ,DATERANGE('2020-06-01','2022-06-01','[)') prange
         -----------forecast into baseline------------------------------------
         ,DATERANGE('2022-06-01','2022-06-01','[)') frange   -- this range effectively excludes
         -----------baseline selection for increment--------------------------
-        ,DATERANGE('2021-07-29','2021-07-29','[)') selection
+        ,DATERANGE('2021-07-31','2021-07-31','[)') selection
         -----------selection increment size----------------------------------
         ,'0 year'::interval AS incr
         -----------iterations to merge with----------------------------------
         ,(SELECT jsonb_agg(x.v) FROM (VALUES('copy'),('actuals'),('actuals_plug')) AS x(v)) iter
         -----------existing baseline overlap---------------------------------
-        ,DATERANGE('2000-06-01','2021-07-29') overlap
+        ,DATERANGE('2000-06-01','2021-07-31') overlap
 );
 
 --select * from tdr