CLAP-393 Fix : 사용자가 작업 취소시 해당 알림 삭제 처리

Author: starboxxxx

src/main/java/clap/server/adapter/outbound/persistense/NotificationPersistenceAdapter.java

@@ -42,6 +42,13 @@ public List<Notification> findNotificationsByMemberId(final Long memberId) {
                 .collect(Collectors.toList());
     }
 
+    @Override
+    public List<Notification> findNotificationsByTaskId(Long taskId) {
+        return notificationRepository.findByTask_TaskId(taskId)
+                .stream().map(notificationPersistenceMapper::toDomain)
+                .collect(Collectors.toList());
+    }
+
     @Override
     public Integer countNotification(final Long memberId) {
         return notificationRepository.countByIsReadFalseAndReceiver_MemberId(memberId);
@@ -51,4 +58,9 @@ public Integer countNotification(final Long memberId) {
     public void save(final Notification notification) {
         notificationRepository.save(notificationPersistenceMapper.toEntity(notification));
     }
+
+    @Override
+    public void delete(Notification notification) {
+        notificationRepository.delete(notificationPersistenceMapper.toEntity(notification));
+    }
 }

src/main/java/clap/server/adapter/outbound/persistense/repository/notification/NotificationRepository.java

@@ -27,5 +27,7 @@ Slice<NotificationEntity> findAllByReceiver_MemberIdOrderByCreatedAtDesc(
             "AND n.task.isDeleted = false")
     List<NotificationEntity> findAllByReceiver_MemberId(Long memberId);
 
+    List<NotificationEntity> findByTask_TaskId(Long taskId);
+
     Integer countByIsReadFalseAndReceiver_MemberId(Long memberId);
 }

src/main/java/clap/server/application/port/outbound/notification/CommandNotificationPort.java

@@ -5,4 +5,6 @@
 
 public interface CommandNotificationPort {
     void save(Notification notification);
+
+    void delete(Notification notification);
 }

src/main/java/clap/server/application/port/outbound/notification/LoadNotificationPort.java

@@ -16,5 +16,7 @@ public interface LoadNotificationPort {
 
     List<Notification> findNotificationsByMemberId(Long memberId);
 
+    List<Notification> findNotificationsByTaskId(Long taskId);
+
     Integer countNotification(Long memberId);
 }

src/main/java/clap/server/application/service/task/CancelTaskService.java

@@ -2,24 +2,37 @@
 
 import clap.server.application.port.inbound.domain.TaskService;
 import clap.server.application.port.inbound.task.CancelTaskUsecase;
+import clap.server.application.port.outbound.notification.CommandNotificationPort;
+import clap.server.application.port.outbound.notification.LoadNotificationPort;
 import clap.server.common.annotation.architecture.ApplicationService;
+import clap.server.domain.model.notification.Notification;
 import clap.server.domain.model.task.Task;
 import lombok.RequiredArgsConstructor;
 import org.springframework.transaction.annotation.Transactional;
 
-import java.util.Objects;
+import java.util.List;
 
 
 @ApplicationService
 @RequiredArgsConstructor
 @Transactional
 public class CancelTaskService implements CancelTaskUsecase {
     private final TaskService taskService;
+    private final LoadNotificationPort loadNotificationPort;
+    private final CommandNotificationPort commandNotificationPort;
 
     @Override
     public void cancleTask(Long taskId, Long memberId) {
         Task task = taskService.findById(taskId);
+        deleteNotification(task.getTaskId());
         task.cancelTask(memberId);
         taskService.upsert(task);
     }
+
+    private void deleteNotification(Long taskId) {
+        List<Notification> notificationList =  loadNotificationPort.findNotificationsByTaskId(taskId);
+
+        notificationList.forEach(commandNotificationPort::delete);
+    }
+
 }