feat: 봉사 기록 등록 이벤트 구현

- 도메인 이벤트 타입에 봉사 시간 정산 이벤트 등록
- 발행될 봉사 시간 정산 이벤트 클래스 생성
- 봉사 시간 정산 이벤트 퍼블리셔 생성
- 구독을 위한 봉사 시간 정산 이벤트 RedisSubscriber 생성
- RedisListenerRegistrar애 구독 클래스 추가
- 봉사 시간 정산 이벤트 메세지 컨버터 생성
- 봉사 기록 생성 이벤트 핸들러 인터페이스 생성
- 봉사 기록 생성 이벤트 핸들러 구현체 생성
- 봉사 시간 정산 메서드에 봉사 기록 생성 이벤트 의존성 주입
- 테스트 코드 작성및 검증 완료

Author: 7zrv

src/main/java/com/somemore/domains/volunteerapply/service/SettleVolunteerApplyFacadeService.java

@@ -9,6 +9,7 @@
 import com.somemore.domains.volunteerapply.event.VolunteerReviewRequestEvent;
 import com.somemore.domains.volunteerapply.usecase.SettleVolunteerApplyFacadeUseCase;
 import com.somemore.domains.volunteerapply.usecase.VolunteerApplyQueryUseCase;
+import com.somemore.domains.volunteerrecord.event.VolunteerRecordEventPublisher;
 import com.somemore.global.common.event.ServerEventPublisher;
 import com.somemore.global.common.event.ServerEventType;
 import com.somemore.global.exception.BadRequestException;
@@ -30,6 +31,7 @@ public class SettleVolunteerApplyFacadeService implements SettleVolunteerApplyFa
     private final RecruitBoardQueryUseCase recruitBoardQueryUseCase;
     private final UpdateVolunteerUseCase updateVolunteerUseCase;
     private final ServerEventPublisher serverEventPublisher;
+    private final VolunteerRecordEventPublisher volunteerRecordEventPublisher;
 
     @Override
     public void settleVolunteerApplies(VolunteerApplySettleRequestDto dto, UUID centerId) {
@@ -47,6 +49,7 @@ public void settleVolunteerApplies(VolunteerApplySettleRequestDto dto, UUID cent
             apply.changeAttended(true);
             updateVolunteerUseCase.updateVolunteerStats(apply.getVolunteerId(), hours);
             publishVolunteerReviewRequestEvent(apply, recruitBoard);
+            volunteerRecordEventPublisher.publishVolunteerRecordCreateEvent(apply, recruitBoard);
         });
 
     }

src/main/java/com/somemore/domains/volunteerrecord/event/VolunteerRecordCreateEvent.java

@@ -0,0 +1,39 @@
+package com.somemore.domains.volunteerrecord.event;
+
+import com.fasterxml.jackson.annotation.JsonCreator;
+import com.fasterxml.jackson.annotation.JsonProperty;
+import com.somemore.global.common.event.DomainEventSubType;
+import com.somemore.global.common.event.ServerEvent;
+import com.somemore.global.common.event.ServerEventType;
+import lombok.Getter;
+import lombok.experimental.SuperBuilder;
+
+import java.time.LocalDate;
+import java.time.LocalDateTime;
+import java.util.UUID;
+
+@Getter
+@SuperBuilder
+public class VolunteerRecordCreateEvent extends ServerEvent<DomainEventSubType> {
+
+    private final UUID volunteerId;
+    private final String title;
+    private final LocalDate volunteerDate;
+    private final int volunteerHours;
+
+    @JsonCreator
+    private VolunteerRecordCreateEvent(
+            @JsonProperty(value = "volunteerId", required = true) UUID volunteerId,
+            @JsonProperty(value = "title", required = true) String title,
+            @JsonProperty(value = "volunteerDate", required = true) LocalDate volunteerDate,
+            @JsonProperty(value = "volunteerHours", required = true) int volunteerHours) {
+
+        super(ServerEventType.DOMAIN_EVENT, DomainEventSubType.VOLUNTEER_HOURS_SETTLE, LocalDateTime.now());
+
+        this.volunteerId = volunteerId;
+        this.title = title;
+        this.volunteerDate = volunteerDate;
+        this.volunteerHours = volunteerHours;
+    }
+
+}

src/main/java/com/somemore/domains/volunteerrecord/event/VolunteerRecordEventPublisher.java

