Remove beacon_status from beacons table

Author: VincentAntoine

…_beacon_malfunction_initial_location.sql …93__Update_beacon_malfunctions_table.sqlbackend/src/main/resources/db/migration/internal/V0.393__Add_beacon_malfunction_initial_location.sql renamed to backend/src/main/resources/db/migration/internal/V0.393__Update_beacon_malfunctions_table.sql backend/src/main/resources/db/migration/internal/V0.393__Add_beacon_malfunction_initial_location.sql renamed to backend/src/main/resources/db/migration/internal/V0.393__Update_beacon_malfunctions_table.sql

@@ -54,6 +54,6 @@ WHERE initial_vessel_status != 'AT_SEA'::beacon_malfunctions_vessel_status;
 ALTER TABLE beacon_malfunctions
 ALTER COLUMN is_followed SET NOT NULL;
 
--- Drop unused column
+-- Drop unused columns
 ALTER TABLE beacon_malfunctions
 DROP COLUMN beacon_status_at_malfunction_creation;

backend/src/main/resources/db/migration/internal/V0.394__Update_satellite_operators_statuses_view.sql

@@ -0,0 +1,85 @@
+DROP VIEW satellite_operators_statuses;
+
+CREATE VIEW satellite_operators_statuses AS
+
+WITH recent_positions AS (
+    SELECT
+        DATE_TRUNC('hour', date_time) AS date_hour,
+        s.id AS satellite_operator_id,
+        v.id AS vessel_id
+    FROM positions p
+    JOIN vessels v
+    ON v.cfr = p.internal_reference_number
+    JOIN beacons b
+    ON b.vessel_id = v.id
+    JOIN satellite_operators s
+    ON s.id = b.satellite_operator_id
+    WHERE
+        date_time < DATE_TRUNC('hour', CURRENT_TIMESTAMP AT TIME ZONE 'UTC') AND
+        date_time >= DATE_TRUNC('hour', CURRENT_TIMESTAMP AT TIME ZONE 'UTC') - INTERVAL '24 hours'
+
+    UNION ALL
+
+    SELECT
+        DATE_TRUNC('hour', date_time) AS date_hour,
+        s.id AS satellite_operator_id,
+        v.id AS vessel_id
+    FROM positions p
+    JOIN vessels v
+    ON v.ircs = p.ircs
+    JOIN beacons b
+    ON b.vessel_id = v.id
+    JOIN satellite_operators s
+    ON s.id = b.satellite_operator_id
+    WHERE
+        date_time < DATE_TRUNC('hour', CURRENT_TIMESTAMP AT TIME ZONE 'UTC') AND
+        date_time >= DATE_TRUNC('hour', CURRENT_TIMESTAMP AT TIME ZONE 'UTC') - INTERVAL '24 hours'
+),
+
+positions_histogram AS (
+    SELECT
+        date_hour,
+        satellite_operator_id,
+        COUNT(DISTINCT vessel_id) AS nb_vessels_emitting
+    FROM recent_positions p
+    GROUP BY date_hour, satellite_operator_id
+),
+
+nb_attributed_beacons_per_operator AS (
+    SELECT
+        s.id AS satellite_operator_id,
+        COUNT(*) AS nb_attributed_beacons
+    FROM beacons b
+    JOIN satellite_operators s
+    ON s.id = b.satellite_operator_id
+    WHERE vessel_id IS NOT NULL
+    GROUP BY s.id
+),
+
+shares_histogram AS (
+    SELECT
+        date_hour,
+        s.id AS satellite_operator_id,
+        nb_vessels_emitting::DOUBLE PRECISION / nb_attributed_beacons::DOUBLE PRECISION AS share_vessels_emitting
+    FROM nb_attributed_beacons_per_operator n
+    JOIN positions_histogram h
+    ON h.satellite_operator_id = n.satellite_operator_id
+    JOIN satellite_operators s
+    ON n.satellite_operator_id = s.id
+),
+
+nb_hours_share_ok_per_operator AS (
+    SELECT
+        s.id AS satellite_operator_id,
+        SUM(CASE WHEN share_vessels_emitting > 0.7 THEN 1 ELSE 0 END) AS nb_hours_with_share_ok
+    FROM satellite_operators s
+    LEFT JOIN shares_histogram sh
+    ON s.id = sh.satellite_operator_id
+    GROUP BY s.id
+)
+
+SELECT
+    satellite_operator_id,
+    CASE WHEN nb_hours_with_share_ok = 24 THEN true ELSE false END AS operator_is_up
+FROM nb_hours_share_ok_per_operator
+ORDER BY 1

backend/src/main/resources/db/migration/internal/V0.395__Update_beacons_table.sql

@@ -0,0 +1,2 @@
+ALTER TABLE beacons
+DROP COLUMN beacon_status;

backend/src/main/resources/db/testdata/V666.23__Insert_dummy_beacons.sql

@@ -1,12 +1,12 @@
 INSERT INTO public.beacons (
-    beacon_number, vessel_id,  beacon_status, is_coastal, satellite_operator_id, logging_datetime_utc)
+    beacon_number, vessel_id, is_coastal, satellite_operator_id, logging_datetime_utc)
 VALUES
-    (   'FGEDX85',         1,    'ACTIVATED',      TRUE,                     1,    '2021-5-12 12:23'),
-    (    '123456',         2,    'ACTIVATED',      FALSE,                     1,    '2021-4-22 22:25'),
-    (    'ETETE4',         3,    'ACTIVATED',      FALSE,                     1,    '2021-3-20 12:38'),
-    (    'A56CZ2',         4,    'ACTIVATED',      FALSE,                     2,    '2021-2-20 12:25'),
-    (   'FEZFS65',         5, 'UNSUPERVISED',      FALSE,                     2,    '2021-1-12 10:47'),
-    (   'LHGY122',         7,      'IN_TEST',      FALSE,                     2,    '2021-12-2 12:21'),
-    (   'NB56FR8',         8,    'ACTIVATED',      FALSE,                     2,      '2021-6-2 9:23'),
-    (   'PO8U9U4',         9,    'ACTIVATED',      FALSE,                     2,     '2021-5-2 12:27'),
-    (   'ABC1234',      null,    'ACTIVATED',      FALSE,                     2,     '2021-5-1 12:20');
+    (   'FGEDX85',         1,      TRUE,                     1,    '2021-5-12 12:23'),
+    (    '123456',         2,      FALSE,                     1,    '2021-4-22 22:25'),
+    (    'ETETE4',         3,      FALSE,                     1,    '2021-3-20 12:38'),
+    (    'A56CZ2',         4,      FALSE,                     2,    '2021-2-20 12:25'),
+    (   'FEZFS65',         5,      FALSE,                     2,    '2021-1-12 10:47'),
+    (   'LHGY122',         7,      FALSE,                     2,    '2021-12-2 12:21'),
+    (   'NB56FR8',         8,      FALSE,                     2,      '2021-6-2 9:23'),
+    (   'PO8U9U4',         9,      FALSE,                     2,     '2021-5-2 12:27'),
+    (   'ABC1234',      null,      FALSE,                     2,     '2021-5-1 12:20');