Merge pull request #125 from swyp-app-team-4/feat#124-add-naver-static-map-image

[Feat] 사용자 장소 Resolve 시 정적 지도(Static Map) 썸네일 자동 생성 및 저장

Author: KOKEONHO

src/main/java/boombimapi/domain/place/command/api/dto/request/ResolveMemberPlaceRequest.java

@@ -5,25 +5,22 @@ public record ResolveMemberPlaceRequest(
     String name,
     String address,
     Double latitude,
-    Double longitude,
-    String imageUrl
+    Double longitude
 ) {
 
     public static ResolveMemberPlaceRequest of(
         String uuid,
         String name,
         String address,
         Double latitude,
-        Double longitude,
-        String imageUrl
-    ) {
+        Double longitude
+        ) {
         return new ResolveMemberPlaceRequest(
             uuid,
             name,
             address,
             latitude,
-            longitude,
-            imageUrl
+            longitude
         );
     }
 }

src/main/java/boombimapi/domain/place/command/entity/MemberPlace.java

@@ -52,32 +52,28 @@ private MemberPlace(
         String name,
         String address,
         Double latitude,
-        Double longitude,
-        String imageUrl
+        Double longitude
     ) {
         this.uuid = uuid;
         this.name = name;
         this.address = address;
         this.latitude = latitude;
         this.longitude = longitude;
-        this.imageUrl = imageUrl;
     }
 
     public static MemberPlace of(
         String uuid,
         String name,
         String address,
         Double latitude,
-        Double longitude,
-        String imageUrl
+        Double longitude
     ) {
         return MemberPlace.builder()
             .uuid(uuid)
             .name(name)
             .address(address)
             .latitude(latitude)
             .longitude(longitude)
-            .imageUrl(imageUrl)
             .build();
     }
 

src/main/java/boombimapi/domain/place/command/infrastructure/NaverStaticMapWebClient.java

@@ -0,0 +1,52 @@
+package boombimapi.domain.place.command.infrastructure;
+
+import boombimapi.global.properties.StaticMapProperties;
+import org.springframework.beans.factory.annotation.Qualifier;
+import org.springframework.http.HttpStatusCode;
+import org.springframework.stereotype.Component;
+import org.springframework.web.reactive.function.client.WebClient;
+import reactor.core.publisher.Mono;
+
+@Component
+public class NaverStaticMapWebClient {
+
+    private final WebClient webClient;
+    private final StaticMapProperties properties;
+
+    public NaverStaticMapWebClient(
+        @Qualifier("naverStaticMapHttpClient") WebClient webClient,
+        StaticMapProperties properties
+    ) {
+        this.webClient = webClient;
+        this.properties = properties;
+    }
+
+    public byte[] fetchStaticMapImage(
+        double latitude,
+        double longitude
+    ) {
+        String center = longitude + "," + latitude;
+        String markers = properties.markerStyle()
+            + "|pos:" + longitude + " " + latitude
+            + "|viewSizeRatio:" + properties.viewSizeRatio();
+
+        return webClient.get()
+            .uri(uriBuilder -> uriBuilder.path("/map-static/v2/raster")
+                .queryParam("w", properties.width())
+                .queryParam("h", properties.height())
+                .queryParam("level", properties.level())
+                .queryParam("scale", properties.scale())
+                .queryParam("center", center)
+                .queryParam("markers", markers)
+                .build())
+            .retrieve()
+            .onStatus(HttpStatusCode::isError, res ->
+                res.bodyToMono(String.class)
+                    .flatMap(error -> Mono.error(new RuntimeException(
+                        "Naver StaticMap error: " + res.statusCode() + " / " + error))))
+            .bodyToMono(byte[].class)
+            .block();
+
+    }
+
+}

src/main/java/boombimapi/domain/place/command/repository/MemberPlaceRepository.java

@@ -7,7 +7,9 @@
 import boombimapi.domain.search.presentation.dto.PlaceNameProjection;
 import org.springframework.data.domain.Pageable;
 import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.Modifying;
 import org.springframework.data.jpa.repository.Query;
