From 4869265ea34c7ee4950a110abc910109aef74e24 Mon Sep 17 00:00:00 2001
From: Paul Trowbridge <fleetside72@hotmail.com>
Date: Sat, 22 Sep 2018 00:30:11 -0400
Subject: [PATCH] add trigger for balance inserts

---
 db_deploy.sql                  | 112 ++++++++++++++++++++++++++++++++-
 schema/triggers/bal_insert.sql |  38 +++++------
 2 files changed, 126 insertions(+), 24 deletions(-)

diff --git a/db_deploy.sql b/db_deploy.sql
index 902df48..6081d59 100644
--- a/db_deploy.sql
+++ b/db_deploy.sql
@@ -216,4 +216,114 @@ 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
+    EXECUTE PROCEDURE evt.gl_insert();
+
+---------------------------handle balance updates----------------------------------------
+
+CREATE OR REPLACE FUNCTION evt.bal_insert() RETURNS trigger
+    LANGUAGE plpgsql
+    AS 
+    $func$
+    BEGIN
+        WITH
+        seq AS (
+            WITH RECURSIVE rf (acct, fspr, minrange, maxrange, dur, id, obal, debits, credits, cbal) AS
+            (
+                SELECT
+                    rng.acct
+                    ,rng.fspr
+                    ,rng.minrange
+                    ,rng.maxrange
+                    ,f.dur
+                    ,f.id
+                    ,b.obal::numeric(12,2)
+                    ,b.debits::numeric(12,2)
+                    ,b.credits::numeric(12,2)
+                    ,b.cbal::numeric(12,2)
+                FROM
+                    (
+                        --for each item determine if a gap exists between new an previous period (if any)
+                        SELECT
+                            ins.acct
+                            ,ins.fspr
+                            ,lower(f.dur) dur
+                            ,CASE WHEN lower(f.dur) > max(lower(bp.dur)) THEN max(lower(bp.dur)) ELSE lower(f.dur) END minrange
+                            ,CASE WHEN lower(f.dur) < max(lower(bp.dur)) THEN max(lower(bp.dur)) ELSE lower(f.dur) END maxrange
+                        FROM
+                            (
+                                SELECT
+                                    *
+                                FROM
+                                    evt.bal
+                                WHERE
+                                    fspr = '2018.11'
+                            ) ins
+                            INNER JOIN evt.fspr f ON
+                                f.id = ins.fspr
+                            LEFT OUTER JOIN evt.bal b ON
+                                b.acct = ins.acct
+                            LEFT OUTER JOIN evt.fspr bp ON
+                                bp.id = b.fspr
+                        WHERE
+                            b.fspr <> '2018.11'
+                        GROUP BY
+                            ins.acct
+                            ,ins.fspr
+                            ,f.dur
+                    ) rng
+                    INNER JOIN evt.fspr f ON
+                        lower(f.dur) = minrange
+                    INNER JOIN evt.bal b ON 
+                        b.acct = rng.acct
+                        AND b.fspr = f.id
+                
+                UNION ALL
+
+                SELECT
+                    rf.acct
+                    ,rf.fspr
+                    ,rf.minrange
+                    ,rf.maxrange
+                    ,f.dur
+                    ,f.id
+                    ,COALESCE(rf.cbal,0)::numeric(12,2)
+                    ,COALESCE(b.debits,0)::numeric(12,2)
+                    ,COALESCE(b.credits,0)::numeric(12,2)
+                    ,(COALESCE(rf.cbal,0) + COALESCE(b.debits,0) + COALESCE(b.credits,0))::numeric(12,2)
+                FROM
+                    rf
+                    INNER JOIN evt.fspr f ON
+                        lower(f.dur) = upper(rf.dur)
+                    LEFT OUTER JOIN evt.bal b ON
+                        b.acct = rf.acct
+                        AND b.fspr = f.id
+                WHERE
+                    lower(f.dur) <= rf.maxrange
+            )
+            SELECT * FROM rf
+        )
+        INSERT INTO
+            evt.bal (Acct, fspr, obal, debits, credits, cbal)
+        SELECT
+            acct
+            ,fspr
+            ,obal
+            ,debits
+            ,credits
+            ,cbal
+        FROM
+            seq
+        ON CONFLICT ON CONSTRAINT bal_pk DO UPDATE SET
+            obal = EXCLUDED.obal
+            ,debits = EXCLUDED.debits
+            ,credits = EXCLUDED.credits
+            ,cbal = EXCLUDED.cbal;
+        RETURN NULL;
+    END;
+    $func$;
+
+CREATE TRIGGER bal_insert 
+    AFTER INSERT ON evt.bal
+    REFERENCING NEW TABLE AS ins 
+    FOR EACH STATEMENT
+    EXECUTE PROCEDURE evt.bal_insert();
\ No newline at end of file
diff --git a/schema/triggers/bal_insert.sql b/schema/triggers/bal_insert.sql
index b13dea3..a459543 100644
--- a/schema/triggers/bal_insert.sql
+++ b/schema/triggers/bal_insert.sql
@@ -1,4 +1,4 @@
----------------------------handle new gl lines----------------------------------------
+---------------------------handle balance updates----------------------------------------
 
 CREATE OR REPLACE FUNCTION evt.bal_insert() RETURNS trigger
     LANGUAGE plpgsql
@@ -82,30 +82,22 @@ CREATE OR REPLACE FUNCTION evt.bal_insert() RETURNS trigger
             )
             SELECT * FROM rf
         )
-        select * from seq
-        ,xseq AS (
+        INSERT INTO
+            evt.bal (Acct, fspr, obal, debits, credits, cbal)
         SELECT
-            rng.*
-            ,fspr.id
-            ,row_number() OVER (partition by rng.acct, rng.fspr ORDER BY lower(fspr.dur) ASC) rn
-            ,coalesce(b.obal,0) obal
-            ,coalesce(b.debits,0) debits
-            ,coalesce(b.credits,0) credits
-            ,coalesce(b.cbal,0) cbal
+            acct
+            ,fspr
+            ,obal
+            ,debits
+            ,credits
+            ,cbal
         FROM
-            rng
-            INNER JOIN evt.fspr ON
-                lower(fspr.dur) >= minrange
-                AND lower(fspr.dur) <= maxrange
-            LEFT OUTER JOIN evt.bal b ON
-                b.acct = rng.acct
-                AND b.fspr = fspr.id
-        ORDER BY
-            rng.acct
-            ,rng.fspr
-            ,rn
-        )
-        select * from seq
+            seq
+        ON CONFLICT ON CONSTRAINT bal_pk DO UPDATE SET
+            obal = EXCLUDED.obal
+            ,debits = EXCLUDED.debits
+            ,credits = EXCLUDED.credits
+            ,cbal = EXCLUDED.cbal;
         RETURN NULL;
     END;
     $func$;