Merge pull request #44 from CapstoneProjectCMC/payment-service

Payment service

Author: boypro5235

payment-service/src/main/java/com/codecampus/payment/controller/PaymentStatisticController.java

@@ -0,0 +1,38 @@
+package com.codecampus.payment.controller;
+
+import com.codecampus.payment.dto.common.ApiResponse;
+import com.codecampus.payment.service.PaymentStatisticService;
+import lombok.RequiredArgsConstructor;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.RestController;
+
+@RestController
+@RequestMapping("/payment-statistics")
+@RequiredArgsConstructor
+public class PaymentStatisticController {
+  private final PaymentStatisticService paymentStatisticService;
+
+  @GetMapping("/daily-deposit")
+  public ApiResponse<?> getDailyDepositSummary(
+      @RequestParam int year, // 2004 < year < curent year
+      @RequestParam int month // 1 <= month <= 12
+  ) {
+    return ApiResponse.builder()
+        .message("Lấy thống kê thành công!")
+        .result(paymentStatisticService.getDailyDepositSummaryByMonth(year, month))
+        .build();
+  }
+
+  @GetMapping("/daily-statistic")
+  public ApiResponse<?> getDailystatisticSummary(
+      @RequestParam int year, // 2004 < year < curent year
+      @RequestParam int month // 1 <= month <= 12
+  ) {
+    return ApiResponse.builder()
+        .message("Lấy thống kê thành công!")
+        .result(paymentStatisticService.getDailyStatisticSummary(year, month))
+        .build();
+  }
+}

payment-service/src/main/java/com/codecampus/payment/dto/response/DailyDepositSummaryResponse.java

@@ -0,0 +1,9 @@
+package com.codecampus.payment.dto.response;
+
+import java.math.BigDecimal;
+import java.time.LocalDate;
+
+public record DailyDepositSummaryResponse (
+    LocalDate day,
+    BigDecimal totalAmount
+) {}

payment-service/src/main/java/com/codecampus/payment/dto/response/DailyStatisticSummaryResponse.java

@@ -0,0 +1,14 @@
+package com.codecampus.payment.dto.response;
+
+import java.math.BigDecimal;
+import java.time.LocalDate;
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+import lombok.Setter;
+
+public record DailyStatisticSummaryResponse(
+    LocalDate day,
+    BigDecimal depositAmount,
+    BigDecimal purchaseAmount,
+    BigDecimal walletBalance
+) {}

payment-service/src/main/java/com/codecampus/payment/exception/ErrorCode.java

