[Feat] 위치기반 리마인드 알림 시 해당 일기와 해당 일기 기준 반경 500m 내의 일기들에 한달(30일) 쿨타임 부여

src/main/java/TtattaBackend/ttatta/domain/Diaries.java

@@ -87,6 +87,8 @@ public class Diaries extends BaseEntity {
     @Column(name = "enc_ver", nullable = false)
     private short encVer = 1;
 
+    @Column(nullable = false)
+    private int memoryDiaryAlarmCoolTime;
 
     public void setUsers(Users users) {
         // 기존에 이미 등록되어 있던 관계를 제거
@@ -122,4 +124,7 @@ public void updateContent(String content) {
         this.content = content;
     }
 
+    public void updateMemoryDiaryAlarmCoolTime(int memoryDiaryAlarmCoolTime) {
+        this.memoryDiaryAlarmCoolTime = memoryDiaryAlarmCoolTime;
+    }
 }

src/main/java/TtattaBackend/ttatta/repository/DiaryRepository.java

@@ -6,6 +6,7 @@
 import org.springframework.data.domain.Page;
 import org.springframework.data.domain.PageRequest;
 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;
 import org.springframework.security.core.parameters.P;
@@ -170,11 +171,16 @@ WHERE ST_Contains(
           d.location
         )
         AND d.user_id = :userId
+        AND d.memory_diary_alarm_cool_time = 0
         """, nativeQuery = true)
     List<Diaries> findNearDiariesCandidates(
             @Param("wkt") String wkt,
             @Param("userId") Long userId
     );
 
     List<Diaries> findAllByCreatedAtBetween(LocalDateTime startDateTime, LocalDateTime endDateTime);
+
+    @Modifying
+    @Query("UPDATE Diaries d SET d.memoryDiaryAlarmCoolTime = d.memoryDiaryAlarmCoolTime - 1 WHERE d.memoryDiaryAlarmCoolTime > 0")
+    void decreaseCoolTimeOnMemoryDiaries();
 }

src/main/java/TtattaBackend/ttatta/service/AlarmService/AlarmCommandServiceImpl.java

@@ -416,4 +416,11 @@ public AlarmResponseDTO.GetAllAlarmsResponseDTO getAllAlarms() {
                 getDailySummaryAlarm
         );
     }
+
+    // 매일 자정에 위치기반 알림 쿨타임 차감 on 알림들 예약하는 메소드 실행
+    @Scheduled(cron = "0 0 0 * * *", zone = "Asia/Seoul")
+    @Transactional
+    public void decreaseMemoryDiaryAlarmCoolTime() {
+        diaryRepository.decreaseCoolTimeOnMemoryDiaries();
+    }
 }

src/main/java/TtattaBackend/ttatta/service/DiaryService/DiaryQueryServiceImpl.java

@@ -17,6 +17,7 @@
 import TtattaBackend.ttatta.security.EnvelopeCryptoService;
 import TtattaBackend.ttatta.web.dto.DiaryRequestDTO;
 import TtattaBackend.ttatta.web.dto.DiaryResponseDTO;
+import jakarta.transaction.Transactional;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.locationtech.jts.geom.Coordinate;
@@ -52,6 +53,7 @@ public class DiaryQueryServiceImpl implements DiaryQueryService{
     private static final int SEARCH_RANGE = 100;    // 검색 범위 설정 (100m)
     private final GeometryFactory geometryFactory;
     private final EnvelopeCryptoService envelopeCryptoService;
+    private static final int MEMORY_DIARY_COOL_TIME_AREA_RANGE = 500;    // 검색 범위 설정 (100m)
 
     @Override
     public DiaryResponseDTO.FootprintDiaryListDTO getFootprintDiaryList(Long diaryCategoryId, DiaryRequestDTO.ViewOnMapDTO request){
@@ -269,6 +271,7 @@ public List<LocalDateTime> getDiaryDateList() {
     }
 
     @Override
+    @Transactional
     public void findRemindDiary(DiaryRequestDTO.RemindDTO request) {
         Long userId = SecurityUtil.getCurrentUserId();
         Users user = userRepository.findById(userId).orElseThrow(
@@ -310,6 +313,8 @@ public void findRemindDiary(DiaryRequestDTO.RemindDTO request) {
                 ));
         System.out.println("nearestDiaries real Candidates: " + nearestDiary.get().getId());
 
+        // 반환한 일기(nearestDiary) 주변 500m반경 내의 일기들의 위치기반 추억 알림 쿨타임을 한달(30일)로 설정
+        setMemoryDiaryAlarmCoolTime(userId, nearestDiary.get(), 30);
 
         // 시간 계산
         long days = ChronoUnit.DAYS.between(nearestDiary.get().getDate().toLocalDate(), LocalDate.now());
@@ -331,6 +336,37 @@ public void findRemindDiary(DiaryRequestDTO.RemindDTO request) {
         alarmCommandService.sendMemoryDiaryAlarm(user, timeMessage, nearestDiary.get().getId());
     }
 
+    private void setMemoryDiaryAlarmCoolTime(Long userId, Diaries currentDiary, int coolTime) {
+        // 1. 일기 주변 500m 반경 내 일기들 조회
+        Decoded decoded = tryDecode(currentDiary, userId);
+        Double currentLatitude = decoded.lat();
+        Double currentLongitude = decoded.lng();
+        List<Pt> square = buildSquare(currentLatitude, currentLongitude, 600.0);
+        String wkt = toPolygonWKT(square);
+        List<Diaries> nearDiariesCandidates = diaryRepository.findNearDiariesCandidates(wkt, userId);
+        // 서버 로그에서 확인하기 위함
+        for (Diaries diary : nearDiariesCandidates) {
+            System.out.println("nearDiariesCandidates id: " + diary.getId());
+        }
+
+        if (nearDiariesCandidates.isEmpty()) {    // 검색 범위 내에 일기가 없는 경우
+            return;
+        }
+
+        // 검색 범위(정사각형) 내 복호화를 진행하고, 실제로 일기 위도 경도에서 100m 원 안에 있는 일기 중 가장 최신 일기 반환
+        // 영 이상하면 getDate -> getCreatedAt으로 수정 (마지막줄)
+        List<Diaries> nearestDiary = nearDiariesCandidates
+                .parallelStream()
+                .map(d -> tryDecode(d, userId))   // Decoded(diaries, lat, lng, ok)
+                .filter(Decoded::ok)
+                .filter(dd -> haversineMeters(currentLatitude, currentLongitude, dd.lat(), dd.lng()) <= MEMORY_DIARY_COOL_TIME_AREA_RANGE)
+                .map(Decoded::diary)
+                .toList();
+
+        // 2. 각 엔티티 값 수정 -> 트랜잭션 커밋 때 DB에 UPDATE됨(Managed라면)
+        nearestDiary.forEach(d -> d.updateMemoryDiaryAlarmCoolTime(coolTime));
+    }
+
     @Override
     public List<String> getPresignedForPost(String imageType) {
         Long userId = SecurityUtil.getCurrentUserId();