Performed sql creation script breakdown and added cleaning triggers for event table

sql/1_create_user.sql

@@ -0,0 +1,27 @@
+/*
+    USER
+*/
+-- Cleanup
+DROP TABLE IF EXISTS app_user;
+DROP TYPE IF EXISTS user_role_enum CASCADE;
+-- Creation
+do $$
+begin
+if not exists (SELECT 1 FROM pg_type WHERE typname = 'user_role_enum') THEN
+    create type user_role_enum AS ENUM ('admin','operator');
+end if;
+end
+$$;
+create table if not exists app_user (
+    id      bigserial not null,
+    role    user_role_enum not null,
+    name    varchar(255) not null,                  --COMMENT 'ФИО Потльзователя',
+    login   varchar(255) not null unique,           --COMMENT ' Логин',
+    pass 	varchar(2584) not null,                 --COMMENT 'Пароль',
+    created timestamp not null default CURRENT_TIMESTAMP,
+    updated timestamp not null default CURRENT_TIMESTAMP,
+    deleted timestamp default null,
+    PRIMARY KEY (id, login)
+);
+comment on table app_user is 'Пользователи';
+comment on column app_user.role is 'Признак группировки';

sql/2_create_tag.sql

@@ -0,0 +1,22 @@
+/*
+    PROCESS TAG
+*/
+-- Cleanup
+DROP TABLE IF EXISTS tags;
+DROP TYPE IF EXISTS tag_type_enum CASCADE;
+-- Creation
+do $$
+begin
+if not exists (SELECT 1 FROM pg_type WHERE typname = 'tag_type_enum') THEN
+    create type tag_type_enum as enum('Bool','Int','UInt','DInt','Word','LInt','Real','Time','Date_And_Time');
+end if;
+end
+$$;
+create table if not exists tags (
+    id 		serial not null,
+    type      tag_type_enum not null,                 --COMMENT 'S7DataType(bool, int, uInt, dInt, word, lInt, real, time, dateAndTime)',
+    name      varchar(255) not null unique,	        --COMMENT 'Имя тэга в системе',
+    description   varchar(255) not null DEFAULT '',   --COMMENT 'Дополнительная информация о тэге',
+    PRIMARY KEY (id)
+);
+comment on table tags is 'Справочник тэгов проекта.';

sql/3_create_event.sql

