search by specification

src/main/java/com/fjb/sunrise/controllers/TransactionController.java

@@ -5,6 +5,7 @@
 
 import com.fjb.sunrise.dtos.base.DataTableInputDTO;
 import com.fjb.sunrise.dtos.requests.CreateOrUpdateTransactionRequest;
+import com.fjb.sunrise.dtos.responses.StatisticResponse;
 import com.fjb.sunrise.dtos.responses.TransactionFullPageResponse;
 import com.fjb.sunrise.mappers.TransactionMapper;
 import com.fjb.sunrise.models.Transaction;
@@ -74,6 +75,12 @@ public String postUpdate(@PathVariable Long id,
         throws ParseException {
         request.setId(id);
         transactionService.update(request);
-        return "redirect:transnsaction/create";
+        return "redirect:/transaction/create";
+    }
+
+    @GetMapping("/statistic")
+    @ResponseBody
+    public StatisticResponse getStatistic() {
+        return transactionService.statistic();
     }
 }

src/main/java/com/fjb/sunrise/dtos/base/CategoryAndTotalAmountPerCategory.java

@@ -0,0 +1,20 @@
+package com.fjb.sunrise.dtos.base;
+
+import java.io.Serializable;
+import lombok.Getter;
+import lombok.Setter;
+
+@Getter
+@Setter
+public class CategoryAndTotalAmountPerCategory implements Serializable {
+    private String category;
+    private Double totalAmountPerCategory;
+
+    public CategoryAndTotalAmountPerCategory() {
+    }
+
+    public CategoryAndTotalAmountPerCategory(String category, Double totalAmountPerCategory) {
+        this.category = category;
+        this.totalAmountPerCategory = totalAmountPerCategory;
+    }
+}

src/main/java/com/fjb/sunrise/dtos/base/CategoryAndTotalAmountPerCategoryForChart.java

@@ -0,0 +1,20 @@
+package com.fjb.sunrise.dtos.base;
+
+import java.io.Serializable;
+import lombok.Getter;
+import lombok.Setter;
+
+@Getter
+@Setter
+public class CategoryAndTotalAmountPerCategoryForChart implements Serializable {
+    private String category;
+    private String totalAmountPerCategory;
+
+    public CategoryAndTotalAmountPerCategoryForChart() {
+    }
+
+    public CategoryAndTotalAmountPerCategoryForChart(String category, String totalAmountPerCategory) {
+        this.category = category;
+        this.totalAmountPerCategory = totalAmountPerCategory;
+    }
+}

src/main/java/com/fjb/sunrise/dtos/base/DayAndTotalAmountPerDay.java

@@ -0,0 +1,25 @@
+package com.fjb.sunrise.dtos.base;
+
+import java.io.Serializable;
+import java.time.LocalDateTime;
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.Getter;
+import lombok.Setter;
+import lombok.ToString;
+
+@Getter
+@Setter
+@ToString
+public class DayAndTotalAmountPerDay implements Serializable {
+    private LocalDateTime day;
+    private Double amountPerDay;
+
+    public DayAndTotalAmountPerDay() {
+    }
+
+    public DayAndTotalAmountPerDay(LocalDateTime day, Double amountPerDay) {
+        this.day = day;
+        this.amountPerDay = amountPerDay;
+    }
+}

src/main/java/com/fjb/sunrise/dtos/base/DayAndTotalAmountPerDayForChart.java

@@ -0,0 +1,17 @@
+package com.fjb.sunrise.dtos.base;
+
+import java.io.Serializable;
+import java.time.LocalDateTime;
+
+public class DayAndTotalAmountPerDayForChart implements Serializable {
+    private String day;
+    private String amountPerDay;
+
+    public DayAndTotalAmountPerDayForChart() {
+    }
+
+    public DayAndTotalAmountPerDayForChart(String day, String amountPerDay) {
+        this.day = day;
+        this.amountPerDay = amountPerDay;
+    }
+}

src/main/java/com/fjb/sunrise/dtos/responses/StatisticResponse.java

@@ -0,0 +1,17 @@
+package com.fjb.sunrise.dtos.responses;
+
+import com.fjb.sunrise.dtos.base.DayAndTotalAmountPerDay;
+import com.fjb.sunrise.dtos.base.DayAndTotalAmountPerDayForChart;
+import java.io.Serializable;
+import java.util.List;
+import java.util.Map;
+import lombok.Data;
+
+@Data
+public class StatisticResponse implements Serializable {
+    private List<DayAndTotalAmountPerDayForChart> totalIn3Month;
+    private String totalThisYear;
+    private String totalInputThisYear;
+    private String totalThisMonth;
+    private List<?> totalThisMonthByCategory;
+}

