fix: change daily inverter energy calculation (et/somenergia-jardiner…

…!103)

Merge branch 'fix/inverter_energy' into 'main'

dbt_jardiner/models/jardiner/marts/_marts__exposures.yaml

@@ -13,8 +13,6 @@ exposures:
       En un futur també mostrarà l'estat d'alarmes.
 
     depends_on:
-      - ref('dm_dset_energy_inverter__daily__accumulated')
-      - ref('dm_dset_energy_inverter__daily__reset_daily')
       - ref('dm_dashboard_overview_monthly')
       - ref('dm_dashboard_overview_instant')
       - ref('dm_dashboard_overview__produccio_cartera')
@@ -41,7 +39,7 @@ exposures:
       - ref('dm_plant_production_hourly')
       - ref('dm_metrics_production_5min')
       - ref('dm_plants')
-      - ref('dm_dset_energy_inverter__agg_monthly_for_om')
+      - ref('dm_dset_energy_inverter__monthly__reset_daily')
 
     owner:
       name: Gestió D'Actius

dbt_jardiner/models/jardiner/marts/dm_dset_energy_inverter__monthly__reset_daily.sql

@@ -0,0 +1,23 @@
+{{ config(materialized="view") }}
+
+with
+    inverter_energy_monthly as (
+        select
+            date_trunc('month', day, 'Europe/Madrid') as month_date,
+            plant_name,
+            device_name,
+            coalesce(sum(inverter_total_energy_kwh), sum(inverter_export_energy_kwh))/1000 as inverter_energy_mwh
+        from {{ ref("int_dset_energy_inverter__daily__reset_daily") }}
+        group by
+            date_trunc('month', day, 'Europe/Madrid'),
+            plant_name,
+            device_name
+    )
+    select
+        month_date as mes,
+        plant_name as nom_planta,
+        device_name as aparell,
+        inverter_energy_mwh as energia_inversor_mwh
+    from inverter_energy_monthly
+    where month_date > '2023-12-01'
+    order by month_date desc, plant_name, device_name

dbt_jardiner/models/jardiner/marts/dm_dset_energy_inverter__daily__reset_daily.sql → dbt_jardiner/models/jardiner/marts/int_dset_energy_inverter__daily__reset_daily.sql

@@ -18,6 +18,7 @@ with
             metric_name = 'energia_activa_exportada'
             {# filter to discard previous day data which gets reset early morning #}
             and extract(hour from ts at time zone 'Europe/Madrid') > 3
+            or metric_name = 'energia_activa_exportada_total'
         group by
             date_trunc('day', ts, 'Europe/Madrid'),
             plant_uuid,
@@ -27,9 +28,34 @@ with
             metric_name
     ),
     inverter_energy_daily as (
-        select *, diff_inverter_energy_kwh as inverter_energy_kwh
+        select
+            day,
+            plant_name,
+            device_name,
+            case
+                when metric_name = 'energia_activa_exportada'
+                then diff_inverter_energy_kwh
+                else null
+            end as inverter_export_energy_kwh,
+            case
+                when metric_name = 'energia_activa_exportada_total'
+                then diff_inverter_energy_kwh
+                else null
+            end as inverter_total_energy_kwh
         from inverter_energy_daily_metrics
         order by day desc, plant_name, device_name
+    ),
+    all_inverter_energy_metrics_in_one_tb as (
+        select
+            day,
+            plant_name,
+            device_name,
+            max(inverter_export_energy_kwh) as inverter_export_energy_kwh,
+            max(inverter_total_energy_kwh) as inverter_total_energy_kwh
+        from inverter_energy_daily
+        group by day, plant_name, device_name
     )
 select *
-from inverter_energy_daily
+from all_inverter_energy_metrics_in_one_tb
+where day > '2023-12-15' --data aprox en que dset transforma correctament aquestes mètriques
+order by day desc, plant_name, device_name