@@ -0,0 +1,31 @@
+package com.somemore.domains.volunteerrecord.event;
+
+import com.somemore.domains.recruitboard.domain.RecruitBoard;
+import com.somemore.domains.volunteerapply.domain.VolunteerApply;
+import com.somemore.global.common.event.DomainEventSubType;
+import com.somemore.global.common.event.ServerEventPublisher;
+import com.somemore.global.common.event.ServerEventType;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Component;
+
+@RequiredArgsConstructor
+@Component
+public class VolunteerRecordEventPublisher {
+
+    private final ServerEventPublisher serverEventPublisher;
+
+    public void publishVolunteerRecordCreateEvent(VolunteerApply apply, RecruitBoard recruitBoard) {
+
+        VolunteerRecordCreateEvent event = VolunteerRecordCreateEvent
+                .builder()
+                .type(ServerEventType.DOMAIN_EVENT)
+                .subType(DomainEventSubType.VOLUNTEER_HOURS_SETTLE)
+                .volunteerId(apply.getVolunteerId())
+                .title(recruitBoard.getTitle())
+                .volunteerDate(recruitBoard.getRecruitmentInfo().getVolunteerEndDateTime().toLocalDate())
+                .volunteerHours(recruitBoard.getRecruitmentInfo().getVolunteerHours())
+                .build();
+
+        serverEventPublisher.publish(event);
+    }
+}

src/main/java/com/somemore/domains/volunteerrecord/event/convert/VolunteerRecordMessageConverter.java

@@ -0,0 +1,51 @@
+package com.somemore.domains.volunteerrecord.event.convert;
+
+import com.fasterxml.jackson.core.JsonProcessingException;
+import com.fasterxml.jackson.databind.JsonNode;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.somemore.domains.volunteerrecord.domain.VolunteerRecord;
+import com.somemore.domains.volunteerrecord.event.VolunteerRecordCreateEvent;
+import com.somemore.global.common.event.DomainEventSubType;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Component;
+
+@Slf4j
+@RequiredArgsConstructor
+@Component
+public class VolunteerRecordMessageConverter {
+
+    private static final String SUB_TYPE = "subType";
+    private final ObjectMapper objectMapper;
+
+    public VolunteerRecord from(String message) {
+        try {
+            JsonNode rootNode = objectMapper.readTree(message);
+            String eventType = rootNode.get(SUB_TYPE).asText();
+
+            return switch (DomainEventSubType.from(eventType)) {
+                case VOLUNTEER_HOURS_SETTLE -> buildVolunteerRecordCreate(message);
+                default -> {
+                    log.error("지원하지 않는 이벤트 타입입니다: {}", eventType);
+                    throw new IllegalArgumentException("지원하지 않는 이벤트 타입입니다: " + eventType);
+                }
+            };
+        } catch (Exception e) {
+            log.error("메시지 변환 실패: {}", e.getMessage());
+            throw new IllegalStateException("메시지 변환 중 오류가 발생했습니다.", e);
+        }
+    }
+
+    private VolunteerRecord buildVolunteerRecordCreate(String message) throws JsonProcessingException {
+
+        VolunteerRecordCreateEvent volunteerRecordCreateEvent = objectMapper.readValue(message, VolunteerRecordCreateEvent.class);
+
+        return VolunteerRecord.create(
+                volunteerRecordCreateEvent.getVolunteerId(),
+                volunteerRecordCreateEvent.getTitle(),
+                volunteerRecordCreateEvent.getVolunteerDate(),
+                volunteerRecordCreateEvent.getVolunteerHours()
+        );
+
+    }
+}

src/main/java/com/somemore/domains/volunteerrecord/event/handler/SettleVolunteerHoursHandler.java

@@ -0,0 +1,9 @@
+package com.somemore.domains.volunteerrecord.event.handler;
+
+import com.somemore.domains.volunteerrecord.domain.VolunteerRecord;
+
+public interface SettleVolunteerHoursHandler {
+
+    void handle(VolunteerRecord volunteerRecord);
+
+}

src/main/java/com/somemore/domains/volunteerrecord/event/handler/SettleVolunteerHoursHandlerImpl.java

@@ -0,0 +1,21 @@
+package com.somemore.domains.volunteerrecord.event.handler;
+
+import com.somemore.domains.volunteerrecord.domain.VolunteerRecord;
+import com.somemore.domains.volunteerrecord.usecase.VolunteerRecordCreateUseCase;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Component;
+import org.springframework.transaction.annotation.Transactional;
+
+@Component
+@RequiredArgsConstructor
+@Transactional
+public class SettleVolunteerHoursHandlerImpl implements SettleVolunteerHoursHandler {
+
+    private final VolunteerRecordCreateUseCase volunteerRecordCreateUseCase;
+
+    @Override
+    public void handle(VolunteerRecord volunteerRecord) {
+
+        volunteerRecordCreateUseCase.create(volunteerRecord);
+    }
+}

src/main/java/com/somemore/domains/volunteerrecord/event/subscriber/RedisSettleVolunteerHoursSubscriber.java

