CLAP-267 Feat: 상태 변경시에 알림 전송 로직 추가

<footer>
- 관련: #302

Author: joowojr

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

@@ -1,12 +1,14 @@
 package clap.server.application.service.task;
 
 import clap.server.adapter.inbound.web.dto.task.request.UpdateTaskOrderRequest;
+import clap.server.adapter.outbound.persistense.entity.notification.constant.NotificationType;
 import clap.server.adapter.outbound.persistense.entity.task.constant.TaskStatus;
 import clap.server.application.port.inbound.domain.MemberService;
 import clap.server.application.port.inbound.domain.TaskService;
 import clap.server.application.port.inbound.task.UpdateTaskBoardUsecase;
 import clap.server.application.port.inbound.task.UpdateTaskOrderAndStatusUsecase;
 import clap.server.application.port.outbound.task.LoadTaskPort;
+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.Task;
@@ -19,13 +21,16 @@
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.transaction.annotation.Transactional;
 
+import java.util.List;
+
 @Slf4j
 @ApplicationService
 @RequiredArgsConstructor
 class UpdateTaskBoardService implements UpdateTaskBoardUsecase, UpdateTaskOrderAndStatusUsecase {
     private final MemberService memberService;
     private final TaskService taskService;
     private final LoadTaskPort loadTaskPort;
+    private final SendNotificationService sendNotificationService;
 
     private final TaskOrderCalculationPolicy taskOrderCalculationPolicy;
     private final ProcessorValidationPolicy processorValidationPolicy;
@@ -98,6 +103,7 @@ public void updateTaskOrderAndStatus(Long processorId, UpdateTaskOrderRequest re
         Task targetTask = taskService.findById(request.targetTaskId());
         processorValidationPolicy.validateProcessor(processorId, targetTask);
 
+        Task updatedTask;
         Task prevTask;
         Task nextTask;
 
@@ -116,44 +122,47 @@ public void updateTaskOrderAndStatus(Long processorId, UpdateTaskOrderRequest re
             // 하나의 task만 존재할 경우 상태만 update
             if (prevTask == null && nextTask == null) {
                 targetTask.updateTaskStatus(targetStatus);
-                taskService.upsert(targetTask);
+                updatedTask = taskService.upsert(targetTask);
             } else if (prevTask == null) {
                 long newOrder = taskOrderCalculationPolicy.calculateOrderForBottom(null, nextTask);
-                updateNewTaskOrderAndStatus(targetStatus, targetTask, newOrder);
+                updatedTask = updateNewTaskOrderAndStatus(targetStatus, targetTask, newOrder);
             } else if (nextTask == null) {
                 long newOrder = taskOrderCalculationPolicy.calculateOrderForBottom(prevTask, null);
-                updateNewTaskOrderAndStatus(targetStatus, targetTask, newOrder);
+                updatedTask = updateNewTaskOrderAndStatus(targetStatus, targetTask, newOrder);
             } else {
                 long newOrder = taskOrderCalculationPolicy.calculateNewProcessorOrder(prevTask.getProcessorOrder(), nextTask.getProcessorOrder());
-                updateNewTaskOrderAndStatus(targetStatus, targetTask, newOrder);
+                updatedTask = updateNewTaskOrderAndStatus(targetStatus, targetTask, newOrder);
             }
         } else if (request.prevTaskId() == 0) {
             nextTask = findByIdAndStatus(request.nextTaskId(), targetStatus);
             // 해당 상태에서 바로 앞 있는 작업 찾기
             prevTask = loadTaskPort.findPrevOrderTaskByProcessorOrderAndStatus(processorId, targetStatus, nextTask.getProcessorOrder()).orElse(null);
             long newOrder = taskOrderCalculationPolicy.calculateOrderForTop(prevTask, nextTask);
-            updateNewTaskOrderAndStatus(targetStatus, targetTask, newOrder);
+            updatedTask = updateNewTaskOrderAndStatus(targetStatus, targetTask, newOrder);
         } else if (request.nextTaskId() == 0) {
             prevTask = findByIdAndStatus(request.prevTaskId(), targetStatus);
             // 해당 상태에서 바로 뒤에 있는 작업 찾기
             nextTask = loadTaskPort.findNextOrderTaskByProcessorOrderAndStatus(processorId, targetStatus, prevTask.getProcessorOrder()).orElse(null);
             long newOrder = taskOrderCalculationPolicy.calculateOrderForBottom(prevTask, nextTask);
-            updateNewTaskOrderAndStatus(targetStatus, targetTask, newOrder);
+            updatedTask = updateNewTaskOrderAndStatus(targetStatus, targetTask, newOrder);
         } else {
             prevTask = findByIdAndStatus(request.prevTaskId(), targetStatus);
             nextTask = findByIdAndStatus(request.nextTaskId(), targetStatus);
             long newOrder = taskOrderCalculationPolicy.calculateNewProcessorOrder(prevTask.getProcessorOrder(), nextTask.getProcessorOrder());
-            updateNewTaskOrderAndStatus(targetStatus, targetTask, newOrder);
+            updatedTask = updateNewTaskOrderAndStatus(targetStatus, targetTask, newOrder);
         }
+
+        //TODO: 최종 단계에서 주석 처리 해제
+        //publishNotification(targetTask, NotificationType.STATUS_SWITCHED, String.valueOf(updatedTask.getTaskStatus()));
     }
 
     /**
      * 작업의 상태와 순서를 업데이트하는 메서드
      */
-    private void updateNewTaskOrderAndStatus(TaskStatus targetStatus, Task targetTask, long newOrder) {
+    private Task updateNewTaskOrderAndStatus(TaskStatus targetStatus, Task targetTask, long newOrder) {
         targetTask.updateProcessorOrder(newOrder);
         targetTask.updateTaskStatus(targetStatus);
-        taskService.upsert(targetTask);
+        return taskService.upsert(targetTask);
     }
 
     /**
@@ -166,5 +175,15 @@ public void validateRequest(UpdateTaskOrderRequest request, TaskStatus targetSta
         }
     }
 
+    private void publishNotification(Task task, NotificationType notificationType, String message) {
+        List<Member> receivers = List.of(task.getRequester(), task.getProcessor());
+        receivers.forEach(receiver -> {
+            sendNotificationService.sendPushNotification(receiver, notificationType,
+                    task, message, null);
+        });
+        sendNotificationService.sendAgitNotification(notificationType,
+                task, message, null);
+    }
+
 }