IRVE : utilisation de floats en base de données pour la valeur puissance_nominale (#5531)

Author: vdegove

apps/transport/lib/db/irve_valid_pdc.ex

@@ -31,7 +31,7 @@ defmodule DB.IRVEValidPDC do
     field(:nbre_pdc, :integer, null: false)
     field(:id_pdc_itinerance, :string, null: false)
     field(:id_pdc_local, :string)
-    field(:puissance_nominale, :decimal, null: false)
+    field(:puissance_nominale, :float, null: false)
     field(:prise_type_ef, :boolean, null: false)
     field(:prise_type_2, :boolean, null: false)
     field(:prise_type_combo_ccs, :boolean, null: false)

apps/transport/lib/irve/data_frame.ex

@@ -116,17 +116,9 @@ defmodule Transport.IRVE.DataFrame do
 
   Congratulations for reading this far.
   """
+
   def dataframe_from_csv_body!(body, schema \\ Transport.IRVE.StaticIRVESchema.schema_content(), strict \\ true) do
-    dtypes =
-      schema
-      |> Map.fetch!("fields")
-      |> Enum.map(fn %{"name" => name, "type" => type} ->
-        {
-          String.to_atom(name),
-          String.to_atom(type)
-          |> Transport.IRVE.DataFrame.remap_schema_type(strict)
-        }
-      end)
+    dtypes = schema_dtypes(schema, strict)
 
     delimiter = guess_delimiter!(body)
 
@@ -137,6 +129,26 @@ defmodule Transport.IRVE.DataFrame do
     end
   end
 
+  @doc """
+  Computes Explorer dtypes from a TableSchema, using `remap_schema_type/2`.
+
+  iex> Transport.IRVE.DataFrame.schema_dtypes() |> Keyword.fetch!(:puissance_nominale)
+  {:f, 64}
+  iex> Transport.IRVE.DataFrame.schema_dtypes() |> Keyword.fetch!(:id_pdc_itinerance)
+  :string
+  """
+  def schema_dtypes(schema \\ Transport.IRVE.StaticIRVESchema.schema_content(), strict \\ true) do
+    schema
+    |> Map.fetch!("fields")
+    |> Enum.map(fn %{"name" => name, "type" => type} ->
+      {
+        String.to_atom(name),
+        String.to_atom(type)
+        |> Transport.IRVE.DataFrame.remap_schema_type(strict)
+      }
+    end)
+  end
+
   defmodule ColumnDelimiterGuessError do
     @moduledoc """
     Raised when the code could not determine the proper delimiter.

apps/transport/lib/irve/database_exporter.ex

@@ -30,7 +30,7 @@ defmodule Transport.IRVE.DatabaseExporter do
             stream
             |> Stream.map(&Map.merge(elem(&1, 0), elem(&1, 1)))
             |> Enum.into([])
-            |> Explorer.DataFrame.new()
+            |> Explorer.DataFrame.new(dtypes: Transport.IRVE.DataFrame.schema_dtypes())
 
           {:ok, result}
         end,

apps/transport/priv/repo/migrations/20260605083835_change_irve_puissance_nominale_to_float.exs

@@ -0,0 +1,9 @@
+defmodule DB.Repo.Migrations.ChangeIrvePuissanceNominaleToFloat do
+  use Ecto.Migration
+
+  def change do
+    alter table(:irve_valid_pdc) do
+      modify(:puissance_nominale, :float, from: :decimal)
+    end
+  end
+end