[#15] 지역 인증 기능, 주변 지역 찾기 기능 구현

build.gradle

@@ -25,10 +25,15 @@ dependencies {
     implementation 'io.jsonwebtoken:jjwt-impl:0.11.5'
     implementation 'io.jsonwebtoken:jjwt-jackson:0.11.5'
 
+    implementation 'org.locationtech.jts:jts-core:1.19.0'
+
+    implementation 'org.springframework.retry:spring-retry'
+
     compileOnly 'org.projectlombok:lombok'
     annotationProcessor 'org.projectlombok:lombok'
 
     testImplementation 'org.springframework.boot:spring-boot-starter-test'
+    testImplementation 'org.locationtech.proj4j:proj4j:1.2.3'
 }
 
 tasks.named('test') {

src/main/java/com/directors/DirectorsApplication.java

@@ -2,12 +2,14 @@
 
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.retry.annotation.EnableRetry;
 
 @SpringBootApplication
+@EnableRetry
 public class DirectorsApplication {
 
-	public static void main(String[] args) {
-		SpringApplication.run(DirectorsApplication.class, args);
-	}
-	
+    public static void main(String[] args) {
+        SpringApplication.run(DirectorsApplication.class, args);
+    }
+
 }

src/main/java/com/directors/application/region/RegionService.java

@@ -0,0 +1,81 @@
+package com.directors.application.region;
+
+import com.directors.domain.region.Region;
+import com.directors.domain.region.RegionRepository;
+import com.directors.domain.user.UserRegion;
+import com.directors.domain.user.UserRegionRepository;
+import jakarta.annotation.PostConstruct;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.locationtech.jts.geom.Coordinate;
+import org.locationtech.jts.geom.GeometryFactory;
+import org.locationtech.jts.geom.Point;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.io.BufferedReader;
+import java.io.InputStream;
+import java.io.InputStreamReader;
+import java.util.List;
+import java.util.stream.Collectors;
+
+@Service
+@RequiredArgsConstructor
+@Slf4j
+public class RegionService {
+
+    private final RegionRepository regionRepository;
+    private final UserRegionRepository userRegionRepository;
+
+    @PostConstruct
+    private void loadRegionData() {
+        String pathPrefix = "/regionCSV/";
+        String pathSuffix = "_좌표.csv";
+        String[] regions = {
+                "강원", "경기", "경남", "경북", "광주", "대구", "대전", "부산", "서울", "세종", "울산", "인천", "전남", "전북", "제주", "충남", "충북"
+        };
+
+        for (int i = 0; i < regions.length; i++) {
+            List<String> regionDataLines = null;
+
+            var inputStream = getClass().getResourceAsStream(pathPrefix + regions[i] + pathSuffix);
+            var reader = new BufferedReader(new InputStreamReader(inputStream));
+            regionDataLines = reader.lines().collect(Collectors.toList());
+
+            var collect = regionDataLines.stream()
+                    .map(this::regionDataLineToRegion)
+                    .collect(Collectors.toList());
+
+            regionRepository.saveAll(collect);
+        }
+    }
+
+    @Transactional
+    public List<String> getNearestAddress(String userId, int distance) {
+        var userRegion = userRegionRepository
+                .findByUserId(userId)
+                .orElseThrow(() -> new RuntimeException()); // TODO: 04.05 먼저 지역 인증이 필요하다는 예외가 필요.
+        var region = regionRepository.findByRegionId(userRegion.getRegionId()).orElseThrow();
+
+        return getNearestRegion(region, distance)
+                .stream()
+                .map(reg -> reg.getAddress().unitAddress())
+                .collect(Collectors.toList());
+    }
+
+    private Region regionDataLineToRegion(String regionLine) {
+        String[] lineSplit = regionLine.split(",");
+        return Region.of(lineSplit[0], lineSplit[1], coordinateToPoint(lineSplit[2], lineSplit[3]));
+    }
+
+    private Point coordinateToPoint(String longitude, String latitude) {
+        double lon = Double.parseDouble(longitude);
+        double lat = Double.parseDouble(latitude);
+        return new GeometryFactory().createPoint(new Coordinate(lon, lat));
+    }
+
+    private List<Region> getNearestRegion(Region region, int distance) {
+        List<Region> regionWithin = regionRepository.findRegionWithin(region, distance * 1000);
+        return regionWithin;
+    }
+}

src/main/java/com/directors/application/field/SpecialtyService.java → src/main/java/com/directors/application/specialty/SpecialtyService.java

@@ -1,9 +1,10 @@
-package com.directors.application.field;
+package com.directors.application.specialty;
 
 import com.directors.domain.specialty.Specialty;
 import com.directors.domain.specialty.SpecialtyRepository;
 import lombok.RequiredArgsConstructor;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
 
 import java.util.NoSuchElementException;
 import java.util.Optional;
@@ -14,20 +15,23 @@ public class SpecialtyService {
 
     private final SpecialtyRepository specialtyRepository;
 
+    @Transactional
     public void createSpecialty(Specialty specialty, String userIdByToken) {
         specialty.setUserId(userIdByToken);
         specialtyRepository.saveSpecialty(specialty);
     }
 
+    @Transactional
     public void updateSpecialty(Specialty requestSpecialty) {
-        Optional<Specialty> specialtyByFieldId = specialtyRepository.findSpecialtyByFieldId(requestSpecialty.getId());
-        Specialty specialty = specialtyByFieldId.orElseThrow(() -> new NoSuchElementException());
+        var specialtyByFieldId = specialtyRepository.findSpecialtyByFieldId(requestSpecialty.getId());
+        var specialty = specialtyByFieldId.orElseThrow(() -> new NoSuchElementException());
 
         specialty.updateSpecialtyInfo(requestSpecialty.getProperty(), requestSpecialty.getDescription());
 
         specialtyRepository.saveSpecialty(specialty);
     }
 
+    @Transactional
     public void deleteSpecialty(String specialty) {
         specialtyRepository.deleteSpecialty(specialty);
     }

src/main/java/com/directors/application/user/AuthenticateRegionService.java

@@ -0,0 +1,61 @@
+package com.directors.application.user;
+
+import com.directors.domain.region.Address;
+import com.directors.domain.region.Region;
+import com.directors.domain.region.RegionApiClient;
+import com.directors.domain.region.RegionRepository;
+import com.directors.domain.user.UserRegion;
+import com.directors.domain.user.UserRegionRepository;
+import com.directors.presentation.user.request.AuthenticateRegionRequest;
+import com.directors.presentation.user.response.AuthenticateRegionResponse;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.util.NoSuchElementException;
+
+@Service
+@RequiredArgsConstructor
+@Slf4j
+public class AuthenticateRegionService {
+    private final RegionApiClient regionApiClient;
+    private final RegionRepository regionRepository;
+    private final UserRegionRepository userRegionRepository;
+
+    @Transactional
+    public AuthenticateRegionResponse authenticate(AuthenticateRegionRequest request, String userId) {
+        var addressByApi = regionApiClient.findRegionAddressByLocation(request.latitude(), request.longitude());
+        var region = regionRepository.findByFullAddress(addressByApi.fullAddress())
+                .orElseThrow(() -> new NoSuchElementException());
+
+        var userAddress = updateUserRegionAddress(userId, region);
+
+        return new AuthenticateRegionResponse(userAddress.fullAddress(), userAddress.unitAddress());
+    }
+
+    private Address updateUserRegionAddress(String userId, Region region) {
+        if (userRegionRepository.existsByUserId(userId)) {
+            return updateExistUserRegion(userId, region).getAddress();
+        }
+        return saveUserRegion(userId, region).getAddress();
+    }
+
+    private UserRegion saveUserRegion(String userId, Region region) {
+        UserRegion savedUserRegion;
+        var newUserRegion = UserRegion.of(region.getAddress(), userId, region.getId());
+
+        savedUserRegion = userRegionRepository.save(newUserRegion);
+        return savedUserRegion;
+    }
+
+    private UserRegion updateExistUserRegion(String userId, Region region) {
+        var userRegion = userRegionRepository.findByUserId(userId).get();
+
+        userRegion.setAddress(region.getAddress());
+        userRegion.setRegionId(region.getId());
+
+        return userRegionRepository.save(userRegion);
+    }
+
+}

src/main/java/com/directors/domain/region/Address.java

@@ -0,0 +1,10 @@
+package com.directors.domain.region;
+
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+
+public record Address (
+        String fullAddress,
+        String unitAddress
+){
+}

src/main/java/com/directors/domain/region/Region.java

@@ -0,0 +1,28 @@
+package com.directors.domain.region;
+
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Getter;
+import org.locationtech.jts.geom.Point;
+
+@AllArgsConstructor
+@Getter
+@Builder
+public class Region {
+    private Long id;
+
+    private Address address;
+
+    private Point point;
+
+    public void setId(Long id) {
+        this.id = id;
+    }
+
+    public static Region of(String fullAddress, String unitAddress, Point point) {
+        return Region.builder()
+                .address(new Address(fullAddress, unitAddress))
+                .point(point)
+                .build();
+    }
+}

src/main/java/com/directors/domain/region/RegionApiClient.java

@@ -0,0 +1,5 @@
+package com.directors.domain.region;
+
+public interface RegionApiClient {
+    Address findRegionAddressByLocation(double latitude, double longitude);
+}

src/main/java/com/directors/domain/region/RegionRepository.java

@@ -0,0 +1,16 @@
+package com.directors.domain.region;
+
+import java.util.List;
+import java.util.Optional;
+
+public interface RegionRepository {
+    Optional<Region> findByFullAddress(String fullAddress);
+
+    Optional<Region> findByRegionId(Long regionId);
+
+    Region save(Region region);
+
+    void saveAll(List<Region> regions);
+
+    List<Region> findRegionWithin(Region region, double distance);
+}

src/main/java/com/directors/domain/user/UserRegion.java

@@ -0,0 +1,35 @@
+package com.directors.domain.user;
+
+import com.directors.domain.region.Address;
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Getter;
+
+@AllArgsConstructor
+@Builder
+@Getter
+public class UserRegion {
+    private String id;
+    private Address address;
+    private String userId;
+    private Long regionId;
+
+    public void setId(String id) {
+        this.id = id;
+    }
+    public void setRegionId(Long regionId) {
+        this.regionId = regionId;
+    }
+
+    public void setAddress(Address address) {
+        this.address = address;
+    }
+
+    public static UserRegion of(Address address, String userId, Long regionId) {
+        return UserRegion.builder()
+                .address(address)
+                .userId(userId)
+                .regionId(regionId)
+                .build();
+    }
+}

src/main/java/com/directors/domain/user/UserRegionRepository.java

@@ -0,0 +1,11 @@
+package com.directors.domain.user;
+
+import java.util.Optional;
+
+public interface UserRegionRepository {
+    Optional<UserRegion> findByUserId(String userId);
+
+    boolean existsByUserId(String userId);
+
+    UserRegion save(UserRegion userRegion);
+}

src/main/java/com/directors/infrastructure/api/ApiSender.java

@@ -0,0 +1,29 @@
+package com.directors.infrastructure.api;
+
+import org.springframework.core.ParameterizedTypeReference;
+import org.springframework.http.HttpEntity;
+import org.springframework.http.HttpHeaders;
+import org.springframework.http.HttpMethod;
+import org.springframework.http.ResponseEntity;
+import org.springframework.retry.annotation.Backoff;
+import org.springframework.retry.annotation.Retryable;
+import org.springframework.stereotype.Component;
+import org.springframework.web.client.HttpClientErrorException;
+import org.springframework.web.client.HttpServerErrorException;
+import org.springframework.web.client.RestTemplate;
+import org.springframework.web.util.UriComponents;
+
+import java.util.Map;
+
+@Component
+public class ApiSender {
+    @Retryable(retryFor = {HttpClientErrorException.class, HttpServerErrorException.class}, maxAttempts = 3, backoff = @Backoff(delay = 1000))
+    public ResponseEntity<Map<String, Object>> send(HttpMethod method, UriComponents uri) throws HttpClientErrorException, HttpServerErrorException {
+        RestTemplate restTemplate = new RestTemplate();
+        HttpHeaders header = new HttpHeaders();
+        HttpEntity<String> entity = new HttpEntity<>(header);
+
+        return restTemplate.exchange(uri.toString(), method, entity, new ParameterizedTypeReference<>() {
+        });
+    }
+}