feat: Reader/Writer 통해 조회 로직 분리

backend/src/main/java/corea/room/service/RoomAutomaticService.java

@@ -0,0 +1,86 @@
+package corea.room.service;
+
+import corea.room.domain.Room;
+import corea.scheduler.domain.AutomaticMatching;
+import corea.scheduler.domain.AutomaticUpdate;
+import corea.scheduler.domain.ScheduleStatus;
+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 AutomaticMatchingService automaticMatchingService;
+    private final AutomaticUpdateService automaticUpdateService;
+
+    @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());
+
+        automaticMatchingService.modifyTask(updateRoom);
+        automaticUpdateService.modifyTask(updateRoom);
+    }
+
+    @Transactional
+    public void createAutomatic(Room room) {
+        automaticMatchingWriter.create(room);
+        automaticUpdateWriter.create(room);
+
+        automaticMatchingService.matchOnRecruitmentDeadline(room);
+        automaticUpdateService.updateAtReviewDeadline(room);
+    }
+
+    @Transactional
+    public void deleteAutomatic(Room room) {
+        AutomaticMatching automaticMatching = automaticMatchingReader.findWithRoom(room);
+        AutomaticUpdate automaticUpdate = automaticUpdateReader.findWithRoom(room);
+
+        automaticMatchingWriter.delete(automaticMatching);
+        automaticUpdateWriter.delete(automaticUpdate);
+
+        automaticMatchingService.cancel(room.getId());
+        automaticUpdateService.cancel(room.getId());
+    }
+
+    @EventListener(ApplicationReadyEvent.class)
+    public void schedulePendingAutomaticMatching() {
+        List<AutomaticMatching> matchings = automaticMatchingReader.findByStatus(ScheduleStatus.PENDING);
+
+        log.info("{}개의 방에 대해 자동 매칭 재예약 시작", matchings.size());
+
+        matchings.forEach(automaticMatchingService::matchOnRecruitmentDeadline);
+
+        log.info("{}개의 방에 대해 자동 매칭 재예약 완료", matchings.size());
+    }
+
+    @EventListener(ApplicationReadyEvent.class)
+    public void schedulePendingAutomaticUpdate() {
+        List<AutomaticUpdate> updates = automaticUpdateReader.findByStatus(ScheduleStatus.PENDING);
+
+        log.info("{}개의 방에 대해 자동 상태 업데이트 재예약 시작", updates.size());
+
+        updates.forEach(automaticUpdateService::updateAtReviewDeadline);
+
+        log.info("{}개의 방에 대해 자동 상태 업데이트 재예약 완료", updates.size());
+    }
+}

backend/src/main/java/corea/room/service/RoomService.java

@@ -11,18 +11,10 @@
 import corea.participation.domain.ParticipationStatus;
 import corea.participation.repository.ParticipationRepository;
 import corea.room.domain.Room;
-import corea.room.domain.RoomClassification;
-import corea.room.domain.RoomStatus;
 import corea.room.dto.*;
 import corea.room.repository.RoomRepository;
