feat: 콜벤 기능 구현 by DHkimgit · Pull Request #2151 · BCSDLab/KOIN_API_V2

DHkimgit · 2026-02-11T13:06:13Z

🔍 개요

신고 기능을 제외한 콜벤 도메인 구현

close [공통] 콜벤 스프린트 기본 기능 구현 #2150

🚀 주요 변경 내용

비동기 이벤트 기반 알림 저장 구현

Spring의 ApplicationEventPublisher와 @TransactionalEventListener를 활용하여 도메인 이벤트 기반 알림 시스템을 구현
구현된 알림 타입
- RECRUITMENT_COMPLETE : 모집 인원 마감 시
- NEW_MESSAGE : 새로운 채팅 메시지 수신 시
- PARTICIPANT_JOINED : 새로운 참여자 합류 시
- DEPARTURE_UPCOMING : 출발 30분 전 알림

sequenceDiagram
    participant Client
    participant Controller
    participant Service
    participant EventPublisher
    participant EventListener
    participant NotificationService
    participant DB

    Client->>Controller: POST /callvan/posts/{id}/participants
    Controller->>Service: join(postId, userId)
    Service->>DB: 참여자 저장
    Service->>EventPublisher: publishEvent(ParticipantJoinedEvent)
    Service-->>Controller: 완료
    Controller-->>Client: 201 Created
    
    Note over EventPublisher,EventListener: 트랜잭션 커밋 후 비동기 실행
    
    EventPublisher->>EventListener: @TransactionalEventListener
    EventListener->>NotificationService: notifyParticipantJoined()
    NotificationService->>DB: 알림 저장 (다른 참여자들에게)

Redis Sorted Set(ZSET) 기반 지연 작업 큐

출발 30분 전 알림을 효율적으로 처리하기 위해 Redis Sorted Set을 활용하여 지연 작업 큐를 구현
매 분마다 스케줄러가 실행되지만 출발 30분 전 1번만 RDB 조회/삽입 작업 수행

sequenceDiagram
    participant PostCreate as 게시글 생성
    participant Scheduler as CallvanNotificationScheduler
    participant Redis as Redis Sorted Set
    participant CronJob as @Scheduled (매분 실행)
    participant DB as Database

    PostCreate->>Scheduler: scheduleNotification(post)
    Scheduler->>Scheduler: 출발시간 - 30분 계산
    Scheduler->>Redis: ZADD (score: timestamp)
    Note over Redis: Key: callvan:notification:queue<br/>Score: 알림 발송 시각 (epoch)

    loop 매분마다
        CronJob->>Redis: ZRANGEBYSCORE (0, now)
        Redis-->>CronJob: 발송 시각 도래한 작업들
        CronJob->>DB: 참여자들에게 알림 생성
        CronJob->>Redis: ZREM (처리 완료된 작업 제거)
    end

DB 폴링 대비 Redis 활용으로 성능 향상 기대

콜벤 가입 API 동시성 제어 적용

