Merge pull request #152 from swyp-app-team-4/feat#151-point-eligibility

[Feat] 사용자 혼잡도 공유 시 포인트 획득 분기 처리 기능 구현

Author: KOKEONHO

src/main/java/boombimapi/domain/congestion/application/MemberCongestionService.java

@@ -13,7 +13,10 @@
 import boombimapi.domain.place.command.entity.MemberPlace;
 import boombimapi.domain.place.command.repository.MemberPlaceRepository;
 import boombimapi.domain.point.application.PointService;
+import boombimapi.domain.point.infrastructure.repository.MemberPointGrantRepository;
+import boombimapi.global.geo.GeoDistance;
 import boombimapi.global.infra.exception.error.BoombimException;
+import java.util.Set;
 import lombok.RequiredArgsConstructor;
 import org.springframework.stereotype.Service;
 
@@ -25,6 +28,7 @@ public class MemberCongestionService {
     private final MemberPlaceRepository memberPlaceRepository;
     private final MemberCongestionRepository memberCongestionRepository;
     private final CongestionLevelRepository congestionLevelRepository;
+    private final MemberPointGrantRepository memberPointGrantRepository;
     private final PointService pointService;
 
     public CreateMemberCongestionResponse createMemberCongestion(
@@ -46,7 +50,11 @@ public CreateMemberCongestionResponse createMemberCongestion(
             congestionMessage = congestionLevel.getMessage();
         }
 
-        pointService.earnPointForCongestion(member, 10L);
+        boolean pointReceivable = checkPointReceivable(memberId, request.latitude(), request.longitude());
+
+        if (pointReceivable) {
+            pointService.earnPointForCongestion(member, 10L);
+        }
 
         MemberCongestion memberCongestion = MemberCongestion.of(
             member,
@@ -58,7 +66,55 @@ public CreateMemberCongestionResponse createMemberCongestion(
         );
 
         return CreateMemberCongestionResponse
-            .from(memberCongestionRepository.save(memberCongestion));
+            .of(memberCongestionRepository.save(memberCongestion), pointReceivable);
     }
 
+    private boolean checkPointReceivable(
+        String memberId,
+        double latitude,
+        double longitude
+    ) {
+        final int DAILY_LIMIT = 5;
+        final long WINDOW_MS = 3_600_000L;
+
+        int todayCount = memberPointGrantRepository.getTodayCount(memberId);
+        if (todayCount >= DAILY_LIMIT) {
+            return false;
+        }
+
+        long currentTimeMillis = System.currentTimeMillis();
+
+        memberPointGrantRepository.removeStaledKeys(
+            memberId,
+            currentTimeMillis,
+            WINDOW_MS
+        );
+
+        Set<String> recentCoordinates = memberPointGrantRepository.rangeByScore(
+            memberId,
+            currentTimeMillis - WINDOW_MS,
+            currentTimeMillis
+        );
+
+        for (String coordinate : recentCoordinates) {
+            int commaIndex = coordinate.indexOf(',');
+            double prevLat = Double.parseDouble(coordinate.substring(0, commaIndex));
+            double prevLon = Double.parseDouble(coordinate.substring(commaIndex + 1));
+            double distance = GeoDistance.haversineMeters(latitude, longitude, prevLat, prevLon);
+            if (distance <= 300.0) {
+                return false;
+            }
+        }
+
+        memberPointGrantRepository.addRecentCoordinate(
+            memberId,
+            latitude,
+            longitude,
+            currentTimeMillis
+        );
+
+        memberPointGrantRepository.incrementToday(memberId);
+
+        return true;
+    }
 }

src/main/java/boombimapi/domain/congestion/dto/response/CreateMemberCongestionResponse.java

@@ -4,15 +4,18 @@
 
 public record CreateMemberCongestionResponse(
     Long memberCongestionId,
-    String memberPlaceName
+    String memberPlaceName,
+    boolean pointReceived
 ) {
 
-    public static CreateMemberCongestionResponse from(
-        MemberCongestion memberCongestion
+    public static CreateMemberCongestionResponse of(
+        MemberCongestion memberCongestion,
+        boolean pointReceived
     ) {
         return new CreateMemberCongestionResponse(
             memberCongestion.getId(),
-            memberCongestion.getMemberPlace().getName()
+            memberCongestion.getMemberPlace().getName(),
+            pointReceived
         );
     }
 

src/main/java/boombimapi/domain/point/infrastructure/repository/MemberPointGrantRepository.java

@@ -0,0 +1,102 @@
+package boombimapi.domain.point.infrastructure.repository;
+
+import java.time.LocalDate;
+import java.time.ZoneId;
+import java.time.format.DateTimeFormatter;
+import java.util.Locale;
+import java.util.Set;
+import java.util.concurrent.TimeUnit;
+import lombok.RequiredArgsConstructor;
+import org.springframework.data.redis.core.StringRedisTemplate;
+import org.springframework.stereotype.Repository;
+
+@Repository
+@RequiredArgsConstructor
+public class MemberPointGrantRepository {
+
+    private final StringRedisTemplate redisTemplate;
+
+    private static final String RECENT_KEY_PREFIX = "point:recent:";
+    private static final String DAILY_KEY_PREFIX = "point:daily:";
+
+    private static final ZoneId KST = ZoneId.of("Asia/Seoul");
+    private static final DateTimeFormatter DAY_FORMAT = DateTimeFormatter.BASIC_ISO_DATE;
+
+    public void removeStaledKeys(
+        String memberId,
+        long currentMs,
+        long windowMs
+    ) {
+        redisTemplate.opsForZSet().removeRangeByScore(
+            RECENT_KEY_PREFIX + memberId,
+            0,
+            currentMs - windowMs
+        );
+    }
+
+    public Set<String> rangeByScore(
+        String memberId,
+        long fromMs,
+        long toMs
+    ) {
+        return redisTemplate.opsForZSet().rangeByScore(
+            RECENT_KEY_PREFIX + memberId,
+            fromMs,
+            toMs
+        );
+    }
+
+    public void addRecentCoordinate(
+        String memberId,
+        double latitude,
+        double longitude,
+        long currentMs
+    ) {
+        String key = RECENT_KEY_PREFIX + memberId;
+        String memberCoordinate = String.format(
+            Locale.ROOT,
+            "%.15f,%.15f",
+            latitude,
+            longitude
+        );
+
+        redisTemplate.opsForZSet().add(key, memberCoordinate, currentMs);
+        redisTemplate.expire(key, 2, TimeUnit.HOURS);
+    }
+
+    public int getTodayCount(
+        String memberId
+    ) {
+        String key = todayKey(memberId);
+        String value = redisTemplate.opsForValue().get(key);
+
+        if (value == null) {
+            return 0;
+        }
+        return Integer.parseInt(value);
+    }
+
+    public void incrementToday(
+        String memberId
+    ) {
+        String key = todayKey(memberId);
+        Long after = redisTemplate.opsForValue().increment(key);
+
+        if (after == null) {
+            return;
+        }
+
+        if (after == 1L) {
+            redisTemplate.expire(key, 3, TimeUnit.DAYS);
+        }
+
+    }
+
+    private String todayKey(
+        String memberId
+    ) {
+        String date = LocalDate.now(KST).format(DAY_FORMAT);
+        return DAILY_KEY_PREFIX + memberId + ":" + date;
+    }
+
+}