From 9fa7dd7e04c1dbf668cc3dc6f72be7fc350e4131 Mon Sep 17 00:00:00 2001 From: Paul Trowbridge Date: Fri, 5 Oct 2018 14:29:29 -0400 Subject: [PATCH] delete files copied from other branch yeclose --- schema/functions/balrf_re.sql | 206 --------------------- schema/functions/balrf_re_do.sql | 200 -------------------- schema/functions/balrf_re_do_select.sql | 173 ------------------ schema/triggers/gl_insert_re.sql | 233 ------------------------ 4 files changed, 812 deletions(-) delete mode 100644 schema/functions/balrf_re.sql delete mode 100644 schema/functions/balrf_re_do.sql delete mode 100644 schema/functions/balrf_re_do_select.sql delete mode 100644 schema/triggers/gl_insert_re.sql diff --git a/schema/functions/balrf_re.sql b/schema/functions/balrf_re.sql deleted file mode 100644 index bd07dd8..0000000 --- a/schema/functions/balrf_re.sql +++ /dev/null @@ -1,206 +0,0 @@ -------------------------function that rolls balances forward------------------------------------------- - -CREATE OR REPLACE FUNCTION evt.balrf() RETURNS void -LANGUAGE plpgsql AS -$func$ -DECLARE - _mind timestamptz; - _maxd timestamptz; - _minp ltree; - _maxp ltree; -BEGIN - ----------------------------------------------------------------------------------------------------------------------------------------------------------------- - --get last periods touched and last rollforward if available - ----------------------------------------------------------------------------------------------------------------------------------------------------------------- - SELECT - --get last rollforward, if none, use earliest period touched - COALESCE( - MAX(lower(dur)) FILTER (WHERE prop @> '{"rf":"global"}'::jsonb) - ,MIN(lower(dur)) FILTER (WHERE prop @> '{"gltouch":"yes"}'::jsonb) - ) mind - --max period touched - ,MAX(lower(dur)) FILTER (WHERE prop @> '{"gltouch":"yes"}'::jsonb) maxd - INTO - _mind - ,_maxd - FROM - evt.fspr; - - ----------------------------------------------------------------------------------------------------------------------------------------------------------------- - --test if a roll forward is required - ----------------------------------------------------------------------------------------------------------------------------------------------------------------- - IF _maxd <= _mind THEN - RETURN; - END IF; - - 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 - ,id - ) - ----------------------------------------------------------------------------------------------------------------------------------------------------------------- - --upsert the cascaded balances - ----------------------------------------------------------------------------------------------------------------------------------------------------------------- - ,ins AS ( - INSERT INTO - evt.bal - SELECT - acct - ,id - ,obal - ,debits - ,credits - ,cbal - FROM - bld - ON CONFLICT ON CONSTRAINT bal_pk DO UPDATE SET - obal = EXCLUDED.obal - ,debits = EXCLUDED.debits - ,credits = EXCLUDED.credits - ,cbal = EXCLUDED.cbal - RETURNING * - ) - ----------------------------------------------------------------------------------------------------------------------------------------------------------------- - --determine all fiscal periods involved - ----------------------------------------------------------------------------------------------------------------------------------------------------------------- - ,touched AS ( - SELECT DISTINCT - fspr - FROM - ins - ) - ----------------------------------------------------------------------------------------------------------------------------------------------------------------- - --update evt.fsor to reflect roll status - ----------------------------------------------------------------------------------------------------------------------------------------------------------------- - UPDATE - evt.fspr f - SET - prop = COALESCE(f.prop,'{}'::jsonb) || '{"rf":"global"}'::jsonb - FROM - touched t - WHERE - t.fspr = f.id; - - -END; -$func$; - -COMMENT ON FUNCTION evt.balrf() IS 'close any gaps and ensure all accounts roll forward'; \ No newline at end of file diff --git a/schema/functions/balrf_re_do.sql b/schema/functions/balrf_re_do.sql deleted file mode 100644 index f305ca5..0000000 --- a/schema/functions/balrf_re_do.sql +++ /dev/null @@ -1,200 +0,0 @@ -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; - - 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 - ----------------------------------------------------------------------------------------------------------------------------------------------------------------- - ,ins AS ( - INSERT INTO - evt.bal - SELECT - acct - ,id - ,obal - ,debits - ,credits - ,cbal - FROM - bld - ON CONFLICT ON CONSTRAINT bal_pk DO UPDATE SET - obal = EXCLUDED.obal - ,debits = EXCLUDED.debits - ,credits = EXCLUDED.credits - ,cbal = EXCLUDED.cbal - RETURNING * - ) - ----------------------------------------------------------------------------------------------------------------------------------------------------------------- - --determine all fiscal periods involved - ----------------------------------------------------------------------------------------------------------------------------------------------------------------- - ,touched AS ( - SELECT DISTINCT - fspr - FROM - ins - ) - ----------------------------------------------------------------------------------------------------------------------------------------------------------------- - --update evt.fsor to reflect roll status - ----------------------------------------------------------------------------------------------------------------------------------------------------------------- - UPDATE - evt.fspr f - SET - prop = COALESCE(f.prop,'{}'::jsonb) || '{"rf":"global"}'::jsonb - FROM - touched t - WHERE - t.fspr = f.id; - - -END; -$func$; \ No newline at end of file diff --git a/schema/functions/balrf_re_do_select.sql b/schema/functions/balrf_re_do_select.sql deleted file mode 100644 index a5b79ad..0000000 --- a/schema/functions/balrf_re_do_select.sql +++ /dev/null @@ -1,173 +0,0 @@ -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; diff --git a/schema/triggers/gl_insert_re.sql b/schema/triggers/gl_insert_re.sql deleted file mode 100644 index 19dbba9..0000000 --- a/schema/triggers/gl_insert_re.sql +++ /dev/null @@ -1,233 +0,0 @@ ----------------------------handle new gl lines---------------------------------------- - -CREATE OR REPLACE FUNCTION evt.gl_insert() RETURNS trigger -LANGUAGE plpgsql -AS -$func$ -DECLARE - _mind timestamptz; - _maxd timestamptz; -BEGIN - ------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------- - --find min and max applicable periods to roll - --min: earliest period involved in current gl posting - --max: latest period involved in any posting, or if none, the current posting - ------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------- - SELECT - (SELECT min(lower(f.dur)) FROM ins INNER JOIN evt.fspr f ON f.id = ins.fspr) - ,GREATEST( - --the last period inserted - (SELECT max(lower(f.dur)) FROM ins INNER JOIN evt.fspr f ON f.id = ins.fspr), - --or the last period touched anywhere, or if null, the last period inserted to - COALESCE( - (SELECT max(lower(dur)) FROM evt.fspr WHERE prop @> '{"gltouch":"yes"}'), - (SELECT max(lower(f.dur)) FROM ins INNER JOIN evt.fspr f ON f.id = ins.fspr) - ) - ) - INTO - _mind - ,_maxd; - - - ------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------- - --aggregate all inserted gl transactions - ------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------- - WITH - agg AS ( - SELECT - acct - ,fspr - ,dur - ,coalesce(sum(amount) FILTER (WHERE amount > 0),0) debits - ,coalesce(sum(amount) FILTER (WHERE amount < 0),0) credits - FROM - ins - INNER JOIN evt.fspr f ON - f.id = ins.fspr - GROUP BY - acct - ,fspr - ,dur - ) - ------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------- - --get every account touched in the transaction - ------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------- - ,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 - agg b - --account master - INNER JOIN evt.acct x ON - x.acct = b.acct - 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 * - ) - ------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------- - --roll the balances forward - ------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------- - ,bld AS ( - WITH RECURSIVE rf (acct, func, re, flag, id, dur, obal, debits, credits, cbal, incr_re) AS - ( - SELECT - a.acct - ,a.func - ,a.re - ,null::BOOLEAN - ,f.id - ,f.dur - ,COALESCE(b.obal::numeric(12,2),0) - ,(COALESCE(b.debits,0) + COALESCE(agg.debits,0))::numeric(12,2) - ,(COALESCE(b.credits,0) + COALESCE(agg.credits,0))::numeric(12,2) - ,(COALESCE(b.cbal,0) + COALESCE(agg.debits,0) + COALESCE(agg.credits,0))::numeric(12,2) - ,CASE func WHEN 'netinc' THEN (COALESCE(agg.debits,0) + COALESCE(agg.credits,0))::numeric(12,2) ELSE 0 END incr_re - FROM - arng a - INNER JOIN evt.fspr f ON - upper(f.dur) = _mind - LEFT OUTER JOIN evt.bal b ON - b.acct = a.acct - AND b.fspr = f.id - LEFT OUTER JOIN agg ON - agg.acct = a.acct - AND agg.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 - ,f.id - ,f.dur - -- this column needs to pickup existing re - --if h.food is already in retained earnings and then you add in the entire re-rolled balance again it will be doubled up - --only the increment of the original transaction should be added to retained earnings - --the incremental retained earnings needs to survive even past the first dump to ret earn just in case a second year-end is encountered - ,CASE dc.flag WHEN true THEN 0 WHEN false THEN COALESCE(rf.incr_re,0) + COALESCE(b.obal,0) ELSE COALESCE(rf.cbal,0) END::numeric(12,2) obal - ,CASE dc.flag WHEN true THEN 0 WHEN false THEN 0 ELSE COALESCE(b.debits,0) + COALESCE(agg.debits,0) END::numeric(12,2) debits - ,CASE dc.flag WHEN true THEN 0 WHEN false THEN 0 ELSE COALESCE(b.credits,0) + COALESCe(agg.credits,0) END::numeric(12,2) credits - ,CASE dc.flag WHEN true THEN 0 WHEN false THEN COALESCE(rf.incr_re,0) + COALESCE(b.obal,0) ELSE COALESCE(rf.cbal,0) + COALESCE(b.debits,0) + COALESCE(b.credits,0) + COALESCE(agg.debits,0) + COALESCE(agg.credits,0) END::numeric(12,2) cbal - ,CASE dc.flag WHEN true THEN rf.incr_re WHEN false THEN COALESCE(rf.incr_re,0) + COALESCE(b.obal,0) ELSE COALESCE(rf.incr_re,0) + COALESCE(agg.debits,0) + COALESCE(agg.credits,0) END::numeric(12,2) incr_re - 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) - 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 - LEFT OUTER JOIN agg ON - agg.acct = CASE dc.flag - WHEN true THEN rf.acct - WHEN false THEN rf.re - ELSE rf.acct - END - AND agg.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 - ,id - ) - ------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------- - --insert the balances - ------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------- - ,ins AS ( - INSERT INTO - evt.bal (acct, fspr, obal, debits, credits, cbal) - SELECT - acct - ,id - ,obal - ,debits - ,credits - ,cbal - FROM - bld - ON CONFLICT ON CONSTRAINT bal_pk DO UPDATE SET - obal = EXCLUDED.obal - ,debits = EXCLUDED.debits - ,credits = EXCLUDED.credits - ,cbal = EXCLUDED.cbal - ,prop = evt.bal.prop || EXCLUDED.prop - RETURNING * - ) - ----------------------------------------------------------------------------------------------------------------------------------------------------------------- - --determine all fiscal periods involved - ----------------------------------------------------------------------------------------------------------------------------------------------------------------- - ,touched as ( - SELECT DISTINCT - fspr - FROM - ins - ) - ----------------------------------------------------------------------------------------------------------------------------------------------------------------- - --update evt.fspr to reflect roll status - ----------------------------------------------------------------------------------------------------------------------------------------------------------------- - UPDATE - evt.fspr f - SET - prop = COALESCE(f.prop,'{}'::JSONB) || '{"gltouch":"yes"}'::jsonb - FROM - touched t - WHERE - f.id = t.fspr; - - ------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------- - --this is to catch up all the other accounts if actually necessary - ------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------- - PERFORM evt.balrf(); - - RETURN NULL; -END; -$func$; - -COMMENT ON FUNCTION evt.gl_insert IS 'update evt.bal with new ledger rows'; - -CREATE TRIGGER gl_insert - AFTER INSERT ON evt.gl - REFERENCING NEW TABLE AS ins - FOR EACH STATEMENT - EXECUTE PROCEDURE evt.gl_insert(); \ No newline at end of file