Resolve "824 crashes have $0 comprehensive cost"

atd-vzd/migrations/migration_update_audit_log_trigger_2021-10-03--1721.sql

@@ -0,0 +1,172 @@
+-- Augment the atd_txdot_crashes_update_audit_log() function to compute and store the crash based comprehensive cost
+-- This updated version of the function is also found in atd-vzd/triggers/atd_txdot_crashes_updates_audit_log.sql
+create or replace function atd_txdot_crashes_updates_audit_log() returns trigger
+    language plpgsql
+as
+$$
+DECLARE
+    estCompCostList decimal(10,2)[];
+    estCompCostListCrashBased decimal(10,2)[];
+    estCompEconList decimal(10,2)[];
+    speedMgmtList decimal(10,2)[];
+BEGIN
+    ------------------------------------------------------------------------------------------
+    -- CHANGE-LOG OPERATIONS
+    ------------------------------------------------------------------------------------------
+    -- Stores a copy of the current record into the change log
+    IF  (TG_OP = 'UPDATE') then
+        INSERT INTO atd_txdot_change_log (record_id, record_crash_id, record_type, record_json, updated_by)
+        VALUES (old.crash_id, old.crash_id, 'crashes', row_to_json(old), NEW.updated_by);
+    END IF;
+
+    -- COPIES THE CITY_ID INTO ORIGINAL_CITY_ID FOR BACKUP
+    IF (TG_OP = 'INSERT') THEN
+            NEW.original_city_id = NEW.city_id;
+    END IF;
+
+    ------------------------------------------------------------------------------------------
+    -- LATITUDE / LONGITUDE OPERATIONS
+    ------------------------------------------------------------------------------------------
+
+    -- When CRIS is present, populate values to Primary column
+    -- NOTE: It will update primary only if there is no lat/long data in the geo-coded or primary columns.
+    -- If there is data in primary coordinates, then it will not do anything.
+    -- If the there is geocoded data, it will not do anything.
+    IF (
+        (NEW.latitude is not null AND NEW.longitude is not null)
+        AND (NEW.latitude_geocoded is null AND NEW.longitude_geocoded is null)
+        AND (NEW.latitude_primary is null AND NEW.longitude_primary is null)
+    ) THEN
+        NEW.latitude_primary = NEW.latitude;
+        NEW.longitude_primary = NEW.longitude;
+    END IF;
+
+    -- When GeoCoded lat/longs are present, populate value to Primary
+    -- NOTE: It will only update if there are geocoded lat/longs and there are no primary lat/longs
+    IF (
+        (NEW.latitude_geocoded is not null AND NEW.longitude_geocoded is not null)
+        AND (NEW.latitude_primary is null AND NEW.longitude_primary is null)
+    ) THEN
+        NEW.latitude_primary = NEW.latitude_geocoded;
+        NEW.longitude_primary = NEW.longitude_geocoded;
+    END IF;
+    -- Finally we update the position field
+    NEW.position = ST_SetSRID(ST_MakePoint(NEW.longitude_primary, NEW.latitude_primary), 4326);
+    --- END OF LAT/LONG OPERATIONS ---
+
+
+    ------------------------------------------------------------------------------------------
+    -- CONFIRMED ADDRESSES
+    ------------------------------------------------------------------------------------------
+
+    -- If there is no confirmed primary address provided, then generate it:
+    IF (NEW.address_confirmed_primary IS NULL) THEN
+      NEW.address_confirmed_primary   = TRIM(CONCAT(NEW.rpt_street_pfx, ' ', NEW.rpt_block_num, ' ', NEW.rpt_street_name, ' ', NEW.rpt_street_sfx));
+    END IF;
+    -- If there is no confirmed secondary address provided, then generate it:
+    IF (NEW.address_confirmed_secondary IS NULL) THEN
+    NEW.address_confirmed_secondary = TRIM(CONCAT(NEW.rpt_sec_street_pfx, ' ', NEW.rpt_sec_block_num, ' ', NEW.rpt_sec_street_name, ' ', NEW.rpt_sec_street_sfx));
+    END IF;
+    --- END OF ADDRESS OPERATIONS ---
+
+    ------------------------------------------------------------------------------------------
+    -- APD's Death Count
+    ------------------------------------------------------------------------------------------
+    -- If our apd death count is null, then assume death_cnt's value
+    IF (NEW.atd_fatality_count IS NULL) THEN
+        NEW.atd_fatality_count = NEW.death_cnt;
+    END IF;
+
+    IF (NEW.apd_confirmed_death_count IS NULL) THEN
+        NEW.apd_confirmed_death_count = NEW.death_cnt;
+    -- Otherwise, the value has been entered manually, signal change with confirmed as 'Y'
+    ELSE
+        IF (NEW.apd_confirmed_death_count > 0) THEN
+            NEW.apd_confirmed_fatality = 'Y';
+        ELSE
+            NEW.apd_confirmed_fatality = 'N';
+        END IF;
+    END IF;
+    -- If the death count is any different from the original, then it is human-manipulated.
+    IF (NEW.apd_confirmed_death_count = NEW.death_cnt) THEN
+        NEW.apd_human_update = 'N';
+    ELSE
+        NEW.apd_human_update = 'Y';
+    END IF;
+    -- END OF APD's DEATH COUNT
+
+    ------------------------------------------------------------------------------------------
+    -- ESTIMATED COSTS
+    ------------------------------------------------------------------------------------------
+
+    -- First we need to gather a list of all of our costs, comprehensive and economic.
+    estCompCostList = ARRAY(SELECT est_comp_cost_amount FROM atd_txdot__est_comp_cost ORDER BY est_comp_cost_id ASC);
+    estCompCostListCrashBased = ARRAY(SELECT est_comp_cost_amount FROM atd_txdot__est_comp_cost_crash_based ORDER BY est_comp_cost_id ASC);
+    estCompEconList = ARRAY(SELECT est_econ_cost_amount FROM atd_txdot__est_econ_cost ORDER BY est_econ_cost_id ASC);
+
+    NEW.est_comp_cost = (0
+       + (NEW.unkn_injry_cnt * (estCompCostList[1]))
+       + (NEW.atd_fatality_count * (estCompCostList[2]))
+       + (NEW.sus_serious_injry_cnt * (estCompCostList[3]))
+       + (NEW.nonincap_injry_cnt * (estCompCostList[4]))
+       + (NEW.poss_injry_cnt * (estCompCostList[5]))
+       + (NEW.non_injry_cnt * (estCompCostList[6]))
+    )::decimal(10,2);
+
+    IF (NEW.atd_fatality_count > 0) THEN NEW.est_comp_cost_crash_based = estCompCostListCrashBased[1];
+    ELSIF (NEW.sus_serious_injry_cnt > 0) THEN NEW.est_comp_cost_crash_based = estCompCostListCrashBased[2];
+    ELSIF (NEW.nonincap_injry_cnt > 0) THEN NEW.est_comp_cost_crash_based = estCompCostListCrashBased[3];
+    ELSIF (NEW.poss_injry_cnt > 0) THEN NEW.est_comp_cost_crash_based = estCompCostListCrashBased[4];
+    ELSIF (NEW.non_injry_cnt > 0) THEN NEW.est_comp_cost_crash_based = estCompCostListCrashBased[5];
+    ELSIF (NEW.unkn_injry_cnt > 0) THEN NEW.est_comp_cost_crash_based = estCompCostListCrashBased[6];
+    ELSE NEW.est_comp_cost_crash_based = estCompCostListCrashBased[5]; -- default value of non-injury;
+    END IF;
+
+    NEW.est_econ_cost = (0
+       + (NEW.unkn_injry_cnt * (estCompEconList[1]))
+       + (NEW.atd_fatality_count * (estCompEconList[2]))
+       + (NEW.sus_serious_injry_cnt * (estCompEconList[3]))
+       + (NEW.nonincap_injry_cnt * (estCompEconList[4]))
+       + (NEW.poss_injry_cnt * (estCompEconList[5]))
+       + (NEW.non_injry_cnt * (estCompEconList[6]))
+    )::decimal(10,2);
+    --- END OF COST OPERATIONS ---
+
+    ------------------------------------------------------------------------------------------
+    -- SPEED MGMT POINTS
+    ------------------------------------------------------------------------------------------
+    speedMgmtList = ARRAY (SELECT speed_mgmt_points FROM atd_txdot__speed_mgmt_lkp ORDER BY speed_mgmt_id ASC);
+
+    NEW.speed_mgmt_points = (0
+       + (NEW.unkn_injry_cnt * (speedMgmtList [1]))
+       + (NEW.atd_fatality_count * (speedMgmtList [2]))
+       + (NEW.sus_serious_injry_cnt * (speedMgmtList [3]))
+       + (NEW.nonincap_injry_cnt * (speedMgmtList [4]))
+       + (NEW.poss_injry_cnt * (speedMgmtList [5]))
+       + (NEW.non_injry_cnt * (speedMgmtList [6]))
+    )::decimal (10,2);
+    --- END OF SPEED MGMT POINTS ---
+
+    ------------------------------------------------------------------------------------------
+    -- MODE CATEGORY DATA
+    ------------------------------------------------------------------------------------------
+    NEW.atd_mode_category_metadata = get_crash_modes(NEW.crash_id);
+    --- END OF MODE CATEGORY DATA ---
+
+    ------------------------------------------------------------------------------------------
+    -- AUSTIN FULL PURPOSE
+    ------------------------------------------------------------------------------------------
+    -- Set Austin Full Purpose to Y (TRUE) when it has Austin City ID and no coordinates.
+    IF (NEW.position IS NULL and NEW.city_id = 22) THEN
+        NEW.austin_full_purpose = 'Y';
+    END IF;
+    --- END OF AUSTIN FULL PURPOSE ---
+
+    -- Record the current timestamp
+    NEW.last_update = current_timestamp;
+    RETURN NEW;
+END;
+$$;
+
+-- set ownership if needed
+alter function atd_txdot_crashes_updates_audit_log() owner to atd_vz_data;

atd-vzd/triggers/atd_txdot_crashes_updates_audit_log.sql

@@ -117,7 +117,7 @@ BEGIN
     ELSIF (NEW.poss_injry_cnt > 0) THEN NEW.est_comp_cost_crash_based = estCompCostListCrashBased[4];
     ELSIF (NEW.non_injry_cnt > 0) THEN NEW.est_comp_cost_crash_based = estCompCostListCrashBased[5];
     ELSIF (NEW.unkn_injry_cnt > 0) THEN NEW.est_comp_cost_crash_based = estCompCostListCrashBased[6];
-    ELSE NEW.est_comp_cost_crash_based = 0;
+    ELSE NEW.est_comp_cost_crash_based = estCompCostListCrashBased[5]; -- default value of non-injury
     END IF;
 
     NEW.est_econ_cost = (0