Spring 이벤트를 활용한 트랜잭션 분리와 비즈니스 로직 개선기 (사용자가 섭취를 한다. 특정 상황에 부합하는 경우 포인트를 지급한다. 지급하게 된 경우 클라이언트에 응답을 보내 결과를 보여줘야 한다. 이때 백엔드의 로직은?)

  private final CaringService caringService; // 직접 의존

  public Long save(Long userId, Long myProductId, LocalDateTime intakeDateTime) {
      // 복용 기록 저장
      IntakeRecord record = new IntakeRecord(user, myProduct, intakeDateTime);
      intakeRecordRepository.save(record);

      // 케어링 포인트 처리 (같은 트랜잭션)
      caringService.recordIntake(user, myProduct, intakeDateTime);

      return record.getId();
  }

  // constructor, getters...

  public Long save(Long userId, Long myProductId, LocalDateTime intakeDateTime) {
      // 복용 기록 저장
      IntakeRecord record = new IntakeRecord(user, myProduct, intakeDateTime);
      intakeRecordRepository.save(record);

      // 이벤트 발행으로 대체
      IntakeRecordSavedEvent event = new IntakeRecordSavedEvent(this, userId, myProductId, intakeDateTime);
      applicationEventPublisher.publishEvent(event);

      return record.getId();
  }

  @TransactionalEventListener(phase = TransactionPhase.AFTER_COMMIT)
  @Transactional  // 새로운 트랜잭션 시작
  public void recordIntake(IntakeRecordSavedEvent event) {
      // 복용 기록 저장 트랜잭션이 성공적으로 커밋된 후에만 실행
      // 케어링 처리 실패가 복용 기록에 영향을 주지 않음
  }

      // 결과 확인 후 이벤트 발행
      if (points.isPresent()) {
          applicationEventPublisher.publishEvent(new CaringPointIssuedEvent(...));
      }
  }

      if (issuedPoint.isPresent()) {
          // 포인트 히스토리 저장
          PointHistory pointHistory = new PointHistory(user, null, "케어링", issuedPoint.get());
          pointHistoryRepository.save(pointHistory);

          // 실제 지급 시점에서 즉시 이벤트 발행 🎯
          CaringPointIssuedEvent event = new CaringPointIssuedEvent(/*...*/);
          applicationEventPublisher.publishEvent(event);
      }
  }

  public IntakeRecordSaveResponse save(Long userId, Long myProductId, LocalDateTime intakeDateTime) {
      // 복용 기록 저장
      IntakeRecord record = new IntakeRecord(user, myProduct, intakeDateTime);
      intakeRecordRepository.save(record);

      // 포인트 결과 대기를 위한 Future 준비
      CompletableFuture<CaringPointIssuedEvent> pointEventFuture = new CompletableFuture<>();
      pendingPointEvents.put(userId, pointEventFuture);

      // 이벤트 발행
      IntakeRecordSavedEvent event = new IntakeRecordSavedEvent(this, userId, myProductId, intakeDateTime);
      applicationEventPublisher.publishEvent(event);

      try {
          // 최대 5초 대기 (포인트 지급 시 즉시 완료)
          CaringPointIssuedEvent pointEvent = pointEventFuture.get(5, TimeUnit.SECONDS);
          return IntakeRecordSaveResponse.withPoint(
              record.getId(),
              pointEvent.getIssuedPoints(),
              pointEvent.getMaxConsecutiveCaringDays(),
              pointEvent.getNextBigPointDay(),
              pointEvent.getNextBigPointValue()
          );
      } catch (Exception e) {
          // 타임아웃 또는 포인트 미지급
          return IntakeRecordSaveResponse.withoutPoint(record.getId());
      } finally {
          pendingPointEvents.remove(userId);
      }
  }

  @EventListener
  public void handleCaringPointIssued(CaringPointIssuedEvent event) {
      CompletableFuture<CaringPointIssuedEvent> future = pendingPointEvents.get(event.getUserId());
      if (future != null) {
          future.complete(event); // 즉시 완료!
      }
  }

  Client->>IntakeRecordService: save() 호출
  IntakeRecordService->>IntakeRecordService: 복용 기록 저장 (Tx A)
  IntakeRecordService->>IntakeRecordService: 이벤트 발행 + Future 대기
  Note over IntakeRecordService: 트랜잭션 A 커밋

  IntakeRecordService-->>CaringService: IntakeRecordSavedEvent
  CaringService->>CaringService: 케어링 처리 (Tx B)
  CaringService->>CaringPointService: judgeAndIssuePoint()
  CaringPointService->>CaringPointService: 포인트 지급
  CaringPointService-->>IntakeRecordService: CaringPointIssuedEvent

  IntakeRecordService->>IntakeRecordService: Future 완료
  IntakeRecordService->>Client: 풍부한 응답 반환

  @EventListener
  public void sendPointNotification(CaringPointIssuedEvent event) {
      // 포인트 지급 알림 전송
  }

  @EventListener
  public void trackIntakeRecord(IntakeRecordSavedEvent event) {
      // 복용 기록 분석 데이터 수집
  }