src/main/java/com/fjb/sunrise/repositories/CategoryRepository.java

@@ -4,7 +4,9 @@
 import org.springframework.data.domain.Page;
 import org.springframework.data.domain.Pageable;
 import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.JpaSpecificationExecutor;
 
-public interface CategoryRepository extends JpaRepository<Category, Long> {
+
+public interface CategoryRepository extends JpaRepository<Category, Long>, JpaSpecificationExecutor<Category> {
     Page<Category> findAll(Pageable pageable);
 }

src/main/java/com/fjb/sunrise/repositories/TransactionRepository.java

@@ -1,10 +1,36 @@
 package com.fjb.sunrise.repositories;
 
+import com.fjb.sunrise.dtos.base.CategoryAndTotalAmountPerCategory;
+import com.fjb.sunrise.dtos.base.DayAndTotalAmountPerDay;
+import com.fjb.sunrise.enums.ETrans;
 import com.fjb.sunrise.models.Transaction;
+import java.time.LocalDateTime;
+import java.util.List;
 import org.springframework.data.domain.Page;
 import org.springframework.data.domain.Pageable;
 import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.JpaSpecificationExecutor;
+import org.springframework.data.jpa.repository.Query;
+
+public interface TransactionRepository extends JpaRepository<Transaction, Long>,
+    JpaSpecificationExecutor<Transaction> {
 
-public interface TransactionRepository extends JpaRepository<Transaction, Long> {
     Page<Transaction> findAll(Pageable pageable);
+
+    @Query("select sum(t.amount) from Transaction t "
+        + "where t.updatedAt between ?1 and ?2")
+    Double sumAmountInRange(LocalDateTime start, LocalDateTime end);
+
+    @Query("select new com.fjb.sunrise.dtos.base.DayAndTotalAmountPerDay(t.updatedAt,sum(t.amount)) from Transaction t"
+        + " where t.updatedAt between ?1 and ?2 group by t.updatedAt")
+    List<DayAndTotalAmountPerDay> sumAmountPerDayIn3Month(LocalDateTime start, LocalDateTime endOf3Month);
+
+    @Query("select sum(t.amount) from Transaction t "
+        + "where t.transactionType = ?1 and t.updatedAt between ?2 and ?3 ")
+    Double sumTransactionTypeINInThisYear(ETrans transactionType, LocalDateTime start, LocalDateTime end);
+
+    @Query("select new com.fjb.sunrise.dtos.base.CategoryAndTotalAmountPerCategory(t.category.name,sum(t.amount)) "
+        + "from Transaction t "
+        + "group by t.category order by sum(t.amount) desc limit 4")
+    List<CategoryAndTotalAmountPerCategory> sumAmountPerCategory();
 }

src/main/java/com/fjb/sunrise/services/CategoryService.java

@@ -22,5 +22,9 @@ public interface CategoryService {
 
     List<CategoryResponseDto> getAllCategories();
 
+
+    List<Category> findAllByUser();
+
     Page<Category> getCategoryList(DataTableInputDTO payload);
+
 }

src/main/java/com/fjb/sunrise/services/TransactionService.java

@@ -2,6 +2,7 @@
 
 import com.fjb.sunrise.dtos.base.DataTableInputDTO;
 import com.fjb.sunrise.dtos.requests.CreateOrUpdateTransactionRequest;
+import com.fjb.sunrise.dtos.responses.StatisticResponse;
 import com.fjb.sunrise.models.Transaction;
 import java.text.ParseException;
 import org.springframework.data.domain.Page;
@@ -16,4 +17,6 @@ public interface TransactionService {
     Page<Transaction> getTransactionList(DataTableInputDTO payload);
 
     Transaction update(CreateOrUpdateTransactionRequest request) throws ParseException;
+
+    StatisticResponse statistic();
 }

src/main/java/com/fjb/sunrise/services/impl/CategoryServiceImpl.java

@@ -88,4 +88,17 @@ public List<CategoryResponseDto> getAllCategories() {
             .stream().map(categoryMapper::toCategoryResponseDto)
             .toList();
     }
+
+    @Override
+    public List<Category> findAllByUser() {
+        //        Specification specs = Specification.where(
+        //            ((root, query, builder) -> {
+        //                builder.equal(root.get("createdBy"),
+        //                    "ADMIN")
+        //            })
+        //        );
+        return List.of();
+    }
+
+
 }