finish initial gl_insert function

db_deploy.sql

@@ -166,4 +166,49 @@ CREATE TRIGGER log_insert
     AFTER INSERT ON evt.bpr
     REFERENCING NEW TABLE AS ins 
     FOR EACH STATEMENT 
-    EXECUTE PROCEDURE evt.log_insert();
+    EXECUTE PROCEDURE evt.log_insert();
+
+---------------------------handle new gl lines----------------------------------------
+
+CREATE OR REPLACE FUNCTION evt.gl_insert() RETURNS trigger
+    LANGUAGE plpgsql
+    AS 
+    $func$
+    BEGIN
+        WITH
+        agg AS (
+            SELECT
+                acct
+                ,fspr
+                ,coalesce(sum(amount) FILTER (WHERE amount > 0),0) debits
+                ,coalesce(sum(amount) FILTER (WHERE amount < 0),0) credits
+            FROM
+                ins
+            GROUP BY
+                acct
+                ,fspr
+        )
+        INSERT INTO
+            evt.bal
+        SELECT
+            acct
+            ,fspr
+            ,0 obal
+            ,debits
+            ,credits
+            ,debits + credits
+        FROM
+            agg
+        ON CONFLICT ON CONSTRAINT bal_pk DO UPDATE SET
+            debits = evt.bal.debits + EXCLUDED.debits
+            ,credits = evt.bal.credits + EXCLUDED.credits
+            ,cbal = evt.bal.cbal + EXCLUDED.debits + EXCLUDED.credits;
+        RETURN NULL;
+    END;
+    $func$;
+
+CREATE TRIGGER gl_insert 
+    AFTER INSERT ON evt.gl
+    REFERENCING NEW TABLE AS ins 
+    FOR EACH STATEMENT
+    EXECUTE PROCEDURE evt.gl_insert();

schema/triggers/gl_insert.sql

@@ -4,33 +4,41 @@ CREATE OR REPLACE FUNCTION evt.gl_insert() RETURNS trigger
     LANGUAGE plpgsql
     AS 
     $func$
-    --upsert gl balance
+    BEGIN
-    --if a new period is created roll any gaps
+        WITH
-    WITH
+        agg AS (
-    agg AS (
+            SELECT
+                acct
+                ,fspr
+                ,coalesce(sum(amount) FILTER (WHERE amount > 0),0) debits
+                ,coalesce(sum(amount) FILTER (WHERE amount < 0),0) credits
+            FROM
+                ins
+            GROUP BY
+                acct
+                ,fspr
+        )
+        INSERT INTO
+            evt.bal
         SELECT
             acct
             ,fspr
-            ,sum(amount) FILTER (WHERE amount > 0) debits
+            ,0 obal
-            ,sum(amount) FILTER (WHERE amount < 0) credits
+            ,debits
+            ,credits
+            ,debits + credits
         FROM
-            ins
+            agg
-        GROUP BY
+        ON CONFLICT ON CONSTRAINT bal_pk DO UPDATE SET
-            acct
+            debits = evt.bal.debits + EXCLUDED.debits
-            ,fspr
+            ,credits = evt.bal.credits + EXCLUDED.credits
-    )
+            ,cbal = evt.bal.cbal + EXCLUDED.debits + EXCLUDED.credits;
-    INSERT INTO
+        RETURN NULL;
-        evt.bal
+    END;
-    SELECT
+    $func$;
-        acct
+
-        ,fspr
+CREATE TRIGGER gl_insert 
-        ,0
+    AFTER INSERT ON evt.gl
-        ,debits
+    REFERENCING NEW TABLE AS ins 
-        ,credits
+    FOR EACH STATEMENT
-        ,debits + credits
+    EXECUTE PROCEDURE evt.gl_insert();
-    FROM
-        agg
-    ON CONFLICT ON CONSTRAINT PRIMARY KEY DO UPDATE SET
-        debits = debits + EXCLUDED.debits
-        ,credits = credits + EXCLUDED.credits
-        ,cbal = cbal + debits + credits