chore: verify value in footer and payments

Author: eulixir

CHANGELOG

@@ -3,7 +3,8 @@
 All notable changes to this project will be documented in this file.
 
 ## Version History
-- 1.3.2 (2023-21-06)
+- 1.3.3 (2023-17-07)
+- 1.3.2 (2023-14-07)
 - 1.3.1 (2023-21-06)
 - 1.3.0 (2023-29-05)
 - 1.2.5 (2023-18-05)

README.md

@@ -14,7 +14,7 @@ In `mix.exs`, add the ExMachina dependency:
 ```elixir
 def deps do
   [
-    {:ex_cnab, "~> 1.3.2"},
+    {:ex_cnab, "~> 1.3.3"},
   ]
 end
 ```

app/excnab/cnab240/services/build_details.ex

@@ -90,7 +90,7 @@ defmodule ExCnab.Cnab240.Services.BuildDetails do
          %{header: header, detail: details, footer: footer} <- hd[detail_key_id],
          {:ok, builded_header} <- ChunkHeader.generate(header),
          {:ok, builded_details} <- Details.generate(details),
-         {:ok, builded_footer} <- ChunkFooter.generate(footer),
+         {:ok, builded_footer} <- ChunkFooter.generate(footer, builded_details),
          amount <- get_chunk_infos(builded_header, builded_footer) do
       details = [
         %{

app/excnab/cnab240/services/calc_amout.ex

@@ -0,0 +1,58 @@
+defmodule ExCnab.Cnab240.Services.CalcAmount do
+  @spec run(Map.t()) :: Integer.t()
+  def run(details) do
+    details
+    |> hd()
+    |> Map.get(:servico)
+    |> Map.get(:segmento)
+    |> calc_model(details)
+  end
+
+  defp calc_model("A", details) do
+    Enum.reduce(details, 0, fn detail, acc ->
+      case detail.servico.segmento == "A" do
+        true ->
+          acc + String.to_integer(detail.credito.valor_pagamento)
+
+        false ->
+          acc
+      end
+    end)
+  end
+
+  defp calc_model("J", details) do
+    Enum.reduce(details, 0, fn detail, acc ->
+      case detail.servico.segmento == "J" do
+        true ->
+          acc + String.to_integer(detail.pagamento.valor_pagamento)
+
+        false ->
+          acc
+      end
+    end)
+  end
+
+  defp calc_model("N", details) do
+    Enum.reduce(details, 0, fn detail, acc ->
+      case detail.servico.segmento == "J" do
+        true ->
+          acc + String.to_integer(detail.pagamento.valor_pagamento)
+
+        false ->
+          acc
+      end
+    end)
+  end
+
+  defp calc_model("O", details) do
+    Enum.reduce(details, 0, fn detail, acc ->
+      case detail.servico.segmento == "O" do
+        true ->
+          acc + String.to_integer(detail.pagamento.valor_pagamento)
+
+        false ->
+          acc
+      end
+    end)
+  end
+end

app/excnab/cnab240/services/decode.ex

@@ -9,6 +9,8 @@ defmodule ExCnab.Cnab240.Services.Decode do
 
   alias ExCnab.Cnab240.Services.GetFileInfo
 
+  alias ExCnab.Cnab240.Services.HasIdenticalInformations
+
   @item_type %{
     "0" => :file_header,
     "1" => :chunk_header,
@@ -20,38 +22,46 @@ defmodule ExCnab.Cnab240.Services.Decode do
 
   @spec run(String.t(), Map.t()) :: {:ok, Map.t()} | {:error, String.t()}
   def run(file, attrs \\ %{}) do
-    list = read_file(file)
-
-    with {:ok, map} <- classify_by_type(list),
-         {:ok, file_header} <- FileHeader.generate(map.file_header, attrs),
-         {:ok, details} <- BuildDetails.run(map.chunks, attrs),
-         {:ok, footer} <- FileFooter.generate(map.file_footer, attrs),
-         {:ok, filename_info} <- GetFileInfo.run(file, attrs) do
-      build_response(file_header, details, footer, filename_info, :ok)
-    else
-      {:error, error, line_error} ->
-        line =
-          list
-          |> Enum.find_index(&(&1 == line_error))
-          |> Kernel.+(1)
-
-        {:error, error, "Falha na linha #{line}"}
-
-      {:error, error} ->
-        {:error, error}
+    with list <- read_file(file),
+         {:ok, content} <- generate_content(file, attrs, list) do
+      build_response(
+        content.file_header,
+        content.details,
+        content.footer,
+        content.filename_info,
+        :ok
+      )
     end
   end
 
   @spec run!(String.t(), Map.t()) :: Map.t() | {:error, String.t()}
   def run!(file, attrs) do
-    list = read_file(file)
+    with list <- read_file(file),
+         {:ok, content} <- generate_content(file, attrs, list) do
+      build_response(
+        content.file_header,
+        content.details,
+        content.footer,
+        content.filename_info,
+        :no
+      )
+    end
+  end
 
-    with {:ok, map} <- classify_by_type(list),
+  defp generate_content(file, attrs, list) do
+    with :ok <- HasIdenticalInformations.run(list),
+         {:ok, map} <- classify_by_type(list),
          {:ok, file_header} <- FileHeader.generate(map.file_header, attrs),
          {:ok, details} <- BuildDetails.run(map.chunks, attrs),
          {:ok, footer} <- FileFooter.generate(map.file_footer, attrs),
          {:ok, filename_info} <- GetFileInfo.run(file, attrs) do
-      build_response(file_header, details, footer, filename_info, :no)
+      {:ok,
+       %{
+         file_header: file_header,
+         details: details,
+         footer: footer,
+         filename_info: filename_info
+       }}
     else
       {:error, error, line_error} ->
         line =

app/excnab/cnab240/services/has_identical_informations.ex

@@ -0,0 +1,24 @@
+defmodule ExCnab.Cnab240.Services.HasIdenticalInformations do
+  @moduledoc """
+  Service to check if the CNAB 240 file has identical informations.
+  """
+
+  @spec run(list) :: :ok | {:error, String.t()}
+  def run(list), do: find_list(list, list, :ok)
+
+  defp find_list(list, [hd | tl], :ok) do
+    index = Enum.find_index(tl, &(&1 == hd))
+
+    currentIndex = Enum.find_index(list, &(&1 == hd))
+
+    case index do
+      nil ->
+        find_list(list, tl, :ok)
+
+      _ ->
+        {:error, "A linha #{currentIndex + 1} está duplicada"}
+    end
+  end
+
+  defp find_list(_list, [], :ok), do: :ok
+end

app/excnab/cnab240/templates/chunk_footer.ex

@@ -35,8 +35,8 @@ defmodule ExCnab.Cnab240.Templates.ChunkFooter do
 
   alias ExCnab.Cnab240.Validator.Details.ChunkFooter, as: ChunkFooterValidator
 
-  @spec generate(String.t()) :: {:ok, Map.t()} | {:error, String.t()}
-  def generate(raw_string) do
+  @spec generate(String.t(), Map.t()) :: {:ok, Map.t()} | {:error, String.t()}
+  def generate(raw_string, builded_details) do
     control_field = control_fields(raw_string)
     total = total_fields(raw_string)
 
@@ -48,7 +48,7 @@ defmodule ExCnab.Cnab240.Templates.ChunkFooter do
       uso_febraban_02: convert_position(raw_string, 66, 230),
       ocorrencias: convert_position(raw_string, 231, 240)
     }
-    |> ChunkFooterValidator.call(raw_string)
+    |> ChunkFooterValidator.call(raw_string, builded_details)
   end
 
   defp control_fields(raw_string) do

app/validators/details/chunk_footer.validator.ex

@@ -3,10 +3,11 @@ defmodule ExCnab.Cnab240.Validator.Details.ChunkFooter do
   An implementation of chain of responsibility to validate the chunk footer.
   """
 
-  @spec call(Map.t(), Map.t()) :: {:ok, Map.t()} | {:error, String.t()}
-  def call(builded_footer, raw_footer) do
+  @spec call(Map.t(), String.t(), Map.t()) :: {:ok, Map.t()} | {:error, String.t()}
+  def call(builded_footer, raw_footer, builded_details) do
     with :ok <- validate_length(raw_footer),
-         :ok <- validate_record_type(builded_footer.controle.registro) do
+         :ok <- validate_record_type(builded_footer.controle.registro),
+         :ok <- validate_value_amount(builded_footer, builded_details) do
       {:ok, builded_footer}
     else
       {:error, reason} ->
@@ -35,4 +36,17 @@ defmodule ExCnab.Cnab240.Validator.Details.ChunkFooter do
         {:error, "Tipo de registro incorreto: #{record_type}, deveria ser #{@record_type}}"}
     end
   end
+
+  defp validate_value_amount(builded_footer, builded_details) do
+    details_value = ExCnab.Cnab240.Services.CalcAmount.run(builded_details)
+    footer_value = String.to_integer(builded_footer.total.valor)
+
+    case details_value == footer_value do
+      true ->
+        :ok
+
+      false ->
+        {:error, "Valor total do lote incorreto: #{footer_value}, deveria ser #{details_value}"}
+    end
+  end
 end

mix.exs

@@ -4,8 +4,8 @@ defmodule ExCnab.MixProject do
   def project do
     [
       app: :ex_cnab,
-      version: "1.3.2",
-      elixir: "~> 1.14",
+      version: "1.3.3",
+      elixir: "~> 1.10",
       elixirc_paths: elixirc_paths(Mix.env()),
       start_permanent: Mix.env() == :prod,
       description: description(),