[TIL] 프로젝트 25일차.. 구현했던 기능들 마무리하기!!

🌞 오늘은 어떤 하루였지..

오전에는 상품 가격 변동 로직을 마무리하는 데 시간을 쏟았다.

// 가격 관련 Kafka Listener
@KafkaListener(topics = "${kafka.topic.price}", groupId = "${spring.kafka.consumer.product-combination.group-id}")
public void listenPriceChange(@Header(KafkaHeaders.RECEIVED_KEY) String key, String value) {
    log.info("📥 가격변동 메시지 수신: key={}, value={}", key, value);

    try {
        OperationWrapperDto wrapperDto = JsonHelper.fromJson(value, OperationWrapperDto.class);

        // PRICE_CHANGE 타입이 아닌 메시지가 잘못 들어왔을 경우 무시
        if (!wrapperDto.operationType().equals(OperationType.PRICE_CHANGE)) {
            log.info("⚠️ PRICE_CHANGE 타입이 아닌 메시지 수신: {}", wrapperDto.operationType());
            return;
        }

        ProductOptionCombinationPriceDto priceDto = JsonHelper.fromJson(wrapperDto.payload(), ProductOptionCombinationPriceDto.class);

        productOptionCombinationService.changePrice(priceDto, wrapperDto, key);
    } catch (NotFoundException e) {
        log.warn("⚠️ 필수 데이터 누락으로 가격 변경 메시지 처리 실패 ({}): {}", e.getErrorCode(), e.getMessage());
    } catch (Exception e) {
        log.error("❌ 예기치 못한 오류로 가격 변경 메시지 처리 실패: {}", e.getMessage());
    }
}

가격 관련해서 KafkaListener를 생성했고, 이미 만들어진 틀에 내가 만들 로직이 정상적으로 들어갈 수 있도록 하는 게 생각보다 어려웠다..

@Transactional
public void changePrice(ProductOptionCombinationPriceDto priceDto, OperationWrapperDto wrapperDto, String key) {
    Long combinationId = priceDto.productOptionCombinationId();
    Integer newPrice = priceDto.price();
    String lockKey = "softLock:priceChange:combination:" + combinationId;

    ProductOptionCombination combination = productOptionCombinationRepository.findById(combinationId)
        .orElseThrow(() -> new NotFoundException(ErrorCode.PRODUCT_OPTION_COMBINATION_NOT_FOUND));
    Integer currentPrice = combination.getPrice();

    // 가격 변경
    if (!newPrice.equals(currentPrice)) {
        combination.updatePrice(newPrice);
        log.info("✅ 가격 변경 감지 및 반영 완료: combinationId={}", combinationId);
    } else {
        log.info("❌ 가격 변동 없음: combinationId={}", combinationId);
    }

    // soft Lock 해제
    redisTemplate.delete(lockKey);
    log.info("🔓 soft lock 해제 완료: {}", lockKey);

    redisTemplate.opsForValue().set("status:" + priceDto.operationId(), true, Duration.ofMinutes(5));
}

다음과 같이 다른 팀원들이 개발한 틀에 맞춰서 로직을 구현했고 성공적으로 가격 변경이 이루어지는 것을 확인했다.

그리고 오후에는 지금까지 개발한 내용에 맞춰서 API 명세서를 수정했다. 하나하나 수정하면서 필요한 내용도 작성하느라 시간을 꽤 많이 잡아먹었다.

 

마지막으로 프로젝트 마무리 겸 각자 개발한 내용 발표하기로 해서 내가 구현한 내용들에 대해 어떻게 보여주면 좋을지 생각하고 준비를 하면서 하루를 마무리했다.

내일 발표 순서 생각

배송, 택배사, 송장, 출고지(물류센터), 재고 감소, 가격 변경

1. 택배사 관련 기능 구현
   1. 택배사 생성
   2. 택배사 생성
   3. 택배사 조회
   4. 택배사 수정
2. 출고지 관련 기능 구현
   1. 출고지 생성
   2. 출고지 생성
   3. 택배사 삭제 → 출고지에 등록되어 있는 택배사 삭제 X
   4. 출고지 조회
   5. 출고지 수정
   6. 출고지 삭제
3. 재고 감소 → 배송 생성 구현 → 슬랙 알림 메시지
   1. 결제 후 재고 감소 로직 실행
   2. 재고 감소 완료 후 배송 생성 토픽으로 메시지 전송
   3. 배송 생성 성공 시 슬랙 알림 메시지 전송
   4. 배송 생성 실패 시 슬랙 알림 메시지 전송 + 재고 복원 로직 진행
4. 송장 관련 기능 구현
   1. 송장 생성
5. 출고 → 카카오톡 알림 메시지
   1. 배송 수정 → 송장 번호 등록 + 상태 출고로 변경 후 카카오톡 알림 메시지 전송
6. 배송중, 배송 완료 → 카카오톡 알림 메시지
   1. 배송 상태 수정 후 카카오톡 알림 메시지 전송
7. 가격 변경 구현
   1. 가격 변경 로직 진행

 

🗓️ 내일은 뭐 하지?!

✔️ 내가 구현한 내용 발표하기