Feature/226 관심 기관 봉사 모집 등록 알림

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

@@ -0,0 +1,20 @@
+package com.somemore.global.common.event;
+
+import lombok.RequiredArgsConstructor;
+
+import java.util.Arrays;
+
+@RequiredArgsConstructor
+public enum DomainEventSubType {
+    CREATE_RECRUIT_BOARD("모집 글 등록"),
+    ;
+
+    private final String description;
+
+    public static DomainEventSubType from(String value) {
+        return Arrays.stream(DomainEventSubType.values())
+                .filter(type -> type.name().equalsIgnoreCase(value))
+                .findFirst()
+                .orElseThrow(() -> new IllegalArgumentException("잘못된 도메인 이벤트 타입입니다: " + value));
+    }
+}

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

@@ -10,13 +10,8 @@
 @SuperBuilder
 public abstract class ServerEvent<T extends Enum<T>> {
 
-    @JsonProperty("type")
     private final ServerEventType type;
-
-    @JsonProperty("subType")
     private final T subType;
-
-    @JsonProperty("createdAt")
     private final LocalDateTime createdAt;
 
     protected ServerEvent(

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

@@ -9,7 +9,9 @@
 @RequiredArgsConstructor
 @Getter
 public enum ServerEventType {
-    NOTIFICATION(NotificationSubType.class);
+    NOTIFICATION(NotificationSubType.class),
+    DOMAIN_EVENT(DomainEventSubType.class),
+    ;
 
     private final Class<? extends Enum<?>> subtype;
 

src/main/java/com/somemore/global/redis/config/RedisConfig.java

@@ -1,7 +1,6 @@
 package com.somemore.global.redis.config;
 
 import com.somemore.global.common.event.ServerEventType;
-import java.util.Map;
 import lombok.RequiredArgsConstructor;
 import org.apache.commons.lang3.StringUtils;
 import org.redisson.Redisson;
@@ -19,6 +18,8 @@
 import org.springframework.data.redis.repository.configuration.EnableRedisRepositories;
 import org.springframework.data.redis.serializer.StringRedisSerializer;
 
+import java.util.Map;
+
 @Configuration
 @EnableRedisRepositories
 @RequiredArgsConstructor
@@ -55,13 +56,21 @@ public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory connec
 
     @Bean
     public ChannelTopic notificationTopic() {
-        return new ChannelTopic("notifications");
+        return new ChannelTopic("notification");
     }
 
     @Bean
-    public Map<ServerEventType, ChannelTopic> eventTopicMap(ChannelTopic notificationTopic) {
+    public ChannelTopic domainEventTopic() {
+        return new ChannelTopic("domainEvent");
+    }
+
+
+    @Bean
+    public Map<ServerEventType, ChannelTopic> eventTopicMap(ChannelTopic notificationTopic,
+                                                            ChannelTopic domainEventTopic) {
         return Map.of(
-                ServerEventType.NOTIFICATION, notificationTopic
+                ServerEventType.NOTIFICATION, notificationTopic,
+                ServerEventType.DOMAIN_EVENT, domainEventTopic
         );
     }
 

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

@@ -1,6 +1,7 @@
 package com.somemore.global.redis.registrar;
 
-import com.somemore.notification.subscriber.RedisNotificationSubscriber;
+import com.somemore.interestcenter.event.subscriber.RedisCreateRecruitBoardSubscriber;
+import com.somemore.notification.event.subscriber.RedisNotificationSubscriber;
 import jakarta.annotation.PostConstruct;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
@@ -15,7 +16,9 @@ public class RedisListenerRegistrar {
 
     private final RedisMessageListenerContainer container;
     private final RedisNotificationSubscriber redisNotificationSubscriber;
+    private final RedisCreateRecruitBoardSubscriber redisCreateRecruitBoardSubscriber;
     private final ChannelTopic notificationTopic;
+    private final ChannelTopic domainEventTopic;
 
     @PostConstruct
     public void registerListeners() {
@@ -24,6 +27,7 @@ public void registerListeners() {
 
     private void registerNotificationListener() {
         container.addMessageListener(redisNotificationSubscriber, notificationTopic);
-        log.info("Redis 알림 리스너가 '{}' 토픽에 성공적으로 등록되었습니다.", notificationTopic.getTopic());
+        container.addMessageListener(redisCreateRecruitBoardSubscriber, domainEventTopic);
+        log.info("리스너가 토픽에 성공적으로 등록되었습니다.");
     }
 }

src/main/java/com/somemore/interestcenter/event/converter/CreateRecruitBoardMessageConverter.java

@@ -0,0 +1,37 @@
+package com.somemore.interestcenter.event.converter;
+
+import com.fasterxml.jackson.core.JsonProcessingException;
+import com.fasterxml.jackson.databind.JsonNode;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.somemore.global.common.event.DomainEventSubType;
+import com.somemore.recruitboard.event.CreateRecruitBoardEvent;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Component;
+
+@Slf4j
+@RequiredArgsConstructor
+@Component
+public class CreateRecruitBoardMessageConverter {
+
+    private final ObjectMapper objectMapper;
+
+    public CreateRecruitBoardEvent from(String message) {
+        try {
+            JsonNode rootNode = objectMapper.readTree(message);
+            String eventType = rootNode.get("subType").asText();
+
+            return switch (DomainEventSubType.from(eventType)) {
+                case CREATE_RECRUIT_BOARD -> parseCreateRecruitBoardEvent(message);
+            };
+        } catch (Exception e) {
+            log.error(e.getMessage());
+            throw new IllegalStateException();
+        }
+    }
+
+    private CreateRecruitBoardEvent parseCreateRecruitBoardEvent(String message) throws JsonProcessingException {
+
+        return objectMapper.readValue(message, CreateRecruitBoardEvent.class);
+    }
+}

src/main/java/com/somemore/interestcenter/event/domain/InterestCenterCreateRecruitBoardEvent.java

@@ -0,0 +1,32 @@
+package com.somemore.interestcenter.event.domain;
+
+import com.fasterxml.jackson.annotation.JsonCreator;
+import com.fasterxml.jackson.annotation.JsonProperty;
+import com.somemore.global.common.event.ServerEvent;
+import com.somemore.global.common.event.ServerEventType;
+import com.somemore.notification.domain.NotificationSubType;
+import lombok.Getter;
+import lombok.experimental.SuperBuilder;
+
+import java.time.LocalDateTime;
+import java.util.UUID;
+
+@Getter
+@SuperBuilder
+public class InterestCenterCreateRecruitBoardEvent extends ServerEvent<NotificationSubType> {
+    private final UUID volunteerId;
+    private final UUID centerId;
+    private final Long recruitBoardId;
+
+    @JsonCreator
+    public InterestCenterCreateRecruitBoardEvent(
+            @JsonProperty(value = "volunteerId", required = true) UUID volunteerId,
+            @JsonProperty(value = "centerId", required = true) UUID centerId,
+            @JsonProperty(value = "recruitBoardId", required = true) Long recruitBoardId
+    ) {
+        super(ServerEventType.NOTIFICATION, NotificationSubType.INTEREST_CENTER_CREATE_RECRUIT_BOARD, LocalDateTime.now());
+        this.volunteerId = volunteerId;
+        this.centerId = centerId;
+        this.recruitBoardId = recruitBoardId;
+    }
+}

src/main/java/com/somemore/interestcenter/event/handler/CreateRecruitBoardHandler.java

@@ -0,0 +1,9 @@
+package com.somemore.interestcenter.event.handler;
+
+import com.somemore.recruitboard.event.CreateRecruitBoardEvent;
+
+public interface CreateRecruitBoardHandler {
+
+    void handle(CreateRecruitBoardEvent event);
+
+}

src/main/java/com/somemore/interestcenter/event/handler/CreateRecruitBoardHandlerImpl.java

@@ -0,0 +1,45 @@
+package com.somemore.interestcenter.event.handler;
+
+import com.somemore.global.common.event.ServerEventPublisher;
+import com.somemore.global.common.event.ServerEventType;
+import com.somemore.interestcenter.event.domain.InterestCenterCreateRecruitBoardEvent;
+import com.somemore.interestcenter.usecase.InterestCenterQueryUseCase;
+import com.somemore.notification.domain.NotificationSubType;
+import com.somemore.recruitboard.event.CreateRecruitBoardEvent;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Component;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.util.List;
+import java.util.UUID;
+
+@Component
+@RequiredArgsConstructor
+@Transactional
+public class CreateRecruitBoardHandlerImpl implements CreateRecruitBoardHandler {
+
+    private final InterestCenterQueryUseCase interestCenterQueryUseCase;
+    private final ServerEventPublisher serverEventPublisher;
+
+    @Override
+    public void handle(CreateRecruitBoardEvent createRecruitBoardEvent) {
+        UUID centerId = createRecruitBoardEvent.getCenterId();
+        List<UUID> volunteerIdsByCenterId = interestCenterQueryUseCase.getVolunteerIdsByCenterId(centerId);
+
+        volunteerIdsByCenterId.forEach(volunteerId ->
+                publishInterestCenterCreateRecruitBoardEvent(createRecruitBoardEvent, volunteerId, centerId)
+        );
+    }
+
+    private void publishInterestCenterCreateRecruitBoardEvent(CreateRecruitBoardEvent createRecruitBoardEvent, UUID volunteerId, UUID centerId) {
+        InterestCenterCreateRecruitBoardEvent event = InterestCenterCreateRecruitBoardEvent.builder()
+                .type(ServerEventType.NOTIFICATION)
+                .subType(NotificationSubType.INTEREST_CENTER_CREATE_RECRUIT_BOARD)
+                .volunteerId(volunteerId)
+                .centerId(centerId)
+                .recruitBoardId(createRecruitBoardEvent.getRecruitBoardId())
+                .build();
+
+        serverEventPublisher.publish(event);
+    }
+}

src/main/java/com/somemore/interestcenter/event/subscriber/RedisCreateRecruitBoardSubscriber.java

@@ -0,0 +1,26 @@
+package com.somemore.interestcenter.event.subscriber;
+
+import com.somemore.interestcenter.event.converter.CreateRecruitBoardMessageConverter;
+import com.somemore.interestcenter.event.handler.CreateRecruitBoardHandler;
+import com.somemore.recruitboard.event.CreateRecruitBoardEvent;
+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 RedisCreateRecruitBoardSubscriber implements MessageListener {
+
+    private final CreateRecruitBoardHandler createRecruitBoardHandler;
+    private final CreateRecruitBoardMessageConverter messageConverter;
+
+    @Override
+    public void onMessage(Message message, byte[] pattern) {
+        CreateRecruitBoardEvent event = messageConverter.from(
+                new String(message.getBody())
+        );
+
+        createRecruitBoardHandler.handle(event);
+    }
+}

src/main/java/com/somemore/interestcenter/repository/InterestCenterRepository.java

@@ -12,6 +12,7 @@ public interface InterestCenterRepository {
     Optional<InterestCenter> findById(Long id);
     Optional<RegisterInterestCenterResponseDto> findInterestCenterResponseById(Long id);
     List<UUID> findInterestCenterIdsByVolunteerId(UUID volunteerId);
+    List<UUID> findVolunteerIdsByCenterId(UUID centerId);
     boolean existsByVolunteerIdAndCenterId(UUID volunteerId, UUID centerId);
     Optional<InterestCenter> findByVolunteerIdAndCenterId(UUID volunteerId, UUID centerId);
 }

src/main/java/com/somemore/interestcenter/repository/InterestCenterRepositoryImpl.java

@@ -1,6 +1,7 @@
 package com.somemore.interestcenter.repository;
 
 import com.querydsl.core.types.Projections;
+import com.querydsl.core.types.dsl.BooleanExpression;
 import com.querydsl.jpa.impl.JPAQueryFactory;
 import com.somemore.interestcenter.domain.InterestCenter;
 import com.somemore.interestcenter.domain.QInterestCenter;
@@ -18,20 +19,21 @@ public class InterestCenterRepositoryImpl implements InterestCenterRepository {
     private final JPAQueryFactory queryFactory;
     private final InterestCenterJpaRepository interestCenterJpaRepository;
 
+    private final static QInterestCenter interestCenter = QInterestCenter.interestCenter;
+
     @Override
     public InterestCenter save(InterestCenter interestCenter) {
         return interestCenterJpaRepository.save(interestCenter);
     }
 
     @Override
     public Optional<InterestCenter> findById(Long id) {
-        QInterestCenter interestCenter = QInterestCenter.interestCenter;
 
         InterestCenter result = queryFactory
                 .selectFrom(interestCenter)
                 .where(
                         interestCenter.id.eq(id)
-                                .and(interestCenter.deleted.eq(false))
+                                .and(isNotDeleted())
                 )
                 .fetchOne();
 
@@ -40,7 +42,6 @@ public Optional<InterestCenter> findById(Long id) {
 
     @Override
     public Optional<RegisterInterestCenterResponseDto> findInterestCenterResponseById(Long id) {
-        QInterestCenter interestCenter = QInterestCenter.interestCenter;
 
         RegisterInterestCenterResponseDto result = queryFactory
                 .select(
@@ -54,7 +55,7 @@ public Optional<RegisterInterestCenterResponseDto> findInterestCenterResponseByI
                 .from(interestCenter)
                 .where(
                         interestCenter.id.eq(id)
-                                .and(interestCenter.deleted.eq(false))
+                                .and(isNotDeleted())
                 )
                 .fetchOne();
 
@@ -63,38 +64,49 @@ public Optional<RegisterInterestCenterResponseDto> findInterestCenterResponseByI
 
     @Override
     public List<UUID> findInterestCenterIdsByVolunteerId(UUID volunteerId) {
-        QInterestCenter interestCenter = QInterestCenter.interestCenter;
 
         return queryFactory
                 .select(interestCenter.centerId)
                 .from(interestCenter)
                 .where(
                         interestCenter.volunteerId.eq(volunteerId)
-                                .and(interestCenter.deleted.eq(false))
+                                .and(isNotDeleted())
+                )
+                .fetch();
+    }
+
+    @Override
+    public List<UUID> findVolunteerIdsByCenterId(UUID centerId) {
+
+        return queryFactory
+                .select(interestCenter.volunteerId)
+                .from(interestCenter)
+                .where(
+                        interestCenter.centerId.eq(centerId),
+                        isNotDeleted()
                 )
                 .fetch();
     }
 
     @Override
     public boolean existsByVolunteerIdAndCenterId(UUID volunteerId, UUID centerId) {
-        QInterestCenter interestCenter = QInterestCenter.interestCenter;
 
         Integer result = queryFactory
                 .selectOne()
                 .from(interestCenter)
                 .where(
                         interestCenter.volunteerId.eq(volunteerId)
                                 .and(interestCenter.centerId.eq(centerId))
-                                .and(interestCenter.deleted.eq(false))
+                                .and(isNotDeleted())
                 )
                 .fetchFirst();
 
         return result != null;
     }
 
+
     @Override
     public Optional<InterestCenter> findByVolunteerIdAndCenterId(UUID volunteerId, UUID centerId) {
-        QInterestCenter interestCenter = QInterestCenter.interestCenter;
 
         InterestCenter result = queryFactory.selectFrom(interestCenter)
                 .where(
@@ -106,4 +118,7 @@ public Optional<InterestCenter> findByVolunteerIdAndCenterId(UUID volunteerId, U
         return Optional.ofNullable(result);
     }
 
+    private static BooleanExpression isNotDeleted() {
+        return interestCenter.deleted.eq(false);
+    }
 }