상호 평가 반영 스케줄링

backend/ddang/src/main/java/com/ddang/ddang/review/application/ReviewService.java

@@ -44,9 +44,9 @@ public Long create(final CreateReviewDto reviewDto) {
         validateWriterCanReview(findAuction, writer);
 
         final Review review = reviewDto.toEntity(findAuction, writer, target);
-        final Review persistReview = saveReviewAndUpdateReliability(review, target);
 
-        return persistReview.getId();
+        return reviewRepository.save(review)
+                               .getId();
     }
 
     private void validateWriterCanReview(final Auction auction, final User writer) {
@@ -63,18 +63,9 @@ private void validateAlreadyReviewed(final Auction auction, final User writer) {
         }
     }
 
-    private Review saveReviewAndUpdateReliability(final Review review, final User target) {
-        final Review persistReview = reviewRepository.save(review);
-
-        final List<Review> targetReviews = reviewRepository.findAllByTargetId(target.getId());
-        target.updateReliability(targetReviews);
-
-        return persistReview;
-    }
-
     public ReadReviewDetailDto readByReviewId(final Long reviewId) {
         final Review findReview = reviewRepository.findById(reviewId)
-                                              .orElseThrow(() -> new ReviewNotFoundException("해당 평가를 찾을 수 없습니다."));
+                                                  .orElseThrow(() -> new ReviewNotFoundException("해당 평가를 찾을 수 없습니다."));
 
         return ReadReviewDetailDto.from(findReview);
     }

backend/ddang/src/main/java/com/ddang/ddang/review/domain/Reviews.java

@@ -0,0 +1,54 @@
+package com.ddang.ddang.review.domain;
+
+import com.ddang.ddang.user.domain.User;
+import lombok.EqualsAndHashCode;
+import lombok.Getter;
+import lombok.RequiredArgsConstructor;
+import lombok.ToString;
+
+import java.util.List;
+import java.util.Set;
+
+import static java.util.stream.Collectors.toSet;
+
+@RequiredArgsConstructor
+@Getter
+@EqualsAndHashCode
+@ToString
+public class Reviews {
+
+    private final List<Review> reviews;
+
+    public double addAllReviewScore() {
+        return reviews.stream()
+                      .mapToDouble(review -> review.getScore().getValue())
+                      .sum();
+    }
+
+    public int size() {
+        return reviews.size();
+    }
+
+    public boolean isEmpty() {
+        return reviews.isEmpty();
+    }
+
+    public Set<User> findReviewTargets() {
+        return reviews.stream()
+                      .map(Review::getTarget)
+                      .collect(toSet());
+    }
+
+    public List<Review> findReviewsByTarget(final User targetUser) {
+        return reviews.stream()
+                      .filter(review -> review.getTarget().equals(targetUser))
+                      .toList();
+    }
+
+    public Long findLastReviewId() {
+        final int lastIndex = reviews.size() - 1;
+
+        return reviews.get(lastIndex)
+                      .getId();
+    }
+}

backend/ddang/src/main/java/com/ddang/ddang/review/infrastructure/persistence/JpaReviewRepository.java

@@ -19,4 +19,6 @@ public interface JpaReviewRepository extends JpaRepository<Review, Long> {
     List<Review> findAllByTargetId(final Long targetId);
 
     Optional<Review> findByAuctionIdAndWriterId(final Long auctionId, final Long writerId);
+
+    List<Review> findAllByIdGreaterThan(final Long id);
 }

backend/ddang/src/main/java/com/ddang/ddang/user/domain/Reliability.java

@@ -1,40 +1,29 @@
 package com.ddang.ddang.user.domain;
 
-import com.ddang.ddang.review.domain.Review;
 import jakarta.persistence.Embeddable;
 import lombok.AccessLevel;
 import lombok.EqualsAndHashCode;
 import lombok.Getter;
 import lombok.NoArgsConstructor;
 import lombok.ToString;
 
