MNG-20 feat: MissionComment CRUD 추가

Author: minsu20

src/main/java/com/moing/backend/domain/missionArchive/application/mapper/MissionArchiveMapper.java

@@ -51,6 +51,7 @@ public static MissionArchiveRes mapToMissionArchiveRes(MissionArchive missionArc
                         .filter(heart -> heart.getMissionArchive().equals( missionArchive))// heartStatus가 true인 요소만 필터링
                         .count())
                 .contents(missionArchive.getContents())
+                .comments(missionArchive.getCommentNum())
                 .build();
     }
 

src/main/java/com/moing/backend/domain/missionArchive/domain/entity/MissionArchive.java

@@ -3,7 +3,6 @@
 
 import com.moing.backend.domain.member.domain.entity.Member;
 import com.moing.backend.domain.mission.domain.entity.Mission;
-import com.moing.backend.domain.mission.domain.entity.constant.MissionStatus;
 import com.moing.backend.domain.missionArchive.application.dto.req.MissionArchiveReq;
 import com.moing.backend.domain.missionHeart.domain.entity.MissionHeart;
 import com.moing.backend.global.entity.BaseTimeEntity;
@@ -50,6 +49,8 @@ public class MissionArchive extends BaseTimeEntity { // 1회 미션을 저장 
     @OneToMany(mappedBy = "missionArchive", cascade = CascadeType.REMOVE)
     private List<MissionHeart> heartList = new ArrayList<>();
 
+    //반정규화
+    private Long commentNum;
 
     public void updateArchive(MissionArchiveReq missionArchiveReq) {
         this.archive = missionArchiveReq.getArchive();
@@ -60,6 +61,13 @@ public void updateCount(Long count) {
         this.count = count;
     }
 
+    public void incrComNum() {
+        this.commentNum++;
+    }
+
+    public void decrComNum() {
+        this.commentNum--;
+    }
 
 
 }

src/main/java/com/moing/backend/domain/missionComment/application/mapper/MissionCommentMapper.java

@@ -0,0 +1,20 @@
+package com.moing.backend.domain.missionComment.application.mapper;
+
+import com.moing.backend.domain.comment.application.dto.request.CreateCommentRequest;
+import com.moing.backend.domain.missionArchive.domain.entity.MissionArchive;
+import com.moing.backend.domain.missionComment.domain.entity.MissionComment;
+import com.moing.backend.domain.teamMember.domain.entity.TeamMember;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Component;
+
+@Component
+@RequiredArgsConstructor
+public class MissionCommentMapper {
+    public static MissionComment toMissionComment(TeamMember teamMember, MissionArchive missionArchive, CreateCommentRequest createCommentRequest, boolean isLeader) {
+        MissionComment missionComment=new MissionComment();
+        missionComment.init(createCommentRequest.getContent(),isLeader);
+        missionComment.updateMissionArchive(missionArchive);
+        missionComment.updateTeamMember(teamMember);
+        return missionComment;
+    }
+}

src/main/java/com/moing/backend/domain/missionComment/application/service/CreateMissionCommentUseCase.java

@@ -0,0 +1,41 @@
+package com.moing.backend.domain.missionComment.application.service;
+
+import com.moing.backend.domain.boardComment.application.service.SendCommentAlarmUseCase;
+import com.moing.backend.domain.comment.application.dto.request.CreateCommentRequest;
+import com.moing.backend.domain.comment.application.dto.response.CreateCommentResponse;
+import com.moing.backend.domain.missionComment.application.mapper.MissionCommentMapper;
+import com.moing.backend.domain.missionComment.domain.entity.MissionComment;
+import com.moing.backend.domain.missionComment.domain.service.MissionCommentSaveService;
+import com.moing.backend.domain.team.application.service.CheckLeaderUseCase;
+import com.moing.backend.global.response.BaseMissionServiceResponse;
+import com.moing.backend.global.utils.BaseMissionService;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Service;
+
+import javax.transaction.Transactional;
+
+@Service
+@RequiredArgsConstructor
+@Transactional
+public class CreateMissionCommentUseCase {
+
+    private final MissionCommentSaveService missionCommentSaveService;
+    private final BaseMissionService baseMissionService;
+    private final CheckLeaderUseCase checkLeaderUseCase;
+    private final SendCommentAlarmUseCase sendCommentAlarmUseCase;
+    /**
+     * 게시글 댓글 생성
+     */
+    public CreateCommentResponse createBoardComment(String socialId, Long teamId, Long missionArchiveId, CreateCommentRequest createCommentRequest) {
+        // 1. 미션 게시글 댓글 생성
+        BaseMissionServiceResponse data = baseMissionService.getCommonData(socialId, teamId, missionArchiveId);
+        boolean isLeader = checkLeaderUseCase.isTeamLeader(data.getMember(), data.getTeam());
+        MissionComment missionComment = missionCommentSaveService.saveComment(MissionCommentMapper.toMissionComment(data.getTeamMember(), data.getMissionArchive(), createCommentRequest, isLeader));
+        // 2. 미션 게시글 댓글 개수 증가
+        data.getMissionArchive().incrComNum();
+//        // 3. 미션 게시글 댓글 알림
+//        sendCommentAlarmUseCase.sendNewUploadAlarm(data, missionComment);
+        return new CreateCommentResponse(missionComment.getMissionCommentId());
+    }
+}
+

src/main/java/com/moing/backend/domain/missionComment/application/service/DeleteMissionCommentUseCase.java

@@ -0,0 +1,39 @@
+package com.moing.backend.domain.missionComment.application.service;
+
+import com.moing.backend.domain.boardComment.exception.NotAuthByBoardCommentException;
+import com.moing.backend.domain.missionComment.domain.entity.MissionComment;
+import com.moing.backend.domain.missionComment.domain.service.MissionCommentDeleteService;
+import com.moing.backend.domain.missionComment.domain.service.MissionCommentGetService;
+import com.moing.backend.global.response.BaseMissionServiceResponse;
+import com.moing.backend.global.utils.BaseMissionService;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Service;
+
+import javax.transaction.Transactional;
+
+@Service
+@Transactional
+@RequiredArgsConstructor
+public class DeleteMissionCommentUseCase {
+
+    private final MissionCommentGetService missionCommentGetService;
+    private final MissionCommentDeleteService missionCommentDeleteService;
+    private final BaseMissionService baseMissionService;
+
+    /**
+     * 게시글 댓글 삭제
+     */
+
+    public void deleteMissionComment(String socialId, Long teamId, Long missionArchiveId, Long boardCommentId){
+        // 1. 게시글 댓글 조회
+        BaseMissionServiceResponse data = baseMissionService.getCommonData(socialId, teamId, missionArchiveId);
+        MissionComment missionComment =missionCommentGetService.getComment(boardCommentId);
+        // 2. 게시글 댓글 작성자만
+        if (data.getTeamMember() == missionComment.getTeamMember()) {
+            // 3. 삭제
+            missionCommentDeleteService.deleteComment(missionComment);
+            // 4. 댓글 개수 줄이기
+            data.getMissionArchive().decrComNum();
+        } else throw new NotAuthByBoardCommentException();
+    }
+}

src/main/java/com/moing/backend/domain/missionComment/application/service/GetMissionCommentUseCase.java

@@ -0,0 +1,27 @@
+package com.moing.backend.domain.missionComment.application.service;
+
+import com.moing.backend.domain.comment.application.dto.response.GetCommentResponse;
+import com.moing.backend.domain.missionComment.domain.service.MissionCommentGetService;
+import com.moing.backend.global.response.BaseMissionServiceResponse;
+import com.moing.backend.global.utils.BaseMissionService;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Service;
+
+import javax.transaction.Transactional;
+
+@Service
+@Transactional
+@RequiredArgsConstructor
+public class GetMissionCommentUseCase {
+
+    private final MissionCommentGetService missionCommentGetService;
+    private final BaseMissionService baseMissionService;
+
+    /**
+     * 게시글 댓글 전체 조회
+     */
+    public GetCommentResponse getBoardCommentAll(String socialId, Long teamId, Long missionArchiveId){
+        BaseMissionServiceResponse data = baseMissionService.getCommonData(socialId, teamId, missionArchiveId);
+        return missionCommentGetService.getCommentAll(missionArchiveId, data.getTeamMember());
+    }
+}

src/main/java/com/moing/backend/domain/missionComment/application/service/SendMissionAlarmUseCase.java

@@ -0,0 +1,4 @@
+package com.moing.backend.domain.missionComment.application.service;
+
+public class SendMissionAlarmUseCase {
+}

src/main/java/com/moing/backend/domain/missionComment/domain/entity/MissionComment.java

@@ -0,0 +1,48 @@
+package com.moing.backend.domain.missionComment.domain.entity;
+
+import com.moing.backend.domain.comment.domain.entity.Comment;
+import com.moing.backend.domain.missionArchive.domain.entity.MissionArchive;
+import com.moing.backend.domain.teamMember.domain.entity.TeamMember;
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+
+import javax.persistence.*;
+
+@Entity
+@Builder
+@NoArgsConstructor
+@AllArgsConstructor
+@Getter
+public class MissionComment extends Comment {
+
+    @Id
+    @GeneratedValue(strategy = GenerationType.IDENTITY)
+    @Column(name = "mission_comment_id")
+    private Long missionCommentId;
+
+    @ManyToOne(fetch = FetchType.LAZY)
+    @JoinColumn(name = "team_member_id")
+    private TeamMember teamMember;
+
+    @ManyToOne(fetch = FetchType.LAZY)
+    @JoinColumn(name = "mission_archive_id")
+    private MissionArchive missionArchive;
+
+    /**
+     * 연관관계 매핑
+     */
+    public void updateMissionArchive(MissionArchive missionArchive) {
+        this.missionArchive=missionArchive;
+    }
+
+    public void updateTeamMember(TeamMember teamMember) {
+        this.teamMember = teamMember;
+    }
+
+    public void init(String content, boolean isLeader){
+        this.content=content;
+        this.isLeader=isLeader;
+    }
+}

src/main/java/com/moing/backend/domain/missionComment/domain/repository/MissionCommentCustomRepository.java

@@ -0,0 +1,14 @@
+package com.moing.backend.domain.missionComment.domain.repository;
+
+import com.moing.backend.domain.comment.application.dto.response.GetCommentResponse;
+import com.moing.backend.domain.history.application.dto.response.NewUploadInfo;
+import com.moing.backend.domain.teamMember.domain.entity.TeamMember;
+
+import java.util.List;
+import java.util.Optional;
+
+public interface MissionCommentCustomRepository {
+    GetCommentResponse findMissionCommentAll(Long missionArchiveId, TeamMember teamMember);
+
+    Optional<List<NewUploadInfo>> findNewUploadInfo(Long memberId, Long missionArchiveId);
+}

src/main/java/com/moing/backend/domain/missionComment/domain/repository/MissionCommentCustomRepositoryImpl.java

@@ -0,0 +1,86 @@
+package com.moing.backend.domain.missionComment.domain.repository;
+
+import com.moing.backend.domain.block.domain.repository.BlockRepositoryUtils;
+import com.moing.backend.domain.comment.application.dto.response.CommentBlocks;
+import com.moing.backend.domain.comment.application.dto.response.GetCommentResponse;
+import com.moing.backend.domain.comment.application.dto.response.QCommentBlocks;
+import com.moing.backend.domain.history.application.dto.response.NewUploadInfo;
+import com.moing.backend.domain.teamMember.domain.entity.QTeamMember;
+import com.moing.backend.domain.teamMember.domain.entity.TeamMember;
+import com.querydsl.core.types.ExpressionUtils;
+import com.querydsl.core.types.Projections;
+import com.querydsl.core.types.dsl.BooleanExpression;
+import com.querydsl.jpa.JPAExpressions;
+import com.querydsl.jpa.impl.JPAQueryFactory;
+
+import javax.persistence.EntityManager;
+import java.util.List;
+import java.util.Optional;
+
+import static com.moing.backend.domain.member.domain.entity.QMember.member;
+import static com.moing.backend.domain.missionComment.domain.entity.QMissionComment.missionComment;
+import static com.moing.backend.domain.teamMember.domain.entity.QTeamMember.teamMember;
+
+public class MissionCommentCustomRepositoryImpl implements MissionCommentCustomRepository{
+
+    private final JPAQueryFactory queryFactory;
+
+    public MissionCommentCustomRepositoryImpl(EntityManager em) {
+        this.queryFactory = new JPAQueryFactory(em);
+    }
+
+
+    @Override
+    public GetCommentResponse findMissionCommentAll(Long missionArchiveId, TeamMember teamMember) {
+
+        BooleanExpression blockCondition = BlockRepositoryUtils.blockCondition(teamMember.getTeamMemberId(), missionComment.teamMember.member.memberId);
+
+        List<CommentBlocks> commentBlocks = queryFactory
+                .select(new QCommentBlocks(
+                        missionComment.missionCommentId,
+                        missionComment.content,
+                        missionComment.teamMember.member.nickName,
+                        missionComment.isLeader,
+                        missionComment.teamMember.member.profileImage,
+                        ExpressionUtils.as(JPAExpressions
+                                .selectOne()
+                                .from(QTeamMember.teamMember)
+                                .where(QTeamMember.teamMember.eq(teamMember)
+                                        .and(QTeamMember.teamMember.eq(missionComment.teamMember)))
+                                .exists(), "isWriter"),
+                        missionComment.teamMember.isDeleted,
+                        missionComment.createdDate,
+                        missionComment.teamMember.member.memberId))
+                .from(missionComment)
+                .leftJoin(missionComment.teamMember, QTeamMember.teamMember)
+                .leftJoin(missionComment.teamMember.member, member)
+                .where(missionComment.missionArchive.id.eq(missionArchiveId)
+                        .and(blockCondition))
+                .orderBy(missionComment.createdDate.asc())
+                .fetch();
+
+        return new GetCommentResponse(commentBlocks);
+    }
+
+    @Override
+    public Optional<List<NewUploadInfo>> findNewUploadInfo(Long memberId, Long missionArchiveId) {
+        BooleanExpression blockCondition= BlockRepositoryUtils.blockCondition(missionComment.teamMember.member.memberId, memberId);
+
+        List<NewUploadInfo> result = queryFactory.select(Projections.constructor(NewUploadInfo.class,
+                        missionComment.teamMember.member.fcmToken,
+                        missionComment.teamMember.member.memberId,
+                        missionComment.teamMember.member.isNewUploadPush,
+                        missionComment.teamMember.member.isSignOut))
+                .distinct()
+                .from(missionComment)
+                .leftJoin(missionComment.teamMember, teamMember)
+                .leftJoin(missionComment.teamMember.member, member)
+                .where(missionComment.missionArchive.id.eq(missionArchiveId) //게시글의 댓글인데
+                        .and(missionComment.teamMember.member.memberId.ne(memberId)) //나는 포함 안하고
+                        .and(missionComment.teamMember.isDeleted.eq(false)) //탈퇴한 사람도 포함 안함
+                        .and(blockCondition))
+                .fetch();
+
+        return result.isEmpty() ? Optional.empty() : Optional.of(result);
+    }
+}