feat: create weekly/monthly report api

Author: KoungQ

src/main/java/com/project/analysis/domain/application/dto/request/CreateWeeklyReportRequest.java

@@ -0,0 +1,15 @@
+package com.project.analysis.domain.application.dto.request;
+
+import com.project.analysis.domain.domain.entity.AnalyzedSleepLevel;
+import com.project.analysis.domain.domain.entity.AnalyzedSoundEvent;
+import com.project.analysis.domain.domain.entity.PeriodicReport;
+import lombok.Builder;
+
+import java.util.List;
+
+@Builder
+public record CreateWeeklyReportRequest (
+        PeriodicReport periodicReport,
+        List<AnalyzedSleepLevel> analyzedSleepLevels,
+        List<AnalyzedSoundEvent> analyzedSoundEvents
+) {}

src/main/java/com/project/analysis/domain/application/usecase/CreateMonthlyReportUseCase.java

@@ -0,0 +1,45 @@
+package com.project.analysis.domain.application.usecase;
+
+import com.project.analysis.domain.domain.entity.*;
+import com.project.analysis.domain.domain.service.AnalyzedSleepLevelService;
+import com.project.analysis.domain.domain.service.AnalyzedSoundEventService;
+import com.project.analysis.domain.domain.service.PeriodicReportService;
+import com.project.analysis.domain.domain.service.SleepSessionService;
+import com.project.analysis.domain.infra.client.CreatePeriodicReportClient;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Service;
+
+import java.time.DayOfWeek;
+import java.time.LocalDate;
+import java.time.temporal.TemporalAdjusters;
+import java.util.List;
+
+@Service
+@RequiredArgsConstructor
+public class CreateMonthlyReportUseCase {
+
+    private final PeriodicReportService periodicReportService;
+    private final SleepSessionService sleepSessionService;
+    private final AnalyzedSoundEventService analyzedSoundEventService;
+    private final AnalyzedSleepLevelService analyzedSleepLevelService;
+    private final CreatePeriodicReportClient createPeriodicReportClient;
+
+    public void execute(Long userNo, LocalDate date) {
+        PeriodicReport periodicReport = periodicReportService.findByUserNoAndStartedAt(userNo, date, DurationType.MONTHLY)
+                .orElse(
+                        PeriodicReport.builder()
+                                .userNo(userNo)
+                                .periodStartedAt(date.with(TemporalAdjusters.firstDayOfMonth()))
+                                .durationType(DurationType.MONTHLY)
+                                .build()
+                );
+
+        SleepSession sleepSession = sleepSessionService.findByUserNo(userNo, date);
+        List<AnalyzedSleepLevel> analyzedSleepLevels = analyzedSleepLevelService.findAll(sleepSession);
+        List<AnalyzedSoundEvent> analyzedSoundEvents = analyzedSoundEventService.findAll(sleepSession);
+
+        PeriodicReport request = createPeriodicReportClient.request(periodicReport, analyzedSleepLevels, analyzedSoundEvents);
+
+        periodicReportService.save(request);
+    }
+}

src/main/java/com/project/analysis/domain/application/usecase/CreateWeeklyReportUseCase.java

@@ -0,0 +1,47 @@
+package com.project.analysis.domain.application.usecase;
+
+import com.project.analysis.domain.domain.entity.*;
+import com.project.analysis.domain.domain.service.AnalyzedSleepLevelService;
+import com.project.analysis.domain.domain.service.AnalyzedSoundEventService;
+import com.project.analysis.domain.domain.service.PeriodicReportService;
+import com.project.analysis.domain.domain.service.SleepSessionService;
+import com.project.analysis.domain.infra.client.CreatePeriodicReportClient;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Service;
+
+import java.time.DayOfWeek;
+import java.time.LocalDate;
+import java.time.temporal.TemporalAdjusters;
+import java.util.List;
+
+import static com.project.analysis.domain.domain.entity.DurationType.WEEKLY;
+
+@Service
+@RequiredArgsConstructor
+public class CreateWeeklyReportUseCase {
+
+    private final PeriodicReportService periodicReportService;
+    private final SleepSessionService sleepSessionService;
+    private final AnalyzedSoundEventService analyzedSoundEventService;
+    private final AnalyzedSleepLevelService analyzedSleepLevelService;
+    private final CreatePeriodicReportClient createPeriodicReportClient;
+
+    public void execute(Long userNo, LocalDate date) {
+        PeriodicReport periodicReport = periodicReportService.findByUserNoAndStartedAt(userNo, date, WEEKLY)
+                .orElse(
+                        PeriodicReport.builder()
+                                .userNo(userNo)
+                                .periodStartedAt(date.with(TemporalAdjusters.nextOrSame(DayOfWeek.SUNDAY)))
+                                .durationType(WEEKLY)
+                                .build()
+                );
+
+        SleepSession sleepSession = sleepSessionService.findByUserNo(userNo, date);
+        List<AnalyzedSleepLevel> analyzedSleepLevels = analyzedSleepLevelService.findAll(sleepSession);
+        List<AnalyzedSoundEvent> analyzedSoundEvents = analyzedSoundEventService.findAll(sleepSession);
+
+        PeriodicReport request = createPeriodicReportClient.request(periodicReport, analyzedSleepLevels, analyzedSoundEvents);
+
+        periodicReportService.save(request);
+    }
+}

