diff --git a/feed-domain/src/main/java/com/xquare/v1servicefeed/comment/api/impl/CommentApiImpl.java b/feed-domain/src/main/java/com/xquare/v1servicefeed/comment/api/impl/CommentApiImpl.java index 1cc4f20c..1c15f109 100644 --- a/feed-domain/src/main/java/com/xquare/v1servicefeed/comment/api/impl/CommentApiImpl.java +++ b/feed-domain/src/main/java/com/xquare/v1servicefeed/comment/api/impl/CommentApiImpl.java @@ -9,6 +9,7 @@ import com.xquare.v1servicefeed.comment.spi.CommandCommentSpi; import com.xquare.v1servicefeed.comment.spi.QueryCommentSpi; import com.xquare.v1servicefeed.configuration.spi.SecuritySpi; +import com.xquare.v1servicefeed.feed.CategoryEnum; import com.xquare.v1servicefeed.feed.Feed; import com.xquare.v1servicefeed.feed.spi.QueryFeedSpi; import com.xquare.v1servicefeed.notification.NotificationSpi; @@ -35,7 +36,8 @@ public class CommentApiImpl implements CommentApi { private final QueryCommentSpi queryCommentSpi; private final SecuritySpi securitySpi; private final NotificationSpi notificationSpi; - private static final String FEED_COMMENT = "FEED_COMMENT"; + private static final String FEED_NOTICE_COMMENT = "FEED_NOTICE_COMMENT"; + private static final String FEED_BAMBOO_COMMENT = "FEED_BAMBOO_COMMENT"; private static final String CONTENT = "댓글이 달렸습니다."; @Override @@ -52,9 +54,17 @@ public void saveComment(CreateCommentDomainRequest request) { .build() ); + if (feed.getType().equals(CategoryEnum.NOTICE.getName())) { + sendNotification(FEED_NOTICE_COMMENT, feed); + } else { + sendNotification(FEED_BAMBOO_COMMENT, feed); + } + } + + private void sendNotification(String topic, Feed feed) { notificationSpi.sendNotification( feed.getUserId(), - FEED_COMMENT, + topic, CONTENT, feed.getId().toString() ); diff --git a/feed-domain/src/main/java/com/xquare/v1servicefeed/feedlike/api/impl/FeedLikeApiImpl.java b/feed-domain/src/main/java/com/xquare/v1servicefeed/feedlike/api/impl/FeedLikeApiImpl.java index 1ecfcc96..47a2cade 100644 --- a/feed-domain/src/main/java/com/xquare/v1servicefeed/feedlike/api/impl/FeedLikeApiImpl.java +++ b/feed-domain/src/main/java/com/xquare/v1servicefeed/feedlike/api/impl/FeedLikeApiImpl.java @@ -2,6 +2,7 @@ import com.xquare.v1servicefeed.annotation.DomainService; import com.xquare.v1servicefeed.configuration.spi.SecuritySpi; +import com.xquare.v1servicefeed.feed.CategoryEnum; import com.xquare.v1servicefeed.feed.Feed; import com.xquare.v1servicefeed.feed.spi.QueryFeedSpi; import com.xquare.v1servicefeed.feedlike.FeedLike; @@ -23,6 +24,9 @@ public class FeedLikeApiImpl implements FeedLikeApi { private final QueryFeedLikeSpi queryFeedLikeSpi; private final SecuritySpi securitySpi; private final NotificationSpi notificationSpi; + private static final String FEED_NOTICE_LIKE = "FEED_NOTICE_COMMENT"; + private static final String FEED_BAMBOO_LIKE = "FEED_BAMBOO_COMMENT"; + private static final String CONTENT = "좋아요가 달렸습니다."; @Override public void saveFeedLike(UUID feedId) { @@ -40,10 +44,18 @@ public void saveFeedLike(UUID feedId) { .build() ); + if (feed.getType().equals(CategoryEnum.NOTICE.getName())) { + sendNotification(FEED_NOTICE_LIKE, feed); + } else { + sendNotification(FEED_BAMBOO_LIKE, feed); + } + } + + private void sendNotification(String topic, Feed feed) { notificationSpi.sendNotification( feed.getUserId(), - "FEED_LIKE", - "좋아요가 달렸습니다.", + topic, + CONTENT, feed.getId().toString() ); }