-import corea.scheduler.domain.AutomaticMatching;
-import corea.scheduler.domain.AutomaticUpdate;
-import corea.scheduler.repository.AutomaticMatchingRepository;
-import corea.scheduler.repository.AutomaticUpdateRepository;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
-import org.springframework.data.domain.Page;
-import org.springframework.data.domain.PageRequest;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
@@ -47,8 +39,8 @@ public class RoomService {
     private final MatchResultRepository matchResultRepository;
     private final ParticipationRepository participationRepository;
     private final FailedMatchingRepository failedMatchingRepository;
-    private final AutomaticMatchingRepository automaticMatchingRepository;
-    private final AutomaticUpdateRepository automaticUpdateRepository;
+    private final RoomAutomaticService roomAutomaticService;
+
 
     @Transactional
     public RoomResponse create(long memberId, RoomCreateRequest request) {
@@ -60,8 +52,7 @@ public RoomResponse create(long memberId, RoomCreateRequest request) {
         Participation participation = new Participation(room, manager);
 
         participationRepository.save(participation);
-        automaticMatchingRepository.save(new AutomaticMatching(room.getId(), request.recruitmentDeadline()));
-        automaticUpdateRepository.save(new AutomaticUpdate(room.getId(), request.reviewDeadline()));
+        roomAutomaticService.createAutomatic(room);
 
         return RoomResponse.of(room, participation.getMemberRole(), ParticipationStatus.MANAGER);
     }
@@ -131,8 +122,7 @@ public void delete(long roomId, long memberId) {
 
         roomRepository.delete(room);
         participationRepository.deleteAllByRoomId(roomId);
-        automaticMatchingRepository.deleteByRoomId(roomId);
-        automaticUpdateRepository.deleteByRoomId(roomId);
+        roomAutomaticService.deleteAutomatic(room);
     }
 
     private void validateDeletionAuthority(Room room, long memberId) {

backend/src/main/java/corea/scheduler/service/AutomaticMatchingReader.java

@@ -0,0 +1,30 @@
+package corea.scheduler.service;
+
+import corea.exception.CoreaException;
+import corea.exception.ExceptionType;
+import corea.room.domain.Room;
+import corea.scheduler.domain.AutomaticMatching;
+import corea.scheduler.domain.ScheduleStatus;
+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> findByStatus(ScheduleStatus status) {
+        return automaticMatchingRepository.findAllByStatus(status);
+    }
+}

backend/src/main/java/corea/scheduler/service/AutomaticMatchingWriter.java

@@ -0,0 +1,37 @@
+package corea.scheduler.service;
+
+import corea.room.domain.Room;
+import corea.scheduler.domain.AutomaticMatching;
+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);
+    }
+}

backend/src/main/java/corea/scheduler/service/AutomaticUpdateReader.java

@@ -0,0 +1,32 @@
+package corea.scheduler.service;
+
+import corea.exception.CoreaException;
+import corea.exception.ExceptionType;
+import corea.room.domain.Room;
+import corea.scheduler.domain.AutomaticUpdate;
+import corea.scheduler.domain.ScheduleStatus;
+import corea.scheduler.repository.AutomaticUpdateRepository;
+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 AutomaticUpdateReader {
+
+    private final AutomaticUpdateRepository automaticUpdateRepository;
+
+    public AutomaticUpdate findWithRoom(Room room) {
+        return automaticUpdateRepository.findByRoomId(room.getId())
+                .orElseThrow(() -> new CoreaException(ExceptionType.AUTOMATIC_UPDATE_NOT_FOUND));
+    }
+
+    public List<AutomaticUpdate> findByStatus(ScheduleStatus status) {
+        return automaticUpdateRepository.findAllByStatus(status)
+                .stream()
+                .toList();
+    }
+}

backend/src/main/java/corea/scheduler/service/AutomaticUpdateWriter.java

@@ -0,0 +1,40 @@
+package corea.scheduler.service;
+
+import corea.room.domain.Room;
+import corea.scheduler.domain.AutomaticUpdate;
+import corea.scheduler.repository.AutomaticUpdateRepository;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Component;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.time.LocalDateTime;
+
+@Component
+@RequiredArgsConstructor
+@Transactional
+public class AutomaticUpdateWriter {
+
+    private final AutomaticUpdateRepository automaticUpdateRepository;
+
+    public AutomaticUpdate updateTime(AutomaticUpdate automaticUpdate, LocalDateTime reviewDeadline) {
+        AutomaticUpdate updateEntity = new AutomaticUpdate(
+                automaticUpdate.getId(),
+                automaticUpdate.getRoomId(),
+                reviewDeadline,
+                automaticUpdate.getStatus()
+        );
+        return automaticUpdateRepository.save(updateEntity);
+    }
+
+    public AutomaticUpdate create(Room room) {
+        AutomaticUpdate createEntity = new AutomaticUpdate(
+                room.getId(),
+                room.getReviewDeadline()
+        );
+        return automaticUpdateRepository.save(createEntity);
+    }
+
+    public void delete(AutomaticUpdate automaticUpdate) {
+        automaticUpdateRepository.delete(automaticUpdate);
+    }
+}