src/main/java/com/project/analysis/domain/domain/repository/PeriodicReportRepository.java

@@ -0,0 +1,12 @@
+package com.project.analysis.domain.domain.repository;
+
+import com.project.analysis.domain.domain.entity.DurationType;
+import com.project.analysis.domain.domain.entity.PeriodicReport;
+import org.springframework.data.jpa.repository.JpaRepository;
+
+import java.time.LocalDate;
+import java.util.Optional;
+
+public interface PeriodicReportRepository extends JpaRepository<PeriodicReport, Long> {
+    Optional<PeriodicReport> findByUserNoAndPeriodStartedAtAndDurationType(Long userNo, LocalDate periodStartedAt, DurationType durationType);
+}

src/main/java/com/project/analysis/domain/domain/service/PeriodicReportService.java

@@ -0,0 +1,25 @@
+package com.project.analysis.domain.domain.service;
+
+import com.project.analysis.domain.domain.entity.DurationType;
+import com.project.analysis.domain.domain.entity.PeriodicReport;
+import com.project.analysis.domain.domain.repository.PeriodicReportRepository;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Service;
+
+import java.time.LocalDate;
+import java.util.Optional;
+
+@Service
+@RequiredArgsConstructor
+public class PeriodicReportService {
+
+    private final PeriodicReportRepository periodicReportRepository;
+
+    public Optional<PeriodicReport> findByUserNoAndStartedAt(Long userNo, LocalDate startedAt, DurationType type) {
+        return periodicReportRepository.findByUserNoAndPeriodStartedAtAndDurationType((userNo, startedAt, type);
+    }
+
+    public void save(PeriodicReport periodicReport) {
+        periodicReportRepository.save(periodicReport);
+    }
+}

src/main/java/com/project/analysis/domain/infra/client/CreatePeriodicReportClient.java

@@ -0,0 +1,45 @@
+package com.project.analysis.domain.infra.client;
+
+import com.project.analysis.domain.application.dto.request.CreateWeeklyReportRequest;
+import com.project.analysis.domain.application.dto.request.SleepAnalysisRequest;
+import com.project.analysis.domain.application.dto.response.CreateDailyReportResponse;
+import com.project.analysis.domain.domain.entity.AnalyzedSleepLevel;
+import com.project.analysis.domain.domain.entity.AnalyzedSoundEvent;
+import com.project.analysis.domain.domain.entity.PeriodicReport;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.http.HttpStatusCode;
+import org.springframework.http.MediaType;
+import org.springframework.stereotype.Component;
+import org.springframework.web.client.RestClient;
+import org.springframework.web.client.RestClientException;
+
+import java.util.List;
+
+@Slf4j
+@Component
+@RequiredArgsConstructor
+public class CreatePeriodicReportClient {
+
+    private final RestClient aiAnalysisModelRestClient;
+
+    public PeriodicReport request(PeriodicReport periodicReport, List<AnalyzedSleepLevel> analyzedSleepLevels, List<AnalyzedSoundEvent> analyzedSoundEvents) {
+        return aiAnalysisModelRestClient
+                    .post()
+                    .uri("/analyze/periodic_report/json")
+                    .contentType(MediaType.APPLICATION_JSON)
+                    .body(
+                            CreateWeeklyReportRequest.builder()
+                                    .periodicReport(periodicReport)
+                                    .analyzedSleepLevels(analyzedSleepLevels)
+                                    .analyzedSoundEvents(analyzedSoundEvents)
+                            .build()
+                    )
+                    .retrieve()
+                    .onStatus(HttpStatusCode::isError, (req, res) -> {
+                        log.error("AI analysis model returned error: {}", res.getStatusCode());
+                        throw new RestClientException("AI analysis model error: " + res.getStatusCode());
+                    })
+                    .body(PeriodicReport.class);
+    }
+}

src/main/java/com/project/analysis/domain/ui/CreateMonthlyReportController.java

@@ -0,0 +1,22 @@
+package com.project.analysis.domain.ui;
+
+import com.project.analysis.domain.application.usecase.CreateMonthlyReportUseCase;
+import com.project.analysis.domain.ui.spec.CreateMonthlyReportApiSpec;
+import com.project.analysis.global.common.BaseResponse;
+import lombok.RequiredArgsConstructor;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.time.LocalDate;
+
+@RestController
+@RequiredArgsConstructor
+public class CreateMonthlyReportController implements CreateMonthlyReportApiSpec {
+
+    private final CreateMonthlyReportUseCase createMonthlyReportUseCase;
+
+    @Override
+    public BaseResponse<Void> analyze(Long userNo, LocalDate date) {
+        createMonthlyReportUseCase.execute(userNo, date);
+        return BaseResponse.onSuccess();
+    }
+}

src/main/java/com/project/analysis/domain/ui/CreateWeeklyReportController.java

@@ -0,0 +1,22 @@
+package com.project.analysis.domain.ui;
+
+import com.project.analysis.domain.application.usecase.CreateWeeklyReportUseCase;
+import com.project.analysis.domain.ui.spec.CreateWeeklyReportApiSpec;
+import com.project.analysis.global.common.BaseResponse;
+import lombok.RequiredArgsConstructor;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.time.LocalDate;
+
+@RestController
+@RequiredArgsConstructor
+public class CreateWeeklyReportController implements CreateWeeklyReportApiSpec {
+
+    private final CreateWeeklyReportUseCase createWeeklyReportUseCase;
+
+    @Override
+    public BaseResponse<Void> analyze(Long userNo, LocalDate date) {
+        createWeeklyReportUseCase.execute(userNo, date);
+        return BaseResponse.onSuccess();
+    }
+}

src/main/java/com/project/analysis/domain/ui/spec/CreateMonthlyReportApiSpec.java

@@ -0,0 +1,23 @@
+package com.project.analysis.domain.ui.spec;
+
+import com.project.analysis.global.annotation.CurrentUser;
+import com.project.analysis.global.common.BaseResponse;
+import io.swagger.v3.oas.annotations.Operation;
+import io.swagger.v3.oas.annotations.tags.Tag;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+
+import java.time.LocalDate;
+
+@Tag(name = "Analysis")
+public interface CreateMonthlyReportApiSpec {
+
+    @Operation(
+            summary = "월간 레포트 생성 API"
+    )
+    @PostMapping(value = "/api/analysis/reports/monthly")
+    BaseResponse<Void> analyze(
+            @CurrentUser Long userNo,
+            @RequestParam LocalDate date
+    );
+}

src/main/java/com/project/analysis/domain/ui/spec/CreateWeeklyReportApiSpec.java

@@ -0,0 +1,23 @@
+package com.project.analysis.domain.ui.spec;
+
+import com.project.analysis.global.annotation.CurrentUser;
+import com.project.analysis.global.common.BaseResponse;
+import io.swagger.v3.oas.annotations.Operation;
+import io.swagger.v3.oas.annotations.tags.Tag;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+
+import java.time.LocalDate;
+
+@Tag(name = "Analysis")
+public interface CreateWeeklyReportApiSpec {
+
+    @Operation(
+            summary = "주간 레포트 생성 API"
+    )
+    @PostMapping(value = "/api/analysis/reports/weekly")
+    BaseResponse<Void> analyze(
+            @CurrentUser Long userNo,
+            @RequestParam LocalDate date
+    );
+}