M3-382 픽셀 클러스터링 집계

.github/workflows/cd_dev.yml

@@ -38,6 +38,7 @@ jobs:
           echo "APPLE_PRIVATE_KEY=${{ secrets.APPLE_PRIVATE_KEY }}" >> .env
           echo "LATEST_VERSION=${{ secrets.LATEST_VERSION }}" >> .env
           echo "FORCE_UPDATE_VERSION=${{  secrets.FORCE_UPDATE_VERSION  }}" >> .env
+          echo "GEOCODING_API=${{  secrets.GEOCODING_API  }}" >> .env
           
           echo "SPRING_PROFILES_ACTIVE=dev" >> .env
 

.github/workflows/cd_prod.yml

@@ -38,6 +38,7 @@ jobs:
           echo "APPLE_PRIVATE_KEY=${{ secrets.APPLE_PRIVATE_KEY }}" >> .env
           echo "LATEST_VERSION=${{ secrets.LATEST_VERSION_PROD }}" >> .env
           echo "FORCE_UPDATE_VERSION=${{  secrets.FORCE_UPDATE_VERSION_PROD  }}" >> .env
+          echo "GEOCODING_API=${{  secrets.GEOCODING_API  }}" >> .env
 
       - name: gradlew에 실행 권한 부여
         run: chmod +x ./gradlew

src/main/java/com/m3pro/groundflip/controller/PixelController.java

@@ -13,6 +13,7 @@
 import org.springframework.web.bind.annotation.RestController;
 
 import com.m3pro.groundflip.domain.dto.Response;
+import com.m3pro.groundflip.domain.dto.pixel.ClusteredPixelCount;
 import com.m3pro.groundflip.domain.dto.pixel.CommunityModePixelResponse;
 import com.m3pro.groundflip.domain.dto.pixel.CommunityPixelInfoResponse;
 import com.m3pro.groundflip.domain.dto.pixel.IndividualHistoryPixelResponse;
@@ -23,6 +24,7 @@
 import com.m3pro.groundflip.domain.dto.pixelUser.IndividualHistoryPixelInfoResponse;
 import com.m3pro.groundflip.service.PixelManager;
 import com.m3pro.groundflip.service.PixelReader;
+import com.m3pro.groundflip.service.RegionService;
 
 import io.swagger.v3.oas.annotations.Operation;
 import io.swagger.v3.oas.annotations.Parameter;
