DO
$func$
DECLARE
    _mind timestamptz;
    _maxd timestamptz;
    _minp ltree;
    _maxp ltree;
BEGIN
    -----------------------------------------------------------------------------------------------------------------------------------------------------------------
    --get last periods touched and last rollforward if available
    -----------------------------------------------------------------------------------------------------------------------------------------------------------------
    SELECT
        (SELECT lower(dur) FROM evt.fspr WHERE id = '2018.08'::ltree)
        ,(SELECT lower(dur) FROM evt.fspr WHERE id = '2019.02'::ltree)
    INTO
        _mind
        ,_maxd
    FROM
        evt.fspr;

    RAISE NOTICE 'earliest stamp%',_mind;
    RAISE NOTICE 'latest stamp%',_maxd;

    -----------------------------------------------------------------------------------------------------------------------------------------------------------------
    --test if a roll forward is required
    -----------------------------------------------------------------------------------------------------------------------------------------------------------------
    IF _maxd <= _mind THEN
        RETURN;
    END IF;
            
    CREATE TEMP TABLE balrf_do AS (
    WITH
    -----------------------------------------------------------------------------------------------------------------------------------------------------------------
    --list each period in min and max
    -----------------------------------------------------------------------------------------------------------------------------------------------------------------
    prng AS (
        SELECT 
            id
            ,dur
            ,prop
        FROM
            evt.fspr f
        WHERE
            lower(f.dur) >= _mind
            AND lower(f.dur) <= _maxd
    )
    -----------------------------------------------------------------------------------------------------------------------------------------------------------------
    --get every account involved in target range
    -----------------------------------------------------------------------------------------------------------------------------------------------------------------
    ,arng AS (
        SELECT DISTINCT
            b.acct
            --if no retained earnings account exists then automitically create it (assuming no other account is called re)
            ,COALESCE(a.acct,subpath(b.acct,0,1)||'re'::ltree) re
            ,a.acct existing_re
            ,x.prop->>'func' func
        FROM
            evt.bal b
            INNER JOIN evt.acct x ON
                x.acct = b.acct
            INNER JOIN prng ON
                prng.id = b.fspr
            LEFT OUTER JOIN evt.acct a ON
                subpath(a.acct,0,1) = subpath(b.acct,0,1)
                AND a.prop @> '{"retained_earnings":"set"}'::jsonb
    )
    -----------------------------------------------------------------------------------------------------------------------------------------------------------------
    --if the default retained earnings account was null, insert the new one to evt.acct
    -----------------------------------------------------------------------------------------------------------------------------------------------------------------
    ,new_re AS (
        INSERT INTO
            evt.acct (acct, prop)
        SELECT DISTINCT
            re, '{"retained_earnings":"set"}'::jsonb
        FROM
            arng
        WHERE
            existing_re IS NULL
        RETURNING *
    )
    -----------------------------------------------------------------------------------------------------------------------------------------------------------------
    --cascade the balances
    -----------------------------------------------------------------------------------------------------------------------------------------------------------------
    ,bld AS (
        WITH RECURSIVE rf (acct, func, re, flag, id, dur, obal, debits, credits, cbal) AS
        (
            SELECT
                a.acct
                ,a.func
                ,a.re
                ,null::boolean flag
                ,f.id
                ,f.dur
                ,COALESCE(b.obal,0)::numeric(12,2)
                ,COALESCE(b.debits,0)::numeric(12,2)
                ,COALESCE(b.credits,0)::numeric(12,2)
                ,COALESCE(b.cbal,0)::numeric(12,2)
            FROM
                arng a
                INNER JOIN evt.fspr f ON
                    lower(f.dur) = _mind
                LEFT OUTER JOIN evt.bal b ON
                    b.acct = a.acct
                    AND b.fspr = f.id
            
            UNION ALL

            SELECT
                --if the year is changing a duplicate join will happen which will allow moving balances to retained earnings
                --the duplicate join happens only for accounts flagged as temporary and needing closed to retained earnings
                --on the true side, the account retains its presence but takes on a zero balance
                --on the false side, the account is swapped out for retained earngings accounts and take on the balance of the expense account
                --if duplciate does not join itself, then treat as per anchor query above and continue aggregating balances for the target range
                CASE dc.flag WHEN true THEN rf.acct  WHEN false THEN rf.re  ELSE rf.acct                                                 END acct
                ,rf.func
                ,rf.re
                ,dc.flag flag
                ,f.id
                ,f.dur
                ,CASE dc.flag WHEN true THEN 0       WHEN false THEN rf.cbal ELSE rf.cbal                                                END::numeric(12,2) obal
                ,CASE dc.flag WHEN true THEN 0       WHEN false THEN 0       ELSE COALESCE(b.debits,0)                       END::numeric(12,2) debits
                ,CASE dc.flag WHEN true THEN 0       WHEN false THEN 0       ELSE COALESCE(b.credits,0)                     END::numeric(12,2) credits
                ,CASE dc.flag WHEN true THEN 0       WHEN false THEN rf.cbal ELSE rf.cbal + COALESCE(b.debits,0) + COALESCE(b.credits,0) END::numeric(12,2) cbal
            FROM
                rf
                INNER JOIN evt.fspr f ON
                    lower(f.dur) = upper(rf.dur)
                LEFT OUTER JOIN (SELECT * FROM (VALUES (true), (false)) X (flag)) dc ON
                    rf.func = 'netinc'
                    AND subpath(rf.id,0,1) <> subpath(f.id,0,1)
                --this join needs to include any currently booked retained earnings
                LEFT OUTER JOIN evt.bal b ON
                    b.acct = CASE dc.flag
                                WHEN true THEN rf.acct
                                WHEN false THEN rf.re
                                ELSE rf.acct 
                             END
                    AND b.fspr = f.id
            WHERE
                lower(f.dur) <= _maxd
        ) 
        SELECT 
            acct
            ,id
            ,SUM(obal) obal
            ,SUM(debits) debits
            ,SUM(credits) credits
            ,SUM(cbal) cbal 
        FROM 
            rf 
        GROUP BY 
            acct
            ,func
            ,id
    )
    -----------------------------------------------------------------------------------------------------------------------------------------------------------------
    --upsert the cascaded balances
    -----------------------------------------------------------------------------------------------------------------------------------------------------------------
    SELECT
        acct
        ,id
        ,obal
        ,debits
        ,credits
        ,cbal
    FROM 
        bld
    ) WITH DATA;
  

END;
$func$;
SELECT * FROM balrf_do order by id, acct;