Cabi에 CQRS 적용해보기

List<ActiveCabinetInfoEntities> activeCabinetInfos = cabinetQueryService.findActiveCabinetInfoEntities(building, floor); Map<Cabinet, List<LentHistory>> cabinetLentHistories = activeCabinetInfos.stream(). collect(groupingBy(ActiveCabinetInfoEntities::getCabinet, mapping(ActiveCabinetInfoEntities::getLentHistory, Collectors.toList()))); List<Cabinet> allCabinetsOnSection = cabinetQueryService.findAllCabinetsByBuildingAndFloor(building, floor); Map<Long, List<ClubLentHistory>> clubLentMap = clubLentQueryService.findAllActiveLentHistoriesWithClub().stream() .collect(groupingBy(ClubLentHistory::getCabinetId)); Map<String, List<CabinetPreviewDto>> cabinetPreviewsBySection = new LinkedHashMap<>(); allCabinetsOnSection.stream() .sorted(Comparator.comparing(Cabinet::getVisibleNum)) .forEach(cabinet -> { String section = cabinet.getCabinetPlace().getLocation().getSection(); if (cabinet.getLentType().equals(LentType.CLUB)) { if (!clubLentMap.containsKey(cabinet.getId())) { cabinetPreviewsBySection.computeIfAbsent(section, k -> new ArrayList<>()) .add(cabinetMapper.toCabinetPreviewDto(cabinet, 0, null)); } else { clubLentMap.get(cabinet.getId()).stream() .map(c -> c.getClub().getName()) .findFirst().ifPresent(clubName -> cabinetPreviewsBySection .computeIfAbsent(section, k -> new ArrayList<>()) .add(cabinetMapper.toCabinetPreviewDto(cabinet, 0, clubName))); } return; } List<LentHistory> lentHistories = cabinetLentHistories.getOrDefault(cabinet, Collections.emptyList()); String title = getCabinetTitle(cabinet, lentHistories); cabinetPreviewsBySection.computeIfAbsent(section, k -> new ArrayList<>()) .add(cabinetMapper.toCabinetPreviewDto(cabinet, lentHistories.size(), title)); }); return cabinetPreviewsBySection.entrySet().stream() .map(entry -> cabinetMapper.toCabinetsPerSectionResponseDto(entry.getKey(), entry.getValue())) .collect(Collectors.toList());

final LocalDateTime now = LocalDateTime.now(); final LocalDateTime yesterday = now.minusDays(1).withHour(13).withMinute(0).withSecond(0); List<Cabinet> pendingCabinets = cabinetQueryService.findPendingCabinetsNotLentTypeAndStatus( building, LentType.CLUB, List.of(AVAILABLE, PENDING)); List<Long> cabinetIds = pendingCabinets.stream() .filter(cabinet -> cabinet.isStatus(PENDING)) .map(Cabinet::getId).collect(Collectors.toList()); Map<Long, List<LentHistory>> lentHistoriesMap; if (now.getHour() < 13) { lentHistoriesMap = lentQueryService.findPendingLentHistoriesOnDate( yesterday.toLocalDate(), cabinetIds) .stream().collect(groupingBy(LentHistory::getCabinetId)); } else { lentHistoriesMap = lentQueryService.findCabinetLentHistories(cabinetIds) .stream().collect(groupingBy(LentHistory::getCabinetId)); } Map<Integer, List<CabinetPreviewDto>> cabinetFloorMap = cabinetQueryService.findAllFloorsByBuilding(building).stream() .collect(toMap(key -> key, value -> new ArrayList<>())); pendingCabinets.forEach(cabinet -> { Integer floor = cabinet.getCabinetPlace().getLocation().getFloor(); if (cabinet.isStatus(AVAILABLE)) { cabinetFloorMap.get(floor).add(cabinetMapper.toCabinetPreviewDto(cabinet, 0, null)); } if (cabinet.isStatus(PENDING)) { lentHistoriesMap.get(cabinet.getId()).stream() .map(LentHistory::getEndedAt) .max(LocalDateTime::compareTo) .ifPresent(latestEndedAt -> cabinetFloorMap.get(floor) .add(cabinetMapper.toCabinetPreviewDto(cabinet, 0, null))); } }); return cabinetMapper.toCabinetPendingResponseDto(cabinetFloorMap);

// Entity Wrapping EventListener @Component @NoArgsConstructor public class CqrsEventListener { ... } // Entity @Entity ... @EntityEventListener(value = CqrsEventListener.class) public class LentHistory { ... }

