Update api_utils.py

api_utils.py

@@ -83,22 +83,49 @@ def api_get_tide_level(
     
     try:
         # 대상 시간 파싱
+        kst = pytz.timezone('Asia/Seoul')
         if target_time:
             query_time = datetime.fromisoformat(target_time.replace('Z', '+00:00'))
+            if query_time.tzinfo is None:
+                query_time = kst.localize(query_time)
         else:
-            query_time = datetime.now(pytz.timezone('Asia/Seoul'))
+            query_time = datetime.now(kst)
+        
+        # UTC로 변환하여 쿼리 (중요!)
+        query_time_utc = query_time.astimezone(pytz.UTC)
+        query_str = query_time_utc.strftime('%Y-%m-%dT%H:%M:%S')
         
-        query_str = query_time.strftime('%Y-%m-%dT%H:%M:%S')
+        # 가장 가까운 5분 단위로 반올림
+        minutes = query_time.minute
+        rounded_minutes = round(minutes / 5) * 5
+        if rounded_minutes == 60:
+            query_time_rounded = query_time.replace(minute=0, second=0, microsecond=0) + timedelta(hours=1)
+        else:
+            query_time_rounded = query_time.replace(minute=rounded_minutes, second=0, microsecond=0)
         
-        # 1차: 최종 예측 (tide_predictions) 조회
+        query_time_rounded_utc = query_time_rounded.astimezone(pytz.UTC)
+        
+        # 1차: 정확한 시간 매칭 시도
         result = supabase.table('tide_predictions')\
             .select('*')\
             .eq('station_id', station_id)\
-            .gte('predicted_at', query_str)\
-            .order('predicted_at')\
-            .limit(1)\
+            .eq('predicted_at', query_time_rounded_utc.strftime('%Y-%m-%dT%H:%M:%S'))\
             .execute()
         
+        # 2차: 정확한 매칭이 없으면 전후 5분 범위에서 가장 가까운 것
+        if not result.data:
+            start_time = (query_time_rounded_utc - timedelta(minutes=5)).strftime('%Y-%m-%dT%H:%M:%S')
+            end_time = (query_time_rounded_utc + timedelta(minutes=5)).strftime('%Y-%m-%dT%H:%M:%S')
+            
+            result = supabase.table('tide_predictions')\
+                .select('*')\
+                .eq('station_id', station_id)\
+                .gte('predicted_at', start_time)\
+                .lte('predicted_at', end_time)\
+                .order('predicted_at')\
+                .limit(1)\
+                .execute()
+        
         if result.data:
             # 최종 예측 데이터가 있는 경우
             data = result.data[0]
@@ -121,15 +148,28 @@ def api_get_tide_level(
             )
         
         # 2차: 조화 예측 (harmonic_predictions) 폴백
-        if use_harmonic_fallback:
+        if use_harmonic_fallback and not result.data:
+            # 1차: 정확한 시간 매칭 시도
             result = supabase.table('harmonic_predictions')\
                 .select('*')\
                 .eq('station_id', station_id)\
-                .gte('predicted_at', query_str)\
-                .order('predicted_at')\
-                .limit(1)\
+                .eq('predicted_at', query_time_rounded_utc.strftime('%Y-%m-%dT%H:%M:%S'))\
                 .execute()
             
+            # 2차: 정확한 매칭이 없으면 전후 5분 범위
+            if not result.data:
+                start_time = (query_time_rounded_utc - timedelta(minutes=5)).strftime('%Y-%m-%dT%H:%M:%S')
+                end_time = (query_time_rounded_utc + timedelta(minutes=5)).strftime('%Y-%m-%dT%H:%M:%S')
+                
+                result = supabase.table('harmonic_predictions')\
+                    .select('*')\
+                    .eq('station_id', station_id)\
+                    .gte('predicted_at', start_time)\
+                    .lte('predicted_at', end_time)\
+                    .order('predicted_at')\
+                    .limit(1)\
+                    .execute()
+            
             if result.data:
                 data = result.data[0]
                 # UTC를 KST로 변환
@@ -146,7 +186,9 @@ def api_get_tide_level(
                         "harmonic_value": round(data.get('harmonic_level', 0), 1),
                         "data_source": "harmonic_only",
                         "confidence": "medium",
-                        "note": "잔차 예측이 없어 조화 예측만 제공됩니다"
+                        "note": "잔차 예측이 없어 조화 예측만 제공됩니다",
+                        "query_time": query_time.strftime('%Y-%m-%d %H:%M:%S KST'),
+                        "matched_time_diff_seconds": abs((time_utc - query_time_utc).total_seconds())
                     },
                     meta=get_station_meta(station_id)
                 )