인구수 추이 api 구현

Author: gkfktkrh153

src/main/java/com/dduckddak/domain/data/controller/PopulationController.java

@@ -24,6 +24,13 @@ public class PopulationController {
 
     private final PopulationService populationService;
 
+    @Operation(summary = "행정동의 유동인구 수 추이")
+    @GetMapping("/floating/transition")
+    public ApiResponse<PopulationTransitionResponse> getFloatingPopulationTransition(@RequestParam(value = "code") String code){
+        PopulationTransitionResponse floatingPopulationTransition = populationService.getFloatingPopulationTransition(code);
+        return success(floatingPopulationTransition);
+    }
+
     @Operation(summary = "행정동별 전체 유동인구 조회", description = "parameter로 행정동코드(code)를 받아 해당 행정동의 전체 유동인구를 조회")
     @GetMapping("/floating/quarter")
     public ApiResponse<PopulationByQuarterDto> getFloatingPopulationByCodeTop5(@RequestParam(value = "code") String code) {

src/main/java/com/dduckddak/domain/data/dto/PopulationTransitionResponse.java

@@ -0,0 +1,25 @@
+package com.dduckddak.domain.data.dto;
+
+import com.dduckddak.domain.data.model.Population;
+
+import java.util.List;
+
+public record PopulationTransitionResponse(
+        List<PopulationData> populationList
+) {
+    public record PopulationData(
+            long quarter,
+            long populationOfTown,
+            int rankAtCity,
+            long populationAvgOfCity,
+            int rankAtDistrict,
+            long populationAvgOfDistrict
+
+    ) {
+    }
+
+    public static PopulationTransitionResponse from(List<PopulationData> populations) {
+        return new PopulationTransitionResponse(populations);
+    }
+}
+

src/main/java/com/dduckddak/domain/data/repository/PopulationRepositoryCustom.java

@@ -21,4 +21,6 @@ public interface PopulationRepositoryCustom {
 
 
     List<PopulationsTop10Response> findPopulationsTop10(String selectCriteria, String orderCriteria, String populationType);
-    }
+
+    List<Population> findFloatingPopulationTransition(String code);
+}

src/main/java/com/dduckddak/domain/data/repository/PopulationRepositoryImpl.java

@@ -118,4 +118,17 @@ public List findPopulationsTop10(String selectCriteria, String orderCriteria, St
         return responseList;
     }
 
+    @Override
+    public List<Population> findFloatingPopulationTransition(String code) {
+
+        return queryFactory
+                .selectFrom(population)
+                .innerJoin(population.town, town).fetchJoin()
+                .where(population.populationType.eq(PopulationType.FloatingPopulation)
+                        .and(town.quarter.in(20241, 20234, 20233, 20232, 20231)))
+                .orderBy(population.town.quarter.desc(), population.totalPopulation.desc())
+                .fetch();
+
+    }
+
 }

src/main/java/com/dduckddak/domain/data/service/PopulationService.java

@@ -1,9 +1,7 @@
 package com.dduckddak.domain.data.service;
 
-import com.dduckddak.domain.data.dto.PopulationByDistrictResponse;
-import com.dduckddak.domain.data.dto.PopulationByQuarterDto;
-import com.dduckddak.domain.data.dto.PopulationsTop10Response;
-import com.dduckddak.domain.data.dto.TimelyDto;
+import com.dduckddak.domain.data.dto.*;
+import com.dduckddak.domain.data.dto.PopulationTransitionResponse.PopulationData;
 import com.dduckddak.domain.data.model.Population;
 import com.dduckddak.domain.data.model.PopulationType;
 import com.dduckddak.domain.data.repository.PopulationRepository;
@@ -12,6 +10,7 @@
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
+import java.util.ArrayList;
 import java.util.Comparator;
 import java.util.List;
 
@@ -74,4 +73,35 @@ else if(age.equals("60"))
         System.out.println(columnName);
         return populationRepository.findPopulationsTop10(columnName, orderCriteria, "'residentPopulation'");
     }
+
+    public PopulationTransitionResponse getFloatingPopulationTransition(String code) {
+        List<Population> populations = populationRepository.findFloatingPopulationTransition(code);
+        List<PopulationData> populationDataList = new ArrayList<>();
+
+        long[] quarterArr = new long[]{20241L, 20234L, 20233L, 20232L, 20231L};
+        for(long quarter : quarterArr){
+
+            List<Population> listOfCity = populations.stream().filter
+                    (p -> p.getTown().getQuarter().equals(quarter)).toList();
+
+            Population population = listOfCity.stream().filter(p -> p.getTown().getCode().equals(code)).findFirst().get();
+            long populationOfTown = population.getTotalPopulation();
+
+            int rankAtCity = listOfCity.indexOf(population) + 1; // 20241분기 시 내 등수
+            long populationAvgOfCity = (long) listOfCity.stream().mapToLong(Population::getTotalPopulation).average().getAsDouble();
+
+
+            List<Population> listOfDistrict = listOfCity.stream().filter
+                    (p -> p.getTown().getName().split(" ")[0].equals(population.getTown().getName().split(" ")[0])).toList();
+
+            int rankAtDistrict = listOfDistrict.indexOf(population) + 1; // 20241분기 구 내 등수
+            long populationAvgOfDistrict = (long) listOfDistrict.stream().mapToLong(Population::getTotalPopulation).average().getAsDouble();
+
+            populationDataList.add(new PopulationData(quarter, populationOfTown, rankAtCity, populationAvgOfCity, rankAtDistrict, populationAvgOfDistrict));
+        }
+
+        return PopulationTransitionResponse.from(populationDataList);
+
+
+    }
 }