@Component @Logging(level = LogLevel.DEBUG) public class CqrsRedis { private final RedisTemplate<String, String> redisTemplate; // expire 같은 조금 더 많은 기능을 지원 private final HashOperations<String, String, String> hashTemplate; // hash 사용 가능 private final ValueOperations<String, String> valueTemplate; private final ObjectMapper objectMapper; @Autowired public CqrsRedis(RedisTemplate<String, String> redisTemplate, RedisTemplate<String, String> hashTemplate, RedisTemplate<String, String> valueTemplate, ObjectMapper objectMapper) { this.redisTemplate = redisTemplate; this.hashTemplate = hashTemplate.opsForHash(); this.valueTemplate = valueTemplate.opsForValue(); this.objectMapper = objectMapper; } }

private <T> String dtoToString(T dto) { if (dto == null) { return null; } try { return objectMapper.writeValueAsString(dto); } catch (JsonProcessingException e) { log.error("DTO to JSON Parse Error : {}, {}", dto, e.toString()); throw ExceptionStatus.INTERNAL_SERVER_ERROR.asDomainException(); } } private <T> T stringToDto(String value) { if (value == null) { return null; } try { //@formatter:off return objectMapper.readValue(value, new TypeReference<>() {}); //@formatter:on } catch (JsonProcessingException e) { log.error("String to JSON Parse Error : {}, {}", value, e.toString()); throw ExceptionStatus.INTERNAL_SERVER_ERROR.asDomainException(); } }

public void addPendingCabinet(Cabinet cabinet) { Location location = cabinet.getCabinetPlace().getLocation(); String floor = location.getFloor().toString(); List<CabinetPreviewDto> pendingCabinets = cqrsRedis.getPendingCabinets(floor); pendingCabinets.add(cabinetMapper.toCabinetPreviewDto(cabinet, 0, null)); pendingCabinets.sort(Comparator.comparing(CabinetPreviewDto::getVisibleNum)); cqrsRedis.setPendingCabinet(floor, pendingCabinets); }

@Transactional(readOnly = true) public void synchronizeCabinet(Cabinet cabinet) { List<LentHistory> cabinetLentHistories = lentQueryService.findCabinetLentHistoriesWithUserAndCabinet(cabinet.getId()); this.syncAll(cabinet, cabinetLentHistories); } private void syncAll(Cabinet cabinet, List<LentHistory> cabinetLentHistories) { this.syncPendingCabinet(cabinet, cabinetLentHistories); // this.syncCabinetPerSection(cabinet, cabinetLentHistories); } private void syncPendingCabinet(Cabinet cabinet, List<LentHistory> cabinetLentHistories) { if (cabinet.isStatus(AVAILABLE)) { cqrsService.addPendingCabinet(cabinet); } else if (cabinet.isStatus(PENDING)) { LocalDate yesterday = LocalDateTime.now().minusDays(1).toLocalDate(); LentHistory recentLentHistory = cabinetLentHistories.stream() .max(Comparator.comparing(LentHistory::getEndedAt)).orElse(null); if (recentLentHistory != null && recentLentHistory.isSameEndedAtDate(yesterday)) { cqrsService.addPendingCabinet(cabinet); } } }

@PostUpdate public void onPostPersist(Object object) { log.info("onPostPersist {}", object.toString()); if (object instanceof Cabinet) { Cabinet cabinet = (Cabinet) object; cqrsManager.synchronizeCabinet(cabinet); } ... }

public AvailableCabinetResponseDto getPendingCabinet(String building) { final LocalDateTime now = LocalDateTime.now(); final LocalDateTime yesterday = now.minusDays(1).withHour(13).withMinute(0).withSecond(0); List<Cabinet> pendingCabinets = cabinetQueryService.findPendingCabinetsNotLentTypeAndStatus( building, LentType.CLUB, List.of(AVAILABLE, PENDING)); List<Long> cabinetIds = pendingCabinets.stream() .filter(cabinet -> cabinet.isStatus(PENDING)) .map(Cabinet::getId).collect(Collectors.toList()); Map<Long, List<LentHistory>> lentHistoriesMap; if (now.getHour() < 13) { lentHistoriesMap = lentQueryService.findPendingLentHistoriesOnDate( yesterday.toLocalDate(), cabinetIds) .stream().collect(groupingBy(LentHistory::getCabinetId)); } else { lentHistoriesMap = lentQueryService.findCabinetLentHistories(cabinetIds) .stream().collect(groupingBy(LentHistory::getCabinetId)); } Map<Integer, List<CabinetPreviewDto>> cabinetFloorMap = cabinetQueryService.findAllFloorsByBuilding(building).stream() .collect(toMap(key -> key, value -> new ArrayList<>())); pendingCabinets.forEach(cabinet -> { Integer floor = cabinet.getCabinetPlace().getLocation().getFloor(); if (cabinet.isStatus(AVAILABLE)) { cabinetFloorMap.get(floor).add(cabinetMapper.toCabinetPreviewDto(cabinet, 0, null)); } if (cabinet.isStatus(PENDING)) { lentHistoriesMap.get(cabinet.getId()).stream() .map(LentHistory::getEndedAt) .max(LocalDateTime::compareTo) .ifPresent(latestEndedAt -> cabinetFloorMap.get(floor) .add(cabinetMapper.toCabinetPreviewDto(cabinet, 0, null))); } }); return cabinetMapper.toCabinetPendingResponseDto(cabinetFloorMap); }

public AvailableCabinetResponseDto getPendingCabinet(String building) { return cqrsService.getAvailableCabinet(building); }

@PostPersist @PostUpdate public void onPostUpdate(Object object) { if (object instanceof LentHistory) { LentHistory lentHistory = (LentHistory) object; cqrsManager.changeCabinetLentHistory(lentHistory); } else if (object instanceof Cabinet) { cqrsManager.changeCabinet((Cabinet) object); } }

@Async @Transactional(readOnly = true) public void changeCabinet(Cabinet cabinet) { // 영속화(연관관계를 가지는 엔티티 포함) Cabinet findCabinet = cabinetQueryService.getCabinet(cabinet.getId()); this.changeAvailableCabinet(findCabinet); this.changeCabinetPerSection(findCabinet); this.changeCabinetInfo(findCabinet); this.changeUserLentInfo(cabinet); } @Async @Transactional(readOnly = true) public void changeCabinetLentHistory(LentHistory lentHistory) { // LentHistory PostPersist 경우 DB에서 찾으면 없기 때문에 비영속 상태 유지 + 연관관계를 가지는 엔티티 영속화 Cabinet cabinet = cabinetQueryService.getCabinet(lentHistory.getCabinetId()); User user = userQueryService.getUser(lentHistory.getUserId()); this.changeCabinetPerSection(lentHistory, cabinet, user); this.changeCabinetInfo(lentHistory); this.changeUserLentInfo(cabinet, lentHistory); }