AIBE5_Project2_Team8/src/main/java/com/knoc/review/service/ReviewRequestService.java at 02e4c8c23bc9e06f3bd8f3460220f25f5c1ba95d · prgrms-aibe-devcourse/AIBE5_Project2_Team8 · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
package com.knoc.review.service;

import com.knoc.chat.entity.ChatSystemEvent;
import com.knoc.chat.entity.MessageType;
import com.knoc.global.exception.BusinessException;
import com.knoc.global.exception.ErrorCode;
import com.knoc.member.Member;
import com.knoc.member.MemberRepository;
import com.knoc.order.entity.Order;
import com.knoc.order.entity.OrderStatus;
import com.knoc.order.repository.OrderRepository;
import com.knoc.review.dto.ReviewRequestCreateRequest;
import com.knoc.review.dto.ReviewRequestCreateResponse;
import com.knoc.review.dto.ReviewRequestUpdateRequest;
import com.knoc.review.entity.ReviewRequest;
import com.knoc.review.repository.ReviewReportRepository;
import com.knoc.review.repository.ReviewRequestRepository;
import lombok.RequiredArgsConstructor;
import org.springframework.context.ApplicationEventPublisher;
import org.springframework.dao.DataIntegrityViolationException;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

@Service
@Transactional
@RequiredArgsConstructor
public class ReviewRequestService {
    private final OrderRepository orderRepository;
    private final ReviewRequestRepository reviewRequestRepository;
    private final ApplicationEventPublisher eventPublisher;
    private final MemberRepository memberRepository;
    private final ReviewReportRepository reviewReportRepository;

    public ReviewRequestCreateResponse createReviewRequest(ReviewRequestCreateRequest dto, String email) {
       Order order = juniorAndOrderValidation(email, dto.getOrderId());

        // 중복 검증
        if (reviewRequestRepository.existsByOrderId(order.getId())) {
            throw new BusinessException(ErrorCode.REVIEW_REQUEST_ALREADY_EXISTS);
        }

        // 리뷰 요청서 저장
        ReviewRequest reviewRequest = ReviewRequest.builder()
                .order(order)
                .githubPrUrl(dto.getGithubPrUrl())
                .projectContext(dto.getProjectContext())
                .concernPoint(dto.getConcernPoint())
                .build();

        try {
            reviewRequestRepository.saveAndFlush(reviewRequest);
        } catch (DataIntegrityViolationException e) {
            throw new BusinessException(ErrorCode.REVIEW_REQUEST_ALREADY_EXISTS);
        }


        // 시스템 이벤트 발행
        eventPublisher.publishEvent(new ChatSystemEvent(
                order.getChatRoom().getId(),
                MessageType.REVIEW_SUBMITTED,
                null,
                order.getId()
        ));

        // 6. 저장된 주문을 클라이언트에게 보여줄 전용 응답 객체(DTO)로 변환
        return ReviewRequestCreateResponse.from(reviewRequest);
    }

    @Transactional
    public Long updateReviewRequest(String email, ReviewRequestUpdateRequest req) {
        Order order = juniorAndOrderValidation(email, req.orderId());
        if (reviewReportRepository.existsByReviewRequest_Order_Id(order.getId())) {
            throw new BusinessException(ErrorCode.REVIEW_REPORT_ALREADY_EXISTS);
        }
        ReviewRequest rr = reviewRequestRepository.findByOrder(order)
                .orElseThrow(() -> new BusinessException(ErrorCode.REVIEW_REQUEST_NOT_FOUND));
        rr.update(req.githubPrUrl(), req.projectContext(), req.concernPoint());
        return order.getId();
    }

    private Order juniorAndOrderValidation(String email, Long orderId) {
        // juniorId 가져오기
        Long juniorId = memberRepository.findByEmail(email)
                .map(Member::getId)
                .orElseThrow(() -> new BusinessException(ErrorCode.MEMBER_NOT_FOUND));

        // 해당 주문 가져오기
        Order order = orderRepository.findById(orderId)
                .orElseThrow(() -> new BusinessException(ErrorCode.ORDER_NOT_FOUND));

        // 주니어 소유 검증
        if (!order.getJunior().getId().equals(juniorId)) {
            throw new BusinessException(ErrorCode.NOT_JUNIOR_FOR_ORDER);
        }

        // 상태 검증
        if (order.getStatus() != OrderStatus.PAID) {
            throw new BusinessException(ErrorCode.REVIEW_REQUEST_NOT_ALLOWED);
        }
        return order;
    }
}