feat: 이벤트 기반 알림 생성 로직

src/main/java/com/fowoco/server/approval/application/ApprovalDomainEvents.java

@@ -0,0 +1,54 @@
+package com.fowoco.server.approval.application;
+
+import com.fowoco.server.auth.application.ActorContext;
+import com.fowoco.server.common.web.RequestMetadata;
+import com.fowoco.server.reliability.domain.DomainEventEnvelope;
+import com.fowoco.server.reliability.domain.EventActorType;
+import com.fowoco.server.reliability.domain.SafeEventPayload;
+import com.fowoco.server.task.domain.Task;
+import java.time.Instant;
+import java.util.Map;
+import java.util.Set;
+import java.util.UUID;
+
+final class ApprovalDomainEvents {
+
+    private static final String PAYLOAD_VERSION = "1";
+    private static final String AGGREGATE_TYPE = "Task";
+    private static final Set<String> APPROVAL_REQUESTED_FIELDS = Set.of(
+            "task_title",
+            "task_type"
+    );
+
+    private ApprovalDomainEvents() {
+    }
+
+    static DomainEventEnvelope approvalRequested(
+            UUID eventId,
+            Task task,
+            ActorContext actor,
+            RequestMetadata metadata,
+            Instant occurredAt
+    ) {
+        return new DomainEventEnvelope(
+                eventId,
+                "ApprovalRequested",
+                PAYLOAD_VERSION,
+                AGGREGATE_TYPE,
+                task.taskId(),
+                task.companyId(),
+                EventActorType.HR_USER,
+                actor.actorId(),
+                metadata.requestId(),
+                metadata.traceId(),
+                occurredAt,
+                SafeEventPayload.of(
+                        APPROVAL_REQUESTED_FIELDS,
+                        Map.of(
+                                "task_title", task.title(),
+                                "task_type", task.taskType()
+                        )
+                )
+        );
+    }
+}

src/main/java/com/fowoco/server/approval/application/ApprovalService.java

@@ -19,6 +19,7 @@
 import com.fowoco.server.common.error.ApiException;
 import com.fowoco.server.common.error.ErrorCode;
 import com.fowoco.server.common.id.UuidGenerator;
+import com.fowoco.server.reliability.application.port.DomainEventPublisher;
 import com.fowoco.server.common.security.TenantDatabaseContext;
 import com.fowoco.server.common.web.RequestMetadata;
 import com.fowoco.server.settings.application.port.CompanySettingsRepository;
