3주차 과제 (윤석호)

src/main/java/com/econovation/third_project/agrregate/AdminPageQuery.java

@@ -0,0 +1,9 @@
+package com.econovation.third_project.agrregate;
+
+import java.util.List;
+
+public interface AdminPageQuery {
+    String getType();
+    List<?> execute();
+
+}

src/main/java/com/econovation/third_project/agrregate/AdminPageQueryAggregator.java

@@ -0,0 +1,52 @@
+package com.econovation.third_project.agrregate;
+
+import java.util.List;
+import java.util.Map;
+import java.util.Optional;
+import java.util.Set;
+import java.util.concurrent.CompletableFuture;
+import java.util.function.Function;
+import java.util.stream.Collectors;
+import org.springframework.stereotype.Component;
+
+//TODO: 제네릭?
+@Component
+public class AdminPageQueryAggregator {
+    private final Map<String, AdminPageQuery> queries;
+    public AdminPageQueryAggregator(List<AdminPageQuery> queries) {
+        this.queries = queries.stream()
+                .collect(Collectors.toMap(AdminPageQuery::getType, Function.identity()));
+    }
+
+    public Map<String, List<?>> aggregate(Set<String> requests){
+        List<AdminPageQuery> queriesToExecute = getQueriesToExecute(requests);
+        Map<String, CompletableFuture<List<?>>> executedQueries = executeQueriesAsync(queriesToExecute);
+        return aggregateResults(executedQueries);
+    }
+
+    private List<AdminPageQuery> getQueriesToExecute(Set<String> requests){
+        return requests.stream()
+                .map(request -> Optional.ofNullable(queries.get(request))
+                        .orElseThrow(IllegalArgumentException::new)
+                )
+                .toList();
+    }
+
+    private Map<String, CompletableFuture<List<?>>> executeQueriesAsync(List<AdminPageQuery> queriesToExecute){
+        return queriesToExecute.stream()
+                .collect(Collectors.toMap(
+                        AdminPageQuery::getType,
+                        query-> CompletableFuture.supplyAsync(query::execute)
+                ));
+    }
+
+    private Map<String, List<?>> aggregateResults(Map<String, CompletableFuture<List<?>>> executedQueries) {
+        return CompletableFuture.allOf(executedQueries.values().toArray(new CompletableFuture[0]))
+                .<Map<String, List<?>>>thenApply(v ->
+                        executedQueries.entrySet().stream()
+                                .collect(Collectors.toMap(Map.Entry::getKey, entry -> entry.getValue().join()))
+                )
+                .join();
+    }
+
+}

src/main/java/com/econovation/third_project/agrregate/PathQuery.java

@@ -0,0 +1,21 @@
+package com.econovation.third_project.agrregate;
+
+import com.econovation.third_project.service.PathService;
+import java.util.List;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Component;
+
+@Component
+@RequiredArgsConstructor
+public class PathQuery implements AdminPageQuery{
+    private final PathService pathService;
+    @Override
+    public String getType() {
+        return "path";
+    }
+
+    @Override
+    public List<?> execute() {
+        return pathService.getApplicantNumberEachPath();
+    }
+}

src/main/java/com/econovation/third_project/config/Field.java

@@ -0,0 +1,20 @@
+package com.econovation.third_project.config;
+
+import lombok.Getter;
+import lombok.RequiredArgsConstructor;
+
+@RequiredArgsConstructor
+@Getter
+public enum Field {
+    WEB("WEB"),
+    APP("APP"),
+    AI("AI"),
+    GAME("GAME"),
+    IOT("IoT"),
+    ARVR("AR/VR"),
+    NONE("선택없음");
+
+    private final String fieldName;
+
+
+}

src/main/java/com/econovation/third_project/config/Job.java

@@ -0,0 +1,14 @@
+package com.econovation.third_project.config;
+
+import lombok.Getter;
+import lombok.RequiredArgsConstructor;
+
+@RequiredArgsConstructor
+@Getter
+public enum Job {
+    DEVELOPER("개발자"),
+    PLANNER("기획자"),
+    DESIGNER("디자이너");
+
+    private final String jobName;
+}

src/main/java/com/econovation/third_project/config/SupportPath.java

@@ -0,0 +1,16 @@
+package com.econovation.third_project.config;
+
+import lombok.Getter;
+import lombok.RequiredArgsConstructor;
+
+@RequiredArgsConstructor
+@Getter
+public enum SupportPath {
+    POSTER("홍보 포스터"),
+    DEPARTMENT_ANNOUNCEMENT("학과 공지사항"),
+    ACQUAINTANCE("지인 소개"),
+    INSTAGRAM("인스타그램"),
+    EVERYTIME("에브리타임");
+    private final String entryPathName;
+
+}