@@ -44,6 +46,7 @@
 public class PixelController {
 	private final PixelManager pixelManager;
 	private final PixelReader pixelReader;
+	private final RegionService regionService;
 
 	@Operation(summary = "개인전 픽셀 조회", description = "특정 좌표를 중심으로 반경 내 개인전 픽셀 정보를 조회 API")
 	@Parameters({
@@ -165,6 +168,56 @@ public Response<PixelCountResponse> getCommunityPixelCount(
 		return Response.createSuccess(pixelReader.getCommunityPixelCount(communityId));
 	}
 
+	@Operation(summary = "개인전 클러스터링된 픽셀 조회", description = "특정 좌표를 중심으로 반경 내 개인전 클러스터링된 픽셀 정보 API")
+	@Parameters({
+		@Parameter(name = "current-latitude", description = "원의 중심 좌표의 위도", example = "37.503717"),
+		@Parameter(name = "current-longitude", description = "원의 중심 좌표의 경도", example = "127.044317"),
+		@Parameter(name = "radius", description = "미터 단위의 반경", example = "1000"),
+	})
+	@GetMapping("/individual-mode/clustered")
+	public Response<List<ClusteredPixelCount>> getNearIndividualClusteredPixels(
+		@RequestParam(name = "current-latitude") @Min(-90) @Max(90) double currentLatitude,
+		@RequestParam(name = "current-longitude") @Min(-180) @Max(180) double currentLongitude,
+		@RequestParam(name = "radius") @Min(0) int radius) {
+
+		return Response.createSuccess(
+			regionService.getIndividualModeClusteredPixelCount(currentLatitude, currentLongitude, radius));
+	}
+
+	@Operation(summary = "개인기록 클러스터링된 픽셀 조회", description = "특정 좌표를 중심으로 반경 내 개인기록 클러스터링된 픽셀 정보 API")
+	@Parameters({
+		@Parameter(name = "current-latitude", description = "원의 중심 좌표의 위도", example = "37.503717"),
+		@Parameter(name = "current-longitude", description = "원의 중심 좌표의 경도", example = "127.044317"),
+		@Parameter(name = "radius", description = "미터 단위의 반경", example = "1000"),
+		@Parameter(name = "user-id", description = "찾고자 하는 user의 id", example = "127"),
+	})
+	@GetMapping("/individual-history/clustered")
+	public Response<List<ClusteredPixelCount>> getNearIndividualHistoryClusteredPixels(
+		@RequestParam(name = "current-latitude") @Min(-90) @Max(90) double currentLatitude,
+		@RequestParam(name = "current-longitude") @Min(-180) @Max(180) double currentLongitude,
+		@RequestParam(name = "radius") @Min(0) int radius,
+		@RequestParam(name = "user-id") @NotNull() Long userId) {
+
+		return Response.createSuccess(
+			regionService.getIndividualHistoryClusteredPixelCount(currentLatitude, currentLongitude, radius, userId));
+	}
+
+	@Operation(summary = "그룹전 클러스터링된 픽셀 조회", description = "특정 좌표를 중심으로 반경 내 그룹전 클러스터링된 픽셀 정보를 조회 API")
+	@Parameters({
+		@Parameter(name = "current-latitude", description = "원의 중심 좌표의 위도", example = "37.503717"),
+		@Parameter(name = "current-longitude", description = "원의 중심 좌표의 경도", example = "127.044317"),
+		@Parameter(name = "radius", description = "미터 단위의 반경", example = "1000"),
+	})
+	@GetMapping("/community-mode/clustered")
+	public Response<List<ClusteredPixelCount>> getNearCommunityClusteredPixels(
+		@RequestParam(name = "current-latitude") @Min(-90) @Max(90) double currentLatitude,
+		@RequestParam(name = "current-longitude") @Min(-180) @Max(180) double currentLongitude,
+		@RequestParam(name = "radius") @Min(0) int radius) {
+
+		return Response.createSuccess(
+			regionService.getCommunityModeClusteredPixelCount(currentLatitude, currentLongitude, radius));
+	}
+
 	@Operation(summary = "주간 픽셀 개수 조회", description = "특정 유저의 주간 방문한 픽셀을 조회하는 api")
 	@GetMapping("/count/daily/{userId}")
 	public Response<List<Integer>> getDailyPixel(

src/main/java/com/m3pro/groundflip/domain/dto/pixel/ClusteredPixelCount.java

@@ -0,0 +1,46 @@
+package com.m3pro.groundflip.domain.dto.pixel;
+
+import com.m3pro.groundflip.enums.RegionLevel;
+
+import io.swagger.v3.oas.annotations.media.Schema;
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+@Schema()
+@AllArgsConstructor
+@NoArgsConstructor
+@Data
+@Builder
+public class ClusteredPixelCount {
+	@Schema(description = "지역 ID", example = "1234")
+	private Long regionId;
+
+	@Schema(description = "지역 이름", example = "홍길동")
+	private String regionName;
+
+	@Schema(description = "지역별 픽셀 개수", example = "3")
+	private int count;
+
+	@Schema(description = "지역의 중심 위도", example = "37.6464")
+	private double latitude;
+
+	@Schema(description = "지역의 중심 경도", example = "127.6897")
+	private double longitude;
+
+	@Schema(description = "집계 단위", example = "127.6897")
+	private RegionLevel regionLevel;
+
+	public static ClusteredPixelCount from(Long regionId, String regionName, int count, double latitude,
+		double longitude, RegionLevel regionLevel) {
+		return ClusteredPixelCount.builder()
+			.regionId(regionId)
+			.regionName(regionName)
+			.count(count)
+			.latitude(latitude)
+			.longitude(longitude)
+			.regionLevel(regionLevel)
+			.build();
+	}
+}

src/main/java/com/m3pro/groundflip/domain/dto/pixel/RegionInfo.java

@@ -0,0 +1,13 @@
+package com.m3pro.groundflip.domain.dto.pixel;
+
+public interface RegionInfo {
+	Long getRegionId();
+
+	double getLatitude();
+
+	double getLongitude();
+
+	String getName();
+
+	Integer getCount();
+}

src/main/java/com/m3pro/groundflip/domain/dto/pixel/naverApi/ReverseGeocodingResult.java

@@ -0,0 +1,22 @@
+package com.m3pro.groundflip.domain.dto.pixel.naverApi;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+import io.swagger.v3.oas.annotations.media.Schema;
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+@AllArgsConstructor
+@NoArgsConstructor
+@Data
+@Builder
+@Schema(title = "네이버 api json 결과")
+public class ReverseGeocodingResult {
+	@JsonProperty("region")
+	private String regionName;
+
+	@JsonProperty("region_id")
+	private Long regionId;
+}

src/main/java/com/m3pro/groundflip/domain/entity/CompetitionCount.java

@@ -0,0 +1,47 @@
+package com.m3pro.groundflip.domain.entity;
+
+import jakarta.persistence.Column;
+import jakarta.persistence.Entity;
+import jakarta.persistence.FetchType;
+import jakarta.persistence.GeneratedValue;
+import jakarta.persistence.GenerationType;
+import jakarta.persistence.Id;
+import jakarta.persistence.JoinColumn;
+import jakarta.persistence.ManyToOne;
+import lombok.AccessLevel;
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+
+@Getter
+@Entity
+@NoArgsConstructor(access = AccessLevel.PROTECTED)
+@AllArgsConstructor
+@Builder
+public class CompetitionCount {
+	@Id
+	@GeneratedValue(strategy = GenerationType.IDENTITY)
+	@Column(name = "competition_count_id")
+	private Long id;
+
+	private Integer individualModeCount;
+
+	private Integer communityModeCount;
+
+	private Integer year;
+
+	private Integer week;
+
+	@ManyToOne(fetch = FetchType.LAZY)
+	@JoinColumn(name = "region_id")
+	private Region region;
+
+	public void increaseIndividualModeCount() {
+		this.individualModeCount++;
+	}
+
+	public void increaseCommunityModeCount() {
+		this.communityModeCount++;
+	}
+}

src/main/java/com/m3pro/groundflip/domain/entity/Pixel.java

@@ -6,7 +6,10 @@
 
 import jakarta.persistence.Column;
 import jakarta.persistence.Entity;
+import jakarta.persistence.FetchType;
 import jakarta.persistence.Id;
+import jakarta.persistence.JoinColumn;
+import jakarta.persistence.ManyToOne;
 import lombok.AccessLevel;
 import lombok.AllArgsConstructor;
 import lombok.Builder;
@@ -39,6 +42,10 @@ public class Pixel {
 
 	private Long communityId;
 
+	@ManyToOne(fetch = FetchType.EAGER)
+	@JoinColumn(name = "region_id")
+	private Region region;
+
 	private LocalDateTime createdAt;
 
 	private LocalDateTime userOccupiedAt;

src/main/java/com/m3pro/groundflip/domain/entity/Region.java

@@ -0,0 +1,41 @@
+package com.m3pro.groundflip.domain.entity;
+
+import org.locationtech.jts.geom.Point;
+
+import com.m3pro.groundflip.domain.entity.global.BaseTimeEntity;
+import com.m3pro.groundflip.enums.RegionLevel;
+
+import jakarta.persistence.Column;
+import jakarta.persistence.Entity;
+import jakarta.persistence.EnumType;
+import jakarta.persistence.Enumerated;
+import jakarta.persistence.GeneratedValue;
+import jakarta.persistence.GenerationType;
+import jakarta.persistence.Id;
+import lombok.AccessLevel;
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+
+@Getter
+@Entity
+@NoArgsConstructor(access = AccessLevel.PROTECTED)
+@AllArgsConstructor
+@Builder
+public class Region extends BaseTimeEntity {
+	@Id
+	@GeneratedValue(strategy = GenerationType.IDENTITY)
+	@Column(name = "region_id")
+	private Long id;
+
+	private String name;
+
+	private Long parentId;
+
+	@Column(columnDefinition = "POINT SRID 4326 NOT NULL")
+	private Point coordinate;
+
+	@Enumerated(EnumType.STRING)
+	private RegionLevel regionLevel;
+}

src/main/java/com/m3pro/groundflip/domain/entity/UserRegionCount.java

@@ -0,0 +1,43 @@
+package com.m3pro.groundflip.domain.entity;
+
+import com.m3pro.groundflip.domain.entity.global.BaseTimeEntity;
+
+import jakarta.persistence.Column;
+import jakarta.persistence.Entity;
+import jakarta.persistence.FetchType;
+import jakarta.persistence.GeneratedValue;
+import jakarta.persistence.GenerationType;
+import jakarta.persistence.Id;
+import jakarta.persistence.JoinColumn;
+import jakarta.persistence.ManyToOne;
+import lombok.AccessLevel;
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+
+@Getter
+@Entity
+@NoArgsConstructor(access = AccessLevel.PROTECTED)
+@AllArgsConstructor
+@Builder
+public class UserRegionCount extends BaseTimeEntity {
+	@Id
+	@GeneratedValue(strategy = GenerationType.IDENTITY)
+	@Column(name = "user_region_count_id")
+	private Long id;
+
+	private Integer count;
+
+	@ManyToOne(fetch = FetchType.LAZY)
+	@JoinColumn(name = "user_id")
+	private User user;
+
+	@ManyToOne(fetch = FetchType.LAZY)
+	@JoinColumn(name = "region_id")
+	private Region region;
+
+	public void increaseCount() {
+		this.count++;
+	}
+}

src/main/java/com/m3pro/groundflip/enums/RegionLevel.java

@@ -0,0 +1,13 @@
+package com.m3pro.groundflip.enums;
+
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+
+@AllArgsConstructor
+@Getter
+public enum RegionLevel {
+	CITY("city"),
+	PROVINCE("PROVINCE");
+
+	private final String level;
+}

src/main/java/com/m3pro/groundflip/repository/CompetitionCountRepository.java

@@ -0,0 +1,19 @@
+package com.m3pro.groundflip.repository;
+
+import java.util.Optional;
+
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.Query;
+import org.springframework.data.repository.query.Param;
+
+import com.m3pro.groundflip.domain.entity.CompetitionCount;
+import com.m3pro.groundflip.domain.entity.Region;
+
+public interface CompetitionCountRepository extends JpaRepository<CompetitionCount, Long> {
+	@Query("SELECT c FROM CompetitionCount c WHERE c.region = :id AND c.week = :week AND c.year = :year")
+	Optional<CompetitionCount> findByRegion(
+		@Param("id") Region region,
+		@Param("week") int week,
+		@Param("year") int year
+	);
+}