feat: add sum of debits and credits

Author: Abi-Nf

src/main/java/app/banking/repository/TransactionRepository.java

@@ -1,11 +1,14 @@
 package app.banking.repository;
 
+import app.banking.DTO.AmountOnDate;
 import app.banking.DTO.StateItem;
+import app.banking.DTO.SumDebitsAndCredits;
 import app.banking.models.*;
 import lombok.SneakyThrows;
 import org.springframework.stereotype.Repository;
 import postgres.addict.Queries;
 
+import java.sql.Date;
 import java.sql.ResultSet;
 import java.time.LocalDate;
 import java.util.ArrayList;
@@ -14,6 +17,8 @@
 
 import static app.banking.models.TransactionStatus.CANCELED;
 import static app.banking.models.TransactionStatus.NO_PAYED;
+import static app.banking.models.TransactionType.CREDIT;
+import static app.banking.models.TransactionType.DEBIT;
 
 @Repository
 public class TransactionRepository extends CommonCrud<Transaction, Long> {
@@ -176,4 +181,44 @@ public List<Transaction> findAllByIdAndType(Long accountId, TransactionType filt
       .end()
     );
   }
+
+  private SumDebitsAndCredits mapResultSet(ResultSet resultSet){
+    List<AmountOnDate> incomes = new ArrayList<>();
+    List<AmountOnDate> outcomes = new ArrayList<>();
+
+    try {
+      while (resultSet.next()) {
+        Date date = resultSet.getDate("period_start");
+        double income = resultSet.getDouble("income");
+        double outcome = resultSet.getDouble("expense");
+        incomes.add(AmountOnDate
+          .builder()
+            .iteration(date.toLocalDate())
+            .amount(income)
+          .build());
+        outcomes.add(AmountOnDate
+          .builder()
+            .iteration(date.toLocalDate())
+            .amount(outcome)
+          .build());
+      }
+    }catch (Exception ignored){}
+
+    return SumDebitsAndCredits
+      .builder()
+      .listIncomes(incomes)
+      .listOutComes(outcomes)
+      .build();
+  }
+
+  @SneakyThrows
+  public SumDebitsAndCredits findSumDebitsAndCreditsByAccountId(Long accountId, String sort){
+    Queries queries = Queries
+      .select()
+      .from(Queries.calls("get_income_expense_data_custom_period", sort))
+      .where()
+        .equals("id_account", accountId)
+      .end();
+    return mapResultSet(executeQueries(queries));
+  }
 }