PostCommentService.java

package clap.server.application.service.history;

import clap.server.adapter.inbound.web.dto.history.request.CreateCommentRequest;
import clap.server.adapter.outbound.persistense.entity.member.constant.MemberRole;
import clap.server.adapter.outbound.persistense.entity.notification.constant.NotificationType;
import clap.server.adapter.outbound.persistense.entity.task.constant.TaskHistoryType;
import clap.server.application.port.inbound.domain.MemberService;
import clap.server.application.port.inbound.domain.TaskService;
import clap.server.application.port.inbound.history.SaveCommentAttachmentUsecase;
import clap.server.application.port.inbound.history.SaveCommentUsecase;
import clap.server.application.port.outbound.s3.S3UploadPort;
import clap.server.application.port.outbound.task.CommandAttachmentPort;
import clap.server.application.port.outbound.task.CommandCommentPort;
import clap.server.application.port.outbound.taskhistory.CommandTaskHistoryPort;
import clap.server.application.service.webhook.SendNotificationService;
import clap.server.common.annotation.architecture.ApplicationService;
import clap.server.domain.model.member.Member;
import clap.server.domain.model.task.Attachment;
import clap.server.domain.model.task.Comment;
import clap.server.domain.model.task.Task;
import clap.server.domain.model.task.TaskHistory;
import clap.server.common.constants.FilePathConstants;
import clap.server.domain.policy.task.TaskCommentPolicy;
import lombok.RequiredArgsConstructor;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.web.multipart.MultipartFile;

import java.util.Objects;

@ApplicationService
@RequiredArgsConstructor
public class PostCommentService implements SaveCommentUsecase, SaveCommentAttachmentUsecase {

    private final MemberService memberService;
    private final TaskService taskService;
    private final CommandCommentPort commandCommentPort;
    private final S3UploadPort s3UploadPort;
    private final CommandAttachmentPort commandAttachmentPort;
    private final CommandTaskHistoryPort commandTaskHistoryPort;
    private final SendNotificationService sendNotificationService;
    private final TaskCommentPolicy taskCommentPolicy;

    @Transactional
    @Override
    public void save(Long memberId, Long taskId, CreateCommentRequest request) {
        Task task = taskService.findById(taskId);
        Member member = memberService.findActiveMember(memberId);

        // 일반 회원일 경우 => 요청자인지 확인
        taskCommentPolicy.validateCommentPermission(task, member);
        Comment comment = Comment.createComment(member, task, request.content());
        Comment savedComment = commandCommentPort.saveComment(comment);

        TaskHistory taskHistory = TaskHistory.createTaskHistory(TaskHistoryType.COMMENT, task, null, member, savedComment);
        commandTaskHistoryPort.save(taskHistory);

        Member processor = task.getProcessor();
        Member requester = task.getRequester();
        if (Objects.equals(member.getMemberId(), requester.getMemberId())) {
            publishNotification(processor, task, request.content(), member.getNickname());
        } else {
            publishNotification(requester, task, request.content(), member.getNickname());
        }

    }

    @Transactional
    @Override
    public void saveCommentAttachment(Long memberId, Long taskId, MultipartFile file) {
        Task task = taskService.findById(taskId);
        Member member = memberService.findActiveMember(memberId);

        taskCommentPolicy.validateCommentPermission(task, member);
        Comment comment = Comment.createComment(member, task, null);
        Comment savedComment = commandCommentPort.saveComment(comment);
        String fileName = saveAttachment(file, task, savedComment);

        TaskHistory taskHistory = TaskHistory.createTaskHistory(TaskHistoryType.COMMENT_FILE, task, null, member, savedComment);
        commandTaskHistoryPort.save(taskHistory);

        Member processor = task.getProcessor();
        Member requester = task.getRequester();
        if (member.getMemberInfo().getRole() == requester.getMemberInfo().getRole()) {
            publishNotification(processor, task, fileName + "(첨부파일)", requester.getNickname());
        } else {
            publishNotification(requester, task, fileName + "(첨부파일)", processor.getNickname());
        }

    }

    private String saveAttachment(MultipartFile file, Task task, Comment comment) {
        String fileUrl = s3UploadPort.uploadSingleFile(FilePathConstants.TASK_COMMENT, file);
        Attachment attachment = Attachment.createCommentAttachment(task, comment, file.getOriginalFilename(), fileUrl, file.getSize());
        commandAttachmentPort.save(attachment);
        return file.getOriginalFilename();
    }

    private void publishNotification(Member receiver, Task task, String message, String commenterName) {
        boolean isManager = receiver.getMemberInfo().getRole() == MemberRole.ROLE_MANAGER;
        sendNotificationService.sendPushNotification(receiver, NotificationType.COMMENT, task, message, commenterName, isManager);
    }
}