+import org.springframework.data.repository.query.Param;
 
 public interface MemberPlaceRepository extends JpaRepository<MemberPlace, Long> {
 
@@ -22,18 +24,26 @@ List<MemberPlace> findByLatitudeBetweenAndLongitudeBetween(
 
     // 연관 검색
     @Query("""
-    select p.name as name
-    from MemberPlace p
-    where lower(p.name) like lower(concat('%', ?1, '%'))
-    order by lower(p.name) asc
-""")
+            select p.name as name
+            from MemberPlace p
+            where lower(p.name) like lower(concat('%', ?1, '%'))
+            order by lower(p.name) asc
+        """)
     List<PlaceNameProjection> searchByName(String keyword, Pageable pageable);
 
 
-
     // 검색 결과
     List<MemberPlace> findEntitiesByNameContainingIgnoreCase(String keyword, Pageable pageable);
 
-
-
+    @Modifying(clearAutomatically = true, flushAutomatically = true)
+    @Query(value = """
+        UPDATE member_places
+           SET image_url = :imageUrl,
+               updated_at = NOW()
+         WHERE id = :memberPlaceId
+        """, nativeQuery = true)
+    void updateImageUrl(
+        @Param("memberPlaceId") Long memberPlaceId,
+        @Param("imageUrl") String imageUrl
+    );
 }

src/main/java/boombimapi/domain/place/command/service/MemberPlaceService.java

@@ -10,6 +10,7 @@
 import boombimapi.domain.member.domain.entity.Member;
 import boombimapi.domain.member.domain.repository.MemberRepository;
 import boombimapi.domain.place.command.api.dto.request.ResolveMemberPlaceRequest;
+import boombimapi.domain.place.command.infrastructure.NaverStaticMapWebClient;
 import boombimapi.domain.place.query.api.dto.request.ViewportRequest;
 import boombimapi.domain.place.query.api.dto.response.member.GetMemberPlaceDetailResponse;
 import boombimapi.domain.place.query.api.dto.response.member.MemberPlaceSummaryResponse;
@@ -19,6 +20,7 @@
 import boombimapi.domain.place.query.api.dto.response.node.ViewportPlaceNodeResponse;
 import boombimapi.domain.place.command.entity.MemberPlace;
 import boombimapi.domain.place.command.repository.MemberPlaceRepository;
+import boombimapi.global.infra.s3.presentation.application.S3Service;
 import boombimapi.global.vo.Coordinate;
 import boombimapi.global.geo.core.ClusterMarker;
 import boombimapi.global.geo.core.ClusterPoint;
@@ -39,6 +41,7 @@
 import org.springframework.data.domain.Pageable;
 import org.springframework.data.domain.Slice;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
 
 @Slf4j
 @Service
@@ -52,24 +55,40 @@ public class MemberPlaceService {
     private final Clusterer clusterer;
     private final FavoriteRepository favoriteRepository;
 
+    private final NaverStaticMapWebClient naverStaticMapWebClient;
+    private final S3Service s3Service;
+
+    // TODO: 추후 트랜잭션 분리 시 리팩터링
+    @Transactional
     public ResolveMemberPlaceResponse resolveMemberPlace(
         ResolveMemberPlaceRequest request
     ) {
+        Optional<MemberPlace> memberPlaceOptional = memberPlaceRepository.findByUuid(request.uuid());
+
+        if (memberPlaceOptional.isPresent()) {
+            return ResolveMemberPlaceResponse.from(memberPlaceOptional.get());
+        }
+
+        MemberPlace created = memberPlaceRepository.save(
+            MemberPlace.of(
+                request.uuid(),
+                request.name(),
+                request.address(),
+                request.latitude(),
+                request.longitude()
+            )
+        );
+
+        try {
+            byte[] bytes = naverStaticMapWebClient.fetchStaticMapImage(request.latitude(), request.longitude());
+            String key = "maps/naver/static-map/%d.png".formatted(created.getId());
+            String url = s3Service.storeStaticMapImage(key, bytes, "image/png");
+            memberPlaceRepository.updateImageUrl(created.getId(), url);
+        } catch (Exception e) {
+            log.warn("Static map generation failed. placeId={}, err={}", created.getId(), e.toString());
+        }
 
-        // TODO: 레이스 컨디션 처리 필요(동일 uuid 동시 생성 방지)
-        MemberPlace memberPlace = memberPlaceRepository.findByUuid(request.uuid())
-            .orElseGet(() -> memberPlaceRepository.save(
-                MemberPlace.of(
-                    request.uuid(),
-                    request.name(),
-                    request.address(),
-                    request.latitude(),
-                    request.longitude(),
-                    request.imageUrl()
-                )
-            ));
-
-        return ResolveMemberPlaceResponse.from(memberPlace);
+        return ResolveMemberPlaceResponse.from(created);
     }
 
     public GetMemberPlaceDetailResponse getMemberPlaceDetail(