@@ -0,0 +1,27 @@
+package com.somemore.domains.volunteerrecord.event.subscriber;
+
+import com.somemore.domains.volunteerrecord.domain.VolunteerRecord;
+import com.somemore.domains.volunteerrecord.event.convert.VolunteerRecordMessageConverter;
+import com.somemore.domains.volunteerrecord.event.handler.SettleVolunteerHoursHandler;
+import lombok.RequiredArgsConstructor;
+import org.springframework.data.redis.connection.Message;
+import org.springframework.data.redis.connection.MessageListener;
+import org.springframework.stereotype.Component;
+
+@Component
+@RequiredArgsConstructor
+public class RedisSettleVolunteerHoursSubscriber implements MessageListener {
+
+    private final SettleVolunteerHoursHandler settleVolunteerHoursHandler;
+    private final VolunteerRecordMessageConverter messageConverter;
+
+    @Override
+    public void onMessage(Message message, byte[] pattern) {
+
+        VolunteerRecord volunteerRecord = messageConverter.from(
+                new String(message.getBody())
+        );
+
+        settleVolunteerHoursHandler.handle(volunteerRecord);
+    }
+}

src/main/java/com/somemore/global/common/event/DomainEventSubType.java

@@ -7,6 +7,7 @@
 @RequiredArgsConstructor
 public enum DomainEventSubType {
     CREATE_RECRUIT_BOARD("모집 글 등록"),
+    VOLUNTEER_HOURS_SETTLE("봉사 시간 정산")
     ;
 
     private final String description;

src/main/java/com/somemore/global/redis/registrar/RedisListenerRegistrar.java

@@ -2,6 +2,7 @@
 
 import com.somemore.domains.interestcenter.event.subscriber.RedisCreateRecruitBoardSubscriber;
 import com.somemore.domains.notification.event.subscriber.RedisNotificationSubscriber;
+import com.somemore.domains.volunteerrecord.event.subscriber.RedisSettleVolunteerHoursSubscriber;
 import jakarta.annotation.PostConstruct;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
@@ -17,6 +18,7 @@ public class RedisListenerRegistrar {
     private final RedisMessageListenerContainer container;
     private final RedisNotificationSubscriber redisNotificationSubscriber;
     private final RedisCreateRecruitBoardSubscriber redisCreateRecruitBoardSubscriber;
+    private final RedisSettleVolunteerHoursSubscriber redisSettleVolunteerHoursSubscriber;
     private final ChannelTopic notificationTopic;
     private final ChannelTopic domainEventTopic;
 
@@ -25,9 +27,11 @@ public void registerListeners() {
         registerNotificationListener();
     }
 
+    // 알림 리스너와 분리
     private void registerNotificationListener() {
         container.addMessageListener(redisNotificationSubscriber, notificationTopic);
         container.addMessageListener(redisCreateRecruitBoardSubscriber, domainEventTopic);
+        container.addMessageListener(redisSettleVolunteerHoursSubscriber, domainEventTopic);
         log.info("리스너가 토픽에 성공적으로 등록되었습니다.");
     }
 }

src/test/java/com/somemore/domains/volunteerapply/service/SettleVolunteerApplyFacadeServiceTest.java

@@ -7,6 +7,8 @@
 import com.somemore.domains.volunteerapply.domain.VolunteerApply;
 import com.somemore.domains.volunteerapply.dto.request.VolunteerApplySettleRequestDto;
 import com.somemore.domains.volunteerapply.repository.VolunteerApplyRepository;
+import com.somemore.domains.volunteerrecord.domain.VolunteerRecord;
+import com.somemore.domains.volunteerrecord.repository.VolunteerRecordJpaRepository;
 import com.somemore.global.exception.BadRequestException;
 import com.somemore.support.IntegrationTestSupport;
 import org.junit.jupiter.api.DisplayName;
@@ -40,6 +42,9 @@ class SettleVolunteerApplyFacadeServiceTest extends IntegrationTestSupport {
     @Autowired
     private VolunteerRepository volunteerRepository;
 
+    @Autowired
+    private VolunteerRecordJpaRepository volunteerRecordJpaRepository;
+
     @DisplayName("봉사 활동 지원을 정산할 수 있다.")
     @Test
     void settleVolunteerApplies() {
@@ -86,6 +91,18 @@ void settleVolunteerApplies() {
         assertThat(findVolunteer1.getTotalVolunteerCount()).isEqualTo(1);
         assertThat(findVolunteer2.getTotalVolunteerCount()).isEqualTo(1);
         assertThat(findVolunteer3.getTotalVolunteerCount()).isEqualTo(1);
+
+        // 봉사 기록 생성 확인
+        List<VolunteerRecord> records = volunteerRecordJpaRepository.findAll();
+        assertThat(records).hasSize(3);
+
+        assertThat(records)
+                .extracting(VolunteerRecord::getVolunteerId)
+                .containsExactlyInAnyOrder(volunteer1.getId(), volunteer2.getId(), volunteer3.getId());
+
+        assertThat(records)
+                .extracting(VolunteerRecord::getVolunteerHours)
+                .containsOnly(hour);
     }
 
     @DisplayName("정산시, 지원 리스트에 존재하지 않는 지원이 있는 경우 에러가 발생한다.")