@@ -0,0 +1,140 @@
+/*
+    PROCESS EVENT
+*/
+-- Cleanup
+DROP TRIGGER IF EXISTS event_insert_trigger ON event;
+DROP TRIGGER IF EXISTS event_delete_trigger ON event;
+DROP FUNCTION IF EXISTS event_purge_records();
+DROP FUNCTION IF EXISTS event_check_for_purge();
+DROP FUNCTION IF EXISTS event_counter_inc();
+DROP FUNCTION IF EXISTS event_counter_dec();
+DROP INDEX IF EXISTS idx_event_timestamp;
+DROP VIEW IF EXISTS event_view;
+DROP TABLE IF EXISTS event;
+DROP TABLE IF EXISTS event_utils;
+-- Creation
+CREATE TABLE IF NOT EXISTS event (
+    uid         BIGSERIAL PRIMARY KEY, --'1.000000000000', --COMMENT 'Идентификатор записи',
+    timestamp   TIMESTAMP NOT NULL,
+    pid         int2 NOT NULL,                      --COMMENT 'Идентификатор тэга.',
+    value       int2 NOT NULL,                      --COMMENT 'Значение тэга 0..255, аварийно если >0.',
+    status      int2 NOT NULL                       --COMMENT 'DsStatus as 0..255',
+); 
+comment on table event is 'События. Только тэги дискретных значений, регистрируется 0 - как норма, > 0 - как авария.';
+CREATE INDEX idx_event_timestamp ON event (timestamp ASC);
+
+CREATE TABLE
+    IF NOT EXISTS event_utils (
+        id SERIAL PRIMARY KEY,
+        row_count BIGINT,
+        row_limit BIGINT,
+        purge_batch_size INT,
+        purge_shift_size INT,
+        is_purge_running BOOLEAN
+    );
+
+INSERT INTO
+    event_utils (
+        row_count,
+        row_limit,
+        purge_batch_size,
+        purge_shift_size,
+        is_purge_running
+    )
+VALUES
+    (0, 6000000, 1000, 1000, 'f');
+
+CREATE OR REPLACE FUNCTION event_purge_records()
+RETURNS void 
+LANGUAGE plpgsql AS $$
+DECLARE
+    deleted INT;
+    to_delete INT;
+    batch_size INT;
+    is_purge_possible BOOLEAN;
+BEGIN
+    SELECT (row_count - row_limit + purge_shift_size), purge_batch_size
+    FROM event_utils INTO to_delete, batch_size;
+
+    WITH upd_result AS (
+        UPDATE event_utils SET is_purge_running = true WHERE id = 1 AND is_purge_running = false
+        RETURNING *
+    ) SELECT count(*) = 1 FROM upd_result INTO is_purge_possible;
+
+    IF is_purge_possible THEN
+        deleted := 0;
+
+        WHILE (to_delete - deleted) > batch_size LOOP
+            WITH del_result AS (
+                DELETE FROM event
+                WHERE ctid IN (
+                    SELECT ctid FROM event
+                    ORDER BY timestamp, uid ASC
+                    LIMIT batch_size
+                ) RETURNING *
+            ) SELECT (count(*) + deleted) FROM del_result into deleted;
+        END LOOP;
+
+        DELETE FROM event WHERE ctid IN (
+            SELECT ctid FROM event
+            ORDER BY timestamp, uid ASC
+            LIMIT (to_delete - deleted)
+        );
+
+        UPDATE event_utils SET is_purge_running = false WHERE id = 1;
+    END IF;
+END;
+$$;
+
+CREATE OR REPLACE FUNCTION event_check_for_purge()
+RETURNS void 
+LANGUAGE plpgsql
+AS $$
+DECLARE
+    is_purge_needed BOOLEAN;
+BEGIN
+    SELECT row_count > row_limit FROM event_utils WHERE id = 1 INTO is_purge_needed;
+    IF is_purge_needed THEN
+        PERFORM event_purge_records();
+    END IF;
+END;
+$$;
+
+CREATE OR REPLACE FUNCTION event_counter_inc()
+RETURNS trigger 
+LANGUAGE plpgsql
+AS $$
+DECLARE
+add_count INT;
+BEGIN
+    SELECT count(*) FROM new_tbl INTO add_count;
+    UPDATE event_utils SET row_count = COALESCE(row_count, 0) + add_count WHERE id = 1;
+    PERFORM event_check_for_purge();
+    RETURN new;
+END;
+$$;
+
+CREATE OR REPLACE FUNCTION event_counter_dec()
+RETURNS trigger 
+LANGUAGE plpgsql
+AS $$
+DECLARE
+    del_count INT;
+BEGIN
+    SELECT count(*) FROM old_tbl INTO del_count;
+    UPDATE event_utils SET row_count = COALESCE(row_count, 0) - del_count WHERE id = 1;
+    RETURN new;
+END;
+$$;
+
+create trigger event_insert_trigger
+	AFTER INSERT ON public."event"
+	REFERENCING NEW TABLE AS new_tbl
+	FOR EACH STATEMENT
+	EXECUTE PROCEDURE public.event_counter_inc();
+
+create trigger event_delete_trigger
+	AFTER DELETE ON event
+	REFERENCING OLD TABLE AS old_tbl 
+	FOR EACH STATEMENT
+	EXECUTE PROCEDURE  public.event_counter_dec();

sql/4_create_event_view.sql

@@ -0,0 +1,17 @@
+-- Cleanup
+DROP VIEW IF EXISTS event_view;
+-- Creation
+create or replace view event_view as
+    select
+        e.uid AS uid,
+        e.pid AS pid,
+        e.value AS value,
+        e.status AS status,
+        e.timestamp AS timestamp,
+        t.type AS type,
+        t.name AS name,
+        t.description AS description
+    from
+        (event e
+    left join tags t on
+        (e.pid = t.id));

sql/5_create_operating_cycle.sql

