Merge pull request #361 from TaskFlow-CLAP/CLAP-300

starboxxxx · web-flow · commit 3178e194f23d · 2025-02-06T16:19:02.000+09:00
CLAP-300 Redirection 주소 연결 작업
diff --git a/src/main/java/clap/server/adapter/outbound/api/EmailClient.java b/src/main/java/clap/server/adapter/outbound/api/EmailClient.java
@@ -20,12 +20,12 @@ public class EmailClient implements SendEmailPort, SendWebhookEmailPort {
     private final JavaMailSender mailSender;
 
     @Override
-    public void sendWebhookEmail(PushNotificationTemplate request) {
+    public void sendWebhookEmail(PushNotificationTemplate request, String taskDetailUrl) {
         try {
             MimeMessage mimeMessage = mailSender.createMimeMessage();
             MimeMessageHelper helper = new MimeMessageHelper(mimeMessage, true, "UTF-8");
 
-            EmailTemplate template = emailTemplateBuilder.createWebhookTemplate(request);
+            EmailTemplate template = emailTemplateBuilder.createWebhookTemplate(request, taskDetailUrl);
             helper.setTo(template.email());
             helper.setSubject(template.subject());
             helper.setText(template.body(), true);
diff --git a/src/main/java/clap/server/adapter/outbound/api/EmailTemplateBuilder.java b/src/main/java/clap/server/adapter/outbound/api/EmailTemplateBuilder.java
@@ -13,11 +13,10 @@ public class EmailTemplateBuilder {
 
     private final SpringTemplateEngine templateEngine;
 
-    public EmailTemplate createWebhookTemplate(PushNotificationTemplate request) {
+    public EmailTemplate createWebhookTemplate(PushNotificationTemplate request, String taskDetailUrl) {
         Context context = new Context();
         String templateName = "";
         String subject = "";
-        String taskDetailUrl = "https://www.naver.com"; //ToDo task 상세 조회페이지 url 추가
         switch (request.notificationType()) {
             case TASK_REQUESTED:
                 templateName = "task-request";
@@ -49,6 +48,7 @@ public EmailTemplate createWebhookTemplate(PushNotificationTemplate request) {
                 context.setVariable("title", request.taskName());
                 break;
             case COMMENT:
+                templateName = "comment";
                 subject = "[TaskFlow 알림] 댓글이 작성되었습니다.";
                 context.setVariable("taskDetailUrl", taskDetailUrl);
                 context.setVariable("comment", request.message());
diff --git a/src/main/java/clap/server/adapter/outbound/api/KakaoWorkBlockBuilder.java b/src/main/java/clap/server/adapter/outbound/api/KakaoWorkBlockBuilder.java
@@ -14,8 +14,7 @@ public class KakaoWorkBlockBuilder {
 
     private final ObjectMapper objectMapper;
 
-    public String makeObjectBlock(PushNotificationTemplate request){
-        String taskDetailUrl = "https://www.naver.com";
+    public String makeObjectBlock(PushNotificationTemplate request, String taskDetailUrl){
         return switch (request.notificationType()) {
             case TASK_REQUESTED -> makeTaskRequestBlock(request, taskDetailUrl);
             case STATUS_SWITCHED -> makeTaskStatusBlock(request, taskDetailUrl);
diff --git a/src/main/java/clap/server/adapter/outbound/api/KakaoWorkClient.java b/src/main/java/clap/server/adapter/outbound/api/KakaoWorkClient.java
@@ -25,11 +25,11 @@ public class KakaoWorkClient implements SendKaKaoWorkPort {
     private final KakaoWorkBlockBuilder kakaoWorkBlockBuilder;
 
     @Override
-    public void sendKakaoWork(PushNotificationTemplate request) {
+    public void sendKakaoWork(PushNotificationTemplate request, String taskDetailUrl) {
         RestTemplate restTemplate = new RestTemplate();
 
         // Payload 생성
-        String payload = kakaoWorkBlockBuilder.makeObjectBlock(request);
+        String payload = kakaoWorkBlockBuilder.makeObjectBlock(request, taskDetailUrl);
 
         // HTTP 요청 헤더 설정
         HttpHeaders headers = new HttpHeaders();
diff --git a/src/main/java/clap/server/application/port/outbound/webhook/SendKaKaoWorkPort.java b/src/main/java/clap/server/application/port/outbound/webhook/SendKaKaoWorkPort.java
@@ -4,5 +4,5 @@
 
 public interface SendKaKaoWorkPort {
 
-    void sendKakaoWork(PushNotificationTemplate request);
+    void sendKakaoWork(PushNotificationTemplate request, String taskDetailUrl);
 }
diff --git a/src/main/java/clap/server/application/port/outbound/webhook/SendWebhookEmailPort.java b/src/main/java/clap/server/application/port/outbound/webhook/SendWebhookEmailPort.java
@@ -4,5 +4,5 @@
 
 public interface SendWebhookEmailPort {
 
-    void sendWebhookEmail(PushNotificationTemplate request);
+    void sendWebhookEmail(PushNotificationTemplate request, String taskDetailUrl);
 }
diff --git a/src/main/java/clap/server/application/service/history/PostCommentService.java b/src/main/java/clap/server/application/service/history/PostCommentService.java
@@ -92,6 +92,7 @@ private String saveAttachment(MultipartFile file, Task task, Comment comment) {
     }
 
     private void publishNotification(Member receiver, Task task, String message, String commenterName) {
-        sendNotificationService.sendPushNotification(receiver, NotificationType.COMMENT, task, message, commenterName);
+        boolean isManager = receiver.getMemberInfo().getRole() == MemberRole.ROLE_MANAGER;
+        sendNotificationService.sendPushNotification(receiver, NotificationType.COMMENT, task, message, commenterName, isManager);
     }
 }
diff --git a/src/main/java/clap/server/application/service/task/ApprovalTaskService.java b/src/main/java/clap/server/application/service/task/ApprovalTaskService.java
@@ -3,6 +3,7 @@
 import clap.server.adapter.inbound.web.dto.task.request.ApprovalTaskRequest;
 import clap.server.adapter.inbound.web.dto.task.response.ApprovalTaskResponse;
 import clap.server.adapter.inbound.web.dto.task.response.FindApprovalFormResponse;
+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.mapper.TaskResponseMapper;
@@ -73,10 +74,11 @@ public FindApprovalFormResponse findApprovalForm(Long managerId, Long taskId) {
 
     private void publishNotification(List<Member> receivers, Task task, String processorName){
         receivers.forEach(receiver -> {
+            boolean isManager = receiver.getMemberInfo().getRole() == MemberRole.ROLE_MANAGER;
             sendNotificationService.sendPushNotification(receiver, NotificationType.PROCESSOR_ASSIGNED,
-                    task, processorName, null);
+                    task, processorName, null, isManager);
         });
-        sendNotificationService.sendAgitNotification(NotificationType.PROCESSOR_CHANGED,
+        sendNotificationService.sendAgitNotification(NotificationType.PROCESSOR_ASSIGNED,
                 task, processorName, null);
     }
 
diff --git a/src/main/java/clap/server/application/service/task/CreateTaskService.java b/src/main/java/clap/server/application/service/task/CreateTaskService.java
@@ -3,6 +3,7 @@
 import clap.server.adapter.inbound.web.dto.task.request.CreateTaskRequest;
 import clap.server.adapter.inbound.web.dto.task.response.CreateTaskResponse;
 
+import clap.server.adapter.outbound.persistense.entity.member.constant.MemberRole;
 import clap.server.adapter.outbound.persistense.entity.notification.constant.NotificationType;
 import clap.server.application.mapper.AttachmentMapper;
 import clap.server.application.mapper.TaskResponseMapper;
@@ -61,8 +62,10 @@ private void saveAttachments(List<MultipartFile> files, Task task) {
 
     private void publishNotification(Task task) {
         List<Member> reviewers = memberService.findReviewers();
-        reviewers.forEach(reviewer -> {sendNotificationService.sendPushNotification(reviewer, NotificationType.TASK_REQUESTED,
-                task, null, null);});
+        reviewers.forEach(reviewer -> {
+            boolean isManager = reviewer.getMemberInfo().getRole() == MemberRole.ROLE_MANAGER;
+            sendNotificationService.sendPushNotification(reviewer, NotificationType.TASK_REQUESTED,
+                task, null, null, isManager);});
 
         sendNotificationService.sendAgitNotification(NotificationType.TASK_REQUESTED,
                 task, null, null);
diff --git a/src/main/java/clap/server/application/service/task/UpdateTaskBoardService.java b/src/main/java/clap/server/application/service/task/UpdateTaskBoardService.java
@@ -1,6 +1,7 @@
 package clap.server.application.service.task;
 
 import clap.server.adapter.inbound.web.dto.task.request.UpdateTaskOrderRequest;
+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.adapter.outbound.persistense.entity.task.constant.TaskStatus;
@@ -184,7 +185,8 @@ public void validateRequest(UpdateTaskOrderRequest request, TaskStatus targetSta
     private void publishNotification(Task task, NotificationType notificationType, String message, String taskTitle) {
         List<Member> receivers = List.of(task.getRequester(), task.getProcessor());
         receivers.forEach(receiver -> {
-            sendNotificationService.sendPushNotification(receiver, notificationType, task, message, null);
+            boolean isManager = receiver.getMemberInfo().getRole() == MemberRole.ROLE_MANAGER;
+            sendNotificationService.sendPushNotification(receiver, notificationType, task, message, null, isManager);
         });
         sendNotificationService.sendAgitNotification(notificationType,
                 task, message, null);
diff --git a/src/main/java/clap/server/application/service/task/UpdateTaskService.java b/src/main/java/clap/server/application/service/task/UpdateTaskService.java
@@ -3,6 +3,7 @@
 import clap.server.adapter.inbound.web.dto.task.request.UpdateTaskLabelRequest;
 import clap.server.adapter.inbound.web.dto.task.request.UpdateTaskProcessorRequest;
 import clap.server.adapter.inbound.web.dto.task.request.UpdateTaskRequest;
+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.adapter.outbound.persistense.entity.task.constant.TaskStatus;
@@ -103,7 +104,8 @@ public void updateTaskProcessor(Long taskId, Long userId, UpdateTaskProcessorReq
         TaskHistory taskHistory = TaskHistory.createTaskHistory(TaskHistoryType.PROCESSOR_CHANGED, task, null, processor,null);
         commandTaskHistoryPort.save(taskHistory);
 
-        publishNotification(updateTask, NotificationType.PROCESSOR_CHANGED, processor.getNickname());
+        List<Member> receivers = List.of(updateTask.getRequester(), updateTask.getProcessor());
+        publishNotification(receivers, updateTask, NotificationType.PROCESSOR_CHANGED, processor.getNickname());
     }
 
     @Transactional
@@ -137,13 +139,13 @@ private List<Attachment> validateAndGetAttachments(List<Long> attachmentIdsToDel
         return attachmentsOfTask;
     }
 
-    private void publishNotification(Task task, NotificationType notificationType, String message) {
-        List<Member> receivers = List.of(task.getRequester(), task.getProcessor());
+    private void publishNotification(List<Member> receivers, Task task, NotificationType notificationType, String message) {
         receivers.forEach(receiver -> {
+            boolean isManager = receiver.getMemberInfo().getRole() == MemberRole.ROLE_MANAGER;
             sendNotificationService.sendPushNotification(receiver, notificationType,
-                    task, message, null);
+                    task, message, null, isManager);
         });
 
-            sendNotificationService.sendAgitNotification(notificationType, task, message, null);
+        sendNotificationService.sendAgitNotification(notificationType, task, message, null);
     }
 }
diff --git a/src/main/java/clap/server/application/service/webhook/NotificationSender.java b/src/main/java/clap/server/application/service/webhook/NotificationSender.java
@@ -3,5 +3,5 @@
 import clap.server.adapter.outbound.api.dto.PushNotificationTemplate;
 
 public interface NotificationSender {
-    void send(PushNotificationTemplate template);
+    void send(PushNotificationTemplate template, String taskDetailUrl);
 }
diff --git a/src/main/java/clap/server/application/service/webhook/SendKaKaoWorkService.java b/src/main/java/clap/server/application/service/webhook/SendKaKaoWorkService.java
@@ -11,7 +11,7 @@ public class SendKaKaoWorkService implements NotificationSender {
 
     private final SendKaKaoWorkPort sendKaKaoWorkPort;
 
-    public void send(PushNotificationTemplate request) {
-        sendKaKaoWorkPort.sendKakaoWork(request);
+    public void send(PushNotificationTemplate request, String taskDetailUrl) {
+        sendKaKaoWorkPort.sendKakaoWork(request, taskDetailUrl);
     }
 }
diff --git a/src/main/java/clap/server/application/service/webhook/SendNotificationService.java b/src/main/java/clap/server/application/service/webhook/SendNotificationService.java
@@ -74,6 +74,19 @@ public void sendPushNotification(Member receiver, NotificationType notificationT
         allOf.join();
     }
 
+    private String extractTaskUrl(NotificationType notificationType, Task task, Boolean isManager) {
+        String taskDetailUrl = "http://localhost:5173/my-request?taskId=" + task.getTaskId();
+        if (isManager) {
+            if (notificationType == NotificationType.TASK_REQUESTED) {
+                taskDetailUrl = "http://localhost:5173/requested?taskId=" + task.getTaskId();
+            }
+            else {
+                taskDetailUrl = "http://localhost:5173/my-task?taskId=" + task.getTaskId();
+            }
+        }
+        return taskDetailUrl;
+    }
+
     @Async("notificationExecutor")
     public void sendAgitNotification(NotificationType notificationType,
                                      Task task, String message, String commenterName) {
diff --git a/src/main/java/clap/server/application/service/webhook/SendWebhookEmailService.java b/src/main/java/clap/server/application/service/webhook/SendWebhookEmailService.java
@@ -11,7 +11,7 @@ public class SendWebhookEmailService implements NotificationSender {
 
     private final SendWebhookEmailPort sendWebhookEmailPort;
 
-    public void send(PushNotificationTemplate request) {
-        sendWebhookEmailPort.sendWebhookEmail(request);
+    public void send(PushNotificationTemplate request, String taskDetailUrl) {
+        sendWebhookEmailPort.sendWebhookEmail(request, taskDetailUrl);
     }
 }

Original file line number	Diff line number	Diff line change
`@@ -4,5 +4,5 @@`
`4`	`4`
`5`	`5`	`public interface SendKaKaoWorkPort {`
`6`	`6`
`7`		`- void sendKakaoWork(PushNotificationTemplate request);`
	`7`	`+ void sendKakaoWork(PushNotificationTemplate request, String taskDetailUrl);`
`8`	`8`	`}`
Original file line number	Diff line number	Diff line change
`@@ -4,5 +4,5 @@`
`4`	`4`
`5`	`5`	`public interface SendWebhookEmailPort {`
`6`	`6`
`7`		`- void sendWebhookEmail(PushNotificationTemplate request);`
	`7`	`+ void sendWebhookEmail(PushNotificationTemplate request, String taskDetailUrl);`
`8`	`8`	`}`
Original file line number	Diff line number	Diff line change
`@@ -92,6 +92,7 @@ private String saveAttachment(MultipartFile file, Task task, Comment comment) {`
`92`	`92`	`}`
`93`	`93`
`94`	`94`	`private void publishNotification(Member receiver, Task task, String message, String commenterName) {`
`95`		`- sendNotificationService.sendPushNotification(receiver, NotificationType.COMMENT, task, message, commenterName);`
	`95`	`+ boolean isManager = receiver.getMemberInfo().getRole() == MemberRole.ROLE_MANAGER;`
	`96`	`+ sendNotificationService.sendPushNotification(receiver, NotificationType.COMMENT, task, message, commenterName, isManager);`
`96`	`97`	`}`
`97`	`98`	`}`