Skip to content

[feat] 알림센터 알림 or 푸시알림 클릭 시 BE 로직 구현 #309

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
seongjunnoh merged 29 commits into from
Sep 23, 2025
Merged

[feat] 알림센터 알림 or 푸시알림 클릭 시 BE 로직 구현 #309

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
29 commits
Select commit Hold shift + click to select a range
543820f
[chore] notifications table 구조 변경을 위한 sql 파일 추가 (#308)
seongjunnoh Sep 22, 2025
c9165c1
[feat] NotificationJpaEntity 에 추가할 data 및 컨버터 추가 (#308)
seongjunnoh Sep 22, 2025
f51edcc
[refactor] 수정된 notification 구조에 따라 jpa, 도메인 엔티티 및 mapper 코드 수정 (#308)
seongjunnoh Sep 22, 2025
75d058a
[rename] 피드 관련 알림 처리하는 메서드 네이밍 수정 (#308)
seongjunnoh Sep 22, 2025
100eb32
[refactor] fcm 푸시 알림을 위한 이벤트 퍼블리시 시에 notificationId 추가 및 리다이렉트를 위한 다른…
seongjunnoh Sep 22, 2025
c352794
[refactor] 알림 동기 처리 executor 코드 수정 (#308)
seongjunnoh Sep 22, 2025
22ecd82
[refactor] FeedNotificationOrchestratorSyncImpl 코드 수정 (#308)
seongjunnoh Sep 22, 2025
3480f73
[refactor] FeedNotificationOrchestratorSyncImpl 의 테스트 코드 수정 (#308)
seongjunnoh Sep 22, 2025
698c5c7
[refactor] RoomNotificationOrchestratorSyncImpl 코드 수정 (#308)
seongjunnoh Sep 22, 2025
cd275df
[refactor] RoomNotificationOrchestratorSyncImpl 의 테스트 코드 수정 (#308)
seongjunnoh Sep 22, 2025
6929522
[refactor] fcm 푸시알림을 위한 이벤트 퍼블리시 관련 코드 수정 (#308)
seongjunnoh Sep 22, 2025
b8b456c
[refactor] fcm 푸시알림을 위한 이벤트 리스너 관련 코드 수정 (#308)
seongjunnoh Sep 22, 2025
9b22d5a
[refactor] fcm 푸시알림을 위한 이벤트 리스너 관련 테스트 코드 수정 (#308)
seongjunnoh Sep 22, 2025
d957988
[feat] 알림 읽음 처리 api controller 구현 (#308)
seongjunnoh Sep 22, 2025
b04aebb
[feat] 알림 읽음 처리 api use case 구현 (#308)
seongjunnoh Sep 22, 2025
7359995
[feat] 알림 읽음 처리 api 영속성 코드 구현 (#308)
seongjunnoh Sep 22, 2025
dc5c3b1
[feat] 알림 관련 error code 추가 (#308)
seongjunnoh Sep 22, 2025
d81ed04
[feat] 알림 읽음 처리 api 관련 스웨거 ResponseDescription 추가 (#308)
seongjunnoh Sep 22, 2025
792edd2
[test] 알림 읽음 처리 api 통합 테스트 코드 추가 (#308)
seongjunnoh Sep 22, 2025
c1ef1b6
[test] Notification 도메인 엔티티 단위 테스트 코드 추가 (#308)
seongjunnoh Sep 22, 2025
91f312a
[move] PlatformType enum 에 정적 팩토리 메서드 추가 및 패키지 구조 이동 (#308)
seongjunnoh Sep 22, 2025
af90d6b
[refactor] 기존 fcm 토큰 등록 api 의 request body 유효성 검증 강화 (#308)
seongjunnoh Sep 22, 2025
4c2778a
[refactor] PlatformType 패키지 구조 이동에 따른 import 문 수정 (#308)
seongjunnoh Sep 22, 2025
1f061a3
[refactor] MessageRoute 수정 및 패키지 이동 (#308)
seongjunnoh Sep 22, 2025
4b6e9c5
Merge remote-tracking branch 'origin' into feat/#308-notification-red…
seongjunnoh Sep 22, 2025
7459b5f
[rename] 네이밍 수정 (#308)
seongjunnoh Sep 23, 2025
48394c0
[refactor] request dto bean validation error message 추가 (#308)
seongjunnoh Sep 23, 2025
8d4ba69
[move] PlatformType enum 패키지 이동 (#308)
seongjunnoh Sep 23, 2025
57f9970
[docs] api 명세 추가 (#308)
seongjunnoh Sep 23, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
11 changes: 11 additions & 0 deletions src/main/java/konkuk/thip/common/exception/code/ErrorCode.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -231,6 +231,17 @@ public enum ErrorCode implements ResponseCode {
* 205000 : notification error
*/
INVALID_NOTIFICATION_TYPE(HttpStatus.BAD_REQUEST, 205000, "유효하지 않은 알림 타입입니다."),
NOTIFICATION_REDIRECT_DATA_SERIALIZE_FAILED(HttpStatus.INTERNAL_SERVER_ERROR, 205001, "알림 리다이렉트 데이터 직렬화에 실패했습니다."),
NOTIFICATION_REDIRECT_DATA_DESERIALIZE_FAILED(HttpStatus.INTERNAL_SERVER_ERROR, 205002, "알림 리다이렉트 데이터 역직렬화에 실패했습니다."),
NOTIFICATION_NOT_FOUND(HttpStatus.NOT_FOUND, 205003, "존재하지 않는 NOTIFICATION 입니다."),
NOTIFICATION_ACCESS_FORBIDDEN(HttpStatus.FORBIDDEN, 205004, "알림 접근 권한이 없습니다."),
NOTIFICATION_ALREADY_CHECKED(HttpStatus.BAD_REQUEST, 205005, "이미 읽음 처리된 알림입니다."),


/**
* 300000 : util error
*/
INVALID_FE_PLATFORM(HttpStatus.BAD_REQUEST, 300000, "유효하지 않은 FE 플랫폼입니다."),

;

Expand Down
8 changes: 7 additions & 1 deletion src/main/java/konkuk/thip/common/swagger/SwaggerResponseDescription.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -358,7 +358,8 @@ public enum SwaggerResponseDescription {
// Notiification
FCM_TOKEN_REGISTER(new LinkedHashSet<>(Set.of(
USER_NOT_FOUND,
FCM_TOKEN_NOT_FOUND
FCM_TOKEN_NOT_FOUND,
INVALID_FE_PLATFORM
))),
FCM_TOKEN_ENABLE_STATE_CHANGE(new LinkedHashSet<>(Set.of(
USER_NOT_FOUND,
Expand All @@ -376,6 +377,11 @@ public enum SwaggerResponseDescription {
NOTIFICATION_SHOW(new LinkedHashSet<>(Set.of(
INVALID_NOTIFICATION_TYPE
))),
NOTIFICATION_MARK_TO_CHECKED(new LinkedHashSet<>(Set.of(
NOTIFICATION_NOT_FOUND,
NOTIFICATION_ACCESS_FORBIDDEN,
NOTIFICATION_ALREADY_CHECKED
))),

;
private final Set<ErrorCode> errorCodeList;
Expand Down
2 changes: 1 addition & 1 deletion src/main/java/konkuk/thip/feed/application/service/FeedCreateService.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -71,7 +71,7 @@ private void sendNotifications(FeedCreateCommand command, Long savedFeedId) {
List<User> targetUsers = userQueryPort.getAllFollowersByUserId(command.userId());
User actorUser = userCommandPort.findById(command.userId());
for (User targetUser : targetUsers) {
feedNotificationOrchestrator.notifyFolloweeNewPost(targetUser.getId(), actorUser.getId(), actorUser.getNickname(), savedFeedId);
feedNotificationOrchestrator.notifyFolloweeNewFeed(targetUser.getId(), actorUser.getId(), actorUser.getNickname(), savedFeedId);
Copy link
Member

@hd0rable hd0rable Sep 22, 2025

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

오호 피드 게시물일때 이름을 좀더 명확하게 수정하셨군욧 좋네요

}
}

Expand Down
4 changes: 2 additions & 2 deletions src/main/java/konkuk/thip/message/adapter/in/event/MessageFeedEventListener.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -34,8 +34,8 @@ public void onFeedCommentReplied(FeedEvents.FeedCommentRepliedEvent e) {

@Async
@TransactionalEventListener(phase = TransactionPhase.AFTER_COMMIT)
public void onFolloweeNewPost(FeedEvents.FolloweeNewPostEvent e) {
feedUseCase.handleFolloweeNewPost(e);
public void onFolloweeNewFeed(FeedEvents.FolloweeNewFeedEvent e) {
feedUseCase.handleFolloweeNewFeed(e);
}

@Async
Expand Down
58 changes: 21 additions & 37 deletions src/main/java/konkuk/thip/message/adapter/out/event/FeedEventPublisherAdapter.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -14,89 +14,73 @@ public class FeedEventPublisherAdapter implements FeedEventCommandPort {

@Override
public void publishFollowEvent(
String title, String content,
Long targetUserId, Long actorUserId, String actorUsername) {
String title, String content, Long notificationId,
Long targetUserId) {
publisher.publishEvent(FeedEvents.FollowerEvent.builder()
.title(title)
.content(content)
.notificationId(notificationId)
.targetUserId(targetUserId)
.actorUserId(actorUserId)
.actorUsername(actorUsername)
.build());
}

@Override
public void publishFeedCommentedEvent(
String title, String content,
Long targetUserId, Long actorUserId, String actorUsername,
Long feedId) {
String title, String content, Long notificationId,
Long targetUserId) {
publisher.publishEvent(FeedEvents.FeedCommentedEvent.builder()
.title(title)
.content(content)
.notificationId(notificationId)
.targetUserId(targetUserId)
.actorUserId(actorUserId)
.actorUsername(actorUsername)
.feedId(feedId)
.build());
}

@Override
public void publishFeedRepliedEvent(
String title, String content,
Long targetUserId, Long actorUserId, String actorUsername,
Long feedId) {
String title, String content, Long notificationId,
Long targetUserId) {
publisher.publishEvent(FeedEvents.FeedCommentRepliedEvent.builder()
.title(title)
.content(content)
.notificationId(notificationId)
.targetUserId(targetUserId)
.actorUserId(actorUserId)
.actorUsername(actorUsername)
.feedId(feedId)
.build());
}

@Override
public void publishFolloweeNewPostEvent(
String title, String content,
Long targetUserId, Long actorUserId, String actorUsername,
Long feedId) {
publisher.publishEvent(FeedEvents.FolloweeNewPostEvent.builder()
public void publishFolloweeNewFeedEvent(
String title, String content, Long notificationId,
Long targetUserId) {
publisher.publishEvent(FeedEvents.FolloweeNewFeedEvent.builder()
.title(title)
.content(content)
.notificationId(notificationId)
.targetUserId(targetUserId)
.actorUserId(actorUserId)
.actorUsername(actorUsername)
.feedId(feedId)
.build());
}

@Override
public void publishFeedLikedEvent(
String title, String content,
Long targetUserId, Long actorUserId, String actorUsername,
Long feedId) {
String title, String content, Long notificationId,
Long targetUserId) {
publisher.publishEvent(FeedEvents.FeedLikedEvent.builder()
.title(title)
.content(content)
.notificationId(notificationId)
.targetUserId(targetUserId)
.actorUserId(actorUserId)
.actorUsername(actorUsername)
.feedId(feedId)
.build());
}

@Override
public void publishFeedCommentLikedEvent(
String title, String content,
Long targetUserId, Long actorUserId, String actorUsername,
Long feedId) {
String title, String content, Long notificationId,
Long targetUserId) {
publisher.publishEvent(FeedEvents.FeedCommentLikedEvent.builder()
.title(title)
.content(content)
.notificationId(notificationId)
.targetUserId(targetUserId)
.actorUserId(actorUserId)
.actorUsername(actorUsername)
.feedId(feedId)
.build());
}
}
}
97 changes: 29 additions & 68 deletions src/main/java/konkuk/thip/message/adapter/out/event/RoomEventPublisherAdapter.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -14,148 +14,109 @@ public class RoomEventPublisherAdapter implements RoomEventCommandPort {

@Override
public void publishRoomPostCommentedEvent(
String title, String content,
Long targetUserId, Long actorUserId, String actorUsername,
Long roomId, Integer page, Long postId, String postType) {
String title, String content, Long notificationId,
Long targetUserId) {
publisher.publishEvent(RoomEvents.RoomPostCommentedEvent.builder()
.title(title)
.content(content)
.notificationId(notificationId)
.targetUserId(targetUserId)
.actorUserId(actorUserId)
.actorUsername(actorUsername)
.roomId(roomId)
.page(page)
.postId(postId)
.postType(postType)
.build());
}

@Override
public void publishRoomVoteStartedEvent(
String title, String content,
Long targetUserId, Long roomId, String roomTitle,
Integer page, Long postId) {
String title, String content, Long notificationId,
Long targetUserId) {
publisher.publishEvent(RoomEvents.RoomVoteStartedEvent.builder()
.title(title)
.content(content)
.notificationId(notificationId)
.targetUserId(targetUserId)
.roomId(roomId)
.roomTitle(roomTitle)
.page(page)
.postId(postId)
.build());
}

@Override
public void publishRoomRecordCreatedEvent(
String title, String content,
Long targetUserId, Long actorUserId, String actorUsername,
Long roomId, String roomTitle, Integer page, Long postId) {
String title, String content, Long notificationId,
Long targetUserId) {
publisher.publishEvent(RoomEvents.RoomRecordCreatedEvent.builder()
.title(title)
.content(content)
.notificationId(notificationId)
.targetUserId(targetUserId)
.actorUserId(actorUserId)
.actorUsername(actorUsername)
.roomId(roomId)
.roomTitle(roomTitle)
.page(page)
.postId(postId)
.build());
}

@Override
public void publishRoomRecruitClosedEarlyEvent(
String title, String content,
Long targetUserId, Long roomId, String roomTitle) {
String title, String content, Long notificationId,
Long targetUserId) {
publisher.publishEvent(RoomEvents.RoomRecruitClosedEarlyEvent.builder()
.title(title)
.content(content)
.notificationId(notificationId)
.targetUserId(targetUserId)
.roomId(roomId)
.roomTitle(roomTitle)
.build());
}

@Override
public void publishRoomActivityStartedEvent(
String title, String content,
Long targetUserId, Long roomId, String roomTitle) {
String title, String content, Long notificationId,
Long targetUserId) {
publisher.publishEvent(RoomEvents.RoomActivityStartedEvent.builder()
.title(title)
.content(content)
.notificationId(notificationId)
.targetUserId(targetUserId)
.roomId(roomId)
.roomTitle(roomTitle)
.build());
}

@Override
public void publishRoomJoinEventToHost(
String title, String content,
Long hostUserId, Long roomId, String roomTitle,
Long actorUserId, String actorUsername) {
String title, String content, Long notificationId,
Long targetUserId) {
publisher.publishEvent(RoomEvents.RoomJoinRequestedToOwnerEvent.builder()
.title(title)
.content(content)
.ownerUserId(hostUserId)
.roomId(roomId)
.roomTitle(roomTitle)
.applicantUserId(actorUserId)
.applicantUsername(actorUsername)
.notificationId(notificationId)
.targetUserId(targetUserId)
.build());
}

@Override
public void publishRoomCommentLikedEvent(
String title, String content,
Long targetUserId, Long actorUserId, String actorUsername,
Long roomId, Integer page, Long postId, String postType) {
String title, String content, Long notificationId,
Long targetUserId) {
publisher.publishEvent(RoomEvents.RoomCommentLikedEvent.builder()
.title(title)
.content(content)
.notificationId(notificationId)
.targetUserId(targetUserId)
.actorUserId(actorUserId)
.actorUsername(actorUsername)
.roomId(roomId)
.page(page)
.postId(postId)
.postType(postType)
.build());
}

@Override
public void publishRoomPostLikedEvent(
String title, String content,
Long targetUserId, Long actorUserId, String actorUsername,
Long roomId, Integer page, Long postId, String postType) {
String title, String content, Long notificationId,
Long targetUserId) {
publisher.publishEvent(RoomEvents.RoomPostLikedEvent.builder()
.title(title)
.content(content)
.notificationId(notificationId)
.targetUserId(targetUserId)
.actorUserId(actorUserId)
.actorUsername(actorUsername)
.roomId(roomId)
.page(page)
.postId(postId)
.postType(postType)
.build());
}

@Override
public void publishRoomPostCommentRepliedEvent(
String title, String content,
Long targetUserId, Long actorUserId, String actorUsername, Long roomId, Integer page, Long postId, String postType) {
String title, String content, Long notificationId,
Long targetUserId) {
publisher.publishEvent(RoomEvents.RoomPostCommentRepliedEvent.builder()
.title(title)
.content(content)
.notificationId(notificationId)
.targetUserId(targetUserId)
.actorUserId(actorUserId)
.actorUsername(actorUsername)
.roomId(roomId)
.page(page)
.postId(postId)
.postType(postType)
.build());
}
}
}
Loading