Added missing scripts for current version (#516)

Author: acn-sbuad

src/Altinn.Notifications.Persistence/Migration/v0.29/01-functions-and-procedures.sql

@@ -1 +1,392 @@
--- This script is autogenerated from the tool DbTools. Do not edit manually.
+-- This script is autogenerated from the tool DbTools. Do not edit manually.
+
+-- getemailrecipients.sql:
+CREATE OR REPLACE FUNCTION notifications.getemailrecipients_v2(_alternateid uuid)
+RETURNS TABLE(
+    recipientorgno text, 
+    recipientnin text, 
+    toaddress text
+) 
+LANGUAGE 'plpgsql'
+AS $BODY$
+DECLARE
+__orderid BIGINT := (SELECT _id from notifications.orders
+			where alternateid = _alternateid);
+BEGIN
+RETURN query 
+	SELECT e.recipientorgno, e.recipientnin, e.toaddress
+	FROM notifications.emailnotifications e
+	WHERE e._orderid = __orderid;
+END;
+$BODY$;
+
+-- getemailsstatusnewupdatestatus.sql:
+CREATE OR REPLACE FUNCTION notifications.getemails_statusnew_updatestatus()
+    RETURNS TABLE(alternateid uuid, subject text, body text, fromaddress text, toaddress text, contenttype text) 
+    LANGUAGE 'plpgsql'
+AS $BODY$
+DECLARE
+    latest_email_timeout TIMESTAMP WITH TIME ZONE;
+BEGIN
+    SELECT emaillimittimeout INTO latest_email_timeout FROM notifications.resourcelimitlog WHERE id = (SELECT MAX(id) FROM notifications.resourcelimitlog);
+		IF latest_email_timeout IS NOT NULL THEN
+			IF latest_email_timeout >= NOW() THEN
+				RETURN QUERY SELECT NULL::uuid AS alternateid, NULL::text AS subject, NULL::text AS body, NULL::text AS fromaddress, NULL::text AS toaddress, NULL::text AS contenttype WHERE FALSE;
+                RETURN;
+			ELSE 
+				UPDATE notifications.resourcelimitlog SET emaillimittimeout = NULL WHERE id = (SELECT MAX(id) FROM notifications.resourcelimitlog);
+			END IF;
+		END IF;
+		
+        RETURN query 
+            WITH updated AS (
+                UPDATE notifications.emailnotifications
+                    SET result = 'Sending', resulttime = now()
+                    WHERE result = 'New' 
+                    RETURNING notifications.emailnotifications.alternateid, _orderid, notifications.emailnotifications.toaddress)
+            SELECT u.alternateid, et.subject, et.body, et.fromaddress, u.toaddress, et.contenttype 
+            FROM updated u, notifications.emailtexts et
+            WHERE u._orderid = et._orderid;    
+END;
+$BODY$;
+
+-- getemailsummary.sql:
+CREATE OR REPLACE FUNCTION notifications.getemailsummary_v2(
+	_alternateorderid uuid,
+	_creatorname text)
+    RETURNS TABLE(
+        sendersreference text, 
+        alternateid uuid, 
+        recipientorgno text, 
+        recipientnin text, 
+        toaddress text, 
+        result emailnotificationresulttype, 
+        resulttime timestamptz) 
+    LANGUAGE 'plpgsql'
+AS $BODY$
+
+	BEGIN
+		RETURN QUERY
+		   SELECT o.sendersreference, n.alternateid, n.recipientorgno, n.recipientnin, n.toaddress, n.result, n.resulttime
+			FROM notifications.emailnotifications n
+            LEFT JOIN notifications.orders o ON n._orderid = o._id
+			WHERE o.alternateid = _alternateorderid
+			and o.creatorname = _creatorname;
+        IF NOT FOUND THEN
+            RETURN QUERY
+            SELECT o.sendersreference, NULL::uuid, NULL::text, NULL::text, NULL::text, NULL::emailnotificationresulttype, NULL::timestamptz
+            FROM notifications.orders o
+            WHERE o.alternateid = _alternateorderid
+            and o.creatorname = _creatorname;
+        END IF;
+	END;
+$BODY$;
+
+-- getmetrics.sql:
+CREATE OR REPLACE FUNCTION notifications.getmetrics(
+    month_input int,
+    year_input int
+)
+RETURNS TABLE (
+    org text,
+    placed_orders bigint,
+    sent_emails bigint,
+    succeeded_emails bigint,
+    sent_sms bigint,
+    succeeded_sms bigint
+)
+AS $$
+BEGIN
+    RETURN QUERY
+    SELECT
+        o.creatorname,
+        COUNT(DISTINCT o._id) AS placed_orders,
+        SUM(CASE WHEN e._id IS NOT NULL THEN 1 ELSE 0 END) AS sent_emails,
+        SUM(CASE WHEN e.result = 'Succeeded' THEN 1 ELSE 0 END) AS succeeded_emails,
+        SUM(CASE WHEN s._id IS NOT NULL THEN s.smscount ELSE 0 END) AS sent_sms,
+        SUM(CASE WHEN s.result = 'Accepted' THEN 1 ELSE 0 END) AS succeeded_sms
+    FROM notifications.orders o
+    LEFT JOIN notifications.emailnotifications e ON o._id = e._orderid
+    LEFT JOIN notifications.smsnotifications s ON o._id = s._orderid
+    WHERE EXTRACT(MONTH FROM o.requestedsendtime) = month_input
+        AND EXTRACT(YEAR FROM o.requestedsendtime) = year_input
+    GROUP BY o.creatorname;
+END;
+$$ LANGUAGE plpgsql;
+
+
+-- getorderincludestatus.sql:
+CREATE OR REPLACE FUNCTION notifications.getorder_includestatus_v2(
+    _alternateid uuid,
+    _creatorname text
+)
+RETURNS TABLE(
+    alternateid uuid,
+    creatorname text,
+    sendersreference text,
+    created timestamp with time zone,                  
+    requestedsendtime timestamp with time zone,
+    processed timestamp with time zone,
+    processedstatus orderprocessingstate,
+    notificationchannel text,
+    generatedemailcount bigint,
+    succeededemailcount bigint,
+    generatedsmscount bigint, 
+    succeededsmscount bigint
+) 
+LANGUAGE 'plpgsql'
+AS $BODY$
+DECLARE
+    _target_orderid INTEGER;
+    _succeededEmailCount BIGINT;
+    _generatedEmailCount BIGINT;
+    _succeededSmsCount BIGINT;
+    _generatedSmsCount BIGINT;
+BEGIN
+    SELECT _id INTO _target_orderid 
+    FROM notifications.orders
+    WHERE orders.alternateid = _alternateid 
+    AND orders.creatorname = _creatorname;
+    
+    SELECT
+        SUM(CASE WHEN result = 'Succeeded' THEN 1 ELSE 0 END), 
+        COUNT(1) AS generatedEmailCount
+    INTO _succeededEmailCount, _generatedEmailCount
+    FROM notifications.emailnotifications
+    WHERE _orderid = _target_orderid;
+    
+    SELECT      
+        SUM(CASE WHEN result = 'Accepted' THEN 1 ELSE 0 END), 
+        COUNT(1) AS generatedSmsCount
+    INTO _succeededSmsCount, _generatedSmsCount
+    FROM notifications.smsnotifications
+    WHERE _orderid = _target_orderid;
+
+    RETURN QUERY
+    SELECT 
+        orders.alternateid,
+        orders.creatorname,
+        orders.sendersreference,
+        orders.created,
+        orders.requestedsendtime,
+        orders.processed,
+        orders.processedstatus,
+        orders.notificationorder->>'NotificationChannel',
+        _generatedEmailCount,
+        _succeededEmailCount,
+        _generatedSmsCount, 
+        _succeededSmsCount
+    FROM
+        notifications.orders AS orders
+    WHERE 
+        orders.alternateid = _alternateid;
+END;
+$BODY$;
+
+
+-- getorderspastsendtimeupdatestatus.sql:
+CREATE OR REPLACE FUNCTION notifications.getorders_pastsendtime_updatestatus()
+    RETURNS TABLE(notificationorders jsonb)
+    LANGUAGE 'plpgsql'
+AS $BODY$
+BEGIN
+RETURN QUERY
+	UPDATE notifications.orders
+	SET processedstatus = 'Processing'
+	WHERE _id IN (select _id
+				 from notifications.orders
+				 where processedstatus = 'Registered'
+				 and requestedsendtime <= now() + INTERVAL '1 minute'
+				 limit 50)
+	RETURNING notificationorder AS notificationorders;
+END;
+$BODY$;
+
+-- getsmsrecipients.sql:
+CREATE OR REPLACE FUNCTION notifications.getsmsrecipients_v2(_orderid uuid)
+RETURNS TABLE(
+  recipientorgno text, 
+  recipientnin text,
+  mobilenumber text
+) 
+LANGUAGE 'plpgsql'
+AS $BODY$
+DECLARE
+__orderid BIGINT := (SELECT _id from notifications.orders
+			where alternateid = _orderid);
+BEGIN
+RETURN query 
+	SELECT s.recipientorgno, s.recipientnin, s.mobilenumber
+	FROM notifications.smsnotifications s
+	WHERE s._orderid = __orderid;
+END;
+$BODY$;
+
+-- getsmsstatusnewupdatestatus.sql:
+CREATE OR REPLACE FUNCTION notifications.getsms_statusnew_updatestatus()
+    RETURNS TABLE(alternateid uuid, sendernumber text, mobilenumber text, body text) 
+    LANGUAGE 'plpgsql'
+AS $BODY$
+BEGIN
+		
+    RETURN query 
+    WITH updated AS (
+        UPDATE notifications.smsnotifications
+        SET result = 'Sending', resulttime = now()
+        WHERE result = 'New' 
+        RETURNING notifications.smsnotifications.alternateid, _orderid, notifications.smsnotifications.mobilenumber)
+    SELECT u.alternateid, st.sendernumber, u.mobilenumber, st.body
+    FROM updated u, notifications.smstexts st
+    WHERE u._orderid = st._orderid;    
+END;
+$BODY$;
+
+-- getsmssummary.sql:
+CREATE OR REPLACE FUNCTION notifications.getsmssummary_v2(
+	_alternateorderid uuid,
+	_creatorname text)
+    RETURNS TABLE(
+        sendersreference text, 
+        alternateid uuid, 
+        recipientorgno text, 
+        recipientnin text, 
+        mobilenumber text, 
+        result smsnotificationresulttype, 
+        resulttime timestamptz) 
+    LANGUAGE 'plpgsql'
+AS $BODY$
+
+	BEGIN
+		RETURN QUERY
+		   SELECT o.sendersreference, n.alternateid, n.recipientorgno, n.recipientnin, n.mobilenumber, n.result, n.resulttime
+			FROM notifications.smsnotifications n
+            LEFT JOIN notifications.orders o ON n._orderid = o._id
+			WHERE o.alternateid = _alternateorderid
+			and o.creatorname = _creatorname;
+        IF NOT FOUND THEN
+            RETURN QUERY
+            SELECT o.sendersreference, NULL::uuid, NULL::text, NULL::text, NULL::text, NULL::smsnotificationresulttype, NULL::timestamptz
+            FROM notifications.orders o
+            WHERE o.alternateid = _alternateorderid
+            and o.creatorname = _creatorname;
+        END IF;
+	END;
+$BODY$;
+
+-- insertemailnotification.sql:
+CREATE OR REPLACE PROCEDURE notifications.insertemailnotification(
+_orderid uuid, 
+_alternateid uuid, 
+_recipientorgno TEXT,
+_recipientnin TEXT,
+_toaddress TEXT, 
+_result text, 
+_resulttime timestamptz, 
+_expirytime timestamptz)
+LANGUAGE 'plpgsql'
+AS $BODY$
+DECLARE
+__orderid BIGINT := (SELECT _id from notifications.orders
+			where alternateid = _orderid);
+BEGIN
+
+INSERT INTO notifications.emailnotifications(
+_orderid, 
+alternateid, 
+recipientorgno, 
+recipientnin, 
+toaddress, result, 
+resulttime, 
+expirytime)
+VALUES (
+__orderid, 
+_alternateid,
+_recipientorgno,
+_recipientnin,
+_toaddress,
+_result::emailnotificationresulttype,
+_resulttime,
+_expirytime);
+END;
+$BODY$;
+
+-- insertemailtext.sql:
+CREATE OR REPLACE PROCEDURE notifications.insertemailtext(__orderid BIGINT, _fromaddress TEXT, _subject TEXT, _body TEXT, _contenttype TEXT)
+LANGUAGE 'plpgsql'
+AS $BODY$
+BEGIN
+INSERT INTO notifications.emailtexts(_orderid, fromaddress, subject, body, contenttype)
+	VALUES (__orderid, _fromaddress, _subject, _body, _contenttype);
+END;
+$BODY$;
+
+
+-- insertorder.sql:
+CREATE OR REPLACE FUNCTION notifications.insertorder(_alternateid UUID, _creatorname TEXT, _sendersreference TEXT, _created TIMESTAMPTZ, _requestedsendtime TIMESTAMPTZ, _notificationorder JSONB)
+RETURNS BIGINT
+    LANGUAGE 'plpgsql'
+AS $BODY$
+DECLARE
+_orderid BIGINT;
+BEGIN
+	INSERT INTO notifications.orders(alternateid, creatorname, sendersreference, created, requestedsendtime, processed, notificationorder) 
+	VALUES (_alternateid, _creatorname, _sendersreference, _created, _requestedsendtime, _created, _notificationorder)
+   RETURNING _id INTO _orderid;
+   
+   RETURN _orderid;
+END;
+$BODY$;
+
+-- insertsmsnotification.sql:
+CREATE OR REPLACE PROCEDURE notifications.insertsmsnotification(
+_orderid uuid, 
+_alternateid uuid, 
+_recipientorgno TEXT, 
+_recipientnin TEXT,
+_mobilenumber TEXT, 
+_result text, 
+_smscount integer,
+_resulttime timestamptz, 
+_expirytime timestamptz
+)
+LANGUAGE 'plpgsql'
+AS $BODY$
+DECLARE
+__orderid BIGINT := (SELECT _id from notifications.orders
+			where alternateid = _orderid);
+BEGIN
+
+INSERT INTO notifications.smsnotifications(
+_orderid, 
+alternateid,
+recipientorgno, 
+recipientnin, 
+mobilenumber,
+result,
+smscount,
+resulttime,
+expirytime)
+VALUES (
+__orderid,
+_alternateid,
+_recipientorgno, 
+_recipientnin, 
+_mobilenumber,
+_result::smsnotificationresulttype,
+_smscount,
+_resulttime,
+_expirytime);
+END;
+$BODY$;
+
+-- updateemailstatus.sql:
+CREATE OR REPLACE PROCEDURE notifications.updateemailstatus(_alternateid UUID, _result text, _operationid text)
+LANGUAGE 'plpgsql'
+AS $BODY$
+BEGIN
+	UPDATE notifications.emailnotifications 
+	SET result = _result::emailnotificationresulttype, resulttime = now(), operationid = _operationid
+	WHERE alternateid = _alternateid;
+END;
+$BODY$;
+