-
Notifications
You must be signed in to change notification settings - Fork 7
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Browse files
Browse the repository at this point in the history
* feat: repository 의존성 제거, 테스트 명확하게 변경 * feat: Reader/Writer 통해 조회 로직 분리 * feat: 룸 수정 기능 구현 * refactor: 피드백 반영 * fix: 충돌 해결 --------- Co-authored-by: youngsu5582 <[email protected]>
- Loading branch information
1 parent
6cd7484
commit ab2235b
Showing
20 changed files
with
832 additions
and
414 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
76 changes: 76 additions & 0 deletions
76
backend/src/main/java/corea/room/dto/RoomUpdateRequest.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,76 @@ | ||
package corea.room.dto; | ||
|
||
import com.fasterxml.jackson.annotation.JsonFormat; | ||
import corea.member.domain.Member; | ||
import corea.room.domain.Room; | ||
import corea.room.domain.RoomClassification; | ||
import corea.room.domain.RoomStatus; | ||
import io.swagger.v3.oas.annotations.media.Schema; | ||
import jakarta.validation.constraints.NotBlank; | ||
import jakarta.validation.constraints.NotNull; | ||
|
||
import java.time.LocalDateTime; | ||
import java.util.List; | ||
|
||
@Schema(description = "방 수정 요청") | ||
public record RoomUpdateRequest( | ||
@Schema(description = "방 ID", example = "99") | ||
@NotBlank | ||
long roomId, | ||
|
||
@Schema(description = "방 제목", example = "MVC를 아시나요?") | ||
@NotBlank | ||
String title, | ||
|
||
@Schema(description = "방 내용", example = "MVC 패턴을 아시나요?") | ||
String content, | ||
|
||
@Schema(description = "repository 링크", example = "https://github.com/example/java-racingcar") | ||
@NotBlank | ||
String repositoryLink, | ||
|
||
@Schema(description = "썸네일 링크", example = "https://gongu.copyright.or.kr/gongu/wrt/cmmn/wrtFileImageView.do?wrtSn=13301655&filePath=L2Rpc2sxL25ld2RhdGEvMjAyMS8yMS9DTFMxMDAwNC8xMzMwMTY1NV9XUlRfMjFfQ0xTMTAwMDRfMjAyMTEyMTNfMQ==&thumbAt=Y&thumbSe=b_tbumb&wrtTy=10004") | ||
String thumbnailLink, | ||
|
||
@Schema(description = "상호 리뷰 인원", example = "2") | ||
@NotNull | ||
int matchingSize, | ||
|
||
@Schema(description = "중심으로 리뷰하면 좋은 키워드", example = "[\"TDD\", \"클린코드\"]") | ||
List<String> keywords, | ||
|
||
@Schema(description = "제한 참여 인원", example = "200") | ||
@NotNull | ||
int limitedParticipants, | ||
|
||
@Schema(description = "모집 마감일", example = "2024-07-30 15:00") | ||
@NotNull | ||
@JsonFormat(pattern = "yyyy-MM-dd HH:mm") | ||
LocalDateTime recruitmentDeadline, | ||
|
||
@Schema(description = "리뷰 마감일", example = "2024-08-10 23:59") | ||
@NotNull | ||
@JsonFormat(pattern = "yyyy-MM-dd HH:mm") | ||
LocalDateTime reviewDeadline, | ||
|
||
@Schema(description = "방이 속하는 분야", example = "BE") | ||
@NotNull | ||
RoomClassification classification | ||
) { | ||
|
||
private static final int INITIAL_PARTICIPANTS_SIZE = 1; | ||
private static final RoomStatus INITIAL_ROOM_STATUS = RoomStatus.OPEN; | ||
|
||
public Room toEntity(Member manager) { | ||
return new Room( | ||
roomId, | ||
title, content, | ||
matchingSize, repositoryLink, | ||
thumbnailLink, keywords, | ||
INITIAL_PARTICIPANTS_SIZE, limitedParticipants, | ||
manager, recruitmentDeadline, | ||
reviewDeadline, classification, | ||
INITIAL_ROOM_STATUS | ||
); | ||
} | ||
} |
84 changes: 84 additions & 0 deletions
84
backend/src/main/java/corea/room/service/RoomAutomaticService.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,84 @@ | ||
package corea.room.service; | ||
|
||
import corea.room.domain.Room; | ||
import corea.scheduler.domain.*; | ||
import corea.scheduler.service.*; | ||
import lombok.RequiredArgsConstructor; | ||
import lombok.extern.slf4j.Slf4j; | ||
import org.springframework.boot.context.event.ApplicationReadyEvent; | ||
import org.springframework.context.event.EventListener; | ||
import org.springframework.stereotype.Service; | ||
import org.springframework.transaction.annotation.Transactional; | ||
|
||
import java.util.List; | ||
|
||
@Slf4j | ||
@Service | ||
@RequiredArgsConstructor | ||
@Transactional(readOnly = true) | ||
public class RoomAutomaticService { | ||
|
||
private final AutomaticUpdateWriter automaticUpdateWriter; | ||
private final AutomaticUpdateReader automaticUpdateReader; | ||
|
||
private final AutomaticMatchingWriter automaticMatchingWriter; | ||
private final AutomaticMatchingReader automaticMatchingReader; | ||
|
||
private final AutomaticMatchingScheduler automaticMatchingScheduler; | ||
private final AutomaticUpdateScheduler automaticUpdateScheduler; | ||
|
||
@Transactional | ||
public void updateTime(Room updateRoom) { | ||
AutomaticMatching automaticMatching = automaticMatchingReader.findWithRoom(updateRoom); | ||
AutomaticUpdate automaticUpdate = automaticUpdateReader.findWithRoom(updateRoom); | ||
|
||
automaticMatchingWriter.updateTime(automaticMatching, updateRoom.getRecruitmentDeadline()); | ||
automaticUpdateWriter.updateTime(automaticUpdate, updateRoom.getReviewDeadline()); | ||
|
||
automaticMatchingScheduler.modifyTask(updateRoom); | ||
automaticUpdateScheduler.modifyTask(updateRoom); | ||
} | ||
|
||
@Transactional | ||
public void createAutomatic(Room room) { | ||
automaticMatchingWriter.create(room); | ||
automaticUpdateWriter.create(room); | ||
|
||
automaticMatchingScheduler.matchOnRecruitmentDeadline(room); | ||
automaticUpdateScheduler.updateAtReviewDeadline(room); | ||
} | ||
|
||
@Transactional | ||
public void deleteAutomatic(Room room) { | ||
AutomaticMatching automaticMatching = automaticMatchingReader.findWithRoom(room); | ||
AutomaticUpdate automaticUpdate = automaticUpdateReader.findWithRoom(room); | ||
|
||
automaticMatchingWriter.delete(automaticMatching); | ||
automaticUpdateWriter.delete(automaticUpdate); | ||
|
||
automaticMatchingScheduler.cancel(room.getId()); | ||
automaticUpdateScheduler.cancel(room.getId()); | ||
} | ||
|
||
@EventListener(ApplicationReadyEvent.class) | ||
public void schedulePendingAutomaticMatching() { | ||
List<AutomaticMatching> matchings = automaticMatchingReader.findAllByStatus(ScheduleStatus.PENDING); | ||
|
||
log.info("{}개의 방에 대해 자동 매칭 재예약 시작", matchings.size()); | ||
|
||
matchings.forEach(automaticMatchingScheduler::matchOnRecruitmentDeadline); | ||
|
||
log.info("{}개의 방에 대해 자동 매칭 재예약 완료", matchings.size()); | ||
} | ||
|
||
@EventListener(ApplicationReadyEvent.class) | ||
public void schedulePendingAutomaticUpdate() { | ||
List<AutomaticUpdate> updates = automaticUpdateReader.findAllByStatus(ScheduleStatus.PENDING); | ||
|
||
log.info("{}개의 방에 대해 자동 상태 업데이트 재예약 시작", updates.size()); | ||
|
||
updates.forEach(automaticUpdateScheduler::updateAtReviewDeadline); | ||
|
||
log.info("{}개의 방에 대해 자동 상태 업데이트 재예약 완료", updates.size()); | ||
} | ||
} |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
28 changes: 28 additions & 0 deletions
28
backend/src/main/java/corea/scheduler/domain/AutomaticMatchingReader.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,28 @@ | ||
package corea.scheduler.domain; | ||
|
||
import corea.exception.CoreaException; | ||
import corea.exception.ExceptionType; | ||
import corea.room.domain.Room; | ||
import corea.scheduler.repository.AutomaticMatchingRepository; | ||
import lombok.RequiredArgsConstructor; | ||
import org.springframework.stereotype.Component; | ||
import org.springframework.transaction.annotation.Transactional; | ||
|
||
import java.util.List; | ||
|
||
@Component | ||
@RequiredArgsConstructor | ||
@Transactional(readOnly = true) | ||
public class AutomaticMatchingReader { | ||
|
||
private final AutomaticMatchingRepository automaticMatchingRepository; | ||
|
||
public AutomaticMatching findWithRoom(Room room) { | ||
return automaticMatchingRepository.findByRoomId(room.getId()) | ||
.orElseThrow(() -> new CoreaException(ExceptionType.AUTOMATIC_MATCHING_NOT_FOUND)); | ||
} | ||
|
||
public List<AutomaticMatching> findAllByStatus(ScheduleStatus status) { | ||
return automaticMatchingRepository.findAllByStatus(status); | ||
} | ||
} |
36 changes: 36 additions & 0 deletions
36
backend/src/main/java/corea/scheduler/domain/AutomaticMatchingWriter.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,36 @@ | ||
package corea.scheduler.domain; | ||
|
||
import corea.room.domain.Room; | ||
import corea.scheduler.repository.AutomaticMatchingRepository; | ||
import lombok.RequiredArgsConstructor; | ||
import org.springframework.stereotype.Component; | ||
import org.springframework.transaction.annotation.Transactional; | ||
|
||
import java.time.LocalDateTime; | ||
|
||
@Component | ||
@RequiredArgsConstructor | ||
@Transactional | ||
public class AutomaticMatchingWriter { | ||
|
||
private final AutomaticMatchingRepository automaticMatchingRepository; | ||
|
||
public AutomaticMatching updateTime(AutomaticMatching automaticMatching, LocalDateTime matchingStartTime) { | ||
AutomaticMatching updateEntity = new AutomaticMatching( | ||
automaticMatching.getId(), | ||
automaticMatching.getRoomId(), | ||
matchingStartTime, | ||
automaticMatching.getStatus() | ||
); | ||
return automaticMatchingRepository.save(updateEntity); | ||
} | ||
|
||
public AutomaticMatching create(Room room) { | ||
AutomaticMatching entity = new AutomaticMatching(room.getId(),room.getRecruitmentDeadline()); | ||
return automaticMatchingRepository.save(entity); | ||
} | ||
|
||
public void delete(AutomaticMatching automaticMatching) { | ||
automaticMatchingRepository.delete(automaticMatching); | ||
} | ||
} |
Oops, something went wrong.