@@ -58,6 +59,7 @@ public class ApprovalService implements ApprovalControlPort {
     private final SafeJsonService safeJsonService;
     private final UuidGenerator uuidGenerator;
     private final Clock clock;
+    private final DomainEventPublisher eventPublisher;
 
     public ApprovalService(
             ActorAuthorizer actorAuthorizer,
@@ -72,7 +74,8 @@ public ApprovalService(
             AuditEventRepository auditRepository,
             SafeJsonService safeJsonService,
             UuidGenerator uuidGenerator,
-            Clock clock
+            Clock clock,
+            DomainEventPublisher eventPublisher
     ) {
         this.actorAuthorizer = actorAuthorizer;
         this.tenantDatabaseContext = tenantDatabaseContext;
@@ -87,6 +90,7 @@ public ApprovalService(
         this.safeJsonService = safeJsonService;
         this.uuidGenerator = uuidGenerator;
         this.clock = clock;
+        this.eventPublisher = eventPublisher;
     }
 
     @Transactional
@@ -144,6 +148,13 @@ public ApprovalResult requestApproval(
                 metadata,
                 now
         );
+        eventPublisher.publish(ApprovalDomainEvents.approvalRequested(
+                uuidGenerator.generate(),
+                savedTask,
+                actor,
+                metadata,
+                now
+        ));
         return result(savedApproval, savedTask);
     }
 

src/main/java/com/fowoco/server/company/application/port/CompanyRepository.java

@@ -1,12 +1,12 @@
 package com.fowoco.server.company.application.port;
 
 import com.fowoco.server.company.domain.Company;
+import java.util.List;
 import java.util.Optional;
 import java.util.UUID;
 
 public interface CompanyRepository {
-
     Optional<Company> findById(UUID companyId);
-
     void insert(Company company);
+    List<UUID> findAllIds();
 }

src/main/java/com/fowoco/server/company/infrastructure/persistence/JpaCompanyRepository.java

@@ -3,6 +3,7 @@
 import com.fowoco.server.company.application.port.CompanyRepository;
 import com.fowoco.server.company.domain.Company;
 import jakarta.persistence.EntityManager;
+import java.util.List;
 import java.util.Objects;
 import java.util.Optional;
 import java.util.UUID;
@@ -30,4 +31,11 @@ public void insert(Company company) {
         entityManager.persist(CompanyJpaEntity.fromDomain(company));
         entityManager.flush();
     }
+
+    @Override
+    public List<UUID> findAllIds() {
+        return entityManager
+                .createQuery("SELECT company.companyId FROM CompanyJpaEntity company", UUID.class)
+                .getResultList();
+    }
 }

src/main/java/com/fowoco/server/notification/application/DueSoonCompanyNotifier.java

@@ -0,0 +1,60 @@
+package com.fowoco.server.notification.application;
+
+import com.fowoco.server.common.id.UuidGenerator;
+import com.fowoco.server.common.security.TenantDatabaseContext;
+import com.fowoco.server.notification.application.port.NotificationRepository;
+import com.fowoco.server.notification.domain.Notification;
+import com.fowoco.server.notification.domain.NotificationTargetType;
+import com.fowoco.server.task.application.port.TaskRepository;
+import com.fowoco.server.task.domain.Task;
+import java.time.Clock;
+import java.time.LocalDate;
+import java.util.UUID;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Propagation;
+import org.springframework.transaction.annotation.Transactional;
+
+@Service
+public class DueSoonCompanyNotifier {
+
+    private final TaskRepository taskRepository;
+    private final NotificationRepository notificationRepository;
+    private final TenantDatabaseContext tenantDatabaseContext;
+    private final UuidGenerator uuidGenerator;
+    private final Clock clock;
+
+    public DueSoonCompanyNotifier(
+            TaskRepository taskRepository,
+            NotificationRepository notificationRepository,
+            TenantDatabaseContext tenantDatabaseContext,
+            UuidGenerator uuidGenerator,
+            Clock clock
+    ) {
+        this.taskRepository = taskRepository;
+        this.notificationRepository = notificationRepository;
+        this.tenantDatabaseContext = tenantDatabaseContext;
+        this.uuidGenerator = uuidGenerator;
+        this.clock = clock;
+    }
+
+    @Transactional(propagation = Propagation.REQUIRES_NEW)
+    public void processCompany(UUID companyId, LocalDate today, LocalDate windowEnd) {
+        tenantDatabaseContext.setCompanyIdForCurrentTransaction(companyId);
+        taskRepository.findOpenTasksDueBetween(companyId, today, windowEnd)
+                .forEach(this::createDueSoonNotification);
+    }
+
+    private void createDueSoonNotification(Task task) {
+        Notification notification = Notification.create(
+                uuidGenerator.generate(),
+                task.companyId(),
+                task.createdBy(),
+                NotificationTargetType.TASK,
+                task.taskId(),
+                "마감이 임박했습니다: " + task.title(),
+                clock.instant(),
+                clock.instant()
+        );
+        notificationRepository.insert(notification);
+    }
+}

src/main/java/com/fowoco/server/notification/application/DueSoonNotificationScheduler.java

@@ -0,0 +1,38 @@
+package com.fowoco.server.notification.application;
+
+import com.fowoco.server.company.application.port.CompanyRepository;
+import java.time.Clock;
+import java.time.LocalDate;
+import java.time.ZoneId;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+
+@Component
+public class DueSoonNotificationScheduler {
+
+    private static final int UPCOMING_DAYS = 7;
+
+    private final CompanyRepository companyRepository;
+    private final DueSoonCompanyNotifier companyNotifier;
+    private final Clock clock;
+
+    public DueSoonNotificationScheduler(
+            CompanyRepository companyRepository,
+            DueSoonCompanyNotifier companyNotifier,
+            Clock clock
+    ) {
+        this.companyRepository = companyRepository;
+        this.companyNotifier = companyNotifier;
+        this.clock = clock;
+    }
+
+    @Scheduled(cron = "0 0 3 * * *", zone = "Asia/Seoul")
+    public void notifyDueSoonTasks() {
+        LocalDate today = LocalDate.now(clock.withZone(ZoneId.of("Asia/Seoul")));
+        LocalDate windowEnd = today.plusDays(UPCOMING_DAYS);
+
+        companyRepository.findAllIds().forEach(companyId ->
+                companyNotifier.processCompany(companyId, today, windowEnd)
+        );
+    }
+}

src/main/java/com/fowoco/server/notification/application/NotificationEventHandler.java

@@ -0,0 +1,143 @@
+package com.fowoco.server.notification.application;
+
+import com.fowoco.server.common.id.UuidGenerator;
+import com.fowoco.server.common.security.TenantDatabaseContext;
+import com.fowoco.server.notification.application.port.NotificationRepository;
+import com.fowoco.server.notification.domain.Notification;
+import com.fowoco.server.notification.domain.NotificationTargetType;
+import com.fowoco.server.reliability.application.port.DomainEventHandler;
+import com.fowoco.server.reliability.domain.DomainEventEnvelope;
+import com.fowoco.server.task.application.port.TaskRepository;
+import com.fowoco.server.task.domain.Task;
+import com.fowoco.server.task.domain.TaskSource;
+import java.time.Clock;
+import java.util.Set;
+import org.springframework.stereotype.Component;
+
+@Component
+public final class NotificationEventHandler implements DomainEventHandler {
+
+    private static final String HANDLER_NAME = "notificationFromTaskEvents";
+    private static final String TASK_CREATED = "TaskCreated";
+    private static final String APPROVAL_REQUESTED = "ApprovalRequested";
+    private static final String WORKER_RESPONSE_SUBMITTED = "WorkerResponseSubmitted";
+    private static final String TASK_NEEDS_INFO = "TaskNeedsInfo";
+    private static final Set<String> SUPPORTED_EVENTS =
+            Set.of(TASK_CREATED, APPROVAL_REQUESTED, WORKER_RESPONSE_SUBMITTED, TASK_NEEDS_INFO);
+
+    private final TaskRepository taskRepository;
+    private final NotificationRepository notificationRepository;
+    private final TenantDatabaseContext tenantDatabaseContext;
+    private final UuidGenerator uuidGenerator;
+    private final Clock clock;
+
+    public NotificationEventHandler(
+            TaskRepository taskRepository,
+            NotificationRepository notificationRepository,
+            TenantDatabaseContext tenantDatabaseContext,
+            UuidGenerator uuidGenerator,
+            Clock clock
+    ) {
+        this.taskRepository = taskRepository;
+        this.notificationRepository = notificationRepository;
+        this.tenantDatabaseContext = tenantDatabaseContext;
+        this.uuidGenerator = uuidGenerator;
+        this.clock = clock;
+    }
+
+    @Override
+    public String handlerName() {
+        return HANDLER_NAME;
+    }
+
+    @Override
+    public boolean supports(String eventType) {
+        return SUPPORTED_EVENTS.contains(eventType);
+    }
+
+    @Override
+    public void handle(DomainEventEnvelope event) {
+        if (TASK_CREATED.equals(event.eventType())) {
+            handleTaskCreated(event);
+        } else if (APPROVAL_REQUESTED.equals(event.eventType())) {
+            handleApprovalRequested(event);
+        } else if (WORKER_RESPONSE_SUBMITTED.equals(event.eventType())) {
+            handleWorkerResponseSubmitted(event);
+        } else if (TASK_NEEDS_INFO.equals(event.eventType())) {
+            handleTaskNeedsInfo(event);
+        }
+    }
+
+    private void handleTaskCreated(DomainEventEnvelope event) {
+        tenantDatabaseContext.setCompanyIdForCurrentTransaction(event.companyId());
+        Task task = taskRepository.findByIdAndCompanyId(event.aggregateId(), event.companyId())
+                .orElseThrow(() -> new IllegalStateException("task not found for TaskCreated event"));
+
+        if (task.source() != TaskSource.AI_CANDIDATE) {
+            return;
+        }
+
+        Notification notification = Notification.create(
+                uuidGenerator.generate(),
+                task.companyId(),
+                event.actorId(),
+                NotificationTargetType.TASK,
+                task.taskId(),
+                "Agent 분석이 완료됐습니다: " + task.title(),
+                event.occurredAt(),
+                clock.instant()
+        );
+        notificationRepository.insert(notification);
+    }
+
+    private void handleApprovalRequested(DomainEventEnvelope event) {
+        tenantDatabaseContext.setCompanyIdForCurrentTransaction(event.companyId());
+        Object taskTitle = event.payload().values().get("task_title");
+
+        Notification notification = Notification.create(
+                uuidGenerator.generate(),
+                event.companyId(),
+                event.actorId(),
+                NotificationTargetType.TASK,
+                event.aggregateId(),
+                "승인 요청이 도착했습니다: " + taskTitle,
+                event.occurredAt(),
+                clock.instant()
+        );
+        notificationRepository.insert(notification);
+    }
+
+    private void handleWorkerResponseSubmitted(DomainEventEnvelope event) {
+        tenantDatabaseContext.setCompanyIdForCurrentTransaction(event.companyId());
+        Object taskTitle = event.payload().values().get("task_title");
+
+        Notification notification = Notification.create(
+                uuidGenerator.generate(),
+                event.companyId(),
+                event.actorId(),
+                NotificationTargetType.TASK,
+                event.aggregateId(),
+                "문서 제출이 완료됐습니다: " + taskTitle,
+                event.occurredAt(),
+                clock.instant()
+        );
+        notificationRepository.insert(notification);
+    }
+
+    private void handleTaskNeedsInfo(DomainEventEnvelope event) {
+        tenantDatabaseContext.setCompanyIdForCurrentTransaction(event.companyId());
+        Object taskTitle = event.payload().values().get("task_title");
+
+        Notification notification = Notification.create(
+                uuidGenerator.generate(),
+                event.companyId(),
+                event.actorId(),
+                NotificationTargetType.TASK,
+                event.aggregateId(),
+                "문서 보완이 필요합니다: " + taskTitle,
+                event.occurredAt(),
+                clock.instant()
+        );
+        notificationRepository.insert(notification);
+    }
+}