Changes between Version 5 and Version 6 of appdevelopment

Timestamp:

09/30/25 18:52:04 (2 weeks ago)

Author:

155036

Comment:

--

appdevelopment

@@ -318 +318 @@
 }}}
 
+=== p_event_risk_overview ===
+{{{
+CREATE OR REPLACE PROCEDURE p_event_risk_overview(
+  IN  p_event_id   int,
+  IN  p_actor_id   int,
+  IN  p_user_id    int,
+  IN  p_from_date  date DEFAULT NULL,
+  IN  p_to_date    date DEFAULT NULL,
+  INOUT p_cur      refcursor DEFAULT NULL
+)
+LANGUAGE plpgsql
+AS $$
+BEGIN
+  IF p_cur IS NULL THEN p_cur := 'cur_event_risk_overview'; END IF;
+
+  OPEN p_cur FOR
+  WITH
+  -- Кој актер и која локација се поврзани со настанот
+  event_context AS (
+    SELECT ed.global_event_id, ed.actor_id, ed.location_id
+    FROM event_details ed
+    WHERE ed.global_event_id = p_event_id
+       OR ed.actor_id = p_actor_id
+  ),
+  -- Нотификации поврзани со корисник или настан
+  notif AS (
+    SELECT n.notification_id, n.user_id, n.notification_date, n.event_id
+    FROM notifications n
+    WHERE (n.user_id = p_user_id AND n.notification_date BETWEEN COALESCE(p_from_date,'1900-01-01') AND COALESCE(p_to_date, now()::date))
+       OR (n.event_id = p_event_id)
+  ),
+  -- Прогнози поврзани со настанот/актерот
+  preds AS (
+    SELECT pr.prediction_id, pr.event_id, pr.actor_id, pr.predicted_date, pr.confidence
+    FROM predictions pr
+    WHERE pr.event_id = p_event_id
+       OR pr.actor_id = p_actor_id
+  ),
+  -- Аналитика за настан + актер по датуми
+  analytics AS (
+    SELECT ea.event_id, ea.actor_id, ea.date, ea.metric_value
+    FROM event_analytics ea
+    WHERE ea.event_id = p_event_id
+      AND ea.actor_id = p_actor_id
+      AND ea.date BETWEEN COALESCE(p_from_date,'1900-01-01') AND COALESCE(p_to_date, now()::date)
+  ),
+  -- Ризици помеѓу парови актери
+  risks AS (
+    SELECT cr.actor1_id, cr.actor2_id, cr.predicted_date, cr.risk_score
+    FROM conflict_risk cr
+    WHERE (cr.actor1_id = p_actor_id OR cr.actor2_id = p_actor_id)
+      AND cr.predicted_date BETWEEN COALESCE(p_from_date,'1900-01-01') AND COALESCE(p_to_date, now()::date)
+  )
+  SELECT jsonb_build_object(
+    'event_id', p_event_id,
+    'actor_id', p_actor_id,
+    'notifications', COALESCE(jsonb_agg(DISTINCT notif), '[]'::jsonb),
+    'predictions',  COALESCE(jsonb_agg(DISTINCT preds), '[]'::jsonb),
+    'analytics',    COALESCE(jsonb_agg(DISTINCT analytics), '[]'::jsonb),
+    'risks',        COALESCE(jsonb_agg(DISTINCT risks), '[]'::jsonb)
+  ) AS j
+  FROM notif, preds, analytics, risks;
+END;
+$$;
+}}}
+
+== Објаснување на Execution Plan ==
+
+При повик на `p_event_risk_overview` со `EXPLAIN (ANALYZE, BUFFERS)`, PostgreSQL користи индекс скенирања за оптимален пристап:
+
+ * **event_details** → `Index Scan` на `ix_event_details_event` или `ix_event_details_actor` за брзо наоѓање актери/локации поврзани со настанот.
+ * **notifications** → `Index Scan` на `ix_notifications_user` (композитен индекс по user/date) или `ix_notifications_event` за пребарување на кориснички нотификации.
+ * **predictions** → `Index Scan` на `ix_predictions_event` или `ix_predictions_actor` за селекција на предвидувања.
+ * **event_analytics** → `Index Scan` на `ix_analytics_event_actor` со дополнително филтрирање по `date`.
+ * **conflict_risk** → `Index Scan` на `ix_conflict_pair_date` за проверка на ризици меѓу актери во даден временски интервал.
+
+Ова покажува дека секоја табела се пристапува преку соодветен индекс наместо со целосно скенирање,
+што значително ја зголемува брзината и ја намалува потрошувачката на ресурси при сложени аналитички пребарувања.
+
 == Индекси ==