Merge pull request #13 from CarToi/dev

[feat/consume] 데이터 소비 로직 1차 배포

Author: kimD0ngjun

src/jmh/java/org/jun/saemangeum/benchmark/process/ContentCollectServiceBenchmark.java

@@ -1,6 +1,6 @@
 package org.jun.saemangeum.benchmark.process;
 
-import org.jun.saemangeum.process.application.service.ContentCollectService;
+import org.jun.saemangeum.pipeline.application.service.ContentCollectService;
 import org.openjdk.jmh.annotations.*;
 import org.springframework.context.annotation.AnnotationConfigApplicationContext;
 import org.springframework.context.annotation.ComponentScan;

src/jmh/java/org/jun/saemangeum/benchmark/process/MockContentCollectServiceBenchmark.java

@@ -2,8 +2,8 @@
 
 import org.jun.saemangeum.global.domain.Content;
 import org.jun.saemangeum.global.repository.ContentRepository;
-import org.jun.saemangeum.process.application.collect.base.Refiner;
-import org.jun.saemangeum.process.application.service.ContentCollectService;
+import org.jun.saemangeum.pipeline.application.collect.base.Refiner;
+import org.jun.saemangeum.pipeline.application.service.ContentCollectService;
 import org.jun.saemangeum.global.service.ContentService;
 import org.mockito.Mockito;
 import org.openjdk.jmh.annotations.*;

src/main/java/org/jun/saemangeum/SaemangeumApplication.java

@@ -2,7 +2,9 @@
 
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.scheduling.annotation.EnableScheduling;
 