@@ -0,0 +1,60 @@
+/*
+    PROCESS OPERATING CYCLE
+*/
+-- Cleanup
+DROP VIEW IF EXISTS operating_cycle_metric_value_view;
+DROP TABLE IF EXISTS operating_cycle;
+DROP TABLE IF EXISTS operating_cycle_metric;
+DROP TABLE IF EXISTS operating_cycle_metric_value;
+DROP TYPE IF EXISTS metric_data_type_enum CASCADE;
+-- Creation
+do $$
+begin
+if not exists (SELECT 1 FROM pg_type WHERE typname = 'metric_data_type_enum') THEN
+    create type metric_data_type_enum as enum('bool','int','real','time','date','timestamp','string');
+end if;
+end
+$$;
+create table operating_cycle (
+    id                bigserial NOT NULL,     -- 'Идентификатор записи рабочего цикла',
+    timestamp_start   timestamp NOT NULL,     --COMMENT 'Дата и время начала рабочего цикла',
+    timestamp_stop    timestamp NOT NULL,     --COMMENT 'Дата и время окончания рабочего цикла',
+    alarm_class       char(2) NOT NULL,       -- COMMENT 'Point alarm class as 0..15, 0 - no alarm',
+    PRIMARY KEY (id)
+);
+create table operating_cycle_metric (
+    id            char(6) NOT NULL,        --COMMENT 'Идентификатор метрики статистических значений рабочего цикла',
+    name          varchar(255) NOT NULL,   --COMMENT 'Имя метрики статистических значений рабочего цикла',
+    description   varchar(255) NOT NULL,   --COMMENT 'Имя метрики статистических значений рабочего цикла',
+    PRIMARY KEY (id)
+    --KEY name_idx1 (name)
+);
+insert into operating_cycle_metric (id, name, description) values
+    (1, 'average', 'Среднее арифметическое'),
+    (2, 'max', 'Максимальное'),
+    (3, 'min', 'Минимальное'),
+    (4, 'trip_count', 'Количество срабатываний'),
+    (5, 'diviation_max', 'Максимальное отклонение');
+create table operating_cycle_metric_value (
+    operating_cycle_id    int8 NOT NULL,  --COMMENT 'Идентификатор записи рабочего цикла, к которрй относится данная хапись',
+    pid                   int4 NOT NULL,  --COMMENT 'ID тэга',
+    metric_id             char(6) NOT NULL,  --COMMENT 'Идентификатор метрики рабочего цикла, к которрй относится данная хапись',
+    value                 decimal(16,8) NOT NULL,  --COMMENT 'Значеник метрики',
+    PRIMARY KEY (operating_cycle_id, pid, metric_id)
+);
+create or replace view operating_cycle_metric_value_view as
+    select
+        ocmv.operating_cycle_id AS operating_cycle_id,
+        ocmv.pid AS "point_id",
+        tag.name AS point_name,
+        ocmv.metric_id AS "metric_id",
+        ocm."name" as metric_name,
+        ocmv.value AS value
+--		    tag.type AS type,
+--		    tag.description AS description
+    from
+        (operating_cycle_metric_value ocmv
+    left join tags tag on
+        (ocmv.pid = tag.id)
+    left join operating_cycle_metric ocm on
+        (ocmv.metric_id = ocm.id));

sql/6_create_operating_metric.sql