@Transactional
@ConcurrencyGuard(lockName = "callvanJoin")
public void join(Integer postId, Integer userId) {

콜벤의 정원이 지정되어 있으므로 정원 초과 등 동시성 문제 발생 가능
https://github.com/BCSDLab/KOIN_API_V2/wiki/%F0%9F%93%9D-%ED%94%84%EB%A1%9C%EC%A0%9D%ED%8A%B8-%EC%96%B4%EB%85%B8%ED%85%8C%EC%9D%B4%EC%85%98-%EC%A0%95%EB%A6%AC#concurrencyguard
구현되어 있는 어노테이션 사용

💬 참고 사항

구현 단위로 커밋 나눠놨습니다.

✅ Checklist (완료 조건)

코드 스타일 가이드 준수
[] 테스트 코드 포함됨
Reviewers / Assignees / Labels 지정 완료
보안 및 민감 정보 검증 (API 키, 환경 변수, 개인정보 등)

github-actions · 2026-02-11T13:12:06Z

Unit Test Results

360 tests 312 ✔️ 4s ⏱️
164 suites     1 💤
164 files   47 ❌

For more details on these failures, see this check.

Results for commit b9ce83f.

♻️ This comment has been updated with latest results.

Soundbar91

고생하셨습니다 ~
feat: 콜벤 게시글 상태 변경 PUT API 3개, feat: 콜벤 게시글 상태 변경 PUT API 3개, feat: 콜벤 게시글 조회 API is_author, is_joined 필드 추가 리뷰입니당

Soundbar91 · 2026-02-13T14:14:03Z

src/main/java/in/koreatech/koin/domain/callvan/service/CallvanPostStatusService.java

+        if (!callvanPost.getAuthor().getId().equals(userId)) {
+            throw CustomException.of(ApiResponseCode.FORBIDDEN_AUTHOR);
+        }


C

콜벤 게시글 작성자 검증 로직을 CallvanPost 내부에 넣어도 괜찮을 거 같아요 !

BaeJinho4028

feat: 콜벤 게시글 상세 정보 조회 GET API
feat: 콜벤 채팅 전송 및 조회 API
feat: 콜벤 알림 API

에 대한 간단 리뷰 남깁니다.

BaeJinho4028 · 2026-02-13T14:18:17Z

src/main/java/in/koreatech/koin/domain/callvan/dto/CallvanPostDetailResponse.java

+) {
+    public static CallvanPostDetailResponse from(CallvanPost post, Integer userId) {
+        String departureName = post.getDepartureType().getName();
+        if (post.getDepartureCustomName() != null && !post.getDepartureCustomName().isBlank()) {


StringUtils.hasText() 써도 좋을거 같아요 1

BaeJinho4028 · 2026-02-13T14:18:22Z

src/main/java/in/koreatech/koin/domain/callvan/dto/CallvanPostDetailResponse.java

+        }
+
+        String arrivalName = post.getArrivalType().getName();
+        if (post.getArrivalCustomName() != null && !post.getArrivalCustomName().isBlank()) {


StringUtils.hasText() 써도 좋을거 같아요 2

BaeJinho4028 · 2026-02-13T14:19:25Z

src/main/java/in/koreatech/koin/domain/callvan/dto/CallvanPostDetailResponse.java

+) {
+    public static CallvanPostDetailResponse from(CallvanPost post, Integer userId) {


줄넘김 이슈

BaeJinho4028 · 2026-02-13T14:19:37Z

src/main/java/in/koreatech/koin/domain/callvan/dto/CallvanPostDetailResponse.java

+    ) {
+        public static CallvanParticipantResponse from(CallvanParticipant participant, Integer userId) {


줄넘김 이슈

BaeJinho4028 · 2026-02-13T14:20:29Z

src/main/java/in/koreatech/koin/domain/callvan/dto/CallvanChatMessageResponse.java

+) {
+    public static CallvanChatMessageResponse of(CallvanPost post, List<CallvanChatMessage> messages, Integer userId) {


줄넘김 이슈

BaeJinho4028 · 2026-02-13T14:21:16Z

src/main/java/in/koreatech/koin/domain/callvan/dto/CallvanChatMessageResponse.java

+        @Schema(description = "내 메시지 여부", example = "true")
+        Boolean isMine
+    ) {
+        public static CallvanMessageDto from(CallvanChatMessage message, Integer currentUserId) {


줄넘김 이슈

BaeJinho4028 · 2026-02-13T14:22:19Z

src/main/java/in/koreatech/koin/domain/callvan/model/CallvanParticipant.java

+        if(this.isDeleted) {
+            this.isDeleted = false;
+        }
+    }
+
+    public void leaveCallvan() {
+        if(!this.isDeleted) {
+            this.isDeleted = true;
+        }


둘다 if문이 필요 없을지도요

BaeJinho4028 · 2026-02-13T14:23:12Z

src/main/java/in/koreatech/koin/domain/callvan/service/CallvanChatService.java

+        if (user.getNickname() != null) {
+            return user.getNickname();
+        }
+        if (user.getAnonymousNickname() != null) {
+            return user.getAnonymousNickname();
+        }


중복되어서 이게 모델에서 공통으로 처리를 해주거나, 근본적으로 해결할 수 있는 방법이 있을 거 같아요.

BaeJinho4028 · 2026-02-13T14:25:11Z

src/main/java/in/koreatech/koin/domain/callvan/service/CallvanPostJoinService.java

+        if (user.getNickname() != null) {
+            return user.getNickname();
+        }
+        if (user.getAnonymousNickname() != null) {
+            return user.getAnonymousNickname();
+        }


또 중복되네요

BaeJinho4028 · 2026-02-13T14:25:43Z

src/main/java/in/koreatech/koin/domain/callvan/dto/CallvanNotificationResponse.java

+        if (notification.getDepartureCustomName() != null && !notification.getDepartureCustomName().isBlank()) {
+            departureName = notification.getDepartureCustomName();
+        }
+
+        String arrivalName = notification.getArrivalType().getName();
+        if (notification.getArrivalCustomName() != null && !notification.getArrivalCustomName().isBlank()) {
+            arrivalName = notification.getArrivalCustomName();
+        }


이것도 중복으로 나타나네요

dh2906 · 2026-02-13T14:36:01Z

src/main/java/in/koreatech/koin/domain/callvan/controller/CallvanApi.java

+        #### 비즈니스 로직
+        1. 출발지/도착지 필터링 시, 선택된 장소 타입들에 해당하는 게시글을 조회합니다.
+        2. `CUSTOM` 타입이 선택되고 키워드가 입력된 경우, 사용자가 직접 입력한 장소명에서 해당 키워드를 포함하는 게시글도 결과에 포함됩니다.
+        3. 정렬 기준이 `DEPARTURE`인 경우, 출발 날짜와 시간 순으로 내림차순(최신 순) 정렬됩니다.


명세에서는 내림차순 정렬로 되어있는데, CallvanPostQueryRepository에서 135번째 줄 메소드는 오름차순으로 정렬 되어있는 것 같으로 보여요!

DHkimgit added 10 commits February 11, 2026 00:28

feat: 콜벤 등록 POST API

60bd4cf

feat: 콜벤 등록 POST API 커스텀 장소 검증 로직 추가

532326c

feat: 콜벤 게시글 조회 GET API

e288039

feat: 콜벤 참여 POST API

9586a0b

feat: 콜벤 게시글 조회 API is_author, is_joined 필드 추가

7fc572c

feat: 콜벤 게시글 상태 변경 PUT API 3개

dd808ce

feat: 콜벤 게시글 상태 변경 PUT API 3개

8cbba16

feat: 콜벤 게시글 상세 정보 조회 GET API

c2907f8

feat: 콜벤 채팅 전송 및 조회 API

01f5e4e

feat: 콜벤 알림 API

a01d3ef

DHkimgit requested review from BaeJinho4028, ImTotem, Soundbar91, dh2906 and taejinn February 11, 2026 13:06

DHkimgit self-assigned this Feb 11, 2026

DHkimgit added 기능 새로운 기능을 개발합니다. Team Campus 캠퍼스 팀에서 작업할 이슈입니다 labels Feb 11, 2026

github-actions bot requested review from duehee and krSeonghyeon February 11, 2026 13:06

Soundbar91 approved these changes Feb 13, 2026

View reviewed changes

BaeJinho4028 reviewed Feb 13, 2026

View reviewed changes

dh2906 reviewed Feb 13, 2026

View reviewed changes

DHkimgit added 4 commits February 14, 2026 15:25

fix: 리뷰 반영

4239b61

feat: 콜벤 게시글 조회 GET API 정렬 필터 추가

bb16afa

feat: 콜벤 게시글 조회 GET API 상태 필터 List 기반으로 변경

6f01f6c

fix: 닉네임 로직 리뷰 반영

1c817d7

fix: 문서 수정

b9ce83f

		) {
		public static CallvanPostDetailResponse from(CallvanPost post, Integer userId) {

		) {
		public static CallvanParticipantResponse from(CallvanParticipant participant, Integer userId) {

		) {
		public static CallvanChatMessageResponse of(CallvanPost post, List<CallvanChatMessage> messages, Integer userId) {

Conversation

DHkimgit commented Feb 11, 2026 • edited Loading Uh oh! There was an error while loading. Please reload this page.

Uh oh!

🔍 개요

🚀 주요 변경 내용

비동기 이벤트 기반 알림 저장 구현

Redis Sorted Set(ZSET) 기반 지연 작업 큐

콜벤 가입 API 동시성 제어 적용

💬 참고 사항

✅ Checklist (완료 조건)

Uh oh!

github-actions bot commented Feb 11, 2026 • edited Loading Uh oh! There was an error while loading. Please reload this page.

Uh oh!

Unit Test Results

Uh oh!

Soundbar91 left a comment • edited Loading Uh oh! There was an error while loading. Please reload this page.

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

C

Uh oh!

BaeJinho4028 left a comment

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Reviewers

Assignees

Labels

Projects

Milestone

Development

Uh oh!

4 participants

DHkimgit commented Feb 11, 2026 •

edited

Loading

github-actions bot commented Feb 11, 2026 •

edited

Loading

Soundbar91 left a comment •

edited

Loading