+@EnableScheduling
 @SpringBootApplication
 public class SaemangeumApplication {
 

src/main/java/org/jun/saemangeum/consume/controller/SurveyController.java

@@ -0,0 +1,43 @@
+package org.jun.saemangeum.consume.controller;
+
+import lombok.RequiredArgsConstructor;
+import org.jun.saemangeum.consume.domain.dto.AverageRequest;
+import org.jun.saemangeum.consume.domain.dto.RecommendationResponse;
+import org.jun.saemangeum.consume.domain.dto.SurveyCreateRequest;
+import org.jun.saemangeum.consume.domain.dto.SurveyUpdateRequest;
+import org.jun.saemangeum.consume.service.SurveyRecommendationService;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.List;
+
+@RestController
+@RequestMapping("/api/survey")
+@RequiredArgsConstructor
+public class SurveyController {
+
+    private final SurveyRecommendationService surveyRecommendationService;
+
+    /**
+     * 사용자 설문 결과 추천 응답 데이터 리스트 반환
+     */
+    @PostMapping("/recommendation")
+    public List<RecommendationResponse> createSurvey(@RequestBody SurveyCreateRequest request) {
+        return surveyRecommendationService.createRecommendationsBySurvey(request);
+    }
+
+    /**
+     * 사용자 설문 결과 만족도 반영 요청
+     */
+    @PatchMapping("/update")
+    public void updateSurvey(@RequestBody SurveyUpdateRequest request) {
+        surveyRecommendationService.updateSurvey(request);
+    }
+
+    /**
+     * 평균 사용자 설문 응답 확인 응답 데이터 리스트 반환
+     */
+    @GetMapping("/average")
+    public List<RecommendationResponse> readAverageSurvey(@RequestBody AverageRequest request) {
+        return surveyRecommendationService.calculateAverageSurvey(request);
+    }
+}

src/main/java/org/jun/saemangeum/consume/domain/dto/AverageRequest.java

@@ -0,0 +1,10 @@
+package org.jun.saemangeum.consume.domain.dto;
+
+public record AverageRequest(
+        int age, // 연령대
+        String gender, // 성별
+        String city, // 거주의향 지역
+        String want, // 여유 선호
+        String mood // 분위기 선호
+) {
+}

src/main/java/org/jun/saemangeum/consume/domain/dto/RecommendationResponse.java

@@ -0,0 +1,12 @@
+package org.jun.saemangeum.consume.domain.dto;
+
+import org.jun.saemangeum.global.domain.Category;
+
+public record RecommendationResponse(
+        String title, // 추천 컨텐츠명
+        String position, // 위치 (주소 혹은 추상적인 지리적 위치)
+        Category category, // 컨텐츠 분류 (FESTIVAL, EVENT, TOUR, CULTURE)
+        String image, // 이미지 소스 url (null 가능성 존재)
+        String url // 컨텐츠 데이터 출처
+) {
+}

src/main/java/org/jun/saemangeum/consume/domain/dto/SurveyCreateRequest.java

@@ -0,0 +1,12 @@
+package org.jun.saemangeum.consume.domain.dto;
+
+public record SurveyCreateRequest(
+        String clientId, // UUID 문자열 처리
+        int age, // 연령대
+        String gender, // 성별
+        String resident, // 실거주지
+        String city, // 거주의향 지역
+        String want, // 여유 선호
+        String mood // 분위기 선호
+) {
+}

src/main/java/org/jun/saemangeum/consume/domain/dto/SurveyUpdateRequest.java

@@ -0,0 +1,9 @@
+package org.jun.saemangeum.consume.domain.dto;
+
+import java.util.List;
+
+public record SurveyUpdateRequest(
+        String clientId,
+        List<Integer> satisfactions
+) {
+}

src/main/java/org/jun/saemangeum/consume/domain/entity/RecommendationLog.java

@@ -0,0 +1,31 @@
+package org.jun.saemangeum.consume.domain.entity;
+
+import jakarta.persistence.*;
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+import org.jun.saemangeum.global.domain.Content;
+
+@Entity
+@Builder
+@Table(name = "recommendation_logs")
+@Getter
+@NoArgsConstructor
+@AllArgsConstructor
+public class RecommendationLog {
+    @Id
+    @GeneratedValue(strategy = GenerationType.IDENTITY)
+    private Long id;
+
+    @Column(name = "content_id")
+    private Long contentId;
+
+    @Column(name = "survey_id")
+    private Long surveyId;
+
+    public RecommendationLog(Content content, Survey survey) {
+        this.contentId = content.getId();
+        this.surveyId = survey.getId();
+    }
+}

src/main/java/org/jun/saemangeum/consume/domain/entity/Survey.java

@@ -0,0 +1,58 @@
+package org.jun.saemangeum.consume.domain.entity;
+
+import jakarta.persistence.*;
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+import org.jun.saemangeum.consume.domain.dto.SurveyCreateRequest;
+
+// 엔티티 필드를 어떻게 잡아야 평균값 산출이 쉬우려나...
+@Entity
+@Builder
+@Table(name = "surveys")
+@Getter
+@NoArgsConstructor
+@AllArgsConstructor
+public class Survey {
+    @Id
+    @GeneratedValue(strategy = GenerationType.IDENTITY)
+    private Long id;
+
+    @Column(name = "client_id")
+    private String clientId; // UUID 클라이언트 id
+
+    // 설문 응답
+    private int age; // 연령대
+    private String gender; // 성별
+    private String resident; // 실거주지
+    private String city; // 거주의향 지역
+    private String want; // 여유 선호
+    private String mood; // 분위기 선호
+
+    // 후속 평가
+    private int help; // 도움 정도(1, 2, 3, 4, 5)
+    private int preference; // 선호도 정도(1, 2, 3, 4, 5)
+    private int intention; // 의향 변화 정도(1, 2, 3, 4, 5)
+
+    public static Survey create(SurveyCreateRequest request) {
+        return Survey.builder()
+                .clientId(request.clientId())
+                .age(request.age())
+                .gender(request.gender())
+                .resident(request.resident())
+                .city(request.city())
+                .want(request.want())
+                .mood(request.mood())
+                .help(3) // 기본값 3
+                .preference(3)
+                .intention(3)
+                .build();
+    }
+
+    public void updateEvaluation(int help, int preference, int intention) {
+        this.help = help;
+        this.preference = preference;
+        this.intention = intention;
+    }
+}