Feature/hodadako step2

build.gradle

@@ -32,6 +32,7 @@ dependencies {
     implementation 'org.springframework.retry:spring-retry'
     implementation 'org.apache.commons:commons-lang3:3.13.0'
     implementation 'org.apache.commons:commons-collections4:4.4'
+    implementation 'com.mysql:mysql-connector-j'
     compileOnly 'org.projectlombok:lombok'
     annotationProcessor 'org.projectlombok:lombok'
     testImplementation 'org.springframework.boot:spring-boot-starter-test'

src/main/java/org/c4marathon/assignment/domain/email_record/dto/EmailRecordRequest.java → src/main/java/org/c4marathon/assignment/domain/email_record/dto/SaveEmailRecordRequest.java

@@ -8,19 +8,17 @@
 import jakarta.validation.constraints.Positive;
 import jakarta.validation.constraints.Size;
 
-public class EmailRecordRequest {
-	public record Save(
-		@NotNull
-		@Positive
-		Long memberId,
-		@NotBlank
-		String content,
-		@NotBlank
-		@Size(max = 50)
-		String subject
-	) {
-		public EmailRecord toEntity(Member member) {
-			return new EmailRecord(member, this.content, this.subject);
-		}
+public record SaveEmailRecordRequest(
+	@NotNull
+	@Positive
+	Long memberId,
+	@NotBlank
+	String content,
+	@NotBlank
+	@Size(max = 50)
+	String subject
+) {
+	public EmailRecord toEntity(Member member) {
+		return new EmailRecord(member, this.content, this.subject);
 	}
 }

src/main/java/org/c4marathon/assignment/domain/email_record/presentation/EmailRecordController.java

@@ -2,7 +2,7 @@
 
 import java.net.URI;
 
-import org.c4marathon.assignment.domain.email_record.dto.EmailRecordRequest;
+import org.c4marathon.assignment.domain.email_record.dto.SaveEmailRecordRequest;
 import org.c4marathon.assignment.domain.email_record.entity.EmailRecord;
 import org.c4marathon.assignment.domain.email_record.service.EmailRecordService;
 import org.springframework.beans.factory.annotation.Value;
@@ -25,7 +25,7 @@ public class EmailRecordController {
 	private String baseUrl;
 
 	@PostMapping("/v1/email-records")
-	public ResponseEntity<EmailRecord> saveEmailRecord(@Valid EmailRecordRequest.Save request) {
+	public ResponseEntity<EmailRecord> saveEmailRecord(@Valid SaveEmailRecordRequest request) {
 		EmailRecord saved = emailRecordService.save(request);
 		URI uri = UriComponentsBuilder.fromUriString(baseUrl + saved.getId())
 			.build()

src/main/java/org/c4marathon/assignment/domain/email_record/repository/EmailRecordRepository.java

@@ -19,7 +19,7 @@ public interface EmailRecordRepository extends JpaRepository<EmailRecord, Long>
 		"""
 			SELECT new org.c4marathon.assignment.domain.email_record.query.EmailRecordQueryResult(er.id, er.member.email, er.subject, er.content) 
 			FROM EmailRecord er 
-			LEFT JOIN FETCH er.member
+			LEFT JOIN er.member
 			WHERE er.emailStatus =:status
 			ORDER BY er.id ASC
 			""")

src/main/java/org/c4marathon/assignment/domain/email_record/service/EmailRecordService.java

@@ -2,11 +2,7 @@
 
 import static org.c4marathon.assignment.common.configuration.AsyncConfig.*;
 
-import java.util.concurrent.CompletableFuture;
-import java.util.concurrent.ExecutionException;
-import java.util.concurrent.Future;
-
-import org.c4marathon.assignment.domain.email_record.dto.EmailRecordRequest;
+import org.c4marathon.assignment.domain.email_record.dto.SaveEmailRecordRequest;
 import org.c4marathon.assignment.domain.email_record.entity.EmailRecord;
 import org.c4marathon.assignment.domain.email_record.event.EmailRecordEvent;
 import org.c4marathon.assignment.domain.email_record.query.EmailRecordQueryResult;
@@ -30,7 +26,7 @@ public class EmailRecordService {
 	private final ApplicationEventPublisher eventPublisher;
 
 	@Transactional
-	public EmailRecord save(EmailRecordRequest.Save request) {
+	public EmailRecord save(SaveEmailRecordRequest request) {
 		var member = memberReader.find(request.memberId());
 		return emailRecordStore.store(request.toEntity(member));
 	}

src/main/java/org/c4marathon/assignment/domain/transaction/entity/Transaction.java

@@ -0,0 +1,69 @@
+package org.c4marathon.assignment.domain.transaction.entity;
+
+import java.time.LocalDateTime;
+import java.util.Objects;
+
+import org.c4marathon.assignment.common.entity.BaseEntity;
+import org.hibernate.annotations.ColumnDefault;
+
+import jakarta.persistence.Column;
+import jakarta.persistence.Entity;
+import jakarta.persistence.GeneratedValue;
+import jakarta.persistence.GenerationType;
+import jakarta.persistence.Id;
+import jakarta.persistence.Table;
+import lombok.AccessLevel;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+
+@Entity
+@Table(name = "transaction", indexes = {})
+@Getter
+@NoArgsConstructor(access = AccessLevel.PROTECTED)
+public class Transaction {
+	@Id
+	@GeneratedValue(strategy = GenerationType.IDENTITY)
+	@Column(name = "transaction_id") // 여기서 컬럼명을 "transaction_id"로 변경
+	private Integer id;
+
+	@Column(name = "sender_account", columnDefinition = "varchar(20)", nullable = false)
+	private String senderAccount;
+
+	@Column(name = "receiver_account", columnDefinition = "varchar(20)", nullable = false)
+	private String receiverAccount;
+
+	@Column(name = "sender_swift_code", columnDefinition = "varchar(11)", nullable = false)
+	private String senderSwiftCode;
+
+	@Column(name = "receiver_swift_code", columnDefinition = "varchar(11)", nullable = false)
+	private String receiverSwiftCode;
+
+	@Column(name = "sender_name", columnDefinition = "varchar(30)", nullable = false)
+	private String senderName;
+
+	@Column(name = "receiver_name", columnDefinition = "varchar(30)", nullable = false)
+	private String receiverName;
+
+	@Column(name = "amount", nullable = false)
+	private Long amount;
+
+	@Column(name = "memo", columnDefinition = "varchar(200)")
+	private String memo;
+
+	@ColumnDefault("CURRENT_TIMESTAMP")
+	@Column(name = "transaction_date", nullable = false)
+	private LocalDateTime transactionDate;
+
+	@Override
+	public boolean equals(Object o) {
+		if (o instanceof Transaction t) {
+			return this.getId() == t.getId();
+		}
+		return false;
+	}
+
+	@Override
+	public int hashCode() {
+		return Objects.hash(this);
+	}
+}

src/main/java/org/c4marathon/assignment/domain/transaction/entity/TransactionType.java

@@ -0,0 +1,5 @@
+package org.c4marathon.assignment.domain.transaction.entity;
+
+public enum TransactionType {
+	TRANSFER
+}

src/main/java/org/c4marathon/assignment/domain/transaction/repository/TransactionReader.java

@@ -0,0 +1,19 @@
+package org.c4marathon.assignment.domain.transaction.repository;
+
+import java.time.LocalDate;
+import java.util.stream.Stream;
+
+import org.c4marathon.assignment.domain.transfer_statistics.entity.TransferStatistics;
+import org.springframework.stereotype.Component;
+
+import lombok.RequiredArgsConstructor;
+
+@Component
+@RequiredArgsConstructor
+public class TransactionReader {
+	private final TransactionRepository transactionRepository;
+
+	public Stream<TransferStatistics> findTransferStatisticsBetweeen(LocalDate from, LocalDate to) {
+		return transactionRepository.findTransactionBetween(from, to);
+	}
+}

src/main/java/org/c4marathon/assignment/domain/transaction/repository/TransactionRepository.java

@@ -0,0 +1,24 @@
+package org.c4marathon.assignment.domain.transaction.repository;
+
+import java.time.LocalDate;
+import java.util.stream.Stream;
+
+import org.c4marathon.assignment.domain.transaction.entity.Transaction;
+import org.c4marathon.assignment.domain.transfer_statistics.entity.TransferStatistics;
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.Query;
+import org.springframework.data.repository.query.Param;
+
+public interface TransactionRepository extends JpaRepository<Transaction, Long> {
+	@Query(
+		"""
+			SELECT new TransferStatistics(SUM(t.amount), 
+			SUM(SUM(t.amount)) OVER (ORDER BY DATE(t.transactionDate)), t.transactionDate) 
+			FROM Transaction t
+			WHERE t.transactionDate BETWEEN :startDate AND :endDate
+			GROUP BY t.transactionDate
+			ORDER BY t.transactionDate DESC
+			""")
+	Stream<TransferStatistics> findTransactionBetween(@Param("startDate") LocalDate startDate,
+		@Param("endDate") LocalDate endDate);
+}

src/main/java/org/c4marathon/assignment/domain/transfer_statistics/dto/AggregateTransferStatisticsRequest.java

@@ -0,0 +1,13 @@
+package org.c4marathon.assignment.domain.transfer_statistics.dto;
+
+import java.time.LocalDateTime;
+
+import jakarta.validation.constraints.NotBlank;
+import jakarta.validation.constraints.PastOrPresent;
+
+public record AggregateTransferStatisticsRequest(
+	@NotBlank
+	@PastOrPresent
+	LocalDateTime targetDate
+) {
+}

src/main/java/org/c4marathon/assignment/domain/transfer_statistics/dto/GetAllTransferStatisticsRequest.java

@@ -0,0 +1,21 @@
+package org.c4marathon.assignment.domain.transfer_statistics.dto;
+
+import java.time.LocalDate;
+
+import jakarta.validation.constraints.AssertTrue;
+import jakarta.validation.constraints.NotBlank;
+import jakarta.validation.constraints.Past;
+
+public record GetAllTransferStatisticsRequest(
+	@NotBlank
+	@Past
+	LocalDate startDate,
+	@NotBlank
+	@Past
+	LocalDate endDate
+) {
+	@AssertTrue(message = "시작 날짜는 종료 날짜보다 이전이어야 합니다.")
+	public boolean isStartDateBeforeEndDate() {
+		return startDate.isBefore(endDate);
+	}
+}

src/main/java/org/c4marathon/assignment/domain/transfer_statistics/entity/TransferStatistics.java

@@ -0,0 +1,47 @@
+package org.c4marathon.assignment.domain.transfer_statistics.entity;
+
+import java.time.LocalDateTime;
+import java.util.Objects;
+
+import org.c4marathon.assignment.common.entity.BaseEntity;
+
+import jakarta.persistence.Column;
+import jakarta.persistence.Entity;
+import jakarta.persistence.Table;
+import lombok.AccessLevel;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+
+@Entity
+@Table(name = "transfer_statistics_hodadako")
+@Getter
+@NoArgsConstructor(access = AccessLevel.PROTECTED)
+public class TransferStatistics extends BaseEntity {
+	@Column(name = "daily_total_amount", columnDefinition = "bigint")
+	private Long dailyTotalAmount;
+
+	@Column(name = "cumulative_total_amount", columnDefinition = "bigint")
+	private Long cumulativeTotalAmount;
+
+	@Column(name = "unit_date", columnDefinition = "datetime")
+	private LocalDateTime unitDate;
+
+	public TransferStatistics(Long dailyTotalAmount, Long cumulativeTotalAmount, LocalDateTime unitDate) {
+		this.dailyTotalAmount = dailyTotalAmount;
+		this.cumulativeTotalAmount = cumulativeTotalAmount;
+		this.unitDate = unitDate;
+	}
+
+	@Override
+	public boolean equals(Object o) {
+		if (o instanceof TransferStatistics transferStatistics) {
+			return this.getId() == transferStatistics.getId();
+		}
+		return false;
+	}
+
+	@Override
+	public int hashCode() {
+		return Objects.hash(this);
+	}
+}

src/main/java/org/c4marathon/assignment/domain/transfer_statistics/presentation/TransferStatisticsController.java

@@ -0,0 +1,40 @@
+package org.c4marathon.assignment.domain.transfer_statistics.presentation;
+
+import java.time.LocalDate;
+import java.util.List;
+
+import org.c4marathon.assignment.domain.transfer_statistics.dto.AggregateTransferStatisticsRequest;
+import org.c4marathon.assignment.domain.transfer_statistics.dto.GetAllTransferStatisticsRequest;
+import org.c4marathon.assignment.domain.transfer_statistics.entity.TransferStatistics;
+import org.c4marathon.assignment.domain.transfer_statistics.service.TransferStatisticsService;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.RestController;
+
+import lombok.RequiredArgsConstructor;
+
+@RestController
+@RequiredArgsConstructor
+@RequestMapping("/api")
+public class TransferStatisticsController {
+	private final TransferStatisticsService transferStatisticsService;
+
+	@GetMapping("/v1/transfer-statistics")
+	public ResponseEntity<List<TransferStatistics>> getTransferStatisticsInBetween(
+		@RequestParam(name = "start-date") LocalDate startDate, @RequestParam(name = "end-date") LocalDate endDate) {
+		return ResponseEntity.ok(
+			transferStatisticsService.findAllByUnitDateBetween(
+				new GetAllTransferStatisticsRequest(startDate, endDate)));
+	}
+
+	@PostMapping("/v1/transfer-statistics")
+	public ResponseEntity<TransferStatistics> aggregateTransferStatistics(
+		@RequestBody AggregateTransferStatisticsRequest request
+	) {
+		return ResponseEntity.ok(transferStatisticsService.getStatistics(request));
+	}
+}

src/main/java/org/c4marathon/assignment/domain/transfer_statistics/repository/TransferStatisticsReader.java

@@ -0,0 +1,25 @@
+package org.c4marathon.assignment.domain.transfer_statistics.repository;
+
+import java.time.LocalDate;
+import java.util.stream.Stream;
+
+import org.c4marathon.assignment.domain.transfer_statistics.entity.TransferStatistics;
+import org.springframework.stereotype.Component;
+
+import jakarta.persistence.EntityNotFoundException;
+import lombok.RequiredArgsConstructor;
+
+@Component
+@RequiredArgsConstructor
+public class TransferStatisticsReader {
+	private final TransferStatisticsRepository transferStatisticsRepository;
+
+	public Stream<TransferStatistics> findAllByUnitDateBetween(LocalDate from, LocalDate to) {
+		return transferStatisticsRepository.findAllByUnitDateBetween(from, to);
+	}
+
+	public TransferStatistics findByUnitDate(LocalDate date) {
+		return transferStatisticsRepository.findByUnitDate(date)
+			.orElseThrow(() -> new EntityNotFoundException("해당 송금 통계는 존재하지 않습니다."));
+	}
+}

src/main/java/org/c4marathon/assignment/domain/transfer_statistics/repository/TransferStatisticsRepository.java

@@ -0,0 +1,31 @@
+package org.c4marathon.assignment.domain.transfer_statistics.repository;
+
+import static org.hibernate.jpa.HibernateHints.*;
+
+import java.time.LocalDate;
+import java.util.Optional;
+import java.util.stream.Stream;
+
+import org.c4marathon.assignment.domain.transfer_statistics.entity.TransferStatistics;
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.Query;
+import org.springframework.data.jpa.repository.QueryHints;
+import org.springframework.data.repository.query.Param;
+
+import jakarta.persistence.QueryHint;
+
+public interface TransferStatisticsRepository extends JpaRepository<TransferStatistics, Long> {
+	@Query(
+		"""
+			SELECT ts FROM TransferStatistics ts
+			WHERE ts.unitDate between :startDate AND :endDate
+			ORDER BY ts.unitDate DESC
+			""")
+	@QueryHints(value = {
+		@QueryHint(name = HINT_FETCH_SIZE, value = "" + Integer.MAX_VALUE),
+		@QueryHint(name = HINT_CACHEABLE, value = "false"),
+	})
+	Stream<TransferStatistics> findAllByUnitDateBetween(@Param("startDate") LocalDate startDate, @Param("endDate") LocalDate endDate);
+
+	Optional<TransferStatistics> findByUnitDate(LocalDate date);
+}