fix: 인사이트 조회 오류 해결

Author: khlee

common/common-domain/common-application-service/src/main/java/com/project/imdang/common/domain/event/DomainEventMessageListener.java

@@ -6,7 +6,7 @@ public abstract class DomainEventMessageListener<E extends DomainEventMessage> {
 
     public abstract void process(E domainEventMessage);
 
-    @EventListener
+
     public void handle(E domainEventMessage) {
         try {
             process(domainEventMessage);

imdang-container/build.gradle

@@ -19,6 +19,7 @@ dependencies {
     implementation project(':insight-service:insight-domain:insight-domain-core')
 
     implementation project(':member-service:member-application')
+    implementation project(':member-service:member-messaging:listener')
     implementation project(':member-service:member-persistence')
     implementation project(':member-service:member-domain:member-application-service')
     implementation project(':member-service:member-domain:member-domain-core')

insight-service/insight-domain/insight-application-service/src/main/java/com/project/imdang/insight/domain/dto/insight/detail/InsightDetailResult.java

@@ -31,8 +31,6 @@ public class InsightDetailResult {
 
     private InsightId insightId;    //인사이트ID
 
-    private List<String> mainImage;       //메인 이미지
-    //TODO : 추가 이미지
     private String title;           //제목
 
     private Address address;    //단지 주소
@@ -53,7 +51,7 @@ public class InsightDetailResult {
     private Long accusedCount;       //신고수
     private Long viewCount;          //조회수
 
-//    private Integer score;
+
     private ZonedDateTime createdAt;
     private Boolean createdByMe;
     private List<String> images;        // image URL 리스트

insight-service/insight-domain/insight-application-service/src/main/java/com/project/imdang/insight/domain/handler/insight/DetailInsightQueryHandler.java

@@ -48,7 +48,7 @@ public InsightDetailResult detailInsight(DetailInsightQuery detailInsightQuery)
                 .orElseThrow(() -> new MemberNotFoundException(requestedBy));
 
         // 작성한 인사이트가 없거나, 최신 작성 날짜가 한달 이상인 경우
-        if (requestMember.getInsightCount() < 1 || requestMember.getLatestInsightCreateDate().isBefore(LocalDate.now().minusDays(30))) {
+        if (requestMember.getLatestInsightCreateDate() == null || requestMember.getLatestInsightCreateDate().isBefore(LocalDate.now().minusDays(30))) {
             throw new InsightDomainException("Latest insight create Date is before one month");
         }
 

insight-service/insight-persistence/src/main/java/com/project/imdang/insight/persistence/repository/DistrictJpaRepository.java

@@ -5,14 +5,15 @@
 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 DistrictJpaRepository extends JpaRepository<DistrictEntity, String> {
 
     @Query("select distinct d.code, d.siDo, d.siGunGu from DistrictEntity d " +
             "where d.siDo = :siDo and d.siGunGu <> '' and d.eupMyeonDong = '' and d.deletedAt is null")
-    Page<Object[]> findAllSiGunGuBySiDo(String siDo, Pageable pageable);
+    Page<Object[]> findAllSiGunGuBySiDo(@Param("siDo") String siDo, Pageable pageable);
 
     @Query("select distinct d.code, d.siDo, d.siGunGu, d.eupMyeonDong from DistrictEntity d " +
             "where d.siDo = :siDo and d.siGunGu = :siGunGu and d.eupMyeonDong <> '' and d.deletedAt is null")
-    Page<Object[]> findAllEupMyeonDongBySiDoAndSiGunGu(String siDo, String siGunGu, Pageable pageable);
+    Page<Object[]> findAllEupMyeonDongBySiDoAndSiGunGu(@Param("siDo") String siDo, @Param("siGunGu") String siGunGu, Pageable pageable);
 }

insight-service/insight-persistence/src/main/java/com/project/imdang/insight/persistence/repository/InsightJpaRepository.java

@@ -69,7 +69,7 @@ List<Object[]> findAllApartmentComplexAndInsightCountByMemberIdAndDistrict(@Para
                     "where i.member_id = :memberId " +
                     "and i.complex_name = :apartmentComplexName",
             nativeQuery = true)
-    Page<InsightEntity> findAllByMemberIdAndApartmentComplexAndOnlyMine(String memberId, String apartmentComplexName, PageRequest pageRequest);
+    Page<InsightEntity> findAllByMemberIdAndApartmentComplexAndOnlyMine(@Param("memberId") String memberId, @Param("apartmentComplexName") String apartmentComplexName, PageRequest pageRequest);
 
     @Query(value = "select i.* from insight i left join recommend r on i.id = r.recommended_insight_id " +
             "where (i.member_id = :memberId or r.recommend_member_id = :memberId) " +
@@ -78,7 +78,7 @@ List<Object[]> findAllApartmentComplexAndInsightCountByMemberIdAndDistrict(@Para
                     "where (i.member_id = :memberId or r.recommend_member_id = :memberId) " +
                     "and i.complex_id = :apartmentComplexName",
             nativeQuery = true)
-    Page<InsightEntity> findAllByMemberIdAndApartmentComplex(String memberId, String apartmentComplexName, PageRequest pageRequest);
+    Page<InsightEntity> findAllByMemberIdAndApartmentComplex(@Param("memberId") String memberId, @Param("apartmentComplexName") String apartmentComplexName, PageRequest pageRequest);
 
     @Query(value = "select i.* from insight i " +
             "where i.member_id = :memberId " +

member-service/member-domain/member-application-service/src/main/java/com/project/imdang/member/domain/handler/member/UpdateMemberCommandHandler.java

@@ -21,8 +21,8 @@ public class UpdateMemberCommandHandler {
     @Transactional
     public Boolean update(MemberId memberId) {
         Member member = memberHelper.get(memberId);
-        Member accusedMember = memberDomainService.updateMember(member);
-        memberHelper.save(accusedMember);
+        Member updatedMember = memberDomainService.updateMember(member);
+        memberHelper.save(updatedMember);
         return true;
     }
 }

member-service/member-messaging/listener/src/main/java/com/project/imdang/member/messaging/listener/InsightAccusedEventMessageListener.java

@@ -5,6 +5,7 @@
 import com.project.imdang.insight.messaging.message.InsightAccusedEventMessage;
 import com.project.imdang.member.domain.ports.input.service.MemberApplicationService;
 import lombok.extern.slf4j.Slf4j;
+import org.springframework.context.event.EventListener;
 import org.springframework.stereotype.Component;
 
 @Slf4j
@@ -17,6 +18,11 @@ public InsightAccusedEventMessageListener(MemberApplicationService memberApplica
         this.memberApplicationService = memberApplicationService;
     }
 
+    @EventListener
+    public void handle(InsightAccusedEventMessage event) {
+        super.handle(event);
+    }
+
     @Override
     public void process(InsightAccusedEventMessage domainEventMessage) {
         MemberId accusedMemberId = new MemberId(domainEventMessage.accusedMemberId());

member-service/member-messaging/listener/src/main/java/com/project/imdang/member/messaging/listener/InsightCreatedEventMessageListener.java

@@ -2,10 +2,10 @@
 
 import com.project.imdang.common.domain.event.DomainEventMessageListener;
 import com.project.imdang.common.domain.valueobject.MemberId;
-import com.project.imdang.insight.messaging.message.InsightAccusedEventMessage;
 import com.project.imdang.insight.messaging.message.InsightCreatedEventMessage;
 import com.project.imdang.member.domain.ports.input.service.MemberApplicationService;
 import lombok.extern.slf4j.Slf4j;
+import org.springframework.context.event.EventListener;
 import org.springframework.stereotype.Component;
 
 @Slf4j
@@ -17,6 +17,12 @@ public class InsightCreatedEventMessageListener extends DomainEventMessageListen
     public InsightCreatedEventMessageListener(MemberApplicationService memberApplicationService) {
         this.memberApplicationService = memberApplicationService;
     }
+
+    @EventListener
+    public void handle(InsightCreatedEventMessage event) {
+        super.handle(event);
+    }
+
     @Override
     public void process(InsightCreatedEventMessage domainEventMessage) {
         //인사이트 생성 시 유저 정보 업데이트 (가장 최근 인사이트 작성 일시)

member-service/member-service-client/member-service-client-api-impl/src/main/java/com/project/imdang/member/domain/client/MemberInfoResolverImpl.java

@@ -30,6 +30,7 @@ public Optional<MemberData> resolve(MemberId memberId) {
                 .gender(entity.getGender().name())
                 .deviceToken(entity.getDeviceToken())
                 .accusedCount(entity.getAccusedCount())
+                .latestInsightCreateDate(entity.getLatestInsightCreateDate())
                 .build());
     }
 
@@ -46,6 +47,7 @@ public List<MemberData> resolve(List<MemberId> memberIds) {
                         .gender(entity.getGender().name())
                         .deviceToken(entity.getDeviceToken())
                         .accusedCount(entity.getAccusedCount())
+                        .latestInsightCreateDate(entity.getLatestInsightCreateDate())
                         .build())
                 .collect(Collectors.toList());
     }