@@ -59,6 +59,11 @@ public enum ErrorCode {
   PURCHASED_ITEM(4059103, NOT_ACCEPTABLE.toString(), "Đã mua sản phẩm!",
       BAD_REQUEST),
 
+  // 406 - Input Validation Error
+  MONTH_INVALID(4069101, BAD_REQUEST_STATUS, "Tháng không hợp lệ!", BAD_REQUEST),
+
+  YEAR_INVALID(4069102, BAD_REQUEST_STATUS, "Năm không hợp lệ!", BAD_REQUEST),
+
   // 409 - Conflict
   USER_ALREADY_EXISTS(4099101, CONFLICT_STATUS, "Người dùng đã tồn tại!",
       CONFLICT),

payment-service/src/main/java/com/codecampus/payment/repository/PaymentTransactionRepository.java

@@ -1,10 +1,16 @@
 package com.codecampus.payment.repository;
 
 import com.codecampus.payment.entity.PaymentTransaction;
+import com.codecampus.payment.repository.projection.DailyDepositSummaryProjection;
+import com.codecampus.payment.repository.projection.DailyStatisticSummaryProjection;
+import java.time.Instant;
+import java.util.List;
 import java.util.Optional;
 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.Query;
+import org.springframework.data.repository.query.Param;
 
 public interface PaymentTransactionRepository
     extends JpaRepository<PaymentTransaction, String> {
@@ -15,4 +21,53 @@ Page<PaymentTransaction> findAllByUserIdOrderByCreatedAtDesc(
   boolean existsByReferenceCode(String referenceCode);
 
   Optional<PaymentTransaction> findByReferenceCode(String referenceCode);
+
+  @Query(
+      value = """
+        SELECT 
+            CAST(paid_at AS DATE) AS day,
+            SUM(amount) AS totalAmount
+        FROM payment_transaction
+        WHERE paid_at BETWEEN :startDate AND :endDate
+          AND status = 'SUCCESS'
+          AND type = 0
+        GROUP BY CAST(paid_at AS DATE)
+        ORDER BY CAST(paid_at AS DATE)
+        """,
+      nativeQuery = true
+  )
+  List<DailyDepositSummaryProjection> getDailyDepositSummary(Instant startDate, Instant endDate);
+
+  @Query(value = """
+      WITH opening_balance AS (
+          SELECT COALESCE(SUM(CASE WHEN pt.type = 0 THEN pt.amount ELSE -pt.amount END), 0) AS balance
+          FROM payment_transaction pt
+          WHERE pt.user_id = :userId
+            AND pt.status = 'SUCCESS'
+            AND pt.paid_at < :startDate
+      )
+      SELECT
+          d.day,
+          d.depositAmount,
+          d.purchaseAmount,
+          ob.balance + SUM(d.depositAmount - d.purchaseAmount)
+              OVER (ORDER BY d.day ROWS BETWEEN UNBOUNDED PRECEDING AND CURRENT ROW) AS walletBalance
+      FROM (
+          SELECT
+              CAST(pt.paid_at AS DATE) AS day,
+              SUM(CASE WHEN pt.type = 0 THEN pt.amount ELSE 0 END) AS depositAmount,
+              SUM(CASE WHEN pt.type = 1 THEN pt.amount ELSE 0 END) AS purchaseAmount
+          FROM payment_transaction pt
+          WHERE pt.user_id = :userId
+            AND pt.status = 'SUCCESS'
+            AND pt.paid_at BETWEEN :startDate AND :endDate
+          GROUP BY CAST(pt.paid_at AS DATE)
+      ) d
+      CROSS JOIN opening_balance ob
+      ORDER BY d.day;               
+        """, nativeQuery = true)
+  List<DailyStatisticSummaryProjection> getDailyDepositSummaryByUser(
+      String userId,
+      Instant startDate,
+      Instant endDate);
 }

payment-service/src/main/java/com/codecampus/payment/repository/projection/DailyDepositSummaryProjection.java

@@ -0,0 +1,10 @@
+package com.codecampus.payment.repository.projection;
+
+import java.math.BigDecimal;
+import java.time.LocalDate;
+
+public interface DailyDepositSummaryProjection {
+  LocalDate getDay();
+  BigDecimal getTotalAmount();
+}
+

payment-service/src/main/java/com/codecampus/payment/repository/projection/DailyStatisticSummaryProjection.java

@@ -0,0 +1,12 @@
+package com.codecampus.payment.repository.projection;
+
+import com.codecampus.payment.constant.TransactionEnum;
+import java.math.BigDecimal;
+import java.time.LocalDate;
+
+public interface DailyStatisticSummaryProjection {
+  LocalDate getDay();
+  BigDecimal getDepositAmount();
+  BigDecimal getPurchaseAmount();
+  BigDecimal getWalletBalance();
+}

payment-service/src/main/java/com/codecampus/payment/service/PaymentStatisticService.java

@@ -0,0 +1,78 @@
+package com.codecampus.payment.service;
+
+import com.codecampus.payment.dto.response.DailyDepositSummaryResponse;
+import com.codecampus.payment.dto.response.DailyStatisticSummaryResponse;
+import com.codecampus.payment.exception.AppException;
+import com.codecampus.payment.exception.ErrorCode;
+import com.codecampus.payment.helper.AuthenticationHelper;
+import com.codecampus.payment.repository.PaymentTransactionRepository;
+import java.time.Instant;
+import java.time.LocalDate;
+import java.time.Year;
+import java.time.YearMonth;
+import java.time.ZoneOffset;
+import java.util.List;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Service;
+
+@Service
+@RequiredArgsConstructor
+public class PaymentStatisticService {
+  private final PaymentTransactionRepository paymentTransactionRepository;
+
+  public List<DailyDepositSummaryResponse> getDailyDepositSummaryByMonth(int year, int month) {
+    if (!AuthenticationHelper.getMyRoles().contains("ADMIN")) {
+      throw new AppException(ErrorCode.UNAUTHORIZED);
+    }
+    if (year < 2004 || year > Year.now().getValue() ) {
+      throw new AppException(ErrorCode.YEAR_INVALID);
+    }
+    if (month < 1 || month > 12) {
+      throw new AppException(ErrorCode.MONTH_INVALID);
+    }
+
+
+    YearMonth ym = YearMonth.of(year, month);
+    LocalDate start = ym.atDay(1);
+    LocalDate end = ym.atEndOfMonth();
+
+    Instant startDate = start.atStartOfDay().toInstant(ZoneOffset.UTC);
+    Instant endDate = end.plusDays(1).atStartOfDay().toInstant(ZoneOffset.UTC);
+
+    return paymentTransactionRepository.getDailyDepositSummary(startDate, endDate)
+        .stream()
+        .map(p -> new DailyDepositSummaryResponse(
+            p.getDay(),
+            p.getTotalAmount()
+        ))
+        .toList();
+  }
+
+  public List<DailyStatisticSummaryResponse> getDailyStatisticSummary(int year, int month) {
+    if (year < 2004 || year > Year.now().getValue() ) {
+      throw new AppException(ErrorCode.YEAR_INVALID);
+    }
+    if (month < 1 || month > 12) {
+      throw new AppException(ErrorCode.MONTH_INVALID);
+    }
+    String userId = AuthenticationHelper.getMyUserId();
+
+    YearMonth ym = YearMonth.of(year, month);
+    LocalDate start = ym.atDay(1);
+    LocalDate end = ym.atEndOfMonth();
+
+    Instant startDate = start.atStartOfDay().toInstant(ZoneOffset.UTC);
+    Instant endDate = end.plusDays(1).atStartOfDay().toInstant(ZoneOffset.UTC);
+
+    return paymentTransactionRepository.getDailyDepositSummaryByUser(userId, startDate, endDate)
+        .stream()
+        .map(p -> new DailyStatisticSummaryResponse(
+            p.getDay(),
+            p.getPurchaseAmount(),
+            p.getDepositAmount(),
+            p.getWalletBalance()
+        ))
+        .toList();
+  }
+
+}