src/main/java/com/econovation/third_project/controller/AdminQueryController.java

@@ -1,28 +1,36 @@
 package com.econovation.third_project.controller;
 
-import com.econovation.third_project.database.Database;
-import com.econovation.third_project.database.Registration;
+import com.econovation.third_project.agrregate.AdminPageQueryAggregator;
+import java.util.List;
+import java.util.Map;
+import java.util.Set;
 import lombok.RequiredArgsConstructor;
 import org.springframework.http.ResponseEntity;
 import org.springframework.stereotype.Controller;
 import org.springframework.web.bind.annotation.GetMapping;
-import org.springframework.web.bind.annotation.PostMapping;
 import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
 
 @Controller
 @RequiredArgsConstructor
+@RequestMapping("/api/admin")
 public class AdminQueryController {
-    private final Database database;
+    private final AdminPageQueryAggregator adminPageQueryAggregator;
 
-    // 예시 코드
-    @PostMapping("/registration")
-    public ResponseEntity<Object> postRegistrate(@RequestBody Registration registration) {
-        database.register(registration);
-        return ResponseEntity.ok().build();
-    }
-    @GetMapping("/registration")
-    public ResponseEntity<Registration> getRegistration(String userId) {
-        return ResponseEntity.ok().body(database.getRegistration(userId));
+    @GetMapping("/applicants/async-test")
+    public ResponseEntity<Map<String, List<?>>> getApplicantsInfo(@RequestBody Set<String> fields){
+        return ResponseEntity.ok().body(
+                adminPageQueryAggregator.aggregate(fields));
     }
 
+
+    //TODO:
+    // 병렬 스트림 + async의 장점,
+    // 병렬 스트림, async 각각 적절한 상황,
+    // 서비스 메서드마다 다른 인자가 필요한 경우,
+    // 일부 의존 관계가 있을경우 어떻게 처리할지
+    // 서비스 메서드 맵 어떻게 뺄지,
+    // 적절한 스레드 수 알아보기,
+    // 자바 비동기 기초,
+
 }

src/main/java/com/econovation/third_project/controller/ApplicationController.java

@@ -0,0 +1,22 @@
+package com.econovation.third_project.controller;
+
+import com.econovation.third_project.dto.CreateApplicationReq;
+import com.econovation.third_project.service.ApplicationService;
+import lombok.RequiredArgsConstructor;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+@RequestMapping("/api")
+@RequiredArgsConstructor
+@RestController
+public class ApplicationController {
+    private final ApplicationService applicationService;
+
+    @PostMapping("/application")
+    public ResponseEntity<Integer> createApplication(@RequestBody CreateApplicationReq createApplicationReq){
+        return ResponseEntity.ok().body(applicationService.createApplication(createApplicationReq));
+    }
+}

src/main/java/com/econovation/third_project/database/Application.java

@@ -0,0 +1,36 @@
+package com.econovation.third_project.database;
+
+import java.util.concurrent.atomic.AtomicInteger;
+import lombok.Builder;
+import lombok.Getter;
+import lombok.NonNull;
+
+
+@Getter
+public final class Application {
+    private static final AtomicInteger lastUsedId = new AtomicInteger(0);
+    @NonNull
+    private final Integer applicationId = lastUsedId.getAndIncrement();
+    @NonNull
+    private final Registration registration;
+    @NonNull
+    private final PersonalInformation personalInformation;
+    @NonNull
+    private final Path path;
+    @NonNull
+    private final DesiredTime desiredTime;
+
+    @Builder
+    public Application(Registration registration, PersonalInformation personalInformation,
+            Path path,
+            DesiredTime desiredTime) {
+        this.registration = registration;
+        this.personalInformation = personalInformation;
+        this.path = path;
+        this.desiredTime = desiredTime;
+    }
+}
+
+
+
+

src/main/java/com/econovation/third_project/database/Database.java

@@ -1,8 +1,9 @@
 package com.econovation.third_project.database;
 
-import java.util.HashMap;
+import java.util.Collection;
 import java.util.Map;
-import java.util.UUID;
+import java.util.Random;
+import java.util.concurrent.ConcurrentHashMap;
 import org.springframework.stereotype.Component;
 
 /**
@@ -11,18 +12,65 @@
  */
 @Component
 public class Database {
-    private final Map<String, Registration> registration = new HashMap<>();
-    private final Map<String, Path> path = new HashMap<>();
-    private final Map<String, PersonalInformation> personalInformation = new HashMap<>();
-    private final Map<String, DesiredTime> desiredTime = new HashMap<>();
+    //key: user id, value: application id
+    private final Map<Integer, Integer> applications = new ConcurrentHashMap<>();
+    //key: application id
+    private final Map<Integer, Registration> registrations = new ConcurrentHashMap<>();
+    //key: application id
+    private final Map<Integer, Path> paths = new ConcurrentHashMap<>();
+    //key: application id
+    private final Map<Integer, PersonalInformation> personalInformation = new ConcurrentHashMap<>();
+    //key: application id
+    private final Map<Integer, DesiredTime> desiredTimes = new ConcurrentHashMap<>();
 
-
-    public void register(Registration registrationRequest) {
-        // 기본적으로 이전 제출시 등록된 정보가 있으면 덮어쓰기를 지원합니다.
-        registration.put(UUID.randomUUID().toString(), registrationRequest);
+    public Collection<Registration> getAllRegistrations(){
+        return registrations.values();
+    }
+    public Collection<PersonalInformation> getAllPersonalInformation(){
+        return personalInformation.values();
+    }
+    public Collection<Path> getAllPath() {
+        return paths.values();
+    }
+    public Collection<DesiredTime> getAllDesiredTime(){
+        return desiredTimes.values();
     }
 
-    public Registration getRegistration(String userId) {
-        return registration.get(userId);
+    //지원자는 userId가 없으니 같은 지원서인지 판단할 기준을 따로 만들어야 함
+    public Integer upsertApplication(Integer userId, Application application){
+        Integer applicationId = applications.computeIfAbsent(userId, k -> application.getApplicationId());
+        upsertRegistration(applicationId, application.getRegistration());
+        upsertPath(applicationId, application.getPath());
+        upsertDesiredTime(applicationId, application.getDesiredTime());
+        upsertPersonalInformation(applicationId, application.getPersonalInformation());
+        return applicationId;
+    }
+    public void upsertRegistration(Integer applicationId, Registration registration){
+        registrations.put(applicationId, registration);
+    }
+    public void upsertPath(Integer applicationId, Path path){
+        paths.put(applicationId, path);
+    }
+    public void upsertPersonalInformation(Integer applicationId, PersonalInformation personalInformation){
+        this.personalInformation.put(applicationId, personalInformation);
+    }
+    public void upsertDesiredTime(Integer applicationId, DesiredTime desiredTime){
+        desiredTimes.put(applicationId, desiredTime);
     }
+
+
+
+//    public void register(Registration registrationRequest) {
+//        // 기본적으로 이전 제출시 등록된 정보가 있으면 덮어쓰기를 지원합니다.
+//        registration.put(UUID.randomUUID().toString(), registrationRequest);
+//    }
+//
+//    public Registration getRegistration(String userId) {
+//        return registration.get(userId);
+//    }
+
+
+
+
+
 }

src/main/java/com/econovation/third_project/database/DesiredTime.java

@@ -1,13 +1,32 @@
 package com.econovation.third_project.database;
 
+import java.util.HashMap;
 import java.util.List;
-import lombok.AllArgsConstructor;
+import java.util.Map;
 import lombok.Getter;
 
-@AllArgsConstructor
 @Getter
 public class DesiredTime {
-    String registrationId;
-    // 희망 시간 (11 * 3)의 테이블 형태를 준수합니다.
-    private List<int[]> desiredTime;
+    private static final Map<List<Integer>, List<Integer>> cachedTimes = new HashMap<>();
+    private final List<List<Integer>> desiredTimes;
+
+    public DesiredTime(List<List<Integer>> desiredTimes) {
+        validateDesiredTime(desiredTimes);
+        this.desiredTimes = desiredTimes.stream()
+                .map(time-> cachedTimes.computeIfAbsent(time, t->t))
+                .toList();
+    }
+    private void validateDesiredTime(List<List<Integer>> desiredTimes) {
+        //27기 기준
+        int interviewDays = 3;
+        int hoursPerDay = 11;
+
+        desiredTimes.forEach(
+                time -> {
+                    if (time.get(0) >= interviewDays || time.get(1) >= hoursPerDay)
+                        throw new IllegalArgumentException("면접 시간 잘못 입력");
+                }
+        );
+
+    }
 }