src/main/java/com/faf223/expensetrackerfaf/controller/ExpenseController.java

@@ -2,6 +2,7 @@ package com.faf223.expensetrackerfaf.controller;
 
 import com.faf223.expensetrackerfaf.dto.ExpenseCreationDTO;
 import com.faf223.expensetrackerfaf.dto.ExpenseDTO;
+import com.faf223.expensetrackerfaf.dto.IncomeDTO;
 import com.faf223.expensetrackerfaf.dto.mappers.ExpenseMapper;
 import com.faf223.expensetrackerfaf.model.Expense;
 import com.faf223.expensetrackerfaf.model.ExpenseCategory;
@@ -97,24 +98,34 @@ public class ExpenseController {
 
     @GetMapping("/personal-expenses")
     public ResponseEntity<List<ExpenseDTO>> getExpensesByUser(@RequestParam Optional<LocalDate> date,
-                                                              @RequestParam Optional<Month> month) {
+                                                              @RequestParam Optional<Month> month,
+                                                              @RequestParam Optional<Integer> startYear,
+                                                              @RequestParam Optional<Integer> endYear,
+                                                              @RequestParam Optional<String> lastUnit) {
 
         Authentication authentication = SecurityContextHolder.getContext().getAuthentication();
 
         if (authentication != null && authentication.getPrincipal() instanceof UserDetails userDetails) {
 
             String email = userDetails.getUsername();
-            List<ExpenseDTO> expenses;
+            List<ExpenseDTO> expenses = Collections.emptyList();
 
-            expenses = date.map(localDate -> expenseService.getTransactionsByDate(localDate, email).stream().map(expenseMapper::toDto).toList())
+            if(date.isPresent())
-                    .orElseGet(() -> month.map(value -> expenseService.getTransactionsByMonth(value, email).stream().map(expenseMapper::toDto).toList())
+                expenses = expenseService.getTransactionsByDate(date.get(), email).stream().map(expenseMapper::toDto).toList();
-                            .orElseGet(() -> expenseService.getTransactionsByEmail(email).stream().map(expenseMapper::toDto).toList()));
+            else if(month.isPresent())
+                expenses = expenseService.getTransactionsByMonth(month.get(), email).stream().map(expenseMapper::toDto).toList();
+            else if(startYear.isPresent() && endYear.isPresent())
+                expenses = expenseService.getYearIntervalTransactions(email, startYear.get(), endYear.get()).stream().map(expenseMapper::toDto).toList();
+            else if(lastUnit.isPresent()) {
+
+                if(lastUnit.get().equalsIgnoreCase("week"))
+                    expenses = expenseService.getLastWeekTransactions(email).stream().map(expenseMapper::toDto).toList();
+                else if(lastUnit.get().equalsIgnoreCase("month"))
+                    expenses = expenseService.getLastMonthTransactions(email).stream().map(expenseMapper::toDto).toList();
 
-            if (!expenses.isEmpty()) {
-                return ResponseEntity.ok(expenses);
-            } else {
-                return ResponseEntity.ok(Collections.emptyList());
             }
+
+            return ResponseEntity.ok(expenses);
         }
 
         throw new TransactionsNotFoundException("The expenses have not been found");

src/main/java/com/faf223/expensetrackerfaf/controller/IncomeController.java

@@ -97,24 +97,34 @@ public class IncomeController {
 
     @GetMapping("/personal-incomes")
     public ResponseEntity<List<IncomeDTO>> getExpensesByUser(@RequestParam Optional<LocalDate> date,
-                                                              @RequestParam Optional<Month> month) {
+                                                             @RequestParam Optional<Month> month,
+                                                             @RequestParam Optional<Integer> startYear,
+                                                             @RequestParam Optional<Integer> endYear,
+                                                             @RequestParam Optional<String> lastUnit) {
 
         Authentication authentication = SecurityContextHolder.getContext().getAuthentication();
 
         if (authentication != null && authentication.getPrincipal() instanceof UserDetails userDetails) {
 
             String email = userDetails.getUsername();
-            List<IncomeDTO> incomes;
+            List<IncomeDTO> incomes = Collections.emptyList();
 
-            incomes = date.map(localDate -> incomeService.getTransactionsByDate(localDate, email).stream().map(incomeMapper::toDto).toList())
+            if(date.isPresent())
-                    .orElseGet(() -> month.map(value -> incomeService.getTransactionsByMonth(value, email).stream().map(incomeMapper::toDto).toList())
+                incomes = incomeService.getTransactionsByDate(date.get(), email).stream().map(incomeMapper::toDto).toList();
-                            .orElseGet(() -> incomeService.getTransactionsByEmail(email).stream().map(incomeMapper::toDto).toList()));
+            else if(month.isPresent())
+                incomes = incomeService.getTransactionsByMonth(month.get(), email).stream().map(incomeMapper::toDto).toList();
+            else if(startYear.isPresent() && endYear.isPresent())
+                incomes = incomeService.getYearIntervalTransactions(email, startYear.get(), endYear.get()).stream().map(incomeMapper::toDto).toList();
+            else if(lastUnit.isPresent()) {
+
+                if(lastUnit.get().equalsIgnoreCase("week"))
+                    incomes = incomeService.getLastWeekTransactions(email).stream().map(incomeMapper::toDto).toList();
+                else if(lastUnit.get().equalsIgnoreCase("month"))
+                    incomes = incomeService.getLastMonthTransactions(email).stream().map(incomeMapper::toDto).toList();
 
-            if (!incomes.isEmpty()) {
-                return ResponseEntity.ok(incomes);
-            } else {
-                return ResponseEntity.ok(Collections.emptyList());
             }
+
+            return ResponseEntity.ok(incomes);
         }
 
         throw new TransactionsNotFoundException("The expenses have not been found");

src/main/java/com/faf223/expensetrackerfaf/repository/ExpenseRepository.java

@@ -3,6 +3,7 @@ package com.faf223.expensetrackerfaf.repository;
 import com.faf223.expensetrackerfaf.model.Expense;
 import com.faf223.expensetrackerfaf.model.User;
 import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.query.Procedure;
 import org.springframework.stereotype.Repository;
 
 import java.time.LocalDate;
@@ -14,4 +15,16 @@ public interface ExpenseRepository extends JpaRepository<Expense, Long> {
     List<Expense> findByDate(LocalDate date);
 
     List<Expense> findByDateBetween(LocalDate start, LocalDate end);
+
+    @Procedure(procedureName = "get_expenses_by_month")
+    List<Expense> filterByMonth(int month);
+
+    @Procedure(procedureName = "get_last_week_expenses")
+    List<Expense> findLastWeek();
+
+    @Procedure(procedureName = "get_last_month_expenses")
+    List<Expense> findLastMonth();
+
+    @Procedure(procedureName = "get_expenses_by_year_interval")
+    List<Expense> filterByYearInterval(int start, int end);
 }

src/main/java/com/faf223/expensetrackerfaf/repository/IncomeRepository.java

@@ -3,6 +3,7 @@ package com.faf223.expensetrackerfaf.repository;
 import com.faf223.expensetrackerfaf.model.Income;
 import com.faf223.expensetrackerfaf.model.User;
 import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.query.Procedure;
 import org.springframework.stereotype.Repository;
 
 import java.time.LocalDate;
@@ -14,4 +15,16 @@ public interface IncomeRepository extends JpaRepository<Income, Long> {
     List<Income> findByDate(LocalDate date);
 
     List<Income> findByDateBetween(LocalDate start, LocalDate end);
+
+    @Procedure(procedureName = "get_incomes_by_month")
+    List<Income> filterByMonth(int month);
+
+    @Procedure(procedureName = "get_last_week_incomes")
+    List<Income> findLastWeek();
+
+    @Procedure(procedureName = "get_last_month_incomes")
+    List<Income> findLastMonth();
+
+    @Procedure(procedureName = "get_incomes_by_year_interval")
+    List<Income> filterByYearInterval(int start, int end);
 }

src/main/java/com/faf223/expensetrackerfaf/service/CredentialService.java

@@ -0,0 +1,18 @@
+package com.faf223.expensetrackerfaf.service;
+
+import com.faf223.expensetrackerfaf.model.Credential;
+import com.faf223.expensetrackerfaf.repository.CredentialRepository;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Service;
+
+@Service
+@RequiredArgsConstructor
+public class CredentialService {
+
+    private final CredentialRepository credentialRepository;
+
+    public Credential findByEmail(String email) {
+        return credentialRepository.findByEmail(email).orElse(null);
+    }
+
+}

src/main/java/com/faf223/expensetrackerfaf/service/ExpenseService.java

@@ -4,6 +4,7 @@ import com.faf223.expensetrackerfaf.model.*;
 import com.faf223.expensetrackerfaf.repository.CredentialRepository;
 import com.faf223.expensetrackerfaf.repository.ExpenseRepository;
 import com.faf223.expensetrackerfaf.repository.UserRepository;
+import com.faf223.expensetrackerfaf.util.TransactionFilter;
 import com.faf223.expensetrackerfaf.util.exceptions.UserNotAuthenticatedException;
 import com.faf223.expensetrackerfaf.util.exceptions.UserNotFoundException;
 import lombok.RequiredArgsConstructor;
@@ -25,6 +26,7 @@ public class ExpenseService implements ITransactionService {
     private final ExpenseRepository expenseRepository;
     private final CredentialRepository credentialRepository;
     private final UserRepository userRepository;
+    private final TransactionFilter transactionFilter;
 
     public void createOrUpdate(IMoneyTransaction expense) {
         expenseRepository.save((Expense) expense);
@@ -47,37 +49,47 @@ public class ExpenseService implements ITransactionService {
 
     @Override
     public List<Expense> getTransactionsByDate(LocalDate date, String email) {
-        return getTransactionsByDate(date)
+        return (List<Expense>) transactionFilter.filterByEmail(getTransactionsByDate(date), email);
-                .stream()
-                .filter(transaction -> {
-                    Optional<Credential> credential = credentialRepository.findByEmail(email);
-                    if(credential.isEmpty())
-                        throw new UserNotFoundException("The user has not been found");
-                    return credential.get().getUser().equals(transaction.getUser());
-                })
-                .toList();
     }
 
-    // TODO: store transaction month in a separate field in the DB and change this logic
     @Override
     public List<Expense> getTransactionsByMonth(Month month) {
-        LocalDate startOfMonth = LocalDate.of(LocalDate.now().getYear(), month, 1);
+        return expenseRepository.filterByMonth(month.getValue());
-        LocalDate endOfMonth = startOfMonth.plusMonths(1).minusDays(1);
-
-        return expenseRepository.findByDateBetween(startOfMonth, endOfMonth);
     }
 
     @Override
     public List<Expense> getTransactionsByMonth(Month month, String email) {
-        return getTransactionsByMonth(month)
+        return (List<Expense>) transactionFilter.filterByEmail(getTransactionsByMonth(month), email);
-                .stream()
+    }
-                .filter(transaction -> {
+
-                    Optional<Credential> credential = credentialRepository.findByEmail(email);
+    @Override
-                    if(credential.isEmpty())
+    public List<Expense> getLastWeekTransactions() {
-                        throw new UserNotFoundException("The user has not been found");
+        return expenseRepository.findLastWeek();
-                    return credential.get().getUser().equals(transaction.getUser());
+    }
-                })
+
-                .toList();
+    @Override
+    public List<Expense> getLastWeekTransactions(String email) {
+        return (List<Expense>) transactionFilter.filterByEmail(getLastWeekTransactions(), email);
+    }
+
+    @Override
+    public List<Expense> getLastMonthTransactions() {
+        return expenseRepository.findLastMonth();
+    }
+
+    @Override
+    public List<Expense> getLastMonthTransactions(String email) {
+        return (List<Expense>) transactionFilter.filterByEmail(getLastMonthTransactions(), email);
+    }
+
+    @Override
+    public List<Expense> getYearIntervalTransactions(int start, int end) {
+        return expenseRepository.filterByYearInterval(start, end);
+    }
+
+    @Override
+    public List<Expense> getYearIntervalTransactions(String email, int start, int end) {
+        return (List<Expense>) transactionFilter.filterByEmail(getYearIntervalTransactions(start, end), email);
     }
 
     public List<Expense> getTransactions() {
@@ -113,4 +125,5 @@ public class ExpenseService implements ITransactionService {
 
         throw new UserNotAuthenticatedException("You are not authenticated");
     }
+
 }

src/main/java/com/faf223/expensetrackerfaf/service/ITransactionService.java

@@ -17,6 +17,12 @@ public interface ITransactionService {
     List<? extends IMoneyTransaction> getTransactionsByDate(LocalDate date, String email);
     List<? extends IMoneyTransaction> getTransactionsByMonth(Month month);
     List<? extends IMoneyTransaction> getTransactionsByMonth(Month month, String email);
+    List<? extends IMoneyTransaction> getLastWeekTransactions();
+    List<? extends IMoneyTransaction> getLastWeekTransactions(String email);
+    List<? extends IMoneyTransaction> getLastMonthTransactions();
+    List<? extends IMoneyTransaction> getLastMonthTransactions(String email);
+    List<? extends IMoneyTransaction> getYearIntervalTransactions(int start, int end);
+    List<? extends IMoneyTransaction> getYearIntervalTransactions(String email, int start, int end);
     IMoneyTransaction getTransactionById(long id);
     void deleteTransactionById(long it);
     boolean belongsToUser(IMoneyTransaction transaction);

src/main/java/com/faf223/expensetrackerfaf/service/IncomeService.java

@@ -7,6 +7,7 @@ import com.faf223.expensetrackerfaf.model.User;
 import com.faf223.expensetrackerfaf.repository.CredentialRepository;
 import com.faf223.expensetrackerfaf.repository.IncomeRepository;
 import com.faf223.expensetrackerfaf.repository.UserRepository;
+import com.faf223.expensetrackerfaf.util.TransactionFilter;
 import com.faf223.expensetrackerfaf.util.exceptions.UserNotAuthenticatedException;
 import com.faf223.expensetrackerfaf.util.exceptions.UserNotFoundException;
 import lombok.RequiredArgsConstructor;
@@ -28,6 +29,7 @@ public class IncomeService implements ITransactionService {
     private final IncomeRepository incomeRepository;
     private final CredentialRepository credentialRepository;
     private final UserRepository userRepository;
+    private final TransactionFilter transactionFilter;
 
     public void createOrUpdate(IMoneyTransaction income) {
         incomeRepository.save((Income) income);
@@ -65,13 +67,9 @@ public class IncomeService implements ITransactionService {
                 .toList();
     }
 
-    // TODO: store transaction month in a separate field in the DB and change this logic
     @Override
     public List<Income> getTransactionsByMonth(Month month) {
-        LocalDate startOfMonth = LocalDate.of(LocalDate.now().getYear(), month, 1);
+        return incomeRepository.filterByMonth(month.getValue());
-        LocalDate endOfMonth = startOfMonth.plusMonths(1).minusDays(1);
-
-        return incomeRepository.findByDateBetween(startOfMonth, endOfMonth);
     }
 
     @Override
@@ -87,6 +85,36 @@ public class IncomeService implements ITransactionService {
                 .toList();
     }
 
+    @Override
+    public List<Income> getLastWeekTransactions() {
+        return incomeRepository.findLastWeek();
+    }
+
+    @Override
+    public List<Income> getLastWeekTransactions(String email) {
+        return (List<Income>) transactionFilter.filterByEmail(getLastWeekTransactions(), email);
+    }
+
+    @Override
+    public List<Income> getLastMonthTransactions() {
+        return incomeRepository.findLastMonth();
+    }
+
+    @Override
+    public List<Income> getLastMonthTransactions(String email) {
+        return (List<Income>) transactionFilter.filterByEmail(getLastMonthTransactions(), email);
+    }
+
+    @Override
+    public List<Income> getYearIntervalTransactions(int start, int end) {
+        return incomeRepository.filterByYearInterval(start, end);
+    }
+
+    @Override
+    public List<Income> getYearIntervalTransactions(String email, int start, int end) {
+        return (List<Income>) transactionFilter.filterByEmail(getYearIntervalTransactions(start, end), email);
+    }
+
     public Income getTransactionById(long id) {
         return incomeRepository.findById(id).orElse(null);
     }

src/main/java/com/faf223/expensetrackerfaf/util/TransactionFilter.java

@@ -0,0 +1,30 @@
+package com.faf223.expensetrackerfaf.util;
+
+import com.faf223.expensetrackerfaf.model.Credential;
+import com.faf223.expensetrackerfaf.model.IMoneyTransaction;
+import com.faf223.expensetrackerfaf.service.CredentialService;
+import com.faf223.expensetrackerfaf.util.exceptions.UserNotFoundException;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Component;
+
+import java.util.List;
+
+@Component
+@RequiredArgsConstructor
+public class TransactionFilter {
+
+    private final CredentialService credentialService;
+
+    public List<? extends IMoneyTransaction> filterByEmail(List<? extends IMoneyTransaction> transactions, String email) {
+        return transactions
+                .stream()
+                .filter(transaction -> {
+                    Credential credential = credentialService.findByEmail(email);
+                    if(credential == null)
+                        throw new UserNotFoundException("The user has not been found");
+                    return credential.getUser().equals(transaction.getUser());
+                })
+                .toList();
+    }
+
+}