Naughty-BE-Spring/src/main/java/naughty/tuzamate/domain/comment/service/command/CommentCommandServiceImpl.java at 713dd108f6959959080660f55ad4a6c059b6ac76 · NaughtyComputer/Naughty-BE-Spring · 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
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
package naughty.tuzamate.domain.comment.service.command;

import lombok.RequiredArgsConstructor;
import naughty.tuzamate.auth.principal.PrincipalDetails;
import naughty.tuzamate.domain.comment.code.CommentErrorCode;
import naughty.tuzamate.domain.comment.converter.CommentConverter;
import naughty.tuzamate.domain.comment.dto.CommentReqDTO;
import naughty.tuzamate.domain.comment.dto.CommentResDTO;
import naughty.tuzamate.domain.comment.entity.Comment;
import naughty.tuzamate.domain.comment.repository.CommentRepository;
import naughty.tuzamate.domain.notification.entity.Notification;
import naughty.tuzamate.domain.notification.service.NotificationService;
import naughty.tuzamate.domain.post.code.PostErrorCode;
import naughty.tuzamate.domain.post.entity.Post;
import naughty.tuzamate.domain.post.repository.PostRepository;
import naughty.tuzamate.domain.user.entity.User;
import naughty.tuzamate.domain.user.repository.UserRepository;
import naughty.tuzamate.global.error.GeneralErrorCode;
import naughty.tuzamate.global.error.exception.CustomException;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.util.LinkedHashSet;
import java.util.Map;
import java.util.Set;

@Service
@Transactional
@RequiredArgsConstructor
public class CommentCommandServiceImpl implements CommentCommandService {

    private final UserRepository userRepository;
    private final CommentRepository commentRepository;
    private final PostRepository postRepository;
    private final NotificationService notificationService;

    @Override
    public CommentResDTO.CreateCommentResponseDTO createComment(
            CommentReqDTO.CreateCommentRequestDTO reqDTO, Long postId, PrincipalDetails principalDetails
    ) {
        User commentWriter = userRepository.findById(principalDetails.getId())
                .orElseThrow(() -> new CustomException(CommentErrorCode.COMMENT_NOT_FOUND));

        Post post = postRepository.findById(postId)
                .orElseThrow(() -> new CustomException(PostErrorCode.POST_NOT_FOUND));

        Comment parent = null;

        if (reqDTO.parentId() != null) {
            parent = commentRepository.findById(reqDTO.parentId())
                    .orElseThrow(() -> new CustomException(CommentErrorCode.COMMENT_NOT_FOUND));
        }

        Comment comment = CommentConverter.toComment(reqDTO, commentWriter, post, parent);

        commentRepository.save(comment);

        // 알림 대상 계산
        Set<Long> receivers = new LinkedHashSet<>();

        Long postWriterId = post.getUser().getId();
        Long parentWriterId = parent != null ? parent.getUser().getId() : null;
        Long writerId = commentWriter.getId();

        if (!postWriterId.equals(writerId)) {
            receivers.add(postWriterId);
        }
        if (parentWriterId != null && !parentWriterId.equals(writerId) && !parentWriterId.equals(postWriterId)) {
            receivers.add(parentWriterId);
        }

        // 알림 저장 + (커밋 후) FCM 발송
        for (Long receiverId : receivers) {
            Notification notification = Notification.builder()
                    .receiver(User.builder().id(receiverId).build())
                    .title("새 댓글이 달렸습니다")
                    .content(comment.getContent())
                    .targetId(post.getId())
                    .isRead(false)
                    .build();

            Map<String, String> data = Map.of(
                    "type", "COMMENT",
                    "postId", String.valueOf(post.getId()),
                    "commentId", String.valueOf(comment.getId()),
                    "deeplink", "myapp://post/" + post.getId() + "?commentId=" + comment.getId()
            );

            notificationService.saveAndDispatch(
                    notification, receiverId,
                    "새 댓글 알림", comment.getContent(),
                    data, true, "OPEN_POST" // 클릭 액션 키(프론트에 맞추기)
            );
        }

        return CommentConverter.toCreateCommentResponseDTO(comment);
    }

    @Override
    public CommentResDTO.UpdateCommentResponseDTO updateComment(
            CommentReqDTO.UpdateCommentRequestDTO reqDTO,
            Long commentId,
            PrincipalDetails principalDetails
    ) {
        Comment comment = commentRepository.findById(commentId)
                .orElseThrow(() -> new CustomException(CommentErrorCode.COMMENT_NOT_FOUND));

        if (!comment.getUser().getId().equals(principalDetails.getUser().getId())) {
            throw new CustomException(GeneralErrorCode.FORBIDDEN_403); // 권한 없음
        }

        comment.updateContent(reqDTO.content());

        return CommentConverter.toUpdateCommentResponseDTO(comment);
    }

    @Override
    public CommentResDTO.DeleteCommentResponseDTO deleteComment(Long commentId, PrincipalDetails principalDetails) {
        Comment comment = commentRepository.findById(commentId)
                .orElseThrow(() -> new CustomException(CommentErrorCode.COMMENT_NOT_FOUND));

        if (!comment.getUser().getId().equals(principalDetails.getUser().getId())) {
            throw new CustomException(GeneralErrorCode.FORBIDDEN_403);
        }

        commentRepository.delete(comment);

        return CommentConverter.toDeleteCommentResponseDTO(commentId);
    }
}