@@ -0,0 +1,82 @@
+/*
+    PROCESS OPERATING METRIC
+*/
+-- Cleanup
+DROP TABLE IF EXISTS operating_metric;
+DROP TYPE IF EXISTS metric_data_type_enum CASCADE;
+-- Creation
+do $$
+begin
+if not exists (SELECT 1 FROM pg_type WHERE typname = 'metric_data_type_enum') THEN
+    create type metric_data_type_enum as enum('bool','int','real','time','date','timestamp','string');
+end if;	   
+end
+$$; 
+create table operating_metric (
+    id            char(6) NOT NULL unique,     --COMMENT 'Идентификатор метрики',
+    type          metric_data_type_enum not null,      --COMMENT 'enum('bool','int','real','time','date','timestamp','string')',
+    name          varchar(255) NOT NULL,       --COMMENT 'Имя метрики',
+    description   varchar(255) NOT NULL,       --COMMENT 'Описание метрики',
+    value         text NOT NULL,               --COMMENT 'Значение метрики',
+    PRIMARY KEY (name)
+);
+comment on table operating_metric is 'Общие метрики';
+insert into operating_metric (id, type, name, description, value) values
+    ('1.1',     'string',   'crane-type', 'тип крана', 'unknown'),
+    ('1.2',     'string',   'crane-index', 'индекс крана', 'unknown'),
+    ('1.3',     'string',   'crane-vendor', 'наименование предприятия - изготовителя крана', 'ООО "ТКЗ"'),
+    ('1.4',     'string',   'crane-serial-number', 'заводской номер крана', '000-000'),
+    ('1.5',     'date',     'crane-manufacturing-date', 'год изготовления крана', '2023-03-03'),
+    ('1.6',     'real',     'crane-capacity', 'грузоподъемность крана, тонны', '0.0'),
+    ('1.7',     'string',   'crane-classification-group', 'группа классификации (режима) крана', 'M8'),
+    ('1.7.1',   'string',   'winch1-classification-group', 'группа классификации (режима) лебедки 1 крана', 'M8'),
+    ('1.7.2',   'string',   'winch2-classification-group', 'группа классификации (режима) лебедки 2 крана', 'M8'),
+    ('1.7.3',   'string',   'winch3-classification-group', 'группа классификации (режима) лебедки 3 крана', 'M8'),
+    ('1.8',     'real',     'crane-nominal-characteristic-number', 'нор­мативное характеристическое число крана', '0.0'),
+    ('1.8.1',   'real',     'winch1-nominal-characteristic-number', 'нор­мативное характеристическое число лебедки 1 крана', '0.0'),
+    ('1.8.2',   'real',     'winch2-nominal-characteristic-number', 'нор­мативное характеристическое число лебедки 2 крана', '0.0'),
+    ('1.8.3',   'real',     'winch3-nominal-characteristic-number', 'нор­мативное характеристическое число лебедки 3 крана', '0.0'),
+    ('1.9',     'date',     'crane-commissioning-date', 'дата ввода крана в эксплуатацию', '2023-03-03'),
+    ('1.10',    'int',      'crane-standard-service-life ', 'нормативный срок службы крана', '0'),
+    ('2.1',     'string',   'fault-recorder-type', 'тип Регистратора параметров', 'Fault Recorder'),
+    ('2.2',     'string',   'fault-recorder-model', 'модификация Регистратора параметров', 'v0.0.1'),
+    ('2.3',     'string',   'fault-recorder-vendor', 'наименование предприятия - изготовителя Регистратора параметров', 'ООО "ТКЗ"'),
+    ('2.4',     'string',   'fault-recorder-serial-number', 'заводской номер Регистратора параметров', '000-000'),
+    ('2.5',     'date',     'fault-recorder-manufacturing-date', 'год изготовления Регистратора параметров', '2023-03-03'),
+    ('2.6',     'date',     'fault-recorder-installation-date', 'дата установки РП на кран', '2023-03-03'),
+    ('2.7',     'string',   'fault-recorder-installation-company', 'наименование организации, установившей Регистратора параметров на кран', 'ООО "ТКЗ"'),
+    ('3.1',     'real',     'crane-total-operating-hours', 'общее количество часов работы крана', '0.0'),
+    ('3.2.0',   'real',     'pump-total-operating-hours', 'общее количество часов работы насосной станции (моточасы)', '0.0'),
+    ('3.2.1',   'real',     'winch1-total-operating-hours', 'общее количество часов работы лебедки 1 (моточасы)', '0.0'),
+    ('3.2.2',   'real',     'winch2-total-operating-hours', 'общее количество часов работы лебедки 2 (моточасы)', '0.0'),
+    ('3.2.3',   'real',     'winch3-total-operating-hours', 'общее количество часов работы лебедки 3 (моточасы)', '0.0'),
+    ('3.3',     'int',      'total-operating-cycles-count', 'суммарное число рабочих циклов', '0'),
+    ('3.4',     'real',     'cycles-distribution-by-load-ranges', 'распределение циклов по диапазонам нагрузки', '0.0'),
+    ('3.4.1',   'real',     'cycles-0_05-0_15-load-range', 'циклов в диапазоне загрузки 0,05 - 0,15', '0.0'),
+    ('3.4.2',   'real',     'cycles-0_15-0_25_load-range', 'циклов в диапазоне загрузки 0,15 - 0,25', '0.0'),
+    ('3.4.3',   'real',     'cycles-0_25-0_35_load-range', 'циклов в диапазоне загрузки 0,25 - 0,35', '0.0'),
+    ('3.4.4',   'real',     'cycles-0_35-0_45_load-range', 'циклов в диапазоне загрузки 0,35 - 0,45', '0.0'),
+    ('3.4.5',   'real',     'cycles-0_45-0_55_load-range', 'циклов в диапазоне загрузки 0,45 - 0,55', '0.0'),
+    ('3.4.6',   'real',     'cycles-0_55-0_65_load-range', 'циклов в диапазоне загрузки 0,55 - 0,65', '0.0'),
+    ('3.4.7',   'real',     'cycles-0_65-0_75_load-range', 'циклов в диапазоне загрузки 0,65 - 0,75', '0.0'),
+    ('3.4.8',   'real',     'cycles-0_75-0_85_load-range', 'циклов в диапазоне загрузки 0,75 - 0,85', '0.0'),
+    ('3.4.9',   'real',     'cycles-0_85-0_95_load-range', 'циклов в диапазоне загрузки 0,85 - 0,95', '0.0'),
+    ('3.4.10',  'real',     'cycles-0_95-1_05_load-range', 'циклов в диапазоне загрузки 0,95 - 1,05', '0.0'),
+    ('3.4.11',  'real',     'cycles-1_05-1_15_load-range', 'циклов в диапазоне загрузки 1,05 - 1,15', '0.0'),
+    ('3.4.12',  'real',     'cycles-1_15-1_25_load-range', 'циклов в диапазоне загрузки 1,15 - 1,25', '0.0'),
+    ('3.4.13',  'real',     'cycles-1_15-_load-range', 'циклов в диапазоне загрузки 1,25 -', '0.0'),
+    ('3.5',     'real',     'crane-total-lifted-mass', 'суммарная масса поднятых грузов. тонн', '0.0'),
+    ('3.5.1',   'real',     'winch1-total-lifted-mass', 'суммарная масса поднятых грузов лебедка 1', '0.0'),
+    ('3.5.2',   'real',     'winch2-total-lifted-mass', 'суммарная масса поднятых грузов лебедка 2', '0.0'),
+    ('3.5.3',   'real',     'winch3-total-lifted-mass', 'суммарная масса поднятых грузов лебедка 3', '0.0'),
+    ('3.6.1',   'int',      'winch1-load-limiter-trip-count', 'количество срабатываний ограничителя грузоподъемности лебедка 1', '0'),
+    ('3.6.2',   'int',      'winch2-load-limiter-trip-count', 'количество срабатываний ограничителя грузоподъемности лебедка 2', '0'),
+    ('3.6.3',   'int',      'winch3-load-limiter-trip-count', 'количество срабатываний ограничителя грузоподъемности лебедка 3', '0'),
+    ('3.7',     'real',     'crane-characteristic-number', 'текущее характеристическое число для крана', '0.0'),
+    ('3.7.1',   'real',     'winch1-characteristic-number', 'текущее характеристическое число лебедка 1', '0.0'),
+    ('3.7.2',   'real',     'winch2-characteristic-number', 'текущее характеристическое число лебедка 2', '0.0'),
+    ('3.7.3',   'real',     'winch3-characteristic-number', 'текущее характеристическое число лебедка 3', '0.0'),
+    ('3.8',     'real',     'crane-load-spectrum-factor', 'коэффициент распределения нагрузок для крана', '0.0'),
+    ('3.8.1',   'real',     'winch1-load-spectrum-factor', 'коэффициент распределения нагрузок лебедка 1', '0.0'),
+    ('3.8.2',   'real',     'winch2-load-spectrum-factor', 'коэффициент распределения нагрузок лебедка 2', '0.0'),
+    ('3.8.3',   'real',     'winch3-load-spectrum-factor', 'коэффициент распределения нагрузок лебедка 3', '0.0');

sql/7_create_report.sql

@@ -0,0 +1,14 @@
+/*
+    ERROR REPORTING
+*/
+-- Cleanup
+DROP TABLE IF EXISTS report;
+-- Creation
+create table if not exists report (
+    timestamp   timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP,
+    code        smallint NOT NULL,
+    message     varchar(50) NOT NULL,
+    stack       text NOT NULL,
+    PRIMARY KEY (timestamp)
+);
+comment on table report is 'Отчеты об ошибках в работе приложений.';