-import java.util.List;
-
 @Embeddable
 @NoArgsConstructor(access = AccessLevel.PROTECTED)
 @Getter
 @EqualsAndHashCode
 @ToString
 public class Reliability {
 
-    public static final Reliability INITIAL_RELIABILITY = new Reliability(null);
+    private static final double INITIAL_RELIABILITY_VALUE = Double.MIN_VALUE;
+    public static final Reliability INITIAL_RELIABILITY = new Reliability(INITIAL_RELIABILITY_VALUE);
 
-    private Double value;
+    private double value;
 
-    public Reliability(final Double value) {
+    public Reliability(final double value) {
         this.value = value;
     }
 
-    public void updateReliability(final List<Review> reviews) {
-        if (reviews.isEmpty()) {
-            this.value = null;
-
-            return;
-        }
-
-        this.value = reviews.stream()
-                            .mapToDouble(review -> review.getScore().getValue())
-                            .average()
-                            .orElseGet(null);
+    public double calculateReviewScoreSum(final int appliedReviewCount) {
+        return value * appliedReviewCount;
     }
 }

backend/ddang/src/main/java/com/ddang/ddang/user/domain/ReliabilityUpdateHistory.java

@@ -0,0 +1,29 @@
+package com.ddang.ddang.user.domain;
+
+import com.ddang.ddang.common.entity.BaseCreateTimeEntity;
+import jakarta.persistence.Entity;
+import jakarta.persistence.GeneratedValue;
+import jakarta.persistence.GenerationType;
+import jakarta.persistence.Id;
+import lombok.EqualsAndHashCode;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+import lombok.ToString;
+
+@Entity
+@NoArgsConstructor
+@Getter
+@EqualsAndHashCode(of = "id", callSuper = false)
+@ToString(of = {"id", })
+public class ReliabilityUpdateHistory extends BaseCreateTimeEntity {
+
+    @Id
+    @GeneratedValue(strategy = GenerationType.IDENTITY)
+    private Long id;
+
+    private Long lastAppliedReviewId = 0L;
+
+    public ReliabilityUpdateHistory(final Long lastAppliedReviewId) {
+        this.lastAppliedReviewId = lastAppliedReviewId;
+    }
+}

backend/ddang/src/main/java/com/ddang/ddang/user/domain/User.java

@@ -2,7 +2,6 @@
 
 import com.ddang.ddang.common.entity.BaseTimeEntity;
 import com.ddang.ddang.image.domain.ProfileImage;
-import com.ddang.ddang.review.domain.Review;
 import jakarta.persistence.AttributeOverride;
 import jakarta.persistence.CascadeType;
 import jakarta.persistence.Column;
@@ -23,8 +22,6 @@
 import lombok.NoArgsConstructor;
 import lombok.ToString;
 
-import java.util.List;
-
 @Entity
 @NoArgsConstructor(access = AccessLevel.PROTECTED)
 @Getter
@@ -89,7 +86,7 @@ public void withdrawal() {
         this.deleted = DELETED_STATUS;
     }
 
-    public void updateReliability(final List<Review> reviews) {
-        reliability.updateReliability(reviews);
+    public void updateReliability(final Reliability reliability) {
+        this.reliability = reliability;
     }
 }

backend/ddang/src/main/java/com/ddang/ddang/user/domain/UserReliability.java

@@ -0,0 +1,72 @@
+package com.ddang.ddang.user.domain;
+
+import com.ddang.ddang.review.domain.Reviews;
+import jakarta.persistence.AttributeOverride;
+import jakarta.persistence.CascadeType;
+import jakarta.persistence.Column;
+import jakarta.persistence.Embedded;
+import jakarta.persistence.Entity;
+import jakarta.persistence.FetchType;
+import jakarta.persistence.ForeignKey;
+import jakarta.persistence.GeneratedValue;
+import jakarta.persistence.GenerationType;
+import jakarta.persistence.Id;
+import jakarta.persistence.JoinColumn;
+import jakarta.persistence.OneToOne;
+import lombok.AccessLevel;
+import lombok.EqualsAndHashCode;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+import lombok.ToString;
+
+@Entity
+@NoArgsConstructor(access = AccessLevel.PROTECTED)
+@Getter
+@EqualsAndHashCode(of = "id", callSuper = false)
+@ToString(of = {"id", "reliability", "appliedReviewCount"})
+public class UserReliability {
+
+    @Id
+    @GeneratedValue(strategy = GenerationType.IDENTITY)
+    private Long id;
+
+    @OneToOne(fetch = FetchType.LAZY, cascade = {CascadeType.PERSIST, CascadeType.REMOVE})
+    @JoinColumn(name = "user_id", foreignKey = @ForeignKey(name = "fk_user_reliability_user"), nullable = false)
+    private User user;
+
+    @Embedded
+    @AttributeOverride(name = "value", column = @Column(name = "reliability"))
+    private Reliability reliability;
+
+    private int appliedReviewCount = 0;
+
+    public UserReliability(final User user) {
+        this.user = user;
+        this.reliability = user.getReliability();
+    }
+
+    public void updateReliability(final Reviews newReviews) {
+        if (newReviews.isEmpty()) {
+            return;
+        }
+        final Reliability newReliability = calculateNewReliability(newReviews);
+
+        this.reliability = newReliability;
+        addAppliedReviewCount(newReviews.size());
+        user.updateReliability(newReliability);
+    }
+
+    private Reliability calculateNewReliability(final Reviews newReviews) {
+        final double currentReviewScoreSum = reliability.calculateReviewScoreSum(appliedReviewCount);
+        final double newReviewScoreSum = newReviews.addAllReviewScore();
+        final int allReviewCount = appliedReviewCount + newReviews.size();
+
+        final double newReliabilityValue = (currentReviewScoreSum + newReviewScoreSum) / allReviewCount;
+
+        return new Reliability(newReliabilityValue);
+    }
+
+    private void addAppliedReviewCount(final int newReviewCount) {
+        this.appliedReviewCount += newReviewCount;
+    }
+}

backend/ddang/src/main/java/com/ddang/ddang/user/infrastructure/persistence/JpaReliabilityUpdateHistoryRepository.java

@@ -0,0 +1,11 @@
+package com.ddang.ddang.user.infrastructure.persistence;
+
+import com.ddang.ddang.user.domain.ReliabilityUpdateHistory;
+import org.springframework.data.jpa.repository.JpaRepository;
+
+import java.util.Optional;
+
+public interface JpaReliabilityUpdateHistoryRepository extends JpaRepository<ReliabilityUpdateHistory, Long> {
+
+    Optional<ReliabilityUpdateHistory> findFirstByOrderByIdDesc();
+}

backend/ddang/src/main/java/com/ddang/ddang/user/infrastructure/persistence/JpaUserReliabilityRepository.java

@@ -0,0 +1,11 @@
+package com.ddang.ddang.user.infrastructure.persistence;
+
+import com.ddang.ddang.user.domain.UserReliability;
+import org.springframework.data.jpa.repository.JpaRepository;
+
+import java.util.Optional;
+
+public interface JpaUserReliabilityRepository extends JpaRepository<UserReliability, Long> {
+
+    Optional<UserReliability> findByUserId(final Long userId);
+}

backend/ddang/src/test/java/com/ddang/ddang/review/application/ReviewServiceTest.java

@@ -17,6 +17,7 @@
 
 import java.util.List;
 
+import static org.assertj.core.api.Assertions.assertThat;
 import static org.assertj.core.api.AssertionsForClassTypes.assertThatThrownBy;
 
 @IsolateDatabase
@@ -28,15 +29,12 @@ class ReviewServiceTest extends ReviewServiceFixture {
     ReviewService reviewService;
 
     @Test
-    void 평가를_등록한고_평가_상대의_신뢰도를_갱신한다() {
+    void 평가를_등록한다() {
         // when
         final Long actual = reviewService.create(구매자에_대한_평가_등록을_위한_DTO);
 
         // then
-        SoftAssertions.assertSoftly(softAssertions -> {
-            softAssertions.assertThat(actual).isPositive();
-            softAssertions.assertThat(구매자.getReliability().getValue()).isEqualTo(구매자가_새로운_평가_점수를_받고난_후의_신뢰도_점수);
-        });
+        assertThat(actual).isPositive();
     }
 
     @Test

backend/ddang/src/test/java/com/ddang/ddang/review/application/fixture/ReviewServiceFixture.java

@@ -36,11 +36,11 @@ public class ReviewServiceFixture {
     @Autowired
     private JpaReviewRepository reviewRepository;
 
-    private Double 구매자가_판매자1에게_받은_평가_점수 = 5.0d;
-    private Double 구매자가_판매자2에게_받은_평가_점수 = 1.0d;
-    private Double 구매자가_받을_새로운_평가_점수 = 4.5d;
+    private double 구매자가_판매자1에게_받은_평가_점수 = 5.0d;
+    private double 구매자가_판매자2에게_받은_평가_점수 = 1.0d;
+    private double 구매자가_받을_새로운_평가_점수 = 4.5d;
 
-    protected Double 구매자가_새로운_평가_점수를_받고난_후의_신뢰도_점수 =
+    protected double 구매자가_새로운_평가_점수를_받고난_후의_신뢰도_점수 =
             (구매자가_판매자1에게_받은_평가_점수 + 구매자가_판매자2에게_받은_평가_점수 + 구매자가_받을_새로운_평가_점수) / 3;
     protected Long 존재하지_않는_사용자 = -999L;
     protected User 판매자1;