Merge pull request #210 from SynTech-T5/develop

2.2.0

Author: wanasart

aods_dev_v3.sql

@@ -60,7 +60,7 @@ CREATE TABLE IF NOT EXISTS users (
   usr_username    VARCHAR(32)  NOT NULL UNIQUE,
   usr_email       VARCHAR(64) NOT NULL UNIQUE,
   usr_password    VARCHAR(255) NOT NULL,
-  usr_name        VARCHAR(32),  
+  usr_name        VARCHAR(64),  
   usr_phone       VARCHAR(10),
   usr_profile     VARCHAR(255),
 
@@ -96,7 +96,7 @@ CREATE TABLE IF NOT EXISTS events (
   evt_id          INTEGER GENERATED BY DEFAULT AS IDENTITY PRIMARY KEY,
 
   evt_icon        VARCHAR(32) NOT NULL,
-  evt_name        VARCHAR(32) UNIQUE NOT NULL,
+  evt_name        VARCHAR(32) NOT NULL,
   evt_description TEXT,
 
   evt_created_at  TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP,
@@ -264,7 +264,8 @@ CREATE TABLE notification_thresholds (
     nth_critical  BOOLEAN DEFAULT FALSE,
     nth_high      BOOLEAN DEFAULT FALSE,
     nth_medium    BOOLEAN DEFAULT FALSE,
-    nth_low       BOOLEAN DEFAULT FALSE
+    nth_low       BOOLEAN DEFAULT FALSE,
+    nth_status    BOOLEAN DEFAULT TRUE
 );
 
 CREATE TABLE event_priority (
@@ -293,7 +294,7 @@ CREATE TABLE notification_recipients (
 CREATE TABLE IF NOT EXISTS reports (
   rpt_id         INTEGER GENERATED BY DEFAULT AS IDENTITY PRIMARY KEY,
 
-  rpt_name        VARCHAR(32) NOT NULL,
+  rpt_name        VARCHAR(64) NOT NULL,
   rpt_template    VARCHAR(16) NOT NULL DEFAULT 'general' CHECK (rpt_template IN ('general', 'alert', 'performance')),
   rpt_type        VARCHAR(16) NOT NULL DEFAULT 'pdf' CHECK (rpt_type  IN ('pdf')),
   rpt_range_start DATE NOT NULL,
@@ -574,45 +575,93 @@ CREATE INDEX IF NOT EXISTS idx_rln_recipient_created_desc
 ---------------------------------[ Notification Emails ]--------------------------------
 CREATE OR REPLACE VIEW v_notification_emails AS
 SELECT
-  r.rcp_id,
-  COALESCE(u.usr_email, r.rcp_email)                        AS email,
-  COALESCE(u.usr_name, u.usr_username, NULL)                AS display_name,
-  (u.usr_id IS NOT NULL
-     OR EXISTS (SELECT 1 FROM users ux WHERE ux.usr_email = r.rcp_email)
-  )                                                         AS is_internal,
-  rl.rln_entity,
-  rl.rln_entity_id,
-  r.rcp_created_at
+  -- Link Info
+  rl.rln_id        AS link_id,
+  rl.rln_entity    AS entity,
+  rl.rln_entity_id AS entity_id,
+
+  -- Recipient Info
+  r.rcp_id         AS recipient_id,
+
+  -- User Info (internal)
+  u.usr_id         AS user_id,
+  u.usr_username   AS username,
+  u.usr_profile    AS profile,
+
+  -- Email + Display
+  COALESCE(u.usr_email, r.rcp_email) AS email,
+  COALESCE(u.usr_name, u.usr_username, NULL) AS display_name,
+
+  -- Internal Flag
+  (
+    u.usr_id IS NOT NULL
+    OR EXISTS (
+         SELECT 1
+         FROM users ux
+         WHERE ux.usr_email = r.rcp_email
+       )
+  ) AS is_internal,
+
+  -- Timestamp TH
+  TO_CHAR(
+    r.rcp_created_at AT TIME ZONE 'Asia/Bangkok',
+    'YYYY-MM-DD HH24:MI:SS'
+  ) AS created_at_th
+
 FROM recipient_links rl
-JOIN recipients r        ON r.rcp_id  = rl.rln_rcp_id
-LEFT JOIN users u        ON u.usr_id  = r.rcp_usr_id
+JOIN recipients r  ON r.rcp_id = rl.rln_rcp_id
+LEFT JOIN users u  ON u.usr_id = r.rcp_usr_id
 WHERE rl.rln_entity <> 'scheduled_report'
 ORDER BY r.rcp_created_at DESC;
 
 ---------------------------------[ Scheduled Report Emails ]--------------------------------
 CREATE OR REPLACE VIEW v_scheduled_report_emails AS
 SELECT
-  r.rcp_id,
-  COALESCE(u.usr_email, r.rcp_email)                        AS email,
-  COALESCE(u.usr_name, u.usr_username, NULL)                AS display_name,
-  (u.usr_id IS NOT NULL
-     OR EXISTS (SELECT 1 FROM users ux WHERE ux.usr_email = r.rcp_email)
-  )                                                         AS is_internal,
-
-  -- บอกว่าเป็นของ schedule ไหน / report ไหน
-  scr.scr_id                                                AS schedule_id,
-  rpt.rpt_id                                                AS report_id,
-  rpt.rpt_name                                              AS report_name,
-
-  -- เผื่ออยากดู metadata เพิ่มเติม
+  -- Link Info
+  rl.rln_id        AS link_id,
+  rl.rln_entity    AS entity,
+  rl.rln_entity_id AS entity_id,
+
+  -- Recipient Info
+  r.rcp_id         AS recipient_id,
+
+  -- User Info (internal)
+  u.usr_id         AS user_id,
+  u.usr_username   AS username,
+  u.usr_profile    AS profile,
+
+  -- Email + Display
+  COALESCE(u.usr_email, r.rcp_email) AS email,
+  COALESCE(u.usr_name, u.usr_username, NULL) AS display_name,
+
+  -- Internal Flag
+  (
+    u.usr_id IS NOT NULL
+    OR EXISTS (
+         SELECT 1
+         FROM users ux
+         WHERE ux.usr_email = r.rcp_email
+       )
+  ) AS is_internal,
+
+  -- Schedule Info
+  scr.scr_id        AS schedule_id,
+  rpt.rpt_id        AS report_id,
+  rpt.rpt_name      AS report_name,
   scr.scr_frequency,
   scr.scr_time,
-  r.rcp_created_at
+
+  -- Timestamp TH
+  TO_CHAR(
+    r.rcp_created_at AT TIME ZONE 'Asia/Bangkok',
+    'YYYY-MM-DD HH24:MI:SS'
+  ) AS created_at_th
+
 FROM recipient_links rl
-JOIN recipients r          ON r.rcp_id  = rl.rln_rcp_id
-LEFT JOIN users u          ON u.usr_id  = r.rcp_usr_id
+JOIN recipients r     ON r.rcp_id = rl.rln_rcp_id
+LEFT JOIN users u     ON u.usr_id = r.rcp_usr_id
 JOIN scheduled_reports scr ON scr.scr_id = rl.rln_entity_id
-JOIN reports rpt           ON rpt.rpt_id = scr.scr_rpt_id
+JOIN reports rpt      ON rpt.rpt_id = scr.scr_rpt_id
 WHERE rl.rln_entity = 'scheduled_report'
 ORDER BY r.rcp_created_at DESC;
 
@@ -715,6 +764,7 @@ CREATE OR REPLACE VIEW v_events_in_cameras AS
 SELECT
   e.evt_id          AS event_id,
   e.evt_name        AS event_name,
+  e.evt_icon        AS event_icon,
   c.cam_id          AS camera_id,
   c.cam_name        AS camera_name,
   l.loc_name        AS location_name,
@@ -1030,8 +1080,12 @@ CREATE TRIGGER trg_events_after_insert_fill_priority
 AFTER INSERT ON events
 FOR EACH ROW EXECUTE FUNCTION trg_after_events_insert_fill_priority();
 
+ALTER TABLE recipient_links
+ADD CONSTRAINT uq_alert_unique_link
+UNIQUE (rln_rcp_id, rln_entity, rln_entity_id);
+
 /* ============================================================
-   =========    ===========
+   ========= FUNCTIONS   ===========
    ============================================================ */
 
 
@@ -1070,6 +1124,64 @@ FOR EACH ROW
 WHEN (OLD.evt_is_use IS DISTINCT FROM NEW.evt_is_use)
 EXECUTE FUNCTION aods_dev_v3.fn_sync_cds_is_use();
 
+-- เพิ่ม recipient + link (คืนค่า rln_id และ rcp_id)
+CREATE OR REPLACE FUNCTION aods_dev_v3.fn_add_recipient_link(
+  p_email TEXT,
+  p_usr_id INT,
+  p_entity TEXT,
+  p_entity_id INT
+) RETURNS TABLE(rln_id INT, rcp_id INT) LANGUAGE plpgsql AS $$
+DECLARE
+  v_rcp_id INT;
+BEGIN
+  -- หา recipient ที่มี usr_id หรือ email ตรงกันก่อน
+  IF p_usr_id IS NOT NULL THEN
+    SELECT rcp_id INTO v_rcp_id FROM aods_dev_v3.recipients WHERE rcp_usr_id = p_usr_id LIMIT 1;
+  END IF;
+
+  IF v_rcp_id IS NULL AND p_email IS NOT NULL THEN
+    SELECT rcp_id INTO v_rcp_id FROM aods_dev_v3.recipients WHERE rcp_email = p_email LIMIT 1;
+  END IF;
+
+  -- ถ้ายังไม่มี สร้าง
+  IF v_rcp_id IS NULL THEN
+    INSERT INTO aods_dev_v3.recipients (rcp_usr_id, rcp_email)
+    VALUES (p_usr_id, p_email)
+    RETURNING rcp_id INTO v_rcp_id;
+  END IF;
+
+  -- สร้าง link (ป้องกัน duplicate ถ้าต้องการ)
+  INSERT INTO aods_dev_v3.recipient_links (rln_rcp_id, rln_entity, rln_entity_id)
+  VALUES (v_rcp_id, p_entity, p_entity_id)
+  RETURNING rln_id INTO rln_id;
+
+  rcp_id := v_rcp_id;
+  RETURN NEXT;
+END;
+$$;
+
+-- ลบ link (ตาม rln_id) และ cleanup recipients ที่ไม่ถูกอ้างอิง
+CREATE OR REPLACE FUNCTION aods_dev_v3.fn_remove_recipient_link(p_rln_id INT)
+RETURNS VOID LANGUAGE plpgsql AS $$
+DECLARE
+  v_rcp_id INT;
+  v_count INT;
+BEGIN
+  SELECT rln_rcp_id INTO v_rcp_id FROM aods_dev_v3.recipient_links WHERE rln_id = p_rln_id;
+  IF v_rcp_id IS NULL THEN
+    RAISE EXCEPTION 'recipient link % not found', p_rln_id;
+  END IF;
+
+  DELETE FROM aods_dev_v3.recipient_links WHERE rln_id = p_rln_id;
+
+  -- ถ้า recipient ไม่มี link ใดๆ เลย ให้ลบ (cleanup)
+  SELECT COUNT(*) INTO v_count FROM aods_dev_v3.recipient_links WHERE rln_rcp_id = v_rcp_id;
+  IF v_count = 0 THEN
+    DELETE FROM aods_dev_v3.recipients WHERE rcp_id = v_rcp_id;
+  END IF;
+END;
+$$;
+
 -- ============================================================
 -- INSERT BASE DATA
 -- ============================================================
@@ -1175,3 +1287,7 @@ INSERT INTO maintenance_history (
   (8, '2025-10-17', 'repair', 'Technician H', 'เปลี่ยน adapter กล้อง Server Room Cam 02'),
   (9, '2025-10-18', 'routine check', 'Technician I', 'ตรวจเช็คเลนส์และโฟกัสกล้อง Warehouse Exit Cam 01'),
   (10,'2025-10-19', 'installation', 'Technician J', 'ติดตั้งกล้อง Warehouse Exit Cam 02 ใหม่หลังซ่อมบำรุง');
+
+INSERT INTO alert_escalation(
+	aes_severity)
+	VALUES ('critical'), ('high'),('medium'),('low');